Merge remote-tracking branch 'origin/develop_dl_3.7.0.9_huaian' into develop_dl_3.7.0.9_huaian

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

@@ -991,6 +991,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
                     indexStateList.add(createIndexStateVo(equipmentSpeIndex));
 
+                    // 推送数据到组态大屏
+                    pushDataToIntegrationPage(equipmentSpecificIndexList);
+
                     // 添加指标报告
                     saveEquipmentAlarmReportDay(equipmentSpeIndex);
 
@@ -2436,4 +2439,15 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
             }
         }
     }
+
+    private void pushDataToIntegrationPage(List<EquipmentSpecificIndex> specificIndices) {
+        for (EquipmentSpecificIndex specificIndex : specificIndices) {
+            JSONObject message = new JSONObject() {{
+                put("code", String.valueOf(specificIndex.getId()));
+                put("status", specificIndex.getValue());
+                put("value", specificIndex.getValue());
+            }};
+            mqttSendGateway.sendToMqtt(ConfigPageTopicEnum.SYSTEMDETAIL.getTopic(), message.toJSONString());
+        }
+    }
 }