[update] 优化数据库表字段

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

@@ -40,6 +40,9 @@ public class CrossDataRealtimePO {
      */
     @ApiModelProperty(value = "开始时间：yyyy-MM-dd HH:mm:ss", notes = "")
     private Date startTime;
+
+    @ApiModelProperty(value = "结束时间：yyyy-MM-dd HH:mm:ss", notes = "")
+    private Date endTime;
     @ApiModelProperty(value = "持续时间（单位：分钟）", notes = "")
     private Integer duration;
     /**

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

@@ -8,6 +8,7 @@
         <result column="type" property="type"></result>
         <result column="traffic_index" property="trafficIndex"></result>
         <result column="start_time" property="startTime"></result>
+        <result column="end_time" property="endTime"></result>
         <result column="duration" property="duration"></result>
         <result column="is_unbalance" property="isUnbalance"></result>
         <result column="is_spillover" property="isSpillover"></result>
@@ -32,7 +33,7 @@
     </resultMap>
 
     <sql id="Base_Column_List">
-        cross_id,status,type,traffic_index,start_time,duration,is_unbalance,is_spillover,is_congestion,unbalance_index,spillover_index,congestion_index,unbalance_dirs,spillover_dirs,congestion_dirs,flow,flow_rate,speed,queue_length,stop_times,delay_time,sturation,batch_time,gmt_create,gmt_modified,clear_rate
+        cross_id,status,type,traffic_index,start_time,duration,is_unbalance,is_spillover,is_congestion,unbalance_index,spillover_index,congestion_index,unbalance_dirs,spillover_dirs,congestion_dirs,flow,flow_rate,speed,queue_length,stop_times,delay_time,sturation,batch_time,gmt_create,gmt_modified,clear_rate,end_time
     </sql>
 
     <insert id="insertBatch" parameterType="net.wanji.databus.po.CrossDataRealtimePO">
@@ -43,7 +44,7 @@
             (#{entity.crossId},#{entity.status},#{entity.type},#{entity.trafficIndex},#{entity.startTime},#{entity.duration},#{entity.isSpillover},#{entity.isSpillover},#{entity.isCongestion},
             #{entity.unbalanceIndex},#{entity.spilloverIndex},#{entity.congestionIndex},#{entity.unbalanceDirs},#{entity.spilloverDirs},#{entity.congestionDirs},
             #{entity.flow},#{entity.flowRate},#{entity.speed},#{entity.queueLength},#{entity.stopTimes},#{entity.delayTime},#{entity.sturation},#{entity.batchTime},#{entity.gmtCreate},#{entity.gmtModified},
-             #{entity.clearRate})
+             #{entity.clearRate},#{entity.endTime})
         </foreach>
     </insert>
 

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

@@ -19,6 +19,10 @@
         <result column="stop_times" property="stopTimes"></result>
         <result column="delay_time" property="delayTime"></result>
         <result column="sturation" property="sturation"></result>
+        <result column="no_stop_rate" property="noStopRate"></result>
+        <result column="one_stop_rate" property="oneStopRate"></result>
+        <result column="two_stop_rate" property="twoStopRate"></result>
+        <result column="three_stop_rate" property="threeStopRate"></result>
         <result column="batch_time" property="batchTime"></result>
         <result column="gmt_create" property="gmtCreate"></result>
         <result column="gmt_modified" property="gmtModified"></result>
@@ -26,7 +30,7 @@
     </resultMap>
 
     <sql id="Base_Column_List">
-        id,dir_type,in_out_type,cross_id,length,status,traffic_index,start_time,capacity,flow,speed,queue_length,stop_times,
+        id,dir_type,in_out_type,cross_id,length,status,traffic_index,start_time,capacity,duration, flow,speed,queue_length,stop_times,
         delay_time,sturation,no_stop_rate,one_stop_rate,two_stop_rate,three_stop_rate,batch_time,gmt_create,gmt_modified,effusion_time
     </sql>
 
@@ -36,7 +40,9 @@
         values
         <foreach collection="list" item="entity" separator=",">
             ( #{entity.id}, #{entity.dirType}, #{entity.inOutType}, #{entity.crossId}, #{entity.length}, #{entity.status}, #{entity.trafficIndex}, #{entity.startTime}, #{entity.capacity}, #{entity.duration}, #{entity.flow},
-            #{entity.speed}, #{entity.queueLength}, #{entity.stopTimes}, #{entity.delayTime}, #{entity.sturation}, #{entity.batchTime}, #{entity.gmtCreate}, #{entity.gmtModified}, #{entity.effusionTime} )
+            #{entity.speed}, #{entity.queueLength}, #{entity.stopTimes}, #{entity.delayTime}, #{entity.sturation},
+            #{entity.noStopRate},#{entity.oneStopRate},#{entity.twoStopRate},#{entity.threeStopRate},#{entity.batchTime},
+             #{entity.gmtCreate}, #{entity.gmtModified}, #{entity.effusionTime} )
         </foreach>
     </insert>