NatsWorkOrder.go 737 B

12345678910111213141516171819202122232425262728293031
  1. package NatsServer
  2. import (
  3. "Cold_Api/controllers/lib"
  4. "fmt"
  5. "github.com/vmihailenco/msgpack/v5"
  6. "time"
  7. )
  8. func Read_WorkOrderT_State_Count(T_pids string) (int64, int64) {
  9. msg, err := lib.Nats.Request("Cold_WorkOrder_Read_WorkOrderT_State_Count", []byte(T_pids), 3*time.Second)
  10. if err != nil {
  11. return 0, 0
  12. }
  13. fmt.Printf("UserListAll: %v\n", string(msg.Data))
  14. type T_R struct {
  15. Code int16 `xml:"Code"`
  16. Msg string `xml:"Msg"`
  17. TodayWorkOrderNum int64 // 今日工单数量
  18. UntreatedWorkOrderNum int64 // 未处理工单数量
  19. }
  20. var t_R T_R
  21. err = msgpack.Unmarshal(msg.Data, &t_R)
  22. if err != nil {
  23. return 0, 0
  24. }
  25. return t_R.TodayWorkOrderNum, t_R.UntreatedWorkOrderNum
  26. }