zhangqian
2023-10-20 a303829fe0c19d5683d8dddb5a9a8d0001d40ef5
nsq/msg_handler.go
@@ -297,8 +297,16 @@
   }
   detail, err := json.Marshal(record.Details)
   record.Detail = string(detail)
   record.ID = 1
   err = model.NewDevicePlcSearch().SetId(record.ID).Save(&record)
   oldPlcRecord, err := model.NewDevicePlcSearch().SetDeviceId(msg.ID).First()
   if err == gorm.ErrRecordNotFound {
      err = model.NewDevicePlcSearch().Create(&record)
   } else if record.Port != oldPlcRecord.Port ||
      record.Method != oldPlcRecord.Method ||
      record.Address != oldPlcRecord.Address ||
      record.Detail != oldPlcRecord.Detail {
      err = model.NewDevicePlcSearch().SetDeviceId(msg.ID).Save(&record)
   }
   if err != nil {
      return err
   }