Skip to content

A
amos-boot-biz
Commit 279588a9 authored by caotao's avatar caotao
Browse files
Options

移除定时发送风电站基础数据消息

parent 9c55e0d6
Hide whitespace changes
Inline Side-by-side
Showing with 59 additions and 59 deletions
amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/MonitoringServiceIMQTTmpl.java
View file @ 279588a9
...@@ -190,65 +190,65 @@ public class MonitoringServiceIMQTTmpl { ...@@ -190,65 +190,65 @@ public class MonitoringServiceIMQTTmpl {
/** /**
* 实时推送-风电站风场总概览 * 实时推送-风电站风场总概览
*/ */
@Scheduled(cron = fanstationOverviewCron) // @Scheduled(cron = fanstationOverviewCron)
public void getFanstationOverview() { // public void getFanstationOverview() {
List<StationBasic> stationBasicList = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("sequence_nbr").eq("station_type", "FDZ")); // List<StationBasic> stationBasicList = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("sequence_nbr").eq("station_type", "FDZ"));
stationBasicList.forEach(stationBasic -> { // stationBasicList.forEach(stationBasic -> {
String gatewayId = stationBasic.getFanGatewayId(); // String gatewayId = stationBasic.getFanGatewayId();
String[] sumColumns = new String[]{"日发电量", "月发电量", "年发电量"}; // String[] sumColumns = new String[]{"日发电量", "月发电量", "年发电量"};
String[] avgColumns = new String[]{"有功功率", "瞬时风速"}; // String[] avgColumns = new String[]{"有功功率", "瞬时风速"};
List<String> columnList = Arrays.asList(sumColumns); // List<String> columnList = Arrays.asList(sumColumns);
List<String> columnLists = Arrays.asList(avgColumns); // List<String> columnLists = Arrays.asList(avgColumns);
Map<String, Object> columnMap = new HashMap<>(); // Map<String, Object> columnMap = new HashMap<>();
for (String column : columnList) { // for (String column : columnList) {
Double result = commonService.getTotalByIndicatior(gatewayId, column); // Double result = commonService.getTotalByIndicatior(gatewayId, column);
columnMap.put(column, result); // columnMap.put(column, result);
} // }
for (String column : columnLists) { // for (String column : columnLists) {
Double result = commonService.getAvgvalueByIndicatior(gatewayId, column); // Double result = commonService.getAvgvalueByIndicatior(gatewayId, column);
columnMap.put(column, result); // columnMap.put(column, result);
} // }
String num = monitorFanIndicator.getFJCount(gatewayId); // String num = monitorFanIndicator.getFJCount(gatewayId);
columnMap.put("风机台数", num); // columnMap.put("风机台数", num);
Double capacityl = commonService.getStationCapactityByStationWerks(stationBasic.getStationNumber()); // Double capacityl = commonService.getStationCapactityByStationWerks(stationBasic.getStationNumber());
columnMap.put("装机容量", capacityl); // columnMap.put("装机容量", capacityl);
List<Map<String, Object>> objects = new ArrayList<>(); // List<Map<String, Object>> objects = new ArrayList<>();
Map<String, Object> data = new HashMap<>(); // Map<String, Object> data = new HashMap<>();
data.put("title", Float.valueOf(columnMap.get("装机容量").toString())); // data.put("title", Float.valueOf(columnMap.get("装机容量").toString()));
objects.add(data); // objects.add(data);
Map<String, Object> data1 = new HashMap<>(); // Map<String, Object> data1 = new HashMap<>();
data1.put("title", Float.valueOf(columnMap.get("日发电量").toString())); // data1.put("title", Float.valueOf(columnMap.get("日发电量").toString()));
objects.add(data1); // objects.add(data1);
Map<String, Object> data2 = new HashMap<>(); // Map<String, Object> data2 = new HashMap<>();
data2.put("title", columnMap.get("风机台数").toString().replace(".0", "")); // data2.put("title", columnMap.get("风机台数").toString().replace(".0", ""));
objects.add(data2); // objects.add(data2);
Map<String, Object> data3 = new HashMap<>(); // Map<String, Object> data3 = new HashMap<>();
data3.put("title", Float.valueOf(columnMap.get("月发电量").toString())); // data3.put("title", Float.valueOf(columnMap.get("月发电量").toString()));
objects.add(data3); // objects.add(data3);
Map<String, Object> data4 = new HashMap<>(); // Map<String, Object> data4 = new HashMap<>();
data4.put("title", Float.valueOf(columnMap.get("瞬时风速").toString())); // data4.put("title", Float.valueOf(columnMap.get("瞬时风速").toString()));
objects.add(data4); // objects.add(data4);
Map<String, Object> data5 = new HashMap<>(); // Map<String, Object> data5 = new HashMap<>();
data5.put("title", Float.valueOf(columnMap.get("年发电量").toString())); // data5.put("title", Float.valueOf(columnMap.get("年发电量").toString()));
objects.add(data5); // objects.add(data5);
Map<String, Object> data6 = new HashMap<>(); // Map<String, Object> data6 = new HashMap<>();
data6.put("title", Float.valueOf(columnMap.get("有功功率").toString())); // data6.put("title", Float.valueOf(columnMap.get("有功功率").toString()));
objects.add(data6); // objects.add(data6);
Map<String, Object> data7 = new HashMap<>(); // Map<String, Object> data7 = new HashMap<>();
data7.put("title", 0.00); // data7.put("title", 0.00);
objects.add(data7); // objects.add(data7);
IPage<Map<String, Object>> result = new Page<>(); // IPage<Map<String, Object>> result = new Page<>();
result.setRecords(objects); // result.setRecords(objects);
result.setCurrent(1); // result.setCurrent(1);
result.setTotal(objects.size()); // result.setTotal(objects.size());
try { // try {
emqKeeper.getMqttClient().publish(stationBasic.getSequenceNbr() + "_fanStationOverview_topic", JSON.toJSON(result).toString().getBytes("UTF-8"), 1, true); // emqKeeper.getMqttClient().publish(stationBasic.getSequenceNbr() + "_fanStationOverview_topic", JSON.toJSON(result).toString().getBytes("UTF-8"), 1, true);
logger.info("-----------------发送风电站总概览数据消息=================== 成功！" + JSON.toJSONString(result)); // logger.info("-----------------发送风电站总概览数据消息=================== 成功！" + JSON.toJSONString(result));
} catch (Exception exception) { // } catch (Exception exception) {
logger.error("-----------------发送风电站总概览数据消息=================== 失败！"); // logger.error("-----------------发送风电站总概览数据消息=================== 失败！");
} // }
}); // });
} // }
/** /**
* 实时推送-场站功率曲线总概览 * 实时推送-场站功率曲线总概览
......
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