update...

潘钊
1 parent 9bf1aabc
Showing 10 changed files with 429 additions and 9 deletions
src/main/java/com/bsth/data/safe_driv/SafeDriv.java
src/main/java/com/bsth/data/safe_driv/SafeDrivCenter.java
src/main/java/com/bsth/data/safe_driv/SafeDrivDataLoadThread.java
src/main/java/com/bsth/websocket/handler/RealControlSocketHandler.java
src/main/java/com/bsth/websocket/handler/SendUtils.java
src/main/resources/static/real_control_v2/css/main.css
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
src/main/resources/static/real_control_v2/mapmonitor/js/playback.js
+package com.bsth.data.safe_driv;
+
+/**
+ * 安全驾驶
+ * Created by panzhao on 2017/4/6.
+ */
+public class SafeDriv {
+
+    /**
+     * 时间
+     * 2017-04-06 08:00:00.0
+     */
+    private String Startime;
+
+    /**
+     * 时间戳
+     */
+    private Long ts;
+
+    /**
+     * 设备编号
+     */
+    private String sbbh;
+
+    /**
+     * 线路名称
+     */
+    private String xlmc;
+
+    /**
+     * 车辆自编号
+     */
+    private String clzbh;
+
+    /**
+     * 车牌号
+     */
+    private String cph;
+
+    /**
+     * 检查属性
+     * 双脱手 0 单脱手 1 其他为0都是异常
+     */
+    private String jctype;
+
+    /**
+     * 异常种类
+     * 手部检测: 1
+     * 脸部检测: 5
+     * 摄像头检测: 2
+     * 安全带检测: 3
+     * 袖章检测: 4
+     */
+    private String yczltype;
+
+    @Override
+    public int hashCode() {
+        return ("safe_" + (this.getClzbh() + this.getStartime())).hashCode();
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        SafeDriv s2 = (SafeDriv)obj;
+        return (this.getClzbh() + this.getStartime()).equals(s2.getClzbh() + s2.getStartime());
+    }
+
+    public String getStartime() {
+        return Startime;
+    }
+
+    public void setStartime(String startime) {
+        Startime = startime;
+    }
+
+    public String getSbbh() {
+        return sbbh;
+    }
+
+    public void setSbbh(String sbbh) {
+        this.sbbh = sbbh;
+    }
+
+    public String getXlmc() {
+        return xlmc;
+    }
+
+    public void setXlmc(String xlmc) {
+        this.xlmc = xlmc;
+    }
+
+    public String getClzbh() {
+        return clzbh;
+    }
+
+    public void setClzbh(String clzbh) {
+        this.clzbh = clzbh;
+    }
+
+    public String getCph() {
+        return cph;
+    }
+
+    public void setCph(String cph) {
+        this.cph = cph;
+    }
+
+    public String getJctype() {
+        return jctype;
+    }
+
+    public void setJctype(String jctype) {
+        this.jctype = jctype;
+    }
+
+    public String getYczltype() {
+        return yczltype;
+    }
+
+    public void setYczltype(String yczltype) {
+        this.yczltype = yczltype;
+    }
+
+    public Long getTs() {
+        return ts;
+    }
+
+    public void setTs(Long ts) {
+        this.ts = ts;
+    }
+}
+package com.bsth.data.safe_driv;
+
+import com.bsth.Application;
+import com.bsth.websocket.handler.SendUtils;
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 安全驾驶
+ * Created by panzhao on 2017/4/6.
+ */
+@Component
+public class SafeDrivCenter implements CommandLineRunner,ApplicationContextAware {
+
+    private static Set<SafeDriv> data;
+
+    @Autowired
+    SafeDrivDataLoadThread safeDrivDataLoadThread;
+
+    static SendUtils sendUtils;
+
+    /**
+     * 车辆自编号 和 最新一条数据对照
+     */
+    private static Map<String, SafeDriv> safeMap;
+
+    static {
+        data = new HashSet<>();
+        safeMap = new HashMap<>();
+    }
+
+    private static DateTimeFormatter fmt = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss.SSS");
+    public static void put(SafeDriv sd){
+        sd.setTs(fmt.parseMillis(sd.getStartime()));
+        data.add(sd);
+
+        if(sd.getYczltype().indexOf("A") == -1)
+            sd.setYczltype("A" + sd.getYczltype());
+
+        SafeDriv old = safeMap.get(sd.getClzbh());
+        if(old == null || sd.getTs() > old.getTs()){
+            //通知客户端
+            sendUtils.sendSafeDriv(sd);
+        }
+
+        safeMap.put(sd.getClzbh(), sd);
+    }
+
+    @Override
+    public void run(String... strings) throws Exception {
+        //定时加载安全驾驶数据
+        Application.mainServices.scheduleWithFixedDelay(safeDrivDataLoadThread, 60, 5, TimeUnit.SECONDS);
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        sendUtils = applicationContext.getBean(SendUtils.class);
+    }
+}
+package com.bsth.data.safe_driv;
+
+import com.alibaba.fastjson.JSON;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.util.List;
+
+/**
+ * 安全驾驶数据加载线程
+ * Created by panzhao on 2017/4/6.
+ */
+@Component
+public class SafeDrivDataLoadThread extends Thread{
+
+    private final static String url = "http://180.166.5.82:9988//bsth-safedriving/Crlcxb/realtimeInterface.do";
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Override
+    public void run() {
+        List<SafeDriv> list = null;
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        try {
+            httpClient = HttpClients.createDefault();
+            HttpGet get = new HttpGet(url);
+
+            response = httpClient.execute(get);
+
+            HttpEntity entity = response.getEntity();
+            if (null != entity) {
+                BufferedReader br = new BufferedReader(new InputStreamReader(entity.getContent()));
+                StringBuffer stringBuffer = new StringBuffer();
+                String str = "";
+                while ((str = br.readLine()) != null)
+                    stringBuffer.append(str);
+
+
+                list = JSON.parseArray(stringBuffer.toString(), SafeDriv.class);
+                /**
+                 * 模拟数据
+
+                SafeDriv sd1 = new SafeDriv();
+                sd1.setYczltype("1");
+                sd1.setClzbh("W2B-001");
+                sd1.setStartime("2017-04-07 08:00:00.0");
+
+                SafeDriv sd2 = new SafeDriv();
+                sd2.setYczltype("2");
+                sd2.setClzbh("W2B-002");
+                sd2.setStartime("2017-04-07 08:02:00.0");
+
+                SafeDriv sd3 = new SafeDriv();
+                sd3.setYczltype("3");
+                sd3.setClzbh("W2B-003");
+                sd3.setStartime("2017-04-07 08:03:00.0");
+
+                SafeDriv sd4 = new SafeDriv();
+                sd4.setYczltype("4");
+                sd4.setClzbh("W2B-004");
+                sd4.setStartime("2017-04-07 08:04:00.0");
+
+                SafeDriv sd5 = new SafeDriv();
+                sd5.setYczltype("5");
+                sd5.setClzbh("W2B-005");
+                sd5.setStartime("2017-04-07 08:05:00.0");
+
+                list.add(sd1);
+                list.add(sd2);
+                list.add(sd3);
+                list.add(sd4);
+                list.add(sd5);
+                 */
+                for(SafeDriv sd : list){
+                    SafeDrivCenter.put(sd);
+                }
+            }
+
+            httpClient.close();
+            response.close();
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+    }
+}
@@ -94,7 +94,7 @@ public class RealControlSocketHandler implements WebSocketHandler {
 	/**
 	 * 根据线路推送消息
 	 */
-	public synchronized void sendMessageToLine(String lineCode, String msg) {
+	public void sendMessageToLine(String lineCode, String msg) {
 		TextMessage message = new TextMessage(msg.getBytes());
@@ -117,4 +117,28 @@ public class RealControlSocketHandler implements WebSocketHandler {
 			}
 		}
 	}
+
+
+
+	/**
+	 * 全局推送
+	 */
+	public void sendMessage(String msg) {
+
+		TextMessage message = new TextMessage(msg.getBytes());
+
+		Iterator<WebSocketSession> iterator = users.iterator();
+
+		WebSocketSession user;
+		while(iterator.hasNext()){
+			user = iterator.next();
+			try {
+				if (user.isOpen()) {
+					user.sendMessage(message);
+				}
+			} catch (Exception e) {
+				logger.error("sendMessage error ...."+msg);
+			}
+		}
+	}
 }
@@ -5,6 +5,7 @@ import com.bsth.data.BasicData;
 import com.bsth.data.LineConfigData;
 import com.bsth.data.gpsdata.GpsEntity;
 import com.bsth.data.gpsdata.arrival.entity.SignalState;
+import com.bsth.data.safe_driv.SafeDriv;
 import com.bsth.entity.directive.D80;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -184,4 +185,18 @@ public class SendUtils{
 			logger.error("", e);
 		}
 	}
