web 接口添加token

zhangzengfei

2023-08-11 a335f66c4c520728be640ca4e7029ce6f45b8f3d

 msg/send.go

@@ -2,6 +2,9 @@

import (
   "encoding/json"
   "plc-recorder/util"
   "time"

   "plc-recorder/config"
   "plc-recorder/logger"
   "plc-recorder/nsqclient"
@@ -11,5 +14,42 @@
   logger.Debug("plc live data: %+v", response)
   b, _ := json.Marshal(response)

   nsqclient.Produce(config.Options.PLCDataTopic, b)
   // nsq 发布
   nsqclient.Produce(config.Options.PubPLCDataTopic, b)

   // aps 发布
   if config.Options.PostPLCDataWebApi != "" {
      token, _ := util.CreateToken()
      _, err := util.HttpPost(config.Options.PostPLCDataWebApi, b, token)
      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)
   }
}