[update] 数据实时表添加开始日期

signal-optimize-service/src/main/java/net/wanji/opt/task/DataCenterProcessTask.java

@@ -36,7 +36,7 @@ public class DataCenterProcessTask {
 
     /**
      * @description 收到数据中心kafka中的实时数据插入实时数据表、实时历史表
-     * @param []
+     * @param
      * @return void
      */
 
@@ -91,6 +91,5 @@ public class DataCenterProcessTask {
                 crossLaneDataHistMapper.insertBatch(crossLaneDataHistPOS);
             }
         }
-
     }
 }

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

@@ -24,12 +24,13 @@
         <result column="batch_time" property="batchTime"></result>
         <result column="gmt_create" property="gmtCreate"></result>
         <result column="gmt_modified" property="gmtModified"></result>
+        <result column="start_time" property="startTime"></result>
     </resultMap>
 
     <sql id="Base_Column_List">
         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
+            no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,start_time
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossLaneDataHistPO">
@@ -39,7 +40,7 @@
         <foreach collection="list" item="entity" separator=",">
             (#{entity.id},#{entity.crossId},#{entity.flow},#{entity.speed},#{entity.inSpeed},#{entity.outSpeed},#{entity.queueLength},#{entity.stopTimes},#{entity.delayTime},#{entity.capacity},#{entity.sturation},
             #{entity.vehheadDist},#{entity.vehheadTime},#{entity.quality},#{entity.batchTime},#{entity.gmtCreate},#{entity.gmtModified},
-            #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate})
+            #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.startTime})
         </foreach>
     </insert>
 

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

@@ -24,12 +24,13 @@
         <result column="batch_time" property="batchTime"></result>
         <result column="gmt_create" property="gmtCreate"></result>
         <result column="gmt_modified" property="gmtModified"></result>
+        <result column="start_time" property="startTime"></result>
     </resultMap>
 
     <sql id="Base_Column_List">
         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
+            no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,start_time
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossLaneDataRealTimePO">
@@ -39,7 +40,7 @@
         <foreach collection="list" item="entity" separator=",">
             (#{entity.id},#{entity.crossId},#{entity.flow},#{entity.speed},#{entity.inSpeed},#{entity.outSpeed},#{entity.queueLength},#{entity.stopTimes},#{entity.delayTime},#{entity.capacity},#{entity.sturation},
             #{entity.vehheadDist},#{entity.vehheadTime},#{entity.quality},#{entity.batchTime},#{entity.gmtCreate},#{entity.gmtModified},
-            #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate})
+            #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.startTime})
         </foreach>
     </insert>
 

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

@@ -28,12 +28,13 @@
         <result column="batch_time" property="batchTime"></result>
         <result column="gmt_create" property="gmtCreate"></result>
         <result column="gmt_modified" property="gmtModified"></result>
+        <result column="start_time" property="startTime"></result>
     </resultMap>
 
     <sql id="Base_Column_List">
         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
+        no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,start_time
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossTurnDataRealtimePO">
@@ -45,7 +46,7 @@
             #{entity.status},#{entity.trafficIndex},#{entity.speed},#{entity.inSpeed},#{entity.outSpeed},
             #{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.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.startTime})
         </foreach>
     </insert>
 

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

@@ -28,12 +28,13 @@
         <result column="three_stop_rate" property="threeStopRate"></result>
         <result column="gmt_create" property="gmtCreate"></result>
         <result column="gmt_modified" property="gmtModified"></result>
+        <result column="start_time" property="startTime"></result>
     </resultMap>
 
     <sql id="Base_Column_List">
         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
+            no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,start_time
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossTurnDataRealtimePO">
@@ -45,7 +46,7 @@
              #{entity.status},#{entity.trafficIndex},#{entity.speed},#{entity.inSpeed},#{entity.outSpeed},
              #{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.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.startTime})
         </foreach>
     </insert>