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.generation.init.CacheContext; import com.gyee.generation.model.auto.ProBasicEquipment; import com.gyee.generation.model.auto.ProBasicEquipmentPoint; import com.gyee.generation.model.auto.ProEconEquipmentInfoDay5; import com.gyee.generation.model.auto.ProEconShutdownEvent2; import com.gyee.generation.service.auto.IProEconEquipmentInfoDay5Service; import com.gyee.generation.service.auto.IProEconShutdownEvent2Service; 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.util.*; import java.util.stream.Collectors; @Service public class EquipmentInfo5Service { // private static final Logger logger = LoggerFactory.getLogger(EquipmentInfo5Service.class); @Resource private IEdosUtil edosUtil; @Resource private IProEconShutdownEvent2Service proEconShutdownEvent2Service; //状态转换率 @Resource private IProEconEquipmentInfoDay5Service proEconEquipmentInfoDay5Service; public void calEquipmentInfoDay(Date currentDate) throws Exception { resetRate(DateUtils.truncate(currentDate)); } /** * 复位及时率 */ public void resetRate(Date currentDate) throws Exception { //调度时间是第二天，currentDate 是第一天， Date endDate = DateUtils.addDays(currentDate, 1); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.ge("stop_Time",currentDate).le("stop_Time",endDate) .isNotNull("stop_Type_Id").isNotNull("stop_Hours").ne("stop_Type_Id","wh"); List shutdownevents = proEconShutdownEvent2Service.list(queryWrapper); Map rates = new HashMap<>(); for (ProBasicEquipment wt : CacheContext.wtls) { if(wt.getWindpowerstationId().contains("GDC")) { continue; } ProEconEquipmentInfoDay5 rate = new ProEconEquipmentInfoDay5(); rate.setRecordDate(currentDate); rate.setWindpowerstationId(wt.getWindpowerstationId()); rate.setProjectId(wt.getProjectId()); rate.setLineId(wt.getLineId()); rate.setWindturbineId(wt.getId()); rate.setCompanyId(wt.getCompanyId()); rate.setRegionId(wt.getRegionId()); Initial.initial(rate); rates.put(wt.getId(), rate); } for (ProEconShutdownEvent2 item : shutdownevents) { if (rates.containsKey(item.getWindturbineId())) { if (item.getStopHours() <= 1) { double temp = rates.get(item.getWindturbineId()).getTimerate20(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate20(temp); if (item.getStopHours() <= 0.08) { temp = rates.get(item.getWindturbineId()).getTimerate16(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate16(temp); temp = rates.get(item.getWindturbineId()).getTimerate17(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate17(temp); temp = rates.get(item.getWindturbineId()).getTimerate18(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate18(temp); temp = rates.get(item.getWindturbineId()).getTimerate19(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate19(temp); item.setResetRate("5"); } else if (item.getStopHours() <= 0.17) { temp = rates.get(item.getWindturbineId()).getTimerate17(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate17(temp); temp = rates.get(item.getWindturbineId()).getTimerate18(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate18(temp); temp = rates.get(item.getWindturbineId()).getTimerate19(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate19(temp); item.setResetRate("10"); } else if (item.getStopHours() <= 0.25) { temp = rates.get(item.getWindturbineId()).getTimerate18(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate18(temp); temp = rates.get(item.getWindturbineId()).getTimerate19(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate19(temp); item.setResetRate("15"); } else if (item.getStopHours() <= 0.33) { temp = rates.get(item.getWindturbineId()).getTimerate19(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate19(temp); item.setResetRate("20"); } else if (item.getResetRate() == null) { item.setResetRate("99"); } else { item.setResetRate(null); } } if (item.getStopHours() < 24) { double temp = rates.get(item.getWindturbineId()).getTimerate21(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate21(temp); } double temp = rates.get(item.getWindturbineId()).getTimerate22(); temp = temp + 1; rates.get(item.getWindturbineId()).setTimerate22(temp); } } stateRate(currentDate,rates); List dayls=new ArrayList<>(); QueryWrapper queryWrapper2 = new QueryWrapper<>(); queryWrapper2.ge("record_date",currentDate); List dayInfoids = proEconEquipmentInfoDay5Service.list(queryWrapper2) .stream() // .filter(i -> i.getRecordDate().compareTo(currentDate) == 0 // ) .map(ProEconEquipmentInfoDay5::getId).collect(Collectors.toList()); ProEconEquipmentInfoDay5 dayInfo; if (!dayInfoids.isEmpty()) { proEconEquipmentInfoDay5Service.removeByIds(dayInfoids); } for (ProEconEquipmentInfoDay5 day : rates.values()) { dayInfo = new ProEconEquipmentInfoDay5(); buildresetRate(dayInfo, day); dayls.add(dayInfo); //proEconEquipmentInfoDay5Service.save(dayInfo); } List templs=new ArrayList<>(); for(ProEconEquipmentInfoDay5 vo:dayls) { templs.add(vo); if(templs.size()==100) { proEconEquipmentInfoDay5Service.saveBatch(templs); templs=new ArrayList<>(); } } if(!templs.isEmpty()) { proEconEquipmentInfoDay5Service.saveBatch(templs); } // proEconEquipmentInfoDay5Service.saveBatch(dayls); } public void buildresetRate(ProEconEquipmentInfoDay5 dayInfo, ProEconEquipmentInfoDay5 day) { dayInfo.setRecordDate(day.getRecordDate()); dayInfo.setWindpowerstationId(day.getWindpowerstationId()); dayInfo.setProjectId(day.getProjectId()); dayInfo.setLineId(day.getLineId()); dayInfo.setWindturbineId(day.getWindturbineId()); dayInfo.setRegionId(day.getRegionId()); dayInfo.setCompanyId(day.getCompanyId()); dayInfo.setTimerate1(day.getTimerate1()); dayInfo.setTimerate2(day.getTimerate2()); dayInfo.setTimerate3(day.getTimerate3()); dayInfo.setTimerate4(day.getTimerate4()); dayInfo.setTimerate5(day.getTimerate5()); dayInfo.setTimerate6(day.getTimerate6()); dayInfo.setTimerate7(day.getTimerate7()); dayInfo.setTimerate8(day.getTimerate8()); dayInfo.setTimerate9(day.getTimerate9()); dayInfo.setTimerate10(day.getTimerate10()); dayInfo.setTimerate11(day.getTimerate11()); dayInfo.setTimerate12(day.getTimerate12()); dayInfo.setTimerate13(day.getTimerate13()); dayInfo.setTimerate14(day.getTimerate14()); dayInfo.setTimerate15(day.getTimerate15()); dayInfo.setTimerate16(day.getTimerate16()); dayInfo.setTimerate17(day.getTimerate17()); dayInfo.setTimerate18(day.getTimerate18()); dayInfo.setTimerate19(day.getTimerate19()); dayInfo.setTimerate20(day.getTimerate20()); dayInfo.setTimerate21(day.getTimerate21()); dayInfo.setTimerate22(day.getTimerate22()); } /** * 状态转换及时率 */ Map stateDescription1 = new HashMap<>(); Map stateDescription2 = new HashMap<>(); public void stateRate(Date currentDate,Map rates) throws Exception { if (stateDescription1.size() == 0) { stateDescription1.put(3.0, 6.0); stateDescription1.put(3.5, 0.0); stateDescription1.put(4.0, 0.0); } if (stateDescription2.size() == 0) { stateDescription2.put(3.0, 6.0); stateDescription2.put(3.5, 2.0); stateDescription2.put(4.0, 2.0); } //调度时间是第二天，currentDate 是第一天 Date beginDate = DateUtils.truncate(currentDate); Date endDate = DateUtils.addDays(currentDate, 1); // // final CountDownLatch latch = new CountDownLatch(+CacheContext.wtls.size()); for (ProBasicEquipment wt : CacheContext.wtls) { if(wt.getWindpowerstationId().contains("GDC")) { continue; } ProEconEquipmentInfoDay5 rate = rates.get(wt.getId()); List speedDataList = null; List statusDataList = null; if (CacheContext.wtpAimap.containsKey(wt.getId())) { Map wtpmap = CacheContext.wtpAimap.get(wt.getId()); if (wtpmap.containsKey(ContantXk.CJ_SSFS)) { ProBasicEquipmentPoint point = wtpmap.get(ContantXk.CJ_SSFS); speedDataList = edosUtil.getHistoryDatasSnap(point.getNemCode(), beginDate.getTime() / 1000, endDate.getTime() / 1000); } if (wtpmap.containsKey(ContantXk.MXZT)) { ProBasicEquipmentPoint point = wtpmap.get(ContantXk.MXZT); statusDataList = edosUtil.getHistoryDatasSnap(point.getNemCode(), beginDate.getTime() / 1000, endDate.getTime() / 1000); } } if (speedDataList != null && statusDataList != null && statusDataList.size() == speedDataList.size() && !speedDataList.isEmpty()) { double laststatus = -1; Date begin = new Date(); for (int i = 0; i < speedDataList.size(); i++) { double status = statusDataList.get(i).getPointValueInDouble(); double speed = speedDataList.get(i).getPointValueInDouble(); if (i == 0) { begin = new Date(speedDataList.get(i).getPointTime()); laststatus = status; } if (speed <= 3.0) { if (laststatus != status && (status == stateDescription1.get(3.0) || status == stateDescription2.get(3.0))) { Date end = new Date(speedDataList.get(i).getPointTime()); double zhcs = DateUtils.hoursDiff2(begin, end); if (zhcs < 0.25)//5分钟 { double temp = rate.getTimerate1(); temp = temp + 1; rate.setTimerate1(temp); temp = rate.getTimerate2(); temp = temp + 1; rate.setTimerate2(temp); temp = rate.getTimerate3(); temp = temp + 1; rate.setTimerate3(temp); temp = rate.getTimerate4(); temp = temp + 1; rate.setTimerate4(temp); } else if (zhcs < 0.33)//10分钟 { double temp = rate.getTimerate2(); temp = temp + 1; rate.setTimerate2(temp); temp = rate.getTimerate3(); temp = temp + 1; rate.setTimerate3(temp); temp = rate.getTimerate4(); temp = temp + 1; rate.setTimerate4(temp); } else if (zhcs < 0.42)//15分钟 { double temp = rate.getTimerate3(); temp = temp + 1; rate.setTimerate3(temp); temp = rate.getTimerate4(); temp = temp + 1; rate.setTimerate4(temp); } else if (zhcs < 0.5)//20分钟 { double temp = rate.getTimerate4(); temp = temp + 1; rate.setTimerate4(temp); } double temp = rate.getTimerate13(); temp = temp + 1; rate.setTimerate13(temp); } laststatus = status; begin = new Date(speedDataList.get(i).getPointTime()); } else if (speed <= 4.0 && speed > 3.0) { if (laststatus != status && (status == stateDescription1.get(3.5) || status == stateDescription2.get(3.5))) { Date end = new Date(speedDataList.get(i).getPointTime()); double zhcs = DateUtils.hoursDiff2(begin, end); if (zhcs < 0.25)//5分钟 { double temp = rate.getTimerate5(); temp = temp + 1; rate.setTimerate5(temp); temp = rate.getTimerate6(); temp = temp + 1; rate.setTimerate6(temp); temp = rate.getTimerate7(); temp = temp + 1; rate.setTimerate7(temp); temp = rate.getTimerate8(); temp = temp + 1; rate.setTimerate8(temp); } else if (zhcs < 0.33)//10分钟 { double temp = rate.getTimerate6(); temp = temp + 1; rate.setTimerate6(temp); temp = rate.getTimerate7(); temp = temp + 1; rate.setTimerate7(temp); temp = rate.getTimerate8(); temp = temp + 1; rate.setTimerate8(temp); } else if (zhcs < 0.42)//15分钟 { double temp = rate.getTimerate7(); temp = temp + 1; rate.setTimerate7(temp); temp = rate.getTimerate8(); temp = temp + 1; rate.setTimerate8(temp); } else if (zhcs < 0.5)//20分钟 { double temp = rate.getTimerate8(); temp = temp + 1; rate.setTimerate8(temp); } //} double temp = rate.getTimerate14(); temp = temp + 1; rate.setTimerate14(temp); } laststatus = status; begin = new Date(speedDataList.get(i).getPointTime()); } else { if (laststatus != status && (status == stateDescription1.get(4.0) || status == stateDescription2.get(4.0))) { Date end = new Date(speedDataList.get(i).getPointTime()); double zhcs = DateUtils.hoursDiff2(begin, end); if (zhcs < 0.25)//5分钟 { double temp = rate.getTimerate9(); temp = temp + 1; rate.setTimerate9(temp); temp = rate.getTimerate10(); temp = temp + 1; rate.setTimerate10(temp); temp = rate.getTimerate11(); temp = temp + 1; rate.setTimerate11(temp); temp = rate.getTimerate12(); temp = temp + 1; rate.setTimerate12(temp); } else if (zhcs < 0.33)//10分钟 { double temp = rate.getTimerate10(); temp = temp + 1; rate.setTimerate10(temp); temp = rate.getTimerate11(); temp = temp + 1; rate.setTimerate11(temp); temp = rate.getTimerate12(); temp = temp + 1; rate.setTimerate12(temp); } else if (zhcs < 0.42)//15分钟 { double temp = rate.getTimerate11(); temp = temp + 1; rate.setTimerate11(temp); temp = rate.getTimerate12(); temp = temp + 1; rate.setTimerate12(temp); } else if (zhcs < 0.5)//20分钟 { double temp = rate.getTimerate12(); temp = temp + 1; rate.setTimerate12(temp); } double temp = rate.getTimerate15(); temp = temp + 1; rate.setTimerate15(temp); laststatus = status; begin = new Date(speedDataList.get(i).getPointTime()); } } } } } // latch.await(); } }