接收工艺模型新增消息，plc读取时间可配置

zhangqian

2023-09-01 f4c6c982a275fcdead46a7bdb5704fc39b4f1bb0

 nsq/msg_handler.go

@@ -134,12 +134,6 @@

func (slf *ProcessParams) HandleMessage(data []byte) (err error) {
   logx.Infof("get an process params message :%s", data)
   var resp = new(common.ResponseProcessParams)
   err = json.Unmarshal(data, &resp)
   if err != nil {
      logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error())
      return err
   }
   //通知回复收到
   ReceivedMessageChan <- &ReceivedMessage{
      Topic:   slf.Topic,
@@ -147,3 +141,23 @@
   }
   return nil
}

type ProcessParamsSync struct {
   Topic string
}

func (slf *ProcessParamsSync) HandleMessage(data []byte) (err error) {
   logx.Infof("get an process params sync message :%s", data)
   var processModel model.ProcessModel
   err = json.Unmarshal(data, &processModel)
   if err != nil {
      logx.Infof("unmarshal process params sync err :%s", err)
      return err
   }
   err = model.NewProcessModelSearch().Create(&processModel)
   if err != nil {
      logx.Infof("save process params sync err :%s", err)
      return err
   }
   return nil
}