package com.gyee.generation.service; import com.gyee.common.contant.Contant; import com.gyee.common.model.PointData; import com.gyee.common.util.DateUtils; import com.gyee.generation.init.CacheContext; import com.gyee.generation.model.auto.*; import com.gyee.generation.util.realtimesource.IEdosUtil; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.*; /** * @ClassName : AverageAndGeneratingService * @Author : xieshengjie * @Date: 2022/3/22 10:42 * @Description : 平均风速，平均功率，SCADA发电量 */ @Service public class AverageAndGeneratingService { private Date samedayZero; private Date monthFirstZero; private Date yearFirstZero; private Date currentDate; private List wpls; private Map> wppromap; private Map> prolinemap; private Map> linewtmap; private Date tomorrow; private List wtls; private Map> wppointmap; private Map> linepointmap; private Map> propointmap; private Map> wtpAimap; @Resource private IEdosUtil edosUtil; @Value("${typeOfElectric.direct}") private String direct; private void init(){ samedayZero = DateUtils.getSamedayZero(); monthFirstZero = DateUtils.getMonthFirstZero(); yearFirstZero = DateUtils.getYearFirstZero(); currentDate = DateUtils.getCurrentDate(); 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; tomorrow = DateUtils.addDays(samedayZero,1); } /** * 保存平均风速，平均功率，scada发电量实时计算点 * @throws Exception */ public void saveAvespeedAndAvepowerAndScada() throws Exception { init(); List resultList = new ArrayList<>(); String monthbenchPoints = Contant.monthbenchPoints; wpls.stream().forEach(wp->{ List projects = wppromap.get(wp.getId()); Map wppointnewmap = wppointmap.get(wp.getId()); ProBasicWppoint wppointnew = wppointnewmap.get(Contant.RPJFS); ProBasicWppoint ywppointnew = wppointnewmap.get(Contant.YPJFS); ProBasicWppoint nwppointnew = wppointnewmap.get(Contant.NPJFS); ProBasicWppoint powerwppointnew = wppointnewmap.get(Contant.RPJGL); ProBasicWppoint ypowerwppointnew = wppointnewmap.get(Contant.YPJGL); ProBasicWppoint npowerwppointnew = wppointnewmap.get(Contant.NPJGL); ProBasicWppoint fdlwppointnew = wppointnewmap.get(Contant.RFDL); ProBasicWppoint yfdlwppointnew = wppointnewmap.get(Contant.YFDL); ProBasicWppoint nfdlwppointnew = wppointnewmap.get(Contant.NFDL); ProBasicWppoint fnlylwppointnew = wppointnewmap.get(Contant.FNLYL); ProBasicWppoint jpeyhlwppointnew = wppointnewmap.get(Contant.JPEYHL); ProBasicWppoint jpeyhtwppointnew = wppointnewmap.get(Contant.JPEYHT); ProBasicWppoint jybmwppointnew = wppointnewmap.get(Contant.JYBM); ProBasicWppoint jyswppointnew = wppointnewmap.get(Contant.JYS); List projectavespeedList = new ArrayList<>(); List yprojectavespeedList = new ArrayList<>(); List nprojectavespeedList = new ArrayList<>(); List projectavepowerList = new ArrayList<>(); List yprojectavepowerList = new ArrayList<>(); List nprojectavepowerList = new ArrayList<>(); List projectfdlList = new ArrayList<>(); List projectyfdlList = new ArrayList<>(); List projectnfdlList = new ArrayList<>(); projects.stream().forEach(project -> { List lines = prolinemap.get(project.getId()); Map projectpointnewmap = propointmap.get(project.getId()); ProBasicWppoint projectpointnew = projectpointnewmap.get(Contant.RPJFS); ProBasicWppoint yprojectpointnew = projectpointnewmap.get(Contant.YPJFS); ProBasicWppoint nprojectpointnew = projectpointnewmap.get(Contant.NPJFS); ProBasicWppoint powerprojectpointnew = projectpointnewmap.get(Contant.RPJGL); ProBasicWppoint ypowerprojectpointnew = projectpointnewmap.get(Contant.YPJGL); ProBasicWppoint npowerprojectpointnew = projectpointnewmap.get(Contant.NPJGL); ProBasicWppoint fdlprojectpointnew = projectpointnewmap.get(Contant.RFDL); ProBasicWppoint yfdlprojectpointnew = projectpointnewmap.get(Contant.YFDL); ProBasicWppoint nfdlprojectpointnew = projectpointnewmap.get(Contant.NFDL); ProBasicWppoint fnlylprojectpointnew = projectpointnewmap.get(Contant.FNLYL); ProBasicWppoint jpeyhlprojectpointnew = projectpointnewmap.get(Contant.JPEYHL); ProBasicWppoint jpeyhtprojectpointnew = projectpointnewmap.get(Contant.JPEYHT); ProBasicWppoint jybmprojectpointnew = projectpointnewmap.get(Contant.JYBM); ProBasicWppoint jysprojectpointnew = projectpointnewmap.get(Contant.JYS); List lineavespeedList = new ArrayList<>(); List ylineavespeedList = new ArrayList<>(); List nlineavespeedList = new ArrayList<>(); List lineavepowerList = new ArrayList<>(); List ylineavepowerList = new ArrayList<>(); List nlineavepowerList = new ArrayList<>(); List linefdlList = new ArrayList<>(); List ylinefdlList = new ArrayList<>(); List nlinefdlList = new ArrayList<>(); lines.stream().forEach(line -> { List windturbines = linewtmap.get(line.getId()); Map linepointnewmap = linepointmap.get(line.getId()); ProBasicWppoint linepointnew = linepointnewmap.get(Contant.RPJFS); ProBasicWppoint ylinepointnew = linepointnewmap.get(Contant.YPJFS); ProBasicWppoint nlinepointnew = linepointnewmap.get(Contant.NPJFS); ProBasicWppoint linepowerpointnew = linepointnewmap.get(Contant.RPJGL); ProBasicWppoint ylinepowerpointnew = linepointnewmap.get(Contant.YPJGL); ProBasicWppoint nlinepowerpointnew = linepointnewmap.get(Contant.NPJGL); ProBasicWppoint linefdlpointnew = linepointnewmap.get(Contant.RFDL); ProBasicWppoint ylinefdlpointnew = linepointnewmap.get(Contant.YFDL); ProBasicWppoint nlinefdlpointnew = linepointnewmap.get(Contant.NFDL); ProBasicWppoint linefnlylpointnew = linepointnewmap.get(Contant.FNLYL); ProBasicWppoint jpeyhlpointnew = linepointnewmap.get(Contant.JPEYHL); ProBasicWppoint jpeyhtpointnew = linepointnewmap.get(Contant.JPEYHT); ProBasicWppoint jybmpointnew = linepointnewmap.get(Contant.JYBM); ProBasicWppoint jyspointnew = linepointnewmap.get(Contant.JYS); List wtavespeedList = new ArrayList<>(); List ywtavespeedList = new ArrayList<>(); List nwtavespeedList = new ArrayList<>(); List wtavepowerList = new ArrayList<>(); List ywtavepowerList = new ArrayList<>(); List nwtavepowerList = new ArrayList<>(); List rfdlList = new ArrayList<>(); List yfdlList = new ArrayList<>(); List nfdlList = new ArrayList<>(); windturbines.stream().forEach(wt->{ Map windturbinetestingpointnewMap = wtpAimap.get(wt.getId()); ProBasicEquipmentPoint aveSpeedPoint = windturbinetestingpointnewMap.get(Contant.RPJFS); ProBasicEquipmentPoint monthAveSpeedPoint = windturbinetestingpointnewMap.get(Contant.YPJFS); ProBasicEquipmentPoint yearAveSpeedPoint = windturbinetestingpointnewMap.get(Contant.NPJFS); ProBasicEquipmentPoint fjssfs = windturbinetestingpointnewMap.get(Contant.AI022); ProBasicEquipmentPoint avePowerPoint = windturbinetestingpointnewMap.get(Contant.RPJGL); ProBasicEquipmentPoint yavePowerPoint = windturbinetestingpointnewMap.get(Contant.YPJGL); ProBasicEquipmentPoint navePowerPoint = windturbinetestingpointnewMap.get(Contant.NPJGL); ProBasicEquipmentPoint fjssgl = windturbinetestingpointnewMap.get(Contant.AI130); ProBasicEquipmentPoint ai064 = windturbinetestingpointnewMap.get(Contant.AI064); ProBasicEquipmentPoint fjfdl = windturbinetestingpointnewMap.get(Contant.RFDL); ProBasicEquipmentPoint fjyfdl = windturbinetestingpointnewMap.get(Contant.YFDL); ProBasicEquipmentPoint fjnfdl = windturbinetestingpointnewMap.get(Contant.NFDL); ProBasicEquipmentPoint ai138 = windturbinetestingpointnewMap.get(Contant.AI138); ProBasicEquipmentPoint ai139 = windturbinetestingpointnewMap.get(Contant.AI139); try { //算发电量 Double rfdl = 0.0; Double yfdl = 0.0; Double nfdl = 0.0; if (direct.contains(wt.getProjectId())){ rfdl = edosUtil.getSectionData(ai064,tomorrow.getTime()).getPointValueInDouble(); yfdl = edosUtil.getSectionData(ai138,tomorrow.getTime()).getPointValueInDouble(); nfdl = edosUtil.getSectionData(ai139,tomorrow.getTime()).getPointValueInDouble(); }else{ Double currentValue = 0.0; Double samedayValue = 0.0; Double monthFirstValue = 0.0; Double yearFirstValue = 0.0; PointData realData = edosUtil.getSectionData(ai064,tomorrow.getTime()); currentValue = realData.getPointValueInDouble(); samedayValue = edosUtil.getSectionData(ai064,samedayZero.getTime()).getPointValueInDouble(); monthFirstValue = edosUtil.getSectionData(ai064,monthFirstZero.getTime()).getPointValueInDouble(); yearFirstValue = edosUtil.getSectionData(ai064,yearFirstZero.getTime()).getPointValueInDouble(); rfdl = currentValue - samedayValue; yfdl = currentValue - monthFirstValue; nfdl = currentValue - yearFirstValue; } PointData fdlpointData = createPointData(fjfdl, rfdl); rfdlList.add(fdlpointData); PointData yfdlpointData = createPointData(fjyfdl, yfdl); yfdlList.add(yfdlpointData); PointData nfdlpointData = createPointData(fjnfdl, nfdl); yfdlList.add(nfdlpointData); //算平均风速 List ssfsList = edosUtil.getHistStat(fjssfs, samedayZero.getTime() / 1000, currentDate.getTime() / 1000, 1l, null, 2); Optional ssfsFirst = ssfsList.stream().findFirst(); if (ssfsFirst.isPresent()){ PointData pointData = ssfsFirst.get(); double inDouble = pointData.getPointValueInDouble(); createWtPointData(aveSpeedPoint, pointData, inDouble); wtavespeedList.add(pointData); } //算月平均风速 List yssfsList = edosUtil.getHistStat(fjssfs, monthFirstZero.getTime() / 1000, currentDate.getTime() / 1000, 1l, null, 2); Optional yssfsFirst = yssfsList.stream().findFirst(); if (yssfsFirst.isPresent()){ PointData pointData = yssfsFirst.get(); double inDouble = pointData.getPointValueInDouble(); createWtPointData(monthAveSpeedPoint, pointData, inDouble); ywtavespeedList.add(pointData); } //算年平均风速 List nssfsList = edosUtil.getHistStat(fjssfs, yearFirstZero.getTime() / 1000, currentDate.getTime() / 1000, 1l, null, 2); Optional nssfsFirst = nssfsList.stream().findFirst(); if (nssfsFirst.isPresent()){ PointData pointData = nssfsFirst.get(); double inDouble = pointData.getPointValueInDouble(); createWtPointData(yearAveSpeedPoint, pointData, inDouble); nwtavespeedList.add(pointData); } //算平均功率 List ssglList = edosUtil.getHistStat(fjssgl, samedayZero.getTime() / 1000, currentDate.getTime() / 1000, 1l, null, 2); Optional ssglFirst = ssglList.stream().findFirst(); if (ssglFirst.isPresent()){ PointData pointData = ssglFirst.get(); double inDouble = pointData.getPointValueInDouble(); createWtPointData(avePowerPoint, pointData, inDouble); wtavepowerList.add(pointData); } //算月平均功率 List yssglList = edosUtil.getHistStat(fjssgl, monthFirstZero.getTime() / 1000, currentDate.getTime() / 1000, 1l, null, 2); Optional yssglFirst = yssglList.stream().findFirst(); if (yssglFirst.isPresent()){ PointData pointData = yssglFirst.get(); double inDouble = pointData.getPointValueInDouble(); createWtPointData(yavePowerPoint, pointData, inDouble); ywtavepowerList.add(pointData); } //算年平均功率 List nssglList = edosUtil.getHistStat(fjssgl, yearFirstZero.getTime() / 1000, currentDate.getTime() / 1000, 1l, null, 2); Optional nssglFirst = nssglList.stream().findFirst(); if (nssglFirst.isPresent()){ PointData pointData = nssglFirst.get(); double inDouble = pointData.getPointValueInDouble(); createWtPointData(navePowerPoint, pointData, inDouble); nwtavepowerList.add(pointData); } } catch (Exception e) { e.printStackTrace(); } }); resultList.addAll(wtavespeedList); resultList.addAll(ywtavespeedList); resultList.addAll(nwtavespeedList); resultList.addAll(wtavepowerList); resultList.addAll(ywtavepowerList); resultList.addAll(nwtavepowerList); resultList.addAll(rfdlList); resultList.addAll(yfdlList); resultList.addAll(nfdlList); double linefdl = rfdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); double lineyfdl = yfdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); double linenfdl = nfdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData fdlpoint = createWpPointData(linefdlpointnew, linefdl); PointData yfdlpoint = createWpPointData(ylinefdlpointnew, lineyfdl); PointData nfdlpoint = createWpPointData(nlinefdlpointnew, linenfdl); linefdlList.add(fdlpoint); ylinefdlList.add(yfdlpoint); nlinefdlList.add(nfdlpoint); //算节能减排 double jpeyhl = lineyfdl * 0.0059; double jpeyht = lineyfdl * 0.8568; double jybm = lineyfdl * 0.37; double jys = lineyfdl * 3.05; PointData jpeyhlpoint = createWpPointData(jpeyhlpointnew, jpeyhl); PointData jpeyhtpoint = createWpPointData(jpeyhtpointnew, jpeyht); PointData jybmpoint = createWpPointData(jybmpointnew, jybm); PointData jyspoint = createWpPointData(jyspointnew, jys); resultList.add(jpeyhlpoint); resultList.add(jpeyhtpoint); resultList.add(jybmpoint); resultList.add(jyspoint); //算风能利用率 List pointList = new ArrayList<>(); double ssdl = 0; Arrays.stream(monthbenchPoints.split(",")).forEach(code->{ pointList.add(linepointnewmap.get(code).getCode()); }); try { List ssdlList = edosUtil.getRealData(pointList); ssdl = ssdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); } catch (Exception e) { e.printStackTrace(); } double fnlyl = (ssdl+lineyfdl)!=0?lineyfdl/(ssdl+lineyfdl):0; PointData fnlylpoint = createWpPointData(linefnlylpointnew, fnlyl); resultList.add(fnlylpoint); OptionalDouble average = wtavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); if (average.isPresent()){ double linespeed = average.getAsDouble(); PointData pointData = createWpPointData(linepointnew, linespeed); lineavespeedList.add(pointData); } OptionalDouble yaverage = ywtavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); if (yaverage.isPresent()){ double linespeed = yaverage.getAsDouble(); PointData pointData = createWpPointData(ylinepointnew, linespeed); ylineavespeedList.add(pointData); } OptionalDouble naverage = nwtavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); if (naverage.isPresent()){ double linespeed = naverage.getAsDouble(); PointData pointData = createWpPointData(nlinepointnew, linespeed); nlineavespeedList.add(pointData); } Double poweraverage = wtavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData powerpointData = createWpPointData(linepowerpointnew, poweraverage); lineavepowerList.add(powerpointData); Double ypoweraverage = ywtavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData ypowerpointData = createWpPointData(ylinepowerpointnew, ypoweraverage); ylineavepowerList.add(ypowerpointData); Double npoweraverage = nwtavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData npowerpointData = createWpPointData(nlinepowerpointnew, npoweraverage); nlineavepowerList.add(npowerpointData); }); OptionalDouble average = lineavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); OptionalDouble yaverage = ylineavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); OptionalDouble naverage = nlineavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); Double prorfdl = linefdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); Double proyfdl = ylinefdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); Double pronfdl = nlinefdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); resultList.addAll(lineavespeedList); resultList.addAll(ylineavespeedList); resultList.addAll(nlineavespeedList); resultList.addAll(lineavepowerList); resultList.addAll(ylineavepowerList); resultList.addAll(nlineavepowerList); resultList.addAll(linefdlList); resultList.addAll(ylinefdlList); resultList.addAll(nlinefdlList); //算节能减排 double jpeyhl = proyfdl * 0.0059; double jpeyht = proyfdl * 0.8568; double jybm = proyfdl * 0.37; double jys = proyfdl * 3.05; PointData jpeyhlpoint = createWpPointData(jpeyhlprojectpointnew, jpeyhl); PointData jpeyhtpoint = createWpPointData(jpeyhtprojectpointnew, jpeyht); PointData jybmpoint = createWpPointData(jybmprojectpointnew, jybm); PointData jyspoint = createWpPointData(jysprojectpointnew, jys); resultList.add(jpeyhlpoint); resultList.add(jpeyhtpoint); resultList.add(jybmpoint); resultList.add(jyspoint); //算风能利用率 List pointList = new ArrayList<>(); double ssdl = 0; Arrays.stream(monthbenchPoints.split(",")).forEach(code->{ pointList.add(projectpointnewmap.get(code).getCode()); }); try { List ssdlList = edosUtil.getRealData(pointList); ssdl = ssdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); } catch (Exception e) { e.printStackTrace(); } double fnlyl = (ssdl+proyfdl)!=0?proyfdl/(ssdl+proyfdl):0; PointData fnlylpoint = createWpPointData(fnlylprojectpointnew, fnlyl); resultList.add(fnlylpoint); PointData rfdlpointData = createWpPointData(fdlprojectpointnew, prorfdl); PointData yfdlpointData = createWpPointData(yfdlprojectpointnew, proyfdl); PointData nfdlpointData = createWpPointData(nfdlprojectpointnew, pronfdl); projectfdlList.add(rfdlpointData); projectyfdlList.add(yfdlpointData); projectnfdlList.add(nfdlpointData); if (average.isPresent()){ double projectspeed = average.getAsDouble(); PointData pointData = createWpPointData(projectpointnew, projectspeed); projectavespeedList.add(pointData); } if (yaverage.isPresent()){ double projectspeed = yaverage.getAsDouble(); PointData pointData = createWpPointData(yprojectpointnew, projectspeed); yprojectavespeedList.add(pointData); } if (naverage.isPresent()){ double projectspeed = naverage.getAsDouble(); PointData pointData = createWpPointData(nprojectpointnew, projectspeed); nprojectavespeedList.add(pointData); } Double poweraverage = lineavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); Double ypoweraverage = ylineavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); Double npoweraverage = nlineavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData powerpointData = createWpPointData(powerprojectpointnew, poweraverage); projectavepowerList.add(powerpointData); PointData ypowerpointData = createWpPointData(ypowerprojectpointnew, ypoweraverage); yprojectavepowerList.add(ypowerpointData); PointData npowerpointData = createWpPointData(npowerprojectpointnew, npoweraverage); nprojectavepowerList.add(npowerpointData); }); resultList.addAll(projectfdlList); resultList.addAll(projectyfdlList); resultList.addAll(projectnfdlList); double fcrfdl = projectfdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData fdlpointData = createWpPointData(fdlwppointnew, fcrfdl); resultList.add(fdlpointData); double fcyfdl = projectyfdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData yfdlpointData = createWpPointData(yfdlwppointnew, fcyfdl); resultList.add(yfdlpointData); //算节能减排 double jpeyhl = fcyfdl * 0.0059; double jpeyht = fcyfdl * 0.8568; double jybm = fcyfdl * 0.37; double jys = fcyfdl * 3.05; PointData jpeyhlpoint = createWpPointData(jpeyhlwppointnew, jpeyhl); PointData jpeyhtpoint = createWpPointData(jpeyhtwppointnew, jpeyht); PointData jybmpoint = createWpPointData(jybmwppointnew, jybm); PointData jyspoint = createWpPointData(jyswppointnew, jys); resultList.add(jpeyhlpoint); resultList.add(jpeyhtpoint); resultList.add(jybmpoint); resultList.add(jyspoint); //算风能利用率 List pointList = new ArrayList<>(); double ssdl = 0; Arrays.stream(monthbenchPoints.split(",")).forEach(code->{ pointList.add(wppointnewmap.get(code).getCode()); }); try { List ssdlList = edosUtil.getRealData(pointList); ssdl = ssdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); } catch (Exception e) { e.printStackTrace(); } double fnlyl = (ssdl+fcyfdl)!=0?fcyfdl/(ssdl+fcyfdl):0; PointData fnlylpoint = createWpPointData(fnlylwppointnew, fnlyl); resultList.add(fnlylpoint); double fcnfdl = projectnfdlList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); PointData nfdlpointData = createWpPointData(nfdlwppointnew, fcnfdl); resultList.add(nfdlpointData); OptionalDouble average = projectavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); resultList.addAll(projectavespeedList); if (average.isPresent()){ double wpspeed = average.getAsDouble(); PointData pointData = createWpPointData(wppointnew, wpspeed); resultList.add(pointData); } OptionalDouble yaverage = yprojectavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); resultList.addAll(yprojectavespeedList); if (yaverage.isPresent()){ double wpspeed = yaverage.getAsDouble(); PointData pointData = createWpPointData(ywppointnew, wpspeed); resultList.add(pointData); } OptionalDouble naverage = nprojectavespeedList.stream().mapToDouble(PointData::getPointValueInDouble).average(); resultList.addAll(nprojectavespeedList); if (naverage.isPresent()){ double wpspeed = naverage.getAsDouble(); PointData pointData = createWpPointData(nwppointnew, wpspeed); resultList.add(pointData); } Double poweraverage = projectavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); resultList.addAll(projectavepowerList); PointData powerpointData = createWpPointData(powerwppointnew, poweraverage); resultList.add(powerpointData); Double ypoweraverage = yprojectavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); resultList.addAll(yprojectavepowerList); PointData ypowerpointData = createWpPointData(ypowerwppointnew, ypoweraverage); resultList.add(ypowerpointData); Double npoweraverage = nprojectavepowerList.stream().mapToDouble(PointData::getPointValueInDouble).sum(); resultList.addAll(nprojectavepowerList); PointData npowerpointData = createWpPointData(npowerwppointnew, npoweraverage); resultList.add(npowerpointData); }); edosUtil.sendMultiPoint(resultList); } private PointData createPointData(ProBasicEquipmentPoint 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; } private PointData createWpPointData(ProBasicWppoint 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; } private void createWtPointData(ProBasicEquipmentPoint aveSpeedPoint, PointData pointData, double inDouble) { pointData.setEdnaId(aveSpeedPoint.getCode()); pointData.setPointName(aveSpeedPoint.getName()); pointData.setPointValueInDouble(inDouble); pointData.setPointValue(String.valueOf(inDouble)); pointData.setPointTime(currentDate.getTime()); } }