#水位数据&水电站生产运行月报时间格式化修改

hzims-service/hzims-scheduled/src/main/java/com/hnac/hzims/scheduled/service/operation/home/impl/RealTargetServiceImpl.java

@@ -41,6 +41,8 @@ import com.hnac.hzinfo.sdk.analyse.po.MultiAnalyzeCodePO;
 import com.hnac.hzinfo.sdk.core.response.HzPage;
 import com.hnac.hzinfo.sdk.core.response.Result;
 import com.hnac.hzinfo.sdk.v5.device.DeviceDataClient;
+import com.xxl.job.core.log.XxlJobLogger;
+import io.undertow.util.CopyOnWriteMap;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.MapUtils;
@@ -642,14 +644,16 @@ public class RealTargetServiceImpl implements RealTargetService {
 		List<WaterLevelVo> list = new CopyOnWriteArrayList<>();
 		CountDownLatch countDownLatch = new CountDownLatch(modelList.size());
 		for(HzimsAnalyzeModelStationEntity item : modelList){
-			pool.submit(() -> {
+			pool.execute(() -> {
 				try{
-					List<MultiAnalyzeCodePO> multiAnalyzeCodePOList=new ArrayList<>();
+					List<MultiAnalyzeCodePO> multiAnalyzeCodePOList = new ArrayList<>();
-					MultiAnalyzeCodePO multiAnalyzeCodePO=new MultiAnalyzeCodePO();
+					MultiAnalyzeCodePO multiAnalyzeCodePO = new MultiAnalyzeCodePO();
 					multiAnalyzeCodePO.setDeviceCode(item.getInstanceCode());
 					multiAnalyzeCodePO.setSignages(Collections.singletonList(HomePageConstant.FRONT_WATER_LEVEL));
 					multiAnalyzeCodePOList.add(multiAnalyzeCodePO);
-					R<List<AnalyzeCodeBySignagesVO>>result=analyseDataSearchClient.getAnalyzeCodeBySignages(multiAnalyzeCodePOList);
+					R<List<AnalyzeCodeBySignagesVO>> result = analyseDataSearchClient.getAnalyzeCodeBySignages(multiAnalyzeCodePOList);
+
+
 					if(result.isSuccess() && CollectionUtil.isNotEmpty(result.getData())){
 						WaterLevelVo waterLevelVo=new WaterLevelVo();
 						waterLevelVo.setStationCode(item.getStationId());
@@ -671,21 +675,25 @@ public class RealTargetServiceImpl implements RealTargetService {
 						list.add(waterLevelVo);
 					}
 					countDownLatch.countDown();
-				}catch (Exception exception){
+					XxlJobLogger.log("load_water_level : 子线程执行完成 {}", item.getInstanceCode());
-					log.error("load_water_level_error : {}",exception.getMessage());
+				} catch (Exception exception) {
 					countDownLatch.countDown();
+					XxlJobLogger.log("load_water_level_error : 子线程执行失败 {}", exception.getMessage());
 				}
 			});
-		}
+        }
 		try {
+			XxlJobLogger.log("load_water_level ：等待线程执行");
 			countDownLatch.await();
 		} catch (InterruptedException e) {
 			e.printStackTrace();
 			Thread.currentThread().interrupt();
 		}
+		XxlJobLogger.log("load_water_level ：线程执行结束");
 		redisTemplate.opsForValue().set(loadwater_level_key,list);
 	}
 
+
 	/**
 	 * 光伏站-逆变器实时加载
 	 *
@@ -947,7 +955,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		return datas.stream().map(data->{
 			ActivePowerVo active = new ActivePowerVo();
-			Date dateTime = DateUtil.parse(data.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			Date dateTime;
+			if(data.getTs().contains(".0")){
+				dateTime = DateUtil.parse(data.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			}else{
+				dateTime = DateUtil.parse(data.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+			}
 			active.setHour(dateTime.getHours());
 			if (StringUtil.isBlank(data.getVal())) {
 				active.setActivePower("0");
@@ -974,7 +987,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		return records.stream().map(record -> {
 			UsrPowerVo usr = new UsrPowerVo();
-			Date time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			Date time;
+			if(record.getTs().contains(".0")){
+				time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			}else{
+				time = DateUtil.parse(record.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+			}
 			usr.setDate(DateUtil.format(time,DateUtil.PATTERN_DATE));
 			usr.setUsrPower(Float.valueOf(Optional.ofNullable(record.getVal()).orElse("0")));
 			return usr;
@@ -1004,7 +1022,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		return records.stream().map(record -> {
 			PowerMonthVo generate = new PowerMonthVo();
-			Date time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			Date time;
+			if(record.getTs().contains(".0")){
+				time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			}else{
+				time = DateUtil.parse(record.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+			}
 			generate.setStrMonth(DateUtil.format(time, DateUtil.PATTERN_DATE));
 			if(StringUtil.isEmpty(record.getVal())){
 				generate.setPower(0f);
@@ -1217,7 +1240,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		if(StringUtil.isEmpty(time) || "-".equals(time)){
 			return 0.0;
 		}
-		Date date = DateUtil.parse(time, "yyyy-MM-dd HH:mm:ss.sss");
+		Date date;
+		if(time.contains(".000")){
+			date = DateUtil.parse(time, "yyyy-MM-dd HH:mm:ss.sss");
+		}else{
+			date = DateUtil.parse(time, DateUtil.PATTERN_DATETIME);
+		}
 		if(System.currentTimeMillis() - date.getTime() > 30 * 60 * 1000L){
 			return 0.0;
 		}
@@ -1245,7 +1273,11 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		return datas.stream().collect(Collectors.toMap(
 				key-> {
-					Date dateTime = DateUtil.parse(key.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+					if(key.getTs().contains(".0")){
+						Date dateTime = DateUtil.parse(key.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+						return dateTime.getHours();
+					}
+					Date dateTime = DateUtil.parse(key.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
 					return dateTime.getHours();
 				},
 				value -> {
@@ -1417,7 +1449,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 				}
 				datas.addAll(records.stream().map(record -> {
 					PowerMonthVo generate = new PowerMonthVo();
-					Date time = DateUtil.parse(record.get("ts"), "yyyy-MM-dd HH:mm:ss.s");
+					Date time;
+					if(record.get("ts").contains(".0")){
+						time = DateUtil.parse(record.get("ts"), "yyyy-MM-dd HH:mm:ss.s");
+					}else{
+						time = DateUtil.parse(record.get("ts") + ".0", "yyyy-MM-dd HH:mm:ss.s");
+					}
 					generate.setStrMonth(DateUtil.format(time,DateUtil.PATTERN_DATE));
 					String val = record.get(HomePageConstant.HYDROPOWER_GENERATE_POWER);
 					if(StringUtil.isEmpty(val)){
@@ -1535,7 +1572,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 				}
 				datas.addAll(records.stream().map(record -> {
 					PowerMonthVo generate = new PowerMonthVo();
-					Date time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+					Date time;
+					if(record.getTs().contains(".0")){
+						time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+					}else{
+						time = DateUtil.parse(record.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+					}
 					generate.setStrMonth(DateUtil.format(time,DateUtil.PATTERN_DATE));
 					if(StringUtil.isEmpty(record.getVal())){
 						generate.setPower(0f);
@@ -1782,7 +1824,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		return records.stream().map(record -> {
 			PhotovoltaicPowerVo load = new PhotovoltaicPowerVo();
-			Date time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			Date time;
+			if(record.getTs().contains(".0")){
+				time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			}else{
+				time = DateUtil.parse(record.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+			}
 			load.setHour(time.getHours());
 			load.setActivePower(Optional.ofNullable(record.getVal()).orElse("0"));
 			return load;
@@ -1809,7 +1856,12 @@ public class RealTargetServiceImpl implements RealTargetService {
 		}
 		return records.stream().map(record -> {
 			GenerationPowerVo generate = new GenerationPowerVo();
-			Date time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			Date time;
+			if(record.getTs().contains(".0")){
+				time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+			}else{
+				time = DateUtil.parse(record.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+			}
 			generate.setDate(DateUtil.format(time, DateUtil.PATTERN_DATE));
 			generate.setGenerate(Float.valueOf(Optional.ofNullable(record.getVal()).orElse("0")));
 			return generate;

hzims-service/operational/src/main/java/com/hnac/hzims/operational/ecology/service/impl/EcologyFlowStationServiceImpl.java

@@ -310,7 +310,12 @@ public class EcologyFlowStationServiceImpl extends ServiceImpl<EcologyFlowStatio
         }
         return records.stream().map(record -> {
             WaterVo water = new WaterVo();
-            Date time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+            Date time;
+            if(record.getTs().contains(".0")){
+                time = DateUtil.parse(record.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+            }else{
+                time = DateUtil.parse(record.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+            }
             water.setTime(DateUtil.format(time,DateUtil.PATTERN_DATE));
             water.setWater(Double.valueOf(Optional.ofNullable(record.getVal()).orElse("0")));
             if(Math.abs(water.getWater()) == 0){

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/HydropowerServiceImpl.java

@@ -569,6 +569,7 @@ public class HydropowerServiceImpl implements HydropowerService {
 		WaterLevelVo level = validList.get(0);
 		// 前池水位、当日水位曲线
 		response.setFrontWaterLevel(level.getFrontWaterLevel());
+		response.setFrontCurveMap(level.getFrontCurveMap());
 	}
 
 	/**

hzims-service/operational/src/main/java/com/hnac/hzims/operational/main/service/impl/PhotovoltaicServiceImpl.java

@@ -780,7 +780,13 @@ public class PhotovoltaicServiceImpl implements PhotovoltaicService {
         }
         return list.stream().collect(Collectors.groupingBy(AnalyseDataTaosVO::getTs)).entrySet().stream().map(entry ->{
             PhotovoltaicLoadGenerateVo target = new PhotovoltaicLoadGenerateVo();
-            LocalDateTime time = LocalDateTime.parse(DateUtil.format(DateUtil.parse(entry.getKey(), "yyyy-MM-dd HH:mm:ss.s"),DateUtil.PATTERN_DATETIME), DateUtil.DATETIME_FORMATTER);
+            Date date;
+            if(entry.getKey().contains(".0")){
+                date = DateUtil.parse(entry.getKey(), "yyyy-MM-dd HH:mm:ss.s");
+            }else{
+                date = DateUtil.parse(entry.getKey() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+            }
+            LocalDateTime time = LocalDateTime.parse(DateUtil.format(date,DateUtil.PATTERN_DATETIME), DateUtil.DATETIME_FORMATTER);
             target.setPeriod(String.valueOf(time.getHour()));
             target.setValue((float) entry.getValue().stream().filter(val -> !StringUtil.isEmpty(val.getVal())).mapToDouble(o-> Double.parseDouble(String.valueOf(o.getVal()))).sum());
             return target;

hzims-service/operational/src/main/java/com/hnac/hzims/operational/report/service/impl/RunMonthServiceImpl.java

@@ -721,7 +721,12 @@ public class RunMonthServiceImpl extends ServiceImpl<RunMonthMapper, RunMonthEnt
             }
             analyseDatas.addAll(data.getList().stream().peek(item->{
                 item.setSignage(data.getSignage());
-                Date date = DateUtil.parse(item.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+                Date date;
+                if(item.getTs().contains(".0")){
+                    date = DateUtil.parse(item.getTs(), "yyyy-MM-dd HH:mm:ss.s");
+                }else{
+                    date = DateUtil.parse(item.getTs() + ".0", "yyyy-MM-dd HH:mm:ss.s");
+                }
                 day.setTime(date);
                 item.setTs(String.valueOf(day.get(Calendar.DAY_OF_MONTH)));
             }).collect(Collectors.toList()));