ColdVerify_server/Nats/NatsServer/NatsColdApi.go

package NatsServer

import (
	"ColdVerify_server/lib"
	"ColdVerify_server/logs"
	"errors"
	"github.com/vmihailenco/msgpack/v5"
	"time"
)

func Cold_UpdateDevice_CalibrationTime(T_sn, T_CalibrationExpirationTime string) error {
	logs.Println("Nats =>", lib.FuncName(), T_sn, T_CalibrationExpirationTime)

	type T_Req struct {
		T_sn              string
		T_CalibrationTime string
	}
	t_r := T_Req{
		T_sn:              T_sn,
		T_CalibrationTime: T_CalibrationExpirationTime,
	}

	b, err := msgpack.Marshal(&t_r)
	if err != nil {
		logs.Error("Nats =>", "msgpack Marshal err", err)
		return err
	}

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

	type T_R struct {
		Code int16       `xml:"Code"`
		Msg  string      `xml:"Msg"`
		Data interface{} `xml:"Data"`
	}
	var t_R T_R

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