智能时刻表发车间隔报表

徐烜
1 parent 831ec122
Showing 11 changed files with 303 additions and 12 deletions
src/main/java/com/bsth/controller/schedule/core/TTInfoDetailController.java
src/main/java/com/bsth/service/schedule/TTInfoDetailService.java
src/main/java/com/bsth/service/schedule/datatools/TTInfoDetailDataToolsImpl.java
src/main/java/com/bsth/service/schedule/datatools/TTinfoDetailDynamicData.java
src/main/java/com/bsth/service/schedule/impl/SchedulePlanServiceImpl.java
src/main/java/com/bsth/service/schedule/impl/TTInfoDetailServiceImpl.java
src/main/java/com/bsth/service/schedule/impl/plan/MyDroolsConfiguration.java
src/main/resources/static/pages/base/timesmodel/gantt.html
src/main/resources/static/pages/base/timesmodel/js/gantt.js
src/main/resources/static/pages/base/timesmodel/js/v2_2/Main_v2_2_ExcelObj.js
src/main/resources/static/pages/base/timesmodel/js/v2_2/main_v2_2.js
@@ -128,6 +128,32 @@ public class TTInfoDetailController extends BController&lt;TTInfoDetail, Long&gt; {
     	return ttInfoDetailService.skbDetailMxSave(entities);
     }
  
