From 88da1e13a073e8b5656387a246d827593fbd6163 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期五, 04 八月 2023 18:25:59 +0800
Subject: [PATCH] 添加设备查询，修改, 采集数据上报
---
msg/send.go | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/msg/send.go b/msg/send.go
index e7036f1..334d112 100644
--- a/msg/send.go
+++ b/msg/send.go
@@ -2,6 +2,8 @@
import (
"encoding/json"
+ "plc-recorder/util"
+
"plc-recorder/config"
"plc-recorder/logger"
"plc-recorder/nsqclient"
@@ -11,5 +13,14 @@
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.ApsPLCDataWebApi != "" {
+ _, err := util.HttpPost(config.Options.ApsPLCDataWebApi, b)
+ if err != nil {
+ logger.Warn(err.Error())
+ }
+ }
}
--
Gitblit v1.8.0