修改代码

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -952,19 +952,25 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                         }
                         specific.setEquipStatus(EquipQrcodeColorEnum.RED.getCode());
 
-                        //保存 wl_equip_qrcode_record 二维码记录
-                        EquipQrcodeRecord equipQrcodeRecord = new EquipQrcodeRecord();
-                        equipQrcodeRecord.setEquipid(action.getEquipmentSpecificId());
-                        equipQrcodeRecord.setSource("equip");
-                        equipQrcodeRecord.setAlarmTime(new Date());
-                        equipQrcodeRecord.setStatus(EquipQrcodeColorEnum.RED.getCode());
-                        equipQrcodeRecord.setSourceId(equipmentSpecificAlarmLog.getId().toString());
-                        equipQrcodeRecord.setBizOrgCode(action.getBizOrgCode());
-                        equipQrcodeRecord.setBizOrgName(action.getBizOrgName());
-                        equipQrcodeRecord.setSystemCode(action.getSystemIds());
-                        equipQrcodeRecord.setEquipIndex(equipmentSpecificAlarmLog.getEquipmentSpecificIndexKey());
-                        equipQrcodeRecordMapper.insert(equipQrcodeRecord);
-
+                        LambdaQueryWrapper<EquipQrcodeRecord> wrapper = new LambdaQueryWrapper<>();
+                        wrapper.eq(EquipQrcodeRecord::getEquipid, action.getEquipmentSpecificId());
+                        wrapper.eq(EquipQrcodeRecord::getEquipIndex,equipmentSpecificAlarmLog.getEquipmentSpecificIndexKey());
+                        wrapper.isNull(EquipQrcodeRecord::getCleanTime);
+                        EquipQrcodeRecord equipQrcodeRecord = equipQrcodeRecordMapper.selectOne(wrapper);
+                        if (ObjectUtils.isEmpty(equipQrcodeRecord)){
+                            //保存 wl_equip_qrcode_record 二维码记录
+                            EquipQrcodeRecord qrcodeRecord = new EquipQrcodeRecord();
+                            qrcodeRecord.setEquipid(action.getEquipmentSpecificId());
+                            qrcodeRecord.setSource("equip");
+                            qrcodeRecord.setAlarmTime(new Date());
+                            qrcodeRecord.setStatus(EquipQrcodeColorEnum.RED.getCode());
+                            qrcodeRecord.setSourceId(equipmentSpecificAlarmLog.getId().toString());
+                            qrcodeRecord.setBizOrgCode(action.getBizOrgCode());
+                            qrcodeRecord.setBizOrgName(action.getBizOrgName());
+                            qrcodeRecord.setSystemCode(action.getSystemIds());
+                            qrcodeRecord.setEquipIndex(equipmentSpecificAlarmLog.getEquipmentSpecificIndexKey());
+                            equipQrcodeRecordMapper.insert(qrcodeRecord);
+                        }
                         isAlarm = Boolean.TRUE;
                         mqttSendGateway.sendToMqtt(TopicEnum.EQDQR.getTopic(), JSONArray.toJSON(action).toString());
                         iEquipmentSpecificSerivce.updateEquipSpecificStatus(specific.getEquipStatus(), String.valueOf(specific.getId()));