|
@@ -2,29 +2,29 @@ package NatsServer
|
|
|
|
|
|
import (
|
|
|
"Cold_Api/controllers/lib"
|
|
|
- "Cold_Api/logs"
|
|
|
+ "github.com/beego/beego/v2/core/logs"
|
|
|
"Cold_Api/models/Device"
|
|
|
"github.com/vmihailenco/msgpack/v5"
|
|
|
)
|
|
|
|
|
|
func Read_DeviceParameter(T_SN, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), T_SN)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), T_SN)
|
|
|
err := lib.Nats.Publish("Read_DeviceParameter"+T_mqttid, []byte(T_SN))
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
|
|
|
}
|
|
|
func Read_DeviceSensorParameter(T_SN, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), T_SN)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), T_SN)
|
|
|
err := lib.Nats.Publish("Read_DeviceSensorParameter"+T_mqttid, []byte(T_SN))
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
}
|
|
|
|
|
|
func Pu_DeviceParameter(v Device.DeviceParameter, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), v)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), v)
|
|
|
b, err := msgpack.Marshal(&v)
|
|
|
if err != nil {
|
|
|
panic(err)
|
|
@@ -32,12 +32,12 @@ func Pu_DeviceParameter(v Device.DeviceParameter, T_mqttid string) {
|
|
|
|
|
|
err = lib.Nats.Publish("Pu_DeviceParameter"+T_mqttid, b)
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
|
|
|
}
|
|
|
func Pu_DeviceParameter_Sensor(v Device.DeviceSensorParameter, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), v)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), v)
|
|
|
b, err := msgpack.Marshal(&v)
|
|
|
if err != nil {
|
|
|
panic(err)
|
|
@@ -45,11 +45,11 @@ func Pu_DeviceParameter_Sensor(v Device.DeviceSensorParameter, T_mqttid string)
|
|
|
|
|
|
err = lib.Nats.Publish("Pu_DeviceParameter_Sensor"+T_mqttid, b)
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
}
|
|
|
func Set_DeviceTask(v Device.Device_task, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), v)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), v)
|
|
|
b, err := msgpack.Marshal(&v)
|
|
|
if err != nil {
|
|
|
panic(err)
|
|
@@ -57,13 +57,13 @@ func Set_DeviceTask(v Device.Device_task, T_mqttid string) {
|
|
|
|
|
|
err = lib.Nats.Publish("Set_DeviceTask"+T_mqttid, b)
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
func Set_RestartShutdown(v Device.Device_task, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), v)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), v)
|
|
|
b, err := msgpack.Marshal(&v)
|
|
|
if err != nil {
|
|
|
panic(err)
|
|
@@ -71,13 +71,13 @@ func Set_RestartShutdown(v Device.Device_task, T_mqttid string) {
|
|
|
|
|
|
err = lib.Nats.Publish("Set_RestartShutdown"+T_mqttid, b)
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
func Del_DeviceSensor(v Device.DeviceSensor_Del, T_mqttid string) {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), v)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), v)
|
|
|
b, err := msgpack.Marshal(&v)
|
|
|
if err != nil {
|
|
|
panic(err)
|
|
@@ -85,15 +85,15 @@ func Del_DeviceSensor(v Device.DeviceSensor_Del, T_mqttid string) {
|
|
|
|
|
|
err = lib.Nats.Publish("Del_DeviceSensor"+T_mqttid, b)
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
func Get_Device_Realtime(v string, T_mqttid string) {
|
|
|
- //logs.Println("Nats =>", lib.FuncName(),T_mqttid, v)
|
|
|
+ //logs.Info("Nats =>", lib.FuncName(),T_mqttid, v)
|
|
|
err := lib.Nats.Publish("Get_Device_Realtime"+T_mqttid, []byte(v))
|
|
|
if err != nil {
|
|
|
- logs.Println("Nats =>", lib.FuncName(), err)
|
|
|
+ logs.Info("Nats =>", lib.FuncName(), err)
|
|
|
}
|
|
|
}
|