Commit cb98b1a8 authored by KeYong's avatar KeYong

更新指标推送代码

parent 92501530
...@@ -31,4 +31,6 @@ public class SpeIndexVo { ...@@ -31,4 +31,6 @@ public class SpeIndexVo {
private String indexValue; private String indexValue;
private String indexName; private String indexName;
private String qrCode;
} }
...@@ -1245,7 +1245,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -1245,7 +1245,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
/** /**
* 组装数字换流站平台告警数据 * 组装数字换流站平台告警数据
* @param equipmentSpecificIndex * @param
* @return * @return
*/ */
private List<FireEquipmentFireAlarm> createFireEquipmentFireAlarmVo(List<EquipmentSpecificAlarmLog> equipmentAlarmLogs){ private List<FireEquipmentFireAlarm> createFireEquipmentFireAlarmVo(List<EquipmentSpecificAlarmLog> equipmentAlarmLogs){
...@@ -1280,13 +1280,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -1280,13 +1280,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
* @param equipmentSpecificIndexList * @param equipmentSpecificIndexList
*/ */
private void syncSpecificIndexsToGS(List<EquipmentSpecificIndex> equipmentSpecificIndexList){ private void syncSpecificIndexsToGS(List<EquipmentSpecificIndex> equipmentSpecificIndexList){
if (ObjectUtils.isEmpty(equipmentSpecificIndexList) && syncSwitch) { if (!ObjectUtils.isEmpty(equipmentSpecificIndexList) && syncSwitch) {
// 数据同步 // 数据同步
List<EquipmentIndexVO> fireEquipMeasurementCollect = new ArrayList<>(); List<EquipmentIndexVO> fireEquipMeasurementCollect = new ArrayList<>();
equipmentSpecificIndexList.forEach(action->{ equipmentSpecificIndexList.forEach(action->{
EquipmentIndexVO equipmentIndexVO = new EquipmentIndexVO(); EquipmentIndexVO equipmentIndexVO = new EquipmentIndexVO();
BeanUtils.copyProperties(action, equipmentIndexVO); BeanUtils.copyProperties(action, equipmentIndexVO);
fireEquipMeasurementCollect.add(equipmentIndexVO);
}); });
if (0 < fireEquipMeasurementCollect.size()) { if (0 < fireEquipMeasurementCollect.size()) {
syncDataService.syncCreatedFireEquipMeasurement(fireEquipMeasurementCollect); syncDataService.syncCreatedFireEquipMeasurement(fireEquipMeasurementCollect);
......
...@@ -363,10 +363,12 @@ ...@@ -363,10 +363,12 @@
spein.emergency_level AS emergencyLevel, spein.emergency_level AS emergencyLevel,
spein.emergency_level_describe AS emergencyLevelDescribe, spein.emergency_level_describe AS emergencyLevelDescribe,
spein.`value` AS indexValue, spein.`value` AS indexValue,
spein.equipment_index_name AS indexName spein.equipment_index_name AS indexName,
wes.qr_code AS qrCode
FROM FROM
wl_equipment_specific_index AS spein wl_equipment_specific_index AS spein
LEFT JOIN wl_equipment_index AS eqin ON spein.equipment_index_id = eqin.id LEFT JOIN wl_equipment_index AS eqin ON spein.equipment_index_id = eqin.id
LEFT JOIN wl_equipment_specific AS wes ON wes.id = spein.equipment_specific_id
WHERE WHERE
spein.equipment_specific_id = #{id} spein.equipment_specific_id = #{id}
ORDER BY ORDER BY
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment