Skip to content

A
amos-boot-biz
Commit 0eb0ee0e authored by maoying's avatar maoying
Browse files
Options

修改实时消息推送逻辑

parent af6c2e91
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 2 deletions
amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java
View file @ 0eb0ee0e
...@@ -262,7 +262,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -262,7 +262,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
return; return;
} }
log.info(String.format("收到mqtt消息：%s", message)); log.info(String.format("收到mqtt消息：%s", message));
saveDataToDB(topicEntity, iotDatalist); // saveDataToDB(topicEntity, iotDatalist);
realTimeDateProcessing(topicEntity, iotDatalist);
} }
/** /**
...@@ -1416,6 +1417,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -1416,6 +1417,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override @Override
public void afterCommit() { public void afterCommit() {
mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), "");
iEquipmentSpecificSerivce.integrationPageSysDataRefresh(topicEntity.getCode()); iEquipmentSpecificSerivce.integrationPageSysDataRefresh(topicEntity.getCode());
iEquipmentSpecificSerivce.updateEquipmentSpecIndexRealtimeData(equipmentSpecificIndexList); iEquipmentSpecificSerivce.updateEquipmentSpecIndexRealtimeData(equipmentSpecificIndexList);
} }
...@@ -1445,7 +1447,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -1445,7 +1447,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
reportDay.setIndexTrueNum(reportDay.getIndexTrueNum() == null ? equipmentAlarmReportDay.getIndexTrueNum() : reportDay.getIndexTrueNum() + equipmentAlarmReportDay.getIndexTrueNum()); reportDay.setIndexTrueNum(reportDay.getIndexTrueNum() == null ? equipmentAlarmReportDay.getIndexTrueNum() : reportDay.getIndexTrueNum() + equipmentAlarmReportDay.getIndexTrueNum());
iEquipmentAlarmReportDayService.updateById(reportDay); iEquipmentAlarmReportDayService.updateById(reportDay);
} }
mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), "");
} }
private String valueTranslate(String value, String enumStr){ private String valueTranslate(String value, String enumStr){
......
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