山西直流电源系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
whyclxw
7 天以前 669906b87674d4b60a6fd5ea3a938c636952dbc2 
 src/main/java/com/whyc/service/BattRealdataIdService.java


@@ -3,20 +3,32 @@


import com.whyc.dto.Real.BattHisRealDto;


import com.whyc.dto.Real.CompareDto;


import com.whyc.dto.Real.QuarterDto;


import com.whyc.dto.Real.RealDateDTO;


import com.whyc.dto.Response;


import com.whyc.factory.ThreadPoolExecutorFactory;


import com.whyc.mapper.CommonMapper;


import com.whyc.pojo.db_batt_testdata.BattresdataId;


import com.whyc.pojo.db_batt_testdata.BattresdataInf;




import com.whyc.pojo.db_data_history.BattRealdataId;


import com.whyc.pojo.db_station.BattInf;


import com.whyc.pojo.db_param.AlmAnalysisParam;


import com.whyc.pojo.db_param.AppParam;


import com.whyc.util.ActionUtil;


import com.whyc.util.DateUtil;


import com.whyc.util.ThreadLocalUtil;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import javax.annotation.Resource;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


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 BattRealdataIdService {


@@ -30,6 +42,12 @@




    @Autowired


    private BattInfService binfService;




    @Autowired


    private AlmAnalysisParamService almAnalysisParamService;




    @Autowired


    private AppParamService appParamService;






    //获取电池组最近一季度的单体数据


@@ -153,14 +171,97 @@


        return new Response().setII(1,map.size()>0,map,"获取电池组最近一季度的温度数据");


    }


    //系统概览获取半小时核容设备信息


    public Response getHalfHourBattDevData(Integer battgroupId) {


    public Response getHalfHourBattDevData(Integer battgroupId,Integer granularity) {


        String dateTime = ActionUtil.sdfwithOutday.format(new Date());


        String tableName ="db_data_history.tb_batt_realdata_"+battgroupId+"_"+dateTime;


        //获取前半个小时数据


        LocalDateTime now = LocalDateTime.now();


        // 计算半小时前的时间点


        LocalDateTime halfHourAgo = now.minusMinutes(30);


        // 格式化输出


        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");


        String halfHourAgoTime=halfHourAgo.format(formatter);


        String existTableName = commonMapper.existTable("db_data_history", "tb_batt_realdata_"+battgroupId+"_"+dateTime);


        if(existTableName == null){


            return new Response().set(1,false,"当前电池组不存在前面小时数据");


        }


        List<BattHisRealDto> datalist=subTablePageInfoService.getHalfHourBattDevData(tableName);


        List<BattHisRealDto> datalist=subTablePageInfoService.getHalfHourBattDevData(tableName,granularity,halfHourAgoTime);


        return new Response().setII(1,datalist.size()>0,datalist,"获取半小时内核容设备信息");


    }


    //历史实时数据


    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 finalI = i;


            pool.execute(() -> {


                int finalII = finalI;


                BattRealdataId realdata = new BattRealdataId();


                realdata.setRecordTime(monthTimeList.get(finalII).get(0));


                realdata.setRecordTime1(monthTimeList.get(finalII).get(1));


                String table = battgroupId + "_" + ThreadLocalUtil.format(realdata.getRecordTime(),2);


                realdata.setTableName(table);//表名时间格式部分


                //判断表是否存在


                int tableNum = subTablePageInfoService.judgeTable_realdata(table);


                List<RealDateDTO> list = new ArrayList();


                if (tableNum > 0) {


                    //获取指定时间段内最大最小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();


            });


            sleep(200);


        }


        latch.await(10, TimeUnit.MINUTES);


        List dataListSorted = dataList.stream().sorted(Comparator.comparing(RealDateDTO::getRecordTime)).collect(Collectors.toList());


        return new Response().set(1, dataListSorted);


    }


    //电池告警点击具体告警信息查看从告警开始时间到现在的历史实时数据


    public Response getBattHisRealInAlm(Integer battgroupId, String startTime, Integer almId) throws ParseException, InterruptedException {


        //获取告警almId对应的分析配置属性值


        AlmAnalysisParam almAnalysisParam= almAnalysisParamService.getAnalysisParam(almId);


        List<RealDateDTO> dataList = new LinkedList<>();


        //获取预警分析周期阈值


        AppParam appParam = appParamService.getAlarmAnalysisCycle();


        Integer cycleTime=appParam.getParamValue().intValue();


        Date cyscleDate=ActionUtil.getDateAdd(ThreadLocalUtil.parse(startTime,1),cycleTime*(-1));


        //获取cyscleDate到现在所有的历史实时数据


        List<List<Date>> monthTimeList = DateUtil.getMonthTime(cyscleDate,new Date());


        ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor();


        CountDownLatch latch = new CountDownLatch(monthTimeList.size());


        for (int i = 0; i < monthTimeList.size(); i++) {


            int finalI = i;


            pool.execute(() -> {


                int finalII = finalI;


                BattRealdataId realdata = new BattRealdataId();


                realdata.setRecordTime(monthTimeList.get(finalII).get(0));


                realdata.setRecordTime1(monthTimeList.get(finalII).get(1));


                String table = battgroupId + "_" + ThreadLocalUtil.format(realdata.getRecordTime(),2);


                realdata.setTableName(table);//表名时间格式部分


                //判断表是否存在


                int tableNum = subTablePageInfoService.judgeTable_realdata(table);


                List<RealDateDTO> list = new ArrayList();


                if (tableNum > 0) {


                    list = subTablePageInfoService.getBattHisRealInAlm(realdata);


                }


                dataList.addAll(list);


                latch.countDown();


            });


            sleep(200);


        }


        latch.await(10, TimeUnit.MINUTES);


        List dataListSorted = dataList.stream().sorted(Comparator.comparing(RealDateDTO::getRecordTime)).collect(Collectors.toList());


        return new Response().setIII(1,true, dataListSorted,almAnalysisParam,"电池告警点击具体告警信息查看从告警开始时间到现在的历史实时数据");




    }


}