Commit b6962d30 authored by caotao's avatar caotao

23457:任务处置以后预警状态未更新问题处理

parent a9a02046
...@@ -77,7 +77,7 @@ public class WarningRecordStatusMessage extends EmqxListener { ...@@ -77,7 +77,7 @@ public class WarningRecordStatusMessage extends EmqxListener {
queryWrapper.eq("kks",jsonObject.getString("objectId")); queryWrapper.eq("kks",jsonObject.getString("objectId"));
if(params.length==3){ if(params.length==3){
queryWrapper.eq("sub_system",params[0]); queryWrapper.eq("sub_system",params[0]);
queryWrapper.eq("health_level",params[1]); // queryWrapper.eq("health_level",params[1]);
queryWrapper.eq("warning_period",params[2]); queryWrapper.eq("warning_period",params[2]);
} }
List<FanWarningRecord> fanWarningRecords = fanWaringRecordMapper.selectList(queryWrapper); List<FanWarningRecord> fanWarningRecords = fanWaringRecordMapper.selectList(queryWrapper);
...@@ -128,7 +128,7 @@ public class WarningRecordStatusMessage extends EmqxListener { ...@@ -128,7 +128,7 @@ public class WarningRecordStatusMessage extends EmqxListener {
queryWrapper.eq("kks",jsonObject.getString("objectId")); queryWrapper.eq("kks",jsonObject.getString("objectId"));
if(params.length==3){ if(params.length==3){
queryWrapper.eq("subarray",params[0]); queryWrapper.eq("subarray",params[0]);
queryWrapper.eq("health_level",params[1]); // queryWrapper.eq("health_level",params[1]);
queryWrapper.eq("warning_period",params[2]); queryWrapper.eq("warning_period",params[2]);
} }
List<PvWarningRecord> pvWarningRecords = pvWaringRecordMapper.selectList(queryWrapper); List<PvWarningRecord> pvWarningRecords = pvWaringRecordMapper.selectList(queryWrapper);
......
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