diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java index a492db40c..ac4e4d479 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java @@ -564,9 +564,11 @@ public class DayDataServiceImpl implements DayDataService { public void dataToDayHandler(List indexLists, String startTime, String endTime, Integer calType) { log.info(LocalDateTime.now() + "data表转day开始=====》"); Date time = null; + Instant timeInfluxdb = null; SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); try { time = simpleDateFormat.parse(startTime); + timeInfluxdb = time.toInstant(); } catch (ParseException e) { e.printStackTrace(); } @@ -617,6 +619,7 @@ public class DayDataServiceImpl implements DayDataService { DayV dayV = new DayV(); BeanUtils.copyProperties(item, dayV); + dayV.setTime(timeInfluxdb); dayVList.add(dayV); } @@ -636,6 +639,8 @@ public class DayDataServiceImpl implements DayDataService { DayI dayI = new DayI(); BeanUtils.copyProperties(item, dayI); + dayI.setTime(timeInfluxdb); + dayIList.add(dayI); } } @@ -651,6 +656,7 @@ public class DayDataServiceImpl implements DayDataService { DayFlicker dayFlicker = new DayFlicker(); BeanUtils.copyProperties(item, dayFlicker); + dayFlicker.setTime(timeInfluxdb); dayFlickerList.add(dayFlicker); } } @@ -666,6 +672,7 @@ public class DayDataServiceImpl implements DayDataService { DayFluc dayFluc = new DayFluc(); BeanUtils.copyProperties(item, dayFluc); + dayFluc.setTime(timeInfluxdb); dayFlucList.add(dayFluc); } } @@ -681,6 +688,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmPhasicI dayHarmPhasicI = new DayHarmPhasicI(); BeanUtils.copyProperties(item, dayHarmPhasicI); + dayHarmPhasicI.setTime(timeInfluxdb); dayHarmPhasicIList.add(dayHarmPhasicI); } } @@ -696,6 +704,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmPhasicV dayHarmPhasicV = new DayHarmPhasicV(); BeanUtils.copyProperties(item, dayHarmPhasicV); + dayHarmPhasicV.setTime(timeInfluxdb); dayHarmPhasicVList.add(dayHarmPhasicV); } } @@ -711,6 +720,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmPowerP dayHarmPowerP = new DayHarmPowerP(); BeanUtils.copyProperties(item, dayHarmPowerP); + dayHarmPowerP.setTime(timeInfluxdb); dayHarmPowerPList.add(dayHarmPowerP); } } @@ -726,6 +736,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmPowerQ dayHarmPowerQ = new DayHarmPowerQ(); BeanUtils.copyProperties(item, dayHarmPowerQ); + dayHarmPowerQ.setTime(timeInfluxdb); dayHarmPowerQList.add(dayHarmPowerQ); } } @@ -741,6 +752,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmPowerS dayHarmPowerS = new DayHarmPowerS(); BeanUtils.copyProperties(item, dayHarmPowerS); + dayHarmPowerS.setTime(timeInfluxdb); dayHarmPowerSList.add(dayHarmPowerS); } } @@ -756,6 +768,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmRateI dayHarmRateI = new DayHarmRateI(); BeanUtils.copyProperties(item, dayHarmRateI); + dayHarmRateI.setTime(timeInfluxdb); dayHarmRateIList.add(dayHarmRateI); } } @@ -771,6 +784,7 @@ public class DayDataServiceImpl implements DayDataService { DayHarmRateV dayHarmRateV = new DayHarmRateV(); BeanUtils.copyProperties(item, dayHarmRateV); + dayHarmRateV.setTime(timeInfluxdb); dayHarmRateVList.add(dayHarmRateV); } } @@ -786,6 +800,7 @@ public class DayDataServiceImpl implements DayDataService { DayInHarmI dayInHarmI = new DayInHarmI(); BeanUtils.copyProperties(item, dayInHarmI); + dayInHarmI.setTime(timeInfluxdb); dayInHarmIList.add(dayInHarmI); } } @@ -801,6 +816,7 @@ public class DayDataServiceImpl implements DayDataService { DayInHarmV dayInHarmV = new DayInHarmV(); BeanUtils.copyProperties(item, dayInHarmV); + dayInHarmV.setTime(timeInfluxdb); dayInHarmVList.add(dayInHarmV); } } @@ -816,6 +832,7 @@ public class DayDataServiceImpl implements DayDataService { DayPlt dayPlt = new DayPlt(); BeanUtils.copyProperties(item, dayPlt); + dayPlt.setTime(timeInfluxdb); dayPltList.add(dayPlt); } }