+
+	public void sendSafeDriv(SafeDriv sd){
+		Map<String, Object> map = new HashMap<>();
+		map.put("fn", "safeDriv");
+		map.put("t", sd);;
+		ObjectMapper mapper = new ObjectMapper();
+
+		try {
+			socketHandler.sendMessage(mapper.writeValueAsString(map));
+
+		} catch (JsonProcessingException e) {
+			logger.error("", e);
+		}
+	}
 }
@@ -923,4 +923,41 @@ option.oil_station_opt{
 }
 .park-and-station-wrap select{
     width: auto !important;
+}
+
+/** 安全驾驶相关css */
+.safe_driv_pop_wrap{
+    position: absolute;
+    right: 12px;
+    bottom: 12px;
+}
+
+.safe_driv_pop{
+    height: 45px;
+    background: #d44b4b;
+    color: #f2f2f2;
+    font-size: 15px;
+    padding: 9px 10px 0;
+    border: 1px solid #f4f0f0;
+    border-radius: 5px;
+    cursor: pointer;
+    box-shadow: 0 8px 17px 0 rgba(0, 0, 0, 0.2), 0 6px 20px 0 rgba(0, 0, 0, 0.19);
+}
+
+.safe_driv_pop:hover{
+    background: #bc2a2a;
+}
+
+.safe_driv_pop .title{
+    font-weight: 600;
+}
+
+.safe_driv_pop i.uk-icon-times-circle{
+    margin-right: 5px;
+}
+.safe_driv_pop .desc{
+    display: block;
+    font-size: 12px;
+    margin: 2px 0 0 20px;
+    color: #e3e3e3;
 }
 \ No newline at end of file
