从云端请求工艺参数，加入deviceId字段用于消息过滤

zhangqian

2023-09-02 74f8cd07a39795656573d4e4bb2fe85a6dadbb8c

 nsq/nsq.go

@@ -25,7 +25,7 @@
      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())
         logx.Infof("get plc address err: %v", err.Error())
      }
   })

@@ -37,5 +37,13 @@
      _ = Consume(fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })

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

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

   return nil
}