1.调度系统加入进出场私自绕改道提示

王通
1 parent 530d9354
Showing 8 changed files with 155 additions and 1 deletions
src/main/java/com/bsth/data/BasicData.java
src/main/java/com/bsth/message/entity/InoutPark.java
src/main/java/com/bsth/message/handler/MessageHandler.java
src/main/java/com/bsth/websocket/handler/SendUtils.java
src/main/resources/static/real_control_v2/js/platform/inoutPark.js
src/main/resources/static/real_control_v2/js/safe_driv/safeDriv.js
src/main/resources/static/real_control_v2/js/websocket/sch_websocket.js
src/main/resources/static/real_control_v2/main.html
@@ -73,6 +73,9 @@ public class BasicData {
     //线路编码和名称对照
     public static Map<String, String> lineCode2NameMap;
+    //名称和线路编码对照
+    public static Map<String, String> lineName2CodeMap;
+
     public static Map<String, String> lineCodeAllNameMap;
     //停车场
     public static List<String> parkCodeList;
@@ -331,6 +334,7 @@ public class BasicData {
             Line line;
             BiMap<Integer, String> biMap = HashBiMap.create();
             Map<String, String> code2name = new HashMap<>();
+            Map<String, String> name2code = new HashMap<>();
             Map<Integer, String> id2SHcode = new HashMap<Integer, String>();
             Map<String, String> code2SHcode = new HashMap<String, String>();
             Map<String, Integer> tempStationName2YgcNumber = new HashMap<String, Integer>();
@@ -364,6 +368,7 @@ public class BasicData {
                 line = iterator.next();
                 biMap.put(line.getId(), line.getLineCode());
                 code2name.put(line.getLineCode(), line.getName());
+                name2code.put(line.getName(), line.getLineCode());
                 id2SHcode.put(line.getId(), line.getShanghaiLinecode());
                 code2SHcode.put(line.getLineCode(), line.getShanghaiLinecode());
             }
@@ -374,6 +379,7 @@ public class BasicData {
             lineId2CodeMap = biMap;
             lineCode2NameMap = code2name;
+            lineName2CodeMap = name2code;
             lineId2ShangHaiCodeMap = id2SHcode;
             lineCode2ShangHaiCodeMap = code2SHcode;
             stationName2YgcNumber = tempStationName2YgcNumber;
+package com.bsth.message.entity;
+
+import com.bsth.data.BasicData;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+/**
+ * @author Hill
+ */
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class InoutPark {
+
+    /**
+     * 线路名
+     */
+    private String line;
+
+    /**
+     * 线路代码
+     */
+    private String lineId;
+
+    /**
+     * 车辆编码
+     */
+    private String nbbm;
+
+    /**
+     * 发现时间(或发车时间)
+     */
+    private String findTime;
+
+    /**
+     * 进场/出场(绕改道)
+     */
+    private String errType;
+
+    public String getLine() {
+        return line;
+    }
+
+    public void setLine(String line) {
+        this.line = line;
+        this.lineId = BasicData.lineName2CodeMap.get(line);
+    }
+
+    public String getLineId() {
+        return lineId;
+    }
+
+    public String getNbbm() {
+        return nbbm;
+    }
+
+    public void setNbbm(String nbbm) {
+        this.nbbm = nbbm;
+    }
+
+    public String getFindTime() {
+        return findTime;
+    }
+
+    public void setFindTime(String findTime) {
+        this.findTime = findTime;
+    }
+
+    public String getErrType() {
+        return errType;
+    }
+
+    public void setErrType(String errType) {
+        this.errType = errType;
+    }
+}
@@ -3,6 +3,7 @@ package com.bsth.message.handler;
 import com.bsth.message.buffer.CarEnergyBuffer;
 import com.bsth.message.entity.CarEnergy;
 import com.bsth.message.entity.CarErrorStop;
+import com.bsth.message.entity.InoutPark;
 import com.bsth.websocket.handler.SendUtils;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -50,4 +51,16 @@ public class MessageHandler {
             e.printStackTrace();
         }
     }
+
+    @KafkaListener(topics="schedule-mainsys-inoutpark")
+    public void receivedInoutPark(Message<String> message) {
+        try {
+            List<InoutPark> inoutParkList = mapper.readValue(message.getPayload(), mapper.getTypeFactory().constructParametricType(List.class, InoutPark.class));
+            for (InoutPark inoutPark : inoutParkList) {
+                sendUtils.sendInoutPark(inoutPark);
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
 }
@@ -9,6 +9,7 @@ import com.bsth.data.safe_driv.SafeDriv;
 import com.bsth.entity.directive.D80;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import com.bsth.message.entity.CarErrorStop;
+import com.bsth.message.entity.InoutPark;
 import com.bsth.websocket.dto.WsScheduleRealInfo;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -287,4 +288,22 @@ public class SendUtils{
 			logger.error("sendCarErrorStop", e);
 		}
 	}
+
+	/**
+	 * 将车辆进出场私自绕改道发送至线调页面
+	 */
+	public void sendInoutPark(InoutPark inoutPark) {
+		Map<String, Object> map = new HashMap<>();
+		map.put("fn", "inoutPark");
+		map.put("data", inoutPark);
+		ObjectMapper mapper = new ObjectMapper();
+
+		try {
+			if (inoutPark.getLineId() != null) {
+				socketHandler.sendMessageToLine(inoutPark.getLineId(), mapper.writeValueAsString(map));
+			}
+		} catch (JsonProcessingException e) {
+			logger.error("sendInoutPark", e);
+		}
+	}
 }
+/**
+ * 车辆异常停车相关
+ */
+var gb_inoutpark = (function () {
+    var $wrap = $('.multi_plat_msg_pop_wrap');
+    var max = 5;
+
+    var pop = function (data) {
+        //时间格式化
+        data.type = 'inoutpark';
+
+        var htmlStr = template('inoutpark_plat_msg_template', data);
+        var items = $wrap.find('.multi_plat_msg_pop'), len = items.length;
+        if (len >= max)
+            $wrap.find('.multi_plat_msg_pop:lt(' + (len - max) + ')').remove();
+
+        $wrap.append(htmlStr);
+    };
+
+    return {
+        pop: pop
+    }
+})();
 \ No newline at end of file
@@ -100,6 +100,10 @@ var gb_safe_driv = (function () {
                     gb_map_play_back.setParam(data);
                 }
                 break;
+            // 运管中心进出场绕改道
+            case 'inoutpark':
+                $(this).remove();
+                break;
             default:
                 break;
         }
@@ -204,6 +204,10 @@ var gb_sch_websocket = (function () {
         gb_carerrorstop.pop(msg.data);
     };
+    var inoutPark = function (msg) {
+        gb_inoutpark.pop(msg.data);
+    }
+
     var msgHandle = {
         report80: report80,
         faChe: faChe,
@@ -218,7 +222,8 @@ var gb_sch_websocket = (function () {
         rfid: refreshRfid,
         contingencyPlan: contingencyPlan,
         maintenancePlan: maintenancePlan,
-        carErrorStop: carErrorStop
+        carErrorStop: carErrorStop,
+        inoutPark: inoutPark
     };
     function currentSecond() {
@@ -266,11 +266,22 @@
         </div>
     </div>
 </script>
+<script id="inoutpark_plat_msg_template" type="text/html">
+    <div class="multi_plat_msg_pop uk-animation-slide-bottom" style="background-color: #FF7F24;" data-type="{{type}}" data-zbh="{{nbbm}}">
+        <div>
+            <span class="title">{{errType}}私自绕改道</span>
+            <br/>
+            <span class="text"> {{line}}&nbsp;{{nbbm}}&nbsp;&nbsp;在&nbsp;{{findTime}}&nbsp;{{errType}}私自绕改道，<br/>请到运管中心处理</span>
+            <span class="desc" style="color: #ffffff">--浦东公交运管中心管理系统</span>
+        </div>
+    </div>
+</script>
 <script src="/real_control_v2/js/safe_driv/safeDriv.js"  merge="custom_js"></script>
 <script src="/real_control_v2/js/con_plan/conPlan.js"  merge="custom_js"></script>
 <script src="/real_control_v2/js/mt_plan/mtPlan.js"  merge="custom_js"></script>
 <script src="/real_control_v2/js/platform/carErrorStop.js"  merge="custom_js"></script>
+<script src="/real_control_v2/js/platform/inoutPark.js"  merge="custom_js"></script>
 <!-- #### 安全驾驶 end ###  -->
 <!-- 打电话 -->