获取大屏参数

oddlove · oddlove · commit 13bede60a799 · 2024-11-22T16:05:14.000+08:00
diff --git a/ruoyi-simulation/src/main/java/com/ruoyi/simulation/config/TrafficIndirectionListener.java b/ruoyi-simulation/src/main/java/com/ruoyi/simulation/config/TrafficIndirectionListener.java
@@ -2,8 +2,11 @@
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.simulation.call.CallUE4Engine;
+import com.ruoyi.simulation.dao.JunctionMapper;
+import com.ruoyi.simulation.dao.RoadMapper;
 import com.ruoyi.simulation.dao.SpeedMapper;
 import com.ruoyi.simulation.domain.Junction;
 import com.ruoyi.simulation.domain.Road;
@@ -35,21 +38,25 @@ public class TrafficIndirectionListener implements ApplicationListener<Applicati
     public RedisTemplate<String,String> redisTemplate;
     @Resource
     public SpeedMapper speedMapper;
+    @Resource
+    public RoadMapper roadMapper;
+    @Resource
+    public JunctionMapper junctionMapper;
     //每天定时获取历史平均速度
     private Map<String,Double> speedMap = new HashMap<>();
     //一天内的平均速度
     private Map<String, List<Double>> daySpeedMap = new HashMap<>();
     private Map<String, Double> hourSpeedMap = new HashMap<>();
     private Map<String, Double> indirectionTrendMap = new HashMap<>();
