| | |
|---|
| | | package com.whyc.service; |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.whyc.constant.PwrCapperformanceEnum; |
|---|
| | | import com.whyc.dto.AnalysisAlm.ResAnalysis; |
|---|
| | | import com.whyc.dto.Real.CompareDto; |
|---|
| | | import com.whyc.dto.Real.PwrHisRealAcInDto; |
|---|
| | | import com.whyc.dto.Real.PwrHisRealDcoutInDto; |
|---|
| | | import com.whyc.dto.Real.QuarterDto; |
|---|
| | | import com.whyc.dto.RealDataStatic.ResRealDataAc; |
|---|
| | | import com.whyc.dto.RealDataStatic.SticRealDataAc; |
|---|
| | | import com.whyc.dto.Response; |
|---|
| | | import com.whyc.dto.Statistic.QuarterPwr7Res; |
|---|
| | | import com.whyc.factory.ThreadPoolExecutorFactory; |
|---|
| | | import com.whyc.mapper.CommonMapper; |
|---|
| | | import com.whyc.pojo.db_data_history.BattRealdataId; |
|---|
| | | import com.whyc.pojo.db_data_history.PwrdevHistorydataId; |
|---|
| | | import com.whyc.pojo.db_param.AppParam; |
|---|
| | | import com.whyc.pojo.db_param.ApptimeParam; |
|---|
| | | import com.whyc.pojo.db_param.PowerPropertyParam; |
|---|
| | | import com.whyc.pojo.db_param.PowerheartParam; |
|---|
| | | import com.whyc.pojo.db_station.PowerInf; |
|---|
| | | import com.whyc.util.ActionUtil; |
|---|
| | | import com.whyc.util.DateUtil; |
|---|
| | | import com.whyc.util.ThreadLocalUtil; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.List; |
|---|
| | | import java.lang.reflect.Field; |
|---|
| | | import java.text.ParseException; |
|---|
| | | import java.time.LocalDateTime; |
|---|
| | | import java.time.format.DateTimeFormatter; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.CountDownLatch; |
|---|
| | | import java.util.concurrent.ThreadPoolExecutor; |
|---|
| | | import java.util.concurrent.TimeUnit; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | import static java.lang.Thread.sleep; |
|---|
| | | |
|---|
| | | @Service |
|---|
| | | public class PwrdevHistorydataIdService { |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private PowerInfService powerInfService; |
|---|
| | | |
|---|
| | | //系统概览获取半小时交流输入统计 |
|---|
| | | public Response getHalfHourPwrHisAcinData(Integer powerId,Integer granularity) { |
|---|
| | | String dateTime = ActionUtil.sdfwithOutday.format(new Date()); |
|---|
| | | String tableName ="db_data_history.tb_pwrdev_historydata_"+powerId+"_"+dateTime; |
|---|
| | | String existTableName = commonMapper.existTable("db_data_history", "tb_pwrdev_historydata_"+powerId+"_"+dateTime); |
|---|
| | | if(existTableName == null){ |
|---|
| | | return new Response().set(1,false,"当前电池组不存在前面小时数据"); |
|---|
| | | } |
|---|
| | | List<PwrHisRealAcInDto> datalist=subTablePageInfoService.getHalfHourPwrHisAcinData(tableName,granularity); |
|---|
| | | return new Response().setII(1,datalist.size()>0,datalist,"获取半小时内交流输入统计"); |
|---|
| | | @Autowired |
|---|
| | | private AppParamService appParamService; |
|---|
| | | |
|---|
| | | } |
|---|
| | | //系统概览获取半小时直流输出统计 |
|---|
| | | public Response getHalfHourPwrHisDcoutData(Integer powerId,Integer granularity) { |
|---|
| | | String dateTime = ActionUtil.sdfwithOutday.format(new Date()); |
|---|
| | | String tableName ="db_data_history.tb_pwrdev_historydata_"+powerId+"_"+dateTime; |
|---|
| | | String existTableName = commonMapper.existTable("db_data_history", "tb_pwrdev_historydata_"+powerId+"_"+dateTime); |
|---|
| | | if(existTableName == null){ |
|---|
| | | return new Response().set(1,false,"当前电源不存在前面小时数据"); |
|---|
| | | @Autowired |
|---|
| | | private ApptimeParamService apptimeParamService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private PowerPropertyParamService propertyParamService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private PowerheartParamService heartService; |
|---|
| | | |
|---|
| | | //系统概览前N笔交流输入统计 |
|---|
| | | public Response getPwrHisAcinData100(Integer powerId) throws ParseException, InterruptedException { |
|---|
| | | //获取前笔数*时间间隔 |
|---|
| | | PowerheartParam heartParam=heartService.getHeartParamByPowerId(powerId); |
|---|
| | | Integer interverCount=100*5;//默认值 |
|---|
| | | Integer granularity=5;//默认值 |
|---|
| | | if(heartParam!=null){ |
|---|
| | | interverCount=heartParam.getAcinInterverCfg()*heartParam.getAcinCountCfg(); |
|---|
| | | granularity=heartParam.getAcinInterverCfg(); |
|---|
| | | } |
|---|
| | | List<PwrHisRealDcoutInDto> datalist=subTablePageInfoService.getHalfHourPwrHisDcoutData(tableName,granularity); |
|---|
| | | DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); |
|---|
| | | LocalDateTime now = LocalDateTime.now(); |
|---|
| | | String dateTime = now.format(formatter); |
|---|
| | | Date endTime=ActionUtil.sdf.parse(dateTime); |
|---|
| | | // 计算笔数*时间间隔的时间点 |
|---|
| | | LocalDateTime halfHourAgo = now.minusMinutes(interverCount); |
|---|
| | | // 格式化输出 |
|---|
| | | String halfHourAgoTime=halfHourAgo.format(formatter); |
|---|
| | | Date startTime=ActionUtil.sdf.parse(halfHourAgoTime); |
|---|
| | | //获取两个时间分割多少张表 |
|---|
| | | List<List<Date>> monthTimeList = DateUtil.getMonthTime(startTime,endTime); |
|---|
| | | List<PwrHisRealAcInDto> dataList = new LinkedList<>(); |
|---|
| | | ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); |
|---|
| | | CountDownLatch latch = new CountDownLatch(monthTimeList.size()); |
|---|
| | | for (int i = 0; i < monthTimeList.size(); i++) { |
|---|
| | | int finalI = i; |
|---|
| | | Integer finalGranularity = granularity; |
|---|
| | | pool.execute(() -> { |
|---|
| | | int finalII = finalI; |
|---|
| | | Date recordDatetime=monthTimeList.get(finalII).get(0); |
|---|
| | | Date recordDatetime1=monthTimeList.get(finalII).get(1); |
|---|
| | | String table = powerId + "_" + ThreadLocalUtil.format(recordDatetime,2); |
|---|
| | | String tableName="db_data_history.tb_pwrdev_historydata_"+table; |
|---|
| | | //判断表是否存在 |
|---|
| | | int tableNum = subTablePageInfoService.judgeTable_pwrhis(table); |
|---|
| | | List<PwrHisRealAcInDto> list = new ArrayList(); |
|---|
| | | if (tableNum > 0) { |
|---|
| | | //获取指定时间段内最大最小recordNum确保数据的完整 |
|---|
| | | List recordNums= subTablePageInfoService.getPwrMaxAndMinRecordNum(tableName,recordDatetime,recordDatetime1); |
|---|
| | | Integer maxRecordNum= 0; |
|---|
| | | Integer minRecordNum= 0; |
|---|
| | | if(recordNums.size()>0){ |
|---|
| | | maxRecordNum=(Integer)recordNums.get(0); |
|---|
| | | minRecordNum=(Integer)recordNums.get(1); |
|---|
| | | } |
|---|
| | | list=subTablePageInfoService.getHalfHourPwrHisAcinData(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum); |
|---|
| | | } |
|---|
| | | dataList.addAll(list); |
|---|
| | | latch.countDown(); |
|---|
| | | }); |
|---|
| | | sleep(200); |
|---|
| | | } |
|---|
| | | latch.await(10, TimeUnit.MINUTES); |
|---|
| | | List dataListSorted = dataList.stream().sorted(Comparator.comparing(PwrHisRealAcInDto::getRecordDatetime)).collect(Collectors.toList()); |
|---|
| | | return new Response().setII(1,dataList.size()>0,dataListSorted,"获取半小时内交流输入统计"); |
|---|
| | | } |
|---|
| | | //系统概览获取前N笔直流输出统计 |
|---|
| | | public Response getHalfHourPwrHisDcoutData(Integer powerId) throws InterruptedException, ParseException { |
|---|
| | | //获取前笔数*时间间隔 |
|---|
| | | PowerheartParam heartParam=heartService.getHeartParamByPowerId(powerId); |
|---|
| | | Integer interverCount=100*5;//默认值 |
|---|
| | | Integer granularity=5;//默认值 |
|---|
| | | if(heartParam!=null){ |
|---|
| | | interverCount=heartParam.getAcoutInterverCfg()*heartParam.getAcoutCountCfg(); |
|---|
| | | granularity=heartParam.getAcoutInterverCfg();//默认时间间隔一分钟一笔，所以时间间隔就是几笔取一笔 |
|---|
| | | } |
|---|
| | | DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); |
|---|
| | | LocalDateTime now = LocalDateTime.now(); |
|---|
| | | String dateTime = now.format(formatter); |
|---|
| | | Date endTime=ActionUtil.sdf.parse(dateTime); |
|---|
| | | // 计算笔数*时间间隔的时间点 |
|---|
| | | LocalDateTime halfHourAgo = now.minusMinutes(interverCount); |
|---|
| | | // 格式化输出 |
|---|
| | | String halfHourAgoTime=halfHourAgo.format(formatter); |
|---|
| | | Date startTime=ActionUtil.sdf.parse(halfHourAgoTime); |
|---|
| | | //获取两个时间分割多少张表 |
|---|
| | | List<List<Date>> monthTimeList = DateUtil.getMonthTime(startTime,endTime); |
|---|
| | | List<PwrHisRealDcoutInDto> dataList = new LinkedList<>(); |
|---|
| | | ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); |
|---|
| | | CountDownLatch latch = new CountDownLatch(monthTimeList.size()); |
|---|
| | | for (int i = 0; i < monthTimeList.size(); i++) { |
|---|
| | | int finalI = i; |
|---|
| | | Integer finalGranularity = granularity; |
|---|
| | | pool.execute(() -> { |
|---|
| | | int finalII = finalI; |
|---|
| | | Date recordDatetime=monthTimeList.get(finalII).get(0); |
|---|
| | | Date recordDatetime1=monthTimeList.get(finalII).get(1); |
|---|
| | | String table = powerId + "_" + ThreadLocalUtil.format(recordDatetime,2); |
|---|
| | | String tableName="db_data_history.tb_pwrdev_historydata_"+table; |
|---|
| | | //判断表是否存在 |
|---|
| | | int tableNum = subTablePageInfoService.judgeTable_pwrhis(table); |
|---|
| | | List<PwrHisRealDcoutInDto> list = new ArrayList(); |
|---|
| | | if (tableNum > 0) { |
|---|
| | | //获取指定时间段内最大最小recordNum确保数据的完整 |
|---|
| | | List recordNums= subTablePageInfoService.getPwrMaxAndMinRecordNum(tableName,recordDatetime,recordDatetime1); |
|---|
| | | Integer maxRecordNum= 0; |
|---|
| | | Integer minRecordNum= 0; |
|---|
| | | if(recordNums.size()>0){ |
|---|
| | | maxRecordNum=(Integer)recordNums.get(0); |
|---|
| | | minRecordNum=(Integer)recordNums.get(1); |
|---|
| | | } |
|---|
| | | list=subTablePageInfoService.getHalfHourPwrHisDcoutData(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum); |
|---|
| | | } |
|---|
| | | dataList.addAll(list); |
|---|
| | | latch.countDown(); |
|---|
| | | }); |
|---|
| | | sleep(200); |
|---|
| | | } |
|---|
| | | latch.await(10, TimeUnit.MINUTES); |
|---|
| | | List dataListSorted = dataList.stream().sorted(Comparator.comparing(PwrHisRealDcoutInDto::getRecordDatetime)).collect(Collectors.toList()); |
|---|
| | | Long modelCfg=0l; |
|---|
| | | PowerInf pinf=powerInfService.getPowerInfById(powerId); |
|---|
| | | if(pinf!=null){ |
|---|
| | | modelCfg=pinf.getModelCfg(); |
|---|
| | | } |
|---|
| | | return new Response().setIII(1,datalist.size()>0,datalist,modelCfg,"获取半小时内直流输出统计"); |
|---|
| | | return new Response().setIII(1,dataList.size()>0,dataListSorted,modelCfg,"获取半小时内直流输出统计"); |
|---|
| | | } |
|---|
| | | //1.2.7优良电源统计上一季度的电源某一属性和参数阈值超过的次数 |
|---|
| | | public Integer getPwrQuarter7(Integer powerId,Integer powerType) throws NoSuchFieldException, IllegalAccessException { |
|---|
| | | Map<String,Integer> map=new HashMap<>(); |
|---|
| | | //获取优良电源性能统计在平台上的时间参数设置表 |
|---|
| | | ApptimeParam apptimeParam=apptimeParamService.getPwrPerformanceStrartTime(powerId); |
|---|
| | | //获取指定时间到当前时间一共多少月的集合 |
|---|
| | | List<String> datelist=ActionUtil.getDateListBetweenDates(apptimeParam.getParamValue(), new Date()); |
|---|
| | | //获取电源优良判断的标准参数值 |
|---|
| | | List<PowerPropertyParam> paramList=propertyParamService.getPwrStandardParam(powerType); |
|---|
| | | List<String> propertyNameList = paramList.stream() |
|---|
| | | .map(param -> param.getPropertyName()) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | for (int i=0;i<datelist.size();i++) { |
|---|
| | | String date=datelist.get(i); |
|---|
| | | String tableName ="db_data_history.tb_pwrdev_historydata_"+powerId+"_"+date; |
|---|
| | | String existTableName = commonMapper.existTable("db_data_history", "tb_pwrdev_historydata_"+powerId+"_"+date); |
|---|
| | | //判断表是否存在 |
|---|
| | | if(existTableName == null){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | List<PwrdevHistorydataId> datalist=subTablePageInfoService.getPwrQuarter7(tableName,propertyNameList); |
|---|
| | | // 遍历 dataList 并比较属性值 |
|---|
| | | for (PwrdevHistorydataId data : datalist) { |
|---|
| | | for (int j=0;j<paramList.size();j++) { |
|---|
| | | PowerPropertyParam param = paramList.get(j); |
|---|
| | | String propertyName = ActionUtil.toCamelCase(param.getPropertyName()); |
|---|
| | | Field field = PwrdevHistorydataId.class.getDeclaredField(propertyName); |
|---|
| | | field.setAccessible(true); // 如果字段是私有的，需要设置为可访问 |
|---|
| | | Float value = (Float) field.get(data); |
|---|
| | | if ((value > (param.getBasisVal()*param.getAlarmLimithUpper()))||(value <(param.getBasisVal()*param.getAlarmLimitlLower()))) { |
|---|
| | | int limitNum=map.get(param.getPropertyName())==null?0:map.get(param.getPropertyName()); |
|---|
| | | map.put(param.getPropertyName(), limitNum+1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //判断优良电源性能 |
|---|
| | | int pwrPerformence=judgePwrPerformence(map); |
|---|
| | | return pwrPerformence; |
|---|
| | | } |
|---|
| | | //判断优良电源性能 |
|---|
| | | private Integer judgePwrPerformence(Map<String,Integer> map){ |
|---|
| | | //获取apps中优良电源判断参数 |
|---|
| | | List<AppParam> appParamList=appParamService.getPwrPerformenceParam(); |
|---|
| | | Float excellentVal=0f; |
|---|
| | | Float commonlyVal=0f; |
|---|
| | | Float warningVal=0f; |
|---|
| | | for (AppParam appParam : appParamList) { |
|---|
| | | if(appParam.getParamNamePsx().equals("power_excellent_val")){ |
|---|
| | | excellentVal=appParam.getParamValue(); |
|---|
| | | } |
|---|
| | | if(appParam.getParamNamePsx().equals("power_commonly_val")){ |
|---|
| | | commonlyVal=appParam.getParamValue(); |
|---|
| | | } |
|---|
| | | if(appParam.getParamNamePsx().equals("power_warning_val")){ |
|---|
| | | warningVal=appParam.getParamValue(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | Integer performance = PwrCapperformanceEnum.PWRSTATE_1.getStateId(); // 初始化为最优等级 |
|---|
| | | for (Map.Entry<String, Integer> entry : map.entrySet()) { |
|---|
| | | Integer level = evaluateValue(entry.getValue(), excellentVal, commonlyVal, warningVal); |
|---|
| | | // 根据等级排序确定当前是否是最差等级 |
|---|
| | | if (PwrCapperformanceEnum.PWRSTATE_4.getStateId()==level) { |
|---|
| | | performance = PwrCapperformanceEnum.PWRSTATE_4.getStateId(); |
|---|
| | | return performance; // 一旦出现差，直接返回 |
|---|
| | | } else if (PwrCapperformanceEnum.PWRSTATE_3.getStateId()==level && PwrCapperformanceEnum.PWRSTATE_4.getStateId()!=performance) { |
|---|
| | | performance = PwrCapperformanceEnum.PWRSTATE_3.getStateId(); |
|---|
| | | } else if (PwrCapperformanceEnum.PWRSTATE_2.getStateId()==level &&(PwrCapperformanceEnum.PWRSTATE_3.getStateId()!=performance||PwrCapperformanceEnum.PWRSTATE_4.getStateId()!=performance)) { |
|---|
| | | performance = PwrCapperformanceEnum.PWRSTATE_2.getStateId(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return performance; |
|---|
| | | } |
|---|
| | | // 判断单个值的等级 |
|---|
| | | public Integer evaluateValue(Integer value, Float excellentVal, Float commonlyVal, Float warningVal) { |
|---|
| | | if (value <= excellentVal) { |
|---|
| | | return PwrCapperformanceEnum.PWRSTATE_1.getStateId(); |
|---|
| | | } else if (value <= commonlyVal&&value > excellentVal) { |
|---|
| | | return PwrCapperformanceEnum.PWRSTATE_2.getStateId(); |
|---|
| | | } else if (value <= warningVal&&value > commonlyVal) { |
|---|
| | | return PwrCapperformanceEnum.PWRSTATE_3.getStateId(); |
|---|
| | | } else { |
|---|
| | | return PwrCapperformanceEnum.PWRSTATE_4.getStateId(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //电源历史实时查询 |
|---|
| | | public Response getPwrRealDataHis(Integer powerId, Integer granularity, String startTime, String endTime) throws InterruptedException, ParseException { |
|---|
| | | //获取两个时间分割多少张表 |
|---|
| | | List<List<Date>> monthTimeList = DateUtil.getMonthTime(ThreadLocalUtil.parse(startTime,1),ThreadLocalUtil.parse(endTime,1)); |
|---|
| | | List<PwrHisRealDcoutInDto> dataList = new LinkedList<>(); |
|---|
| | | ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); |
|---|
| | | CountDownLatch latch = new CountDownLatch(monthTimeList.size()); |
|---|
| | | for (int i = 0; i < monthTimeList.size(); i++) { |
|---|
| | | int finalI = i; |
|---|
| | | Integer finalGranularity = granularity; |
|---|
| | | pool.execute(() -> { |
|---|
| | | int finalII = finalI; |
|---|
| | | Date recordDatetime=monthTimeList.get(finalII).get(0); |
|---|
| | | Date recordDatetime1=monthTimeList.get(finalII).get(1); |
|---|
| | | String table = powerId + "_" + ThreadLocalUtil.format(recordDatetime,2); |
|---|
| | | String tableName="db_data_history.tb_pwrdev_historydata_"+table; |
|---|
| | | //判断表是否存在 |
|---|
| | | int tableNum = subTablePageInfoService.judgeTable_pwrhis(table); |
|---|
| | | List<PwrHisRealDcoutInDto> list = new ArrayList(); |
|---|
| | | if (tableNum > 0) { |
|---|
| | | //获取指定时间段内最大最小recordNum确保数据的完整 |
|---|
| | | List recordNums= subTablePageInfoService.getPwrMaxAndMinRecordNum(tableName,recordDatetime,recordDatetime1); |
|---|
| | | Integer maxRecordNum= 0; |
|---|
| | | Integer minRecordNum= 0; |
|---|
| | | if(recordNums.size()>0){ |
|---|
| | | maxRecordNum=(Integer)recordNums.get(0); |
|---|
| | | minRecordNum=(Integer)recordNums.get(1); |
|---|
| | | } |
|---|
| | | list=subTablePageInfoService.getPwrRealDataHis(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum); |
|---|
| | | } |
|---|
| | | dataList.addAll(list); |
|---|
| | | latch.countDown(); |
|---|
| | | }); |
|---|
| | | sleep(200); |
|---|
| | | } |
|---|
| | | latch.await(10, TimeUnit.MINUTES); |
|---|
| | | List dataListSorted = dataList.stream().sorted(Comparator.comparing(PwrHisRealDcoutInDto::getRecordDatetime)).collect(Collectors.toList()); |
|---|
| | | return new Response().setII(1,dataList.size()>0,dataListSorted,"获取半小时内直流输出统计"); |
|---|
| | | } |
|---|
| | | //实时数据数据曲线统计-交流单元 |
|---|
| | | public Response getPwrHisAcData(SticRealDataAc stic) throws ParseException, InterruptedException { |
|---|
| | | //获取前笔数*时间间隔 |
|---|
| | | PowerheartParam heartParam=heartService.getHeartParamByPowerId(stic.getPowerId()); |
|---|
| | | Integer interverCount=100*5;//默认值 |
|---|
| | | Integer granularity=5;//默认值 |
|---|
| | | if(heartParam!=null){ |
|---|
| | | interverCount=heartParam.getAcinInterverCfg()*heartParam.getAcinCountCfg(); |
|---|
| | | granularity=heartParam.getAcinInterverCfg(); |
|---|
| | | } |
|---|
| | | DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); |
|---|
| | | LocalDateTime now = LocalDateTime.now(); |
|---|
| | | String dateTime = now.format(formatter); |
|---|
| | | Date endTime=ActionUtil.sdf.parse(dateTime); |
|---|
| | | // 计算笔数*时间间隔的时间点 |
|---|
| | | LocalDateTime halfHourAgo = now.minusMinutes(interverCount); |
|---|
| | | // 格式化输出 |
|---|
| | | String halfHourAgoTime=halfHourAgo.format(formatter); |
|---|
| | | Date startTime=ActionUtil.sdf.parse(halfHourAgoTime); |
|---|
| | | //获取两个时间分割多少张表 |
|---|
| | | List<List<Date>> monthTimeList = DateUtil.getMonthTime(startTime,endTime); |
|---|
| | | List<ResRealDataAc> dataList = new LinkedList<>(); |
|---|
| | | ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); |
|---|
| | | CountDownLatch latch = new CountDownLatch(monthTimeList.size()); |
|---|
| | | for (int i = 0; i < monthTimeList.size(); i++) { |
|---|
| | | int finalI = i; |
|---|
| | | Integer finalGranularity = granularity; |
|---|
| | | pool.execute(() -> { |
|---|
| | | int finalII = finalI; |
|---|
| | | Date recordDatetime=monthTimeList.get(finalII).get(0); |
|---|
| | | Date recordDatetime1=monthTimeList.get(finalII).get(1); |
|---|
| | | String table = stic.getPowerId() + "_" + ThreadLocalUtil.format(recordDatetime,2); |
|---|
| | | String tableName="db_data_history.tb_pwrdev_historydata_"+table; |
|---|
| | | //判断表是否存在 |
|---|
| | | int tableNum = subTablePageInfoService.judgeTable_pwrhis(table); |
|---|
| | | List<ResRealDataAc> list = new ArrayList(); |
|---|
| | | if (tableNum > 0) { |
|---|
| | | //获取指定时间段内最大最小recordNum确保数据的完整 |
|---|
| | | List recordNums= subTablePageInfoService.getPwrMaxAndMinRecordNum(tableName,recordDatetime,recordDatetime1); |
|---|
| | | Integer maxRecordNum= 0; |
|---|
| | | Integer minRecordNum= 0; |
|---|
| | | if(recordNums.size()>0){ |
|---|
| | | maxRecordNum=(Integer)recordNums.get(0); |
|---|
| | | minRecordNum=(Integer)recordNums.get(1); |
|---|
| | | } |
|---|
| | | list=subTablePageInfoService.getPwrHisAcData(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum,stic.getPropertyInfo()); |
|---|
| | | } |
|---|
| | | dataList.addAll(list); |
|---|
| | | latch.countDown(); |
|---|
| | | }); |
|---|
| | | sleep(200); |
|---|
| | | } |
|---|
| | | latch.await(10, TimeUnit.MINUTES); |
|---|
| | | List dataListSorted = dataList.stream().sorted(Comparator.comparing(ResRealDataAc::getRecordDatetime)).collect(Collectors.toList()); |
|---|
| | | return new Response().setII(1,dataList.size()>0,dataListSorted,"获取半小时内交流输入统计"); |
|---|
| | | } |
|---|
| | | } |
|---|
