|
|
@@ -33,9 +33,9 @@ var (
|
|
|
)
|
|
|
|
|
|
const (
|
|
|
- MqttQos1 byte = 1 // 消息至少送达一次
|
|
|
- FastInterval = 1 * time.Second // 快速检测时间间隔
|
|
|
- SlowInterval = 5 * time.Second // 慢速检测时间间隔
|
|
|
+ MqttQos1 byte = 1 //////// 消息至少送达一次
|
|
|
+ FastInterval = 1 * time.Second //////// 快速检测时间间隔
|
|
|
+ SlowInterval = 5 * time.Second //////// 慢速检测时间间隔
|
|
|
)
|
|
|
|
|
|
type MQTTReporter struct {
|
|
|
@@ -49,13 +49,13 @@ type MQTTReporter struct {
|
|
|
inheritDUI string // 继承的历史ID, 可选可为空(换板时)
|
|
|
sensorFileLock sync.Mutex // 用于保护"传感器"数据文件的读和写
|
|
|
|
|
|
- // 主动上报的后台任务, 登录成功时用于照片补录和上报通知类消息
|
|
|
- reuploadHistTask *singletask.OnceTask // 补录数据, 单实例
|
|
|
- reportMcuCfgTask *singletask.OnceTask // 上报配置, 单实例
|
|
|
- reportRtuPosTask *singletask.OnceTask // 上报位置, 单实例
|
|
|
+ ////// 主动上报的后台任务, 登录成功时用于照片补录和上报通知类消息
|
|
|
+ reuploadHistTask *singletask.OnceTask ////// 补录数据, 单实例
|
|
|
+ reportMcuCfgTask *singletask.OnceTask ////// 上报配置, 单实例
|
|
|
+ reportRtuPosTask *singletask.OnceTask ////// 上报位置, 单实例
|
|
|
|
|
|
- // 注册本地的远程方法, 登录成功后用于让服务端能够主动下发指令
|
|
|
- registerRpcMeths *singletask.OnceTask // 注册方法, 单实例
|
|
|
+ ////// 注册本地的远程方法, 登录成功后用于让服务端能够主动下发指令
|
|
|
+ registerRpcMeths *singletask.OnceTask ////// 注册方法, 单实例
|
|
|
}
|
|
|
|
|
|
func ModuleInit() bool {
|