1.大客流数据记录

2.线调站点视频查看 3.线调大客流图片查看

1.大客流数据记录
2.线调站点视频查看 3.线调大客流图片查看
yiming
1 parent a7767911
Showing 7 changed files with 242 additions and 9 deletions
src/main/java/com/bsth/data/zndd/OutEntrance.java
src/main/java/com/bsth/entity/DKLInfo.java
src/main/java/com/bsth/repository/DKLInfoRepository.java
src/main/java/com/bsth/service/DKLInfoService.java
src/main/java/com/bsth/service/impl/DKLInfoServiceImpl.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
@@ -6,9 +6,11 @@ import com.bsth.common.ResponseCode;
 import com.bsth.data.BasicData;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.data.schedule.ScheduleComparator;
+import com.bsth.entity.DKLInfo;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import com.bsth.entity.zndd.StationPeopleLogger;
 import com.bsth.entity.zndd.StationSignsLogger;
+import com.bsth.service.DKLInfoService;
 import com.bsth.util.HttpClientUtils;
 import com.bsth.util.SignUtils;
 import com.bsth.websocket.handler.SendUtils;
@@ -17,8 +19,11 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.web.bind.annotation.*;
+import javax.annotation.PostConstruct;
 import java.io.*;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -31,6 +36,7 @@ import java.io.FileOutputStream;
 import java.io.InputStream;
 import java.text.SimpleDateFormat;
 import java.time.Duration;
