客流摄像头，以及客流提示

ljq
1 parent 7aa83666
Showing 11 changed files with 293 additions and 4 deletions
src/main/java/com/bsth/common/Constants.java
src/main/java/com/bsth/data/zndd/OutEntrance.java
src/main/java/com/bsth/entity/zndd/DKLInfo.java
src/main/java/com/bsth/filter/BaseFilter.java
src/main/java/com/bsth/security/WebSecurityConfig.java
src/main/java/com/bsth/security/filter/LoginInterceptor.java
src/main/java/com/bsth/util/SignUtils.java
src/main/java/com/bsth/websocket/handler/SendUtils.java
src/main/resources/static/real_control_v2/fragments/line_schedule/sch_table.html
src/main/resources/static/real_control_v2/js/line_schedule/legend.js
src/main/resources/static/real_control_v2/js/websocket/sch_websocket.js
@@ -42,6 +42,7 @@ public class Constants {
 	public static final String COMPANY_AUTHORITYS = "cmyAuths";
 	public static final String STATION_AND_SECTION_COUNT = "/station/updateStationAndSectionCode";
  
+	public static final String OUT_URL = "/out/**";
 	/**
 	 * 解除调度指令和班次的外键约束
 	 */
+package com.bsth.data.zndd;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.common.ResponseCode;
+import com.bsth.data.BasicData;
+import com.bsth.data.schedule.DayOfSchedule;
+import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import com.bsth.util.SignUtils;
+import com.bsth.websocket.handler.SendUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.*;
+
+/**
+ * 对外接口
+ * 与站牌、小程序对接接口
+ * 调度预案通用接口
+ */
+@RestController
+@RequestMapping("/out")
+public class OutEntrance {
+
+    @Autowired
+    SendUtils sendUtils;
+    @Autowired
+    DayOfSchedule dayOfSchedule;
+
+
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+
+    @RequestMapping(value = "/klyj", method = RequestMethod.POST)
+    public Map klyj(@RequestBody JSONObject jsonObject) {
+        Map rtn = new HashMap<>();
+        try {
+            logger.info("大客流接口调用----");
+            if(!SignUtils.validation(Long.parseLong(jsonObject.getString("timestamp")),jsonObject.getString("sign"))){
+                rtn.put("status", "验证失败");
+               // return rtn;
+            }
+            String num=jsonObject.getString("num");
+            JSONArray jsonArray = jsonObject.getJSONArray("stations");
+            for (int i = 0; i < jsonArray.size(); i++) {
+                JSONObject line=jsonArray.getJSONObject(i);
+                String lineCode = line.get("lineCode").toString();
+                String stationCode = line.get("stationCode").toString();
+                String dir = line.get("dir").toString();
+                String lineName=BasicData.lineCode2NameMap.get(lineCode);
+                String stationName=BasicData.stationCode2NameMap.get(lineCode+"_"+dir+"_"+stationCode);
+
+                Map m = new HashMap();
+                m.put("stationCode", stationCode);
+                m.put("lineCode", lineCode);
+                m.put("stationName",stationName);
+                m.put("lineName",lineName);
+                m.put("num",num);
+                m.put("xlDir",dir);
+                sendUtils.klyj(m);//推送
+            }
+            rtn.put("status",ResponseCode.SUCCESS);
+        } catch (Exception e) {
+            rtn.put("err", ResponseCode.ERROR);
+            logger.error("",e);
+        }
+        return rtn;
+    }
+
+
+
+    //调度获取站台视频
+    @RequestMapping(value = "/getStationVideo", method = RequestMethod.GET)
+    public String getStationVideo(@RequestParam Map m) {
+        if (m.get("lineCode")==null || m.get("upDown")==null){
+            return null;
+        }
+        String sql="select url from station_video where line_code ='"+m.get("lineCode")+"' and up_down ='"+m.get("upDown")+"'";
+        String url= null;
+        try {
+            url = jdbcTemplate.queryForObject(sql,String.class);
+        } catch (DataAccessException e) {
+            return null;
+        }
+        return url;
+    }
+
+
+}
+package com.bsth.entity.zndd;
+
+import javax.persistence.*;
+import java.util.Date;
+
+
+@Entity
+@Table(name = "dkl_info")
+public class DKLInfo {
+
+	// ID
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Integer id;
+
+	private String lineCode;
+
+	private String lineName;
+
+	private String stationCode;
+
+	private String stationName;
+
+	private int num;
+
+	private String upDown;
+
+	private String image;
+
+	private String status;
+
+	// 创建日期
+	@Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
+	private Date createDate;
+
+
+	public Integer getId() {
+		return id;
+	}
+
+	public void setId(Integer id) {
+		this.id = id;
+	}
+
+	public String getLineCode() {
+		return lineCode;
+	}
+
+	public void setLineCode(String lineCode) {
+		this.lineCode = lineCode;
+	}
+
+	public String getLineName() {
+		return lineName;
+	}
+
+	public void setLineName(String lineName) {
+		this.lineName = lineName;
+	}
+
+	public String getStationCode() {
+		return stationCode;
+	}
+
+	public void setStationCode(String stationCode) {
+		this.stationCode = stationCode;
+	}
+
+	public String getStationName() {
+		return stationName;
+	}
+
+	public void setStationName(String stationName) {
+		this.stationName = stationName;
+	}
+
+	public int getNum() {
+		return num;
+	}
+
+	public void setNum(int num) {
+		this.num = num;
+	}
+
+	public String getUpDown() {
+		return upDown;
+	}
+
+	public void setUpDown(String upDown) {
+		this.upDown = upDown;
+	}
+
+	public String getImage() {
+		return image;
+	}
+
+	public void setImage(String image) {
+		this.image = image;
+	}
+
+	public Date getCreateDate() {
+		return createDate;
+	}
+
+	public void setCreateDate(Date createDate) {
+		this.createDate = createDate;
+	}
+
+	public String getStatus() {
+		return status;
+	}
+
+	public void setStatus(String status) {
+		this.status = status;
+	}
+}
@@ -17,7 +17,7 @@ public abstract class BaseFilter implements Filter {
 	 * 白名单
 	 */
 	private String[] whiteListURLs = { Constants.LOGIN_PAGE,Constants.CAPTCHA, Constants.SERVICE_INTERFACE,
-			Constants.ASSETS_URL, Constants.FAVICON_URL, Constants.METRONIC_URL, Constants.LOGIN, Constants.LOGIN_FAILURE, Constants.UPSTREAM_URL, Constants.XD_CHILD_PAGES, Constants.XD_REAL_GPS, Constants.UP_RFID_URL, Constants.STATION_AND_SECTION_COUNT,Constants.XIANDIAO_LOGIN ,Constants.IPAD_IMG_URL};
+			Constants.ASSETS_URL, Constants.FAVICON_URL, Constants.METRONIC_URL, Constants.LOGIN, Constants.LOGIN_FAILURE, Constants.UPSTREAM_URL, Constants.XD_CHILD_PAGES, Constants.XD_REAL_GPS, Constants.UP_RFID_URL, Constants.STATION_AND_SECTION_COUNT,Constants.XIANDIAO_LOGIN ,Constants.IPAD_IMG_URL,Constants.OUT_URL};
  
 	@Override
 	public void destroy() {
@@ -36,7 +36,7 @@ public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
     public void configure(WebSecurity web) throws Exception {
         // 白名单
         web.ignoring().antMatchers(Constants.LOGIN_PAGE, Constants.LOGIN, Constants.ASSETS_URL, Constants.FAVICON_URL, Constants.CAPTCHA,
-                Constants.SERVICE_INTERFACE, Constants.METRONIC_URL, Constants.LOGIN_FAILURE, Constants.UPSTREAM_URL, Constants.XD_CHILD_PAGES, Constants.UP_RFID_URL,Constants.STATION_AND_SECTION_COUNT);
+                Constants.SERVICE_INTERFACE, Constants.METRONIC_URL, Constants.LOGIN_FAILURE, Constants.UPSTREAM_URL, Constants.XD_CHILD_PAGES, Constants.UP_RFID_URL,Constants.STATION_AND_SECTION_COUNT,Constants.OUT_URL);
     }
  
     @Override
@@ -33,7 +33,7 @@ public class LoginInterceptor implements Filter {
 	 * 相比于 BaseFilter，此处对线调GPS请求进行了拦截验证
 	 */
 	private String[] whiteListURLs = { Constants.LOGIN_PAGE,Constants.CAPTCHA, Constants.SERVICE_INTERFACE,
-			Constants.ASSETS_URL, Constants.FAVICON_URL, Constants.METRONIC_URL, Constants.LOGIN, Constants.LOGIN_FAILURE, Constants.UPSTREAM_URL, Constants.XD_CHILD_PAGES, Constants.UP_RFID_URL,Constants.STATION_AND_SECTION_COUNT,Constants.XIANDIAO_LOGIN,Constants.IPAD_IMG_URL };
+			Constants.ASSETS_URL, Constants.FAVICON_URL, Constants.METRONIC_URL, Constants.LOGIN, Constants.LOGIN_FAILURE, Constants.UPSTREAM_URL, Constants.XD_CHILD_PAGES, Constants.UP_RFID_URL,Constants.STATION_AND_SECTION_COUNT,Constants.XIANDIAO_LOGIN,Constants.IPAD_IMG_URL,Constants.OUT_URL };
  
  
 	@Override
+package com.bsth.util;
+
+import com.bsth.service.schedule.utils.Md5Util;
+
+public class SignUtils {
+
+    private static final String PASSWORD="e126853c7f6f43b4857fa8dfe3b28b5d90be9e68";
+    public static boolean validation(long timestamp,String sign){
+        String md5String= Md5Util.getMd5(timestamp+PASSWORD);
+        if(!md5String.equals(sign)){
+            return false;
+        }
+        if(System.currentTimeMillis()-timestamp>60*1000){
+            return false;
+        }
+        return true;
+    }
+}
@@ -218,6 +218,19 @@ public class SendUtils{
 		}
 	}
  
