diff --git a/src/main/java/com/ssf/mysqloracletest/domain/PeopleVehicleFlow.java b/src/main/java/com/ssf/mysqloracletest/domain/PeopleVehicleFlow.java index e95e2b3..608105d 100644 --- a/src/main/java/com/ssf/mysqloracletest/domain/PeopleVehicleFlow.java +++ b/src/main/java/com/ssf/mysqloracletest/domain/PeopleVehicleFlow.java @@ -1,25 +1,33 @@ package com.ssf.mysqloracletest.domain; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; import java.io.Serializable; -@TableName(value = "people_vehicle_flow") +@TableName(value = "statistics_user_vehicle_info") @Data public class PeopleVehicleFlow implements Serializable { + /** + * 主键 + */ + @TableId(type = IdType.AUTO) + private Long id; + + /** + * 类别(1:人/2:车) + * */ + private Integer statistic_type; /** * 日期 * */ - private String date; + private String statistic_time; /** * 流量 * */ - private String flow; + private String statistic_count; - /** - * 类别(1:人/2:车) - * */ - private Integer type; } diff --git a/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java b/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java index 4875cad..2a658c4 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/PeopleVehicleFlowTask.java @@ -54,9 +54,9 @@ public class PeopleVehicleFlowTask { queryWrapper.between("passtime", formattedDate,date.plusDays(1).format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"))); int count = tMotorvehicleService.count(queryWrapper); PeopleVehicleFlow peopleVehicleFlow = new PeopleVehicleFlow(); - peopleVehicleFlow.setFlow(String.valueOf(count)); - peopleVehicleFlow.setType(2); - peopleVehicleFlow.setDate(date.toString()); + peopleVehicleFlow.setStatistic_count(String.valueOf(count)); + peopleVehicleFlow.setStatistic_type(2); + peopleVehicleFlow.setStatistic_time(date.toString()); peopleVehicleFlowService.save(peopleVehicleFlow); } } catch (Exception e) {