From a3bd93932db4dbf5ddca54ed8c895e08b28c2f3c Mon Sep 17 00:00:00 2001
From: hanrenchun <hanrenchun>
Date: Wed, 3 Jan 2024 21:03:59 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=BA=E8=BD=A6=E5=BD=93=E6=97=A5=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../task/PeopleVehicleHourFlowTask.java       | 23 ++++++++++---------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleHourFlowTask.java b/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleHourFlowTask.java
index 423ec0c..00e400b 100644
--- a/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleHourFlowTask.java
+++ b/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleHourFlowTask.java
@@ -31,7 +31,7 @@ public class PeopleVehicleHourFlowTask {
     //人车流量业表
     private final PeopleVehicleHourFlowService peopleVehicleHourFlowService;
     DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
-
+    DateTimeFormatter formatter1 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
 
     @Scheduled(initialDelay = 100, fixedDelay = 3000)
     public void setVehicleHourFlowService() {
@@ -50,19 +50,20 @@ public class PeopleVehicleHourFlowTask {
             for (int i = 0; i < 24; i++) {
                 //构造查询条件
                 QueryWrapper<TMotorvehicle> queryWrapper = new QueryWrapper<>();
-                //减去i小时
-                LocalDateTime targetHour = startOfDay.minusHours(i);
-                LocalDateTime time = Hour.minusHours(i);
+                //加i小时
+                LocalDateTime targetHour = startOfDay.plusHours(i);
+                LocalDateTime time = Hour.plusHours(i + 1);
                 //将日期部分格式化为数据库存储格式
                 String formattedDate = targetHour.format(formatter);
+                String format = time.format(formatter1);
 
-                queryWrapper.between("passtime",formattedDate,targetHour.plusHours(1).format(formatter));
+                queryWrapper.between("passtime", formattedDate, targetHour.plusHours(i + 1).format(formatter));
                 int count = tMotorvehicleService.count(queryWrapper);
                 PeopleVehicleHourFlow peopleVehicleHourFlow = new PeopleVehicleHourFlow();
                 peopleVehicleHourFlow.setStatistic_count(String.valueOf(count));
                 peopleVehicleHourFlow.setStatistic_type(2);
-                peopleVehicleHourFlow.setStatistic_time(time.toString());
-                PeopleVehicleHourFlow one = peopleVehicleHourFlowService.lambdaQuery().eq(PeopleVehicleHourFlow::getStatistic_time, time.toString())
+                peopleVehicleHourFlow.setStatistic_time(format);
+                PeopleVehicleHourFlow one = peopleVehicleHourFlowService.lambdaQuery().eq(PeopleVehicleHourFlow::getStatistic_time, format)
                         .eq(PeopleVehicleHourFlow::getStatistic_type, 2).one();
                 if (one == null) {
                     boolean save = peopleVehicleHourFlowService.save(peopleVehicleHourFlow);
@@ -108,14 +109,14 @@ public class PeopleVehicleHourFlowTask {
 //                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
                 String formattedDate = targetHour.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
 
-                queryWrapper.between("capturetime",formattedDate,targetHour.plusHours(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+                queryWrapper.between("capturetime", formattedDate, targetHour.plusHours(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                 int count = tStrhEntityInfoKsService.count(queryWrapper);
                 PeopleVehicleHourFlow peopleVehicleHourFlow = new PeopleVehicleHourFlow();
                 peopleVehicleHourFlow.setStatistic_count(String.valueOf(count));
-                peopleVehicleHourFlow.setStatistic_type(2);
+                peopleVehicleHourFlow.setStatistic_type(1);
                 peopleVehicleHourFlow.setStatistic_time(time.toString());
                 PeopleVehicleHourFlow one = peopleVehicleHourFlowService.lambdaQuery().eq(PeopleVehicleHourFlow::getStatistic_time, time.toString())
-                        .eq(PeopleVehicleHourFlow::getStatistic_type, 2).one();
+                        .eq(PeopleVehicleHourFlow::getStatistic_type, 1).one();
                 if (one == null) {
                     boolean save = peopleVehicleHourFlowService.save(peopleVehicleHourFlow);
                     if (save) {
@@ -124,7 +125,7 @@ public class PeopleVehicleHourFlowTask {
                 } else {
                     UpdateWrapper<PeopleVehicleHourFlow> wrapper = new UpdateWrapper<>();
                     wrapper.eq("statistic_time", time.toString());
-                    wrapper.eq("statistic_type", 2);
+                    wrapper.eq("statistic_type", 1);
                     boolean update = peopleVehicleHourFlowService.update(peopleVehicleHourFlow, wrapper);
                     if (update) {
                         logger.info("Face-" + time + ":更新成功");