+import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
@@ -69,6 +75,12 @@ public class OutEntrance {
     @Autowired
     AutomaticSch automaticSch;
+    @Autowired
+    private DKLInfoService dklInfoService;
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
      //调度屏小程序接口。
      @RequestMapping(value = "/OutCar", method = RequestMethod.POST)
      public Map OutCarOutCar(@RequestParam Map m,@RequestBody StationSignsLogger ssLogger) {
@@ -155,10 +167,6 @@ public class OutEntrance {
             }
             String num=jsonObject.getString("num");
             int count=automaticSch.getPenum("DKL","0");
-            if(Integer.parseInt(num)<count){
-                rtn.put("status",ResponseCode.SUCCESS);
-                return rtn;
-            }
             String image=jsonObject.getString("image");
             String img=uploadBase64Img(image);
             JSONArray jsonArray = jsonObject.getJSONArray("stations");
@@ -169,13 +177,27 @@ public class OutEntrance {
                 String lineCode = line.get("lineCode").toString();
                 String stationCode = line.get("stationCode").toString();
                 String dir = line.get("dir").toString();
-                /*StationRoute stationRoute=BasicData.stationCode2StationMap.get(lineCode+"_"+stationCode);*/
+                imgMap.put(lineCode+"_"+dir,image);
+                DKLInfo dklInfo =new DKLInfo();
+                dklInfo.setLineCode(stationCode);
+                String lineName=BasicData.lineCode2NameMap.get(lineCode);
+                String stationName=BasicData.stationCode2NameMap.get(lineCode+"_"+dir+"_"+stationCode);
+                dklInfo.setLineName(lineName);
+                dklInfo.setStationCode(stationCode);
+                dklInfo.setStationName(stationName);
+                dklInfo.setNum(Integer.parseInt(num));
+                dklInfo.setUpDown(dir);
+                dklInfo.setImage(img);
+                dklInfoService.save(dklInfo);
+                if(Integer.parseInt(num)<count){
+                    continue;
+                }
                 Map m = new HashMap();
                 m.put("image", img);
                 m.put("stationCode", stationCode);
                 m.put("lineCode", lineCode);
-                m.put("stationName",BasicData.stationCode2NameMap.get(lineCode+"_"+dir+"_"+stationCode));
-                m.put("lineName",BasicData.lineCode2NameMap.get(lineCode));
+                m.put("stationName",stationName);
+                m.put("lineName",lineName);
                 m.put("num",num);
                 m.put("xlDir",dir);
                 List<ScheduleRealInfo> srList=dayOfSchedule.findByLineAndUpDown(lineCode,Integer.parseInt(dir));
@@ -319,7 +341,7 @@ public class OutEntrance {
                     destfile.mkdirs();
                 }
                 //文件新名称
-                String fileNameNew = AutomaticSch.UUID()+ ".png";
+                String fileNameNew = System.currentTimeMillis()+"_"+AutomaticSch.UUID()+ ".png";
                 File f = new File(destfile.getAbsoluteFile() + File.separator + fileNameNew);
                 // 将字符串转换成二进制，用于显示图片
                 // 将上面生成的图片格式字符串 imgStr，还原成图片显示
@@ -397,7 +419,9 @@ public class OutEntrance {
     @Scheduled(cron = "0 0 0 * * ?")
     public void clearImg(){
         try {
-            File folder=new File(imgurl+"/avat");
+            LocalDateTime date =LocalDateTime.now().minusDays(7);
+            String[] d=date.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")).split("-");
+            File folder=new File(imgurl+"/avat/"+d[0]+"/"+d[1]+"/"+d[2]);
             delete(folder);
         } catch (Exception e) {
             e.printStackTrace();
@@ -416,4 +440,28 @@ public class OutEntrance {
         folder.delete(); // 删除空文件夹或者文件
     }
+    private static Map<String,String> imgMap =new HashMap<>();
+    //调度获取站台视频
+    @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;
+    }
+
+    //调度获取站台图片
+    @RequestMapping(value = "/getStationImg", method = RequestMethod.GET)
+    public String getStationImg(@RequestParam Map m) {
+        String url=imgMap.get(m.get("lineCode")+"_"+m.get("upDown"));
+        return url;
+    }
+
 }
+package com.bsth.entity;
+
+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;
+
+	// 创建日期
+	@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;
+	}
+
+}
+package com.bsth.repository;
+
+import com.bsth.entity.DKLInfo;
+import org.springframework.stereotype.Repository;
+
+
+@Repository
+public interface DKLInfoRepository extends BaseRepository<DKLInfo, Integer> {
+}
+package com.bsth.service;
+
+import com.bsth.entity.DKLInfo;
+
+
+public interface DKLInfoService extends BaseService<DKLInfo, Integer> {
+}
+package com.bsth.service.impl;
+
+import com.bsth.entity.DKLInfo;
+import com.bsth.service.DKLInfoService;
+import org.springframework.stereotype.Service;
+
+
+@Service
+public class DKLInfoServiceImpl extends BaseServiceImpl<DKLInfo, Integer> implements DKLInfoService {
+}
@@ -25,6 +25,8 @@
                 </div>
                 <i class="uk-icon-eye uk-icon-hover ct_eye_icon"></i>
                 <i class="uk-icon-qrcode uk-icon-hover ct_calu_icon"  data-toggle="tooltip" data-placement="bottom"  title="计算应到实到时间对比"></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>
+                <i class="uk-icon-image uk-icon-hover ct_image_icon" data-updown="{{dir}}" data-linecode="{{line.lineCode}}"  data-toggle="tooltip" data-placement="bottom"></i>
                 <!--<i class="uk-icon-share-alt uk-icon-hover tp_info_icon" ></i>-->
@@ -78,6 +78,55 @@ var gb_sch_legend = (function () {
         showYdSdDb();
     }
+    $(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('设备不存在');
+            }*/
+
+        });
+    });
+
+    $(document).on('click', '.schedule-wrap i.ct_image_icon',  function (event) {
+        var upDown=event.target.dataset.updown;
+        var lineCode=event.target.dataset.linecode;
+        var params = {"upDown":upDown,"lineCode":lineCode};
+        $.get('/out/getStationImg', params, function(url){
+            if(url!=''){
+                var imgHtml = "<img src='"+url+"' style='width:700px;height:394px'/>";
+                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 showYdSdDb() {
         if (ydsddb) {
             var sdsjs = $('.schedule-wrap').find('.qdzArrDatesjDD');