+    @RequestMapping(value = "/exportDTDFile2", method = RequestMethod.POST)
+    public void exportFile2(@RequestBody TTinfoDetailDynamicData.LineHeadWayInfo lineHeadWayInfo,
+                            HttpServletResponse response) throws Exception {
+        DataToolsFile dataToolsFile = ttInfoDetailService.exportHeadwayTTinfo(lineHeadWayInfo);
+
+        // 流输出导出文件
+        response.setHeader("content-type", "application/octet-stream");
+        response.setHeader("Content-Disposition", "attachment; filename=" + dataToolsFile.getFile().getName());
+        response.setContentType("application/octet-stream");
+
+        OutputStream os = response.getOutputStream();
+        BufferedOutputStream bos = new BufferedOutputStream(os);
+
+        InputStream is = new FileInputStream(dataToolsFile.getFile());
+        BufferedInputStream bis = new BufferedInputStream(is);
+
+        int length = 0;
+        byte[] temp = new byte[1 * 1024 * 10];
+        while ((length = bis.read(temp)) != -1) {
+            bos.write(temp, 0, length);
+        }
+        bos.flush();
+        bis.close();
+        bos.close();
+        is.close();
+    }
  
     @RequestMapping(value = "/exportDTDFile/{type}", method = RequestMethod.POST)
     public void exportFile(
@@ -34,6 +34,14 @@ public interface TTInfoDetailService extends BService&lt;TTInfoDetail, Long&gt; {
     DataToolsFile exportDynamicTTinfo(TTinfoDetailDynamicData.DTInfos dtInfos, DataToolsFileType type) throws ScheduleException;
  
     /**
+     * 导出班次发车间隔信息。
+     * @param lineHeadWayInfo
+     * @return
+     * @throws ScheduleException
+     */
+    DataToolsFile exportHeadwayTTinfo(TTinfoDetailDynamicData.LineHeadWayInfo lineHeadWayInfo) throws ScheduleException;
+
+    /**
      * 获取时刻表最大发车顺序号
      * @param xlid 线路id
      * @param ttinfoid 时刻表id
@@ -800,4 +800,82 @@ public class TTInfoDetailDataToolsImpl implements DataToolsService, TTInfoDetail
         }
  
     }
+
+    @Override
+    public DataToolsFile exportHeadwayTTinfo(LineHeadWayInfo lineHeadWayInfo) throws ScheduleException {
+        try {
+            // 输出2007版本
+            ExcelPoiOperator excelPoiOperator = new Excel2007PoiOperator();
+
+            // 使用POI，创建xlsx文件
+            org.apache.poi.ss.usermodel.Workbook wb = excelPoiOperator.createWorkBook();
+            // 一个sheet写上下行间隔信息
+            org.apache.poi.ss.usermodel.Sheet sheet = excelPoiOperator.createWorkBookSheet(wb, "时刻表发车间隔信息_统计");
+
+            // 构建第一行数据
+            Row lpHeadRow = excelPoiOperator.createSheetRow(sheet, 0);
+            // 构建上行发车间隔表头
+            excelPoiOperator.createStringCell(wb, lpHeadRow, (short) 0, "路牌", new Color(0x96b9d7));
+            excelPoiOperator.createStringCell(wb, lpHeadRow, (short) 1, "发车时间", new Color(0x96b9d7));
+            excelPoiOperator.createStringCell(wb, lpHeadRow, (short) 2, "发车间隔", new Color(0x96b9d7));
+            // 构造下行发车间隔表头
+            excelPoiOperator.createStringCell(wb, lpHeadRow, (short) 6, "路牌", new Color(0x96b9d7));
+            excelPoiOperator.createStringCell(wb, lpHeadRow, (short) 7, "发车时间", new Color(0x96b9d7));
+            excelPoiOperator.createStringCell(wb, lpHeadRow, (short) 8, "发车间隔", new Color(0x96b9d7));
+
+            // 构造行
+            int maxRow = Math.max(lineHeadWayInfo.getUpBcList().size(), lineHeadWayInfo.getDownBcList().size());
+            List<Row> rowList = new ArrayList<>();
+            for (int i = 1; i <= maxRow; i++) {
+                Row row = excelPoiOperator.createSheetRow(sheet, i);
+                rowList.add(row);
+            }
+
+            // 构造上行发车间隔信息
+            for (int i = 0; i < lineHeadWayInfo.getUpBcList().size(); i++) {
+                BcHeadWayInfo bcHeadWayInfo = lineHeadWayInfo.getUpBcList().get(i);
+                excelPoiOperator.createStringCell(wb, rowList.get(i), (short) 0, bcHeadWayInfo.getLpName());
+                excelPoiOperator.createStringCell(wb, rowList.get(i), (short) 1, bcHeadWayInfo.getFcsj());
+                excelPoiOperator.createStringCell(wb, rowList.get(i), (short) 2, bcHeadWayInfo.getHeadway());
+            }
+            // 构造下行发车间隔信息
+            for (int i = 0; i < lineHeadWayInfo.getDownBcList().size(); i++) {
+                BcHeadWayInfo bcHeadWayInfo = lineHeadWayInfo.getDownBcList().get(i);
+                excelPoiOperator.createStringCell(wb, rowList.get(i), (short) 6, bcHeadWayInfo.getLpName());
+                excelPoiOperator.createStringCell(wb, rowList.get(i), (short) 7, bcHeadWayInfo.getFcsj());
+                excelPoiOperator.createStringCell(wb, rowList.get(i), (short) 8, bcHeadWayInfo.getHeadway());
+            }
+
+            // 自适应单元格长宽
+            sheet.autoSizeColumn(0);
+            sheet.autoSizeColumn(1);
+            sheet.autoSizeColumn(2);
+            sheet.autoSizeColumn(6);
+            sheet.autoSizeColumn(7);
+            sheet.autoSizeColumn(8);
+
+            // wb内存写入文件
+            String filepath = dataToolsProperties.getFileoutputDir() +
+                    File.separator +
+                    "动态时刻表发车间隔信息-" +
+                    new DateTime().toString("yyyyMMddHHmmss") + ".xlsx";
+            File file = new File(filepath);
+            excelPoiOperator.writeExcel(file, wb);
+
+            DataToolsFile dataToolsFile = new DataToolsFile();
+            dataToolsFile.setFileType(DataToolsFileType.XLSX);
+            dataToolsFile.setFile(file);
+
+            return dataToolsFile;
+
+        } catch (Exception exp) {
+            LOGGER.info("//---------------- 动态时刻表发车间隔信息输出 failed... ----------------//");
+
+            StringWriter sw = new StringWriter();
+            exp.printStackTrace(new PrintWriter(sw));
+            LOGGER.info(sw.toString());
+
+            throw new ScheduleException(exp);
+        }
+    }
 }
@@ -400,6 +400,62 @@ public interface TTinfoDetailDynamicData {
         }
     }
  
+    class BcHeadWayInfo { // 班次发车间隔信息
+        /** 路牌名字 */
+        private String lpName;
+        /** 发车时间 */
+        private String fcsj;
+        /** 发车间隔 */
+        private String headway;
+
+        public String getLpName() {
+            return lpName;
+        }
+
+        public void setLpName(String lpName) {
+            this.lpName = lpName;
+        }
+
+        public String getFcsj() {
+            return fcsj;
+        }
+
+        public void setFcsj(String fcsj) {
+            this.fcsj = fcsj;
+        }
+
+        public String getHeadway() {
+            return headway;
+        }
+
+        public void setHeadway(String headway) {
+            this.headway = headway;
+        }
+    }
+
+    class LineHeadWayInfo { // 线路发车间隔信息
+        /** 上行班次发车间隔信息 */
+        private List<BcHeadWayInfo> upBcList;
+        /** 下行班次发车间隔信息 */
+        private List<BcHeadWayInfo> downBcList;
+
+        public List<BcHeadWayInfo> getUpBcList() {
+            return upBcList;
+        }
+
+        public void setUpBcList(List<BcHeadWayInfo> upBcList) {
+            this.upBcList = upBcList;
+        }
+
+        public List<BcHeadWayInfo> getDownBcList() {
+            return downBcList;
+        }
+
+        public void setDownBcList(List<BcHeadWayInfo> downBcList) {
+            this.downBcList = downBcList;
+        }
+    }
+
     //---------------------- 生成时刻表用对象（以上） ---------------------//
  
     /**
@@ -409,4 +465,12 @@ public interface TTinfoDetailDynamicData {
      * @throws ScheduleException
      */
     DataToolsFile exportDynamicTTinfo(DTInfos dtInfos, DataToolsFileType type) throws ScheduleException;
+
+    /**
+     * 导出班次发车间隔信息。
+     * @param lineHeadWayInfo
+     * @return
+     * @throws ScheduleException
+     */
+    DataToolsFile exportHeadwayTTinfo(LineHeadWayInfo lineHeadWayInfo) throws ScheduleException;
 }
