|
@@ -112,7 +112,7 @@ public class CauseJobHandler implements ApplicationRunner {
|
|
//风速
|
|
//风速
|
|
ArrayDeque<PointData> pointData = pdaqMap.get(pointCode);
|
|
ArrayDeque<PointData> pointData = pdaqMap.get(pointCode);
|
|
v = pointData.stream().mapToDouble(PointData::getDoubleValue).average().orElse(0);
|
|
v = pointData.stream().mapToDouble(PointData::getDoubleValue).average().orElse(0);
|
|
- if (System.currentTimeMillis()-pointData.getFirst().getTs()>5*60*1000) {
|
|
|
|
|
|
+ if (System.currentTimeMillis()-pointData.getFirst().getTs()>30*60*1000) {
|
|
//如果离线或者别的原因获取不到风速,从全场实时平均风速获取
|
|
//如果离线或者别的原因获取不到风速,从全场实时平均风速获取
|
|
Map<String, PointData> latest = adapterApi.getLatest(CacheContext.stationRealMeanSpeedMap.get(CacheContext.equipMap.get(entry.getKey()).getWindpowerstationId()));
|
|
Map<String, PointData> latest = adapterApi.getLatest(CacheContext.stationRealMeanSpeedMap.get(CacheContext.equipMap.get(entry.getKey()).getWindpowerstationId()));
|
|
Iterator<PointData> iterator = latest.values().iterator();
|
|
Iterator<PointData> iterator = latest.values().iterator();
|