update...

潘钊
1 parent da807888
Showing 8 changed files with 273 additions and 32 deletions
src/main/java/com/bsth/controller/realcontrol/anomalyCheckController.java
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
src/main/resources/fatso/handle_real_ctl.js
src/main/resources/fatso/package.json
src/main/resources/fatso/parse.js
src/main/resources/fatso/start.js
src/main/resources/static/real_control_v2/js/line_schedule/sch_table.js
src/main/resources/static/real_control_v2/main.html
+package com.bsth.controller.realcontrol;
+
+import com.bsth.data.schedule.DayOfSchedule;
+import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * 相关数据异常检测
+ * Created by panzhao on 2017/4/14.
+ */
+@RestController
+@RequestMapping("anomalyCheck")
+public class anomalyCheckController {
+
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    DayOfSchedule dayOfSchedule;
+    /**
+     * 出现重复班次的车辆
+     * @param nbbm
+     */
+    @RequestMapping(value = "/schRepeat", method = RequestMethod.POST)
+    public void schRepeat(@RequestParam String nbbm){
+        logger.info("前端通知，车辆 " + nbbm + "出现重复班次，开始检测...");
+        List<ScheduleRealInfo> list = dayOfSchedule.findByNbbm(nbbm);
+
+        Set<ScheduleRealInfo> set = new HashSet<>();
+        for(ScheduleRealInfo sch : list){
+            if(!set.add(sch)){
+                logger.info("出现一次重复班次，班次ID：" + sch.getId());
+            }
+        }
+
+        if(set.size() > 0){
+            dayOfSchedule.replaceByNbbm(nbbm, set);
+        }
+    }
+}
@@ -902,4 +902,16 @@ public class DayOfSchedule implements CommandLineRunner {
         }
         return rs;
     }
+
+    /**
+     * 覆盖一辆车的所有班次
+     * @param nbbm
+     * @param sets
+     */
+    public void replaceByNbbm(String nbbm, Set<ScheduleRealInfo> sets){
+        nbbmScheduleMap.removeAll(nbbm);
+        nbbmScheduleMap.putAll(nbbm, sets);
+        //重新计算班次应到时间
+        updateQdzTimePlan(nbbm);
+    }
 }
 \ No newline at end of file
