Cold_mqtt/MqttServer/V3MqttHandle.go

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_new(*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
		}
		// 回复
		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()) > 10 {
				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,
			}
			if r_, DeviceData_old_r := Device.Add_DeviceData(r_Device.T_sn, DeviceSensor_r.T_id, DeviceData_t); r_ {
				// 被替换
				Device.Add_DeviceDataOld(Device.DeviceDataOld{
					T_sn:        r_Device.T_sn,
					T_id:        DeviceSensor_r.T_id,
					T_t:         DeviceData_old_r.T_t,
					T_rh:        DeviceData_old_r.T_rh,
					T_Site:      DeviceData_old_r.T_site,
					T_time:      UT,
					T_operation: 2,
					T_uuid:      "",
				})
			}
			r_Device.T_Site = DeviceData_t.T_Site // GPS
			// 监控状态 数据有效

			if (time.Now().Unix() - UT.Unix()) < 30 {
				r_Device.T_monitor = 1
			}
		}
		Device.Update_Device_new(*r_Device, "T_monitor", "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)
			time_int64_f_x := (int(time_int64_) - int(time_int64_f))
			logs.Println(strconv.FormatInt(Warning_r.T_Msid, 10)+"持续时间:", time_int64_f_x)

			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
				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 {

				continue
			}
			//tp	报警类型
			// 1	温度超上限报警
			// 2	温度超下限报警
			// 3	温度恢复正常
			// 4	湿度超上限报警
			// 5	湿度超下限报警
			// 6	湿度恢复正常
			// 7	温度超上限预警
			// 8	温度超下限预警
			// 9	温度预警恢复正常
			// 10	湿度超上限预警
			// 11	湿度超下限预警
			// 12	湿度预警恢复正常
			//当期湿度:88.0%(↓23.0~↑73.0),已持续1小时33秒
			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
			}
			// 添加报警
			_, 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_new(*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_new(*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 用户提交
			}

			// 过滤参数 相同
			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)

					}
				}

				r_Device.T_monitor = 0
				break
			}

			//// 推送运维信息
			WarningNotice.WarningCompanyNotice(&Warning_r, 0, 0)

			// 添加报警
			_, err = Warning.Add_Warning(Warning_r)

		}
		Device.Update_Device_new(*r_Device, "T_monitor")
		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_new(*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))

}