From 0718b07276198334437f52aa5c6c07cca2002225 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期四, 10 八月 2023 18:17:32 +0800
Subject: [PATCH] 完善数据上报程序, 添加测试

---
 main.go |    7 ++++++-
 1 files changed, 6 insertions(+), 1 deletions(-)

diff --git a/main.go b/main.go
index fd296d0..a828d4b 100644
--- a/main.go
+++ b/main.go
@@ -1,6 +1,7 @@
 package main
 
 import (
+	"plc-recorder/msg"
 	"runtime"
 
 	"plc-recorder/collector"
@@ -24,6 +25,7 @@
 	if runtime.GOOS == "windows" {
 		logFilePath = "log/plc-recorder.log"
 	}
+
 	logger.InitLog(logFilePath, "debug", 15, false)
 	logger.Info("plc-recorde start!")
 
@@ -31,9 +33,12 @@
 	nsqclient.InitNsqProducer()
 
 	// 璁㈤槄璁惧鍙樻洿
-	nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "sensor01", collector.HandleDeviceUpdate)
+	go nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "plc-recorder", collector.HandleDeviceUpdate)
 
 	collector.InitTask()
 
+	// 娴嬭瘯鏁版嵁
+	go msg.TestSendDeviceLiveData()
+
 	select {}
 }

--
Gitblit v1.8.0