|
@@ -74,9 +74,9 @@ func (r *MQTTReporter) onLogin(client mqtt.Client, msg mqtt.Message) {
|
|
|
r.client.Unsubscribe("/yfkj/bxs-sy/server/rpc/response") // 登录成功后, 取消对登录应答的订阅(不关心是否成功)
|
|
r.client.Unsubscribe("/yfkj/bxs-sy/server/rpc/response") // 登录成功后, 取消对登录应答的订阅(不关心是否成功)
|
|
|
baseapp.Logger.Infof("[%s] 登录成功, 设备DUI: %s", MODULE_NAME, r.dui)
|
|
baseapp.Logger.Infof("[%s] 登录成功, 设备DUI: %s", MODULE_NAME, r.dui)
|
|
|
|
|
|
|
|
- r.uploadPhotosTask.Run(r.uploadPendingPhotos, true) // 上报控制板的运行参数, 单实例运行
|
|
|
|
|
|
|
+ r.uploadPhotosTask.Run(r.uploadPendingPhotos, true) // 补录上传历史遗存照片, 单实例运行
|
|
|
r.reportLocTask.Run(r.reportLocation, true) // 定位成功通知当前位置, 单实例运行
|
|
r.reportLocTask.Run(r.reportLocation, true) // 定位成功通知当前位置, 单实例运行
|
|
|
- r.reportMCUTask.Run(func() { r.reportMCUParams(mcu.CfgParams) }, true) // 补录上传历史遗存照片, 单实例运行
|
|
|
|
|
|
|
+ r.reportMCUTask.Run(func() { r.reportMCUParams(mcu.CfgParams) }, true) // 上报控制板的运行参数, 单实例运行
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func (r *MQTTReporter) uploadPendingPhotos() {
|
|
func (r *MQTTReporter) uploadPendingPhotos() {
|