修改裝備數據監聽topic

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/config/EquipmentIotMqttReceiveConfig.java

@@ -109,19 +109,20 @@ public class EquipmentIotMqttReceiveConfig {
         iSyncDataService.saveOrUpdateEquipIotCodeRedisData(equipAndCars);
         List<String> list = new ArrayList<String>();
         if (equipAndCars.size() > 0) {
-            for (EquipmentSpecificVo specificVo : equipAndCars) {
-                String iotCode = specificVo.getIotCode();
-                if (iotCode.length() > 8) {
-                    String prefix = iotCode.substring(0, 8);
-                    String suffix = iotCode.substring(8);
-                    String topicTotal = String.format("%s/%s/property", prefix, suffix);
-                    list.add(topicTotal);
-                }
-            }
+//            for (EquipmentSpecificVo specificVo : equipAndCars) {
+//                String iotCode = specificVo.getIotCode();
+//                if (iotCode.length() > 8) {
+//                    String prefix = iotCode.substring(0, 8);
+//                    String suffix = iotCode.substring(8);
+//                    String topicTotal = String.format("%s/%s/property", prefix, suffix);
+//                    list.add(topicTotal);
+//                }
+//            }
         } else {
             list.add(defaultTopic);
         }
         list.addAll(ConfigPageTopicEnum.getEnumTopicList());          //大屏数据推送接口订阅
+        list.add("+/+/property"); // 添加iot車輛裝備數據上報事件监听
         list.add("+/+/event"); // 添加iot事件监听
         String[] arr = list.toArray(new String[list.size()]);
         adapter = new MqttPahoMessageDrivenChannelAdapter(clientId + "_inbound", mqttPahoClientFactory(), arr);