完善数据上报程序, 添加测试

zhangzengfei

2023-08-10 0718b07276198334437f52aa5c6c07cca2002225

 msg/send.go

@@ -3,6 +3,7 @@
import (
   "encoding/json"
   "plc-recorder/util"
   "time"

   "plc-recorder/config"
   "plc-recorder/logger"
@@ -17,10 +18,37 @@
   nsqclient.Produce(config.Options.PubPLCDataTopic, b)

   // aps 发布
   if config.Options.ApsPLCDataWebApi != "" {
      _, err := util.HttpPost(config.Options.ApsPLCDataWebApi, b)
   if config.Options.PostPLCDataWebApi != "" {
      _, err := util.HttpPost(config.Options.PostPLCDataWebApi, b)
      if err != nil {
         logger.Warn(err.Error())
      }
   }
}

func TestSendDeviceLiveData() {
   for i := 1; i > 0; i++ {

      countData := util.IntToBytes(123)

      response := PLCResponse{
         DeviceID:   "0000",
         DeviceName: "test",
         DeviceIP:   "0.0.0.0",
         Online:     true,
         Message:    "",
         PLCData: []PLCData{{
            StartAddress: 100,
            Length:       1,
            Type:         "int",
            FieldName:    "生产计数",
            RawData:      countData,
         },
         },
      }

      SendDeviceLiveData(&response)

      time.Sleep(3 * time.Second)
   }
}