+/**
+ * 处理线调文件
+ */
+var fs = require('fs')
+    ,cheerio = require('cheerio')
+    ,minifier = require('./minifier')
+    ,crypto = require("crypto")
+    ,CleanCSS = require('clean-css')
+    ,UglifyJS = require("uglify-js");;
+
+//不参与的目录
+var pName = 'bsth_control'
+    ,path = process.cwd()
+    //根目录
+    ,root = path.substr(0, path.indexOf('\\src\\main'))
+    ,workspace = root.substr(0, root.indexOf('\\' + pName))
+    //临时目录
+    ,dest = (workspace + '\\' + pName+'@fatso_copy').replace(/\//g,'\\')
+    ,_static = '\\src\\main\\resources\\static';
+
+
+var mainFile = dest + _static + '\\real_control_v2\\main.html';
+var realCtl = {
+    /**
+     * 处理线调首页
+     */
+    handleMain: function(cb){
+        //读取文件
+        var data = fs.readFileSync(mainFile, 'utf-8')
+            ,$ = cheerio.load(data);
+
+        handleCss($, function () {
+            handleJs($, cb);
+        });
+    }
+};
+
+/**
+ * 处理css
+ * @type {any}
+ */
+var handleCss = function ($, cb) {
+    var cssArray = $('link[rel=stylesheet][merge]');
+    //按 merge 值分组
+    var cssMap = {}, mergeName;
+    for(var i = 0, c; c = cssArray[i++];){
+        mergeName = $(c).attr('merge');
+        if(!cssMap[mergeName])
+            cssMap[mergeName] = [];
+        cssMap[mergeName].push(dest + _static + $(c).attr('href'));
+        //remove
+        $(c).remove();
+    }
+    //按 merge 合并压缩css
+    var ks = get_keys(cssMap), index=0;
+    (function () {
+        if(index >= ks.length){
+            cb && cb();
+            return;
+        }
+        var k = ks[index];
+        index ++;
+        var f = arguments.callee;
+        //合并css
+        new CleanCSS().minify(cssMap[k], function (error, out) {
+            var data = out.styles;
+            var fName = (k + '_' + md5(data)) + '.css';
+            //写入 assets css 目录下
+            var descFile = dest + _static + '\\real_control_v2\\assets\\css\\' + fName;
+            fs.open(descFile, 'a',  function(err, fd){
+
+                fs.write(fd, data, function(){
+                    $('head').append('<link rel="stylesheet" href="/real_control_v2/assets/css/'+fName+'"/>');
+                    console.log(k + ' css', '结束，下一个');
+                    f();
+                });
+            });
+        });
+    })();
+};
+
+/**
+ * 处理js
+ */
+var handleJs = function ($, cb) {
+    var scriptArray = $('script[merge]');
+    //按 merge 值分组
+    var jsMap = {}, mergeName;
+    for(var i = 0, s; s = scriptArray[i++];){
+        mergeName = $(s).attr('merge');
+        if(!jsMap[mergeName])
+            jsMap[mergeName] = [];
+        jsMap[mergeName].push(dest + _static + $(s).attr('src'));
+        //remove
+        $(s).remove();
+    }
+
+    //按 merge 合并压缩js
+    var ks = get_keys(jsMap), index=0;
+    (function () {
+        if(index >= ks.length){
+            write(mainFile, $.html());
+            console.log('线调处理结束'.green);
+            cb && cb();
+            return;
+        }
+        var k = ks[index];
+        index ++;
+        var f = arguments.callee;
+        //合并压缩js
+        var result = UglifyJS.minify(jsMap[k]);
+        var data = result.code;
+        var fName = (k + '_' + md5(data)) + '.js';
+        //写入 assets js 目录下
+        var descFile = dest + _static + '\\real_control_v2\\assets\\js\\' + fName;
+        fs.open(descFile, 'a',  function(err, fd){
+
+            fs.write(fd, data, function(){
+                $('body').append('<script src="/real_control_v2/assets/js/'+fName+'"></script>');
+                console.log(k + ' js', '结束，下一个');
+                f();
+            });
+        });
+    })();
+};
+
+var get_keys = function (json) {
+    var array = [];
+    for (var key in json) {
+        array.push(key);
+    }
+    return array;
+};
+
+function md5(text){
+    return crypto.createHash("md5").update(text).digest("hex");
+}
+
+function write(file, text){
+    fs.writeFile(file, text, function (err) {
+        if (err){
+            console.log(err.toString().red);
+            process.exit();
+        }
+        console.log(file.green);
+    });
+}
+
+
+module.exports = realCtl;
 \ No newline at end of file
-{
-  "name": "fatso",
-  "version": "1.0.0",
-  "description": "子页面js检查、合并、压缩等处理",
-  "main": "start.js",
-  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
-  },
-  "author": "panzhaov5",
-  "license": "ISC",
-  "dependencies": {
-    "cheerio": "^0.20.0",
-    "colors": "^1.1.2",
-    "eventproxy": "^0.3.4",
-    "uglify-js": "^2.6.2"
-  }
-}
+{
+  "name": "fatso",
+  "version": "1.0.0",
+  "description": "子页面js检查、合并、压缩等处理",
+  "main": "start.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "panzhaov5",
+  "license": "ISC",
+  "dependencies": {
+    "cheerio": "^0.20.0",
+    "clean-css": "^4.0.12",
+    "colors": "^1.1.2",
+    "eventproxy": "^0.3.4",
+    "uglify-js": "^2.6.2"
+  }
+}
@@ -51,7 +51,7 @@ var parse = {
 		}
 		return {jsArray: linkArray, $: $, scriptString: scriptString};
 	}
