|
@@ -1,7 +1,6 @@
|
|
|
package com.gyee.generation.service;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.gyee.common.contant.Contant;
|
|
|
import com.gyee.common.model.PointData;
|
|
|
import com.gyee.common.model.StringUtils;
|
|
@@ -9,7 +8,7 @@ import com.gyee.common.util.CommonUtils;
|
|
|
import com.gyee.common.util.DateUtils;
|
|
|
import com.gyee.generation.init.CacheContext;
|
|
|
import com.gyee.generation.model.auto.*;
|
|
|
-import com.gyee.generation.service.auto.IShutdowneventService;
|
|
|
+import com.gyee.generation.service.auto.IProEconShutdowneventService;
|
|
|
import com.gyee.generation.util.realtimesource.IEdosUtil;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
@@ -28,20 +27,20 @@ import java.util.stream.Collectors;
|
|
|
public class FiveLossesService {
|
|
|
@Resource
|
|
|
private IEdosUtil edosUtil;
|
|
|
- private List<Windturbine> wtls;
|
|
|
- private Map<String, Map<String, Windturbinetestingpointnew>> wtpAimap;
|
|
|
+ private List<ProBasicWindturbine> wtls;
|
|
|
+ private Map<String, Map<String, ProBasicEquipmentPoint>> wtpAimap;
|
|
|
private Date samedayZero;
|
|
|
private Date currentDate;
|
|
|
private Date tomorrow;
|
|
|
- private List<Windpowerstation> wpls;
|
|
|
- private Map<String, List<Project>> wppromap;
|
|
|
- private Map<String, List<Line>> prolinemap;
|
|
|
- private Map<String, List<Windturbine>> linewtmap;
|
|
|
- private Map<String, Map<String, Windpowerstationpointnew>> wppointmap;
|
|
|
- private Map<String, Map<String, Windpowerstationpointnew>> linepointmap;
|
|
|
- private Map<String, Map<String, Windpowerstationpointnew>> propointmap;
|
|
|
+ private List<ProBasicWindpowerstation> wpls;
|
|
|
+ private Map<String, List<ProBasicProject>> wppromap;
|
|
|
+ private Map<String, List<ProBasicLine>> prolinemap;
|
|
|
+ private Map<String, List<ProBasicWindturbine>> linewtmap;
|
|
|
+ private Map<String, Map<String, ProBasicWppoint>> wppointmap;
|
|
|
+ private Map<String, Map<String, ProBasicWppoint>> linepointmap;
|
|
|
+ private Map<String, Map<String, ProBasicWppoint>> propointmap;
|
|
|
@Resource
|
|
|
- private IShutdowneventService shutdowneventService;
|
|
|
+ private IProEconShutdowneventService proEconShutdowneventService;
|
|
|
|
|
|
private void init(){
|
|
|
wpls = CacheContext.wpls;
|
|
@@ -72,26 +71,26 @@ public class FiveLossesService {
|
|
|
public void saveShutdownevent(){
|
|
|
init();
|
|
|
List<PointData> resultList = new ArrayList<>();
|
|
|
- QueryWrapper<Shutdownevent> qw = new QueryWrapper<>();
|
|
|
+ QueryWrapper<ProEconShutdownevent> qw = new QueryWrapper<>();
|
|
|
qw.isNull("starttime");
|
|
|
qw.isNotNull("stoptime");
|
|
|
//查出有故障但没恢复的事件
|
|
|
- List<Shutdownevent> shutdownevents = shutdowneventService.list(qw);
|
|
|
+ List<ProEconShutdownevent> shutdownevents = proEconShutdowneventService.list(qw);
|
|
|
List<String> faultWinturbines = null;
|
|
|
List<String> mainWinturbines = null;
|
|
|
if (StringUtils.isNotEmpty(shutdownevents)){
|
|
|
- faultWinturbines = shutdownevents.stream().filter(i->i.getStatuscode()==2).map(s -> s.getWindturbineid()).collect(Collectors.toList());
|
|
|
- mainWinturbines = shutdownevents.stream().filter(i->i.getStatuscode()==4).map(s -> s.getWindturbineid()).collect(Collectors.toList());
|
|
|
+ faultWinturbines = shutdownevents.stream().filter(i->i.getStatusCode()==2).map(s -> s.getWindturbineId()).collect(Collectors.toList());
|
|
|
+ mainWinturbines = shutdownevents.stream().filter(i->i.getStatusCode()==4).map(s -> s.getWindturbineId()).collect(Collectors.toList());
|
|
|
}
|
|
|
|
|
|
List<String> finalFaultWinturbines = faultWinturbines;
|
|
|
List<String> finalMainWinturbines = mainWinturbines;
|
|
|
wtls.stream().forEach(wt->{
|
|
|
- Map<String, Windturbinetestingpointnew> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
- Windturbinetestingpointnew ztmxPoint = windturbinetestingpointnewMap.get(Contant.ZTMX);
|
|
|
- Windturbinetestingpointnew bzglPoint = windturbinetestingpointnewMap.get(Contant.BZGL);
|
|
|
- Windturbinetestingpointnew zsglPoint = windturbinetestingpointnewMap.get(Contant.ZSGL);
|
|
|
- Windturbinetestingpointnew powerPoint = windturbinetestingpointnewMap.get(Contant.AI130);
|
|
|
+ Map<String, ProBasicEquipmentPoint> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
+ ProBasicEquipmentPoint ztmxPoint = windturbinetestingpointnewMap.get(Contant.ZTMX);
|
|
|
+ ProBasicEquipmentPoint bzglPoint = windturbinetestingpointnewMap.get(Contant.BZGL);
|
|
|
+ ProBasicEquipmentPoint zsglPoint = windturbinetestingpointnewMap.get(Contant.ZSGL);
|
|
|
+ ProBasicEquipmentPoint powerPoint = windturbinetestingpointnewMap.get(Contant.AI130);
|
|
|
PointData sectionData = null;
|
|
|
try {
|
|
|
sectionData = edosUtil.getSectionData(ztmxPoint, tomorrow.getTime());
|
|
@@ -102,14 +101,14 @@ public class FiveLossesService {
|
|
|
if (StringUtils.isNotEmpty(finalFaultWinturbines) && finalFaultWinturbines.contains(wt.getId())){ //此风机在之前故障未恢复列表
|
|
|
if (fjzt!=6){
|
|
|
//将时间存储到结束时间,算时间与电量
|
|
|
- Optional<Shutdownevent> first = shutdownevents.stream().filter(i -> i.getWindturbineid().equals(wt.getId())).findFirst();
|
|
|
+ Optional<ProEconShutdownevent> first = shutdownevents.stream().filter(i -> i.getWindturbineId().equals(wt.getId())).findFirst();
|
|
|
if (first.isPresent()){
|
|
|
- Shutdownevent shutdownevent = first.get();
|
|
|
+ ProEconShutdownevent shutdownevent = first.get();
|
|
|
Date starttime = DateUtils.parseLongToDate(sectionData.getPointTime()*1000);
|
|
|
- shutdownevent.setStarttime(starttime);
|
|
|
- Date stoptime = shutdownevent.getStoptime();
|
|
|
+ shutdownevent.setStartTime(starttime);
|
|
|
+ Date stoptime = shutdownevent.getStopTime();
|
|
|
double hour = DateUtils.hoursDiff2(stoptime, starttime);
|
|
|
- shutdownevent.setStophours(hour);
|
|
|
+ shutdownevent.setStopHours(hour);
|
|
|
|
|
|
List<PointData> ztmxDatasSnap = null;
|
|
|
List<PointData> bzglDatasSnap = null;
|
|
@@ -128,33 +127,33 @@ public class FiveLossesService {
|
|
|
double gzss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 6.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRGZSSDL));
|
|
|
shutdownevent.setLosspower(gzss);
|
|
|
}
|
|
|
- shutdowneventService.saveOrUpdate(shutdownevent);
|
|
|
+ proEconShutdowneventService.saveOrUpdate(shutdownevent);
|
|
|
}
|
|
|
}
|
|
|
if (fjzt==8){
|
|
|
- Shutdownevent shutdownevent = new Shutdownevent();
|
|
|
+ ProEconShutdownevent shutdownevent = new ProEconShutdownevent();
|
|
|
shutdownevent.setId(CommonUtils.getUUID());
|
|
|
- shutdownevent.setWindpowerstationid(wt.getWindpowerstationid());
|
|
|
- shutdownevent.setWindturbineid(wt.getId());
|
|
|
+ shutdownevent.setWindpowerstationId(wt.getWindpowerstationId());
|
|
|
+ shutdownevent.setWindturbineId(wt.getId());
|
|
|
Date date = DateUtils.parseLongToDate(sectionData.getPointTime()*1000);
|
|
|
- shutdownevent.setStoptime(date);
|
|
|
- shutdownevent.setProjectid(wt.getProjectid());
|
|
|
- shutdownevent.setStatuscode(4);
|
|
|
- shutdowneventService.save(shutdownevent);
|
|
|
+ shutdownevent.setStopTime(date);
|
|
|
+ shutdownevent.setProjectId(wt.getProjectId());
|
|
|
+ shutdownevent.setStatusCode(4);
|
|
|
+ proEconShutdowneventService.save(shutdownevent);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
else if (StringUtils.isNotEmpty(finalMainWinturbines) && finalMainWinturbines.contains(wt.getId())){ //此风机在之前故障未恢复列表
|
|
|
if (fjzt!=8){
|
|
|
//将时间存储到结束时间,算时间与电量
|
|
|
- Optional<Shutdownevent> first = shutdownevents.stream().filter(i -> i.getWindturbineid().equals(wt.getId())).findFirst();
|
|
|
+ Optional<ProEconShutdownevent> first = shutdownevents.stream().filter(i -> i.getWindturbineId().equals(wt.getId())).findFirst();
|
|
|
if (first.isPresent()){
|
|
|
- Shutdownevent shutdownevent = first.get();
|
|
|
+ ProEconShutdownevent shutdownevent = first.get();
|
|
|
Date starttime = DateUtils.parseLongToDate(sectionData.getPointTime()*1000);
|
|
|
- shutdownevent.setStarttime(starttime);
|
|
|
- Date stoptime = shutdownevent.getStoptime();
|
|
|
+ shutdownevent.setStartTime(starttime);
|
|
|
+ Date stoptime = shutdownevent.getStopTime();
|
|
|
double hour = DateUtils.hoursDiff2(stoptime, starttime);
|
|
|
- shutdownevent.setStophours(hour);
|
|
|
+ shutdownevent.setStopHours(hour);
|
|
|
|
|
|
List<PointData> ztmxDatasSnap = null;
|
|
|
List<PointData> bzglDatasSnap = null;
|
|
@@ -173,37 +172,37 @@ public class FiveLossesService {
|
|
|
double jxss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 8.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRJXSSDL));
|
|
|
shutdownevent.setLosspower(jxss);
|
|
|
}
|
|
|
- shutdowneventService.saveOrUpdate(shutdownevent);
|
|
|
+ proEconShutdowneventService.saveOrUpdate(shutdownevent);
|
|
|
}
|
|
|
}
|
|
|
if (fjzt==6){
|
|
|
- Shutdownevent shutdownevent = new Shutdownevent();
|
|
|
+ ProEconShutdownevent shutdownevent = new ProEconShutdownevent();
|
|
|
shutdownevent.setId(CommonUtils.getUUID());
|
|
|
- shutdownevent.setWindpowerstationid(wt.getWindpowerstationid());
|
|
|
- shutdownevent.setWindturbineid(wt.getId());
|
|
|
+ shutdownevent.setWindpowerstationId(wt.getWindpowerstationId());
|
|
|
+ shutdownevent.setWindturbineId(wt.getId());
|
|
|
Date date = DateUtils.parseLongToDate(sectionData.getPointTime()*1000);
|
|
|
- shutdownevent.setStoptime(date);
|
|
|
- shutdownevent.setProjectid(wt.getProjectid());
|
|
|
- shutdownevent.setStatuscode(2);
|
|
|
- shutdowneventService.save(shutdownevent);
|
|
|
+ shutdownevent.setStopTime(date);
|
|
|
+ shutdownevent.setProjectId(wt.getProjectId());
|
|
|
+ shutdownevent.setStatusCode(2);
|
|
|
+ proEconShutdowneventService.save(shutdownevent);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
else { //没有没结束的故障维护事件
|
|
|
if (fjzt==6 || fjzt==8){
|
|
|
- Shutdownevent shutdownevent = new Shutdownevent();
|
|
|
+ ProEconShutdownevent shutdownevent = new ProEconShutdownevent();
|
|
|
shutdownevent.setId(CommonUtils.getUUID());
|
|
|
- shutdownevent.setWindpowerstationid(wt.getWindpowerstationid());
|
|
|
- shutdownevent.setWindturbineid(wt.getId());
|
|
|
+ shutdownevent.setWindpowerstationId(wt.getWindpowerstationId());
|
|
|
+ shutdownevent.setWindturbineId(wt.getId());
|
|
|
Date date = DateUtils.parseLongToDate(sectionData.getPointTime()*1000);
|
|
|
- shutdownevent.setStoptime(date);
|
|
|
- shutdownevent.setProjectid(wt.getProjectid());
|
|
|
+ shutdownevent.setStopTime(date);
|
|
|
+ shutdownevent.setProjectId(wt.getProjectId());
|
|
|
if (fjzt == 6){
|
|
|
- shutdownevent.setStatuscode(2);
|
|
|
+ shutdownevent.setStatusCode(2);
|
|
|
}else {
|
|
|
- shutdownevent.setStatuscode(4);
|
|
|
+ shutdownevent.setStatusCode(4);
|
|
|
}
|
|
|
- shutdowneventService.save(shutdownevent);
|
|
|
+ proEconShutdowneventService.save(shutdownevent);
|
|
|
}
|
|
|
}
|
|
|
});
|
|
@@ -215,8 +214,8 @@ public class FiveLossesService {
|
|
|
private void wpDaylossesReal() throws Exception {
|
|
|
List<PointData> resultList = new ArrayList<>();
|
|
|
wpls.stream().forEach(wp->{
|
|
|
- List<Project> projects = wppromap.get(wp.getId());
|
|
|
- Map<String, Windpowerstationpointnew> wppointnewMap = wppointmap.get(wp.getId());
|
|
|
+ List<ProBasicProject> projects = wppromap.get(wp.getId());
|
|
|
+ Map<String, ProBasicWppoint> wppointnewMap = wppointmap.get(wp.getId());
|
|
|
AtomicReference<Double> wpdaydjloss = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> wpmonthdjloss = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> wpyeardjloss = new AtomicReference<>(0.0);
|
|
@@ -259,8 +258,8 @@ public class FiveLossesService {
|
|
|
AtomicReference<Double> wpdayqf3 = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> wpdayqf4= new AtomicReference<>(0.0);
|
|
|
projects.stream().forEach(project -> {
|
|
|
- List<Line> lines = prolinemap.get(project.getId());
|
|
|
- Map<String, Windpowerstationpointnew> projectpointnewMap = propointmap.get(project.getId());
|
|
|
+ List<ProBasicLine> lines = prolinemap.get(project.getId());
|
|
|
+ Map<String, ProBasicWppoint> projectpointnewMap = propointmap.get(project.getId());
|
|
|
AtomicReference<Double> projectdaydjloss = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> projectmonthdjloss = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> projectyeardjloss = new AtomicReference<>(0.0);
|
|
@@ -303,8 +302,8 @@ public class FiveLossesService {
|
|
|
AtomicReference<Double> projectdayqf3 = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> projectdayqf4 = new AtomicReference<>(0.0);
|
|
|
lines.stream().forEach(line -> {
|
|
|
- List<Windturbine> windturbines = linewtmap.get(line.getId());
|
|
|
- Map<String, Windpowerstationpointnew> linepointnewMap = linepointmap.get(line.getId());
|
|
|
+ List<ProBasicWindturbine> windturbines = linewtmap.get(line.getId());
|
|
|
+ Map<String, ProBasicWppoint> linepointnewMap = linepointmap.get(line.getId());
|
|
|
AtomicReference<Double> linedaydjloss = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> linemonthdjloss = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> lineyeardjloss = new AtomicReference<>(0.0);
|
|
@@ -347,73 +346,73 @@ public class FiveLossesService {
|
|
|
AtomicReference<Double> linedayqf3 = new AtomicReference<>(0.0);
|
|
|
AtomicReference<Double> linedayqf4 = new AtomicReference<>(0.0);
|
|
|
windturbines.stream().forEach(wt->{
|
|
|
- Map<String, Windturbinetestingpointnew> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
+ Map<String, ProBasicEquipmentPoint> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
//待机
|
|
|
- Windturbinetestingpointnew dayDjPoint = windturbinetestingpointnewMap.get(Contant.WTRDJSSDL);
|
|
|
- Windturbinetestingpointnew monthDjPoint = windturbinetestingpointnewMap.get(Contant.WTYDJSSDL);
|
|
|
- Windturbinetestingpointnew yearDjPoint = windturbinetestingpointnewMap.get(Contant.WTNDJSSDL);
|
|
|
+ ProBasicEquipmentPoint dayDjPoint = windturbinetestingpointnewMap.get(Contant.WTRDJSSDL);
|
|
|
+ ProBasicEquipmentPoint monthDjPoint = windturbinetestingpointnewMap.get(Contant.WTYDJSSDL);
|
|
|
+ ProBasicEquipmentPoint yearDjPoint = windturbinetestingpointnewMap.get(Contant.WTNDJSSDL);
|
|
|
geneLineloss(linedaydjloss, linemonthdjloss, lineyeardjloss, dayDjPoint, monthDjPoint, yearDjPoint);
|
|
|
//手动停机
|
|
|
- Windturbinetestingpointnew daySdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRSTSSDL);
|
|
|
- Windturbinetestingpointnew monthSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYSTSSDL);
|
|
|
- Windturbinetestingpointnew yearSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNSTSSDL);
|
|
|
+ ProBasicEquipmentPoint daySdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRSTSSDL);
|
|
|
+ ProBasicEquipmentPoint monthSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYSTSSDL);
|
|
|
+ ProBasicEquipmentPoint yearSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNSTSSDL);
|
|
|
geneLineloss(linedaysdtjloss, linemonthsdtjloss, lineyearsdtjloss, daySdtjPoint, monthSdtjPoint, yearSdtjPoint);
|
|
|
//性能
|
|
|
- Windturbinetestingpointnew dayXnPoint = windturbinetestingpointnewMap.get(Contant.WTRXNSSDL);
|
|
|
- Windturbinetestingpointnew monthXnPoint = windturbinetestingpointnewMap.get(Contant.WTYXNSSDL);
|
|
|
- Windturbinetestingpointnew yearXnPoint = windturbinetestingpointnewMap.get(Contant.WTNXNSSDL);
|
|
|
+ ProBasicEquipmentPoint dayXnPoint = windturbinetestingpointnewMap.get(Contant.WTRXNSSDL);
|
|
|
+ ProBasicEquipmentPoint monthXnPoint = windturbinetestingpointnewMap.get(Contant.WTYXNSSDL);
|
|
|
+ ProBasicEquipmentPoint yearXnPoint = windturbinetestingpointnewMap.get(Contant.WTNXNSSDL);
|
|
|
geneLineloss(linedayxnloss, linemonthxnloss, lineyearxnloss, dayXnPoint, monthXnPoint, yearXnPoint);
|
|
|
//发电降出力
|
|
|
- Windturbinetestingpointnew dayFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQXSSDL);
|
|
|
- Windturbinetestingpointnew monthFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQXSSDL);
|
|
|
- Windturbinetestingpointnew yearFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQXSSDL);
|
|
|
+ ProBasicEquipmentPoint dayFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQXSSDL);
|
|
|
+ ProBasicEquipmentPoint monthFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQXSSDL);
|
|
|
+ ProBasicEquipmentPoint yearFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQXSSDL);
|
|
|
geneLineloss(linedayfdjclloss, linemonthfdjclloss, lineyearfdjclloss, dayFdjclPoint, monthFdjclPoint, yearFdjclPoint);
|
|
|
//故障
|
|
|
- Windturbinetestingpointnew dayGzPoint = windturbinetestingpointnewMap.get(Contant.WTRGZSSDL);
|
|
|
- Windturbinetestingpointnew monthGzPoint = windturbinetestingpointnewMap.get(Contant.WTYGZSSDL);
|
|
|
- Windturbinetestingpointnew yearGzPoint = windturbinetestingpointnewMap.get(Contant.WTNGZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayGzPoint = windturbinetestingpointnewMap.get(Contant.WTRGZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthGzPoint = windturbinetestingpointnewMap.get(Contant.WTYGZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearGzPoint = windturbinetestingpointnewMap.get(Contant.WTNGZSSDL);
|
|
|
geneLineloss(linedaygzloss, linemonthgzloss, lineyeargzloss, dayGzPoint, monthGzPoint, yearGzPoint);
|
|
|
//故障受累
|
|
|
- Windturbinetestingpointnew dayGzslPoint = windturbinetestingpointnewMap.get(Contant.WTRSZSSDL);
|
|
|
- Windturbinetestingpointnew monthGzslPoint = windturbinetestingpointnewMap.get(Contant.WTYSZSSDL);
|
|
|
- Windturbinetestingpointnew yearGzslPoint = windturbinetestingpointnewMap.get(Contant.WTNSZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayGzslPoint = windturbinetestingpointnewMap.get(Contant.WTRSZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthGzslPoint = windturbinetestingpointnewMap.get(Contant.WTYSZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearGzslPoint = windturbinetestingpointnewMap.get(Contant.WTNSZSSDL);
|
|
|
geneLineloss(linedaygzslloss, linemonthgzslloss, lineyeargzslloss, dayGzslPoint, monthGzslPoint, yearGzslPoint);
|
|
|
//维护
|
|
|
- Windturbinetestingpointnew dayWhPoint = windturbinetestingpointnewMap.get(Contant.WTRJXSSDL);
|
|
|
- Windturbinetestingpointnew monthWhPoint = windturbinetestingpointnewMap.get(Contant.WTYJXSSDL);
|
|
|
- Windturbinetestingpointnew yearWhPoint = windturbinetestingpointnewMap.get(Contant.WTNJXSSDL);
|
|
|
+ ProBasicEquipmentPoint dayWhPoint = windturbinetestingpointnewMap.get(Contant.WTRJXSSDL);
|
|
|
+ ProBasicEquipmentPoint monthWhPoint = windturbinetestingpointnewMap.get(Contant.WTYJXSSDL);
|
|
|
+ ProBasicEquipmentPoint yearWhPoint = windturbinetestingpointnewMap.get(Contant.WTNJXSSDL);
|
|
|
geneLineloss(linedaywhloss, linemonthwhloss, lineyearwhloss, dayWhPoint, monthWhPoint, yearWhPoint);
|
|
|
//维护受累
|
|
|
- Windturbinetestingpointnew dayWhslPoint = windturbinetestingpointnewMap.get(Contant.WTRLZSSDL);
|
|
|
- Windturbinetestingpointnew monthWhslPoint = windturbinetestingpointnewMap.get(Contant.WTYLZSSDL);
|
|
|
- Windturbinetestingpointnew yearWhslPoint = windturbinetestingpointnewMap.get(Contant.WTNLZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayWhslPoint = windturbinetestingpointnewMap.get(Contant.WTRLZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthWhslPoint = windturbinetestingpointnewMap.get(Contant.WTYLZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearWhslPoint = windturbinetestingpointnewMap.get(Contant.WTNLZSSDL);
|
|
|
geneLineloss(linedaywhslloss, linemonthwhslloss, lineyearwhslloss, dayWhslPoint, monthWhslPoint, yearWhslPoint);
|
|
|
//限电降出力
|
|
|
- Windturbinetestingpointnew dayXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQFSSDL);
|
|
|
- Windturbinetestingpointnew monthXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQFSSDL);
|
|
|
- Windturbinetestingpointnew yearXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQFSSDL);
|
|
|
+ ProBasicEquipmentPoint dayXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQFSSDL);
|
|
|
+ ProBasicEquipmentPoint monthXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQFSSDL);
|
|
|
+ ProBasicEquipmentPoint yearXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQFSSDL);
|
|
|
geneLineloss(linedayxdjclloss, linemonthxdjclloss, lineyearxdjclloss, dayXdjclPoint, monthXdjclPoint, yearXdjclPoint);
|
|
|
//限电停机
|
|
|
- Windturbinetestingpointnew dayXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRXDSSDL);
|
|
|
- Windturbinetestingpointnew monthXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYXDSSDL);
|
|
|
- Windturbinetestingpointnew yearXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNXDSSDL);
|
|
|
+ ProBasicEquipmentPoint dayXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRXDSSDL);
|
|
|
+ ProBasicEquipmentPoint monthXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYXDSSDL);
|
|
|
+ ProBasicEquipmentPoint yearXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNXDSSDL);
|
|
|
geneLineloss(linedayxdtjloss, linemonthxdtjloss, lineyearxdtjloss, dayXdtjPoint, monthXdtjPoint, yearXdtjPoint);
|
|
|
//电网受累
|
|
|
- Windturbinetestingpointnew dayDwslPoint = windturbinetestingpointnewMap.get(Contant.WTRWZSSDL);
|
|
|
- Windturbinetestingpointnew monthDwslPoint = windturbinetestingpointnewMap.get(Contant.WTYWZSSDL);
|
|
|
- Windturbinetestingpointnew yearDwslPoint = windturbinetestingpointnewMap.get(Contant.WTNWZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayDwslPoint = windturbinetestingpointnewMap.get(Contant.WTRWZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthDwslPoint = windturbinetestingpointnewMap.get(Contant.WTYWZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearDwslPoint = windturbinetestingpointnewMap.get(Contant.WTNWZSSDL);
|
|
|
geneLineloss(linedaydwslloss, linemonthdwslloss, lineyeardwslloss, dayDwslPoint, monthDwslPoint, yearDwslPoint);
|
|
|
//环境受累
|
|
|
- Windturbinetestingpointnew dayHjslPoint = windturbinetestingpointnewMap.get(Contant.WTRTZSSDL);
|
|
|
- Windturbinetestingpointnew monthHjslPoint = windturbinetestingpointnewMap.get(Contant.WTYTZSSDL);
|
|
|
- Windturbinetestingpointnew yearHjslPoint = windturbinetestingpointnewMap.get(Contant.WTNTZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayHjslPoint = windturbinetestingpointnewMap.get(Contant.WTRTZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthHjslPoint = windturbinetestingpointnewMap.get(Contant.WTYTZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearHjslPoint = windturbinetestingpointnewMap.get(Contant.WTNTZSSDL);
|
|
|
geneLineloss(linedayhjslloss, linemonthhjslloss, lineyearhjslloss, dayHjslPoint, monthHjslPoint, yearHjslPoint);
|
|
|
//欠发发电量
|
|
|
- Windturbinetestingpointnew dayqf0 = windturbinetestingpointnewMap.get(Contant.R0QFZT);
|
|
|
- Windturbinetestingpointnew dayqf1 = windturbinetestingpointnewMap.get(Contant.R1QFZT);
|
|
|
- Windturbinetestingpointnew dayqf2 = windturbinetestingpointnewMap.get(Contant.R2QFZT);
|
|
|
- Windturbinetestingpointnew dayqf3 = windturbinetestingpointnewMap.get(Contant.R3QFZT);
|
|
|
- Windturbinetestingpointnew dayqf4 = windturbinetestingpointnewMap.get(Contant.R4QFZT);
|
|
|
+ ProBasicEquipmentPoint dayqf0 = windturbinetestingpointnewMap.get(Contant.R0QFZT);
|
|
|
+ ProBasicEquipmentPoint dayqf1 = windturbinetestingpointnewMap.get(Contant.R1QFZT);
|
|
|
+ ProBasicEquipmentPoint dayqf2 = windturbinetestingpointnewMap.get(Contant.R2QFZT);
|
|
|
+ ProBasicEquipmentPoint dayqf3 = windturbinetestingpointnewMap.get(Contant.R3QFZT);
|
|
|
+ ProBasicEquipmentPoint dayqf4 = windturbinetestingpointnewMap.get(Contant.R4QFZT);
|
|
|
geneLineQfloss(linedayqf0, linedayqf1, linedayqf2,linedayqf3,linedayqf4, dayqf0, dayqf1, dayqf2,dayqf3,dayqf4);
|
|
|
});
|
|
|
//待机
|
|
@@ -716,7 +715,7 @@ public class FiveLossesService {
|
|
|
edosUtil.sendMultiPoint(resultList);
|
|
|
}
|
|
|
|
|
|
- private void geneLineQfloss(AtomicReference<Double> linedayqf0, AtomicReference<Double> linedayqf1, AtomicReference<Double> linedayqf2, AtomicReference<Double> linedayqf3, AtomicReference<Double> linedayqf4, Windturbinetestingpointnew dayqf0, Windturbinetestingpointnew dayqf1, Windturbinetestingpointnew dayqf2, Windturbinetestingpointnew dayqf3, Windturbinetestingpointnew dayqf4) {
|
|
|
+ private void geneLineQfloss(AtomicReference<Double> linedayqf0, AtomicReference<Double> linedayqf1, AtomicReference<Double> linedayqf2, AtomicReference<Double> linedayqf3, AtomicReference<Double> linedayqf4, ProBasicEquipmentPoint dayqf0, ProBasicEquipmentPoint dayqf1, ProBasicEquipmentPoint dayqf2, ProBasicEquipmentPoint dayqf3, ProBasicEquipmentPoint dayqf4) {
|
|
|
double wtdayqf0 = 0.0;
|
|
|
double wtdayqf1 = 0.0;
|
|
|
double wtdayqf2 = 0.0;
|
|
@@ -744,13 +743,13 @@ public class FiveLossesService {
|
|
|
|
|
|
}
|
|
|
|
|
|
- private void addWpPoint(List<PointData> resultList, Windpowerstationpointnew pointnew, AtomicReference<Double> linedaydjloss) {
|
|
|
+ private void addWpPoint(List<PointData> resultList, ProBasicWppoint pointnew, AtomicReference<Double> linedaydjloss) {
|
|
|
PointData wpPointData = createWpPointData(pointnew, linedaydjloss.get());
|
|
|
resultList.add(wpPointData);
|
|
|
}
|
|
|
|
|
|
|
|
|
- private void geneLineloss(AtomicReference<Double> linedaydjloss, AtomicReference<Double> linemonthdjloss, AtomicReference<Double> lineyeardjloss, Windturbinetestingpointnew dayDjPoint, Windturbinetestingpointnew monthDjPoint, Windturbinetestingpointnew yearDjPoint) {
|
|
|
+ private void geneLineloss(AtomicReference<Double> linedaydjloss, AtomicReference<Double> linemonthdjloss, AtomicReference<Double> lineyeardjloss, ProBasicEquipmentPoint dayDjPoint, ProBasicEquipmentPoint monthDjPoint, ProBasicEquipmentPoint yearDjPoint) {
|
|
|
double wtdaydj = 0.0;
|
|
|
double wtmonthdj = 0.0;
|
|
|
double wtyeardj = 0.0;
|
|
@@ -776,12 +775,12 @@ public class FiveLossesService {
|
|
|
private void wtDaylossesReal() throws Exception {
|
|
|
List<PointData> resultList = new ArrayList<>();
|
|
|
wtls.stream().forEach(wt->{
|
|
|
- Map<String, Windturbinetestingpointnew> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
- Windturbinetestingpointnew powerPoint = windturbinetestingpointnewMap.get(Contant.AI130);
|
|
|
- Windturbinetestingpointnew ztmxPoint = windturbinetestingpointnewMap.get(Contant.ZTMX);
|
|
|
- Windturbinetestingpointnew bzglPoint = windturbinetestingpointnewMap.get(Contant.BZGL);
|
|
|
- Windturbinetestingpointnew zsglPoint = windturbinetestingpointnewMap.get(Contant.ZSGL);
|
|
|
- Windturbinetestingpointnew qfztPoint = windturbinetestingpointnewMap.get(Contant.RSSQFZT);
|
|
|
+ Map<String, ProBasicEquipmentPoint> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
+ ProBasicEquipmentPoint powerPoint = windturbinetestingpointnewMap.get(Contant.AI130);
|
|
|
+ ProBasicEquipmentPoint ztmxPoint = windturbinetestingpointnewMap.get(Contant.ZTMX);
|
|
|
+ ProBasicEquipmentPoint bzglPoint = windturbinetestingpointnewMap.get(Contant.BZGL);
|
|
|
+ ProBasicEquipmentPoint zsglPoint = windturbinetestingpointnewMap.get(Contant.ZSGL);
|
|
|
+ ProBasicEquipmentPoint qfztPoint = windturbinetestingpointnewMap.get(Contant.RSSQFZT);
|
|
|
List<PointData> powerDatasSnap = null;
|
|
|
List<PointData> ztmxDatasSnap = null;
|
|
|
List<PointData> bzglDatasSnap = null;
|
|
@@ -855,7 +854,7 @@ public class FiveLossesService {
|
|
|
edosUtil.sendMultiPoint(resultList);
|
|
|
}
|
|
|
|
|
|
- private double generalQfss(List<PointData> ztmxDatasSnap, List<PointData> bzglDatasSnap, List<PointData> zsglDatasSnap, List<PointData> powerDatasSnap,Double statusValue,List<PointData> resultList,Windturbinetestingpointnew point) {
|
|
|
+ private double generalQfss(List<PointData> ztmxDatasSnap, List<PointData> bzglDatasSnap, List<PointData> zsglDatasSnap, List<PointData> powerDatasSnap,Double statusValue,List<PointData> resultList,ProBasicEquipmentPoint point) {
|
|
|
List<PointData> pointDataList = ztmxDatasSnap.stream().filter(zt -> zt.getPointValueInDouble() == statusValue).collect(Collectors.toList());
|
|
|
Double bzss = 0.0;
|
|
|
Double zsss = 0.0;
|
|
@@ -889,7 +888,7 @@ public class FiveLossesService {
|
|
|
}
|
|
|
|
|
|
|
|
|
- private void generalQfzt(List<PointData> powerDatasSnap, List<PointData> ztmxDatasSnap, List<PointData> zsglDatasSnap,Windturbinetestingpointnew qfztPoint,List<PointData> resultList) {
|
|
|
+ private void generalQfzt(List<PointData> powerDatasSnap, List<PointData> ztmxDatasSnap, List<PointData> zsglDatasSnap,ProBasicEquipmentPoint qfztPoint,List<PointData> resultList) {
|
|
|
double zs = 0;
|
|
|
double pp = 0;
|
|
|
int i = 1;
|
|
@@ -925,7 +924,7 @@ public class FiveLossesService {
|
|
|
}
|
|
|
|
|
|
|
|
|
- private PointData createWpPointData(Windpowerstationpointnew linepointnew, double linespeed) {
|
|
|
+ private PointData createWpPointData(ProBasicWppoint linepointnew, double linespeed) {
|
|
|
PointData pointData = new PointData();
|
|
|
pointData.setEdnaId(linepointnew.getCode());
|
|
|
pointData.setPointTime(currentDate.getTime());
|
|
@@ -944,77 +943,77 @@ public class FiveLossesService {
|
|
|
boolean firstDayOfMonth = DateUtils.isFirstDayOfMonth(currentDate);
|
|
|
boolean firstDayOfYear = DateUtils.isFirstDayOfYear(currentDate);
|
|
|
wtls.stream().forEach(wt->{
|
|
|
- Map<String, Windturbinetestingpointnew> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
+ Map<String, ProBasicEquipmentPoint> windturbinetestingpointnewMap = wtpAimap.get(wt.getId());
|
|
|
//待机
|
|
|
- Windturbinetestingpointnew dayDjPoint = windturbinetestingpointnewMap.get(Contant.WTRDJSSDL);
|
|
|
- Windturbinetestingpointnew monthDjPoint = windturbinetestingpointnewMap.get(Contant.WTYDJSSDL);
|
|
|
- Windturbinetestingpointnew yearDjPoint = windturbinetestingpointnewMap.get(Contant.WTNDJSSDL);
|
|
|
+ ProBasicEquipmentPoint dayDjPoint = windturbinetestingpointnewMap.get(Contant.WTRDJSSDL);
|
|
|
+ ProBasicEquipmentPoint monthDjPoint = windturbinetestingpointnewMap.get(Contant.WTYDJSSDL);
|
|
|
+ ProBasicEquipmentPoint yearDjPoint = windturbinetestingpointnewMap.get(Contant.WTNDJSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayDjPoint,monthDjPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayDjPoint,yearDjPoint,firstDayOfYear);
|
|
|
//手动停机
|
|
|
- Windturbinetestingpointnew daySdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRSTSSDL);
|
|
|
- Windturbinetestingpointnew monthSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYSTSSDL);
|
|
|
- Windturbinetestingpointnew yearSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNSTSSDL);
|
|
|
+ ProBasicEquipmentPoint daySdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRSTSSDL);
|
|
|
+ ProBasicEquipmentPoint monthSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYSTSSDL);
|
|
|
+ ProBasicEquipmentPoint yearSdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNSTSSDL);
|
|
|
geneMonthOrYearLoss(resultList, daySdtjPoint,monthSdtjPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, daySdtjPoint,yearSdtjPoint,firstDayOfYear);
|
|
|
//性能
|
|
|
- Windturbinetestingpointnew dayXnPoint = windturbinetestingpointnewMap.get(Contant.WTRXNSSDL);
|
|
|
- Windturbinetestingpointnew monthXnPoint = windturbinetestingpointnewMap.get(Contant.WTYXNSSDL);
|
|
|
- Windturbinetestingpointnew yearXnPoint = windturbinetestingpointnewMap.get(Contant.WTNXNSSDL);
|
|
|
+ ProBasicEquipmentPoint dayXnPoint = windturbinetestingpointnewMap.get(Contant.WTRXNSSDL);
|
|
|
+ ProBasicEquipmentPoint monthXnPoint = windturbinetestingpointnewMap.get(Contant.WTYXNSSDL);
|
|
|
+ ProBasicEquipmentPoint yearXnPoint = windturbinetestingpointnewMap.get(Contant.WTNXNSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayXnPoint,monthXnPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayXnPoint,yearXnPoint,firstDayOfYear);
|
|
|
//发电降出力
|
|
|
- Windturbinetestingpointnew dayFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQXSSDL);
|
|
|
- Windturbinetestingpointnew monthFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQXSSDL);
|
|
|
- Windturbinetestingpointnew yearFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQXSSDL);
|
|
|
+ ProBasicEquipmentPoint dayFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQXSSDL);
|
|
|
+ ProBasicEquipmentPoint monthFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQXSSDL);
|
|
|
+ ProBasicEquipmentPoint yearFdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQXSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayFdjclPoint,monthFdjclPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayFdjclPoint,yearFdjclPoint,firstDayOfYear);
|
|
|
//故障
|
|
|
- Windturbinetestingpointnew dayGzPoint = windturbinetestingpointnewMap.get(Contant.WTRGZSSDL);
|
|
|
- Windturbinetestingpointnew monthGzPoint = windturbinetestingpointnewMap.get(Contant.WTYGZSSDL);
|
|
|
- Windturbinetestingpointnew yearGzPoint = windturbinetestingpointnewMap.get(Contant.WTNGZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayGzPoint = windturbinetestingpointnewMap.get(Contant.WTRGZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthGzPoint = windturbinetestingpointnewMap.get(Contant.WTYGZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearGzPoint = windturbinetestingpointnewMap.get(Contant.WTNGZSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayGzPoint,monthGzPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayGzPoint,yearGzPoint,firstDayOfYear);
|
|
|
//故障受累
|
|
|
- Windturbinetestingpointnew dayGzslPoint = windturbinetestingpointnewMap.get(Contant.WTRSZSSDL);
|
|
|
- Windturbinetestingpointnew monthGzslPoint = windturbinetestingpointnewMap.get(Contant.WTYSZSSDL);
|
|
|
- Windturbinetestingpointnew yearGzslPoint = windturbinetestingpointnewMap.get(Contant.WTNSZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayGzslPoint = windturbinetestingpointnewMap.get(Contant.WTRSZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthGzslPoint = windturbinetestingpointnewMap.get(Contant.WTYSZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearGzslPoint = windturbinetestingpointnewMap.get(Contant.WTNSZSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayGzslPoint,monthGzslPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayGzslPoint,yearGzslPoint,firstDayOfYear);
|
|
|
//维护
|
|
|
- Windturbinetestingpointnew dayWhPoint = windturbinetestingpointnewMap.get(Contant.WTRJXSSDL);
|
|
|
- Windturbinetestingpointnew monthWhPoint = windturbinetestingpointnewMap.get(Contant.WTYJXSSDL);
|
|
|
- Windturbinetestingpointnew yearWhPoint = windturbinetestingpointnewMap.get(Contant.WTNJXSSDL);
|
|
|
+ ProBasicEquipmentPoint dayWhPoint = windturbinetestingpointnewMap.get(Contant.WTRJXSSDL);
|
|
|
+ ProBasicEquipmentPoint monthWhPoint = windturbinetestingpointnewMap.get(Contant.WTYJXSSDL);
|
|
|
+ ProBasicEquipmentPoint yearWhPoint = windturbinetestingpointnewMap.get(Contant.WTNJXSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayWhPoint,monthWhPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayWhPoint,yearWhPoint,firstDayOfYear);
|
|
|
//维护受累
|
|
|
- Windturbinetestingpointnew dayWhslPoint = windturbinetestingpointnewMap.get(Contant.WTRLZSSDL);
|
|
|
- Windturbinetestingpointnew monthWhslPoint = windturbinetestingpointnewMap.get(Contant.WTYLZSSDL);
|
|
|
- Windturbinetestingpointnew yearWhslPoint = windturbinetestingpointnewMap.get(Contant.WTNLZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayWhslPoint = windturbinetestingpointnewMap.get(Contant.WTRLZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthWhslPoint = windturbinetestingpointnewMap.get(Contant.WTYLZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearWhslPoint = windturbinetestingpointnewMap.get(Contant.WTNLZSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayWhslPoint,monthWhslPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayWhslPoint,yearWhslPoint,firstDayOfYear);
|
|
|
//限电降出力
|
|
|
- Windturbinetestingpointnew dayXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQFSSDL);
|
|
|
- Windturbinetestingpointnew monthXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQFSSDL);
|
|
|
- Windturbinetestingpointnew yearXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQFSSDL);
|
|
|
+ ProBasicEquipmentPoint dayXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTRQFSSDL);
|
|
|
+ ProBasicEquipmentPoint monthXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTYQFSSDL);
|
|
|
+ ProBasicEquipmentPoint yearXdjclPoint = windturbinetestingpointnewMap.get(Contant.WTNQFSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayXdjclPoint,monthXdjclPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayXdjclPoint,yearXdjclPoint,firstDayOfYear);
|
|
|
//限电停机
|
|
|
- Windturbinetestingpointnew dayXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRXDSSDL);
|
|
|
- Windturbinetestingpointnew monthXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYXDSSDL);
|
|
|
- Windturbinetestingpointnew yearXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNXDSSDL);
|
|
|
+ ProBasicEquipmentPoint dayXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTRXDSSDL);
|
|
|
+ ProBasicEquipmentPoint monthXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTYXDSSDL);
|
|
|
+ ProBasicEquipmentPoint yearXdtjPoint = windturbinetestingpointnewMap.get(Contant.WTNXDSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayXdtjPoint,monthXdtjPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayXdtjPoint,yearXdtjPoint,firstDayOfYear);
|
|
|
//电网受累
|
|
|
- Windturbinetestingpointnew dayDwslPoint = windturbinetestingpointnewMap.get(Contant.WTRWZSSDL);
|
|
|
- Windturbinetestingpointnew monthDwslPoint = windturbinetestingpointnewMap.get(Contant.WTYWZSSDL);
|
|
|
- Windturbinetestingpointnew yearDwslPoint = windturbinetestingpointnewMap.get(Contant.WTNWZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayDwslPoint = windturbinetestingpointnewMap.get(Contant.WTRWZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthDwslPoint = windturbinetestingpointnewMap.get(Contant.WTYWZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearDwslPoint = windturbinetestingpointnewMap.get(Contant.WTNWZSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayDwslPoint,monthDwslPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayDwslPoint,yearDwslPoint,firstDayOfYear);
|
|
|
//环境受累
|
|
|
- Windturbinetestingpointnew dayHjslPoint = windturbinetestingpointnewMap.get(Contant.WTRTZSSDL);
|
|
|
- Windturbinetestingpointnew monthHjslPoint = windturbinetestingpointnewMap.get(Contant.WTYTZSSDL);
|
|
|
- Windturbinetestingpointnew yearHjslPoint = windturbinetestingpointnewMap.get(Contant.WTNTZSSDL);
|
|
|
+ ProBasicEquipmentPoint dayHjslPoint = windturbinetestingpointnewMap.get(Contant.WTRTZSSDL);
|
|
|
+ ProBasicEquipmentPoint monthHjslPoint = windturbinetestingpointnewMap.get(Contant.WTYTZSSDL);
|
|
|
+ ProBasicEquipmentPoint yearHjslPoint = windturbinetestingpointnewMap.get(Contant.WTNTZSSDL);
|
|
|
geneMonthOrYearLoss(resultList, dayHjslPoint,monthHjslPoint,firstDayOfMonth);
|
|
|
geneMonthOrYearLoss(resultList, dayHjslPoint,yearHjslPoint,firstDayOfYear);
|
|
|
});
|
|
@@ -1023,7 +1022,7 @@ public class FiveLossesService {
|
|
|
|
|
|
|
|
|
|
|
|
- private void geneMonthOrYearLoss(List<PointData> resultList,Windturbinetestingpointnew dayPoint,Windturbinetestingpointnew monthPoint,boolean firstDayOfMonthOrYear) {
|
|
|
+ private void geneMonthOrYearLoss(List<PointData> resultList,ProBasicEquipmentPoint dayPoint,ProBasicEquipmentPoint monthPoint,boolean firstDayOfMonthOrYear) {
|
|
|
Double dayValue = 0.0;
|
|
|
Double yestodayMonth = 0.0;
|
|
|
try {
|
|
@@ -1038,7 +1037,7 @@ public class FiveLossesService {
|
|
|
resultList.add(createWtPointData(monthPoint,monthValue));
|
|
|
}
|
|
|
|
|
|
- private double generalLoss(List<PointData> ztmxDatasSnap, List<PointData> bzglDatasSnap, List<PointData> zsglDatasSnap, List<PointData> powerDatasSnap,Double statusValue,List<PointData> resultList,Windturbinetestingpointnew point) {
|
|
|
+ private double generalLoss(List<PointData> ztmxDatasSnap, List<PointData> bzglDatasSnap, List<PointData> zsglDatasSnap, List<PointData> powerDatasSnap,Double statusValue,List<PointData> resultList,ProBasicEquipmentPoint point) {
|
|
|
List<PointData> pointDataList = ztmxDatasSnap.stream().filter(zt -> zt.getPointValueInDouble() == statusValue).collect(Collectors.toList());
|
|
|
Double bzss = 0.0;
|
|
|
Double zsss = 0.0;
|
|
@@ -1089,7 +1088,7 @@ public class FiveLossesService {
|
|
|
}
|
|
|
|
|
|
|
|
|
- private PointData createWtPointData(Windturbinetestingpointnew fjfdl, Double rfdl) {
|
|
|
+ private PointData createWtPointData(ProBasicEquipmentPoint fjfdl, Double rfdl) {
|
|
|
PointData pointData = new PointData();
|
|
|
pointData.setEdnaId(fjfdl.getCode());
|
|
|
pointData.setPointName(fjfdl.getName());
|