@@ -8,18 +8,17 @@ import com.bsth.repository.LineRepository;
 import com.bsth.repository.schedule.*;
 import com.bsth.service.schedule.SchedulePlanService;
 import com.bsth.service.schedule.exception.ScheduleException;
+import com.bsth.service.schedule.impl.plan.DroolsSchedulePlan;
+import com.bsth.service.schedule.impl.plan.ScheduleRuleService;
 import com.bsth.service.schedule.impl.plan.kBase3.validate.rule.ValidateRuleResult;
 import com.bsth.service.schedule.impl.plan.kBase3.validate.timetable.CalcuParam;
 import com.bsth.service.schedule.impl.plan.kBase3.validate.timetable.Result;
-import com.bsth.service.schedule.impl.plan.DroolsSchedulePlan;
-import com.bsth.service.schedule.impl.plan.ScheduleRuleService;
 import org.joda.time.DateTime;
 import org.kie.api.KieBase;
 import org.kie.api.runtime.KieSession;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Isolation;
 import org.springframework.transaction.annotation.Propagation;
@@ -35,16 +34,16 @@ import java.util.concurrent.locks.ReentrantLock;
  */
 @Service
 public class SchedulePlanServiceImpl extends BServiceImpl<SchedulePlan, Long> implements SchedulePlanService {
-    @Autowired
-    @Qualifier("coreKBase")
+//    @Autowired
+//    @Qualifier("coreKBase")
     private KieBase coreKBase;
  
-    @Autowired
-    @Qualifier("preKBase")
+//    @Autowired
+//    @Qualifier("preKBase")
     private KieBase preKBase;
  
-    @Autowired
-    @Qualifier("KBase3")
+//    @Autowired
+//    @Qualifier("KBase3")
     private KieBase validateKBase;
  
     @Autowired
@@ -145,6 +145,11 @@ public class TTInfoDetailServiceImpl extends BServiceImpl&lt;TTInfoDetail, Long&gt; im
     }
  
     @Override
+    public DataToolsFile exportHeadwayTTinfo(TTinfoDetailDynamicData.LineHeadWayInfo lineHeadWayInfo) throws ScheduleException {
+        return tTinfoDetailDynamicData.exportHeadwayTTinfo(lineHeadWayInfo);
+    }
+
+    @Override
     public DataToolsFile exportDynamicTTinfo(TTinfoDetailDynamicData.DTInfos dtInfos, DataToolsFileType type) throws ScheduleException {
         return tTinfoDetailDynamicData.exportDynamicTTinfo(dtInfos, type);
     }
@@ -14,12 +14,11 @@ import org.kie.api.runtime.conf.ClockTypeOption;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
  
 /**
  * Drools 6配置类。
  */
-@Configuration
+//@Configuration
 public class MyDroolsConfiguration {
     /** 日志记录器 */
     private static final Logger logger = LoggerFactory.getLogger(MyDroolsConfiguration.class);
@@ -78,6 +78,13 @@
                                     Excel2007 xlsx
                                 </a>
                             </li>
+
+                            <li>
+                                <a href="javascript:" class="tool-action exportHeadWayXlsx">
+                                    <i class="fa fa-file-excel-o"></i>
+                                    发车间隔信息xlsx
+                                </a>
+                            </li>
                         </ul>
                     </div>
  
@@ -180,7 +180,9 @@
                         qdz: _gObj[13],
                         zdz: _gObj[14],
                         STOPTIME: _gObj[15],
-                        isfb: _gObj[16]
+                        isfb: _gObj[16],
+
+                        fcsj_time: _gObj[1] // 原始时间，用于排序
                     });
                 }
  
