Skip to content

T
traffic-signal-platform
Commit dad6662c authored by duanruiming's avatar duanruiming
Browse files
Options

[update] 实时数据历史表

parent 39a8f777
Show whitespace changes
Inline Side-by-side
Showing with 344 additions and 60 deletions
signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossDataHistMapper.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import net.wanji.datacenter.pojo.po.CrossDataHistPO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.Collection;
import java.util.List;
/**
* @author duanruiming
* @date 2023/03/10 20:06
*/
@Mapper
public interface CrossDataHistMapper extends BaseMapper<CrossDataHistPO> {
void insertBatch(@Param("list") List<CrossDataHistPO> list);
void deleteBatch(@Param("list") Collection<String> crossIds);
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossDirDataHistMapper.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import net.wanji.datacenter.pojo.po.CrossDirDataHistPO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.Collection;
import java.util.List;
/**
* @author duanruiming
* @date 2023/03/10 21:09
*/
@Mapper
public interface CrossDirDataHistMapper extends BaseMapper<CrossDirDataHistPO> {
void insertBatch(@Param("list")List<CrossDirDataHistPO> list);
void deleteBatch(@Param("list") Collection<String> crossIds);
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossLaneDataHistMapper.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import net.wanji.datacenter.pojo.po.CrossLaneDataHistPO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.Collection;
import java.util.List;
/**
* @author duanruiming
* @date 2023/03/10 21:11
*/
@Mapper
public interface CrossLaneDataHistMapper extends BaseMapper<CrossLaneDataHistPO> {
void insertBatch(@Param("list") List<CrossLaneDataHistPO> list);
void deleteBatch(@Param("list") Collection<String> crossIds);
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/mapper/CrossTurnDataHistMapper.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import net.wanji.datacenter.pojo.po.CrossTurnDataHistPO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.Collection;
import java.util.List;
/**
* @author duanruiming
* @date 2023/03/10 21:11
*/
@Mapper
public interface CrossTurnDataHistMapper extends BaseMapper<CrossTurnDataHistPO> {
void insertBatch(@Param("list") List<CrossTurnDataHistPO> list);
void deleteBatch(@Param("list") Collection<String> crossIds);
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossDataHistPO.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import lombok.Data;
/**
* @author duanruiming
* @date 2023/03/12 20:49
*/
@Data
@TableName("t_cross_data_hist")
@ApiModel(value = "CrossDataHistPO", description = "路口实时数据历史")
public class CrossDataHistPO extends CrossDataRealTimePO{
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossDirDataHistPO.java
View file @ dad6662c
package net.wanji.datacenter.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* @author hfx
* @date 2023/1/10 16:36
* @desc CrossDataRealtimePO
* @author duanruiming
* @date 2023/03/12 20:51
*/
@Data
@ApiModel(value = "CrossDirDataHistPO", description = "路口转向实时历史数据")
public class CrossDirDataHistPO {
/** 路口方向ID（路口ID_方向_进出口_主辅路序号） */
@ApiModelProperty(name = "路口方向ID（路口ID_方向_进出口_主辅路序号）",notes = "")
private String id ;
/** 路口方向类型：1北；2东北；3东；4东南；5南；6西南；7西；8西北 */
@ApiModelProperty(name = "路口方向类型：1北；2东北；3东；4东南；5南；6西南；7西；8西北",notes = "")
private Integer dirType ;
/** 进出口类型：1进口；2出口 */
@ApiModelProperty(name = "进出口类型：1进口；2出口",notes = "")
private Integer inOutType ;
/** 路口ID */
@ApiModelProperty(name = "路口ID",notes = "")
private String crossId ;
/** 路段长度 */
@ApiModelProperty(name = "路段长度",notes = "")
private Double length ;
/** 交通状态：1畅通；2缓行；3拥堵；4严重拥堵；5未知 */
@ApiModelProperty(name = "交通状态：1畅通；2缓行；3拥堵；4严重拥堵；5未知",notes = "")
private Integer status ;
/** 交通指数 */
@ApiModelProperty(name = "交通指数",notes = "")
private Double trafficIndex ;
@ApiModelProperty(value = "开始时间：yyyy-MM-dd HH:mm:ss",notes = "")
private Date startTime ;
@ApiModelProperty(value = "持续时间（单位：分钟）",notes = "")
private Integer duration ;
/** 交通流量（辆） */
@ApiModelProperty(name = "交通流量（辆）",notes = "")
private Integer flow ;
/** 平均速度（km/h） */
@ApiModelProperty(name = "平均速度（km/h）",notes = "")
private Double speed ;
/** 排队长度（米） */
@ApiModelProperty(name = "排队长度（米）",notes = "")
private Double queueLength ;
/** 停车次数（次） */
@ApiModelProperty(name = "停车次数（次）",notes = "")
private Double stopTimes ;
/** 延误时间（秒） */
@ApiModelProperty(name = "延误时间（秒）",notes = "")
private Integer delayTime ;
/** 饱和度 */
@ApiModelProperty(name = "饱和度",notes = "")
private Double sturation ;
/** 采集时间（10位时间戳） */
@ApiModelProperty(name = "采集时间（10位时间戳）",notes = "")
private Integer batchTime ;
/** 创建时间 */
@ApiModelProperty(name = "创建时间",notes = "")
private Date gmtCreate ;
/** 修改时间 */
@ApiModelProperty(name = "修改时间",notes = "")
private Date gmtModified ;
@TableName("t_cross_dir_data_hist")
@ApiModel(value = "CrossDirDataHistPO", description = "路口转向实时数据历史")
public class CrossDirDataHistPO extends CrossDirDataRealTimePO{
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossLaneDataHistPO.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import lombok.Data;
/**
* @author duanruiming
* @date 2023/03/12 20:53
*/
@Data
@TableName("t_cross_turn_data_hist")
@ApiModel(value = "CrossLaneDataHistPO", description = "路口车道实时数据历史")
public class CrossLaneDataHistPO extends CrossLaneDataRealTimePO{
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/po/CrossTurnDataHistPO.java 0 → 100644
View file @ dad6662c
package net.wanji.datacenter.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import lombok.Data;
/**
* @author duanruiming
* @date 2023/03/12 20:54
*/
@Data
@TableName("t_lane_data_hist")
@ApiModel(value = "CrossTurnDataHistPO", description = "路口转向实时数据历史")
public class CrossTurnDataHistPO extends CrossTurnDataRealTimePO{
}
signal-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/LanePeriodicDataProcessServiceImpl.java
View file @ dad6662c
......@@ -35,6 +35,10 @@ public class LanePeriodicDataProcessServiceImpl implements DataProcessService {
private final CrossTurnDataRealTimeMapper crossTurnDataRealTimeMapper;
private final CrossLaneDataRealTimeMapper crossLaneDataRealTimeMapper;
private final CrossDataRealTimeMapper crossDataRealTimeMapper;
private final CrossLaneDataHistMapper crossLaneDataHistMapper;
private final CrossTurnDataHistMapper crossTurnDataHistMapper;
private final CrossDirDataHistMapper crossDirDataHistMapper;
private final CrossDataHistMapper crossDataHistMapper;
private final LanePeriodicDataEventListConvert lanePeriodicDataEventListConvert;
@Override
......@@ -193,5 +197,10 @@ public class LanePeriodicDataProcessServiceImpl implements DataProcessService {
// 车道数据
// crossLaneDataRealTimeMapper.insertBatch(crossLaneDataRealTimePOS);
// crossDataHistMapper.insertBatch(Arrays.asList(new CrossDataHistPO()));
// crossDirDataHistMapper.insertBatch(Arrays.asList(new CrossDirDataHistPO()));
// crossTurnDataHistMapper.insertBatch(Arrays.asList(new CrossTurnDataHistPO()));
// crossLaneDataHistMapper.insertBatch(Arrays.asList(new CrossLaneDataHistPO()));
}
}
signal-datacenter-service/src/main/resources/mapper/CrossDataHistMapper.xml 0 → 100644
View file @ dad6662c
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="net.wanji.datacenter.mapper.CrossDataHistMapper">
<resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossDataHistPO">
<result column="cross_id" property="crossId"></result>
<result column="status" property="status"></result>
<result column="type" property="type"></result>
<result column="traffic_index" property="trafficIndex"></result>
<result column="start_time" property="startTime"></result>
<result column="duration" property="duration"></result>
<result column="is_unbalance" property="unbalanceStatus"></result>
<result column="is_spillover" property="spilloverStatus"></result>
<result column="is_congestion" property="congestionStatus"></result>
<result column="unbalance_index" property="unbalanceIndex"></result>
<result column="spillover_index" property="spilloverIndex"></result>
<result column="congestion_index" property="congestionIndex"></result>
<result column="unbalance_dirs" property="unbalanceDirs"></result>
<result column="spillover_dirs" property="spilloverDirs"></result>
<result column="congestion_dirs" property="congestionDirs"></result>
<result column="flow" property="flow"></result>
<result column="flow_rate" property="flowRate"></result>
<result column="speed" property="speed"></result>
<result column="queue_length" property="queueLength"></result>
<result column="stop_times" property="stopTimes"></result>
<result column="delay_time" property="delayTime"></result>
<result column="sturation" property="sturation"></result>
<result column="batch_time" property="batchTime"></result>
<result column="gmt_create" property="gmtCreate"></result>
<result column="gmt_modified" property="gmtModified"></result>
</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
</sql>
<insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossDataHistPO">
insert into t_cross_data_hist
(<include refid="Base_Column_List"></include>)
values
<foreach collection="list" item="entity" separator=",">
(#{entity.crossId},#{entity.status},#{entity.type},#{entity.trafficIndex},#{entity.startTime},#{entity.duration},#{entity.unbalanceStatus},#{entity.spilloverStatus},#{entity.congestionIndex},
#{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})
</foreach>
</insert>
<delete id="deleteBatch" parameterType="String">
delete from t_cross_data_hist
where cross_id in
<foreach collection="list" item="crossId" separator=",">
(#{crossId})
</foreach>
</delete>
</mapper>
\ No newline at end of file
signal-datacenter-service/src/main/resources/mapper/CrossDirDataHistMapper.xml 0 → 100644
View file @ dad6662c
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="net.wanji.datacenter.mapper.CrossDirDataHistMapper">
<resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossDirDataHistPO">
<result column="id" property="id"></result>
<result column="dir_type" property="dirType"></result>
<result column="in_out_type" property="inOutType"></result>
<result column="cross_id" property="crossId"></result>
<result column="length" property="length"></result>
<result column="status" property="status"></result>
<result column="traffic_index" property="trafficIndex"></result>
<result column="start_time" property="startTime"></result>
<result column="capacity" property="capacity"></result>
<result column="duration" property="duration"></result>
<result column="flow" property="flow"></result>
<result column="speed" property="speed"></result>
<result column="queue_length" property="queueLength"></result>
<result column="stop_times" property="stopTimes"></result>
<result column="delay_time" property="delayTime"></result>
<result column="sturation" property="sturation"></result>
<result column="batch_time" property="batchTime"></result>
<result column="gmt_create" property="gmtCreate"></result>
<result column="gmt_modified" property="gmtModified"></result>
<result column="effusion_time" property="effusionTime"></result>
</resultMap>
<sql id="Base_Column_List">
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, batch_time, gmt_create, gmt_modified, effusion_time
</sql>
<insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossDirDataHistPO">
insert into t_cross_dir_data_hist
(<include refid="Base_Column_List"></include>)
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} )
</foreach>
</insert>
<delete id="deleteBatch" parameterType="String">
delete from t_cross_dir_data_hist
where cross_id in
<foreach collection="list" item="crossId" separator=",">
(#{crossId})
</foreach>
</delete>
</mapper>
\ No newline at end of file
signal-datacenter-service/src/main/resources/mapper/CrossLaneDataHistMapper.xml 0 → 100644
View file @ dad6662c
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="net.wanji.datacenter.mapper.CrossLaneDataHistMapper">
<resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossLaneDataHistPO">
<result column="id" property="id"></result>
<result column="cross_id" property="crossId"></result>
<result column="flow" property="flow"></result>
<result column="speed" property="speed"></result>
<result column="in_speed" property="inSpeed"></result>
<result column="out_speed" property="outSpeed"></result>
<result column="queue_length" property="queueLength"></result>
<result column="stop_times" property="stopTimes"></result>
<result column="delay_time" property="delayTime"></result>
<result column="capacity" property="capacity"></result>
<result column="sturation" property="sturation"></result>
<result column="vehhead_dist" property="vehheadDist"></result>
<result column="vehhead_time" property="vehheadTime"></result>
<result column="quality" property="quality"></result>
<result column="batch_time" property="batchTime"></result>
<result column="gmt_create" property="gmtCreate"></result>
<result column="gmt_modified" property="gmtModified"></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
</sql>
<insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossLaneDataHistPO">
insert into t_lane_data_hist
(<include refid="Base_Column_List"></include>)
values
<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})
</foreach>
</insert>
<delete id="deleteBatch" parameterType="String">
delete from t_lane_data_hist
where cross_id in
<foreach collection="list" item="crossId" separator=",">
(#{crossId})
</foreach>
</delete>
</mapper>
\ No newline at end of file
signal-datacenter-service/src/main/resources/mapper/CrossTurnDataHistMapper.xml 0 → 100644
View file @ dad6662c
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="net.wanji.datacenter.mapper.CrossTurnDataHistMapper">
<resultMap id="BaseResultMap" type="net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO">
<result column="id" property="id"></result>
<result column="turn_type" property="turnType"></result>
<result column="in_dir" property="inDir"></result>
<result column="out_dir" property="outDir"></result>
<result column="cross_id" property="crossId"></result>
<result column="flow" property="flow"></result>
<result column="status" property="status"></result>
<result column="traffic_index" property="trafficIndex"></result>
<result column="speed" property="speed"></result>
<result column="in_speed" property="inSpeed"></result>
<result column="out_speed" property="outSpeed"></result>
<result column="queue_length" property="queueLength"></result>
<result column="stop_times" property="stopTimes"></result>
<result column="delay_time" property="delayTime"></result>
<result column="sturation" property="sturation"></result>
<result column="vehhead_dist" property="vehheadDist"></result>
<result column="vehhead_time" property="vehheadTime"></result>
<result column="quality" property="quality"></result>
<result column="batch_time" property="batchTime"></result>
<result column="gmt_create" property="gmtCreate"></result>
<result column="gmt_modified" property="gmtModified"></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
</sql>
<insert id="insertBatch" parameterType="net.wanji.datacenter.pojo.po.CrossTurnDataRealTimePO">
insert into t_cross_turn_data_hist
(<include refid="Base_Column_List"></include>)
values
<foreach collection="list" item="entity" separator=",">
(#{entity.id},#{entity.turnType},#{entity.inDir},#{entity.outDir},#{entity.crossId},#{entity.flow},#{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})
</foreach>
</insert>
<delete id="deleteBatch" parameterType="String">
delete from t_cross_turn_data_hist
where cross_id in
<foreach collection="list" item="crossId" separator=",">
(#{crossId})
</foreach>
</delete>
</mapper>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment