From a335f66c4c520728be640ca4e7029ce6f45b8f3d Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期五, 11 八月 2023 11:21:32 +0800 Subject: [PATCH] web 接口添加token --- msg/send.go | 33 +++++++++++++++++++++++++++++++-- 1 files changed, 31 insertions(+), 2 deletions(-) diff --git a/msg/send.go b/msg/send.go index 334d112..ba068d5 100644 --- a/msg/send.go +++ b/msg/send.go @@ -3,6 +3,7 @@ import ( "encoding/json" "plc-recorder/util" + "time" "plc-recorder/config" "plc-recorder/logger" @@ -17,10 +18,38 @@ nsqclient.Produce(config.Options.PubPLCDataTopic, b) // aps 鍙戝竷 - if config.Options.ApsPLCDataWebApi != "" { - _, err := util.HttpPost(config.Options.ApsPLCDataWebApi, b) + 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) + } +} -- Gitblit v1.8.0