-    private Map<String, Double> mileageTrendMap = new HashMap<>();
+    private Map<Integer, Double> mileageTrendMap = new HashMap<>();
     private Map<String, Double> trafficTrendMap = new HashMap<>();
     private int acquiredCount = 0;
     private List<Road> roadList = new ArrayList<>();
     private List<Junction> junctionList = new ArrayList<>();
     @Override
     public void onApplicationEvent(ApplicationStartedEvent e) {
         executionIndirectionScript();
-        getJunctionRoad();
+        getMapBasicData();
         new Thread(new Runnable() {
             @Override
             public void run() {
@@ -71,17 +78,28 @@ private void executionIndirectionScript(){
         //获得总拥堵里程
         this.callUE4Engine.getTrafficIndirection("congestion_mileage.py");
         //获得不同道路的拥堵里程
-        this.callUE4Engine.getTrafficIndirection("road_congestion_mileage.py");
+        this.callUE4Engine.getTrafficIndirection("junction_congestion_mileage.py");
         //获得服务车次
         this.callUE4Engine.getTrafficIndirection("serviced_vehicle.py");
         //获得路网车辆
         this.callUE4Engine.getTrafficIndirection("total_vehicle.py");
     }
 
     /**
-     * 获取道路及路口的字典信息
+     * 获取道路及路口的地图基础数据信息
      */
-    private void getJunctionRoad(){
+    private void getMapBasicData(){
+        this.roadList = this.roadMapper.selectList(new QueryWrapper<>());
+        Map<Integer,Integer> roadMap = new HashMap<>();
+        //设置carla中roadId与道路主键之间的对应关系
+        for(Road road: this.roadList){
+            List<String> relatedList = Arrays.asList(road.getRelatedRoadId().split(","));
+            for(String related: relatedList){
+                roadMap.put(Integer.parseInt(related), road.getRoadId());
+            }
+        }
+        this.redisTemplate.opsForValue().set("roadMap", JSON.toJSONString(roadMap));
+        this.junctionList = this.junctionMapper.selectList(new QueryWrapper<>());
     }
     /**
      * 每天零点整执行读取数据和写入数据的操作
@@ -125,6 +143,8 @@ public void getRedisIndirection(){
                 LoggerUtil.printLoggerStace(e);
             }
             Map<String,Object> indirectionMap = new HashMap<>();
+            //设置交通趋势变化数据
+            this.setTrafficTrend();
             //获取实时的平均车速
             double averageSpeed = this.getAverageSpeed();
             indirectionMap.put("averageSpeed", averageSpeed);
@@ -139,13 +159,11 @@ public void getRedisIndirection(){
             double congestionMileage = this.getCongestionMileage();
             indirectionMap.put("congestionMileage", congestionMileage);
             //获取不同路口的拥堵里程
-            this.setJunctionCongestionMileage(indirectionMap);
+            this.setJunctionIndirection(indirectionMap);
             //获取服务车次
             this.setServicedVehicle(indirectionMap);
             //获取路网车辆
             this.setTotalVehicle(indirectionMap);
-            //设置交通趋势变化数据
-            this.setTrafficTrend();
             for(String sessionId: WebSocketServer.webSocketMap.keySet()){
                 SendResponseUtil.sendIndirectionResponse(indirectionMap, sessionId);
             }
@@ -199,6 +217,13 @@ public void setRoadAverageSpeed(String roadId, double averageSpeed) {
                 road.setAverageSpeed(averageSpeed);
                 double congestionIndirection = speedMap.get(roadId)/averageSpeed;
                 road.setCongestionIndirection(congestionIndirection);
+                double trend = indirectionTrendMap.get(roadId);
+                //计算拥堵指数趋势变化
+                double trendRate = 1d;
+                if(trend!=0){
+                    trendRate = (congestionIndirection-trend)/trend;
+                }
+                road.setCongestionIndirectionTrend(trendRate);
             }
         }.getRoadAverageSpeed();
         indirectionMap.put("roadIndirection", this.roadList);
@@ -234,10 +259,10 @@ public double getCongestionMileage(){
      * 设置不同路口的拥堵里程
      * @param indirectionMap
      */
-    public void setJunctionCongestionMileage(Map<String,Object> indirectionMap){
-        Map<String, Junction> junctionMap = new HashMap<>();
+    public void setJunctionIndirection(Map<String,Object> indirectionMap){
+        Map<Integer, Junction> junctionMap = new HashMap<>();
         for(Junction junction: this.junctionList){
-            junctionMap.put(String.valueOf(junction.getJunctionRoadId()), junction);
+            junctionMap.put(junction.getTrafficLightId(), junction);
             //初始化所有的道路拥堵里程
             junction.setCongestionMileage(0d);
             //初始化拥堵里程趋势变化
@@ -246,10 +271,17 @@ public void setJunctionCongestionMileage(Map<String,Object> indirectionMap){
         //保存不同路口拥堵里程数据
         new ParseJunctionIndirection(){
             @Override
-            protected void setJunctionCongestionMileage(String junctionRoadId, double congestionMileage) {
-                Junction junction = junctionMap.get(junctionRoadId);
+            protected void setJunctionCongestionMileage(int trafficLightId, double congestionMileage) {
+                Junction junction = junctionMap.get(trafficLightId);
                 //设置拥堵里程
                 junction.setCongestionMileage(congestionMileage);
+                double trend = mileageTrendMap.get(trafficLightId);
+                //计算拥堵里程趋势变化
+                double trendRate = 1d;
+                if(trend!=0){
+                    trendRate = (congestionMileage-trend)/trend;
+                }
+                junction.setCongestionMileageTrend(trendRate);
             }
         }.getJunctionCongestionMileage();
         indirectionMap.put("junctionCongestionMileage", junctionList);
@@ -265,7 +297,7 @@ private void setTrafficTrend(){
                 this.indirectionTrendMap.put(String.valueOf(road.getRoadId()), 1d);
             }
             for(Junction junction: this.junctionList){
-                this.mileageTrendMap.put(String.valueOf(junction.getJunctionRoadId()), 0d);
+                this.mileageTrendMap.put(junction.getTrafficLightId(), 0d);
             }
             //保存不同道路的拥堵指数变化趋势
             new ParseRoadIndirection(){
@@ -281,11 +313,10 @@ public void setRoadAverageSpeed(String roadId, double averageSpeed) {
             //保存不同路口的拥堵里程变化趋势
             new ParseJunctionIndirection(){
                 @Override
-                public void setJunctionCongestionMileage(String junctionRoadId, double congestionMileage) {
-                    mileageTrendMap.put(junctionRoadId, congestionMileage);
+                public void setJunctionCongestionMileage(int trafficLightId, double congestionMileage) {
+                    mileageTrendMap.put(trafficLightId, congestionMileage);
                 }
             }.getJunctionCongestionMileage();
-
             //保存平均延误时间变化趋势
             trafficTrendMap.put("averageDelay", this.getAverageDelay());
             //保存总拥堵里程变化趋势
@@ -392,18 +423,20 @@ public void getJunctionCongestionMileage(){
             String roadCongestionMileageStr = redisTemplate.opsForValue().get("road_congestion_mileage");
             if(!StringUtils.isEmpty(roadCongestionMileageStr)) {
                 JSONObject jsonObject = JSON.parseObject(roadCongestionMileageStr);
-                for (String junctionRoadId : jsonObject.keySet()) {
+                for (String identity : jsonObject.keySet()) {
+                    int trafficLightId = Integer.parseInt(identity.split("_")[0]);
+                    System.out.println(identity);
                     //获取不同路口的拥堵里程
-                    double congestionMileage = Double.valueOf(String.valueOf(jsonObject.get(junctionRoadId)));
-                    this.setJunctionCongestionMileage(junctionRoadId, congestionMileage);
+                    double congestionMileage = Double.valueOf(String.valueOf(jsonObject.get(identity)));
+                    this.setJunctionCongestionMileage(trafficLightId, congestionMileage);
                 }
             }
         }
         /**
          * 设置实时拥堵里程数据
-         * @param junctionRoadId
+         * @param trafficLightId
          * @param congestionMileage
          */
-        protected abstract void setJunctionCongestionMileage(String junctionRoadId, double congestionMileage);
+        protected abstract void setJunctionCongestionMileage(int trafficLightId, double congestionMileage);
     }
 }
diff --git a/ruoyi-simulation/src/main/java/com/ruoyi/simulation/dao/JunctionMapper.java b/ruoyi-simulation/src/main/java/com/ruoyi/simulation/dao/JunctionMapper.java
@@ -1,10 +1,11 @@
 package com.ruoyi.simulation.dao;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.simulation.domain.Junction;
 import com.ruoyi.simulation.domain.Speed;
 
 /**
  * 路口信息数据库访问层
  */
-public interface JunctionMapper  extends BaseMapper<Speed> {
+public interface JunctionMapper  extends BaseMapper<Junction> {
 }
diff --git a/ruoyi-simulation/src/main/java/com/ruoyi/simulation/dao/RoadMapper.java b/ruoyi-simulation/src/main/java/com/ruoyi/simulation/dao/RoadMapper.java
@@ -1,10 +1,11 @@
 package com.ruoyi.simulation.dao;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.simulation.domain.Road;
 import com.ruoyi.simulation.domain.Speed;
 
 /**
  * 道路信息数据访问层
  */
-public interface RoadMapper extends BaseMapper<Speed> {
+public interface RoadMapper extends BaseMapper<Road> {
 }
diff --git a/ruoyi-simulation/src/main/java/com/ruoyi/simulation/domain/Junction.java b/ruoyi-simulation/src/main/java/com/ruoyi/simulation/domain/Junction.java
@@ -1,20 +1,28 @@
 package com.ruoyi.simulation.domain;
 
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonIgnore;
 import lombok.Data;
 
 /**
  * 路口指标信息实体类
  */
 @Data
+@TableName("simulation_junction")
 public class Junction {
     /**
      * 路口方向id
      */
-    private Integer junctionRoadId;
+    private Integer junctionId;
     /**
      * 路口方向名称
      */
-    private String junctionRoadName;
+    private String junctionName;
+    /**
+     * 交通灯id
+     */
+    @JsonIgnore
+    private Integer trafficLightId;
     /**
      * 拥堵里程
      */
@@ -23,36 +31,4 @@ public class Junction {
      * 拥堵里程趋势变化
      */
     private Double congestionMileageTrend;
-
-    public Integer getJunctionRoadId() {
-        return junctionRoadId;
-    }
-
-    public void setJunctionRoadId(Integer junctionRoadId) {
-        this.junctionRoadId = junctionRoadId;
-    }
-
-    public String getJunctionRoadName() {
-        return junctionRoadName;
-    }
-
-    public void setJunctionRoadName(String junctionRoadName) {
-        this.junctionRoadName = junctionRoadName;
-    }
-
-    public Double getCongestionMileage() {
-        return congestionMileage;
-    }
-
-    public void setCongestionMileage(Double congestionMileage) {
-        this.congestionMileage = congestionMileage;
-    }
-
-    public Double getCongestionMileageTrend() {
-        return congestionMileageTrend;
-    }
-
-    public void setCongestionMileageTrend(Double congestionMileageTrend) {
-        this.congestionMileageTrend = congestionMileageTrend;
-    }
 }
diff --git a/ruoyi-simulation/src/main/java/com/ruoyi/simulation/domain/Road.java b/ruoyi-simulation/src/main/java/com/ruoyi/simulation/domain/Road.java
@@ -1,12 +1,14 @@
 package com.ruoyi.simulation.domain;
 
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonIgnore;
 import lombok.Data;
 
 /**
  * 道路指标信息实体类
  */
 @Data
+@TableName("simulation_road")
 public class Road {
     /**
      * 道路id
@@ -16,6 +18,11 @@ public class Road {
      * 道路名称
      */
     private String roadName;
+    /**
+     * 地图中相关联的roadId
+     */
+    @JsonIgnore
+    private String relatedRoadId;
     /**
      * 平均速度
      */
diff --git a/ruoyi-simulation/src/main/java/com/ruoyi/simulation/domain/SignalControl.java b/ruoyi-simulation/src/main/java/com/ruoyi/simulation/domain/SignalControl.java
@@ -0,0 +1,74 @@
+package com.ruoyi.simulation.domain;
+
+import lombok.Data;
+
+import java.sql.Timestamp;
+import java.util.Date;
+
+/**
+ * 信号控制信息实体类
+ */
+@Data
+public class SignalControl {
+    /**
+     * 用于区分不同的路口(如序号1表示尖山路-望青路)
+     */
+    private String intersectionId;
+    private String intersectionName;
+    /**
+     * 用于区分同一路口的不同红绿灯控制方案(如1表示方案1，2表示方案2)
+     */
+    private Integer schemeId;
+    /**
+     * 周期ID，用于标识一个完整的周期(现在用1表示，以后可拓展)。
+     */
+    private Integer cycleId;
+    /**
+     * 车辆大方向阶段，以车辆在路口开始行驶方向为准划分，分为"North-South"和"East-West"(表示车辆开始时的南北走向和东西走向)，North-South(B)后面括号加了(B)标识的时非机动车道。
+     */
+    private String Direction;
+    /**
+     * 一个红绿灯周期又四个阶段变化，分别用1、2、3、4代替
+     */
+    private Integer DirectionPhase;
+    /**
+     * 起始方向（如 "South"）
+     */
+    private String FromDirection;
+    /**
+     * 目的方向（如 "East"） (起始方向和目的方向就决定了车辆形式的方向)
+     */
+    private String ToDirection;
+    /**
+     * 机动车道信号灯状态，表示该方向阶段内的绿灯、黄灯、红灯变化。
+     */
+    private String LightStatus;
+    /**
+     * 每个阶段的开始时间。
+     */
+    private Timestamp StartTime;
+    /**
+     * 每个阶段的结束时间。
+     */
+    private Timestamp EndTime;
+    /**
+     * 机动车道的阶段持续时间（以秒为单位）
+     */
+    private Long Duration;
+    /**
+     * 表示南北方向人行道的信号灯状态
+     */
+    private String PedestrianNSLightStatus;
+    /**
+     * 表示南北方向人行道的信号灯持续时间
+     */
+    private Long PedestrianNSDuration;
+    /**
+     * 表示东西方向人行道的信号灯状态及其持续时间。
+     */
+    private String PedestrianEWLightStatus;
+    /**
+     * 表示东西方向人行道的信号灯持续时间。
+     */
+    private Long PedestrianEWDuration;
+}
diff --git a/ruoyi-system/pom.xml b/ruoyi-system/pom.xml
@@ -14,7 +14,6 @@
     </description>
 
     <dependencies>
-
         <!-- 通用工具-->
         <dependency>
             <groupId>com.ruoyi</groupId>
