Commit f5bcdb45 authored by caotao's avatar caotao

消息处理时判断是否已存在告警数据

parent c8377912
......@@ -75,8 +75,8 @@ public class MaintenanceResultHandlerMessage extends EmqxListener {
String stationid = specialMap.get("stationId") == null ? null : specialMap.get("stationId").toString();
Long warningId = specialMap.containsKey("warningId") ? Long.valueOf(specialMap.get("warningId").toString()) : 0L;
if(warningId>0){
hygfMaintenanceTickets = hygfMaintenanceTicketsMapper.selectOne(new QueryWrapper<HYGFMaintenanceTickets>().eq("warning_id", warningId));
if (ObjectUtil.isNotEmpty(hygfMaintenanceTickets)) {
HYGFMaintenanceTickets hygfMaintenanceTickets1 = hygfMaintenanceTicketsMapper.selectOne(new QueryWrapper<HYGFMaintenanceTickets>().eq("warning_id", warningId));
if (ObjectUtil.isNotEmpty(hygfMaintenanceTickets1)) {
return;
}
}
......
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