ColdP_server/controllers/Handle/DeviceParameter.go

package Handle

import (
	"ColdP_server/controllers/MqttServer"
	"ColdP_server/controllers/lib"
	"ColdP_server/models/Device"
	"ColdP_server/models/System"
	"encoding/json"
	"fmt"
	"time"
)

func Go_Read_DeviceParameter() {
	for true {
		for k, _ := range lib.CountryRead_DeviceParameterSnMap {

			fmt.Println("CountryRead_DeviceParameterSnMap => KEY", k)
			Read_DeviceParameter(k)
			delete(lib.CountryRead_DeviceParameterSnMap, k)
		}

		time.Sleep(1)
	}
}

func init() {
	//go Go_Read_DeviceParameter()
}

func Read_DeviceParameter(T_sn string) {
	//  base  读取基本参数
	Msid := lib.Random(1, 9999)
	Rt_parameter := MqttServer.Rt_Parameter{
		Sn:    T_sn,
		Type:  3,
		Param: "base",
		Msid:  (Msid * 10) + 1,
	}

	//  offset     温湿度补偿
	Msid = lib.Random(1, 9999)
	Rt_parameter.Param = "offset"
	Rt_parameter.Msid = (Msid * 10) + 3
	// 回复
	jsonStu, err := json.Marshal(Rt_parameter)
	if err != nil {
		System.Add_Logs("MqttServer", "参数请求 [Rt_Parameter]", "offset")
		fmt.Println("回复失败 [Rt_Parameter],err=", err)
	}
	fmt.Println(string(jsonStu))
	MqttServer.Mqtt_publish(T_sn, string(jsonStu))
	//lib.CountryMsidMap[(Msid*10)+3] = T_uuid   // Mqtt 消息透传

	return

}

func Pu_DeviceParameter(T_uuid string, T_sn string, Rt_parameter_base_ MqttServer.Rt_Parameter_Base_) {
	//  base  读取基本参数
	Msid := lib.Random(1, 9999)
	Rt_parameter := MqttServer.Rt_Parameter_Base{
		Sn:   T_sn,
		Type: 4,
		Msid: (Msid * 10) + 1,
		Base: Rt_parameter_base_,
	}
	// 回复
	jsonStu, err := json.Marshal(Rt_parameter)
	if err != nil {
		System.Add_Logs("设备配置", "MQTT回复失败 [Pu_DeviceParameter]", string(jsonStu))
		fmt.Println("设备配置 MQTT回复失败 [Pu_DeviceParameter],err=", err)
		return
	}
	fmt.Println(string(jsonStu))
	MqttServer.Mqtt_publish(T_sn, string(jsonStu))
	//lib.CountryMsidMap[(Msid*10)+1] = T_uuid   // Mqtt 消息透传

	Deviceparameter := Device.DeviceParameter{
		T_sn:           T_sn,
		T_devName:      Rt_parameter_base_.T_devName,
		T_uploadTime:   Rt_parameter_base_.T_uploadTime,
		T_saveTime:     Rt_parameter_base_.T_saveTime,
		T_overrunSave:  Rt_parameter_base_.T_overrunSave,
		T_overrunAlarm: Rt_parameter_base_.T_overrunAlarm,
		T_outageAlarm:  Rt_parameter_base_.T_outageAlarm,
		T_lostAlarm:    Rt_parameter_base_.T_lostAlarm,
		T_warningTime:  Rt_parameter_base_.T_warningTime,
		T_warningDelay: Rt_parameter_base_.T_warningDelay,
		T_batteryLimit: Rt_parameter_base_.T_batteryLimit,
		T_tempPre:      Rt_parameter_base_.T_tempPre,
		T_humPre:       Rt_parameter_base_.T_humPre,
		T_enwarning:    Rt_parameter_base_.T_enwarning,
		T_uuid:         T_uuid,
		T_Msid:         (Msid * 10) + 1,
		T_SendState:    0,
		T_State:        2,
	}

	if !Device.Add_DeviceParameter(Deviceparameter) {
		System.Add_Logs("设备配置", "插入失败 [Pu_DeviceParameter]", string(jsonStu))
		fmt.Println("设备配置 [Pu_DeviceParameter],err=", err)
	}

	return

}

func Pu_DeviceParameter_Sensor(T_uuid string, T_sn string, Rt_parameter_sensor_ []MqttServer.Rt_Parameter_Sensor_) {
	//  base  读取基本参数
	Msid := lib.Random(1, 9999)
	Rt_parameter := MqttServer.Rt_Parameter_Sensor{
		Sn:     T_sn,
		Type:   4,
		Msid:   (Msid * 10) + 2,
		Sensor: Rt_parameter_sensor_,
	}
	// 回复
	jsonStu, err := json.Marshal(Rt_parameter)
	if err != nil {
		System.Add_Logs("设备配置", "MQTT回复失败 [Pu_DeviceParameter_Sensor]", string(jsonStu))
		fmt.Println("设备配置 MQTT回复失败 [Pu_DeviceParameter_Sensor],err=", err)
	}
	fmt.Println(string(jsonStu))
	MqttServer.Mqtt_publish(T_sn, string(jsonStu))
	//lib.CountryMsidMap[(Msid*10)+2] = T_uuid   // Mqtt 消息透传

	//

	///
	for _, v := range Rt_parameter_sensor_ {
		// 记录传感器
		Devicesensorparameter := Device.DeviceSensorParameter{
			T_sn:      T_sn,
			T_id:      v.T_id,
			T_name:    v.T_name,
			T_Tlower:  v.T_Tlower,
			T_Tupper:  v.T_Tupper,
			T_RHlower: v.T_RHlower,
			T_RHupper: v.T_RHupper,
			T_en:      v.T_en,
			T_free:    v.T_free,

			T_uuid:      T_uuid,
			T_Msid:      (Msid * 10) + 2,
			T_SendState: 0,
			T_State:     2,
		}
		if !Device.Add_DeviceSensorParameter(Devicesensorparameter) {
			System.Add_Logs("设备配置", "插入失败 [Pu_DeviceParameter_Sensor]", string(jsonStu))
			fmt.Println("设备配置 [Pu_DeviceParameter_Sensor],err=", err)
		}
	}

	return

}

func Pu_DeviceParameter_Compensate(T_uuid string, T_sn string, Rt_parameter_compensate_ []MqttServer.Rt_Parameter_Compensate_) {
	//  base  读取基本参数
	Msid := lib.Random(1, 9999)
	Rt_parameter_offset := MqttServer.Rt_Parameter_Offset{
		Sn:     T_sn,
		Type:   4,
		Msid:   (Msid * 10) + 3,
		Offset: Rt_parameter_compensate_,
	}
	// 回复
	jsonStu, err := json.Marshal(Rt_parameter_offset)
	if err != nil {
		System.Add_Logs("MqttServer", "参数请求 [Pu_DeviceParameter_Compensate]", "Offset")
		fmt.Println("回复失败 [Pu_DeviceParameter_Compensate],err=", err)
	}
	fmt.Println(string(jsonStu))

	MqttServer.Mqtt_publish(T_sn, string(jsonStu))
	// lib.CountryMsidMap[(Msid*10)+3] = T_uuid   // Mqtt 消息透传

	///

	return

}