plc写入地址文件通过nsq从云端获取

zhangqian

2023-08-22 b483b294741920e90815c2d1f4c6827d9921310c

 nsq/nsq.go

@@ -2,9 +2,13 @@

import (
   "apsClient/conf"
   "apsClient/constvar"
   "apsClient/model/common"
   "apsClient/pkg/logx"
   "apsClient/pkg/safe"
   "errors"
   "fmt"
   "time"
)

func Init() error {
@@ -17,7 +21,20 @@
   }

   safe.Go(func() {
      _ = Consume(fmt.Sprintf("aps.%v.scheduleTask", conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
      caller := NewCaller(fmt.Sprintf(constvar.NsqTopicGetPlcAddress, conf.Conf.NsqConf.NodeId), fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId))
      var addressResult common.ResponsePlcAddress
      err := caller.Call(common.RequestPlcAddress{DeviceId: conf.Conf.System.DeviceId}, &addressResult, time.Second*2)
      if err != nil {
         logx.Infof("SendParams2 err: %v", err.Error())
      }
   })

   safe.Go(func() {
      _ = Consume(fmt.Sprintf(constvar.NsqTopicScheduleTask, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })

   safe.Go(func() {
      _ = Consume(fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })

   return nil