fix

zhangqian

2023-09-01 313dc7a884e8db3d8597c8eb0003b1f0ae92ca63

 nsq/msg_handler.go

@@ -134,6 +134,16 @@

func (slf *ProcessParams) HandleMessage(data []byte) (err error) {
   logx.Infof("get an process params 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 err :%s", err)
   }
   //通知回复收到
   ReceivedMessageChan <- &ReceivedMessage{
      Topic:   slf.Topic,