+	public void klyj(Map<String, Object> cp) {
+		Map<String, Object> map = new HashMap<>();
+		map.put("fn", "klyj");
+		map.put("data", cp);
+		ObjectMapper mapper = new ObjectMapper();
+
+		try {
+			socketHandler.sendMessageToLine(cp.get("lineCode").toString(), mapper.writeValueAsString(map));
+		} catch (JsonProcessingException e) {
+			logger.error("sendContingencyPlan", e);
+		}
+	}
+
 	/**
 	 * 将车辆异常停车发送至线调页面
 	 */
@@ -25,7 +25,9 @@
                 </div>
                 <i class="uk-icon-eye uk-icon-hover ct_eye_icon"></i>
                 <!--<i class="uk-icon-share-alt uk-icon-hover tp_info_icon" ></i>-->
+                <i class="uk-icon-video-camera uk-icon-hover ct_video_camera_icon" data-updown="{{dir}}" data-linecode="{{line.lineCode}}"  data-toggle="tooltip" data-placement="bottom"></i>
  
+                <span type="text" id="{{line.lineCode}}_{{dir}}" ></span>
                 <span class="warn_multi_station" data-updown="{{dir}}" data-code="{{line.lineCode}}"></span>
                 <div class="search_sch_panel">
                     <form class="uk-form" onsubmit="javascript:return false;">
