[add] 历史表添加dt分区字段

wj-databus/src/main/java/net/wanji/databus/po/CrossDataHistPO.java

@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
 import io.swagger.annotations.ApiModel;
 import lombok.Data;
 
+import java.util.Date;
+
 /**
  * @author duanruiming
  * @date 2023/03/12 20:49
@@ -12,4 +14,5 @@ import lombok.Data;
 @TableName("t_cross_data_hist")
 @ApiModel(value = "CrossDataHistPO", description = "路口实时数据历史")
 public class CrossDataHistPO extends CrossDataRealtimePO {
+    private Integer dt;
 }

wj-databus/src/main/java/net/wanji/databus/po/CrossDirDataHistPO.java

@@ -12,4 +12,5 @@ import lombok.Data;
 @TableName("t_cross_dir_data_hist")
 @ApiModel(value = "CrossDirDataHistPO", description = "路口转向实时数据历史")
 public class CrossDirDataHistPO extends CrossDirDataRealtimePO {
+    private Integer dt;
 }

wj-databus/src/main/java/net/wanji/databus/po/CrossLaneDataHistPO.java

@@ -12,4 +12,5 @@ import lombok.Data;
 @TableName("t_lane_data_hist")
 @ApiModel(value = "CrossLaneDataHistPO", description = "路口车道实时数据历史")
 public class CrossLaneDataHistPO extends CrossLaneDataRealTimePO{
+    private Integer dt;
 }

wj-databus/src/main/java/net/wanji/databus/po/CrossTurnDataHistPO.java

@@ -12,4 +12,5 @@ import lombok.Data;
 @TableName("t_cross_turn_data_hist")
 @ApiModel(value = "CrossTurnDataHistPO", description = "路口转向实时数据历史")
 public class CrossTurnDataHistPO extends CrossTurnDataRealtimePO {
+    private Integer dt;
 }

wj-databus/src/main/resources/mapper/CrossDataHistMapper.xml

@@ -65,7 +65,7 @@
         no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,non_motor_flow,v_85,
         traffic_flow_A,traffic_flow_B,traffic_flow_C,vehicle_length_ratio_mean,time_occupancy,
         strategy, strategy_duration, optimize_count, optimize_seconds, empty_pass, service_level,
-        direction, turn
+        direction, turn,dt
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossDataHistPO">
@@ -81,7 +81,7 @@
             #{entity.nonMotorFlow},#{entity.v85},#{entity.trafficFlowA},#{entity.trafficFlowB},
              #{entity.trafficFlowC},#{entity.vehicleLengthRatioMean},#{entity.timeOccupancy},
             #{entity.strategy}, #{entity.strategyDuration}, #{entity.optimizeCount}, #{entity.optimizeSeconds},
-            #{entity.emptyPass}, #{entity.serviceLevel}, #{entity.direction}, #{entity.turn}
+            #{entity.emptyPass}, #{entity.serviceLevel}, #{entity.direction}, #{entity.turn}, DATE_FORMAT(#{entity.startTime}, '%Y%m%d')
             )
         </foreach>
     </insert>

wj-databus/src/main/resources/mapper/CrossLaneDataHistMapper.xml

@@ -41,7 +41,8 @@
         id, cross_id, flow, speed, in_speed, out_speed, queue_length, stop_times, delay_time, capacity, sturation,
             vehhead_dist, vehhead_time, quality, batch_time, gmt_create, gmt_modified,
             no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,start_time,effusion_rate,green_light_efficiency,
-            vehicle_nums_ratio_mean,vehicle_length_ratio_mean,time_occupancy,non_motor_flow,v_85,traffic_flow_A,traffic_flow_B,traffic_flow_C
+            vehicle_nums_ratio_mean,vehicle_length_ratio_mean,time_occupancy,non_motor_flow,v_85,
+        traffic_flow_A,traffic_flow_B,traffic_flow_C,dt
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossLaneDataHistPO">
@@ -53,7 +54,8 @@
             #{entity.vehheadDist},#{entity.vehheadTime},#{entity.quality},#{entity.batchTime},#{entity.gmtCreate},#{entity.gmtModified},
             #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.startTime},
             #{entity.effusionRate},#{entity.greenLightEfficiency},#{entity.vehicleNumsRatioMean},#{entity.vehicleLengthRatioMean},#{entity.timeOccupancy},
-            #{entity.nonMotorFlow},#{entity.v85},#{entity.trafficFlowA},#{entity.trafficFlowB},#{entity.trafficFlowC})
+            #{entity.nonMotorFlow},#{entity.v85},#{entity.trafficFlowA},#{entity.trafficFlowB},#{entity.trafficFlowC}, DATE_FORMAT(#{entity.startTime}, '%Y%m%d')
+            )
         </foreach>
     </insert>
 

wj-databus/src/main/resources/mapper/CrossTurnDataHistMapper.xml

@@ -37,7 +37,7 @@
         id, turn_type, in_dir, out_dir, cross_id, flow, status, traffic_index, speed, in_speed, out_speed, queue_length,
         stop_times, delay_time, sturation, vehhead_dist, vehhead_time, quality, batch_time, gmt_create, gmt_modified,
         no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,start_time,
-        green_light_efficiency,effusion_rate
+        green_light_efficiency,effusion_rate,dt
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossTurnDataHistPO">
@@ -50,7 +50,8 @@
             #{entity.queueLength},#{entity.stopTimes},#{entity.delayTime},#{entity.sturation},#{entity.vehheadDist},#{entity.vehheadTime},
             #{entity.quality},#{entity.batchTime},#{entity.gmtCreate},#{entity.gmtModified},
             #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.startTime},
-            #{entity.greenLightEfficiency},#{entity.effusionRate})
+            #{entity.greenLightEfficiency},#{entity.effusionRate}, DATE_FORMAT(#{entity.startTime}, '%Y%m%d')
+            )
         </foreach>
     </insert>