From 937f3a3bbf7231e990037a4777b2c778fd8bb7b4 Mon Sep 17 00:00:00 2001 From: Angel <1050374295@qq.com> Date: Wed, 3 Jan 2024 14:35:30 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BA=BA=E6=B5=81=E7=9A=84se?= =?UTF-8?q?t?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../task/PeopleVehicleFlowTask.java | 40 +++++++++++++++---- 1 file changed, 33 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java b/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java index 2a658c4..7210c76 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java @@ -3,20 +3,19 @@ package com.ssf.mysqloracletest.task; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.ssf.mysqloracletest.domain.PeopleVehicleFlow; import com.ssf.mysqloracletest.domain.TMotorvehicle; +import com.ssf.mysqloracletest.domain.TStrhEntityInfoKs; import com.ssf.mysqloracletest.service.PeopleVehicleFlowService; import com.ssf.mysqloracletest.service.TMotorvehicleService; import com.ssf.mysqloracletest.service.TStrhEntityInfoKsService; import com.ssf.mysqloracletest.utils.ConfigParam; import com.ssf.mysqloracletest.utils.StringKit; import lombok.RequiredArgsConstructor; +import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; -import org.slf4j.Logger; -import org.springframework.stereotype.Service; import java.time.LocalDate; -import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; @Component @@ -38,20 +37,18 @@ public class PeopleVehicleFlowTask { try { //获取当前日期 -// LocalDateTime currentDate = LocalDateTime.now();//例如：2023-10-10 00:00:00 -// LocalDateTime startOfDay = currentDate.withHour(0).withMinute(0).withSecond(0); LocalDate localDate = LocalDate.now(); //循环迭代7天 for (int i = 0; i < 7; i++) { //构造查询条件 QueryWrapper queryWrapper = new QueryWrapper<>(); // 减去 i 天并设置查询条件的日期字段 -// LocalDateTime targetDate = currentDate.minusDays(i); + //LocalDateTime targetDate = currentDate.minusDays(i); LocalDate date = localDate.minusDays(i); // 将日期部分格式化为数据库存储格式 String formattedDate = date.format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss")); - queryWrapper.between("passtime", formattedDate,date.plusDays(1).format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"))); + queryWrapper.between("passtime", formattedDate, date.plusDays(1).format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"))); int count = tMotorvehicleService.count(queryWrapper); PeopleVehicleFlow peopleVehicleFlow = new PeopleVehicleFlow(); peopleVehicleFlow.setStatistic_count(String.valueOf(count)); @@ -63,4 +60,33 @@ public class PeopleVehicleFlowTask { logger.info(StringKit.getTrace(e)); } } + + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void setPeopleFlowService() { + if (!"true".equals(ConfigParam.PeopleFlowSwitch)) { + return; + } + + try { + LocalDate localDate = LocalDate.now(); + //循环迭代7天 + for (int i = 0; i < 7; i++) { + //构造查询条件 + QueryWrapper queryWrapper = new QueryWrapper<>(); + // 减去 i 天并设置查询条件的日期字段 + LocalDate date = localDate.minusDays(i); + // 将日期部分格式化为数据库存储格式 + String formattedDate = date.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); + + queryWrapper.between("capturetime", formattedDate, date.plusDays(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); + int count = tStrhEntityInfoKsService.count(queryWrapper); + PeopleVehicleFlow peopleVehicleFlow = new PeopleVehicleFlow(); + peopleVehicleFlow.setStatistic_count(String.valueOf(count)); + peopleVehicleFlow.setStatistic_type(1); + peopleVehicleFlow.setStatistic_time(localDate.toString()); + } + } catch (Exception e) { + logger.info(StringKit.getTrace(e)); + } + } }