Cold_Api/Nats/NatsMqtt.go

package Nats

import (
	"Cold_Api/controllers/lib"
	"Cold_Api/logs"
	"Cold_Api/models/Device"
	"github.com/vmihailenco/msgpack/v5"
)


func Read_DeviceParameter(T_SN string)  {
	logs.Println("Nats =>",lib.FuncName(),T_SN)
	err := Nats.Publish("Read_DeviceParameter", []byte(T_SN))
	if err != nil {
		logs.Println("Nats =>",lib.FuncName(),err)
	}

}
func Read_DeviceSensorParameter(T_SN string)  {
	logs.Println("Nats =>",lib.FuncName(),T_SN)
	err := Nats.Publish("Read_DeviceSensorParameter", []byte(T_SN))
	if err != nil {
		logs.Println("Nats =>",lib.FuncName(),err)
	}
}
func Pu_DeviceParameter(v Device.DeviceParameter)  {
	logs.Println("Nats =>",lib.FuncName(),v)
	b, err := msgpack.Marshal(&v)
	if err != nil {
		panic(err)
	}

	err = Nats.Publish("Pu_DeviceParameter", b)
	if err != nil {
		logs.Println("Nats =>",lib.FuncName(),err)
	}

}
func Pu_DeviceParameter_Sensor(v Device.DeviceSensorParameter)  {
	logs.Println("Nats =>",lib.FuncName(),v)
	b, err := msgpack.Marshal(&v)
	if err != nil {
		panic(err)
	}

	err = Nats.Publish("Pu_DeviceParameter_Sensor", b)
	if err != nil {
		logs.Println("Nats =>",lib.FuncName(),err)
	}

}
func Set_DeviceTask(v Device.Device_task)  {
	logs.Println("Nats =>",lib.FuncName(),v)
	b, err := msgpack.Marshal(&v)
	if err != nil {
		panic(err)
	}

	err = Nats.Publish("Set_DeviceTask", b)
	if err != nil {
		logs.Println("Nats =>",lib.FuncName(),err)
	}

}

func Del_DeviceSensor(v Device.DeviceSensor_Del)  {
	logs.Println("Nats =>",lib.FuncName(),v)
	b, err := msgpack.Marshal(&v)
	if err != nil {
		panic(err)
	}

	err = Nats.Publish("Del_DeviceSensor", b)
	if err != nil {
		logs.Println("Nats =>",lib.FuncName(),err)
	}

}