-}
+};
 function md5(text){
@@ -8,7 +8,8 @@ var fs = require(&#39;fs&#39;)
 	,EventProxy = require('eventproxy')
 	,parse = require('./parse')
 	,minifier = require('./minifier')
-	,crypto = require("crypto");
+	,crypto = require("crypto")
+	,handle_real_ctl = require('./handle_real_ctl');
 //不参与的目录
 var excludes = ['scheduleApp', 'trafficManage', 'control']
@@ -74,15 +75,18 @@ ep.tail(&#39;check-js&#39;, function(){
 //合并压缩JS
 ep.tail('minifier-js', function(){
 	logInfo('handle index.html...');
-	
-	//先处理首页
+
+	//再处理首页
 	ep.emit('handle-index', function(){
 		//递归处理片段
 		walk(dest + _static + '\\pages', function(item){
 			ep.emit('handle-fragment', item);
 		},
 		function(){
-			ep.emit('package-jar');
+			//处理线调
+			handle_real_ctl.handleMain(function () {
+				ep.emit('package-jar');
+			});
 		});
 	});
 });
@@ -11,6 +11,27 @@ var gb_schedule_table = (function () {
         return s1.fcsjT - s2.fcsjT;
     };
+    /**
+     * 检查是否存在重复班次
+     * @param list
+     */
+    var isRepeatData = function (list) {
+        var map = {}, reps = [];
+        for(var i = 0,sch;sch=list[i++];){
+            if(map[sch.id]){
+                reps.push(sch.clZbh);
+            }
+            map[sch.id] = sch;
+        }
+
+        //通知服务端数据有异常
+        $.each(reps, function () {
+            $.post('/anomalyCheck/schRepeat', {nbbm: this});
+        });
+
+        return gb_common.get_vals(map);
+    };
+
     var show = function (cb) {
         //从服务器获取班次数据
         $.get('/realSchedule/lines', {
@@ -20,6 +41,9 @@ var gb_schedule_table = (function () {
                 //排序
                 rs[lineCode].sort(schedule_sort);
                 line2Schedule[lineCode] = {};
+                //------是否有重复班次 #临时代码，为服务端提供诊断信息已解决这个问题
+                rs[lineCode] = isRepeatData(line2Schedule[lineCode]);
+
                 //calc shift
                 $.each(rs[lineCode], function () {
                     calc_sch_real_shift(this);
@@ -32,7 +32,7 @@
     <link rel="stylesheet" href="/real_control_v2/assets/plugins/jstree/default/style.min.css"/>
     <!-- tooltip css-->
     <link rel="stylesheet" href="/real_control_v2/assets/plugins/qtip/jquery.qtip.min.css"/>
-    <link rel="stylesheet" href="/real_control_v2/css/pace.css"/>
+    <link rel="stylesheet" href="/real_control_v2/css/pace.css" merge="custom_style"/>
     <link rel="stylesheet" href="/real_control_v2/css/modal_extend.css" merge="custom_style"/>
 </head>
@@ -100,9 +100,9 @@
 <!-- jquery -->
 <script src="/real_control_v2/assets/js/jquery.min.js"></script>
 <!-- jquery actual -->
-<script src="/real_control_v2/assets/js/jquery.actual.min.js"></script>
+<script src="/real_control_v2/assets/js/jquery.actual.min.js" merge="plugins"></script>
 <!-- jquery.serializejson JSON序列化插件 -->
-<script src="/assets/plugins/jquery.serializejson.js"></script>
+<script src="/assets/plugins/jquery.serializejson.js"  merge="plugins"></script>
 <!-- moment.js 日期处理类库 -->
 <script src="/assets/plugins/moment-with-locales.js"></script>
 <!-- common js -->
@@ -126,18 +126,18 @@
 <script src="/real_control_v2/assets/plugins/uikit-2.27.1/components/lightbox.min.js" merge="uikit_js"></script>
 <!-- jquery contextMenu -->
-<script src="/real_control_v2/assets/js/jquery.contextMenu.min.js"></script>
-<script src="/real_control_v2/assets/js/jquery.ui.position.min.js"></script>
+<script src="/real_control_v2/assets/js/jquery.contextMenu.min.js"  merge="plugins"></script>
+<script src="/real_control_v2/assets/js/jquery.ui.position.min.js"  merge="plugins"></script>
 <!-- formvalidation- -->
-<script src="/real_control_v2/assets/plugins/formvalidation/formValidation.min.js"></script>
-<script src="/real_control_v2/assets/plugins/formvalidation/zh_CN.js"></script>
-<script src="/real_control_v2/assets/plugins/formvalidation/uikit.min.js"></script>
+<script src="/real_control_v2/assets/plugins/formvalidation/formValidation.min.js"  merge="plugins"></script>
+<script src="/real_control_v2/assets/plugins/formvalidation/zh_CN.js"  merge="plugins"></script>
+<script src="/real_control_v2/assets/plugins/formvalidation/uikit.min.js"  merge="plugins"></script>
 <!-- js tree -->
-<script src="/real_control_v2/assets/plugins/jstree/jstree.min.js"></script>
+<script src="/real_control_v2/assets/plugins/jstree/jstree.min.js"  merge="plugins"></script>
 <!-- simple pinyin -->
 <script src="/assets/plugins/pinyin.js"></script>
 <!-- qtip -->
-<script src="/real_control_v2/assets/plugins/qtip/jquery.qtip.min.js"></script>
+<script src="/real_control_v2/assets/plugins/qtip/jquery.qtip.min.js" merge="plugins"></script>
 <!-- 数据 -->
 <script src="/real_control_v2/js/data/data_basic.js" merge="custom_js"></script>