Skip to content

A
amos-boot-biz
Commit fe2f1e01 authored by wujiang's avatar wujiang
Browse files
Options

修改查询显示

parent 1804918c
Show whitespace changes
Inline Side-by-side
Showing with 88 additions and 88 deletions
amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/MonitorFanIndicatorImpl.java
View file @ fe2f1e01
......@@ -147,6 +147,7 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
if("true".equals(i.getValue()))
{
i.setValue("合");
i.setValueLabel(i.getEquipmentIndexName());
}
});
}
......@@ -2143,94 +2144,93 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
return deaviationRateDtoPage;
}
@Scheduled(cron = "0 */10 * * * ?")
//@Scheduled(cron = "0/1 * * * * ?")
public void addNbqAlarmEvent() {
LambdaQueryWrapper<StationBasic> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(BaseEntity::getIsDelete, false);
wrapper.like(StationBasic::getStationType, "GFDZ");
List<StationBasic> stationBasics = stationBasicMapper.selectList(wrapper);
for (StationBasic stationBasic : stationBasics) {
Map<String, List<String>> queryCondtion = new HashMap<>();
Map<String, String> shouldCondtion = new HashMap<>();
queryCondtion.put(CommonConstans.QueryStringGateWayId, Arrays.asList(stationBasic.getFanGatewayId()));
queryCondtion.put(CommonConstans.QueryStringEquipmentIndexName,
Arrays.asList("待机", "停机", "告警运行", "限额运行", "降额运行", "故障停机", "通讯故障", "运行"));
queryCondtion.put(CommonConstans.QueryStringValueKeyword, Arrays.asList("true"));
/**
* 逆变器
*/
List<ESEquipments> indicatorsDtoList = commonServiceImpl.getListDataByCondtions(queryCondtion, null,
ESEquipments.class);
Collections.sort(indicatorsDtoList, (a, b) -> (b.getCreatedTime())
.compareTo(a.getCreatedTime()));
//过滤重复状态
List<ESEquipments> nindicatorsDtoList=indicatorsDtoList.stream().collect(Collectors.collectingAndThen(
Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(ESEquipments::getDisplayName))), ArrayList::new));
/**
* 汇流箱
*/
queryCondtion.remove(CommonConstans.QueryStringEquipmentIndexName);
queryCondtion.remove(CommonConstans.QueryStringValueKeyword);
queryCondtion.put(CommonConstans.QueryStringDataType, Arrays.asList("state"));
shouldCondtion.put(CommonConstans.QueryStringFrontMoudle, "汇流箱");
List<ESEquipments> indicatorsDtoListHLX = commonServiceImpl.getListDataByCondtions(queryCondtion,
shouldCondtion, ESEquipments.class);
/**
* 箱变
*/
shouldCondtion.put(CommonConstans.QueryStringFrontMoudle, "箱变");
List<ESEquipments> indicatorsDtoListXB = commonServiceImpl.getListDataByCondtions(queryCondtion,
shouldCondtion, ESEquipments.class);
nindicatorsDtoList.addAll(indicatorsDtoListHLX);
nindicatorsDtoList.addAll(indicatorsDtoListXB);
List<EquipAlarmEvent> newEquipAlarmEvents = new ArrayList<>();
List<EquipAlarmEvent> newEquipAlarmEvent = new ArrayList<>();
long time = new Date().getTime();
if (CollectionUtils.isNotEmpty(nindicatorsDtoList)) {
for (ESEquipments esEquipments : nindicatorsDtoList) {
EquipAlarmEvent equipAlarmEvent = new EquipAlarmEvent();
equipAlarmEvent.setEquipIndex(esEquipments.getEquipmentNumber());
equipAlarmEvent.setEquipName(esEquipments.getEquipmentSpecificName());
equipAlarmEvent.setAlarmDesc(AlarmDesc.getCode(esEquipments.getEquipmentIndexName()));
equipAlarmEvent.setAlarmDesc(
StringUtils.isEmpty(equipAlarmEvent.getAlarmDesc()) ? esEquipments.getEquipmentIndexName()
: equipAlarmEvent.getAlarmDesc());
equipAlarmEvent.setCreatedTime(esEquipments.getCreatedTime());
equipAlarmEvent.setGatewayId(stationBasic.getFanGatewayId());
equipAlarmEvent.setSort(time);
equipAlarmEvent.setFrontModule(esEquipments.getFrontModule());
equipAlarmEvent.setValue(esEquipments.getValue());
newEquipAlarmEvents.add(equipAlarmEvent);
newEquipAlarmEvent.add(equipAlarmEvent);
}
}
String lastSort = equipAlarmEventMapper.getLastDataBySort(stationBasic.getFanGatewayId());
if (null != lastSort) {
List<EquipAlarmEvent> oldEquipAlarmEvents = equipAlarmEventMapper.getOldDataBySort(lastSort,
stationBasic.getFanGatewayId());
for (EquipAlarmEvent oldEquipAlarmEvent : oldEquipAlarmEvents) {
for (EquipAlarmEvent equipAlarmEvent : newEquipAlarmEvents) {
if (oldEquipAlarmEvent.getEquipIndex().equals(equipAlarmEvent.getEquipIndex())
&& oldEquipAlarmEvent.getAlarmDesc().equals(equipAlarmEvent.getAlarmDesc())
&& oldEquipAlarmEvent.getValue().equals(equipAlarmEvent.getValue())) {
newEquipAlarmEvent.remove(equipAlarmEvent);
}
}
}
}
equipAlarmEventService.saveBatch(newEquipAlarmEvent);
}
}
// @Scheduled(cron = "0 */10 * * * ?")
// //@Scheduled(cron = "0/1 * * * * ?")
// public void addNbqAlarmEvent() {
//
// LambdaQueryWrapper<StationBasic> wrapper = new LambdaQueryWrapper<>();
// wrapper.eq(BaseEntity::getIsDelete, false);
// wrapper.like(StationBasic::getStationType, "GFDZ");
// List<StationBasic> stationBasics = stationBasicMapper.selectList(wrapper);
// for (StationBasic stationBasic : stationBasics) {
// Map<String, List<String>> queryCondtion = new HashMap<>();
// Map<String, String> shouldCondtion = new HashMap<>();
// queryCondtion.put(CommonConstans.QueryStringGateWayId, Arrays.asList(stationBasic.getFanGatewayId()));
// queryCondtion.put(CommonConstans.QueryStringEquipmentIndexName,
// Arrays.asList("待机", "停机", "告警运行", "限额运行", "降额运行", "故障停机", "通讯故障", "运行"));
// queryCondtion.put(CommonConstans.QueryStringValueKeyword, Arrays.asList("true"));
//
// /**
// * 逆变器
// */
// List<ESEquipments> indicatorsDtoList = commonServiceImpl.getListDataByCondtions(queryCondtion, null,
// ESEquipments.class);
// Collections.sort(indicatorsDtoList, (a, b) -> (b.getCreatedTime())
// .compareTo(a.getCreatedTime()));
//
// //过滤重复状态
// List<ESEquipments> nindicatorsDtoList=indicatorsDtoList.stream().collect(Collectors.collectingAndThen(
// Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(ESEquipments::getDisplayName))), ArrayList::new));
//
//
// /**
// * 汇流箱
// */
// queryCondtion.remove(CommonConstans.QueryStringEquipmentIndexName);
// queryCondtion.remove(CommonConstans.QueryStringValueKeyword);
// queryCondtion.put(CommonConstans.QueryStringDataType, Arrays.asList("state"));
// shouldCondtion.put(CommonConstans.QueryStringFrontMoudle, "汇流箱");
// List<ESEquipments> indicatorsDtoListHLX = commonServiceImpl.getListDataByCondtions(queryCondtion,
// shouldCondtion, ESEquipments.class);
// /**
// * 箱变
// */
// shouldCondtion.put(CommonConstans.QueryStringFrontMoudle, "箱变");
// List<ESEquipments> indicatorsDtoListXB = commonServiceImpl.getListDataByCondtions(queryCondtion,
// shouldCondtion, ESEquipments.class);
// nindicatorsDtoList.addAll(indicatorsDtoListHLX);
// nindicatorsDtoList.addAll(indicatorsDtoListXB);
//
// List<EquipAlarmEvent> newEquipAlarmEvents = new ArrayList<>();
// List<EquipAlarmEvent> newEquipAlarmEvent = new ArrayList<>();
// long time = new Date().getTime();
// if (CollectionUtils.isNotEmpty(nindicatorsDtoList)) {
// for (ESEquipments esEquipments : nindicatorsDtoList) {
// EquipAlarmEvent equipAlarmEvent = new EquipAlarmEvent();
// equipAlarmEvent.setEquipIndex(esEquipments.getEquipmentNumber());
// equipAlarmEvent.setEquipName(esEquipments.getEquipmentSpecificName());
// equipAlarmEvent.setAlarmDesc(AlarmDesc.getCode(esEquipments.getEquipmentIndexName()));
// equipAlarmEvent.setAlarmDesc(
// StringUtils.isEmpty(equipAlarmEvent.getAlarmDesc()) ? esEquipments.getEquipmentIndexName()
// : equipAlarmEvent.getAlarmDesc());
// equipAlarmEvent.setCreatedTime(esEquipments.getCreatedTime());
// equipAlarmEvent.setGatewayId(stationBasic.getFanGatewayId());
// equipAlarmEvent.setSort(time);
// equipAlarmEvent.setFrontModule(esEquipments.getFrontModule());
// equipAlarmEvent.setValue(esEquipments.getValue());
// newEquipAlarmEvents.add(equipAlarmEvent);
// newEquipAlarmEvent.add(equipAlarmEvent);
// }
// }
//
// String lastSort = equipAlarmEventMapper.getLastDataBySort(stationBasic.getFanGatewayId());
// if (null != lastSort) {
// List<EquipAlarmEvent> oldEquipAlarmEvents = equipAlarmEventMapper.getOldDataBySort(lastSort,
// stationBasic.getFanGatewayId());
// for (EquipAlarmEvent oldEquipAlarmEvent : oldEquipAlarmEvents) {
// for (EquipAlarmEvent equipAlarmEvent : newEquipAlarmEvents) {
// if (oldEquipAlarmEvent.getEquipIndex().equals(equipAlarmEvent.getEquipIndex())
// && oldEquipAlarmEvent.getAlarmDesc().equals(equipAlarmEvent.getAlarmDesc())
// && oldEquipAlarmEvent.getValue().equals(equipAlarmEvent.getValue())) {
// newEquipAlarmEvent.remove(equipAlarmEvent);
// }
// }
// }
// }
// equipAlarmEventService.saveBatch(newEquipAlarmEvent);
//
// }
// }
public HashMap<String, String> getPvNBQStationBy(String gatewayId) {
HashMap<String, String> result = new HashMap<>();
......
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