1.线调->轨迹回放加入到离站信息导出功能

王通
1 parent bec3c4e6
Showing 3 changed files with 69 additions and 16 deletions
src/main/java/com/bsth/service/gps/GpsServiceImpl.java
src/main/resources/application-dev.properties
src/main/resources/static/real_control_v2/mapmonitor/fragments/playback_v3/right.html
@@ -559,6 +559,22 @@ public class GpsServiceImpl implements GpsService {
     public Map<String, ArrivalEntity> findArrivalByTs(Long st, Long et, List<DeviceChange> dcs) {
         Map<String, ArrivalEntity> map = new HashMap<>();
  
+        List<ArrivalEntity> list = findArrivalListByTs(st, et, dcs);
+
+        String stationName, prefix;
+        for(ArrivalEntity arr : list){
+            prefix = arr.getLineCode() + "_" + arr.getUpDown() + "_";
+            stationName = BasicData.getStationNameByCode(arr.getStopNo(), prefix);
+
+            arr.setStopName(stationName);
+
+            // 反转进出状态
+            map.put(arr.getDeviceId() + "_" + arr.getTs(), arr);
+        }
+        return map;
+    }
+
+    private List<ArrivalEntity> findArrivalListByTs(Long st, Long et, List<DeviceChange> dcs) {
         // weeks_year 分区字段
         Calendar sCal = Calendar.getInstance();
         sCal.setTime(new Date(st));
@@ -591,21 +607,10 @@ public class GpsServiceImpl implements GpsService {
                 sql.append(" UNION ");
         }
  
-        logger.info("arrivl sql : " + sql.toString());
+        logger.info("arrival sql : " + sql.toString());
         JdbcTemplate jdbcTemplate_ms = new JdbcTemplate(DBUtils_MS.getDataSource());
-        List<ArrivalEntity> list = jdbcTemplate_ms.query(sql.toString(), BeanPropertyRowMapper.newInstance(ArrivalEntity.class));
-
-        String stationName, prefix;
-        for(ArrivalEntity arr : list){
-            prefix = arr.getLineCode() + "_" + arr.getUpDown() + "_";
-            stationName = BasicData.getStationNameByCode(arr.getStopNo(), prefix);
  
-            arr.setStopName(stationName);
-
-            // 反转进出状态
-            map.put(arr.getDeviceId() + "_" + arr.getTs(), arr);
-        }
-        return map;
+        return jdbcTemplate_ms.query(sql.toString(), BeanPropertyRowMapper.newInstance(ArrivalEntity.class));
     }
  
  
@@ -1074,7 +1079,55 @@ public class GpsServiceImpl implements GpsService {
  
     @Override
     public void arrivalExcel(String nbbm, long st, long et, HttpServletResponse resp) {
+        st = st * 1000;
+        et = et * 1000;
+        List<DeviceChange> dcs = findDeviceChangeLogs(nbbm, et, st);
+        // 查询到离站数据
+        List<ArrivalEntity> list = findArrivalListByTs(st, et, dcs);
  
+        //创建excel工作簿
+        Workbook wb = new HSSFWorkbook();
+        Sheet sheet = wb.createSheet("到离站信息");
+        //表头
+        Row row = sheet.createRow(0);
+        row.setHeight((short) (1.5 * 256));
+        row.createCell(0).setCellValue("序号");
+        row.createCell(1).setCellValue("车辆");
+        row.createCell(2).setCellValue("牌照号");
+        row.createCell(3).setCellValue("站名");
+        row.createCell(4).setCellValue("时间");
+        row.createCell(5).setCellValue("进/出站");
+        //数据
+        DateTimeFormatter fmtHHmmss = DateTimeFormat.forPattern("HH:mm.ss"), fmt = DateTimeFormat.forPattern("yyyyMMddHHmm");
+        ArrivalEntity arrival;
+        String prefix, stationName;
+        for(int i = 0; i < list.size(); i ++){
+            arrival = list.get(i);
+            prefix = arrival.getLineCode() + "_" + arrival.getUpDown() + "_";
+            stationName = BasicData.getStationNameByCode(arrival.getStopNo(), prefix);
+            row = sheet.createRow(i + 1);
+            row.createCell(0).setCellValue(i + 1);
+            row.createCell(1).setCellValue(nbbm);
+            row.createCell(2).setCellValue(BasicData.nbbmCompanyPlateMap.get(nbbm));
+            row.createCell(3).setCellValue(stationName);
+            row.createCell(4).setCellValue(fmtHHmmss.print(arrival.getTs()));
+            row.createCell(5).setCellValue(arrival.getInOut() == 0 ? "进站" : "出站");
+        }
+
+        String filename = nbbm + "到离站数据" + fmt.print(st) + "至" + fmt.print(et) + ".xls";
+        try {
+            resp.setContentType("application/x-msdownload");
+            resp.addHeader("content-disposition", "attachment;filename=" + URLEncoder.encode(filename, "UTF-8"));
+
+            OutputStream out=resp.getOutputStream();
+            wb.write(out);
+            out.flush();
+            out.close();
+        } catch (UnsupportedEncodingException e) {
+            logger.error("", e);
+        } catch (IOException e) {
+            logger.error("", e);
+        }
     }
  
     @Override
@@ -20,7 +20,7 @@ spring.datasource.control.password= root2jsp
 spring.datasource.control.type= com.zaxxer.hikari.HikariDataSource
 #DATASOURCE
 spring.datasource.control.hikari.minimum-idle= 8
-spring.datasource.control.hikari.maximum-pool-size= 100
+spring.datasource.control.hikari.maximum-pool-size= 16
 #spring.datasource.control.hikari.auto-commit= true
 spring.datasource.control.hikari.idle-timeout= 60000
 #spring.datasource.control.hikari.pool-name= HikariPool
@@ -38,7 +38,7 @@ spring.datasource.info-publish.password= root2jsp
 spring.datasource.info-publish.type= com.zaxxer.hikari.HikariDataSource
 #DATASOURCE
 spring.datasource.info-publish.hikari.minimum-idle= 8
-spring.datasource.info-publish.hikari.maximum-pool-size= 100
+spring.datasource.info-publish.hikari.maximum-pool-size= 16
 #spring.datasource.info-publish.hikari.auto-commit= true
 spring.datasource.info-publish.hikari.idle-timeout= 60000
 #spring.datasource.info-publish.hikari.pool-name= HikariPool
@@ -53,7 +53,7 @@
                 <div class="uk-dropdown uk-dropdown-small">
                     <ul class="uk-nav uk-nav-dropdown">
                         <li><a class="export-excel-abnormal">导出异常数据</a></li>
-                        <!--<li><a class="export-excel-arrival">导出到离站数据</a></li>-->
+                        <li><a class="export-excel-arrival">导出到离站数据</a></li>
                     </ul>
                 </div>
             </div>