| | |
|---|
| | | 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,"获取半小时内直流输出统计"); |
|---|
| | | } |
|---|
| | | } |
|---|
