package com.gyee.generation.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.gyee.common.contant.ContantXk;
import com.gyee.common.model.PointData;
import com.gyee.generation.init.CacheContext;
import com.gyee.generation.model.auto.*;
import com.gyee.generation.model.vo.StatusValue;
import com.gyee.generation.model.vo.WpType;
import com.gyee.generation.service.auto.IProEconInOrOutSpeedTotal2Service;
import com.gyee.generation.service.auto.IProEconInOrOutSpeedTotalService;
import com.gyee.generation.service.auto.IProEconInputOrOutputSpeedService;
import com.gyee.generation.util.DateUtils;
import com.gyee.generation.util.StringUtils;
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.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
import java.util.concurrent.Executor;
import java.util.stream.Collectors;
@Service
public class InputOrOutPutService {
@Resource
private IEdosUtil edosUtil;
@Resource
private IProEconInOrOutSpeedTotal2Service proEconInOrOutSpeedTotal2Service;
@Resource
private IProEconInOrOutSpeedTotalService proEconInOrOutSpeedTotalService;
@Resource
private IProEconInputOrOutputSpeedService proEconInputOrOutputSpeedService;
@Resource
private Executor executor;
@Value("${frequency.cutinandout}")
private Integer frequency;
private static Map<String, Double> statusRanngMap;
public void initialInputOrOutputSpeed()
{
statusRanngMap=new HashMap<>();
List<ProBasicEquipment> wtls= new ArrayList<>();
for(ProBasicPowerstation wp: CacheContext.wpls)
{
if(wp.getId().contains("FDC") )
{
wtls.addAll(CacheContext.wpwtmap.get(wp.getId()));
}
}
List<ProEconInputOrOutputSpeed> ls=new ArrayList<>();
List<String> mxztls=new ArrayList<>();
List<String> ssfsls=new ArrayList<>();
for (ProBasicEquipment wt: wtls)
{
Map<String, ProBasicEquipmentPoint> pointmap= CacheContext.wtpAimap.get(wt.getId());
ProBasicEquipmentPoint mxzt= pointmap.get(ContantXk.SBZT);
mxztls.add(mxzt.getNemCode());
ProBasicEquipmentPoint ssfs= pointmap.get(ContantXk.CJ_SSFS);
ssfsls.add(ssfs.getNemCode());
}
try {
List<PointData> mxztvaluels = edosUtil.getRealData(mxztls);
if(!mxztvaluels.isEmpty() && mxztvaluels.size()==wtls.size())
{
for (int i=0;i<wtls.size();i++)
{
ProBasicEquipment wt=wtls.get(i);
statusRanngMap.put(wt.getId(),mxztvaluels.get(i).getPointValueInDouble());
}
}
} catch (Exception e) {
throw new RuntimeException(e);
}
}
public void inputOrOutputSpeed(Date recordDate) throws Exception {
// Date begin = DateUtils.addSeconds(recordDate, -60);
//
// Date begin = DateUtils.addHours(recordDate, -frequency);
// Date end = recordDate;
// Map<String, ProEconInputOrOutputSpeed> wtTimeStatusMap=new HashMap<>();
// Map<String,Double> wtLastStatusMap=new HashMap<>();
//
// QueryWrapper<ProEconInputOrOutputSpeed> queryWrapper = new QueryWrapper<>();
// queryWrapper.ge("record_date",begin).le("record_date",end);
// queryWrapper.orderByAsc("record_date");
// List<ProEconInputOrOutputSpeed> recordList = proEconInputOrOutputSpeedService.list(queryWrapper);
//
// Map<String, Map<String,ProEconInputOrOutputSpeed>> statusMap=new HashMap<>();
// if(!recordList.isEmpty())
// {
// for(ProEconInputOrOutputSpeed po:recordList)
// {
// if(statusMap.containsKey(po.getWindturbineId()))
// {
// Map<String, ProEconInputOrOutputSpeed> map= statusMap.get(po.getWindturbineId());
// map.put(String.valueOf(po.getRecordDate().getTime()),po);
// }else
// {
// Map<String, ProEconInputOrOutputSpeed> map= new HashMap<>();
// map.put(String.valueOf(po.getRecordDate().getTime()),po);
// statusMap.put(po.getWindturbineId(),map);
// }
//
// }
// }
List<ProBasicEquipment> wtls= new ArrayList<>();
for(ProBasicPowerstation wp: CacheContext.wpls)
{
if(wp.getId().contains("FDC") )
{
wtls.addAll(CacheContext.wpwtmap.get(wp.getId()));
}
}
List<ProEconInputOrOutputSpeed> ls=new ArrayList<>();
List<String> mxztls=new ArrayList<>();
List<String> ssfsls=new ArrayList<>();
for (ProBasicEquipment wt: wtls)
{
Map<String, ProBasicEquipmentPoint> pointmap= CacheContext.wtpAimap.get(wt.getId());
ProBasicEquipmentPoint mxzt= pointmap.get(ContantXk.SBZT);
mxztls.add(mxzt.getNemCode());
ProBasicEquipmentPoint ssfs= pointmap.get(ContantXk.CJ_SSFS);
ssfsls.add(ssfs.getNemCode());
}
List<PointData> mxztvaluels = edosUtil.getRealData(mxztls);
List<PointData> ssfsvaluels = edosUtil.getRealData(ssfsls);
if(ssfsvaluels.size() == mxztvaluels.size() && ssfsvaluels.size()==wtls.size())
{
for (int i=0;i<wtls.size();i++)
{
ProBasicEquipment wt=wtls.get(i);
double status=StringUtils.round(mxztvaluels.get(i).getPointValueInDouble(),0);
if(null !=statusRanngMap)
{
double lastStatus=StringUtils.round( statusRanngMap.get(wt.getId()),0);
PointData ssfspo=ssfsvaluels.get(i);
// 切入切出风速
if (lastStatus == StatusValue.DJ.getCode() && status == StatusValue.YX.getCode())
{
ProEconInputOrOutputSpeed input = new ProEconInputOrOutputSpeed();
input.setWindturbineId(wt.getId());
input.setWindpowerstationId(wt.getWindpowerstationId());
input.setProjectId(wt.getProjectId());
input.setLineId(wt.getLineId());
input.setRecordDate(DateUtils.truncate(new Date()));
input.setInputOrOutput(1);
input.setSpeed(StringUtils.round(ssfspo.getPointValueInDouble(),2));
// if(statusMap.containsKey(wt.getId()))
// {
// Map<String, ProEconInputOrOutputSpeed> map= statusMap.get(wt.getId());
//
// if(!map.containsKey(String.valueOf(ssfspo.getPointTime())) )
// {
// ls.add(input);
// }
// }else {
// ls.add(input);
// }
ls.add(input);
}
else if (lastStatus == StatusValue.YX.getCode() && status== StatusValue.DJ.getCode())
{
ProEconInputOrOutputSpeed input = new ProEconInputOrOutputSpeed();
input.setWindturbineId(wt.getId());
input.setWindpowerstationId(wt.getWindpowerstationId());
input.setProjectId(wt.getProjectId());
input.setLineId(wt.getLineId());
input.setRecordDate(DateUtils.truncate(new Date()));
input.setInputOrOutput(0);
input.setSpeed(StringUtils.round(ssfspo.getPointValueInDouble(),2));
// if(statusMap.containsKey(wt.getId()))
// {
// Map<String, ProEconInputOrOutputSpeed> map= statusMap.get(wt.getId());
//
// if(!map.containsKey(String.valueOf(ssfspo.getPointTime())) )
// {
// ls.add(input);
// }
// }else
// {
// ls.add(input);
// }
ls.add(input);
}
}
statusRanngMap.put(wt.getId(),status);
}
}
// for (ProBasicEquipment wt: wtls) {
// {
//
//// if (wt.getWindpowerstationId().contains(WpType.GDC.id)) {
//// continue;
//// }
// Map<String, ProBasicEquipmentPoint> pointmap= CacheContext.wtpAimap.get(wt.getId());
//
//
// if(statusMap.containsKey(wt.getId()))
// {
// wtTimeStatusMap=statusMap.get(wt.getId());
// }
//
// double lastStatus=-1;
//
//
// ProBasicEquipmentPoint mxzt= pointmap.get(ContantXk.SBZT);
// ProBasicEquipmentPoint ssfs= pointmap.get(ContantXk.CJ_SSFS);
//
// //获取5分钟没个间隔1秒钟，保证状态与时序库保持一致
// List<PointData> statusls = edosUtil.getHistoryDatasSnap(mxzt.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000,null,1L);
// List<PointData> ssfsls = edosUtil.getHistoryDatasSnap(ssfs.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000,null,1L);
//
//
// if(!statusls.isEmpty() && !ssfsls.isEmpty() && ssfsls.size()==statusls.size())
// {
//
// for(int i=0;i<statusls.size();i++)
// {
//
//
// if(wtLastStatusMap.containsKey(wt.getId()))
// {
// lastStatus=wtLastStatusMap.get(wt.getId());
// }
//
// PointData statuspo=statusls.get(i);
// PointData ssfspo=ssfsls.get(i);
// double status= StringUtils.round(statuspo.getPointValueInDouble(),0);
//
// if(i==0)
// {
// lastStatus=status;
// }
// if (!Objects.equals(lastStatus, status))
// {
//
// // 切入切出风速
// if (lastStatus == 0 && status == 1)
// {
// ProEconInputOrOutputSpeed input = new ProEconInputOrOutputSpeed();
//
// input.setWindturbineId(wt.getId());
// input.setWindpowerstationId(wt.getWindpowerstationId());
// input.setProjectId(wt.getProjectId());
// input.setLineId(wt.getLineId());
// input.setRecordDate(new Date());
// input.setInputOrOutput(1);
//
//
// input.setSpeed(StringUtils.round(ssfspo.getPointValueInDouble(),2));
//
// if(!wtTimeStatusMap.containsKey(String.valueOf(statuspo.getPointTime())) && !wtTimeStatusMap.get(String.valueOf(statuspo.getPointTime())).getWindturbineId().equals(wt.getId()))
// {
// //roEconInputOrOutputSpeedService.save(input);
// ls.add(input);
// }
// lastStatus=status;
//
// }
// else if (lastStatus == 1 && status== 0)
// {
// ProEconInputOrOutputSpeed input = new ProEconInputOrOutputSpeed();
// input.setWindturbineId(wt.getId());
// input.setWindpowerstationId(wt.getWindpowerstationId());
// input.setProjectId(wt.getProjectId());
// input.setLineId(wt.getLineId());
// input.setRecordDate(new Date());
// input.setInputOrOutput(0);
//
// input.setSpeed(StringUtils.round(ssfspo.getPointValueInDouble(),2));
//
// if(!wtTimeStatusMap.containsKey(String.valueOf(statuspo.getPointTime())) && !wtTimeStatusMap.get(String.valueOf(statuspo.getPointTime())).getWindturbineId().equals(wt.getId()))
// {
// //proEconInputOrOutputSpeedService.save(input);
//
// ls.add(input);
// }
// lastStatus=status;
// }
//
// wtLastStatusMap.put(wt.getId(), status);
//
// }
// }
//
//
//
// }
//
// }
//
// System.out.println("切入切出数量"+ls.size());
List<ProEconInputOrOutputSpeed> templs = new ArrayList<>();
for (ProEconInputOrOutputSpeed vo : ls) {
templs.add(vo);
if (templs.size() == 100) {
proEconInputOrOutputSpeedService.saveBatch(templs);
templs = new ArrayList<>();
}
}
if (!templs.isEmpty()) {
proEconInputOrOutputSpeedService.saveBatch(templs);
}
// }
}
public void inputOrOutput(Date currentDate) {
currentDate = DateUtils.truncate(currentDate);
// Date end = DateUtils.addDays(currentDate, 1);
// Date daybegin =DateUtils.truncate(currentDate);
Date end = currentDate;
Date daybegin = DateUtils.addDays(currentDate, -1);
Calendar c = Calendar.getInstance();
c.setTime(daybegin);
c.set(Calendar.DAY_OF_MONTH, 1);
Date monthbegin = c.getTime();
c.set(Calendar.MONTH, 0);
Date yearbegin = c.getTime();
for (ProBasicPowerstation wp : CacheContext.wpls) {
if(wp.getId().contains(WpType.GDC.id))
{
continue;
}
List<ProBasicEquipment> wtls = null;
if (CacheContext.wpwtmap.containsKey(wp.getId())) {
wtls = CacheContext.wpwtmap.get(wp.getId());
}
if (null != wtls && !wtls.isEmpty()) {
for (ProBasicEquipment wt : wtls) {
ProEconInOrOutSpeedTotal total1 = null;
ProEconInOrOutSpeedTotal2 total2 = null;
QueryWrapper<ProEconInOrOutSpeedTotal> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("record_date",daybegin).eq("windturbine_id",wt.getId());
Optional<ProEconInOrOutSpeedTotal> total1o = proEconInOrOutSpeedTotalService.list(queryWrapper)
.stream()
// .filter(i -> i.getWindturbineId().equals(wt.getId())
// && i.getRecordDate().compareTo(daybegin) == 0)
.findFirst();
if (total1o.isPresent()) {
total1 = total1o.get();
}
QueryWrapper<ProEconInOrOutSpeedTotal2> queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("record_date",daybegin).eq("windturbine_id",wt.getId());
Optional<ProEconInOrOutSpeedTotal2> total2o = proEconInOrOutSpeedTotal2Service.list(queryWrapper2).stream()
// .filter(i -> i.getWindturbineId().equals(wt.getId())
// && i.getRecordDate().compareTo(daybegin) == 0)
.findFirst();
if (total2o.isPresent()) {
total2 = total2o.get();
}
if (total1 != null) {
QueryWrapper<ProEconInOrOutSpeedTotal> wrapper = new QueryWrapper<>();
wrapper.eq("id", total1.getId());
proEconInOrOutSpeedTotalService.remove(wrapper);
}
if (total2 != null) {
QueryWrapper<ProEconInOrOutSpeedTotal2> wrapper = new QueryWrapper<>();
wrapper.eq("id", total2.getId());
proEconInOrOutSpeedTotal2Service.remove(wrapper);
}
total1 = new ProEconInOrOutSpeedTotal();
total1.setWindturbineId(wt.getId());
total1.setWindpowerstationId(wt.getWindpowerstationId());
total1.setProjectId(wt.getProjectId());
total1.setLineId(wt.getLineId());
total1.setRecordDate(daybegin);
total1.setCompanyId(wt.getCompanyId());
total1.setRegionId(wt.getRegionId());
if(wt.getWindpowerstationId().contains(WpType.FDC.id))
{
total1.setTypes("-1");
}else
{
total1.setTypes("-2");
}
total2 = new ProEconInOrOutSpeedTotal2();
total2.setWindturbineId(wt.getId());
total2.setWindpowerstationId(wt.getWindpowerstationId());
total2.setProjectId(wt.getProjectId());
total2.setLineId(wt.getLineId());
total2.setRecordDate(daybegin);
total2.setRegionId(wt.getRegionId());
total2.setCompanyId(wt.getCompanyId());
if(wt.getWindpowerstationId().contains(WpType.FDC.id))
{
total2.setTypes("-1");
}else
{
total2.setTypes("-2");
}
newMethod(end, daybegin, monthbegin, yearbegin, wt.getId(), total1, total2);
verify(total1);
proEconInOrOutSpeedTotalService.save(total1);
proEconInOrOutSpeedTotal2Service.save(total2);
}
}
}
}
private void verify(ProEconInOrOutSpeedTotal total1) {
//日小风切入
if (Double.isInfinite(total1.getDayInputSmall()) || Double.isNaN(total1.getDayInputSmall()))
{
total1.setDayInputSmall(0.0);
}else
{
total1.setDayInputSmall(StringUtils.round(total1.getDayInputSmall(),2));
}
//日小风切入最小值
if (Double.isInfinite(total1.getDayInputSmallMin()) || Double.isNaN(total1.getDayInputSmallMin()))
{
total1.setDayInputSmallMin(0.0);
}else
{
total1.setDayInputSmallMin(StringUtils.round(total1.getDayInputSmallMin(),2));
}
//日小风切入最大值
if (Double.isInfinite(total1.getDayInputSmallMax()) || Double.isNaN(total1.getDayInputSmallMax()))
{
total1.setDayInputSmallMax(0.0);
}else
{
total1.setDayInputSmallMax(StringUtils.round(total1.getDayInputSmallMax(),2));
}
//日大风切入
if (Double.isInfinite(total1.getDayInputBig()) || Double.isNaN(total1.getDayInputBig()))
{
total1.setDayInputBig(0.0);
}else
{
total1.setDayInputBig(StringUtils.round(total1.getDayInputBig(),2));
}
//日大风切入最大值
if (Double.isInfinite(total1.getDayInputBigMin()) || Double.isNaN(total1.getDayInputBigMin()))
{
total1.setDayInputBigMin(0.0);
}else
{
total1.setDayInputBigMin(StringUtils.round(total1.getDayInputBigMin(),2));
}
//日大风切入最大值
if (Double.isInfinite(total1.getDayInputBigMax()) || Double.isNaN(total1.getDayInputBigMax()))
{
total1.setDayInputBigMax(0.0);
}else
{
total1.setDayInputBigMax(StringUtils.round(total1.getDayInputBigMax(),2));
}
//日小风切出
if (Double.isInfinite(total1.getDayOutputSmall()) || Double.isNaN(total1.getDayOutputSmall()))
{
total1.setDayOutputSmall(0.0);
}else
{
total1.setDayOutputSmall(StringUtils.round(total1.getDayOutputSmall(),2));
}
//日小风切出最小值
if (Double.isInfinite(total1.getDayOutputSmallMin()) || Double.isNaN(total1.getDayOutputSmallMin()))
{
total1.setDayOutputSmallMin(0.0);
}else
{
total1.setDayOutputSmallMin(StringUtils.round(total1.getDayOutputSmallMin(),2));
}
//日小风切出最大值
if (Double.isInfinite(total1.getDayOutputSmallMax()) || Double.isNaN(total1.getDayOutputSmallMax()))
{
total1.setDayOutputSmallMax(0.0);
}else
{
total1.setDayOutputSmallMax(StringUtils.round(total1.getDayOutputSmallMax(),2));
}
//日大风切出
if (Double.isInfinite(total1.getDayOutputBig()) || Double.isNaN(total1.getDayOutputBig()))
{
total1.setDayOutputBig(0.0);
}else
{
total1.setDayOutputBig(StringUtils.round(total1.getDayOutputBig(),2));
}
//日大风切出最大值
if (Double.isInfinite(total1.getDayOutputBigMin()) || Double.isNaN(total1.getDayOutputBigMin()))
{
total1.setDayOutputBigMin(0.0);
}else
{
total1.setDayOutputBigMin(StringUtils.round(total1.getDayOutputBigMin(),2));
}
//日大风切出最大值
if (Double.isInfinite(total1.getDayOutputBigMax()) || Double.isNaN(total1.getDayOutputBigMax()))
{
total1.setDayOutputBigMax(0.0);
}else
{
total1.setDayOutputBigMax(StringUtils.round(total1.getDayOutputBigMax(),2));
}
//月小风切入
if (Double.isInfinite(total1.getMonthInputSmall()) || Double.isNaN(total1.getMonthInputSmall()))
{
total1.setMonthInputSmall(0.0);
}else
{
total1.setMonthInputSmall(StringUtils.round(total1.getMonthInputSmall(),2));
}
//月小风切入最小值
if (Double.isInfinite(total1.getMonthInputSmallMin()) || Double.isNaN(total1.getMonthInputSmallMin()))
{
total1.setMonthInputSmallMin(0.0);
}else
{
total1.setMonthInputSmallMin(StringUtils.round(total1.getMonthInputSmallMin(),2));
}
//月小风切入最大值
if (Double.isInfinite(total1.getMonthInputSmallMax()) || Double.isNaN(total1.getMonthInputSmallMax()))
{
total1.setMonthInputSmallMax(0.0);
}else
{
total1.setMonthInputSmallMax(StringUtils.round(total1.getMonthInputSmallMax(),2));
}
//月大风切入
if (Double.isInfinite(total1.getMonthInputBig()) || Double.isNaN(total1.getMonthInputBig()))
{
total1.setMonthInputBig(0.0);
}else
{
total1.setMonthInputBig(StringUtils.round(total1.getMonthInputBig(),2));
}
//月大风切入最大值
if (Double.isInfinite(total1.getMonthInputBigMin()) || Double.isNaN(total1.getMonthInputBigMin()))
{
total1.setMonthInputBigMin(0.0);
}else
{
total1.setMonthInputBigMin(StringUtils.round(total1.getMonthInputBigMin(),2));
}
//月大风切入最大值
if (Double.isInfinite(total1.getMonthInputBigMax()) || Double.isNaN(total1.getMonthInputBigMax()))
{
total1.setMonthInputBigMax(0.0);
}else
{
total1.setMonthInputBigMax(StringUtils.round(total1.getMonthInputBigMax(),2));
}
//月小风切出
if (Double.isInfinite(total1.getMonthOutputSmall()) || Double.isNaN(total1.getMonthOutputSmall()))
{
total1.setMonthOutputSmall(0.0);
}else
{
total1.setMonthOutputSmall(StringUtils.round(total1.getMonthOutputSmall(),2));
}
//月小风切出最小值
if (Double.isInfinite(total1.getMonthOutputSmallMin()) || Double.isNaN(total1.getMonthOutputSmallMin()))
{
total1.setMonthOutputSmallMin(0.0);
}else
{
total1.setMonthOutputSmallMin(StringUtils.round(total1.getMonthOutputSmallMin(),2));
}
//月小风切出最大值
if (Double.isInfinite(total1.getMonthOutputSmallMax()) || Double.isNaN(total1.getMonthOutputSmallMax()))
{
total1.setMonthOutputSmallMax(0.0);
}else
{
total1.setMonthOutputSmallMax(StringUtils.round(total1.getMonthOutputSmallMax(),2));
}
//月大风切出
if (Double.isInfinite(total1.getMonthOutputBig()) || Double.isNaN(total1.getMonthOutputBig()))
{
total1.setMonthOutputBig(0.0);
}else
{
total1.setMonthOutputBig(StringUtils.round(total1.getMonthOutputBig(),2));
}
//月大风切出最大值
if (Double.isInfinite(total1.getMonthOutputBigMin()) || Double.isNaN(total1.getMonthOutputBigMin()))
{
total1.setMonthOutputBigMin(0.0);
}else
{
total1.setMonthOutputBigMin(StringUtils.round(total1.getMonthOutputBigMin(),2));
}
//月大风切出最大值
if (Double.isInfinite(total1.getMonthOutputBigMax()) || Double.isNaN(total1.getMonthOutputBigMax()))
{
total1.setMonthOutputBigMax(0.0);
}else
{
total1.setMonthOutputBigMax(StringUtils.round(total1.getMonthOutputBigMax(),2));
}
//年小风切入
if (Double.isInfinite(total1.getYearInputSmall()) || Double.isNaN(total1.getYearInputSmall()))
{
total1.setYearInputSmall(0.0);
}else
{
total1.setYearInputSmall(StringUtils.round(total1.getYearInputSmall(),2));
}
//年小风切入最小值
if (Double.isInfinite(total1.getYearInputSmallMin()) || Double.isNaN(total1.getYearInputSmallMin()))
{
total1.setYearInputSmallMin(0.0);
}else
{
total1.setYearInputSmallMin(StringUtils.round(total1.getYearInputSmallMin(),2));
}
//年小风切入最大值
if (Double.isInfinite(total1.getYearInputSmallMax()) || Double.isNaN(total1.getYearInputSmallMax()))
{
total1.setYearInputSmallMax(0.0);
}else
{
total1.setYearInputSmallMax(StringUtils.round(total1.getYearInputSmallMax(),2));
}
//年大风切入
if (Double.isInfinite(total1.getYearInputBig()) || Double.isNaN(total1.getYearInputBig()))
{
total1.setYearInputBig(0.0);
}else
{
total1.setYearInputBig(StringUtils.round(total1.getYearInputBig(),2));
}
//年大风切入最大值
if (Double.isInfinite(total1.getYearInputBigMin()) || Double.isNaN(total1.getYearInputBigMin()))
{
total1.setYearInputBigMin(0.0);
}else
{
total1.setYearInputBigMin(StringUtils.round(total1.getYearInputBigMin(),2));
}
//年大风切入最大值
if (Double.isInfinite(total1.getYearInputBigMax()) || Double.isNaN(total1.getYearInputBigMax()))
{
total1.setYearInputBigMax(0.0);
}else
{
total1.setYearInputBigMax(StringUtils.round(total1.getYearInputBigMax(),2));
}
//年小风切出
if (Double.isInfinite(total1.getYearOutputSmall()) || Double.isNaN(total1.getYearOutputSmall()))
{
total1.setYearOutputSmall(0.0);
}else
{
total1.setYearOutputSmall(StringUtils.round(total1.getYearOutputSmall(),2));
}
//年小风切出最小值
if (Double.isInfinite(total1.getYearOutputSmallMin()) || Double.isNaN(total1.getYearOutputSmallMin()))
{
total1.setYearOutputSmallMin(0.0);
}else
{
total1.setYearOutputSmallMin(StringUtils.round(total1.getYearOutputSmallMin(),2));
}
//年小风切出最大值
if (Double.isInfinite(total1.getYearOutputSmallMax()) || Double.isNaN(total1.getYearOutputSmallMax()))
{
total1.setYearOutputSmallMax(0.0);
}else
{
total1.setYearOutputSmallMax(StringUtils.round(total1.getYearOutputSmallMax(),2));
}
//年大风切出
if (Double.isInfinite(total1.getYearOutputBig()) || Double.isNaN(total1.getYearOutputBig()))
{
total1.setYearOutputBig(0.0);
}else
{
total1.setYearOutputBig(StringUtils.round(total1.getYearOutputBig(),2));
}
//年大风切出最大值
if (Double.isInfinite(total1.getYearOutputBigMin()) || Double.isNaN(total1.getYearOutputBigMin()))
{
total1.setYearOutputBigMin(0.0);
}else
{
total1.setYearOutputBigMin(StringUtils.round(total1.getYearOutputBigMin(),2));
}
//年大风切出最大值
if (Double.isInfinite(total1.getYearOutputBigMax()) || Double.isNaN(total1.getYearOutputBigMax()))
{
total1.setYearOutputBigMax(0.0);
}else
{
total1.setYearOutputBigMax(StringUtils.round(total1.getYearOutputBigMax(),2));
}
//小风切入
if (Double.isInfinite(total1.getInputSmall()) || Double.isNaN(total1.getInputSmall()))
{
total1.setInputSmall(0.0);
}else
{
total1.setInputSmall(StringUtils.round(total1.getInputSmall(),2));
}
//小风切入最小值
if (Double.isInfinite(total1.getInputSmallMin()) || Double.isNaN(total1.getInputSmallMin()))
{
total1.setInputSmallMin(0.0);
}else
{
total1.setInputSmallMin(StringUtils.round(total1.getInputSmallMin(),2));
}
//小风切入最大值
if (Double.isInfinite(total1.getInputSmallMax()) || Double.isNaN(total1.getInputSmallMax()))
{
total1.setInputSmallMax(0.0);
}else
{
total1.setInputSmallMax(StringUtils.round(total1.getInputSmallMax(),2));
}
//大风切入
if (Double.isInfinite(total1.getInputBig()) || Double.isNaN(total1.getInputBig()))
{
total1.setInputBig(0.0);
}else
{
total1.setInputBig(StringUtils.round(total1.getInputBig(),2));
}
//大风切入最大值
if (Double.isInfinite(total1.getInputBigMin()) || Double.isNaN(total1.getInputBigMin()))
{
total1.setInputBigMin(0.0);
}else
{
total1.setInputBigMin(StringUtils.round(total1.getInputBigMin(),2));
}
//大风切入最大值
if (Double.isInfinite(total1.getInputBigMax()) || Double.isNaN(total1.getInputBigMax()))
{
total1.setInputBigMax(0.0);
}else
{
total1.setInputBigMax(StringUtils.round(total1.getInputBigMax(),2));
}
//小风切出
if (Double.isInfinite(total1.getOutputSmall()) || Double.isNaN(total1.getOutputSmall()))
{
total1.setOutputSmall(0.0);
}else
{
total1.setOutputSmall(StringUtils.round(total1.getOutputSmall(),2));
}
//小风切出最小值
if (Double.isInfinite(total1.getOutputSmallMin()) || Double.isNaN(total1.getOutputSmallMin()))
{
total1.setOutputSmallMin(0.0);
}else
{
total1.setOutputSmallMin(StringUtils.round(total1.getOutputSmallMin(),2));
}
//小风切出最大值
if (Double.isInfinite(total1.getOutputSmallMax()) || Double.isNaN(total1.getOutputSmallMax()))
{
total1.setOutputSmallMax(0.0);
}else
{
total1.setOutputSmallMax(StringUtils.round(total1.getOutputSmallMax(),2));
}
//大风切出
if (Double.isInfinite(total1.getOutputBig()) || Double.isNaN(total1.getOutputBig()))
{
total1.setOutputBig(0.0);
}else
{
total1.setOutputBig(StringUtils.round(total1.getOutputBig(),2));
}
//大风切出最大值
if (Double.isInfinite(total1.getOutputBigMin()) || Double.isNaN(total1.getOutputBigMin()))
{
total1.setOutputBigMin(0.0);
}else
{
total1.setOutputBigMin(StringUtils.round(total1.getOutputBigMin(),2));
}
//大风切出最大值
if (Double.isInfinite(total1.getOutputBigMax()) || Double.isNaN(total1.getOutputBigMax()))
{
total1.setOutputBigMax(0.0);
}else
{
total1.setOutputBigMax(StringUtils.round(total1.getOutputBigMax(),2));
}
//日小风切入合格率
if (Double.isInfinite(total1.getDayInputSmallRatio()) || Double.isNaN(total1.getDayInputSmallRatio()))
{
total1.setDayInputSmallRatio(0.0);
}else
{
total1.setDayInputSmallRatio(StringUtils.round(total1.getDayInputSmallRatio(),2));
}
//日小风切出合格率
if (Double.isInfinite(total1.getDayOutputSmallRatio()) || Double.isNaN(total1.getDayOutputSmallRatio()))
{
total1.setDayOutputSmallRatio(0.0);
}else
{
total1.setDayOutputSmallRatio(StringUtils.round(total1.getDayOutputSmallRatio(),2));
}
//日大风切入合格率
if (Double.isInfinite(total1.getDayInputBigRatio()) || Double.isNaN(total1.getDayInputBigRatio()))
{
total1.setDayInputBigRatio(0.0);
}else
{
total1.setDayInputBigRatio(StringUtils.round(total1.getDayInputBigRatio(),2));
}
//日大风切出合格率
if (Double.isInfinite(total1.getDayOutputBigRatio()) || Double.isNaN(total1.getDayOutputBigRatio()))
{
total1.setDayOutputBigRatio(0.0);
}else
{
total1.setDayOutputBigRatio(StringUtils.round(total1.getDayOutputBigRatio(),2));
}
//月小风切入合格率
if (Double.isInfinite(total1.getMonthInputSmallRatio()) || Double.isNaN(total1.getMonthInputSmallRatio()))
{
total1.setMonthInputSmallRatio(0.0);
}else
{
total1.setMonthInputSmallRatio(StringUtils.round(total1.getMonthInputSmallRatio(),2));
}
//月小风切出合格率
if (Double.isInfinite(total1.getMonthOutputSmallRatio()) || Double.isNaN(total1.getMonthOutputSmallRatio()))
{
total1.setMonthOutputSmallRatio(0.0);
}else
{
total1.setMonthOutputSmallRatio(StringUtils.round(total1.getMonthOutputSmallRatio(),2));
}
//月大风切入合格率
if (Double.isInfinite(total1.getMonthInputBigRatio()) || Double.isNaN(total1.getMonthInputBigRatio()))
{
total1.setMonthInputBigRatio(0.0);
}else
{
total1.setMonthInputBigRatio(StringUtils.round(total1.getMonthInputBigRatio(),2));
}
//月大风切出合格率
if (Double.isInfinite(total1.getMonthOutputBigRatio()) || Double.isNaN(total1.getMonthOutputBigRatio()))
{
total1.setMonthOutputBigRatio(0.0);
}else
{
total1.setMonthOutputBigRatio(StringUtils.round(total1.getMonthOutputBigRatio(),2));
}
//年小风切入合格率
if (Double.isInfinite(total1.getYearInputSmallRatio()) || Double.isNaN(total1.getYearInputSmallRatio()))
{
total1.setYearInputSmallRatio(0.0);
}else
{
total1.setYearInputSmallRatio(StringUtils.round(total1.getYearInputSmallRatio(),2));
}
//年小风切出合格率
if (Double.isInfinite(total1.getYearOutputSmallRatio()) || Double.isNaN(total1.getYearOutputSmallRatio()))
{
total1.setYearOutputSmallRatio(0.0);
}else
{
total1.setYearOutputSmallRatio(StringUtils.round(total1.getYearOutputSmallRatio(),2));
}
//年大风切入合格率
if (Double.isInfinite(total1.getYearInputBigRatio()) || Double.isNaN(total1.getYearInputBigRatio()))
{
total1.setYearInputBigRatio(0.0);
}else
{
total1.setYearInputBigRatio(StringUtils.round(total1.getYearInputBigRatio(),2));
}
//年大风切出合格率
if (Double.isInfinite(total1.getYearOutputBigRatio()) || Double.isNaN(total1.getYearOutputBigRatio()))
{
total1.setYearOutputBigRatio(0.0);
}else
{
total1.setYearOutputBigRatio(StringUtils.round(total1.getYearOutputBigRatio(),2));
}
//总小风切入合格率
if (Double.isInfinite(total1.getInputSmallRatio()) || Double.isNaN(total1.getInputSmallRatio()))
{
total1.setInputSmallRatio(0.0);
}else
{
total1.setInputSmallRatio(StringUtils.round(total1.getInputSmallRatio(),2));
}
//总小风切出合格率
if (Double.isInfinite(total1.getOutputSmallRatio()) || Double.isNaN(total1.getOutputSmallRatio()))
{
total1.setOutputSmallRatio(0.0);
}else
{
total1.setOutputSmallRatio(StringUtils.round(total1.getOutputSmallRatio(),2));
}
//总大风切入合格率
if (Double.isInfinite(total1.getInputBigRatio()) || Double.isNaN(total1.getInputBigRatio()))
{
total1.setInputBigRatio(0.0);
}else
{
total1.setInputBigRatio(StringUtils.round(total1.getInputBigRatio(),2));
}
//总大风切出合格率
if (Double.isInfinite(total1.getOutputBigMaxRatio()) || Double.isNaN(total1.getOutputBigMaxRatio()))
{
total1.setOutputBigMaxRatio(0.0);
}else
{
total1.setOutputBigMaxRatio(StringUtils.round(total1.getOutputBigMaxRatio(),2));
}
}
private void newMethod(Date end, Date daybegin, Date monthbegin, Date yearbegin, String windturbineId, ProEconInOrOutSpeedTotal total1, ProEconInOrOutSpeedTotal2 total2) {
buildDay(end, daybegin, windturbineId, total1, total2);
buildMonth(end, monthbegin, windturbineId, total1, total2);
buildyear(end, yearbegin, windturbineId, total1, total2);
QueryWrapper<ProEconInOrOutSpeedTotal> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("windturbine_id",windturbineId);
List<ProEconInOrOutSpeedTotal> items = proEconInOrOutSpeedTotalService.list(queryWrapper);
// .stream()
// .filter(i -> i.getWindturbineId().equals(windturbineId)).collect(Collectors.toList());
items.add(total1);
//总小风切入
DoubleSummaryStatistics summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayInputSmall()) && i.getDayInputSmall() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayInputSmall).summaryStatistics();
total1.setInputSmall(summaryStatistics.getAverage());
//总小风切入最大值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayInputSmallMax()) && i.getDayInputSmallMax() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayInputSmallMax).summaryStatistics();
total1.setInputSmallMax(summaryStatistics.getMax());
//总小风切入最小值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayInputSmallMin()) && i.getDayInputSmallMin() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayInputSmallMin).summaryStatistics();
total1.setInputSmallMin(summaryStatistics.getMin());
//总大风切入
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayInputBig()) && i.getDayInputBig() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayInputBig).summaryStatistics();
total1.setInputBig(summaryStatistics.getAverage());
//总大风切入最大值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayInputBigMax()) && i.getDayInputBigMax() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayInputBigMax).summaryStatistics();
total1.setInputBigMax(summaryStatistics.getMax());
//总大风切入最小值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayInputBigMin()) && i.getDayInputBigMin() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayInputBigMin).summaryStatistics();
total1.setInputBigMin(summaryStatistics.getMin());
//总小风切出
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayOutputSmall()) && i.getDayOutputSmall() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayOutputSmall).summaryStatistics();
total1.setOutputSmall(summaryStatistics.getAverage());
//总小风切出最大值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayOutputSmallMax()) && i.getDayOutputSmallMax() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayOutputSmallMax).summaryStatistics();
total1.setOutputSmallMax(summaryStatistics.getMax());
//总小风切出最小值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayOutputSmallMin()) && i.getDayOutputSmallMin() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayOutputSmallMin).summaryStatistics();
total1.setOutputSmallMin(summaryStatistics.getMin());
//总大风切出
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayOutputBig()) && i.getDayOutputBig() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayOutputBig).summaryStatistics();
total1.setOutputBig(summaryStatistics.getAverage());
//总大风切出最大值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayOutputBigMax()) && i.getDayOutputBigMax() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayOutputBigMax).summaryStatistics();
total1.setOutputBigMax(summaryStatistics.getMax());
//总大风切出最小值
summaryStatistics = items.stream()
.filter(i -> StringUtils.notEmp(i.getDayOutputBigMin()) && i.getDayOutputBigMin() > 0)
.mapToDouble(ProEconInOrOutSpeedTotal::getDayOutputBigMin).summaryStatistics();
total1.setOutputBigMin(summaryStatistics.getMin());
QueryWrapper<ProEconInputOrOutputSpeed> queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("windturbine_id",windturbineId).isNotNull("speed").ne("speed",0);
List<ProEconInputOrOutputSpeed> recordList = proEconInputOrOutputSpeedService.list(queryWrapper2);
// .stream()
// .filter(i -> i.getWindturbineId().equals(windturbineId) && StringUtils.notEmp(i.getSpeed())
// && i.getSpeed() != 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> inputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 1).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> outputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> AList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> ACountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BCountList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CList = inputrecordList.stream().filter(i -> i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CCountList = inputrecordList.stream().filter(i -> i.getSpeed() > 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DList = outputrecordList.stream().filter(i -> i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DCountList = outputrecordList
.stream().filter(i -> i.getSpeed() > 11).collect(Collectors.toList());
//总小风切入合格率
if (ACountList.size() != 0) {
total1.setInputSmallRatio(new BigDecimal(AList.size()).divide(new BigDecimal(ACountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setInputSmallRatio(0.0);
}
//总小风切出合格率
if (BCountList.size() != 0) {
total1.setOutputSmallRatio(new BigDecimal(BList.size()).divide(new BigDecimal(BCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setOutputSmallRatio(0.0);
}
//总大风切入合格率
if (CCountList.size() != 0) {
total1.setInputBigRatio(new BigDecimal(CList.size()).divide(new BigDecimal(CCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setInputBigRatio(0.0);
}
//总大风切出合格率
if (DCountList.size() != 0) {
total1.setOutputBigMaxRatio(new BigDecimal(DList.size()).divide(new BigDecimal(DCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setOutputBigMaxRatio(0.0);
}
}
private void buildDay(Date end, Date daybegin, String windturbineId, ProEconInOrOutSpeedTotal total1, ProEconInOrOutSpeedTotal2 total2) {
int count;
QueryWrapper<ProEconInputOrOutputSpeed> queryWrapper = new QueryWrapper<>();
queryWrapper.ge("record_date",daybegin).le("record_date",end).eq("windturbine_id",windturbineId).isNotNull("speed");
List<ProEconInputOrOutputSpeed> recordList = proEconInputOrOutputSpeedService.list(queryWrapper);
// .stream()
// .filter(i -> i.getWindturbineId().equals(windturbineId) && StringUtils.notEmp(i.getSpeed())
// && (i.getRecordDate().compareTo(daybegin) == 0 || i.getRecordDate().after(daybegin))
// && (i.getRecordDate().compareTo(end) == 0 || i.getRecordDate().before(end))
// && i.getSpeed() != 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> inputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 1).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> outputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> AList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> ACountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BCountList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CCountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() > 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DList = outputrecordList.stream().filter(i -> i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DCountList = outputrecordList
.stream().filter(i -> i.getSpeed() > 11).collect(Collectors.toList());
if (ACountList.size() != 0) {
total1.setDayInputSmallRatio(new BigDecimal(AList.size()).divide(new BigDecimal(ACountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setDayInputSmallRatio(0.0);
}
if (BCountList.size() != 0) {
total1.setDayOutputSmallRatio(new BigDecimal(BList.size()).divide(new BigDecimal(BCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setDayOutputSmallRatio(0.0);
}
if (CCountList.size() != 0) {
total1.setDayInputBigRatio(new BigDecimal(CList.size()).divide(new BigDecimal(CCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setDayInputBigRatio(0.0);
}
if (DCountList.size() != 0) {
total1.setDayOutputBigRatio(new BigDecimal(DList.size()).divide(new BigDecimal(DCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setDayOutputBigRatio(0.0);
}
List<ProEconInputOrOutputSpeed> A1List = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() < 2).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A2List = inputrecordList.stream().filter(i -> i.getSpeed() >= 2
&& i.getSpeed() < 2.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A3List = inputrecordList.stream().filter(i -> i.getSpeed() >= 2.5
&& i.getSpeed() < 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A4List = inputrecordList.stream().filter(i -> i.getSpeed() >= 3
&& i.getSpeed() < 3.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A5List = inputrecordList.stream().filter(i -> i.getSpeed() >= 3.5
&& i.getSpeed() < 4).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A6List = inputrecordList.stream().filter(i -> i.getSpeed() >= 4
&& i.getSpeed() < 5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A7List = inputrecordList.stream().filter(i -> i.getSpeed() >= 5
&& i.getSpeed() <= 11).collect(Collectors.toList());
DoubleSummaryStatistics summaryStatistics = inputrecordList.stream().filter(i ->
i.getSpeed() > 0 && i.getSpeed() < 5)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setDayInputSmall(summaryStatistics.getAverage());
total1.setDayInputSmallMax(summaryStatistics.getMax());
total1.setDayInputSmallMin(summaryStatistics.getMin());
summaryStatistics = inputrecordList.stream().filter(i ->
i.getSpeed() > 18 && i.getSpeed() < 30)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setDayInputBig(summaryStatistics.getAverage());
total1.setDayInputBigMax(summaryStatistics.getMax());
total1.setDayInputBigMin(summaryStatistics.getMin());
total2.setDaya1((double) A1List.size());
total2.setDaya2((double) A2List.size());
total2.setDaya3((double) A3List.size());
total2.setDaya4((double) A4List.size());
total2.setDaya5((double) A5List.size());
total2.setDaya6((double) A6List.size());
total2.setDaya7((double) A7List.size());
count = A1List.size() + A2List.size() + A3List.size() + A4List.size() + A5List.size() + A6List.size() + A7List.size();
if (count > 0) {
total2.setDaya8(new BigDecimal(A1List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya9(new BigDecimal(A2List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya10(new BigDecimal(A3List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya11(new BigDecimal(A4List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya12(new BigDecimal(A5List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya13(new BigDecimal(A6List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya14(new BigDecimal(A7List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total2.setDaya8(0.0);
total2.setDaya9(0.0);
total2.setDaya10(0.0);
total2.setDaya11(0.0);
total2.setDaya12(0.0);
total2.setDaya13(0.0);
total2.setDaya14(0.0);
}
List<ProEconInputOrOutputSpeed> B1List = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() < 2).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B2List = outputrecordList.stream().filter(i -> i.getSpeed() >= 2
&& i.getSpeed() < 2.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B3List = outputrecordList.stream().filter(i -> i.getSpeed() >= 2.5
&& i.getSpeed() < 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B4List = outputrecordList.stream().filter(i -> i.getSpeed() >= 3
&& i.getSpeed() < 3.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B5List = outputrecordList.stream().filter(i -> i.getSpeed() >= 3.5
&& i.getSpeed() < 4).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B6List = outputrecordList.stream().filter(i -> i.getSpeed() >= 4
&& i.getSpeed() < 5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B7List = outputrecordList.stream().filter(i -> i.getSpeed() >= 5
&& i.getSpeed() <= 11).collect(Collectors.toList());
summaryStatistics = outputrecordList.stream().filter(i ->
i.getSpeed() > 0 && i.getSpeed() < 5)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setDayOutputSmall(summaryStatistics.getAverage());
total1.setDayOutputSmallMax(summaryStatistics.getMax());
total1.setDayOutputSmallMin(summaryStatistics.getMin());
summaryStatistics = outputrecordList.stream().filter(i ->
i.getSpeed() > 18 && i.getSpeed() < 30)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setDayOutputBig(summaryStatistics.getAverage());
total1.setDayOutputBigMax(summaryStatistics.getMax());
total1.setDayOutputBigMin(summaryStatistics.getMin());
total2.setDaya1((double) B1List.size());
total2.setDaya2((double) B2List.size());
total2.setDaya3((double) B3List.size());
total2.setDaya4((double) B4List.size());
total2.setDaya5((double) B5List.size());
total2.setDaya6((double) B6List.size());
total2.setDaya7((double) B7List.size());
count = B1List.size() + B2List.size() + B3List.size() + B4List.size() + B5List.size() + B6List.size() + B7List.size();
if (count > 0) {
total2.setDaya8(new BigDecimal(B1List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya9(new BigDecimal(B2List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya10(new BigDecimal(B3List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya11(new BigDecimal(B4List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya12(new BigDecimal(B5List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya13(new BigDecimal(B6List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setDaya14(new BigDecimal(B7List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total2.setDaya8(0.0);
total2.setDaya9(0.0);
total2.setDaya10(0.0);
total2.setDaya11(0.0);
total2.setDaya12(0.0);
total2.setDaya13(0.0);
total2.setDaya14(0.0);
}
}
private void buildMonth(Date end, Date monthbegin, String windturbineId, ProEconInOrOutSpeedTotal total1, ProEconInOrOutSpeedTotal2 total2) {
int count;
QueryWrapper<ProEconInputOrOutputSpeed> queryWrapper = new QueryWrapper<>();
queryWrapper.ge("record_date",monthbegin).le("record_date",end).eq("windturbine_id",windturbineId).isNotNull("speed");
List<ProEconInputOrOutputSpeed> recordList = proEconInputOrOutputSpeedService.list(queryWrapper);
// .stream()
// .filter(i -> i.getWindturbineId().equals(windturbineId) && StringUtils.notEmp(i.getSpeed())
// && (i.getRecordDate().compareTo(monthbegin) == 0 || i.getRecordDate().after(monthbegin))
// && (i.getRecordDate().compareTo(end) == 0 || i.getRecordDate().before(end))
// && i.getSpeed() != 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> inputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 1).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> outputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> AList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> ACountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BCountList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CCountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() > 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DList = outputrecordList.stream().filter(i -> i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DCountList = outputrecordList
.stream().filter(i -> i.getSpeed() > 11).collect(Collectors.toList());
if (ACountList.size() != 0) {
total1.setMonthInputSmallRatio(new BigDecimal(AList.size()).divide(new BigDecimal(ACountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setMonthInputSmallRatio(0.0);
}
if (BCountList.size() != 0) {
total1.setMonthOutputSmallRatio(new BigDecimal(BList.size()).divide(new BigDecimal(BCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setMonthOutputSmallRatio(0.0);
}
if (CCountList.size() != 0) {
total1.setMonthInputBigRatio(new BigDecimal(CList.size()).divide(new BigDecimal(CCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setMonthInputBigRatio(0.0);
}
if (DCountList.size() != 0) {
total1.setMonthOutputBigRatio(new BigDecimal(DList.size()).divide(new BigDecimal(DCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setMonthOutputBigRatio(0.0);
}
List<ProEconInputOrOutputSpeed> A1List = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() < 2).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A2List = inputrecordList.stream().filter(i -> i.getSpeed() >= 2
&& i.getSpeed() < 2.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A3List = inputrecordList.stream().filter(i -> i.getSpeed() >= 2.5
&& i.getSpeed() < 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A4List = inputrecordList.stream().filter(i -> i.getSpeed() >= 3
&& i.getSpeed() < 3.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A5List = inputrecordList.stream().filter(i -> i.getSpeed() >= 3.5
&& i.getSpeed() < 4).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A6List = inputrecordList.stream().filter(i -> i.getSpeed() >= 4
&& i.getSpeed() < 5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A7List = inputrecordList.stream().filter(i -> i.getSpeed() >= 5
&& i.getSpeed() <= 11).collect(Collectors.toList());
DoubleSummaryStatistics summaryStatistics = inputrecordList.stream().filter(i ->
i.getSpeed() > 0 && i.getSpeed() < 5)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setMonthInputSmall(summaryStatistics.getAverage());
total1.setMonthInputSmallMax(summaryStatistics.getMax());
total1.setMonthInputSmallMin(summaryStatistics.getMin());
summaryStatistics = inputrecordList.stream().filter(i ->
i.getSpeed() > 18 && i.getSpeed() < 30)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setMonthInputBig(summaryStatistics.getAverage());
total1.setMonthInputBigMax(summaryStatistics.getMax());
total1.setMonthInputBigMin(summaryStatistics.getMin());
total2.setMontha1((double) A1List.size());
total2.setMontha2((double) A2List.size());
total2.setMontha3((double) A3List.size());
total2.setMontha4((double) A4List.size());
total2.setMontha5((double) A5List.size());
total2.setMontha6((double) A6List.size());
total2.setMontha7((double) A7List.size());
count = A1List.size() + A2List.size() + A3List.size() + A4List.size() + A5List.size() + A6List.size() + A7List.size();
if (count > 0) {
total2.setMontha8(new BigDecimal(A1List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha9(new BigDecimal(A2List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha10(new BigDecimal(A3List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha11(new BigDecimal(A4List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha12(new BigDecimal(A5List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha13(new BigDecimal(A6List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha14(new BigDecimal(A7List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total2.setMontha8(0.0);
total2.setMontha9(0.0);
total2.setMontha10(0.0);
total2.setMontha11(0.0);
total2.setMontha12(0.0);
total2.setMontha13(0.0);
total2.setMontha14(0.0);
}
List<ProEconInputOrOutputSpeed> B1List = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() < 2).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B2List = outputrecordList.stream().filter(i -> i.getSpeed() >= 2
&& i.getSpeed() < 2.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B3List = outputrecordList.stream().filter(i -> i.getSpeed() >= 2.5
&& i.getSpeed() < 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B4List = outputrecordList.stream().filter(i -> i.getSpeed() >= 3
&& i.getSpeed() < 3.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B5List = outputrecordList.stream().filter(i -> i.getSpeed() >= 3.5
&& i.getSpeed() < 4).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B6List = outputrecordList.stream().filter(i -> i.getSpeed() >= 4
&& i.getSpeed() < 5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B7List = outputrecordList.stream().filter(i -> i.getSpeed() >= 5
&& i.getSpeed() <= 11).collect(Collectors.toList());
summaryStatistics = outputrecordList.stream().filter(i ->
i.getSpeed() > 0 && i.getSpeed() < 5)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setMonthOutputSmall(summaryStatistics.getAverage());
total1.setMonthOutputSmallMax(summaryStatistics.getMax());
total1.setMonthOutputSmallMin(summaryStatistics.getMin());
summaryStatistics = outputrecordList.stream().filter(i ->
i.getSpeed() > 18 && i.getSpeed() < 30)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setMonthOutputBig(summaryStatistics.getAverage());
total1.setMonthOutputBigMax(summaryStatistics.getMax());
total1.setMonthOutputBigMin(summaryStatistics.getMin());
total2.setMontha1((double) B1List.size());
total2.setMontha2((double) B2List.size());
total2.setMontha3((double) B3List.size());
total2.setMontha4((double) B4List.size());
total2.setMontha5((double) B5List.size());
total2.setMontha6((double) B6List.size());
total2.setMontha7((double) B7List.size());
count = B1List.size() + B2List.size() + B3List.size() + B4List.size() + B5List.size() + B6List.size() + B7List.size();
if (count > 0) {
total2.setMontha8(new BigDecimal(B1List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha9(new BigDecimal(B2List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha10(new BigDecimal(B3List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha11(new BigDecimal(B4List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha12(new BigDecimal(B5List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha13(new BigDecimal(B6List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setMontha14(new BigDecimal(B7List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total2.setMontha8(0.0);
total2.setMontha9(0.0);
total2.setMontha10(0.0);
total2.setMontha11(0.0);
total2.setMontha12(0.0);
total2.setMontha13(0.0);
total2.setMontha14(0.0);
}
}
private void buildyear(Date end, Date yearbegin, String windturbineId, ProEconInOrOutSpeedTotal total1, ProEconInOrOutSpeedTotal2 total2) {
int count;
QueryWrapper<ProEconInputOrOutputSpeed> queryWrapper = new QueryWrapper<>();
queryWrapper.ge("record_date",yearbegin).le("record_date",end).eq("windturbine_id",windturbineId).isNotNull("speed");
List<ProEconInputOrOutputSpeed> recordList = proEconInputOrOutputSpeedService.list(queryWrapper);
// .stream()
// .filter(i -> i.getWindturbineId().equals(windturbineId) && StringUtils.notEmp(i.getSpeed())
// && (i.getRecordDate().compareTo(yearbegin) == 0 || i.getRecordDate().after(yearbegin))
// && (i.getRecordDate().compareTo(end) == 0 || i.getRecordDate().before(end))
// && i.getSpeed() != 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> inputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 1).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> outputrecordList = recordList.stream()
.filter(i -> i.getInputOrOutput() == 0).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> AList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> ACountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> BCountList = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() <= 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> CCountList = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() > 11).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DList = outputrecordList.stream().filter(i -> i.getSpeed() >= 25).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> DCountList = outputrecordList
.stream().filter(i -> i.getSpeed() > 11).collect(Collectors.toList());
if (ACountList.size() != 0) {
total1.setYearInputSmallRatio(new BigDecimal(AList.size()).divide(new BigDecimal(ACountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setYearInputSmallRatio(0.0);
}
if (BCountList.size() != 0) {
total1.setYearOutputSmallRatio(new BigDecimal(BList.size()).divide(new BigDecimal(BCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setYearOutputSmallRatio(0.0);
}
if (CCountList.size() != 0) {
total1.setYearInputBigRatio(new BigDecimal(CList.size()).divide(new BigDecimal(CCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setYearInputBigRatio(0.0);
}
if (DCountList.size() != 0) {
total1.setYearOutputBigRatio(new BigDecimal(DList.size()).divide(new BigDecimal(DCountList.size()),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total1.setYearOutputBigRatio(0.0);
}
List<ProEconInputOrOutputSpeed> A1List = inputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() < 2).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A2List = inputrecordList.stream().filter(i -> i.getSpeed() >= 2
&& i.getSpeed() < 2.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A3List = inputrecordList.stream().filter(i -> i.getSpeed() >= 2.5
&& i.getSpeed() < 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A4List = inputrecordList.stream().filter(i -> i.getSpeed() >= 3
&& i.getSpeed() < 3.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A5List = inputrecordList.stream().filter(i -> i.getSpeed() >= 3.5
&& i.getSpeed() < 4).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A6List = inputrecordList.stream().filter(i -> i.getSpeed() >= 4
&& i.getSpeed() < 5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> A7List = inputrecordList.stream().filter(i -> i.getSpeed() >= 5
&& i.getSpeed() <= 11).collect(Collectors.toList());
DoubleSummaryStatistics summaryStatistics = inputrecordList.stream().filter(i ->
i.getSpeed() > 0 && i.getSpeed() < 5)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setYearInputSmall(summaryStatistics.getAverage());
total1.setYearInputSmallMax(summaryStatistics.getMax());
total1.setYearInputSmallMin(summaryStatistics.getMin());
summaryStatistics = inputrecordList.stream().filter(i ->
i.getSpeed() > 18 && i.getSpeed() < 30)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setYearInputBig(summaryStatistics.getAverage());
total1.setYearInputBigMax(summaryStatistics.getMax());
total1.setYearInputBigMin(summaryStatistics.getMin());
total2.setYeara1((double) A1List.size());
total2.setYeara2((double) A2List.size());
total2.setYeara3((double) A3List.size());
total2.setYeara4((double) A4List.size());
total2.setYeara5((double) A5List.size());
total2.setYeara6((double) A6List.size());
total2.setYeara7((double) A7List.size());
count = A1List.size() + A2List.size() + A3List.size() + A4List.size() + A5List.size() + A6List.size() + A7List.size();
if (count > 0) {
total2.setYeara8(new BigDecimal(A1List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara9(new BigDecimal(A2List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara10(new BigDecimal(A3List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara11(new BigDecimal(A4List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara12(new BigDecimal(A5List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara13(new BigDecimal(A6List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara14(new BigDecimal(A7List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total2.setYeara8(0.0);
total2.setYeara9(0.0);
total2.setYeara10(0.0);
total2.setYeara11(0.0);
total2.setYeara12(0.0);
total2.setYeara13(0.0);
total2.setYeara14(0.0);
}
List<ProEconInputOrOutputSpeed> B1List = outputrecordList.stream().filter(i -> i.getSpeed() > 0
&& i.getSpeed() < 2).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B2List = outputrecordList.stream().filter(i -> i.getSpeed() >= 2
&& i.getSpeed() < 2.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B3List = outputrecordList.stream().filter(i -> i.getSpeed() >= 2.5
&& i.getSpeed() < 3).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B4List = outputrecordList.stream().filter(i -> i.getSpeed() >= 3
&& i.getSpeed() < 3.5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B5List = outputrecordList.stream().filter(i -> i.getSpeed() >= 3.5
&& i.getSpeed() < 4).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B6List = outputrecordList.stream().filter(i -> i.getSpeed() >= 4
&& i.getSpeed() < 5).collect(Collectors.toList());
List<ProEconInputOrOutputSpeed> B7List = outputrecordList.stream().filter(i -> i.getSpeed() >= 5
&& i.getSpeed() <= 11).collect(Collectors.toList());
summaryStatistics = outputrecordList.stream().filter(i ->
i.getSpeed() > 0 && i.getSpeed() < 5)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setYearOutputSmall(summaryStatistics.getAverage());
total1.setYearOutputSmallMax(summaryStatistics.getMax());
total1.setYearOutputSmallMin(summaryStatistics.getMin());
summaryStatistics = outputrecordList.stream().filter(i ->
i.getSpeed() > 18 && i.getSpeed() < 30)
.mapToDouble(ProEconInputOrOutputSpeed::getSpeed).summaryStatistics();
total1.setYearOutputBig(summaryStatistics.getAverage());
total1.setYearOutputBigMax(summaryStatistics.getMax());
total1.setYearOutputBigMin(summaryStatistics.getMin());
total2.setYeara1((double) B1List.size());
total2.setYeara2((double) B2List.size());
total2.setYeara3((double) B3List.size());
total2.setYeara4((double) B4List.size());
total2.setYeara5((double) B5List.size());
total2.setYeara6((double) B6List.size());
total2.setYeara7((double) B7List.size());
count = B1List.size() + B2List.size() + B3List.size() + B4List.size() + B5List.size() + B6List.size() + B7List.size();
if (count > 0) {
total2.setYeara8(new BigDecimal(B1List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara9(new BigDecimal(B2List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara10(new BigDecimal(B3List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara11(new BigDecimal(B4List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara12(new BigDecimal(B5List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara13(new BigDecimal(B6List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
total2.setYeara14(new BigDecimal(B7List.size()).divide(new BigDecimal(count),
4, RoundingMode.HALF_EVEN).multiply(new BigDecimal(100)).doubleValue());
} else {
total2.setYeara8(0.0);
total2.setYeara9(0.0);
total2.setYeara10(0.0);
total2.setYeara11(0.0);
total2.setYeara12(0.0);
total2.setYeara13(0.0);
total2.setYeara14(0.0);
}
}
}