cold-logistics/common/nats/nats_server/NatsColdApi.go

package nats_server

import (
	"cold-logistics/common/nats"
	"cold-logistics/conf"
	"errors"
	"github.com/vmihailenco/msgpack/v5"
	"time"
)

func Cold_CompanyDeviceSensor_List_ByKey(T_sn string) (data []DeviceSensor_R, count int64, err error) {

	type T_Req struct {
		T_sn  string `xml:"T_sn"`
		T_key string `xml:"T_key"`
	}
	t_Req := T_Req{
		T_sn:  T_sn,
		T_key: conf.ExtConfig.Nats.Key,
	}
	b, _ := msgpack.Marshal(&t_Req)

	msg, err := nats.Nats.Request("Cold_CompanyDeviceSensor_List_ByKey", b, 3*time.Second)
	if err != nil {
		return
	}

	type T_R struct {
		Code  int16            `xml:"Code"`
		Msg   string           `xml:"Msg"`
		Count int64            `xml:"Count"`
		Data  []DeviceSensor_R `xml:"Data"` // 泛型
	}
	var t_R T_R

	err = msgpack.Unmarshal(msg.Data, &t_R)
	if err != nil {
		return
	}
	if t_R.Code != 200 {
		err = errors.New(t_R.Msg)
	}

	return t_R.Data, t_R.Count, nil
}
func Cold_ReadDeviceDataListBy_T_snid(T_snid, startTime, endTime string, page, page_z int) (data []DeviceData_R, count int64, err error) {

	type T_Req struct {
		T_snid     string `xml:"T_snid"`
		Time_start string `xml:"Time_start"`
		Time_end   string `xml:"Time_end"`
		Page       int    `xml:"Page"`
		Page_z     int    `xml:"Page_z"`
	}
	t_Req := T_Req{
		T_snid:     T_snid,
		Time_start: startTime,
		Time_end:   endTime,
		Page:       page,
		Page_z:     page_z,
	}
	b, _ := msgpack.Marshal(&t_Req)

	msg, err := nats.Nats.Request("Cold_ReadDeviceDataListBy_T_snid", b, 3*time.Second)
	if err != nil {
		return
	}

	type T_R struct {
		Code  int16          `xml:"Code"`
		Msg   string         `xml:"Msg"`
		Count int64          `xml:"Count"`
		Data  []DeviceData_R `xml:"Data"` // 泛型
	}
	var t_R T_R

	err = msgpack.Unmarshal(msg.Data, &t_R)
	if err != nil {
		return
	}
	if t_R.Code != 200 {
		err = errors.New(t_R.Msg)
	}

	return t_R.Data, t_R.Count, nil
}
func Cold_ReadDeviceDataListBy_T_snidForLocus(T_snid, startTime, endTime string, page, page_z int) (data []DeviceData_R2, count int64, err error) {

	type T_Req struct {
		T_snid     string `xml:"T_snid"`
		Time_start string `xml:"Time_start"`
		Time_end   string `xml:"Time_end"`
		Page       int    `xml:"Page"`
		Page_z     int    `xml:"Page_z"`
	}
	t_Req := T_Req{
		T_snid:     T_snid,
		Time_start: startTime,
		Time_end:   endTime,
		Page:       page,
		Page_z:     page_z,
	}
	b, _ := msgpack.Marshal(&t_Req)

	msg, err := nats.Nats.Request("Cold_ReadDeviceDataListBy_T_snid", b, 3*time.Second)
	if err != nil {
		return
	}

	type T_R struct {
		Code  int16           `xml:"Code"`
		Msg   string          `xml:"Msg"`
		Count int64           `xml:"Count"`
		Data  []DeviceData_R2 `xml:"Data"` // 泛型
	}
	var t_R T_R

	err = msgpack.Unmarshal(msg.Data, &t_R)
	if err != nil {
		return
	}
	if t_R.Code != 200 {
		err = errors.New(t_R.Msg)
	}

	return t_R.Data, t_R.Count, nil
}