增加实时获取生产进度接口

zhangqian

2023-09-16 ef7d02ce56e98e8cbc5ed6ec746ea39bf0b8c9e2

 nsq/consumer.go

@@ -2,6 +2,7 @@

import (
   "apsClient/conf"
   "apsClient/constvar"
   "apsClient/pkg/logx"
   "apsClient/pkg/nsqclient"
   "context"
@@ -17,8 +18,14 @@
   logx.Infof("Consume NewNsqConsumer topic:%v", topic)
   var handler MsgHandler
   switch topic {
   case fmt.Sprintf("aps.%v.scheduleTask", conf.Conf.NsqConf.NodeId):
   case fmt.Sprintf(constvar.NsqTopicScheduleTask, conf.Conf.NsqConf.NodeId):
      handler = new(ScheduleTask)
   case fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId):
      handler = &PlcAddress{Topic: topic}
   case fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId):
      handler = &ProcessParams{Topic: topic}
   case fmt.Sprintf(constvar.NsqTopicApsProcessParams, conf.Conf.NsqConf.NodeId):
      handler = &ProcessParamsSync{Topic: topic}
   }
   c.AddHandler(handler.HandleMessage)