@@ -966,6 +966,76 @@ var Main_v2_2_ExcelObj = (function() {
         return _celb.fnGenerateExcelLpBcList();
     };
  
+    /**
+     * 获取班次发车间隔数据。
+     * @return {*}
+     */
+    InternalExcelObj.prototype.fnGetBcHeadWayInfoList = function() {
+        // 甘特图班次数据
+        var aGanttBc = this._fnBc();
+
+        var i;
+        var oHeadWayBc = {};
+        // 构造上行班次间隔数据，normal班次，时间排序
+        var upBcList = [];
+        for (i = 0; i < aGanttBc.length; i++) {
+            oHeadWayBc = {};
+            if (aGanttBc[i].xlDir == 'relationshipGraph-up' && aGanttBc[i].bcType == 'normal') {
+                oHeadWayBc.lpName = aGanttBc[i].lpName; // 路牌
+                oHeadWayBc.fcsj = aGanttBc[i].fcsj; // 发车时间
+                oHeadWayBc.fcsj_time = aGanttBc[i].fcsj_time; // 发车时间（毫秒）
+                upBcList.push(oHeadWayBc);
+            }
+        }
+        upBcList.sort(function(t1, t2) {
+            return t1.fcsj_time - t2.fcsj_time;
+        });
+        // 计算发车间隔时间
+        for (i = 0; i < upBcList.length; i++) {
+            if (i == 0) {
+                upBcList[i].headway = 0;
+            } else {
+                upBcList[i].headway = (upBcList[i].fcsj_time - upBcList[i - 1].fcsj_time) / 1000 / 60
+            }
+        }
+
+        // 构造下行班次间隔数据，normal班次，时间排序
+        var downBcList = [];
+        for (i = 0; i < aGanttBc.length; i++) {
+            oHeadWayBc = {};
+            if (aGanttBc[i].xlDir == 'relationshipGraph-down' && aGanttBc[i].bcType == 'normal') {
+                oHeadWayBc.lpName = aGanttBc[i].lpName; // 路牌
+                oHeadWayBc.fcsj = aGanttBc[i].fcsj; // 发车时间
+                oHeadWayBc.fcsj_time = aGanttBc[i].fcsj_time; // 发车时间（毫秒）
+                downBcList.push(oHeadWayBc);
+            }
+        }
+        downBcList.sort(function(t1, t2) {
+            return t1.fcsj_time - t2.fcsj_time;
+        });
+        // 计算发车间隔时间
+        for (i = 0; i < downBcList.length; i++) {
+            if (i == 0) {
+                downBcList[i].headway = 0;
+            } else {
+                downBcList[i].headway = (downBcList[i].fcsj_time - downBcList[i - 1].fcsj_time) / 1000 / 60
+            }
+        }
+
+        // 删除 fcsj_time 属性
+        for (i = 0; i < upBcList.length; i++) {
+            delete upBcList[i].fcsj_time;
+        }
+        for (i = 0; i < downBcList.length; i++) {
+            delete downBcList[i].fcsj_time;
+        }
+
+        return {
+            upBcList : upBcList,
+            downBcList : downBcList
+        };
+    };
+
     return InternalExcelObj;
  
 } ());
 \ No newline at end of file
@@ -69,6 +69,39 @@ var Main_v2_2 = function() {
  
             $('.exportAddXls').off('click');
             $('.exportAddXlsx').off('click');
+            $('.exportHeadWayXlsx').off('click');
+
+            $('.exportHeadWayXlsx').on('click', function() {
+                // TOD：获取发车间隔信息
+                var lineHeadWayInfo = oExcel.fnGetBcHeadWayInfoList();
+
+                console.log(lineHeadWayInfo);
+
+                $(".exportAdd").addClass("disabled");
+                $(".exportAddSpan").html("正在导出...");
+
+                // 提交
+                $.ajax({
+                    type: 'POST',
+                    url: "/tidc/exportDTDFile2",
+                    dataType: 'binary',
+                    contentType: "application/json",
+                    data: JSON.stringify(lineHeadWayInfo),
+                    success: function(data){
+                        oExcel.downloadFile(data, "application/octet-stream", "时刻表发车间隔信息.xls");
+
+                        $(".exportAdd").removeClass("disabled");
+                        $(".exportAddSpan").html(" 导出数据");
+                    },
+                    error: function(xhr, type){
+                        alert('错误：TODO');
+
+                        $(".exportAdd").removeClass("disabled");
+                        $(".exportAddSpan").html(" 导出数据");
+                    }
+                });
+            });
+
  
             $('.exportAddXls').on('click', function() {