Guoguo
c95d47e0c1
- Always sync treatment end (not just early stop), pass start/end times - treatment-done uses api.syncTreatment instead of raw http.post - Move getApp() from module level to onLoad in treatment-done - Avatar upload only returns URL, no longer updates profile directly - COS CDN domain configurable via COS_CDN_DOMAIN env var - Fix operator precedence in request.js token expiry check - Remove unused result variable from COS putObject
258 行
7.6 KiB
JavaScript
258 行
7.6 KiB
JavaScript
var ble = require('../../services/ble')
|
|
var api = require('../../utils/api')
|
|
var commandSync = require('../../services/command-sync')
|
|
var config = require('../../config/env')
|
|
|
|
Page({
|
|
data: {
|
|
statusBarHeight: 44,
|
|
regions: 0,
|
|
wavelength: 2,
|
|
duration: 600000,
|
|
mode: 0,
|
|
remainingMs: 600000,
|
|
remainingText: '10:00',
|
|
battery: 0,
|
|
temperature: 0,
|
|
progress: 0,
|
|
paused: false,
|
|
completed: false,
|
|
startedAt: 0,
|
|
devMode: false,
|
|
regionText: '全脸护理',
|
|
},
|
|
|
|
_getRegionText: function (regionMask) {
|
|
var REGION_MAP = {1:'左脸', 2:'右脸', 4:'额头', 8:'下巴', 16:'鼻', 32:'左眼', 64:'右眼'}
|
|
if (regionMask === 0x7F) return '全脸护理'
|
|
var names = []
|
|
for (var bit in REGION_MAP) {
|
|
if (regionMask & parseInt(bit)) names.push(REGION_MAP[bit])
|
|
}
|
|
return names.length > 0 ? names.join('+') + '护理' : '全脸护理'
|
|
},
|
|
|
|
onLoad: function (options) {
|
|
var app = getApp()
|
|
this.setData({ statusBarHeight: app.globalData.statusBarHeight, devMode: config.__DEV__ || false })
|
|
this._deviceId = ble.getDeviceId() || (app.globalData.currentDevice && app.globalData.currentDevice.device_id) || ''
|
|
var regions = parseInt(options.regions) || 0x7F
|
|
this.setData({
|
|
regions: regions,
|
|
wavelength: parseInt(options.wavelength) || 2,
|
|
duration: parseInt(options.duration) || 600000,
|
|
mode: parseInt(options.mode) || 0,
|
|
remainingMs: parseInt(options.duration) || 600000,
|
|
startedAt: Date.now(),
|
|
regionText: this._getRegionText(regions)
|
|
})
|
|
|
|
this._onStatus = this.onStatus.bind(this)
|
|
this._onComplete = this.onComplete.bind(this)
|
|
this._onException = this.onException.bind(this)
|
|
this._onDisconnect = this.onDisconnect.bind(this)
|
|
this._onReconnect = this.onReconnect.bind(this)
|
|
this._onReconnectFailed = this.onReconnectFailed.bind(this)
|
|
this._sessionId = 'SESS_' + Date.now()
|
|
|
|
ble.on('status', this._onStatus)
|
|
ble.on('treatment_complete', this._onComplete)
|
|
ble.on('exception', this._onException)
|
|
ble.on('disconnected', this._onDisconnect)
|
|
ble.on('reconnected', this._onReconnect)
|
|
ble.on('reconnect_failed', this._onReconnectFailed)
|
|
this.startLocalTimer()
|
|
this.syncCommands()
|
|
this.syncTreatmentStart()
|
|
},
|
|
|
|
onUnload: function () {
|
|
if (this._onStatus) ble.off('status', this._onStatus)
|
|
if (this._onComplete) ble.off('treatment_complete', this._onComplete)
|
|
if (this._onException) ble.off('exception', this._onException)
|
|
if (this._onDisconnect) ble.off('disconnected', this._onDisconnect)
|
|
if (this._onReconnect) ble.off('reconnected', this._onReconnect)
|
|
if (this._onReconnectFailed) ble.off('reconnect_failed', this._onReconnectFailed)
|
|
if (this._localTimer) clearInterval(this._localTimer)
|
|
},
|
|
|
|
startLocalTimer: function () {
|
|
var self = this
|
|
var timer = setInterval(function () {
|
|
if (self.data.completed || self.data.paused) return
|
|
var elapsed = Date.now() - self.data.startedAt
|
|
var remaining = Math.max(0, self.data.duration - elapsed)
|
|
self.updateProgress(remaining)
|
|
if (remaining <= 0) {
|
|
clearInterval(timer)
|
|
self.finishAsComplete()
|
|
}
|
|
}, 1000)
|
|
this._localTimer = timer
|
|
},
|
|
|
|
updateProgress: function (remaining) {
|
|
var total = this.data.duration
|
|
var progress = total > 0 ? Math.round(((total - remaining) / total) * 100) : 0
|
|
var mins = Math.floor(remaining / 60000)
|
|
var secs = Math.floor((remaining % 60000) / 1000)
|
|
this.setData({
|
|
remainingMs: remaining,
|
|
remainingText: ('0' + mins).slice(-2) + ':' + ('0' + secs).slice(-2),
|
|
progress: progress
|
|
})
|
|
},
|
|
|
|
onStatus: function (status) {
|
|
var remaining = status.remaining_ms || 0
|
|
this.updateProgress(remaining)
|
|
this.setData({
|
|
battery: status.battery,
|
|
temperature: status.temperature,
|
|
paused: status.mode_state === 0x03
|
|
})
|
|
this.syncCommands()
|
|
},
|
|
|
|
syncCommands: function () {
|
|
var app = getApp()
|
|
var device = app.globalData.currentDevice || {}
|
|
var deviceId = device.device_id || this.options.device_id
|
|
if (deviceId) commandSync.sync(deviceId)
|
|
},
|
|
|
|
syncTreatmentStart: function () {
|
|
var self = this
|
|
var startTime = new Date(self.data.startedAt)
|
|
var endTime = new Date(self.data.startedAt + self.data.duration)
|
|
api.syncTreatment({
|
|
session_id: self._sessionId,
|
|
device_id: self._deviceId || '',
|
|
start_time: startTime.toISOString(),
|
|
end_time: endTime.toISOString(),
|
|
regions: self.data.regions,
|
|
total_duration_ms: self.data.duration,
|
|
mode: self.data.mode,
|
|
avg_pd: 0,
|
|
source: 'treatment_start'
|
|
}).catch(function () {})
|
|
},
|
|
|
|
syncTreatmentEnd: function (elapsed) {
|
|
var self = this
|
|
var startTime = new Date(self.data.startedAt)
|
|
var endTime = new Date(self.data.startedAt + elapsed)
|
|
api.syncTreatment({
|
|
session_id: self._sessionId,
|
|
device_id: self._deviceId || '',
|
|
start_time: startTime.toISOString(),
|
|
end_time: endTime.toISOString(),
|
|
regions: self.data.regions,
|
|
total_duration_ms: elapsed,
|
|
mode: self.data.mode,
|
|
avg_pd: 0,
|
|
source: 'treatment_end'
|
|
}).catch(function () {})
|
|
},
|
|
|
|
onComplete: function (result) {
|
|
this.setData({ completed: true, progress: 100 })
|
|
var app = getApp()
|
|
app.globalData.currentTreatment = result
|
|
|
|
var self = this
|
|
setTimeout(function () {
|
|
wx.redirectTo({
|
|
url: '/pages/treatment-done/treatment-done?session_id=' + result.session_id +
|
|
'®ions=' + result.regions +
|
|
'&duration=' + result.total_duration_ms +
|
|
'&avg_pd=' + result.avg_pd +
|
|
'&mode=' + (self.data.mode || 0) +
|
|
'&device_id=' + encodeURIComponent(self._deviceId || '')
|
|
})
|
|
}, 1000)
|
|
},
|
|
|
|
finishAsComplete: function () {
|
|
var elapsed = Math.min(this.data.duration, Date.now() - this.data.startedAt)
|
|
this.syncTreatmentEnd(elapsed)
|
|
this.onComplete({
|
|
session_id: this._sessionId,
|
|
regions: this.data.regions,
|
|
total_duration_ms: elapsed,
|
|
avg_pd: 0,
|
|
start_time: new Date(this.data.startedAt).toISOString(),
|
|
end_time: new Date(this.data.startedAt + elapsed).toISOString(),
|
|
source: 'client_timer'
|
|
})
|
|
},
|
|
|
|
onException: function (err) {
|
|
wx.showModal({
|
|
title: '设备异常',
|
|
content: err.error_msg || '护理过程中出现异常',
|
|
showCancel: false,
|
|
complete: function () {
|
|
wx.navigateBack()
|
|
}
|
|
})
|
|
},
|
|
|
|
onDisconnect: function () {
|
|
this.setData({ paused: true })
|
|
wx.showToast({
|
|
title: '设备连接断开，正在重连...',
|
|
icon: 'none',
|
|
duration: 3000
|
|
})
|
|
},
|
|
|
|
onReconnect: function () {
|
|
this.setData({ paused: false })
|
|
wx.showToast({
|
|
title: '设备已重新连接',
|
|
icon: 'success',
|
|
duration: 2000
|
|
})
|
|
},
|
|
|
|
onReconnectFailed: function () {
|
|
var self = this
|
|
if (this._localTimer) {
|
|
clearInterval(this._localTimer)
|
|
this._localTimer = null
|
|
}
|
|
wx.showModal({
|
|
title: '连接丢失',
|
|
content: '设备蓝牙连接已断开，无法恢复。本次护理数据将保存。',
|
|
showCancel: false,
|
|
complete: function () {
|
|
self.finishAsComplete()
|
|
}
|
|
})
|
|
},
|
|
|
|
onBack: function () {
|
|
this.onStop()
|
|
},
|
|
|
|
onStop: function () {
|
|
var self = this
|
|
wx.showModal({
|
|
title: '结束护理',
|
|
content: '确定要提前结束本次护理吗？',
|
|
success: function (res) {
|
|
if (res.confirm) {
|
|
ble.stopTreatment().catch(function () {}).then(function () {
|
|
self.finishAsComplete()
|
|
})
|
|
}
|
|
}
|
|
})
|
|
},
|
|
|
|
onMockComplete: function () {
|
|
this.finishAsComplete()
|
|
}
|
|
})
|