@@ -45,6 +45,42 @@ var gb_sch_legend = (function () {
  
     var eye_dom = '.schedule-wrap i.ct_eye_icon';
     $(document).on('click', eye_dom, changeHandicappedStyle);
+
+
+    $(document).on('click', '.schedule-wrap i.ct_video_camera_icon',  function (event) {
+        var upDown=event.target.dataset.updown;
+        var lineCode=event.target.dataset.linecode;
+        var params = {"upDown":upDown,"lineCode":lineCode};
+        $.get('/out/getStationVideo', params, function(url){
+            if(url!=''){
+                var imgHtml = "<iframe src='"+url+"?autoplay=1' style='width:100%;height:100%'/>";
+                layer.open({
+                    type: 1,
+                    offset: 'auto',
+                    area: [700 + 'px', 394 + 'px'],
+                    shadeClose: true,//点击外围关闭弹窗
+                    scrollbar: true,//不现实滚动条
+                    title: false, //不显示标题
+                    content: imgHtml, //捕获的元素，注意：最好该指定的元素要存放在body最外层，否则可能被其它的相对元素所影响
+                    cancel: function () {
+                    }
+                })
+            }/*else {
+                notify_succ('设备不存在');
+            }*/
+
+        });
+    });
+
+    function popcf(data){
+        if(data.num < 5){
+            $("#"+data.lineCode+"_"+data.xlDir).text("(客流正常)");
+        }else {
+            $("#"+data.lineCode+"_"+data.xlDir).text("(客流拥挤)");
+        }
+
+    }
+
     function changeHandicappedStyle() {
         if($(this).hasClass('active')){
             $(eye_dom).removeClass('active');
@@ -83,6 +119,7 @@ var gb_sch_legend = (function () {
     };
  
     return {
-        init: initLegend
+        init: initLegend,
+        popcf : popcf
     };
 })();
 \ No newline at end of file
@@ -186,6 +186,10 @@ var gb_sch_websocket = (function () {
     var signalState = function (msg) {
         gb_signal_state.put(msg.data);
     };
+    var klyj = function (msg){
+        gb_sch_legend.popcf(msg.data);
+    };
+
  
     var carErrorStop = function (msg){
         gb_carerrorstop.pop(msg.data);
@@ -202,6 +206,7 @@ var gb_sch_websocket = (function () {
         deviceOffline: deviceOffline,
         safeDriv: safeDriv,
         auto_wdtz: autoWdtz,
+        klyj:klyj,
         carErrorStop: carErrorStop
     };