package com.gyee.generation.service;//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.common.model.StringUtils; import com.gyee.generation.init.CacheContext; import com.gyee.generation.model.auto.*; import com.gyee.generation.model.vo.CompanyType; import com.gyee.generation.model.vo.Location; import com.gyee.generation.model.vo.WpType; import com.gyee.generation.service.auto.IProEconPowerstationInfoDay2Service; import com.gyee.generation.util.DateUtils; import com.gyee.generation.util.realtimesource.IEdosUtil; import com.gyee.generation.util.statisticcs.Initial; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; import java.util.stream.Collectors; @Service public class WindPowerInfo2Service { // private static final Logger logger = LoggerFactory.getLogger(WindPowerInfo2Service.class); @Resource private IEdosUtil edosUtil; @Resource private IProEconPowerstationInfoDay2Service proEconPowerstationInfoDay2Service; /** * 计算区域日信息 */ public void calRegionInfoDay(Date recordDate) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("record_date",DateUtils.truncate(recordDate)).eq("location",Location.cp.getValue()); List wpinfodayls = proEconPowerstationInfoDay2Service.list(queryWrapper); // .stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 //// && CacheContext.wpmap.containsKey(i.getWindpowerstationId()) // && i.getLocation().equals(Location.cp.getValue())) // .collect(Collectors.toList()); if (!wpinfodayls.isEmpty()) { Map>> rgmap = new HashMap<>(); for (ProEconPowerstationInfoDay2 wpinfo : wpinfodayls) { if (rgmap.containsKey(wpinfo.getRegionId())) { Map> map = rgmap.get(wpinfo.getRegionId()); List qbls = map.get(CompanyType.qb.id); List fdls = map.get(CompanyType.fd.id); List gfls = map.get(CompanyType.gf.id); if (wpinfo.getForeignKeyId().contains("-1")) { fdls.add(wpinfo); } else if (wpinfo.getForeignKeyId().contains("-2")) { gfls.add(wpinfo); } else if (wpinfo.getForeignKeyId().contains("0")) { qbls.add(wpinfo); } } else { Map> map = new HashMap<>(); List qbls = new ArrayList<>(); List gfls = new ArrayList<>(); List fdls = new ArrayList<>(); if (wpinfo.getForeignKeyId().contains("-1")) { fdls.add(wpinfo); } else if (wpinfo.getForeignKeyId().contains("-2")) { gfls.add(wpinfo); } else if (wpinfo.getForeignKeyId().contains("0")) { qbls.add(wpinfo); } map.put(CompanyType.qb.id, qbls); map.put(CompanyType.fd.id, fdls); map.put(CompanyType.gf.id, gfls); rgmap.put(wpinfo.getRegionId(), map); } } //判断是否有重复记录，先删除重复记录 QueryWrapper queryWrapper2 = new QueryWrapper<>(); queryWrapper2.eq("record_date",DateUtils.truncate(recordDate)).eq("location",Location.rg.getValue()); List idls = proEconPowerstationInfoDay2Service.list(queryWrapper2).stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 //// && CacheContext.wpmap.containsKey(i.getWindpowerstationId()) // && i.getLocation().equals(Location.rg.getValue())) .map(ProEconPowerstationInfoDay2::getId) .collect(Collectors.toList()); if (idls.size() > 0) { proEconPowerstationInfoDay2Service.removeByIds(idls); } for (Map.Entry>> entry : rgmap.entrySet()) { Map> map = entry.getValue(); List qbls = map.get(CompanyType.qb.id); List fdls = map.get(CompanyType.fd.id); List gfls = map.get(CompanyType.gf.id); // if(CacheContext.cpwpmap.size()==qbls.size()) // { ProEconPowerstationInfoDay2 qb = new ProEconPowerstationInfoDay2(); ProEconPowerstationInfoDay2 fd = new ProEconPowerstationInfoDay2(); ProEconPowerstationInfoDay2 gf = new ProEconPowerstationInfoDay2(); if (CacheContext.rgmap.containsKey(entry.getKey())) { ProBasicRegion cp = CacheContext.rgmap.get(entry.getKey()); gf.setRegionId(cp.getId()); gf.setRecordDate(DateUtils.truncate(recordDate)); gf.setForeignKeyId(cp.getId()+"-2"); gf.setLocation(Location.rg.getValue()); fd.setRegionId(cp.getId()); fd.setRecordDate(DateUtils.truncate(recordDate)); fd.setForeignKeyId(cp.getId()+"-1"); fd.setLocation(Location.rg.getValue()); qb.setRegionId(cp.getId()); qb.setRecordDate(DateUtils.truncate(recordDate)); qb.setForeignKeyId(cp.getId()+"0"); qb.setLocation(Location.rg.getValue()); Initial.initial(qb); Initial.initial(fd); Initial.initial(gf); //计算区域级全部 calCp(qb, qbls); //计算公司级风电场站 calCp(fd, fdls); //计算公司级光电场站 calCp(gf, gfls); proEconPowerstationInfoDay2Service.save(qb); proEconPowerstationInfoDay2Service.save(fd); proEconPowerstationInfoDay2Service.save(gf); } // }else // { // logger.debug("公司所属场站数量与保存的场站日信息数量不一致，未进行{0}统计-------结束", entry.getKey()); // // } } } } /** * 计算公司日信息 */ public void calCompanyInfoDay(Date recordDate) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("record_date",DateUtils.truncate(recordDate)).eq("location",Location.wp.getValue()); List wpinfodayls = proEconPowerstationInfoDay2Service.list(queryWrapper); // .stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 //// && CacheContext.wpmap.containsKey(i.getWindpowerstationId()) // && i.getLocation().equals(Location.wp.getValue())) // .collect(Collectors.toList()); if (!wpinfodayls.isEmpty()) { Map>> cpmap = new HashMap<>(); for (ProEconPowerstationInfoDay2 wpinfo : wpinfodayls) { if (cpmap.containsKey(wpinfo.getCompanyId())) { Map> map = cpmap.get(wpinfo.getCompanyId()); List qbls = map.get(CompanyType.qb.id); List fdls = map.get(CompanyType.fd.id); List gfls = map.get(CompanyType.gf.id); if (wpinfo.getWindpowerstationId().contains(WpType.FDC.id)) { fdls.add(wpinfo); } else { gfls.add(wpinfo); } qbls.add(wpinfo); } else { Map> map = new HashMap<>(); List qbls = new ArrayList<>(); List gfls = new ArrayList<>(); List fdls = new ArrayList<>(); if (wpinfo.getWindpowerstationId().contains(WpType.FDC.id)) { fdls.add(wpinfo); } else { gfls.add(wpinfo); } qbls.add(wpinfo); map.put(CompanyType.qb.id, qbls); map.put(CompanyType.fd.id, fdls); map.put(CompanyType.gf.id, gfls); cpmap.put(wpinfo.getCompanyId(), map); } } //判断是否有重复记录，先删除重复记录 QueryWrapper queryWrapper2 = new QueryWrapper<>(); queryWrapper2.eq("record_date",DateUtils.truncate(recordDate)).eq("location",Location.cp.getValue()); List idls = proEconPowerstationInfoDay2Service.list(queryWrapper2).stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 //// && CacheContext.wpmap.containsKey(i.getWindpowerstationId()) // && i.getLocation().equals(Location.cp.getValue())) .map(ProEconPowerstationInfoDay2::getId) .collect(Collectors.toList()); if (idls.size() > 0) { proEconPowerstationInfoDay2Service.removeByIds(idls); } for (Map.Entry>> entry : cpmap.entrySet()) { Map> map = entry.getValue(); List qbls = map.get(CompanyType.qb.id); List fdls = map.get(CompanyType.fd.id); List gfls = map.get(CompanyType.gf.id); // if(CacheContext.cpwpmap.size()==qbls.size()) // { ProEconPowerstationInfoDay2 qb = new ProEconPowerstationInfoDay2(); ProEconPowerstationInfoDay2 fd = new ProEconPowerstationInfoDay2(); ProEconPowerstationInfoDay2 gf = new ProEconPowerstationInfoDay2(); if (CacheContext.cpmap.containsKey(entry.getKey())) { ProBasicCompany cp = CacheContext.cpmap.get(entry.getKey()); gf.setRegionId(cp.getRegionId()); gf.setCompanyId(cp.getId()); gf.setRecordDate(DateUtils.truncate(recordDate)); gf.setForeignKeyId(cp.getId()+"-2"); gf.setLocation(Location.cp.getValue()); fd.setRegionId(cp.getRegionId()); fd.setCompanyId(cp.getId()); fd.setRecordDate(DateUtils.truncate(recordDate)); fd.setForeignKeyId(cp.getId()+"-1"); fd.setLocation(Location.cp.getValue()); qb.setRegionId(cp.getRegionId()); qb.setCompanyId(cp.getId()); qb.setRecordDate(DateUtils.truncate(recordDate)); qb.setForeignKeyId(cp.getId()+"0"); qb.setLocation(Location.cp.getValue()); Initial.initial(qb); Initial.initial(fd); Initial.initial(gf); //计算公司级全部场站 calCp(qb, qbls); //计算公司级风电场站 calCp(fd, fdls); //计算公司级光电场站 calCp(gf, gfls); proEconPowerstationInfoDay2Service.save(qb); proEconPowerstationInfoDay2Service.save(fd); proEconPowerstationInfoDay2Service.save(gf); } // }else // { // logger.debug("公司所属场站数量与保存的场站日信息数量不一致，未进行{0}统计-------结束", entry.getKey()); // // } } } } private void calCp(ProEconPowerstationInfoDay2 pewp, List ls) { if (!ls.isEmpty()) { for (ProEconPowerstationInfoDay2 pepid : ls) { //日合计故障小时（明细） pewp.setRhjgzxsmx(StringUtils.round(pewp.getRhjgzxsmx() + pepid.getRhjgzxsmx(), 2)); //日合计场内受累故障小时（明细） pewp.setRhjcnslgzxsmx(StringUtils.round(pewp.getRhjcnslgzxsmx() + pepid.getRhjcnslgzxsmx(), 2)); //日合计检修小时（明细） pewp.setRhjjxxsmx(StringUtils.round(pewp.getRhjjxxsmx() + pepid.getRhjjxxsmx(), 2)); //日合计场内受累检修小时（明细） pewp.setRhjcnsljxxsmx(StringUtils.round(pewp.getRhjcnsljxxsmx() + pepid.getRhjcnsljxxsmx(), 2)); //日合计待机小时（明细） pewp.setRhjdjxsmx(StringUtils.round(pewp.getRhjdjxsmx() + pepid.getRhjdjxsmx(), 2)); //日合计缺陷降出力小时（明细） pewp.setRhjqxjclxsmx(StringUtils.round(pewp.getRhjqxjclxsmx() + pepid.getRhjqxjclxsmx(), 2)); //日合计手动停机小时（明细） pewp.setRhjsdtjxsmx(StringUtils.round(pewp.getRhjsdtjxsmx() + pepid.getRhjsdtjxsmx(), 2)); //日合计性能小时（明细） pewp.setRhjbwxsmx(StringUtils.round(pewp.getRhjbwxsmx() + pepid.getRhjbwxsmx(), 2)); //日合计限电停机小时（明细） pewp.setRhjxdtjxsmx(StringUtils.round(pewp.getRhjxdtjxsmx() + pepid.getRhjxdtjxsmx(), 2)); //日合计限电降出力小时（明细） pewp.setRhjxdjclxsmx(StringUtils.round(pewp.getRhjxdjclxsmx() + pepid.getRhjxdjclxsmx(), 2)); //日合计场外受累电网小时（明细） pewp.setRhjcwsldwxsmx(StringUtils.round(pewp.getRhjcwsldwxsmx() + pepid.getRhjcwsldwxsmx(), 2)); //日合计场外受累电网小时（明细） pewp.setRhjcwsltqxsmx(StringUtils.round(pewp.getRhjcwsltqxsmx() + pepid.getRhjcwsltqxsmx(), 2)); //日合计通讯中断小时（明细） pewp.setRhjtxzdxsmx(StringUtils.round(pewp.getRhjtxzdxsmx() + pepid.getRhjtxzdxsmx(), 2)); //日合计离线小时（明细） pewp.setRhjlxxsmx(StringUtils.round(pewp.getRhjlxxsmx() + pepid.getRhjlxxsmx(), 2)); //月合计故障小时（明细） pewp.setYhjgzxsmx(StringUtils.round(pewp.getYhjgzxsmx() + pepid.getYhjgzxsmx(), 2)); //月合计场内受累故障小时（明细） pewp.setYhjcnslgzxsmx(StringUtils.round(pewp.getYhjcnslgzxsmx() + pepid.getYhjcnslgzxsmx(), 2)); //月合计检修小时（明细） pewp.setYhjjxxsmx(StringUtils.round(pewp.getYhjjxxsmx() + pepid.getYhjjxxsmx(), 2)); //月合计场内受累检修小时（明细） pewp.setYhjcnsljxxsmx(StringUtils.round(pewp.getYhjcnsljxxsmx() + pepid.getYhjcnsljxxsmx(), 2)); //月合计待机小时（明细） pewp.setYhjdjxsmx(StringUtils.round(pewp.getYhjdjxsmx() + pepid.getYhjdjxsmx(), 2)); //月合计缺陷降出力小时（明细） pewp.setYhjqxjclxsmx(StringUtils.round(pewp.getYhjqxjclxsmx() + pepid.getYhjqxjclxsmx(), 2)); //月合计手动停机小时（明细） pewp.setYhjsdtjxsmx(StringUtils.round(pewp.getYhjsdtjxsmx() + pepid.getYhjsdtjxsmx(), 2)); //月合计性能小时（明细） pewp.setYhjbwxsmx(StringUtils.round(pewp.getYhjbwxsmx() + pepid.getYhjbwxsmx(), 2)); //月合计限电停机小时（明细） pewp.setYhjxdtjxsmx(StringUtils.round(pewp.getYhjxdtjxsmx() + pepid.getYhjxdtjxsmx(), 2)); //月合计限电降出力小时（明细） pewp.setYhjxdjclxsmx(StringUtils.round(pewp.getYhjxdjclxsmx() + pepid.getYhjxdjclxsmx(), 2)); //月合计场外受累电网小时（明细） pewp.setYhjcwsldwxsmx(StringUtils.round(pewp.getYhjcwsldwxsmx() + pepid.getYhjcwsldwxsmx(), 2)); //月合计场外受累电网小时（明细） pewp.setYhjcwsltqxsmx(StringUtils.round(pewp.getYhjcwsltqxsmx() + pepid.getYhjcwsltqxsmx(), 2)); //月合计通讯中断小时（明细） pewp.setYhjtxzdxsmx(StringUtils.round(pewp.getYhjtxzdxsmx() + pepid.getYhjtxzdxsmx(), 2)); //月合计离线小时（明细） pewp.setYhjlxxsmx(StringUtils.round(pewp.getYhjlxxsmx() + pepid.getYhjlxxsmx(), 2)); //年合计故障小时（明细） pewp.setNhjgzxsmx(StringUtils.round(pewp.getNhjgzxsmx() + pepid.getNhjgzxsmx(), 2)); //年合计场内受累故障小时（明细） pewp.setNhjcnslgzxsmx(StringUtils.round(pewp.getNhjcnslgzxsmx() + pepid.getNhjcnslgzxsmx(), 2)); //年合计检修小时（明细） pewp.setNhjjxxsmx(StringUtils.round(pewp.getNhjjxxsmx() + pepid.getNhjjxxsmx(), 2)); //年合计场内受累检修小时（明细） pewp.setNhjcnsljxxsmx(StringUtils.round(pewp.getNhjcnsljxxsmx() + pepid.getNhjcnsljxxsmx(), 2)); //年合计待机小时（明细） pewp.setNhjdjxsmx(StringUtils.round(pewp.getNhjdjxsmx() + pepid.getNhjdjxsmx(), 2)); //年合计缺陷降出力小时（明细） pewp.setNhjqxjclxsmx(StringUtils.round(pewp.getNhjqxjclxsmx() + pepid.getNhjqxjclxsmx(), 2)); //年合计手动停机小时（明细） pewp.setNhjsdtjxsmx(StringUtils.round(pewp.getNhjsdtjxsmx() + pepid.getNhjsdtjxsmx(), 2)); //年合计性能小时（明细） pewp.setNhjbwxsmx(StringUtils.round(pewp.getNhjbwxsmx() + pepid.getNhjbwxsmx(), 2)); //年合计限电停机小时（明细） pewp.setNhjxdtjxsmx(StringUtils.round(pewp.getNhjxdtjxsmx() + pepid.getNhjxdtjxsmx(), 2)); //年合计限电降出力小时（明细） pewp.setNhjxdjclxsmx(StringUtils.round(pewp.getNhjxdjclxsmx() + pepid.getNhjxdjclxsmx(), 2)); //年合计场外受累电网小时（明细） pewp.setNhjcwsldwxsmx(StringUtils.round(pewp.getNhjcwsldwxsmx() + pepid.getNhjcwsldwxsmx(), 2)); //年合计场外受累电网小时（明细） pewp.setNhjcwsltqxsmx(StringUtils.round(pewp.getNhjcwsltqxsmx() + pepid.getNhjcwsltqxsmx(), 2)); //年合计通讯中断小时（明细） pewp.setNhjtxzdxsmx(StringUtils.round(pewp.getNhjtxzdxsmx() + pepid.getNhjtxzdxsmx(), 2)); //年合计离线小时（明细） pewp.setNhjlxxsmx(StringUtils.round(pewp.getNhjlxxsmx() + pepid.getNhjlxxsmx(), 2)); } } } /** * 计算场站日信息 */ public void calWindpowerInfoDay(Date recordDate) throws Exception { Calendar c = Calendar.getInstance(); c.setTime(recordDate); Date end = c.getTime(); Date begin = DateUtils.truncate(c.getTime()); List dayls=new ArrayList<>(); for (ProBasicPowerstation wp : CacheContext.wpls) { if (CacheContext.wppointmap.containsKey(wp.getId())) { // Map pointmap=CacheContext.wppointmap.get(wp.getId()); ProEconPowerstationInfoDay2 pewp = new ProEconPowerstationInfoDay2(); Initial.initial(pewp); pewp.setRegionId(wp.getRegionId()); pewp.setCompanyId(wp.getCompanyId()); pewp.setRecordDate(DateUtils.truncate(recordDate)); pewp.setForeignKeyId(wp.getId()); pewp.setWindpowerstationId(wp.getId()); pewp.setLocation(Location.wp.getValue()); //昨日的统计结果 List pepidls = new ArrayList<>(); Calendar cl = Calendar.getInstance(); cl.setTime(recordDate); //昨日的统计结果 cl.add(Calendar.DAY_OF_MONTH, -1); if (cl.get(Calendar.DAY_OF_MONTH) != 1) { QueryWrapper queryWrapper2 = new QueryWrapper<>(); queryWrapper2.eq("record_date",DateUtils.truncate(cl.getTime())) .eq("windpowerstation_id","wp.getId()") .eq("location",Location.wp.getValue()); pepidls = proEconPowerstationInfoDay2Service.list(queryWrapper2); // .stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(cl.getTime())) == 0 // // && i.getLocation().equals(Location.wp.getValue()) // && i.getWindpowerstationId().equals(wp.getId()) // ) // .collect(Collectors.toList()); } calDetiall(pewp, end, begin, CacheContext.wpwtmap.get(wp.getId()), pepidls); calSimple(pewp, end, begin, CacheContext.wpwtmap.get(wp.getId()), pepidls); //*******************************************年信息统计*********************************************************/ // wpinfodayls.add(pewp); dayls.add(pewp); // proEconPowerstationInfoDay2Service.save(pewp); } } //判断是否有重复记录，先删除重复记录 QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("record_date",DateUtils.truncate(recordDate)).eq("location",Location.wp.getValue()); List idls = proEconPowerstationInfoDay2Service.list(queryWrapper).stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 // && CacheContext.wpmap.containsKey(i.getWindpowerstationId()) // && i.getLocation().equals(Location.wp.getValue())) .map(ProEconPowerstationInfoDay2::getId) .collect(Collectors.toList()); if (idls.size() > 0) { proEconPowerstationInfoDay2Service.removeByIds(idls); } List templs=new ArrayList<>(); for(ProEconPowerstationInfoDay2 vo:dayls) { templs.add(vo); if(templs.size()==1000) { proEconPowerstationInfoDay2Service.saveBatch(templs); templs=new ArrayList<>(); } } if(!templs.isEmpty()) { proEconPowerstationInfoDay2Service.saveBatch(templs); } // proEconPowerstationInfoDay2Service.saveBatch(dayls); } /** * 计算项目日信息 */ public void calProjectInfoDay(Date recordDate) throws Exception { Calendar c = Calendar.getInstance(); c.setTime(recordDate); Date end = c.getTime(); Date begin = DateUtils.truncate(c.getTime()); List dayls=new ArrayList<>(); for (ProBasicProject pj : CacheContext.pjls) { // if(CacheContext.wppointmap.containsKey(pj.getId())) // { // Map pointmap=CacheContext.wppointmap.get(pj.getId()); ProEconPowerstationInfoDay2 pewp = new ProEconPowerstationInfoDay2(); if (CacheContext.wpmap.containsKey(pj.getWindpowerstationId())) { ProBasicPowerstation wp = CacheContext.wpmap.get(pj.getWindpowerstationId()); pewp.setRegionId(wp.getRegionId()); pewp.setCompanyId(wp.getCompanyId()); } Initial.initial(pewp); pewp.setForeignKeyId(pj.getId()); pewp.setWindpowerstationId(pj.getWindpowerstationId()); pewp.setProjectId(pj.getId()); pewp.setLocation(Location.pj.getValue()); pewp.setRecordDate(DateUtils.truncate(recordDate)); //昨日的统计结果 List pepidls = new ArrayList<>(); Calendar cl = Calendar.getInstance(); cl.setTime(recordDate); //昨日的统计结果 cl.add(Calendar.DAY_OF_MONTH, -1); if (cl.get(Calendar.DAY_OF_MONTH) != 1) { QueryWrapper queryWrapper2 = new QueryWrapper<>(); queryWrapper2.eq("record_date",DateUtils.truncate(cl.getTime())) .eq("location",Location.pj.getValue()) .eq("project_id",pj.getId()); pepidls = proEconPowerstationInfoDay2Service.list(queryWrapper2); // .stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(cl.getTime())) == 0 // // && i.getLocation().equals(Location.pj.getValue()) // && i.getProjectId().equals(pj.getId()) // ) // .collect(Collectors.toList()); } calDetiall(pewp, end, begin, CacheContext.pjwtmap.get(pj.getId()), pepidls); calSimple(pewp, end, begin, CacheContext.pjwtmap.get(pj.getId()), pepidls); dayls.add(pewp); // proEconPowerstationInfoDay2Service.save(pewp); // } } //判断是否有重复记录，先删除重复记录 QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("record_date",DateUtils.truncate(recordDate)) .eq("location",Location.pj.getValue()); List idls = proEconPowerstationInfoDay2Service.list(queryWrapper).stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 // && CacheContext.pjmap.containsKey(i.getProjectId()) // && i.getLocation().equals(Location.pj.getValue())) .map(ProEconPowerstationInfoDay2::getId) .collect(Collectors.toList()); if (idls.size() > 0) { proEconPowerstationInfoDay2Service.removeByIds(idls); } List templs=new ArrayList<>(); for(ProEconPowerstationInfoDay2 vo:dayls) { templs.add(vo); if(templs.size()==1000) { proEconPowerstationInfoDay2Service.saveBatch(templs); templs=new ArrayList<>(); } } if(!templs.isEmpty()) { proEconPowerstationInfoDay2Service.saveBatch(templs); } // proEconPowerstationInfoDay2Service.saveBatch(dayls); } /** * 计算线路日信息 */ public void calLineInfoDay(Date recordDate) throws Exception { Calendar c = Calendar.getInstance(); c.setTime(recordDate); Date end = c.getTime(); Date begin = DateUtils.truncate(c.getTime()); List dayls=new ArrayList<>(); for (ProBasicLine ln : CacheContext.lnls) { // if(CacheContext.wppointmap.containsKey(ln.getId())) // { // Map pointmap=CacheContext.wppointmap.get(ln.getId()); ProEconPowerstationInfoDay2 pewp = new ProEconPowerstationInfoDay2(); if (CacheContext.pjmap.containsKey(ln.getProjectId())) { ProBasicProject pj = CacheContext.pjmap.get(ln.getProjectId()); if (CacheContext.wpmap.containsKey(pj.getWindpowerstationId())) { ProBasicPowerstation wp = CacheContext.wpmap.get(pj.getWindpowerstationId()); pewp.setRegionId(wp.getRegionId()); pewp.setCompanyId(wp.getCompanyId()); pewp.setWindpowerstationId(wp.getId()); } } Initial.initial(pewp); pewp.setForeignKeyId(ln.getId()); pewp.setLineId(ln.getId()); pewp.setLocation(Location.ln.getValue()); pewp.setProjectId(ln.getProjectId()); pewp.setRecordDate(DateUtils.truncate(recordDate)); //昨日的统计结果 List pepidls = new ArrayList<>(); Calendar cl = Calendar.getInstance(); cl.setTime(recordDate); //昨日的统计结果 cl.add(Calendar.DAY_OF_MONTH, -1); if (cl.get(Calendar.DAY_OF_MONTH) != 1) { QueryWrapper queryWrapper2 = new QueryWrapper<>(); queryWrapper2.eq("record_date",DateUtils.truncate(cl.getTime())) .eq("location",Location.ln.getValue()) .eq("line_id",ln.getId()); pepidls = proEconPowerstationInfoDay2Service.list(queryWrapper2); // .stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(cl.getTime())) == 0 // && i.getLocation().equals(Location.ln.getValue()) // && i.getLineId().equals(ln.getId()) // ) // .collect(Collectors.toList()); } calDetiall(pewp, end, begin, CacheContext.lnwtmap.get(ln.getId()), pepidls); calSimple(pewp, end, begin, CacheContext.lnwtmap.get(ln.getId()), pepidls); dayls.add(pewp); // proEconPowerstationInfoDay2Service.save(pewp); } // } //判断是否有重复记录，先删除重复记录 QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("record_date",DateUtils.truncate(recordDate)) .eq("location",Location.ln.getValue()); List idls = proEconPowerstationInfoDay2Service.list(queryWrapper).stream() // .filter(i -> i.getRecordDate().compareTo(DateUtils.truncate(recordDate)) == 0 // && CacheContext.lnmap.containsKey(i.getLineId()) // && i.getLocation().equals(Location.ln.getValue())) .map(ProEconPowerstationInfoDay2::getId) .collect(Collectors.toList()); if (idls.size() > 0) { proEconPowerstationInfoDay2Service.removeByIds(idls); } List templs=new ArrayList<>(); for(ProEconPowerstationInfoDay2 vo:dayls) { templs.add(vo); if(templs.size()==1000) { proEconPowerstationInfoDay2Service.saveBatch(templs); templs=new ArrayList<>(); } } if(!templs.isEmpty()) { proEconPowerstationInfoDay2Service.saveBatch(templs); } // proEconPowerstationInfoDay2Service.saveBatch(dayls); } private void calDetiall(ProEconPowerstationInfoDay2 pewp, Date end, Date begin, List wtls, List pepidls) throws Exception { // // 0 待机 // 1 手动停机 // 2 正常发电 // 3 发电降出力 // 4 故障 // 5 故障受累 // 6 检修 // 7 检修受累 // 8 限电降出力 // 9 限电停机 // 10 电网受累 // 11 环境受累 // 12 通讯中断 // 13 设备离线 double lastState;//上一分钟状态 double djsc = 0;//待机时长 double sdtjsc = 0;//手动停机时长 double zcfdsc = 0;//正常发电时长 double fdjclsc = 0;//发电降出力时长 double gzsc = 0;//故障时长 double gzslsc = 0;//故障受累时长 double jxsc = 0;//检修时长 double jxslsc = 0;//检修受累时长 double xdjclsc = 0;//限电降出力时长 double xdtjsc = 0;//限电停机时长 double dwslsc = 0;//电网受累时长 double hjslsc = 0;//环境受累时长 double txzdsc = 0;//通讯中断时长 double sblxsc = 0;//设备离线时长 Map> wtpAimap = CacheContext.wtpAimap; if(!wtls.isEmpty()) { for (ProBasicEquipment wt : wtls) { lastState = -1;//上一分钟状态 Map aimap = wtpAimap.get(wt.getId()); if (aimap.containsKey(ContantXk.MXZT)) { ProBasicEquipmentPoint point = aimap.get(ContantXk.MXZT); //按照分钟时间进行统计状态快照值 List pointls = edosUtil.getHistoryDatasSnap(point.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000); if (!pointls.isEmpty()) { for (PointData po : pointls) { if (po.getPointValueInDouble() == 0) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //待机时长加1分钟 djsc++; } else if (po.getPointValueInDouble() == 1) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //手动停机时长加1分钟 sdtjsc++; } else if (po.getPointValueInDouble() == 2) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //正常发电时长加1分钟 zcfdsc++; } else if (po.getPointValueInDouble() == 3) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //发电降出力时长加1分钟 fdjclsc++; } else if (po.getPointValueInDouble() == 4) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //故障时长加1分钟 gzsc++; } else if (po.getPointValueInDouble() == 5) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //故障受累时长加1分钟 gzslsc++; } else if (po.getPointValueInDouble() == 6) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //检修时长加1分钟 jxsc++; } else if (po.getPointValueInDouble() == 7) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //检修受累时长加1分钟 jxslsc++; } else if (po.getPointValueInDouble() == 8) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //限电降出力时长加1分钟 xdjclsc++; } else if (po.getPointValueInDouble() == 9) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //限电停机时长加1分钟 xdtjsc++; } else if (po.getPointValueInDouble() == 10) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //电网受累时长加1分钟 dwslsc++; } else if (po.getPointValueInDouble() == 11) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //环境受累时长加1分钟 hjslsc++; } else if (po.getPointValueInDouble() == 12) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //通讯中断时长加1分钟 txzdsc++; } else if (po.getPointValueInDouble() == 13) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //设备离线时长加1分钟 sblxsc++; } } } } } } //日合计故障小时（明细） pewp.setRhjgzxsmx(new BigDecimal(gzsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计场内受累故障小时（明细） pewp.setRhjcnslgzxsmx(new BigDecimal(gzslsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计检修小时（明细） pewp.setRhjjxxsmx(new BigDecimal(jxsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计场内受累检修小时（明细） pewp.setRhjcnsljxxsmx(new BigDecimal(jxslsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计待机小时（明细） pewp.setRhjdjxsmx(new BigDecimal(djsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计缺陷降出力小时（明细） pewp.setRhjqxjclxsmx(new BigDecimal(fdjclsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计手动停机小时（明细） pewp.setRhjsdtjxsmx(new BigDecimal(sdtjsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计性能小时（明细） pewp.setRhjbwxsmx(new BigDecimal(zcfdsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计限电停机小时（明细） pewp.setRhjxdtjxsmx(new BigDecimal(xdtjsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计限电降出力小时（明细） pewp.setRhjxdjclxsmx(new BigDecimal(xdjclsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计场外受累电网小时（明细） pewp.setRhjcwsldwxsmx(new BigDecimal(dwslsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计场外受累电网小时（明细） pewp.setRhjcwsltqxsmx(new BigDecimal(hjslsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计通讯中断小时（明细） pewp.setRhjtxzdxsmx(new BigDecimal(txzdsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计离线小时（明细） pewp.setRhjlxxsmx(new BigDecimal(sblxsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //*******************************************日信息统计*********************************************************/ //*******************************************月信息统计*********************************************************/ if (pepidls.isEmpty()) { setLossHoursMonth(pewp); } else { ProEconPowerstationInfoDay2 pepid = pepidls.get(0); //月合计故障小时（明细） pewp.setYhjgzxsmx(StringUtils.round(pepid.getYhjgzxsmx() + pewp.getRhjgzxsmx(), 2)); //月合计场内受累故障小时（明细） pewp.setYhjcnslgzxsmx(StringUtils.round(pepid.getYhjcnslgzxsmx() + pewp.getRhjcnslgzxsmx(), 2)); //月合计检修小时（明细） pewp.setYhjjxxsmx(StringUtils.round(pepid.getYhjjxxsmx() + pewp.getRhjjxxsmx(), 2)); //月合计场内受累检修小时（明细） pewp.setYhjcnsljxxsmx(StringUtils.round(pepid.getYhjcnsljxxsmx() + pewp.getRhjcnsljxxsmx(), 2)); //月合计待机小时（明细） pewp.setYhjdjxsmx(StringUtils.round(pepid.getYhjdjxsmx() + pewp.getRhjdjxsmx(), 2)); //月合计缺陷降出力小时（明细） pewp.setYhjqxjclxsmx(StringUtils.round(pepid.getYhjqxjclxsmx() + pewp.getRhjqxjclxsmx(), 2)); //月合计手动停机小时（明细） pewp.setYhjsdtjxsmx(StringUtils.round(pepid.getYhjsdtjxsmx() + pewp.getRhjsdtjxsmx(), 2)); //月合计性能小时（明细） pewp.setYhjbwxsmx(StringUtils.round(pepid.getYhjbwxsmx() + pewp.getRhjbwxsmx(), 2)); //月合计限电停机小时（明细） pewp.setYhjxdtjxsmx(StringUtils.round(pepid.getYhjxdtjxsmx() + pewp.getRhjxdtjxsmx(), 2)); //月合计限电降出力小时（明细） pewp.setYhjxdjclxsmx(StringUtils.round(pepid.getYhjxdjclxsmx() + pewp.getRhjxdjclxsmx(), 2)); //月合计场外受累电网小时（明细） pewp.setYhjcwsldwxsmx(StringUtils.round(pepid.getYhjcwsldwxsmx() + pewp.getRhjcwsldwxsmx(), 2)); //月合计场外受累电网小时（明细） pewp.setYhjcwsltqxsmx(StringUtils.round(pepid.getYhjcwsltqxsmx() + pewp.getRhjcwsltqxsmx(), 2)); //月合计通讯中断小时（明细） pewp.setYhjtxzdxsmx(StringUtils.round(pepid.getYhjtxzdxsmx() + pewp.getRhjtxzdxsmx(), 2)); //月合计离线小时（明细） pewp.setYhjlxxsmx(StringUtils.round(pepid.getYhjlxxsmx() + pewp.getRhjlxxsmx(), 2)); } //*******************************************月信息统计*********************************************************/ //*******************************************年信息统计*********************************************************/ if (pepidls.isEmpty()) { setLossHoursYear(pewp); } else { ProEconPowerstationInfoDay2 pepid = pepidls.get(0); //年合计故障小时（明细） pewp.setNhjgzxsmx(StringUtils.round(pepid.getNhjgzxsmx() + pewp.getRhjgzxsmx(), 2)); //年合计场内受累故障小时（明细） pewp.setNhjcnslgzxsmx(StringUtils.round(pepid.getNhjcnslgzxsmx() + pewp.getRhjcnslgzxsmx(), 2)); //年合计检修小时（明细） pewp.setNhjjxxsmx(StringUtils.round(pepid.getNhjjxxsmx() + pewp.getRhjjxxsmx(), 2)); //年合计场内受累检修小时（明细） pewp.setNhjcnsljxxsmx(StringUtils.round(pepid.getNhjcnsljxxsmx() + pewp.getRhjcnsljxxsmx(), 2)); //年合计待机小时（明细） pewp.setNhjdjxsmx(StringUtils.round(pepid.getNhjdjxsmx() + pewp.getRhjdjxsmx(), 2)); //年合计缺陷降出力小时（明细） pewp.setNhjqxjclxsmx(StringUtils.round(pepid.getNhjqxjclxsmx() + pewp.getRhjqxjclxsmx(), 2)); //年合计手动停机小时（明细） pewp.setNhjsdtjxsmx(StringUtils.round(pepid.getNhjsdtjxsmx() + pewp.getRhjsdtjxsmx(), 2)); //年合计性能小时（明细） pewp.setNhjbwxsmx(StringUtils.round(pepid.getNhjbwxsmx() + pewp.getRhjbwxsmx(), 2)); //年合计限电停机小时（明细） pewp.setNhjxdtjxsmx(StringUtils.round(pepid.getNhjxdtjxsmx() + pewp.getRhjxdtjxsmx(), 2)); //年合计限电降出力小时（明细） pewp.setNhjxdjclxsmx(StringUtils.round(pepid.getNhjxdjclxsmx() + pewp.getRhjxdjclxsmx(), 2)); //年合计场外受累电网小时（明细） pewp.setNhjcwsldwxsmx(StringUtils.round(pepid.getNhjcwsldwxsmx() + pewp.getRhjcwsldwxsmx(), 2)); //年合计场外受累电网小时（明细） pewp.setNhjcwsltqxsmx(StringUtils.round(pepid.getNhjcwsltqxsmx() + pewp.getRhjcwsltqxsmx(), 2)); //年合计通讯中断小时（明细） pewp.setNhjtxzdxsmx(StringUtils.round(pepid.getNhjtxzdxsmx() + pewp.getRhjtxzdxsmx(), 2)); //年合计离线小时（明细） pewp.setNhjlxxsmx(StringUtils.round(pepid.getNhjlxxsmx() + pewp.getRhjlxxsmx(), 2)); } } private static void setLossHoursYear(ProEconPowerstationInfoDay2 pewp) { //年合计故障小时（明细） pewp.setNhjgzxsmx(pewp.getRhjgzxsmx()); //年合计场内受累故障小时（明细） pewp.setNhjcnslgzxsmx(pewp.getRhjcnslgzxsmx()); //年合计检修小时（明细） pewp.setNhjjxxsmx(pewp.getRhjjxxsmx()); //年合计场内受累检修小时（明细） pewp.setNhjcnsljxxsmx(pewp.getRhjcnsljxxsmx()); //年合计待机小时（明细） pewp.setNhjdjxsmx(pewp.getRhjdjxsmx()); //年合计缺陷降出力小时（明细） pewp.setNhjqxjclxsmx(pewp.getRhjqxjclxsmx()); //年合计手动停机小时（明细） pewp.setNhjsdtjxsmx(pewp.getRhjsdtjxsmx()); //年合计性能小时（明细） pewp.setNhjbwxsmx(pewp.getRhjbwxsmx()); //年合计限电停机小时（明细） pewp.setNhjxdtjxsmx(pewp.getRhjxdtjxsmx()); //年合计限电降出力小时（明细） pewp.setNhjxdjclxsmx(pewp.getRhjxdjclxsmx()); //年合计场外受累电网小时（明细） pewp.setNhjcwsldwxsmx(pewp.getRhjcwsldwxsmx()); //年合计场外受累电网小时（明细） pewp.setNhjcwsltqxsmx(pewp.getRhjcwsltqxsmx()); //年合计通讯中断小时（明细） pewp.setNhjtxzdxsmx(pewp.getRhjtxzdxsmx()); //年合计离线小时（明细） pewp.setNhjlxxsmx(pewp.getRhjlxxsmx()); } private static void setLossHoursMonth(ProEconPowerstationInfoDay2 pewp) { //月合计故障小时（明细） pewp.setYhjgzxsmx(pewp.getRhjgzxsmx()); //月合计场内受累故障小时（明细） pewp.setYhjcnslgzxsmx(pewp.getRhjcnslgzxsmx()); //月合计检修小时（明细） pewp.setYhjjxxsmx(pewp.getRhjjxxsmx()); //月合计场内受累检修小时（明细） pewp.setYhjcnsljxxsmx(pewp.getRhjcnsljxxsmx()); //月合计待机小时（明细） pewp.setYhjdjxsmx(pewp.getRhjdjxsmx()); //月合计缺陷降出力小时（明细） pewp.setYhjqxjclxsmx(pewp.getRhjqxjclxsmx()); //月合计手动停机小时（明细） pewp.setYhjsdtjxsmx(pewp.getRhjsdtjxsmx()); //月合计性能小时（明细） pewp.setYhjbwxsmx(pewp.getRhjbwxsmx()); //月合计限电停机小时（明细） pewp.setYhjxdtjxsmx(pewp.getRhjxdtjxsmx()); //月合计限电降出力小时（明细） pewp.setYhjxdjclxsmx(pewp.getRhjxdjclxsmx()); //月合计场外受累电网小时（明细） pewp.setYhjcwsldwxsmx(pewp.getRhjcwsldwxsmx()); //月合计场外受累电网小时（明细） pewp.setYhjcwsltqxsmx(pewp.getRhjcwsltqxsmx()); //月合计通讯中断小时（明细） pewp.setYhjtxzdxsmx(pewp.getRhjtxzdxsmx()); //月合计离线小时（明细） pewp.setYhjlxxsmx(pewp.getRhjlxxsmx()); } private static void setLossHoursMonthSimple(ProEconPowerstationInfoDay2 pewp) { //月合计待机小时 pewp.setYhjdjxs(pewp.getRhjdjxs()); //月合计维护停机小时 pewp.setYhjjxtjxs(pewp.getRhjjxtjxs()); // 月合计故障停机小时 pewp.setYhjgztjxs(pewp.getRhjgztjxs()); //月合计运行小时 pewp.setYhjyxxs(pewp.getRhjyxxs()); //月合计限电小时 pewp.setYhjxdxs(pewp.getRhjxdxs()); //月合计通讯中断小时 pewp.setYhjtxzdxs(pewp.getRhjtxzdxs()); //月合计受累小时 pewp.setYhjslxs(pewp.getRhjslxs()); } private static void setLossHoursYearSimple(ProEconPowerstationInfoDay2 pewp) { //年合计待机小时 pewp.setNhjdjxs(pewp.getRhjdjxs()); //年合计维护停机小时 pewp.setNhjjxtjxs(pewp.getRhjjxtjxs()); // 年合计故障小时 pewp.setNhjgztjxs(pewp.getRhjgztjxs()); //年合计运行小时 pewp.setNhjyxxs(pewp.getRhjyxxs()); //年合计限电小时 pewp.setNhjxdxs(pewp.getRhjxdxs()); //年合计通讯中断小时 pewp.setNhjtxzdxs(pewp.getRhjtxzdxs()); //年合计受累小时 pewp.setNhjslxs(pewp.getRhjslxs()); } private void calSimple(ProEconPowerstationInfoDay2 pewp, Date end, Date begin, List wtls, List pepidls) throws Exception { // 0 待机 // 1 运行 // 2 故障 // 3 检修 // 4 限电 // 5 受累 // 6 离线 //*******************************************日信息统计*********************************************************/ double lastState = -1;//上一分钟状态 double djsc = 0;//待机时长 double zcfdsc = 0;//正常发电时长 double gzsc = 0;//故障时长 double jxsc = 0;//检修时长 double xdtjsc = 0;//限电停机时长 double slsc = 0;//受累时长 double txzdsc = 0;//通讯中断时长 Map> wtpAimap = CacheContext.wtpAimap; for (ProBasicEquipment wt : wtls) { Map aimap = wtpAimap.get(wt.getId()); if (aimap.containsKey(ContantXk.SBZT)) { ProBasicEquipmentPoint point = aimap.get(ContantXk.SBZT); //按照分钟时间进行统计状态快照值 List pointls = edosUtil.getHistoryDatasSnap(point.getNemCode(), begin.getTime() / 1000, end.getTime() / 1000); if (!pointls.isEmpty()) { for (PointData po : pointls) { if (po.getPointValueInDouble() == 0) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //待机时长加1分钟 djsc++; } else if (po.getPointValueInDouble() == 1) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //正常发电时长加1分钟 zcfdsc++; } else if (po.getPointValueInDouble() == 2) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //故障时长加1分钟 gzsc++; } else if (po.getPointValueInDouble() == 3) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //检修时长加1分钟 jxsc++; } else if (po.getPointValueInDouble() == 4) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //限电停机时长加1分钟 xdtjsc++; } else if (po.getPointValueInDouble() == 5) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //受累时长加1分钟 slsc++; } else if (po.getPointValueInDouble() == 6) { if (lastState != po.getPointValueInDouble()) { //将当前状态保存到上一分钟状态 lastState = po.getPointValueInDouble(); } //通讯中断时长加1分钟 txzdsc++; } } } } } //日合计待机小时 pewp.setRhjdjxs(new BigDecimal(gzsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计维护停机小时 pewp.setRhjjxtjxs(new BigDecimal(jxsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); // 日合计待机小时 pewp.setRhjdjxs(new BigDecimal(djsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计运行小时 pewp.setRhjyxxs(new BigDecimal(zcfdsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计限电小时 pewp.setRhjxdxs(new BigDecimal(xdtjsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计通讯中断小时 pewp.setRhjtxzdxs(new BigDecimal(txzdsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //日合计受累小时 pewp.setRhjslxs(new BigDecimal(slsc).divide(new BigDecimal(60), 2, RoundingMode.HALF_EVEN).doubleValue()); //*******************************************日信息统计*********************************************************/ //*******************************************月信息统计*********************************************************/ if (pepidls.isEmpty()) { setLossHoursMonthSimple(pewp); } else { ProEconPowerstationInfoDay2 pepid = pepidls.get(0); //月合计待机小时 pewp.setYhjdjxs(StringUtils.round(pepid.getYhjdjxs() + pewp.getRhjdjxs(), 2)); //月合计维护停机小时 pewp.setYhjjxtjxs(StringUtils.round(pepid.getYhjjxtjxs() + pewp.getRhjjxtjxs(), 2)); // 月合计故障小时 pewp.setYhjgztjxs(StringUtils.round(pepid.getYhjgztjxs() + pewp.getRhjgztjxs(), 2)); //月合计运行小时 pewp.setYhjyxxs(StringUtils.round(pepid.getYhjyxxs() + pewp.getRhjyxxs(), 2)); //月合计限电小时 pewp.setYhjxdxs(StringUtils.round(pepid.getYhjxdxs() + pewp.getRhjxdxs(), 2)); //月合计通讯中断小时 pewp.setYhjtxzdxs(StringUtils.round(pepid.getYhjtxzdxs() + pewp.getRhjtxzdxs(), 2)); //月合计受累小时 pewp.setYhjslxs(StringUtils.round(pepid.getYhjslxs() + pewp.getRhjslxs(), 2)); } //*******************************************月信息统计*********************************************************/ //*******************************************年信息统计*********************************************************/ if (pepidls.isEmpty()) { setLossHoursYearSimple(pewp); } else { ProEconPowerstationInfoDay2 pepid = pepidls.get(0); //年合计待机小时 pewp.setNhjdjxs(StringUtils.round(pepid.getNhjdjxs() + pewp.getRhjdjxs(), 2)); //年合计维护停机小时 pewp.setNhjjxtjxs(StringUtils.round(pepid.getNhjjxtjxs() + pewp.getRhjjxtjxs(), 2)); // 年合计故障小时 pewp.setNhjgztjxs(StringUtils.round(pepid.getNhjgztjxs() + pewp.getRhjgztjxs(), 2)); //年合计运行小时 pewp.setNhjyxxs(StringUtils.round(pepid.getNhjyxxs() + pewp.getRhjyxxs(), 2)); //年合计限电小时 pewp.setNhjxdxs(StringUtils.round(pepid.getNhjxdxs() + pewp.getRhjxdxs(), 2)); //年合计通讯中断小时 pewp.setNhjtxzdxs(StringUtils.round(pepid.getNhjtxzdxs() + pewp.getRhjtxzdxs(), 2)); //年合计受累小时 pewp.setNhjslxs(StringUtils.round(pepid.getNhjslxs() + pewp.getRhjslxs(), 2)); } //*******************************************年信息统计*********************************************************/ } }