修改上报的数据结构, 添加plc查询接口

zhangzengfei

2023-08-11 bc0b7e914a378b2c40f9d2ec2470b61a19c18288

 main.go

@@ -1,13 +1,15 @@
package main

import (
   "plc-recorder/msg"
   "os"
   "runtime"

   "plc-recorder/collector"
   "plc-recorder/config"
   "plc-recorder/logger"
   "plc-recorder/msg"
   "plc-recorder/nsqclient"
   "plc-recorder/webserver"

   "github.com/rs/zerolog"
)
@@ -35,10 +37,13 @@
   // 订阅设备变更
   go nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "plc-recorder", collector.HandleDeviceUpdate)

   // 启动采集任务
   collector.InitTask()

   // 测试数据
   go msg.TestSendDeviceLiveData()
   if len(os.Args) > 1 && os.Args[1] == "-d" {
      go msg.TestSendDeviceLiveData()
   }

   select {}
   webserver.Serve(config.Options.ServePort)
}