| | |
|---|
| | | public Response getBattRealDataHis(Integer battgroupId, Integer granularity,String startTime,String endTime) throws ParseException, InterruptedException { |
|---|
| | | List<RealDateDTO> dataList = new LinkedList<>(); |
|---|
| | | List<List<Date>> monthTimeList = DateUtil.getMonthTime(ThreadLocalUtil.parse(startTime,1), ThreadLocalUtil.parse(endTime,1)); |
|---|
| | | |
|---|
| | | ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); |
|---|
| | | CountDownLatch latch = new CountDownLatch(monthTimeList.size()); |
|---|
| | | for (int i = 0; i < monthTimeList.size(); i++) { |
|---|
| | |
|---|
| | | int tableNum = subTablePageInfoService.judgeTable_realdata(table); |
|---|
| | | List<RealDateDTO> list = new ArrayList(); |
|---|
| | | if (tableNum > 0) { |
|---|
| | | list = subTablePageInfoService.serchByCondition2(realdata,granularity); |
|---|
| | | //获取指定时间段内最大最小recordNum确保数据的完整 |
|---|
| | | List recordNums= subTablePageInfoService.getMaxAndMinRecordNum(realdata); |
|---|
| | | Integer maxRecordNum= 0; |
|---|
| | | Integer minRecordNum= 0; |
|---|
| | | if(recordNums.size()>0){ |
|---|
| | | maxRecordNum=(Integer)recordNums.get(0); |
|---|
| | | minRecordNum=(Integer)recordNums.get(1); |
|---|
| | | } |
|---|
| | | list = subTablePageInfoService.getBattRealDataHis(realdata,granularity,maxRecordNum,minRecordNum); |
|---|
| | | } |
|---|
| | | dataList.addAll(list); |
|---|
| | | latch.countDown(); |
|---|
