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; 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.util.realtimesource.IEdosUtil; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.*; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; /** * @ClassName : FiveLossesService * @Author : xieshengjie * @Date: 2022/5/2 16:13 * @Description : 五项损失,欠发状态，欠发发电量 */ @Service public class FiveLossesService { @Resource private IEdosUtil edosUtil; private List wtls; private Map> wtpAimap; private Date samedayZero; private Date currentDate; private Date tomorrow; private List wpls; private Map> wppromap; private Map> prolinemap; private Map> linewtmap; private Map> wppointmap; private Map> linepointmap; private Map> propointmap; @Resource private IShutdowneventService shutdowneventService; private void init(){ wpls = CacheContext.wpls; wtls = CacheContext.wtls; wppromap = CacheContext.wppromap; prolinemap = CacheContext.prolinemap; wppointmap = CacheContext.wppointmap; linepointmap = CacheContext.linepointmap; propointmap = CacheContext.propointmap; wtpAimap = CacheContext.wtpAimap; linewtmap = CacheContext.linewtmap; samedayZero = DateUtils.getSamedayZero(); currentDate = DateUtils.getCurrentDate(); tomorrow = DateUtils.addDays(samedayZero,1); } public void lossesReal() throws Exception { init(); wtDaylossesReal(); wtMonthYearlossesReal(); wpDaylossesReal(); } /** * 存储shutdownevent */ public void saveShutdownevent(){ init(); List resultList = new ArrayList<>(); QueryWrapper qw = new QueryWrapper<>(); qw.isNull("starttime"); qw.isNotNull("stoptime"); qw.in("windpowerstationid",wpls.stream().map(wp->wp.getId()).collect(Collectors.toList())); //查出有故障但没恢复的事件 List shutdownevents = shutdowneventService.list(qw); List faultWinturbines = null; List 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()); } List finalFaultWinturbines = faultWinturbines; List finalMainWinturbines = mainWinturbines; wtls.stream().forEach(wt->{ Map 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); PointData sectionData = null; try { sectionData = edosUtil.getSectionData(ztmxPoint, tomorrow.getTime()); } catch (Exception e) { e.printStackTrace(); } double fjzt = sectionData.getPointValueInDouble(); if (StringUtils.isNotEmpty(finalFaultWinturbines) && finalFaultWinturbines.contains(wt.getId())){ //此风机在之前故障未恢复列表 if (fjzt!=6){ //将时间存储到结束时间，算时间与电量 Optional first = shutdownevents.stream().filter(i -> i.getWindturbineid().equals(wt.getId())).findFirst(); if (first.isPresent()){ Shutdownevent shutdownevent = first.get(); Date starttime = DateUtils.parseLongToDate(sectionData.getPointTime()*1000); shutdownevent.setStarttime(starttime); Date stoptime = shutdownevent.getStoptime(); double hour = DateUtils.hoursDiff2(stoptime, starttime); shutdownevent.setStophours(hour); List ztmxDatasSnap = null; List bzglDatasSnap = null; List zsglDatasSnap = null; List powerDatasSnap = null; try { ztmxDatasSnap = edosUtil.getHistoryDatasSnap(ztmxPoint,stoptime.getTime()/1000,starttime.getTime()/1000,null,60l); bzglDatasSnap = edosUtil.getHistoryDatasSnap(bzglPoint,stoptime.getTime()/1000,starttime.getTime()/1000,null,60l); zsglDatasSnap = edosUtil.getHistoryDatasSnap(zsglPoint,stoptime.getTime()/1000,starttime.getTime()/1000,null,60l); powerDatasSnap = edosUtil.getHistoryDatasSnap(powerPoint, stoptime.getTime() / 1000, starttime.getTime() / 1000, null, 60l); } catch (Exception e) { e.printStackTrace(); } if (ztmxDatasSnap.size() == zsglDatasSnap.size()){ //故障 double gzss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 6.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRGZSSDL)); shutdownevent.setLosspower(gzss); } shutdowneventService.saveOrUpdate(shutdownevent); } } if (fjzt==8){ Shutdownevent shutdownevent = new Shutdownevent(); shutdownevent.setId(CommonUtils.getUUID()); 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); } } else if (StringUtils.isNotEmpty(finalMainWinturbines) && finalMainWinturbines.contains(wt.getId())){ //此风机在之前故障未恢复列表 if (fjzt!=8){ //将时间存储到结束时间，算时间与电量 Optional first = shutdownevents.stream().filter(i -> i.getWindturbineid().equals(wt.getId())).findFirst(); if (first.isPresent()){ Shutdownevent shutdownevent = first.get(); Date starttime = DateUtils.parseLongToDate(sectionData.getPointTime()*1000); shutdownevent.setStarttime(starttime); Date stoptime = shutdownevent.getStoptime(); double hour = DateUtils.hoursDiff2(stoptime, starttime); shutdownevent.setStophours(hour); List ztmxDatasSnap = null; List bzglDatasSnap = null; List zsglDatasSnap = null; List powerDatasSnap = null; try { ztmxDatasSnap = edosUtil.getHistoryDatasSnap(ztmxPoint,stoptime.getTime()/1000,starttime.getTime()/1000,null,60l); bzglDatasSnap = edosUtil.getHistoryDatasSnap(bzglPoint,stoptime.getTime()/1000,starttime.getTime()/1000,null,60l); zsglDatasSnap = edosUtil.getHistoryDatasSnap(zsglPoint,stoptime.getTime()/1000,starttime.getTime()/1000,null,60l); powerDatasSnap = edosUtil.getHistoryDatasSnap(powerPoint, samedayZero.getTime() / 1000, currentDate.getTime() / 1000, null, 60l); } catch (Exception e) { e.printStackTrace(); } if (ztmxDatasSnap.size() == zsglDatasSnap.size()){ //维护 double jxss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 8.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRJXSSDL)); shutdownevent.setLosspower(jxss); } shutdowneventService.saveOrUpdate(shutdownevent); } } if (fjzt==6){ Shutdownevent shutdownevent = new Shutdownevent(); shutdownevent.setId(CommonUtils.getUUID()); 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); } } else { //没有没结束的故障维护事件 if (fjzt==6 || fjzt==8){ Shutdownevent shutdownevent = new Shutdownevent(); shutdownevent.setId(CommonUtils.getUUID()); shutdownevent.setWindpowerstationid(wt.getWindpowerstationid()); shutdownevent.setWindturbineid(wt.getId()); Date date = DateUtils.parseLongToDate(sectionData.getPointTime()*1000); shutdownevent.setStoptime(date); shutdownevent.setProjectid(wt.getProjectid()); if (fjzt == 6){ shutdownevent.setStatuscode(2); }else { shutdownevent.setStatuscode(4); } shutdowneventService.save(shutdownevent); } } }); } /** * 场站五损，欠发电量 */ private void wpDaylossesReal() throws Exception { List resultList = new ArrayList<>(); wpls.stream().forEach(wp->{ List projects = wppromap.get(wp.getId()); Map wppointnewMap = wppointmap.get(wp.getId()); AtomicReference wpdaydjloss = new AtomicReference<>(0.0); AtomicReference wpmonthdjloss = new AtomicReference<>(0.0); AtomicReference wpyeardjloss = new AtomicReference<>(0.0); AtomicReference wpdaysdtjloss = new AtomicReference<>(0.0); AtomicReference wpmonthsdtjloss = new AtomicReference<>(0.0); AtomicReference wpyearsdtjloss = new AtomicReference<>(0.0); AtomicReference wpdayxnloss = new AtomicReference<>(0.0); AtomicReference wpmonthxnloss = new AtomicReference<>(0.0); AtomicReference wpyearxnloss = new AtomicReference<>(0.0); AtomicReference wpdayfdjclloss = new AtomicReference<>(0.0); AtomicReference wpmonthfdjclloss = new AtomicReference<>(0.0); AtomicReference wpyearfdjclloss = new AtomicReference<>(0.0); AtomicReference wpdaygzloss = new AtomicReference<>(0.0); AtomicReference wpmonthgzloss = new AtomicReference<>(0.0); AtomicReference wpyeargzloss = new AtomicReference<>(0.0); AtomicReference wpdaygzslloss = new AtomicReference<>(0.0); AtomicReference wpmonthgzslloss = new AtomicReference<>(0.0); AtomicReference wpyeargzslloss = new AtomicReference<>(0.0); AtomicReference wpdaywhloss = new AtomicReference<>(0.0); AtomicReference wpmonthwhloss = new AtomicReference<>(0.0); AtomicReference wpyearwhloss = new AtomicReference<>(0.0); AtomicReference wpdaywhslloss = new AtomicReference<>(0.0); AtomicReference wpmonthwhslloss = new AtomicReference<>(0.0); AtomicReference wpyearwhslloss = new AtomicReference<>(0.0); AtomicReference wpdayxdtjloss = new AtomicReference<>(0.0); AtomicReference wpmonthxdtjloss = new AtomicReference<>(0.0); AtomicReference wpyearxdtjloss = new AtomicReference<>(0.0); AtomicReference wpdayxdjclloss = new AtomicReference<>(0.0); AtomicReference wpmonthxdjclloss = new AtomicReference<>(0.0); AtomicReference wpyearxdjclloss = new AtomicReference<>(0.0); AtomicReference wpdaydwslloss = new AtomicReference<>(0.0); AtomicReference wpmonthdwslloss = new AtomicReference<>(0.0); AtomicReference wpyeardwslloss = new AtomicReference<>(0.0); AtomicReference wpdayhjslloss = new AtomicReference<>(0.0); AtomicReference wpmonthhjslloss = new AtomicReference<>(0.0); AtomicReference wpyearhjslloss = new AtomicReference<>(0.0); AtomicReference wpdayqf0 = new AtomicReference<>(0.0); AtomicReference wpdayqf1 = new AtomicReference<>(0.0); AtomicReference wpdayqf2 = new AtomicReference<>(0.0); AtomicReference wpdayqf3 = new AtomicReference<>(0.0); AtomicReference wpdayqf4= new AtomicReference<>(0.0); projects.stream().forEach(project -> { List lines = prolinemap.get(project.getId()); Map projectpointnewMap = propointmap.get(project.getId()); AtomicReference projectdaydjloss = new AtomicReference<>(0.0); AtomicReference projectmonthdjloss = new AtomicReference<>(0.0); AtomicReference projectyeardjloss = new AtomicReference<>(0.0); AtomicReference projectdaysdtjloss = new AtomicReference<>(0.0); AtomicReference projectmonthsdtjloss = new AtomicReference<>(0.0); AtomicReference projectyearsdtjloss = new AtomicReference<>(0.0); AtomicReference projectdayxnloss = new AtomicReference<>(0.0); AtomicReference projectmonthxnloss = new AtomicReference<>(0.0); AtomicReference projectyearxnloss = new AtomicReference<>(0.0); AtomicReference projectdayfdjclloss = new AtomicReference<>(0.0); AtomicReference projectmonthfdjclloss = new AtomicReference<>(0.0); AtomicReference projectyearfdjclloss = new AtomicReference<>(0.0); AtomicReference projectdaygzloss = new AtomicReference<>(0.0); AtomicReference projectmonthgzloss = new AtomicReference<>(0.0); AtomicReference projectyeargzloss = new AtomicReference<>(0.0); AtomicReference projectdaygzslloss = new AtomicReference<>(0.0); AtomicReference projectmonthgzslloss = new AtomicReference<>(0.0); AtomicReference projectyeargzslloss = new AtomicReference<>(0.0); AtomicReference projectdaywhloss = new AtomicReference<>(0.0); AtomicReference projectmonthwhloss = new AtomicReference<>(0.0); AtomicReference projectyearwhloss = new AtomicReference<>(0.0); AtomicReference projectdaywhslloss = new AtomicReference<>(0.0); AtomicReference projectmonthwhslloss = new AtomicReference<>(0.0); AtomicReference projectyearwhslloss = new AtomicReference<>(0.0); AtomicReference projectdayxdtjloss = new AtomicReference<>(0.0); AtomicReference projectmonthxdtjloss = new AtomicReference<>(0.0); AtomicReference projectyearxdtjloss = new AtomicReference<>(0.0); AtomicReference projectdayxdjclloss = new AtomicReference<>(0.0); AtomicReference projectmonthxdjclloss = new AtomicReference<>(0.0); AtomicReference projectyearxdjclloss = new AtomicReference<>(0.0); AtomicReference projectdaydwslloss = new AtomicReference<>(0.0); AtomicReference projectmonthdwslloss = new AtomicReference<>(0.0); AtomicReference projectyeardwslloss = new AtomicReference<>(0.0); AtomicReference projectdayhjslloss = new AtomicReference<>(0.0); AtomicReference projectmonthhjslloss = new AtomicReference<>(0.0); AtomicReference projectyearhjslloss = new AtomicReference<>(0.0); AtomicReference projectdayqf0 = new AtomicReference<>(0.0); AtomicReference projectdayqf1 = new AtomicReference<>(0.0); AtomicReference projectdayqf2 = new AtomicReference<>(0.0); AtomicReference projectdayqf3 = new AtomicReference<>(0.0); AtomicReference projectdayqf4 = new AtomicReference<>(0.0); lines.stream().forEach(line -> { List windturbines = linewtmap.get(line.getId()); Map linepointnewMap = linepointmap.get(line.getId()); AtomicReference linedaydjloss = new AtomicReference<>(0.0); AtomicReference linemonthdjloss = new AtomicReference<>(0.0); AtomicReference lineyeardjloss = new AtomicReference<>(0.0); AtomicReference linedaysdtjloss = new AtomicReference<>(0.0); AtomicReference linemonthsdtjloss = new AtomicReference<>(0.0); AtomicReference lineyearsdtjloss = new AtomicReference<>(0.0); AtomicReference linedayxnloss = new AtomicReference<>(0.0); AtomicReference linemonthxnloss = new AtomicReference<>(0.0); AtomicReference lineyearxnloss = new AtomicReference<>(0.0); AtomicReference linedayfdjclloss = new AtomicReference<>(0.0); AtomicReference linemonthfdjclloss = new AtomicReference<>(0.0); AtomicReference lineyearfdjclloss = new AtomicReference<>(0.0); AtomicReference linedaygzloss = new AtomicReference<>(0.0); AtomicReference linemonthgzloss = new AtomicReference<>(0.0); AtomicReference lineyeargzloss = new AtomicReference<>(0.0); AtomicReference linedaygzslloss = new AtomicReference<>(0.0); AtomicReference linemonthgzslloss = new AtomicReference<>(0.0); AtomicReference lineyeargzslloss = new AtomicReference<>(0.0); AtomicReference linedaywhloss = new AtomicReference<>(0.0); AtomicReference linemonthwhloss = new AtomicReference<>(0.0); AtomicReference lineyearwhloss = new AtomicReference<>(0.0); AtomicReference linedaywhslloss = new AtomicReference<>(0.0); AtomicReference linemonthwhslloss = new AtomicReference<>(0.0); AtomicReference lineyearwhslloss = new AtomicReference<>(0.0); AtomicReference linedayxdtjloss = new AtomicReference<>(0.0); AtomicReference linemonthxdtjloss = new AtomicReference<>(0.0); AtomicReference lineyearxdtjloss = new AtomicReference<>(0.0); AtomicReference linedayxdjclloss = new AtomicReference<>(0.0); AtomicReference linemonthxdjclloss = new AtomicReference<>(0.0); AtomicReference lineyearxdjclloss = new AtomicReference<>(0.0); AtomicReference linedaydwslloss = new AtomicReference<>(0.0); AtomicReference linemonthdwslloss = new AtomicReference<>(0.0); AtomicReference lineyeardwslloss = new AtomicReference<>(0.0); AtomicReference linedayhjslloss = new AtomicReference<>(0.0); AtomicReference linemonthhjslloss = new AtomicReference<>(0.0); AtomicReference lineyearhjslloss = new AtomicReference<>(0.0); AtomicReference linedayqf0 = new AtomicReference<>(0.0); AtomicReference linedayqf1 = new AtomicReference<>(0.0); AtomicReference linedayqf2 = new AtomicReference<>(0.0); AtomicReference linedayqf3 = new AtomicReference<>(0.0); AtomicReference linedayqf4 = new AtomicReference<>(0.0); windturbines.stream().forEach(wt->{ Map windturbinetestingpointnewMap = wtpAimap.get(wt.getId()); //待机 Windturbinetestingpointnew dayDjPoint = windturbinetestingpointnewMap.get(Contant.WTRDJSSDL); Windturbinetestingpointnew monthDjPoint = windturbinetestingpointnewMap.get(Contant.WTYDJSSDL); Windturbinetestingpointnew 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); 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); 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); 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); 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); 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); 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); 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); 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); 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); 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); 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); geneLineQfloss(linedayqf0, linedayqf1, linedayqf2,linedayqf3,linedayqf4, dayqf0, dayqf1, dayqf2,dayqf3,dayqf4); }); //待机 addWpPoint(resultList, linepointnewMap.get(Contant.RSDJZSDL), linedaydjloss); addWpPoint(resultList, linepointnewMap.get(Contant.YSDJZSDL), linemonthdjloss); addWpPoint(resultList, linepointnewMap.get(Contant.NSDJZSDL), lineyeardjloss); projectdaydjloss.updateAndGet(v->new Double((double) (v + linedaydjloss.get()))); projectmonthdjloss.updateAndGet(v->new Double((double) (v + linemonthdjloss.get()))); projectyeardjloss.updateAndGet(v->new Double((double) (v + lineyeardjloss.get()))); //手动停机 addWpPoint(resultList, linepointnewMap.get(Contant.RSSTZSDL), linedaysdtjloss); addWpPoint(resultList, linepointnewMap.get(Contant.YSSTZSDL), linemonthsdtjloss); addWpPoint(resultList, linepointnewMap.get(Contant.NSSTZSDL), lineyearsdtjloss); projectdaysdtjloss.updateAndGet(v->new Double((double) (v + linedaysdtjloss.get()))); projectmonthsdtjloss.updateAndGet(v->new Double((double) (v + linemonthsdtjloss.get()))); projectyearsdtjloss.updateAndGet(v->new Double((double) (v + lineyearsdtjloss.get()))); //性能 addWpPoint(resultList, linepointnewMap.get(Contant.RXNZSDL), linedayxnloss); addWpPoint(resultList, linepointnewMap.get(Contant.YXNZSDL), linemonthxnloss); addWpPoint(resultList, linepointnewMap.get(Contant.NXNZSDL), lineyearxnloss); projectdayxnloss.updateAndGet(v->new Double((double) (v + linedayxnloss.get()))); projectmonthxnloss.updateAndGet(v->new Double((double) (v + linemonthxnloss.get()))); projectyearxnloss.updateAndGet(v->new Double((double) (v + lineyearxnloss.get()))); //发电降出力 addWpPoint(resultList, linepointnewMap.get(Contant.RSQXZSDL), linedayfdjclloss); addWpPoint(resultList, linepointnewMap.get(Contant.YSQXZSDL), linemonthfdjclloss); addWpPoint(resultList, linepointnewMap.get(Contant.NSQXZSDL), lineyearfdjclloss); projectdayfdjclloss.updateAndGet(v->new Double((double) (v + linedayfdjclloss.get()))); projectmonthfdjclloss.updateAndGet(v->new Double((double) (v + linemonthfdjclloss.get()))); projectyearfdjclloss.updateAndGet(v->new Double((double) (v + lineyearfdjclloss.get()))); double xnss = linedaydjloss.get() + linedaysdtjloss.get() + linedayxnloss.get() + linedayfdjclloss.get(); resultList.add(createWpPointData(linepointnewMap.get(Contant.XNSSDL),xnss)); //故障 addWpPoint(resultList, linepointnewMap.get(Contant.RGZZSDL), linedaygzloss); addWpPoint(resultList, linepointnewMap.get(Contant.YGZZSDL), linemonthgzloss); addWpPoint(resultList, linepointnewMap.get(Contant.NGZZSDL), lineyeargzloss); projectdaygzloss.updateAndGet(v->new Double((double) (v + linedaygzloss.get()))); projectmonthgzloss.updateAndGet(v->new Double((double) (v + linemonthgzloss.get()))); projectyeargzloss.updateAndGet(v->new Double((double) (v + lineyeargzloss.get()))); //故障受累 addWpPoint(resultList, linepointnewMap.get(Contant.RSZZSDL), linedaygzslloss); addWpPoint(resultList, linepointnewMap.get(Contant.YSZZSDL), linemonthgzslloss); addWpPoint(resultList, linepointnewMap.get(Contant.NSZZSDL), lineyeargzslloss); projectdaygzslloss.updateAndGet(v->new Double((double) (v + linedaygzslloss.get()))); projectmonthgzslloss.updateAndGet(v->new Double((double) (v + linemonthgzslloss.get()))); projectyeargzslloss.updateAndGet(v->new Double((double) (v + lineyeargzslloss.get()))); double gzss = linedaygzloss.get()+linedaygzslloss.get(); resultList.add(createWpPointData(linepointnewMap.get(Contant.GZSSDL),gzss)); //维护 addWpPoint(resultList, linepointnewMap.get(Contant.RJXZSDL), linedaywhloss); addWpPoint(resultList, linepointnewMap.get(Contant.YJXZSDL), linemonthwhloss); addWpPoint(resultList, linepointnewMap.get(Contant.NJXZSDL), lineyearwhloss); projectdaywhloss.updateAndGet(v->new Double((double) (v + linedaywhloss.get()))); projectmonthwhloss.updateAndGet(v->new Double((double) (v + linemonthwhloss.get()))); projectyearwhloss.updateAndGet(v->new Double((double) (v + lineyearwhloss.get()))); //维护受累 addWpPoint(resultList, linepointnewMap.get(Contant.RLZZSDL), linedaywhslloss); addWpPoint(resultList, linepointnewMap.get(Contant.YLZZSDL), linemonthwhslloss); addWpPoint(resultList, linepointnewMap.get(Contant.NLZZSDL), lineyearwhslloss); projectdaywhslloss.updateAndGet(v->new Double((double) (v + linedaywhslloss.get()))); projectmonthwhslloss.updateAndGet(v->new Double((double) (v + linemonthwhslloss.get()))); projectyearwhslloss.updateAndGet(v->new Double((double) (v + lineyearwhslloss.get()))); double whss = linedaywhloss.get()+linedaywhslloss.get(); resultList.add(createWpPointData(linepointnewMap.get(Contant.WHSSDL),whss)); //限电降出力 addWpPoint(resultList, linepointnewMap.get(Contant.RQFZSDL), linedayxdjclloss); addWpPoint(resultList, linepointnewMap.get(Contant.YQFZSDL), linemonthxdjclloss); addWpPoint(resultList, linepointnewMap.get(Contant.NQFZSDL), lineyearxdjclloss); projectdayxdjclloss.updateAndGet(v->new Double((double) (v + linedayxdjclloss.get()))); projectmonthxdjclloss.updateAndGet(v->new Double((double) (v + linemonthxdjclloss.get()))); projectyearxdjclloss.updateAndGet(v->new Double((double) (v + lineyearxdjclloss.get()))); //限电停机 addWpPoint(resultList, linepointnewMap.get(Contant.RXDZSDL), linedayxdtjloss); addWpPoint(resultList, linepointnewMap.get(Contant.YXDZSDL), linemonthxdtjloss); addWpPoint(resultList, linepointnewMap.get(Contant.NXDZSDL), lineyearxdtjloss); projectdayxdtjloss.updateAndGet(v->new Double((double) (v + linedayxdtjloss.get()))); projectmonthxdtjloss.updateAndGet(v->new Double((double) (v + linemonthxdtjloss.get()))); projectyearxdtjloss.updateAndGet(v->new Double((double) (v + lineyearxdtjloss.get()))); double xdss = linedayxdjclloss.get()+linedayxdtjloss.get(); resultList.add(createWpPointData(linepointnewMap.get(Contant.XDSSDL),xdss)); //电网受累 addWpPoint(resultList, linepointnewMap.get(Contant.RWZZSDL), linedaydwslloss); addWpPoint(resultList, linepointnewMap.get(Contant.YWZZSDL), linemonthdwslloss); addWpPoint(resultList, linepointnewMap.get(Contant.NWZZSDL), lineyeardwslloss); projectdaydwslloss.updateAndGet(v->new Double((double) (v + linedaydwslloss.get()))); projectmonthdwslloss.updateAndGet(v->new Double((double) (v + linemonthdwslloss.get()))); projectyeardwslloss.updateAndGet(v->new Double((double) (v + lineyeardwslloss.get()))); //环境受累 addWpPoint(resultList, linepointnewMap.get(Contant.RTZZSDL), linedayhjslloss); addWpPoint(resultList, linepointnewMap.get(Contant.YTZZSDL), linemonthhjslloss); addWpPoint(resultList, linepointnewMap.get(Contant.NTZZSDL), lineyearhjslloss); projectdayhjslloss.updateAndGet(v->new Double((double) (v + linedayhjslloss.get()))); projectmonthhjslloss.updateAndGet(v->new Double((double) (v + linemonthhjslloss.get()))); projectyearhjslloss.updateAndGet(v->new Double((double) (v + lineyearhjslloss.get()))); double slss = linedayhjslloss.get()+linedaydwslloss.get(); resultList.add(createWpPointData(linepointnewMap.get(Contant.SLSSDL),slss)); //欠发发电量 addWpPoint(resultList, linepointnewMap.get(Contant.R0QFZT), linedayqf0); addWpPoint(resultList, linepointnewMap.get(Contant.R1QFZT), linedayqf1); addWpPoint(resultList, linepointnewMap.get(Contant.R2QFZT), linedayqf2); addWpPoint(resultList, linepointnewMap.get(Contant.R3QFZT), linedayqf3); addWpPoint(resultList, linepointnewMap.get(Contant.R4QFZT), linedayqf4); projectdayqf0.updateAndGet(v->new Double((double) (v + linedayqf0.get()))); projectdayqf1.updateAndGet(v->new Double((double) (v + linedayqf1.get()))); projectdayqf2.updateAndGet(v->new Double((double) (v + linedayqf2.get()))); projectdayqf3.updateAndGet(v->new Double((double) (v + linedayqf3.get()))); projectdayqf4.updateAndGet(v->new Double((double) (v + linedayqf4.get()))); }); //待机 addWpPoint(resultList, projectpointnewMap.get(Contant.RSDJZSDL), projectdaydjloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YSDJZSDL), projectmonthdjloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NSDJZSDL), projectyeardjloss); wpdaydjloss.updateAndGet(v->new Double((double) (v + projectdaydjloss.get()))); wpmonthdjloss.updateAndGet(v->new Double((double) (v + projectmonthdjloss.get()))); wpyeardjloss.updateAndGet(v->new Double((double) (v + projectyeardjloss.get()))); //手动停机 addWpPoint(resultList, projectpointnewMap.get(Contant.RSSTZSDL), projectdaysdtjloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YSSTZSDL), projectmonthsdtjloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NSSTZSDL), projectyearsdtjloss); wpdaysdtjloss.updateAndGet(v->new Double((double) (v + projectdaysdtjloss.get()))); wpmonthsdtjloss.updateAndGet(v->new Double((double) (v + projectmonthsdtjloss.get()))); wpyearsdtjloss.updateAndGet(v->new Double((double) (v + projectyearsdtjloss.get()))); //性能 addWpPoint(resultList, projectpointnewMap.get(Contant.RXNZSDL), projectdayxnloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YXNZSDL), projectmonthxnloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NXNZSDL), projectyearxnloss); wpdayxnloss.updateAndGet(v->new Double((double) (v + projectdayxnloss.get()))); wpmonthxnloss.updateAndGet(v->new Double((double) (v + projectmonthxnloss.get()))); wpyearxnloss.updateAndGet(v->new Double((double) (v + projectyearxnloss.get()))); //发电降出力 addWpPoint(resultList, projectpointnewMap.get(Contant.RSQXZSDL), projectdayfdjclloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YSQXZSDL), projectmonthfdjclloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NSQXZSDL), projectyearfdjclloss); wpdayfdjclloss.updateAndGet(v->new Double((double) (v + projectdayfdjclloss.get()))); wpmonthfdjclloss.updateAndGet(v->new Double((double) (v + projectmonthfdjclloss.get()))); wpyearfdjclloss.updateAndGet(v->new Double((double) (v + projectyearfdjclloss.get()))); double xnss = projectdaydjloss.get() + projectdaysdtjloss.get()+projectdayxnloss.get()+projectdayfdjclloss.get(); resultList.add(createWpPointData(projectpointnewMap.get(Contant.XNSSDL),xnss)); //故障 addWpPoint(resultList, projectpointnewMap.get(Contant.RGZZSDL), projectdaygzloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YGZZSDL), projectmonthgzloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NGZZSDL), projectyeargzloss); wpdaygzloss.updateAndGet(v->new Double((double) (v + projectdaygzloss.get()))); wpmonthgzloss.updateAndGet(v->new Double((double) (v + projectmonthgzloss.get()))); wpyeargzloss.updateAndGet(v->new Double((double) (v + projectyeargzloss.get()))); //故障受累 addWpPoint(resultList, projectpointnewMap.get(Contant.RSZZSDL), projectdaygzslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YSZZSDL), projectmonthgzslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NSZZSDL), projectyeargzslloss); wpdaygzslloss.updateAndGet(v->new Double((double) (v + projectdaygzslloss.get()))); wpmonthgzslloss.updateAndGet(v->new Double((double) (v + projectmonthgzslloss.get()))); wpyeargzslloss.updateAndGet(v->new Double((double) (v + projectyeargzslloss.get()))); double gzss = projectdaygzloss.get() + projectdaygzslloss.get(); resultList.add(createWpPointData(projectpointnewMap.get(Contant.GZSSDL),gzss)); //维护 addWpPoint(resultList, projectpointnewMap.get(Contant.RJXZSDL), projectdaywhloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YJXZSDL), projectmonthwhloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NJXZSDL), projectyearwhloss); wpdaywhloss.updateAndGet(v->new Double((double) (v + projectdaywhloss.get()))); wpmonthwhloss.updateAndGet(v->new Double((double) (v + projectmonthwhloss.get()))); wpyearwhloss.updateAndGet(v->new Double((double) (v + projectyearwhloss.get()))); //维护受累 addWpPoint(resultList, projectpointnewMap.get(Contant.RLZZSDL), projectdaywhslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YLZZSDL), projectmonthwhslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NLZZSDL), projectyearwhslloss); wpdaywhslloss.updateAndGet(v->new Double((double) (v + projectdaywhslloss.get()))); wpmonthwhslloss.updateAndGet(v->new Double((double) (v + projectmonthwhslloss.get()))); wpyearwhslloss.updateAndGet(v->new Double((double) (v + projectyearwhslloss.get()))); double whss = projectdaywhloss.get() + projectdaywhslloss.get(); resultList.add(createWpPointData(projectpointnewMap.get(Contant.WHSSDL),whss)); //限电降出力 addWpPoint(resultList, projectpointnewMap.get(Contant.RQFZSDL), projectdayxdjclloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YQFZSDL), projectmonthxdjclloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NQFZSDL), projectyearxdjclloss); wpdayxdjclloss.updateAndGet(v->new Double((double) (v + projectdayxdjclloss.get()))); wpmonthxdjclloss.updateAndGet(v->new Double((double) (v + projectmonthxdjclloss.get()))); wpyearxdjclloss.updateAndGet(v->new Double((double) (v + projectyearxdjclloss.get()))); //限电停机 addWpPoint(resultList, projectpointnewMap.get(Contant.RXDZSDL), projectdayxdtjloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YXDZSDL), projectmonthxdtjloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NXDZSDL), projectyearxdtjloss); wpdayxdtjloss.updateAndGet(v->new Double((double) (v + projectdayxdtjloss.get()))); wpmonthxdtjloss.updateAndGet(v->new Double((double) (v + projectmonthxdtjloss.get()))); wpyearxdtjloss.updateAndGet(v->new Double((double) (v + projectyearxdtjloss.get()))); double xdss = projectdayxdjclloss.get() + projectdayxdtjloss.get(); resultList.add(createWpPointData(projectpointnewMap.get(Contant.XDSSDL),xdss)); //电网受累 addWpPoint(resultList, projectpointnewMap.get(Contant.RWZZSDL), projectdaydwslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YWZZSDL), projectmonthdwslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NWZZSDL), projectyeardwslloss); wpdaydwslloss.updateAndGet(v->new Double((double) (v + projectdaydwslloss.get()))); wpmonthdwslloss.updateAndGet(v->new Double((double) (v + projectmonthdwslloss.get()))); wpyeardwslloss.updateAndGet(v->new Double((double) (v + projectyeardwslloss.get()))); //环境受累 addWpPoint(resultList, projectpointnewMap.get(Contant.RTZZSDL), projectdayhjslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.YTZZSDL), projectmonthhjslloss); addWpPoint(resultList, projectpointnewMap.get(Contant.NTZZSDL), projectyearhjslloss); wpdayhjslloss.updateAndGet(v->new Double((double) (v + projectdayhjslloss.get()))); wpmonthhjslloss.updateAndGet(v->new Double((double) (v + projectmonthhjslloss.get()))); wpyearhjslloss.updateAndGet(v->new Double((double) (v + projectyearhjslloss.get()))); double slss = projectdaydwslloss.get() + projectdayhjslloss.get(); resultList.add(createWpPointData(projectpointnewMap.get(Contant.SLSSDL),slss)); //欠发发电量 addWpPoint(resultList, projectpointnewMap.get(Contant.R0QFZT), projectdayqf0); addWpPoint(resultList, projectpointnewMap.get(Contant.R1QFZT), projectdayqf1); addWpPoint(resultList, projectpointnewMap.get(Contant.R2QFZT), projectdayqf2); addWpPoint(resultList, projectpointnewMap.get(Contant.R3QFZT), projectdayqf3); addWpPoint(resultList, projectpointnewMap.get(Contant.R4QFZT), projectdayqf4); wpdayqf0.updateAndGet(v->new Double((double) (v + projectdayqf0.get()))); wpdayqf1.updateAndGet(v->new Double((double) (v + projectdayqf1.get()))); wpdayqf2.updateAndGet(v->new Double((double) (v + projectdayqf2.get()))); wpdayqf3.updateAndGet(v->new Double((double) (v + projectdayqf3.get()))); wpdayqf4.updateAndGet(v->new Double((double) (v + projectdayqf4.get()))); }); //待机 addWpPoint(resultList, wppointnewMap.get(Contant.RSDJZSDL), wpdaydjloss); addWpPoint(resultList, wppointnewMap.get(Contant.YSDJZSDL), wpmonthdjloss); addWpPoint(resultList, wppointnewMap.get(Contant.NSDJZSDL), wpyeardjloss); //手动停机 addWpPoint(resultList, wppointnewMap.get(Contant.RSSTZSDL), wpdaysdtjloss); addWpPoint(resultList, wppointnewMap.get(Contant.YSSTZSDL), wpmonthsdtjloss); addWpPoint(resultList, wppointnewMap.get(Contant.NSSTZSDL), wpyearsdtjloss); //性能 addWpPoint(resultList, wppointnewMap.get(Contant.RXNZSDL), wpdayxnloss); addWpPoint(resultList, wppointnewMap.get(Contant.YXNZSDL), wpmonthxnloss); addWpPoint(resultList, wppointnewMap.get(Contant.NXNZSDL), wpyearxnloss); //发电降出力 addWpPoint(resultList, wppointnewMap.get(Contant.RSQXZSDL), wpdayfdjclloss); addWpPoint(resultList, wppointnewMap.get(Contant.YSQXZSDL), wpmonthfdjclloss); addWpPoint(resultList, wppointnewMap.get(Contant.NSQXZSDL), wpyearfdjclloss); double xnss = wpdaydjloss.get() + wpdaysdtjloss.get()+wpdayxnloss.get()+wpdayfdjclloss.get(); resultList.add(createWpPointData(wppointnewMap.get(Contant.XNSSDL),xnss)); //故障 addWpPoint(resultList, wppointnewMap.get(Contant.RGZZSDL), wpdaygzloss); addWpPoint(resultList, wppointnewMap.get(Contant.YGZZSDL), wpmonthgzloss); addWpPoint(resultList, wppointnewMap.get(Contant.NGZZSDL), wpyeargzloss); //故障受累 addWpPoint(resultList, wppointnewMap.get(Contant.RSZZSDL), wpdaygzslloss); addWpPoint(resultList, wppointnewMap.get(Contant.YSZZSDL), wpmonthgzslloss); addWpPoint(resultList, wppointnewMap.get(Contant.NSZZSDL), wpyeargzslloss); double gzss = wpdaygzloss.get() + wpdaygzslloss.get(); resultList.add(createWpPointData(wppointnewMap.get(Contant.GZSSDL),gzss)); //维护 addWpPoint(resultList, wppointnewMap.get(Contant.RJXZSDL), wpdaywhloss); addWpPoint(resultList, wppointnewMap.get(Contant.YJXZSDL), wpmonthwhloss); addWpPoint(resultList, wppointnewMap.get(Contant.NJXZSDL), wpyearwhloss); //维护受累 addWpPoint(resultList, wppointnewMap.get(Contant.RLZZSDL), wpdaywhslloss); addWpPoint(resultList, wppointnewMap.get(Contant.YLZZSDL), wpmonthwhslloss); addWpPoint(resultList, wppointnewMap.get(Contant.NLZZSDL), wpyearwhslloss); double whss = wpdaywhloss.get() + wpdaywhslloss.get(); resultList.add(createWpPointData(wppointnewMap.get(Contant.WHSSDL),whss)); //限电降出力 addWpPoint(resultList, wppointnewMap.get(Contant.RQFZSDL), wpdayxdjclloss); addWpPoint(resultList, wppointnewMap.get(Contant.YQFZSDL), wpmonthxdjclloss); addWpPoint(resultList, wppointnewMap.get(Contant.NQFZSDL), wpyearxdjclloss); //限电停机 addWpPoint(resultList, wppointnewMap.get(Contant.RXDZSDL), wpdayxdtjloss); addWpPoint(resultList, wppointnewMap.get(Contant.YXDZSDL), wpmonthxdtjloss); addWpPoint(resultList, wppointnewMap.get(Contant.NXDZSDL), wpyearxdtjloss); double xdss = wpdayxdjclloss.get() + wpdayxdtjloss.get(); resultList.add(createWpPointData(wppointnewMap.get(Contant.XDSSDL),xdss)); //电网受累 addWpPoint(resultList, wppointnewMap.get(Contant.RWZZSDL), wpdaydwslloss); addWpPoint(resultList, wppointnewMap.get(Contant.YWZZSDL), wpmonthdwslloss); addWpPoint(resultList, wppointnewMap.get(Contant.NWZZSDL), wpyeardwslloss); //环境受累 addWpPoint(resultList, wppointnewMap.get(Contant.RTZZSDL), wpdayhjslloss); addWpPoint(resultList, wppointnewMap.get(Contant.YTZZSDL), wpmonthhjslloss); addWpPoint(resultList, wppointnewMap.get(Contant.NTZZSDL), wpyearhjslloss); double slss = wpdaydwslloss.get() + wpdayhjslloss.get(); resultList.add(createWpPointData(wppointnewMap.get(Contant.SLSSDL),slss)); //欠发发电量 addWpPoint(resultList, wppointnewMap.get(Contant.R0QFZT), wpdayqf0); addWpPoint(resultList, wppointnewMap.get(Contant.R1QFZT), wpdayqf1); addWpPoint(resultList, wppointnewMap.get(Contant.R2QFZT), wpdayqf2); addWpPoint(resultList, wppointnewMap.get(Contant.R3QFZT), wpdayqf3); addWpPoint(resultList, wppointnewMap.get(Contant.R4QFZT), wpdayqf4); }); edosUtil.sendMultiPoint(resultList); } private void geneLineQfloss(AtomicReference linedayqf0, AtomicReference linedayqf1, AtomicReference linedayqf2, AtomicReference linedayqf3, AtomicReference linedayqf4, Windturbinetestingpointnew dayqf0, Windturbinetestingpointnew dayqf1, Windturbinetestingpointnew dayqf2, Windturbinetestingpointnew dayqf3, Windturbinetestingpointnew dayqf4) { double wtdayqf0 = 0.0; double wtdayqf1 = 0.0; double wtdayqf2 = 0.0; double wtdayqf3 = 0.0; double wtdayqf4 = 0.0; try { wtdayqf0 = edosUtil.getSectionData(dayqf0,tomorrow.getTime()).getPointValueInDouble(); wtdayqf1 = edosUtil.getSectionData(dayqf1,tomorrow.getTime()).getPointValueInDouble(); wtdayqf2 = edosUtil.getSectionData(dayqf2,tomorrow.getTime()).getPointValueInDouble(); wtdayqf3 = edosUtil.getSectionData(dayqf3,tomorrow.getTime()).getPointValueInDouble(); wtdayqf4 = edosUtil.getSectionData(dayqf4,tomorrow.getTime()).getPointValueInDouble(); } catch (Exception e) { e.printStackTrace(); } double finalWtdayqf = wtdayqf0; linedayqf0.updateAndGet(v -> new Double((double) (v + finalWtdayqf))); double finalWtdayqf1 = wtdayqf1; linedayqf1.updateAndGet(v -> new Double((double) (v + finalWtdayqf1))); double finalWtdayqf2 = wtdayqf2; linedayqf2.updateAndGet(v -> new Double((double) (v + finalWtdayqf2))); double finalWtdayqf3 = wtdayqf3; linedayqf3.updateAndGet(v -> new Double((double) (v + finalWtdayqf3))); double finalWtdayqf4 = wtdayqf4; linedayqf4.updateAndGet(v -> new Double((double) (v + finalWtdayqf4))); } private void addWpPoint(List resultList, Windpowerstationpointnew pointnew, AtomicReference linedaydjloss) { PointData wpPointData = createWpPointData(pointnew, linedaydjloss.get()); resultList.add(wpPointData); } private void geneLineloss(AtomicReference linedaydjloss, AtomicReference linemonthdjloss, AtomicReference lineyeardjloss, Windturbinetestingpointnew dayDjPoint, Windturbinetestingpointnew monthDjPoint, Windturbinetestingpointnew yearDjPoint) { double wtdaydj = 0.0; double wtmonthdj = 0.0; double wtyeardj = 0.0; try { wtdaydj = edosUtil.getSectionData(dayDjPoint,tomorrow.getTime()).getPointValueInDouble(); wtmonthdj = edosUtil.getSectionData(monthDjPoint,tomorrow.getTime()).getPointValueInDouble(); wtyeardj = edosUtil.getSectionData(yearDjPoint,tomorrow.getTime()).getPointValueInDouble(); } catch (Exception e) { e.printStackTrace(); } double finalWtdaydj = wtdaydj; linedaydjloss.updateAndGet(v -> new Double((double) (v + finalWtdaydj))); double finalWtmonthdj = wtmonthdj; linemonthdjloss.updateAndGet(v -> new Double((double) (v + finalWtmonthdj))); double finalWtyeardj = wtyeardj; lineyeardjloss.updateAndGet(v -> new Double((double) (v + finalWtyeardj))); } /** * 风机日五损,欠发状态，欠发电量 * @throws Exception */ private void wtDaylossesReal() throws Exception { List resultList = new ArrayList<>(); wtls.stream().forEach(wt->{ Map 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); List powerDatasSnap = null; List ztmxDatasSnap = null; List bzglDatasSnap = null; List zsglDatasSnap = null; List qfztDatasSnap = null; try { powerDatasSnap = edosUtil.getHistoryDatasSnap(powerPoint, samedayZero.getTime() / 1000, currentDate.getTime() / 1000, null, 60l); if (powerDatasSnap.size()==1){ return; } ztmxDatasSnap = edosUtil.getHistoryDatasSnap(ztmxPoint,samedayZero.getTime()/1000,currentDate.getTime()/1000,null,60l); bzglDatasSnap = edosUtil.getHistoryDatasSnap(bzglPoint,samedayZero.getTime()/1000,currentDate.getTime()/1000,null,60l); zsglDatasSnap = edosUtil.getHistoryDatasSnap(zsglPoint,samedayZero.getTime()/1000,currentDate.getTime()/1000,null,60l); qfztDatasSnap = edosUtil.getHistoryDatasSnap(qfztPoint,samedayZero.getTime()/1000,currentDate.getTime()/1000,null,60l); } catch (Exception e) { e.printStackTrace(); } if (ztmxDatasSnap.size() == powerDatasSnap.size()){ //待机损失 double djss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 0.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRDJSSDL)); //手动停机 double sdtj = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 1.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRSTSSDL)); //并网损失电量 double bwss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 2.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRXNSSDL)); //发电降出力 double fdjcl = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 3.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRQXSSDL)); double xnss = djss + sdtj + bwss + fdjcl; resultList.add(createWtPointData(windturbinetestingpointnewMap.get(Contant.XNSSDL),xnss)); //限电降出力 double xdjcl = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 4.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRQFSSDL)); //限电停机 double xdtj = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 5.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRXDSSDL)); double xdss = xdjcl + xdtj; resultList.add(createWtPointData(windturbinetestingpointnewMap.get(Contant.XDSSDL),xdss)); //故障 double gzss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 6.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRGZSSDL)); //故障受累 double gzsl = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 7.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRSZSSDL)); double gzsss = gzss + gzsl; resultList.add(createWtPointData(windturbinetestingpointnewMap.get(Contant.GZSSDL),gzsss)); //检修 double jxss = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 8.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRJXSSDL)); //检修受累 double jxsl = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 9.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRLZSSDL)); double whss = jxss + jxsl; resultList.add(createWtPointData(windturbinetestingpointnewMap.get(Contant.WHSSDL),whss)); //电网受累 double dwsl = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 10.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRWZSSDL)); //环境受累 double hjsl = generalLoss(ztmxDatasSnap, bzglDatasSnap, zsglDatasSnap, powerDatasSnap, 11.0, resultList, windturbinetestingpointnewMap.get(Contant.WTRTZSSDL)); double slss = dwsl + hjsl; resultList.add(createWtPointData(windturbinetestingpointnewMap.get(Contant.SLSSDL),slss)); //欠发状态 generalQfzt(powerDatasSnap, ztmxDatasSnap, zsglDatasSnap,qfztPoint,resultList); //欠发电量 generalQfss(qfztDatasSnap,bzglDatasSnap,zsglDatasSnap,powerDatasSnap,0.0,resultList,windturbinetestingpointnewMap.get(Contant.R0QFZT)); generalQfss(qfztDatasSnap,bzglDatasSnap,zsglDatasSnap,powerDatasSnap,1.0,resultList,windturbinetestingpointnewMap.get(Contant.R1QFZT)); generalQfss(qfztDatasSnap,bzglDatasSnap,zsglDatasSnap,powerDatasSnap,2.0,resultList,windturbinetestingpointnewMap.get(Contant.R2QFZT)); generalQfss(qfztDatasSnap,bzglDatasSnap,zsglDatasSnap,powerDatasSnap,3.0,resultList,windturbinetestingpointnewMap.get(Contant.R3QFZT)); generalQfss(qfztDatasSnap,bzglDatasSnap,zsglDatasSnap,powerDatasSnap,4.0,resultList,windturbinetestingpointnewMap.get(Contant.R4QFZT)); } }); edosUtil.sendMultiPoint(resultList); } private double generalQfss(List ztmxDatasSnap, List bzglDatasSnap, List zsglDatasSnap, List powerDatasSnap,Double statusValue,List resultList,Windturbinetestingpointnew point) { List pointDataList = ztmxDatasSnap.stream().filter(zt -> zt.getPointValueInDouble() == statusValue).collect(Collectors.toList()); Double bzss = 0.0; Double zsss = 0.0; for(int i= 0;i0){ bzss+=temp; } double temp1 = zsgl - power; if (temp1>0){ zsss+=temp1; } // bzss += (bzgl-power<0?0:bzgl-power); // zsss += (zsgl-power<0?0:zsgl-power); } } } } bzss = bzss /60>=0?bzss/60:0; zsss = zsss/60>=0?zsss/60:0; //待有历史改为用自算损失 PointData wtPointData = createWtPointData(point, zsss); resultList.add(wtPointData); return zsss; } private void generalQfzt(List powerDatasSnap, List ztmxDatasSnap, List zsglDatasSnap,Windturbinetestingpointnew qfztPoint,List resultList) { double zs = 0; double pp = 0; int i = 1; for ( ; i <= 5; i++) { zs += zsglDatasSnap.get(zsglDatasSnap.size()-i).getPointValueInDouble(); pp += powerDatasSnap.get(powerDatasSnap.size()-1).getPointValueInDouble(); } zs /= i; pp /= i; double ztmx = ztmxDatasSnap.get(ztmxDatasSnap.size() - 1).getPointValueInDouble(); double[] underissuanceArray = {0,1,2,3,4,5,11}; double qfzt = 0; if (Arrays.asList(underissuanceArray).contains(ztmx)){ double ratioll = 0; if (zs != 0){ ratioll = (zs-pp)/zs; } if (ratioll<0.05){ qfzt = 0; }else if (ratioll >= 0.05 && ratioll < 0.1){ qfzt = 1; }else if (ratioll >= 0.1 && ratioll < 0.2){ qfzt = 2; }else if (ratioll >= 0.2 && ratioll < 0.4) { qfzt = 3; }else { qfzt = 4; } } PointData wtPointData = createWtPointData(qfztPoint, qfzt); resultList.add(wtPointData); } private PointData createWpPointData(Windpowerstationpointnew linepointnew, double linespeed) { PointData pointData = new PointData(); pointData.setEdnaId(linepointnew.getCode()); pointData.setPointTime(currentDate.getTime()); pointData.setPointName(linepointnew.getName()); pointData.setPointValue(String.valueOf(linespeed)); pointData.setPointValueInDouble(linespeed); return pointData; } /** * 风机月、年五损 * @throws Exception */ private void wtMonthYearlossesReal() throws Exception { List resultList = new ArrayList<>(); boolean firstDayOfMonth = DateUtils.isFirstDayOfMonth(currentDate); boolean firstDayOfYear = DateUtils.isFirstDayOfYear(currentDate); wtls.stream().forEach(wt->{ Map windturbinetestingpointnewMap = wtpAimap.get(wt.getId()); //待机 Windturbinetestingpointnew dayDjPoint = windturbinetestingpointnewMap.get(Contant.WTRDJSSDL); Windturbinetestingpointnew monthDjPoint = windturbinetestingpointnewMap.get(Contant.WTYDJSSDL); Windturbinetestingpointnew 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); 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); 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); 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); 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); 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); 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); 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); 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); 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); 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); geneMonthOrYearLoss(resultList, dayHjslPoint,monthHjslPoint,firstDayOfMonth); geneMonthOrYearLoss(resultList, dayHjslPoint,yearHjslPoint,firstDayOfYear); }); edosUtil.sendMultiPoint(resultList); } private void geneMonthOrYearLoss(List resultList,Windturbinetestingpointnew dayPoint,Windturbinetestingpointnew monthPoint,boolean firstDayOfMonthOrYear) { Double dayValue = 0.0; Double yestodayMonth = 0.0; try { if (!firstDayOfMonthOrYear){ yestodayMonth = edosUtil.getSectionData(monthPoint, DateUtils.getYesterdayEnd().getTime()).getPointValueInDouble(); } dayValue = edosUtil.getSectionData(dayPoint,tomorrow.getTime()).getPointValueInDouble(); } catch (Exception e) { e.printStackTrace(); } Double monthValue = dayValue + yestodayMonth; resultList.add(createWtPointData(monthPoint,monthValue)); } private double generalLoss(List ztmxDatasSnap, List bzglDatasSnap, List zsglDatasSnap, List powerDatasSnap,Double statusValue,List resultList,Windturbinetestingpointnew point) { List pointDataList = ztmxDatasSnap.stream().filter(zt -> zt.getPointValueInDouble() == statusValue).collect(Collectors.toList()); Double bzss = 0.0; Double zsss = 0.0; if (statusValue == 2.0 || statusValue == 3.0 || statusValue == 4.0){ for(int i= 0;i0){ bzss+=temp; } double temp1 = zsgl - power; if (temp1>0){ zsss+=temp1; } // bzss += (bzgl-power<0?0:bzgl-power); // zsss += (zsgl-power<0?0:zsgl-power); } } } }else { for(int i= 0;i0){ bzss+=bzgl; } if (zsgl>0){ zsss+=zsgl; } // bzss += bzgl<0?0:bzgl; // zsss += zsgl<0?0:zsgl; } } } } bzss = bzss /60>=0?bzss/60:0; zsss = zsss/60>=0?zsss/60:0; //待有历史改为用自算损失 PointData wtPointData = createWtPointData(point, zsss); resultList.add(wtPointData); return zsss; } private PointData createWtPointData(Windturbinetestingpointnew fjfdl, Double rfdl) { PointData pointData = new PointData(); pointData.setEdnaId(fjfdl.getCode()); pointData.setPointName(fjfdl.getName()); pointData.setPointTime(currentDate.getTime()); pointData.setPointValueInDouble(rfdl); pointData.setPointValue(String.valueOf(rfdl)); return pointData; } }