powerIntelligenceSystem.git

			@@ -8,6 +8,7 @@
			import com.whyc.dto.Real.PwrHisRealDcoutInDto;
			import com.whyc.dto.Real.QuarterDto;
			import com.whyc.dto.RealDataStatic.ResRealDataAc;
			import com.whyc.dto.RealDataStatic.ResRealExportAc;
			import com.whyc.dto.RealDataStatic.SticRealDataAc;
			import com.whyc.dto.Response;
			import com.whyc.dto.Statistic.QuarterPwr7Res;
			@@ -31,6 +32,7 @@
			import java.text.ParseException;
			import java.time.LocalDateTime;
			import java.time.format.DateTimeFormatter;
			import java.time.temporal.TemporalAdjusters;
			import java.util.*;
			import java.util.concurrent.CountDownLatch;
			import java.util.concurrent.ThreadPoolExecutor;
			@@ -304,37 +306,102 @@
			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);
			public Response getSticRealAcData(SticRealDataAc stic) throws ParseException, InterruptedException {
			Integer granularity=2;//默认值
			Map<String,Date> startAndEndTime=DateUtil.getStartAndEndTime(stic.getSticTime());
			//获取两个时间分割多少张表
			List<List<Date>> monthTimeList = DateUtil.getMonthTime(startTime,endTime);
			List<List<Date>> monthTimeList = DateUtil.getMonthTime(startAndEndTime.get("startTime"),startAndEndTime.get("endTime"));
			List<ResRealDataAc> dataList = new LinkedList<>();
			Map<String, Map<String,List<String>>> allTimeMap=new HashMap<>();
			ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor();
			CountDownLatch latch = new CountDownLatch(monthTimeList.size());
			for (int i = 0; i < monthTimeList.size(); i++) {
			int finalI = i;
			Integer finalGranularity = granularity;
			Map<String,List<String>> propertyInfo=stic.getPropertyInfo();
			pool.execute(() -> {
			int finalII = finalI;
			Date recordDatetime=monthTimeList.get(finalII).get(0);
			Date recordDatetime1=monthTimeList.get(finalII).get(1);
			String timeTable=ThreadLocalUtil.format(recordDatetime,2);
			String table = stic.getPowerId() + "_" + timeTable;
			String tableName="db_data_history.tb_pwrdev_historydata_"+table;
			//判断表是否存在
			int tableNum = subTablePageInfoService.judgeTable_pwrhis(table);
			List<ResRealDataAc> list = new ArrayList();
			Map<String,List<String>> timeMap=new HashMap<>();
			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.getSticRealAcData(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum,propertyInfo);
			//所有属性的异动点
			List<Integer> allChangeNums=new ArrayList<>();
			//获取指定时间取出每个参数的异动次数和异动的recordNum
			for (Map.Entry<String, List<String>> entry : propertyInfo.entrySet()) {
			String param = entry.getKey();
			List<String> valueList = entry.getValue();
			for (String value : valueList) {
			float upperLimit=550;
			float lowerLimit=50;
			//查询电源字段的异动
			List changes= subTablePageInfoService.getPwrChangesRecordNum(tableName,recordDatetime,recordDatetime1,value,upperLimit,lowerLimit);
			List<Integer> numList= (List<Integer>) changes.get(0);//record_num的集合
			List<String> timeList= (List<String>) changes.get(1);//record_datetime的集合
			if(numList!=null&&numList.size()>0){
			allChangeNums.addAll(numList);
			}
			//存放每个参数的异动时间点
			timeMap.put(value,timeList);
			}
			}
			//只有存在异动点采取查询异动数据
			if(allChangeNums.size()>0){
			//查询大类参数下所有异动recordNum的记录之和
			List<ResRealDataAc> paramList=subTablePageInfoService.getPwrPropertyChangesByRecordNum(tableName,recordDatetime,recordDatetime1,allChangeNums,propertyInfo);
			list.addAll(paramList);
			}
			}
			allTimeMap.put(timeTable,timeMap);
			dataList.addAll(list);
			latch.countDown();
			});
			sleep(200);
			}
			latch.await(10, TimeUnit.MINUTES);
			List<ResRealDataAc> uniqueList = dataList.stream()
			.distinct()
			.collect(Collectors.toList());
			List dataListSorted = uniqueList.stream().sorted(Comparator.comparing(ResRealDataAc::getRecordNum)).collect(Collectors.toList());
			//所有异动点合并去重
			Map<String, List<String>> mergedMap =ActionUtil.getMergeMap(allTimeMap);
			return new Response().setIII(1,dataList.size()>0,dataListSorted,mergedMap,"实时数据数据曲线统计-交流单元");
			}
			//实时数据统计曲线-交流单元导出(2.5.2)
			public List<ResRealDataAc> getSticRealAcDataForExport(ResRealExportAc exportAc) throws ParseException, InterruptedException {
			Integer granularity=2;//默认值
			Map<String,Date> startAndEndTime=DateUtil.getStartAndEndTime(exportAc.getSticTime());
			//获取两个时间分割多少张表
			List<List<Date>> monthTimeList = DateUtil.getMonthTime(startAndEndTime.get("startTime"),startAndEndTime.get("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;
			Map<String,List<String>> propertyInfo=exportAc.getPropertyInfo();
			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 timeTable=ThreadLocalUtil.format(recordDatetime,2);
			String table = exportAc.getPowerId() + "_" + timeTable;
			String tableName="db_data_history.tb_pwrdev_historydata_"+table;
			//判断表是否存在
			int tableNum = subTablePageInfoService.judgeTable_pwrhis(table);
			@@ -348,7 +415,31 @@
			maxRecordNum=(Integer)recordNums.get(0);
			minRecordNum=(Integer)recordNums.get(1);
			}
			list=subTablePageInfoService.getPwrHisAcData(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum,stic.getPropertyInfo());
			//先按照频率查询出正常数据
			list=subTablePageInfoService.getSticRealAcData(tableName, finalGranularity,recordDatetime,recordDatetime1,maxRecordNum,minRecordNum,propertyInfo);
			//所有属性的异动点
			List<Integer> allChangeNums=new ArrayList<>();
			//获取指定时间取出每个参数的异动次数和异动的recordNum
			for (Map.Entry<String, List<String>> entry : propertyInfo.entrySet()) {
			String param = entry.getKey();
			List<String> valueList = entry.getValue();
			for (String value : valueList) {
			float upperLimit=550;
			float lowerLimit=50;
			//查询电源字段的异动
			List changes= subTablePageInfoService.getPwrChangesRecordNum(tableName,recordDatetime,recordDatetime1,value,upperLimit,lowerLimit);
			List<Integer> numList= (List<Integer>) changes.get(0);//record_num的集合
			if(numList!=null&&numList.size()>0){
			allChangeNums.addAll(numList);
			}
			}
			}
			//只有存在异动点采取查询异动数据
			if(allChangeNums.size()>0){
			//查询大类参数下所有异动recordNum的记录之和
			List<ResRealDataAc> paramList=subTablePageInfoService.getPwrPropertyChangesByRecordNum(tableName,recordDatetime,recordDatetime1,allChangeNums,propertyInfo);
			list.addAll(paramList);
			}
			}
			dataList.addAll(list);
			latch.countDown();
			@@ -356,7 +447,10 @@
			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,"获取半小时内交流输入统计");
			List<ResRealDataAc> uniqueList = dataList.stream()
			.distinct()
			.collect(Collectors.toList());
			List dataListSorted = uniqueList.stream().sorted(Comparator.comparing(ResRealDataAc::getRecordNum)).collect(Collectors.toList());
			return dataListSorted;
			}
			}