package MqttServer import ( "Cold_mqtt/MqttServer/WarningNotice" "Cold_mqtt/Nats/NatsServer" "Cold_mqtt/lib" "Cold_mqtt/logs" "Cold_mqtt/models/Device" "Cold_mqtt/models/Product" "Cold_mqtt/models/Warning" "encoding/json" "fmt" "io/ioutil" "math" "net/http" "strconv" "strings" "time" ) func AsyncFuncV3(r_Device *Device.Device, Ms_project Ms2m_Project, msg []byte) { ms2_Return := Ms2_Return{ Type: Ms_project.Type, Msid: Ms_project.Msid, Status: 1, } switch Ms_project.Type { case 0: // 0:实时数据 var ms2_Project_list Ms2_Project_list err := json.Unmarshal(msg, &ms2_Project_list) if err != nil { logs.Println("MqttServer", "JSON反序列化失败[Ms_project_0]", string(msg)) logs.Println("JSON反序列化失败[Ms_project_0],err=", err) return } for _, v := range ms2_Project_list.Data { // 是否存在传感器 不存在 跳过 DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, lib.To_int(v["id"])) if !is { logs.Println("MqttServer", "实时数据 传感器不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"])) continue } // lost 字段为传感器离线状态(1代表离线,在线不传此字段),如果离线 温湿度时间数据为空 if _, lost_is := v["lost"]; lost_is { DeviceSensor_r.T_link = 0 Device.Update_DeviceSensor(DeviceSensor_r, "T_link") Warning.Add_DeviceLogs(103, *r_Device, fmt.Sprintf("[%d]%s: 传感器异常断开!", DeviceSensor_r.T_id, DeviceSensor_r.T_name)) // 发现 lost 此字段 代表 传感器异常!!!!! continue } int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64) UT := time.Unix(int64_, 0) logs.Println(UT.Format("2006-01-02 15:04:05")) DeviceSensorParameter_r, is := Device.Read_DeviceSensorParameter(r_Device.T_sn, DeviceSensor_r.T_id) if !is { logs.Println("MqttServer", "记录数据 传感器参数不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"])) continue } //// 更新记录 - 缓存 DeviceData_t := Device.DeviceData_R{ T_t: float32(math.Ceil(float64(lib.To_float32(v["t"])*10)) / 10), T_rh: float32(math.Ceil(float64(lib.To_float32(v["h"])*10)) / 10), T_Site: lib.To_string(v["s"]), T_time: UT, T_sp: DeviceSensorParameter_r.Id, } Device.RedisDeviceData_Set(r_Device.T_sn, DeviceSensor_r.T_id, DeviceData_t) r_Device.T_Site = DeviceData_t.T_Site // 传感器属于 连接状态 if DeviceSensor_r.T_link != 1 { DeviceSensor_r.T_link = 1 Device.Update_DeviceSensor(DeviceSensor_r, "T_link") } } Device.Update_Device(*r_Device, "T_Site") // 反馈透传 NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg) return case 1: // 1:记录数据 var ms2_Project_list Ms2_Project_list err := json.Unmarshal(msg, &ms2_Project_list) if err != nil { logs.Println("MqttServer", "JSON反序列化失败[Ms_project_1]", string(msg)) logs.Println("JSON反序列化失败[Ms_project_1],err=", err) return } // 监控状态 数据有效 if math.Abs(float64(time.Now().Unix()-ms2_Project_list.Dut)) < 30 { r_Device.T_monitor = 1 Device.Update_Device(*r_Device, "T_monitor") } // 回复 ms2_Return.Status = 1 for _, v := range ms2_Project_list.Data { int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64) UT := time.Unix(int64_, 0) //时间异常 大于10s,直接丢掉数据 if (UT.Unix() - time.Now().Unix()) > 60 { ms2_Return.Status = 3 continue } // 是否存在传感器 不存在 跳过 DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, lib.To_int(v["id"])) if !is { logs.Println("MqttServer", "记录数据 传感器不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"])) continue } // 获取传感器参数 DeviceSensorParameter_r, is := Device.Read_DeviceSensorParameter(r_Device.T_sn, DeviceSensor_r.T_id) if !is { logs.Println("MqttServer", "记录数据 传感器参数不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"])) continue } //// 更新记录 - 缓存 DeviceData_t := Device.DeviceData_R{ T_t: float32(math.Ceil(float64(lib.To_float32(v["t"])*10)) / 10), T_rh: float32(math.Ceil(float64(lib.To_float32(v["h"])*10)) / 10), T_Site: lib.To_string(v["s"]), T_time: UT, T_sp: DeviceSensorParameter_r.Id, } // 验证 数据是否安装规定上传间隔 //DeviceData_Previous_r, is := Device.RedisDeviceData_Get(r_Device.T_sn+"_Node", DeviceSensor_r.T_id) //if is { // //最新的时间 要大 // if DeviceData_t.T_time.Unix() > DeviceData_Previous_r.T_time.Unix() { // DeviceParameter_r, is := Device.Read_DeviceParameter(r_Device.T_sn) // if is { // // 计算时间差 // duration := DeviceData_Previous_r.T_time.Sub(DeviceData_t.T_time) // // 将时间差表示为秒 // seconds := int(math.Abs(duration.Seconds())) // // 记录间隔 超过 保存间隔(+-10s)范围 // //difference := int(math.Abs(float64(seconds - DeviceParameter_r.T_overA))) // if seconds < (DeviceParameter_r.T_saveT - 10) { // logs.Println(r_Device.T_sn, " 没有达到数据保存间隔,间隔:", seconds, " < ", DeviceParameter_r.T_saveT, "- 10", " 最新记录数据时间:", DeviceData_Previous_r.T_time) // if F_T_Exceeding(r_Device, DeviceData_t, DeviceSensorParameter_r) && F_H_Exceeding(r_Device, DeviceData_t, DeviceSensorParameter_r) { // logs.Println("!!! 跳过记录数据", "["+r_Device.T_sn+"]", string(msg)) // continue // } // } // } // } //} DeviceParameter_r, is := Device.Read_DeviceParameter(r_Device.T_sn) if !is { DeviceParameter_r.T_saveT = 1 } // 判断是否超标 fsfa //if F_T_Exceeding(r_Device, DeviceData_t, DeviceSensorParameter_r) && F_H_Exceeding(r_Device, DeviceData_t, DeviceSensorParameter_r) { // // 数据超标 // logs.Println("数据超标") // //}else { // //} // 补丁, 判断 开机时间 ,根据 上电推送信息 _, is = Device.RedisDeviceData_Get(r_Device.T_sn+"_Redis", DeviceSensor_r.T_id) Device.RedisDeviceData_Set(r_Device.T_sn+"_Redis", DeviceSensor_r.T_id, DeviceData_t) // 写缓存 if is { // 计算周期时间 DeviceData_t.T_time = lib.PeriodTime(DeviceData_t.T_time, DeviceParameter_r.T_saveT/60) logs.Println("计算周期时间:", UT.Format("2006-01-02 15:04:05"), "=>", DeviceData_t.T_time.Format("2006-01-02 15:04:05"), "保存间隔:", DeviceParameter_r.T_saveT) } else { logs.Println("直接保存数据,SN_Redis 获取失败!") } if r_, _ := Device.Add_DeviceData(r_Device.T_sn, DeviceSensor_r.T_id, DeviceData_t, true); r_ { // 被替换 Device.Add_DeviceDataOld(Device.DeviceDataOld{ T_sn: r_Device.T_sn, T_id: DeviceSensor_r.T_id, T_t: DeviceData_t.T_t, T_rh: DeviceData_t.T_rh, T_Site: DeviceData_t.T_Site, T_time: UT, T_operation: 4, // 4:忽略 T_uuid: "", }) } r_Device.T_Site = DeviceData_t.T_Site // GPS // 传感器属于 连接状态 if DeviceSensor_r.T_link != 1 { DeviceSensor_r.T_link = 1 Device.Update_DeviceSensor(DeviceSensor_r, "T_link") } } Device.Update_Device(*r_Device, "T_Site") NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg) break case 2: // 2:设备报警 var ms2_Project Ms2_Project_list err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.PrintlnError("MqttServer", "设备报警", string(msg)) break } // 缓存报警ID,防止重复发送 if Warning.Redis_Warning_Repeat_T_sn_Msid(r_Device.T_sn + "|" + strconv.FormatInt(ms2_Project.Msid, 10)) { logs.Println("MqttServer", " 存在报警 跳过:", string(msg)) break } for _, v := range ms2_Project.Data { var Warning_r Warning.Warning Warning_r.T_pid = r_Device.T_pid Warning_r.T_tp = lib.To_int(v["tp"]) // 报警类型 Warning_r.T_sn = r_Device.T_sn Warning_r.T_id = lib.To_int(v["id"]) Warning_r.T_Msid = Ms_project.Msid Warning_r.T_D_name = r_Device.T_devName Warning_r.T_State = 1 // 获取 传感器 参数 DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, Warning_r.T_id) if !is { logs.Println("MqttServer", " 传感器ID 不存在", string(msg)) break } Warning_r.T_DS_name = DeviceSensor_r.T_name // 获取 传感器 配置参数 DeviceSensorParameter_r, is := Device.Read_DeviceSensorParameter(Warning_r.T_sn, Warning_r.T_id) if !is { logs.Println("MqttServer", " 传感器ID 配置参数不存在", string(msg)) break } // 温度湿度 封装 T := float32(math.Ceil(float64(lib.To_float32(v["t"])*10)) / 10) RH := float32(math.Ceil(float64(lib.To_float32(v["h"])*10)) / 10) // 持续时间计算 time_int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64) time_int64_f, _ := strconv.ParseInt(lib.To_string(v["fut"]), 10, 64) if time_int64_f == 0 { time_int64_f = time_int64_ } Warning_r.T_fUt = time.Unix(time_int64_f, 0) Warning_r.T_Ut = time.Unix(time_int64_, 0) // 如果记录时间大于当前时间 //if time.Now().Unix() < time_int64_ { // Warning_r.T_Ut = time.Now() // Warning_r.T_Remark += "设备时间异常!" // // 推送同步 时间 // go func() { // time.Sleep(time.Second * 3) // logs.Println(fmt.Sprintf("%s 时间相差:%d", r_Device.T_sn, int(math.Abs(float64(time_int64_-time.Now().Unix()))))) // Warning.Add_DeviceLogs(103, *r_Device, fmt.Sprintf("时间相差:%d", int(math.Abs(float64(time_int64_-time.Now().Unix()))))) // RTC_TimeStr(r_Device.T_sn, time.Now().Unix(), 99) // }() //} //时间异常 大于10s,直接丢掉数据 //if (time_int64_ - time.Now().Unix()) > 10 { // ms2_Return.Status = 3 // logs.Println("时间异常 大于10s,直接丢掉数据", Warning_r.T_sn) // continue //} // 查看 sn 是否有归属 if Warning_r.T_pid == 0 { // 寻找报警归属 if len(Warning_r.T_sn) > 10 { //r_Device, err := Device.Read_Device_ByT_sn(Warning_r.T_sn) //if err != nil { // logs.Println("MessageDisconnected 没有该设备:", Warning_r.T_sn) //} Warning_r.T_pid = r_Device.T_pid } } // 报警数据没有按照 设置间隔推送 (!!! 临时解决问题) //if Warning_r.T_tp == 1 || Warning_r.T_tp == 2 || Warning_r.T_tp == 4 || Warning_r.T_tp == 5 { // DeviceParameter_r, is := Device.Read_DeviceParameter(r_Device.T_sn) // if !is { // logs.Println(r_Device.T_sn + " 没有设备参数,跳过") // continue // } // Warningr := Warning.Read_T_snT_idT_tp(Warning_r.T_sn, Warning_r.T_id, Warning_r.T_tp) // if Warningr.Id != 0 { // // 计算时间差 // duration := time.Now().Sub(Warningr.T_Ut) // // // 将时间差表示为秒 // seconds := int(duration.Seconds()) // if seconds < (DeviceParameter_r.T_overA - 3) { // logs.Println(r_Device.T_sn+" 没有达到设置报警间隔,跳过,间隔:", DeviceParameter_r.T_overA, " 时间差", seconds, " New Warningr.Id ", Warningr.Id) // logs.Println("!!! 跳过没有达到设置报警间隔", "["+r_Device.T_sn+"]", string(msg)) // continue // } // } // //} // 时间周期补丁 -------------------- //tp 报警类型 // 1 温度超上限报警 // 2 温度超下限报警 // 3 温度恢复正常 // 4 湿度超上限报警 // 5 湿度超下限报警 // 6 湿度恢复正常 // 7 温度超上限预警 // 8 温度超下限预警 // 9 温度预警恢复正常 // 10 湿度超上限预警 // 11 湿度超下限预警 // 12 湿度预警恢复正常 // 首次时间缓存,防止乱传数据 Warning_r.T_fUt = Warning.Redis_WarningStart(Warning_r) // 补丁 if Warning_r.T_tp == 3 || Warning_r.T_tp == 6 || Warning_r.T_tp == 9 || Warning_r.T_tp == 12 { // 恢复 Ws_time, Ws_is := Warning.Redis_WarningStart_DelK(Warning_r) if !Ws_is { logs.Println("之前没有报警信息,跳过保存报警!") continue } else { logs.Println("之前发送报警信息,首次报警时间:", Ws_time.Format("2006-01-02 15:04:05")) } } else { logs_s := "报警时间首次时间:" + Warning_r.T_fUt.Format("2006-01-02 15:04:05") + ",报警时间:" + Warning_r.T_Ut.Format("2006-01-02 15:04:05") Warning_r.T_Ut = lib.PeriodWTime(Warning_r.T_fUt, Warning_r.T_Ut, 2) logs.Println("报警时间计算处理:", logs_s, "=>", Warning_r.T_Ut.Format("2006-01-02 15:04:05")) if Warning.Redis_WarningTimeListIs(Warning_r) { logs.Println("报警时间已经存在,跳过!:", Warning_r.T_Ut.Format("2006-01-02 15:04:05")) continue } } //当期湿度:88.0%(↓23.0~↑73.0),已持续1小时33秒 time_int64_f_x := (int(Warning_r.T_Ut.Unix()) - int(Warning_r.T_fUt.Unix())) logs.Println("持续时间:", time_int64_f_x) if time_int64_f_x > 0 { Warning_r.T_Remark += "已持续 " + lib.MinuteToDataTime(time_int64_f_x) } //// 报警处理 WarningNotice.WarningCompanyNotice(&Warning_r, T, RH) //封装具体信息 switch { case Warning_r.T_tp == 1, Warning_r.T_tp == 2, Warning_r.T_tp == 3: Warning_r.T_Remark = "当前温度:" + strconv.FormatFloat(float64(T), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_Tlower), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_Tupper), 'f', -1, 32) + ")," + Warning_r.T_Remark break case Warning_r.T_tp == 4, Warning_r.T_tp == 5, Warning_r.T_tp == 6: Warning_r.T_Remark = "当前湿度:" + strconv.FormatFloat(float64(RH), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_RHlower), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_RHupper), 'f', -1, 32) + ")," + Warning_r.T_Remark break case Warning_r.T_tp == 7, Warning_r.T_tp == 8, Warning_r.T_tp == 9: Warning_r.T_Remark = "当前温度:" + strconv.FormatFloat(float64(T), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_tprel), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_tpreu), 'f', -1, 32) + ")," + Warning_r.T_Remark break case Warning_r.T_tp == 10, Warning_r.T_tp == 11, Warning_r.T_tp == 12: Warning_r.T_Remark = "当前湿度:" + strconv.FormatFloat(float64(RH), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_hprel), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_hpreu), 'f', -1, 32) + ")," + Warning_r.T_Remark break } //记录温湿度 Warning_r.T_t = T Warning_r.T_rh = RH Warning_r.T_sp = DeviceSensorParameter_r.Id // 添加报警 _, err = Warning.Add_Warning(Warning_r) //// 不能 同时增加 记录数据,因为缺失GPS数据 } NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg) break case 3: // 3:读取主机参数 var ms2_Project Ms2_Project err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg)) return } T_name := lib.To_string(ms2_Project.Data["name"]) if len(T_name) == 0 { return } if T_name == "*" { T_name = r_Device.T_devName } if r_Device.T_devName == "未知类型" { T_name = Product.Read_ProductType_Get(r_Device.T_model) } if T_name == r_Device.T_sn { T_name = Product.Read_ProductType_Get(r_Device.T_model) } r_Device.T_devName = T_name Deviceparameter := Device.DeviceParameter{ T_sn: r_Device.T_sn, T_name: T_name, T_saveT: lib.To_int(ms2_Project.Data["saveT"]), //数据保存间隔 (s)*最小值60 T_overA: lib.To_int(ms2_Project.Data["overA"]), //超限报警触发间隔 (s)*最小值60 T_outA: lib.To_int(ms2_Project.Data["outA"]), //断电报警触发间隔 (s)*最小值60 T_lostA: lib.To_int(ms2_Project.Data["lostA"]), //传感器掉线报警触发间隔 (s)*最小值60 T_warnD: lib.To_int(ms2_Project.Data["warnD"]), // 超限预警延时 (s)* T_scan: lib.To_int(ms2_Project.Data["scan"]), // 显示轮播间隔 s(1~240) 默认:5 * T_warn: lib.To_int(ms2_Project.Data["warn"]), // 超限预警触发间隔 (s)*为0时预警只触发一次 *最小值60 T_bat: lib.To_int(ms2_Project.Data["bat"]), //电池电量下限 (%)* T_dormancy: lib.To_int(ms2_Project.Data["dormancy"]), //是否进入休眠 0:关闭 1:开启 默认:0 T_snum: lib.To_int(ms2_Project.Data["snum"]), // 【管理主机】 - 传感器数量 (范围0~255) T_btname: lib.To_string(ms2_Project.Data["btname"]), //--蓝牙打印机名称 用于移动端连接蓝牙打印机 T_btsid: lib.To_int(ms2_Project.Data["btsid"]), //--打印机服务号 用于移动端连接蓝牙打印机 T_btchar: lib.To_int(ms2_Project.Data["btchar"]), //--蓝牙特征码 用于移动端连接蓝牙打印机 //T_speed: lib.To_int(ms2_Project.Data["speed"]), //--蓝牙特征码 用于移动端连接蓝牙打印机 T_State: 1, T_SendState: 1, } if Device.Add_DeviceParameter_fun(Deviceparameter) { Warning.Add_DeviceLogs(102, *r_Device, "修改主机参数") } Device.Update_Device(*r_Device, "T_devName") // 获取所有传感器 //Read_DeviceSensorParameter(r_Device.T_sn) // 不用反馈 return case 4: // 4:设置主机参数 - 反馈 var ms2_Return_r Ms2_Return err := json.Unmarshal(msg, &ms2_Return_r) if err != nil { logs.PrintlnError("MqttServer", "JSON反序列化失败[4:设置主机参数]", string(msg), err.Error()) return } DeviceParameter_r, err := Device.Read_DeviceParameter_SN_Msid(r_Device.T_sn, ms2_Return_r.Msid) if err != nil { logs.PrintlnError("MqttServer", " SN_Msid Err![4:设置主机参数]", string(msg), err.Error()) return } DeviceParameter_r.T_SendState = 2 // 判断参数 //1设置成功,0设置失败 if ms2_Return_r.Status == 1 { DeviceParameter_r.T_SendState = 1 r_Device.T_devName = DeviceParameter_r.T_name Device.Update_Device(*r_Device, "T_devName") } // 状态更新 Device.Update_DeviceParameter_(DeviceParameter_r) // 同步参数 DeviceParameter_r.T_State = 1 Device.Add_DeviceParameter_fun(DeviceParameter_r) Warning.Add_DeviceLogs(102, *r_Device, "修改主机参数-反馈成功") // 取消掉 其他参数 Device.UPDATE_DeviceParameter_SN_T_SendState_2_sql(r_Device.T_sn) return case 5: // 读取传感器参数 var ms2_Project Ms2_Project_list err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.Println("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg)) logs.Println("JSON反序列化失败[Ms_Parameter],err=", err) return } for _, v := range ms2_Project.Data { DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, lib.To_int(v["id"])) T_name := lib.To_string(v["name"]) if len(T_name) == 0 { continue } if T_name == "*" { T_name = r_Device.T_sn + "-" + lib.To_string(v["id"]) if is { T_name = DeviceSensor_r.T_name } } // 不存在 if !is { DeviceSensor_r.T_sn = r_Device.T_sn DeviceSensor_r.T_pid = r_Device.T_pid DeviceSensor_r.T_id = lib.To_int(v["id"]) DeviceSensor_r.T_name = T_name DeviceSensor_r.T_datashow = 1 DeviceSensor_r.T_sort = 1 DeviceSensor_r.T_monitor = r_Device.T_monitor // 设备同步参数 DeviceSensor_r.T_Dattery = r_Device.T_Dattery DeviceSensor_r.T_Site = r_Device.T_Site DeviceSensor_r.T_State = r_Device.T_State DeviceSensor_r.T_online = r_Device.T_online DeviceSensor_r.Id = Device.Add_DeviceSensor(*r_Device, DeviceSensor_r) } // 记录传感器 Devicesensorparameter := Device.DeviceSensorParameter{ T_sn: r_Device.T_sn, T_id: lib.To_int(v["id"]), T_name: T_name, // 报警 T_Tlower: lib.To_float32(v["tl"]), T_Tupper: lib.To_float32(v["tu"]), T_RHlower: lib.To_float32(v["hl"]), T_RHupper: lib.To_float32(v["hu"]), // 预警 T_enprel: lib.To_int(v["enprel"]), T_tprel: lib.To_float32(v["tprel"]), T_tpreu: lib.To_float32(v["tpreu"]), T_hprel: lib.To_float32(v["hprel"]), T_hpreu: lib.To_float32(v["hpreu"]), T_enprelnote: lib.To_int(v["enprelnote"]), //T_speed: lib.To_int(v["speed"]), //T_sense: lib.To_int(v["sense"]), T_en: lib.To_int(v["en"]), T_free: lib.To_int(v["free"]), T_Msid: ms2_Project.Msid, // 消息识别ID T_SendState: 1, // 发送状态 0 待发送 1 发送成功 2 失败 3 覆盖 T_State: 1, // 1 系统获取 2 用户提交 } // 强制修改 是否启用预警记录数据 1:启用 0:关闭 默认:1 if Devicesensorparameter.T_enprelnote != 0 { Devicesensorparameter.T_enprelnote = 1 } // 过滤参数 相同 id := Device.Add_DeviceSensorParameter_fun(Devicesensorparameter) Warning.Add_DeviceLogs(102, *r_Device, "修改设备参数") logs.Println("DeviceSensorParameter ID:", id) // 对 传感器 的状态更新 DeviceSensor_r.T_name = T_name DeviceSensor_r.T_sp = id Device.Update_DeviceSensor(DeviceSensor_r, "T_name", "T_sp") } go func() { time.Sleep(time.Second * 3) Get_Device_Realtime(r_Device.T_sn) }() // 不用反馈 return case 6: // 设置传感器参数 var ms2_Return_r Ms2_Return err := json.Unmarshal(msg, &ms2_Return_r) if err != nil { logs.Println("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg)) logs.Println("JSON反序列化失败[Ms_Parameter],err=", err) return } r, is := Device.Read_DeviceSensorParameter_SN_T_id_Msid(r_Device.T_sn, ms2_Return_r.Msid) if !is { logs.Println("设备配置", "设置设备参数 SN_Msid Err! [Ms_Parameter_r]", string(msg)) return } r.T_SendState = 2 // 判断参数 //1设置成功,0设置失败 if ms2_Return_r.Status == 1 { r.T_SendState = 1 DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r.T_sn, r.T_id) if !is { logs.Println("设备配置", "设置传感器参数 r_DeviceSensor Err! [Ms_Parameter_r]", r.T_sn+"|"+strconv.Itoa(r.T_id)) logs.Println("设置传感器参数 r_DeviceSensor Err![Ms_Parameter_r],err=", r.T_sn+"|"+strconv.Itoa(r.T_id)) logs.Println("MqttServer", r_Device.T_sn+"["+lib.To_string(r.T_id)+"] 没有找到传感器:", string(msg)) break } // 添加一份最新的 r.T_State = 0 id := Device.Add_DeviceSensorParameter_fun(r) Warning.Add_DeviceLogs(102, *r_Device, "修改设备参数") logs.Println("DeviceSensorParameter ID:", id) // 对 传感器 的状态更新 DeviceSensor_r.T_name = r.T_name DeviceSensor_r.T_sp = id Device.Update_DeviceSensor(DeviceSensor_r, "T_name", "T_sp") } // 状态更新 Device.Update_DeviceSensorParameter(r, "T_SendState") // 取消掉 其他参数 Device.UPDATE_DeviceSensorParamete_SN_T_SendState_2_sql(r_Device.T_sn, strconv.Itoa(r.T_id)) //// 更新主机参数 //go func() { // time.Sleep(time.Second * 1) // Read_DeviceSensorParameter3(r_Device.T_sn) //}() return case 12: var ms2_Project Ms2_Project_list err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms_project_2]", string(msg), err.Error()) break } // 缓存报警ID,防止重复发送 if Warning.Redis_Warning_Repeat_T_sn_Msid(r_Device.T_sn + "|" + strconv.FormatInt(ms2_Project.Msid, 10)) { logs.Println("MqttServer", " 存在报警 跳过:", string(msg)) break } // { // "sn": "YD0123456789", // "type": 12, // "msid": 125456001, // "data": [ // { // "tp":7, // 对照 报警类型对应表 // "msg": "报警信息或故障信息", //如:1号传感器故障 (非必填,但是 要带字段) // "ut": 1626857518 //产生时间 // }, // .......... //] //} for _, v := range ms2_Project.Data { var Warning_r Warning.Warning Warning_r.T_tp = lib.To_int(v["tp"]) + 100 // 报警类型 Warning_r.T_sn = r_Device.T_sn Warning_r.T_id = -1 Warning_r.T_Msid = Ms_project.Msid Warning_r.T_D_name = r_Device.T_devName Warning_r.T_DS_name = r_Device.T_devName time_int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64) Warning_r.T_Ut = time.Unix(time_int64_, 0) Warning_r.T_Remark = lib.To_string(v["msg"]) Warning_r.T_State = 1 //时间异常 大于10s,直接丢掉数据 if (time_int64_ - time.Now().Unix()) > 10 { ms2_Return.Status = 3 continue } // 持续时间计算 time_int64_f, _ := strconv.ParseInt(lib.To_string(v["fut"]), 10, 64) if time_int64_f == 0 { time_int64_f = time_int64_ } Warning_r.T_fUt = time.Unix(time_int64_f, 0) time_int64_f_x := (int(time_int64_) - int(time_int64_f)) logs.Println(strconv.FormatInt(Warning_r.T_Msid, 10)+"持续时间:", time_int64_f_x) if time_int64_f_x > 0 { Warning_r.T_Remark += " 已持续" + lib.MinuteToDataTime(time_int64_f_x) } // 查看 sn 是否有归属 if Warning_r.T_pid == 0 { // 寻找报警归属 if len(Warning_r.T_sn) > 10 { r_Device, err := Device.Read_Device_ByT_sn(Warning_r.T_sn) if err != nil { logs.Println("MessageDisconnected 没有该设备:", Warning_r.T_sn) } Warning_r.T_pid = r_Device.T_pid } } switch Warning_r.T_tp { case 101: // 主机报警 Warning_r.T_State = 3 WarningNotice.WarningToAdminId(&Warning_r, []int{}) // 发送给 绑定公司管理员 break case 115: Warning_r.T_Remark = "开始监测任务" // 1 start:开始监测任务, // 防止没有结束命令 DeviceTask_r, ok := Device.Read_DeviceTask_All_Limit_1(r_Device.T_sn) logs.Println("DeviceTask_r.id:", DeviceTask_r.Id) if ok { if DeviceTask_r.T_Ut_end.IsZero() { logs.Println("没有结束 强制 更新上一条") DeviceTask_r.T_Ut_end = Warning_r.T_Ut Device.Update_DeviceTask(DeviceTask_r) } } logs.Println("插入新任务") // 插入开始 任务 dt := Device.DeviceTask{ T_sn: r_Device.T_sn, T_Ut_start: Warning_r.T_Ut, T_Ut: Warning_r.T_Ut, T_State: 1, } Device.Add_DeviceTask(dt) r_Device.T_monitor = 1 break case 116: Warning_r.T_Remark = "中途打印任务" DeviceTask_r, ok := Device.Read_DeviceTask_All_Limit_1(r_Device.T_sn) if ok { if DeviceTask_r.T_Ut_end.IsZero() { DeviceTask_r.T_Ut_end = Warning_r.T_Ut DeviceTask_r.T_State = 3 Device.Update_DeviceTask(DeviceTask_r) // 插入开始 任务 dt := Device.DeviceTask{ T_sn: r_Device.T_sn, T_Ut_start: DeviceTask_r.T_Ut_start, T_Ut: Warning_r.T_Ut, T_State: 1, } logs.Println("插入新任务") Device.Add_DeviceTask(dt) } } r_Device.T_monitor = 1 break case 117: Warning_r.T_Remark = "结束监测任务" // 防止没有结束命令 DeviceTask_r, ok := Device.Read_DeviceTask_All_Limit_1(r_Device.T_sn) if ok { if DeviceTask_r.T_Ut_end.IsZero() { DeviceTask_r.T_Ut_end = Warning_r.T_Ut DeviceTask_r.T_State = 2 Device.Update_DeviceTask(DeviceTask_r) } } // 遍历所有探头,停止记录后 将最后一条数据写入关机数据 DeviceSensorList := Device.Read_DeviceSensor_ByTsn(r_Device.T_sn) for _, vd := range DeviceSensorList { DeviceData_t, is := Device.RedisDeviceData_Get(r_Device.T_sn+"_Redis", vd.T_id) if is { Device.Add_DeviceData(r_Device.T_sn, vd.T_id, DeviceData_t, true) Device.RedisDeviceData_Del(r_Device.T_sn+"_Redis", vd.T_id) // 清除缓存标志 } } r_Device.T_monitor = 0 break } Device.Update_Device(*r_Device, "T_monitor") //// 推送运维信息 WarningNotice.WarningCompanyNotice(&Warning_r, 0, 0) // 添加报警 _, err = Warning.Add_Warning(Warning_r) } break case 13: // 上电推送信息 var ms2_Project Ms2_Project err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.Println("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg)) logs.Println("JSON反序列化失败[Ms_Parameter],err=", err) return } var Warning_r Warning.Warning Warning_r.T_tp = 106 // 报警类型 Warning_r.T_sn = r_Device.T_sn Warning_r.T_D_name = r_Device.T_devName Warning_r.T_id = 0 Warning_r.T_DS_name = "" Warning_r.T_Msid = Ms_project.Msid r_Device.T_model = lib.To_string(ms2_Project.Data["model"]) r_Device.T_sver = lib.To_string(ms2_Project.Data["sver"]) r_Device.T_hver = lib.To_string(ms2_Project.Data["hver"]) r_Device.T_imei = lib.To_string(ms2_Project.Data["imei"]) r_Device.T_iccid = lib.To_string(ms2_Project.Data["iccid"]) Device.Update_Device(*r_Device, "T_model", "T_sver", "T_hver", "T_imei", "T_iccid") // 加入日志 // "rtc" : 1671173184,//设备时间 // "rtl" : 3,//设备开机累计运行秒数 // "st" : 1671173177,//设备开机时间 // "lst" : 0//设备上次关机时间 UT_rtc := time.Unix(int64(lib.To_int64(ms2_Project.Data["rtc"])), 0).Format("2006-01-02 15:04:05") UT_st := time.Unix(int64(lib.To_int64(ms2_Project.Data["st"])), 0).Format("2006-01-02 15:04:05") UT_lst := time.Unix(int64(lib.To_int64(ms2_Project.Data["lst"])), 0).Format("2006-01-02 15:04:05") UT_rtl := lib.To_string(ms2_Project.Data["rtl"]) str := "----- 设备信息 -----\n" str += "设备型号:" + r_Device.T_model + " |\n" str += "软件版本:" + r_Device.T_sver + " |\n" str += "硬件版本:" + r_Device.T_hver + " |\n" str += "模组imei:" + r_Device.T_imei + " |\n" str += "sim卡号:" + r_Device.T_iccid + " |\n" str += "设备时间:" + UT_rtc + " |\n" str += "设备开机时间:" + UT_st + " |\n" str += "设备上次关机时间:" + UT_lst + " |\n" str += "设备开机累计运行秒数:" + UT_rtl + " |\n" Warning_r.T_Remark = str Warning_r.T_Ut = time.Now() Warning_r.T_State = 1 // 添加报警 _, err = Warning.Add_Warning(Warning_r) return case 15: // 网络延时测试 Rt_Project_Data_r := Ms2_Project{ Type: Ms_project.Type, Msid: Ms_project.Msid, } var Data map[string]interface{} Data = make(map[string]interface{}) Data["ut"] = Ms_project.Dut Rt_Project_Data_r.Data = Data // 回复 jsonStu, err := json.Marshal(Rt_Project_Data_r) if err != nil { return } Mqtt_publish(r_Device.T_sn, string(jsonStu)) return case 88: // 临时授权 var ms2_Project Ms2_Project err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg)) return } url := "192.168.0.33:3991/CreateAuth" method := "POST" payload := strings.NewReader("model=" + lib.To_string(ms2_Project.Data["model"]) + "&sver=" + lib.To_string(ms2_Project.Data["sver"]) + "&hver=" + lib.To_string(ms2_Project.Data["hver"]) + "&imei=" + lib.To_string(ms2_Project.Data["imei"]) + "&iccid=" + lib.To_string(ms2_Project.Data["iccid"]) + "&sn=" + lib.To_string(ms2_Project.Data["sn"])) client := &http.Client{} req, err := http.NewRequest(method, url, payload) if err != nil { fmt.Println(err) return } req.Header.Add("Content-Type", "application/x-www-form-urlencoded") res, err := client.Do(req) if err != nil { fmt.Println(err) return } defer res.Body.Close() body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) return } fmt.Println(string(body)) // 实体类 type Ms2_Projectccc struct { Pass string `json:"psaa"` Status string `json:"status"` } var ms2_Projectccc Ms2_Projectccc err = json.Unmarshal(body, &ms2_Projectccc) if err != nil { logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms2_Projectccc]", string(msg)) return } Rt_Project_Data_r := Ms2_Project{ Type: Ms_project.Type, Msid: Ms_project.Msid, } var Data map[string]interface{} Data = make(map[string]interface{}) Data["Pass"] = ms2_Projectccc.Pass Data["Status"] = ms2_Projectccc.Status Rt_Project_Data_r.Data = Data // 回复 jsonStu, err := json.Marshal(Rt_Project_Data_r) if err != nil { return } Mqtt_publish(r_Device.T_sn, string(jsonStu)) return case 98: // 时间同步 RTC_TimeStr(r_Device.T_sn, Ms_project.Msid, 98) return case 100: // 设备实时状态推送 var ms2_Project Ms2_Project err := json.Unmarshal(msg, &ms2_Project) if err != nil { logs.Println("MqttServer", "JSON反序列化失败[Ms_project_]", string(msg)) logs.Println("JSON反序列化失败[Ms_project],err=", err) return } r_Device.T_Dattery = lib.To_int(ms2_Project.Data["power"]) //#设备剩余电量百分比 r_Device.T_rssi = lib.To_string(ms2_Project.Data["rssi"]) //#信号强度 Device.Update_Device(*r_Device, "T_Dattery", "T_rssi") // 反馈透传 NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg) Device.Update_Device(*r_Device, "T_Dattery") return default: return } // 回复 jsonStu, err := json.Marshal(ms2_Return) if err != nil { logs.PrintlnError("MqttServer", "json.Marshal ", string(msg)) logs.Println("回复失败 [Ms_project_0],err=", err) return } Mqtt_publish(r_Device.T_sn, string(jsonStu)) } func F_T_Exceeding(r_Device *Device.Device, DeviceData_t Device.DeviceData_R, DeviceSensorParameter_r Device.DeviceSensorParameter) bool { if r_Device.T_ist == 1 { // 温度 1开启 2关闭 if !(DeviceSensorParameter_r.T_Tupper < DeviceData_t.T_t || DeviceData_t.T_t < DeviceSensorParameter_r.T_Tlower) { logs.Println(r_Device.T_sn+" 温度没有超标,且不在保存间隔范围 :", DeviceSensorParameter_r.T_Tupper, DeviceData_t.T_t, DeviceSensorParameter_r.T_Tlower) return true } } return false } func F_H_Exceeding(r_Device *Device.Device, DeviceData_t Device.DeviceData_R, DeviceSensorParameter_r Device.DeviceSensorParameter) bool { if r_Device.T_ish == 1 { // 湿度 1开启 2关闭 if !(DeviceSensorParameter_r.T_RHupper < DeviceData_t.T_rh || DeviceData_t.T_rh < DeviceSensorParameter_r.T_RHlower) { logs.Println(r_Device.T_sn+" 湿度没有超标,且不在保存间隔范围 :", DeviceSensorParameter_r.T_RHupper, DeviceData_t.T_rh, DeviceSensorParameter_r.T_RHlower) return true } } return false }