+/**
+ * 安全驾驶相关
+ */
+var gb_safe_driv = (function () {
+
+    var codes = {
+        'A1': '手部违规',
+        'A2': '摄像头偏离',
+        'A3': '安全带',
+        'A4': '手臂袖章',
+        'A5': '脸部检测'
+    };
+
+    var $wrap = $('.safe_driv_pop_wrap');
+    var max = 5;
+
+    var pop = function (sd) {
+        //只有admin用户能收到
+        var user = gb_northToolbar.user();
+        if(!user || user.userName.indexOf('admin') == -1)
+            return;
+
+        var htmlStr = '<div class="safe_driv_pop uk-animation-slide-bottom">'+
+            ' <span class="title"><i class="uk-icon-times-circle"></i>安全驾驶 '+moment(sd.ts).format('HH:mm')+'</span>'+
+            ' <span class="text"> '+sd.clzbh+' 违规驾驶（'+codes[sd.yczltype]+'）</span><span class="desc">请至安全驾驶监管平台查看图像信息</span>'+
+            '</div>';
+
+        var items = $wrap.find('.safe_driv_pop'), len = items.length;
+        if(len >= max)
+            $wrap.find('.safe_driv_pop:lt('+(len - max)+')').remove();
+
+        $wrap.append(htmlStr);
+    };
+
+    $wrap.on('click', '.safe_driv_pop', function () {
+        $(this).remove();
+    });
+
+    return {
+        pop: pop
+    }
+})();
 \ No newline at end of file
@@ -70,6 +70,10 @@ var gb_sch_websocket = (function () {
         calcUntreated(msg.data.lineId);
     };
+    var safeDriv = function (msg) {
+        gb_safe_driv.pop(msg.t);
+    };
+    
     var waitRemoves = [];
     //车辆发出
     var faChe = function (msg) {
@@ -150,7 +154,8 @@ var gb_sch_websocket = (function () {
         d80Confirm: d80Confirm,
         directive: directiveStatus,
         signal_state: signalState,
-        deviceOffline: deviceOffline
+        deviceOffline: deviceOffline,
+        safeDriv: safeDriv
     };
     function currentSecond() {
@@ -60,6 +60,7 @@
     </div>
 </div>
+<div class="safe_driv_pop_wrap"></div>
 <script>
     delete window.exports;
     delete window.module;
@@ -182,8 +183,10 @@
 <!-- 处理表单片段嵌入问题 -->
 <script src="/real_control_v2/js/forms/form_embed.js"></script>
-
+<!-- 模态框扩展 -->
 <script src="/real_control_v2/js/modal_extend.js"></script>
+<!-- 安全驾驶相关 -->
+<script src="/real_control_v2/js/safe_driv/safeDriv.js" ></script>
 </body>
 </html>
@@ -3,7 +3,7 @@
 var gb_map_play_back = (function () {
     var dom;
-    $.get('/real_control_v2/mapmonitor/fragments/playback_v2/main.html', function (rs) {
+    $.get('/real_control_v2/mapmonitor/fragments/playback/main.html', function (rs) {
         dom = rs;
     });
@@ -13,11 +13,10 @@ var gb_map_play_back = (function () {
             gb_map_imap.call('closeWin', deviceId);
         //show modal
-        open_modal_dom(dom, {deviceId: deviceId, nbbm: nbbm});
-        //var modal = '#map-playback2-modal';
-        //$(document.body).append(dom);
-        //UIkit.modal(modal, {bgclose: false}).show();
-        //$(modal).trigger('show_form', {deviceId: deviceId, nbbm: nbbm});
+        var modal = '#map-playback-modal';
+        $(document.body).append(dom);
+        UIkit.modal(modal, {bgclose: false}).show();
+        $(modal).trigger('show_form', {deviceId: deviceId, nbbm: nbbm});
     };
     //导出excel