修改装备消码为站端执行

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

@@ -698,22 +698,24 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                     equipmentSpeIndex.setEquipmentType(topicEntity.getType());
                     equipmentSpeIndex.setUUID(UUIDUtils.getUUID());
 
-                    // 收到信号触发规则恢复码判断
-                    List<Map<String, String>> list = new ArrayList<>();
-                    Map<String, String> map = new HashMap<>(2);
-                    map.put("sourceId", String.valueOf(equipmentSpecificIndex.getEquipmentSpecificId()));
-                    map.put("indexValue", value);
-                    map.put("specificIndexId", String.valueOf(equipmentSpecificIndex.getId()));
-                    list.add(map);
-                    EquipQrDateDto equipQrDateDto = new EquipQrDateDto();
-                    equipQrDateDto.setContrast("indexValue");
-                    equipQrDateDto.setSource("equip");
-                    equipQrDateDto.setType(equipmentSpecificIndex.getTypeCode());
-                    equipQrDateDto.setData(list);
-                    try {
-                        ruleTrigger.publish(equipQrDateDto, "中心配置赋码规则/update-qr-code", null);
-                    } catch (Exception e) {
-                        log.error("调用规则失败: {}", e.getMessage());
+                    if ("zd".equals(system)) {
+                        // 收到信号触发规则恢复码判断
+                        List<Map<String, String>> list = new ArrayList<>();
+                        Map<String, String> map = new HashMap<>(2);
+                        map.put("sourceId", String.valueOf(equipmentSpecificIndex.getEquipmentSpecificId()));
+                        map.put("indexValue", value);
+                        map.put("specificIndexId", String.valueOf(equipmentSpecificIndex.getId()));
+                        list.add(map);
+                        EquipQrDateDto equipQrDateDto = new EquipQrDateDto();
+                        equipQrDateDto.setContrast("indexValue");
+                        equipQrDateDto.setSource("equip");
+                        equipQrDateDto.setType(equipmentSpecificIndex.getTypeCode());
+                        equipQrDateDto.setData(list);
+                        try {
+                            ruleTrigger.publish(equipQrDateDto, "中心配置赋码规则/update-qr-code", null);
+                        } catch (Exception e) {
+                            log.error("调用规则失败: {}", e.getMessage());
+                        }
                     }
 
                     //es存储数据