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


@@ -2,12 +2,14 @@




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.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;


@@ -17,18 +19,23 @@


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.lang.reflect.Field;


import java.text.ParseException;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


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 {


@@ -53,62 +60,105 @@


    private PowerheartParamService heartService;




    //系统概览前N笔交流输入统计


    public Response getPwrHisAcinData100(Integer powerId) {


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


    public Response getPwrHisAcinData100(Integer powerId) throws ParseException, InterruptedException {


        //获取前笔数*时间间隔


        PowerheartParam heartParam=heartService.getHeartParamByPowerId(powerId);


        Integer interverCount=100*10;//默认值


        Integer granularity=10;//默认值


        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);


        // 格式化输出


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


        String halfHourAgoTime=halfHourAgo.format(formatter);


        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,"当前电池组不存在前面小时数据");


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


                    list=subTablePageInfoService.getHalfHourPwrHisAcinData(tableName, finalGranularity,recordDatetime,recordDatetime1);


                }


                dataList.addAll(list);


                latch.countDown();


            });


            sleep(200);


        }


        List<PwrHisRealAcInDto> datalist=subTablePageInfoService.getHalfHourPwrHisAcinData(tableName,granularity,halfHourAgoTime);


        return new Response().setII(1,datalist.size()>0,datalist,"获取半小时内交流输入统计");




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


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


    public Response getHalfHourPwrHisDcoutData(Integer powerId) throws InterruptedException, ParseException {


        //获取前笔数*时间间隔


        PowerheartParam heartParam=heartService.getHeartParamByPowerId(powerId);


        Integer interverCount=100*10;//默认值


        Integer granularity=10;//默认值


        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);


        // 格式化输出


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


        String halfHourAgoTime=halfHourAgo.format(formatter);




        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,"当前电源不存在前面小时数据");


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


                    list=subTablePageInfoService.getHalfHourPwrHisDcoutData(tableName, finalGranularity,recordDatetime,recordDatetime1);


                }


                dataList.addAll(list);


                latch.countDown();


            });


            sleep(200);


        }


        List<PwrHisRealDcoutInDto> datalist=subTablePageInfoService.getHalfHourPwrHisDcoutData(tableName,granularity,halfHourAgoTime);


        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 {