From 8f76c0757204879816a3006a799faf291340c2aa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=A8=E6=9C=A8c?= <857448963@qq.com> Date: Thu, 26 Oct 2023 10:22:44 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=86=E9=92=9F=E6=95=B0=E6=8D=AE=E8=BD=AC?= =?UTF-8?q?=E6=97=A5=E6=95=B0=E6=8D=AEbug=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mysql/Impl/line/DayDataServiceImpl.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) 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); } }