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
---
collector/device.go | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/collector/device.go b/collector/device.go
index 9812adc..a9fc19e 100644
--- a/collector/device.go
+++ b/collector/device.go
@@ -10,7 +10,8 @@
)
func getDeviceList() ([]msg.PLCDevice, error) {
- responseBody, err := util.HttpPost(config.Options.ApsDeviceWebApi, nil)
+ token, _ := util.CreateToken()
+ responseBody, err := util.HttpPost(config.Options.DeviceListWebApi, nil, token)
if err != nil {
logger.Warn("get device list from aps error:%s", err.Error())
return nil, err
@@ -32,16 +33,16 @@
func HandleDeviceUpdate(message []byte) error {
var device msg.PLCDevice
+ logger.Debug("receive device update msg: %s", string(message))
+
err := json.Unmarshal(message, &device)
if err != nil {
logger.Error("unmarshal device update msg error:%s", err.Error())
return err
}
- if task, ok := mapTask.Load(device.DeviceID); ok {
- // 瀛樺湪鐨勪换鍔�, 鍏堝仠姝㈡帀, 鐒跺悗閲嶆柊寮�鍚竴涓�
- task.(collectorProc).cancel()
- }
+ // 鍏堝仠鎺夋鍦ㄦ墽琛岀殑浠诲姟
+ stopTask(&device)
// 鍒ゆ柇鏄惁鏄噸鏂板惎鍔ㄧ殑鐘舵��, 鍚姩涓�涓柊鐨勪换鍔�
if device.Status == 0 {
--
Gitblit v1.8.0