Update

徐烜
1 parent a2d14a12
Showing 10 changed files with 267 additions and 9 deletions
src/main/java/com/bsth/service/schedule/impl/SchedulePlanServiceImpl.java
src/main/java/com/bsth/service/schedule/rules/MyDroolsConfiguration.java
src/main/java/com/bsth/service/schedule/rules/validate/ValidRepeatBcFunction.java
src/main/java/com/bsth/service/schedule/rules/validate/ValidateParam.java
src/main/java/com/bsth/service/schedule/rules/validate/ValidateResults_output.java
src/main/resources/application-dev.properties
src/main/resources/rules/functions.drl
src/main/resources/rules/validplan.drl
src/main/resources/static/pages/scheduleApp/module/core/schedulePlanManage/list.html
src/main/resources/static/pages/scheduleApp/module/core/scheduleRuleManage/list.html
@@ -21,6 +21,9 @@ import com.bsth.service.schedule.rules.shiftloop.ScheduleRule_input;
 import com.bsth.service.schedule.rules.ttinfo.*;
 import com.bsth.service.schedule.rules.ttinfo2.CalcuParam;
 import com.bsth.service.schedule.rules.ttinfo2.Result;
+import com.bsth.service.schedule.rules.validate.ValidateParam;
+import com.bsth.service.schedule.rules.validate.ValidateResults_output;
+import org.apache.commons.lang3.StringUtils;
 import org.joda.time.DateTime;
 import org.kie.api.KieBase;
 import org.kie.api.runtime.KieSession;
@@ -321,6 +324,59 @@ public class SchedulePlanServiceImpl extends BServiceImpl&lt;SchedulePlan, Long&gt; im
     }
+    /**
+     * 验证排班结果。
+     * @param planResult
+     * @param schedulePlan
+     */
+    public void validPlanResult(PlanResult planResult, SchedulePlan schedulePlan) {
+        // 1-1、构造drools规则输入数据，输出数据
+        ValidateParam validateParam = new ValidateParam(
+                new DateTime(schedulePlan.getScheduleFromTime()),
+                new DateTime(schedulePlan.getScheduleToTime())
+        );
+        // 规则输出数据
+        ValidateResults_output result = new ValidateResults_output();
+
+        // 1-2、构造drools session->载入数据->启动规则->计算->销毁session
+        // 创建session，内部配置的是stateful
+        KieSession session = kieBase.newKieSession();
+
+        // 设置gloable对象，在drl中通过别名使用
+        session.setGlobal("validResult", result);
+        session.setGlobal("log", logger); // 设置日志
+
+        // 载入数据
+        session.insert(validateParam);
+        for (SchedulePlanInfo schedulePlanInfo: planResult.getSchedulePlanInfos()) {
+            session.insert(schedulePlanInfo);
+        }
+
+        // 执行rule
+        session.fireAllRules();
+
+        // 执行完毕销毁，有日志的也要关闭
+        session.dispose();
+
+//        for (ValidateResults_output.ValidInfo validInfo: result.getInfos()) {
+//            logger.info(validInfo.getDesc());
+//        }
+
+        // 取10条错误
+        int size = result.getInfos().size() > 10 ? 10: result.getInfos().size();
+        List<String> desclist = new ArrayList<>();
+        for (int i = 0; i < size; i++) {
+            desclist.add(result.getInfos().get(i).getDesc());
+        }
+        if (desclist.size() > 0) {
+            schedulePlan.setPlanResult(StringUtils.join(desclist, "</br>"));
+        } else {
+            schedulePlan.setPlanResult("ok");
+        }
+
+        // TODO：设定错误信息
+    }
+
     @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.READ_COMMITTED)
     public SchedulePlan save(SchedulePlan schedulePlan) {
         // pre、如果排班的数据之前已经有了，删除之前的数据
@@ -341,6 +397,9 @@ public class SchedulePlanServiceImpl extends BServiceImpl&lt;SchedulePlan, Long&gt; im
         // 3、确定套跑规则
         rerunPlanResult(planResult, schedulePlan);
+        // TODO：3-1、验证排班结果
+        validPlanResult(planResult, schedulePlan);
+
         // 4、保存数据（jdbcTemplate 批量插入）
         Date start4 = new Date();
         scheduleRuleService.generateSchedulePlan(schedulePlan, planResult.getSchedulePlanInfos());
@@ -74,6 +74,9 @@ public class MyDroolsConfiguration {
         kfs.write("src/main/resources/rerun.drl", kieServices.getResources()
                 .newInputStreamResource(this.getClass().getResourceAsStream(
                         "/rules/rerun.drl"), "UTF-8"));
+        kfs.write("src/main/resources/validplan.drl", kieServices.getResources()
+                .newInputStreamResource(this.getClass().getResourceAsStream(
+                        "/rules/validplan.drl"), "UTF-8"));
         // TODO：还有其他drl....
         // 4、创建KieBuilder，使用KieFileSystem构建
+package com.bsth.service.schedule.rules.validate;
+
+import com.bsth.entity.schedule.SchedulePlanInfo;
+import org.kie.api.runtime.rule.AccumulateFunction;
+
+import java.io.*;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 计算班次重复错误。
+ * 同一个路牌下，相同发车时间的班次数。
+ * 注意：使用这个函数时，要一天计算一次，多天计算无意义。
+ */
+public class ValidRepeatBcFunction implements AccumulateFunction {
+    @Override
+    public void writeExternal(ObjectOutput out) throws IOException {
+    }
+
+    @Override
+    public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+
+    }
+
+    protected static class RepeatBcInfo implements Externalizable {
+        /** 错误描述 */
+        public List<ValidateResults_output.ValidInfo> validInfoList = new ArrayList<>();
+        /** 内部计数Map，key：{路牌Id}_{发车时间}，value：个数 */
+        public Map<String, Integer> lpBcFcsjCount = new HashMap<>();
+
+        public RepeatBcInfo() {
+        }
+
+        @Override
+        public void writeExternal(ObjectOutput out) throws IOException {
+            out.writeObject(validInfoList);
+        }
+
+        @Override
+        public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+            validInfoList = (List<ValidateResults_output.ValidInfo>) in.readObject();
+        }
+    }
+
+    @Override
+    public Serializable createContext() {
+        return new RepeatBcInfo();
+    }
+
+    @Override
+    public void init(Serializable serializable) throws Exception {
+        // TODO：
+    }
+
+    @Override
+    public void accumulate(Serializable context, Object o) {
+        RepeatBcInfo repeatBcInfo = (RepeatBcInfo) context;
+        SchedulePlanInfo schedulePlanInfo = (SchedulePlanInfo) o;
+
+        String key = schedulePlanInfo.getLp() + "_" + schedulePlanInfo.getFcsj();
+        SimpleDateFormat sf = new SimpleDateFormat("yyyy年MM月dd日");
+        String infoformat = "日期(%s),路牌(%s),班次(%s),重复(%d)次";
+        if (repeatBcInfo.lpBcFcsjCount.get(key) == null) {
+            repeatBcInfo.lpBcFcsjCount.put(key, 1);
+        } else {
+            int count = repeatBcInfo.lpBcFcsjCount.get(key) + 1;
+            ValidateResults_output.ValidInfo validInfo = new ValidateResults_output.ValidInfo();
+            validInfo.setSd(schedulePlanInfo.getScheduleDate());
+            validInfo.setDesc(String.format(
+                    infoformat,
+                    sf.format(schedulePlanInfo.getScheduleDate()),
+                    schedulePlanInfo.getLpName(),
+                    schedulePlanInfo.getFcsj(),
+                    count));
+            repeatBcInfo.validInfoList.add(validInfo);
+            repeatBcInfo.lpBcFcsjCount.put(key, count);
+        }
+    }
+
+    @Override
+    public boolean supportsReverse() {
+        return false;
+    }
+
+    @Override
+    public void reverse(Serializable serializable, Object o) throws Exception {
+
+    }
+
+    @Override
+    public Class<?> getResultType() {
+        return List.class;
+    }
+
+    @Override
+    public Object getResult(Serializable context) throws Exception {
+        RepeatBcInfo repeatBcInfo = (RepeatBcInfo) context;
+        return repeatBcInfo.validInfoList;
+    }
+}
@@ -16,7 +16,9 @@ public class ValidateParam {
     /** 间隔天数 */
     private Integer days;
-    public ValidateParam() {
+    public ValidateParam(DateTime f, DateTime t) {
+        this.fromDate = f;
+        this.toDate = t;
         Period period = new Period(fromDate, toDate, PeriodType.days());
         days = period.getDays() + 1;
     }
@@ -10,7 +10,7 @@ import java.util.List;
 public class ValidateResults_output {
     private List<ValidInfo> infos = new ArrayList<>();
-    static class ValidInfo {
+    public static class ValidInfo {
         /** 日期 */
         private Date sd;
         /** 描述 */
@@ -10,7 +10,7 @@ spring.jpa.show-sql= true
 spring.datasource.driver-class-name= com.mysql.jdbc.Driver
 spring.datasource.url= jdbc:mysql://127.0.0.1/control?useUnicode=true&characterEncoding=utf-8&useSSL=false
 spring.datasource.username= root
-spring.datasource.password= root
+spring.datasource.password=
 #DATASOURCE
 spring.datasource.max-active=100
@@ -4,4 +4,5 @@ import accumulate com.bsth.service.schedule.rules.ttinfo2.ErrorBcCountFunction e
 import accumulate com.bsth.service.schedule.rules.shiftloop.GidsCountFunction gidscount;
 import accumulate com.bsth.service.schedule.rules.shiftloop.GidFbTimeFunction gidfbtime;
 import accumulate com.bsth.service.schedule.rules.ttinfo.LpInfoResultsFunction lpinforesult;
-import accumulate com.bsth.service.schedule.rules.ttinfo.MinRuleQyrqFunction minruleqyrq
 \ No newline at end of file
+import accumulate com.bsth.service.schedule.rules.ttinfo.MinRuleQyrqFunction minruleqyrq;
+import accumulate com.bsth.service.schedule.rules.validate.ValidRepeatBcFunction vrb;
 \ No newline at end of file
-// TODO：
 \ No newline at end of file
+package com.bsth.service.schedule.rules.validate;
+
+import com.bsth.entity.schedule.SchedulePlanInfo;
+
+import org.joda.time.*;
+import java.util.*;
+
+import org.slf4j.Logger;
+
+// 全局日志类（一般使用调用此规则的service类）
+global Logger log;
+
+// 输出
+global ValidateResults_output validResult;
+
+//------------------------- 第一阶段、构造循环体 ----------------------------//
+
+declare Loop_param
+    start_date: DateTime // 开始日期（这个要不停的更新迭代）
+    end_date: DateTime // 结束日期
+    sdays: Integer // 总共循环的天数
+end
+
+rule "Calcu_Loop_param"
+    salience 1000
+    when
+        ValidateParam(
+            $fd: fromDate,
+            $ed: toDate,
+            $days: days
+        )
+    then
+        Loop_param p = new Loop_param();
+        p.setStart_date($fd);
+        p.setEnd_date($ed);
+        p.setSdays($days);
+
+        insert(p);
+end
+
+//------------------------- 第二阶段、验证计算 ----------------------------//
+
+
+rule "Valid_repeat_bc" // 验证是否存在重复班次
+    salience 600
+    when
+        $lp: Loop_param($sd: start_date, $ed: end_date)
+        eval($sd.isBefore($ed) || $sd.isEqual($ed))
+        $spiList: ArrayList() from collect (SchedulePlanInfo(scheduleDate.getTime() == $sd.millis))
+        $infos: ArrayList() from accumulate ($spi: SchedulePlanInfo() from $spiList, vrb($spi))
+    then
+        // TODO：
+//        log.info("日期={}，班次重复错误数={}", $sd, $infos.size());
+
+        validResult.getInfos().addAll($infos);
+
+        // 迭代
+        $lp.setStart_date($sd.plusDays(1));
+        update($lp);
+
+end
+
+
+
+
+
+
+
+
@@ -9,7 +9,8 @@
                 <th style="width: 100%;">关联时刻表</th>
                 <th style="width: 150px;">排班开始日期</th>
                 <th style="width: 150px;">排班结束日期</th>
-                <th style="width: 250px;">排班人/操作时间</th>
+                <th style="width: 150px;">排班人/操作时间</th>
+                <th style="width: 100px;">状态</th>
                 <th style="width: 180px;">操作</th>
             </tr>
             <tr role="row" class="filter">
@@ -60,6 +61,7 @@
                     </div>
                 </td>
                 <td></td>
+                <td></td>
                 <td>
                     <button class="btn btn-sm green btn-outline filter-submit margin-bottom"
                             ng-click="ctrl.doPage()">
@@ -94,9 +96,28 @@
                     <span ng-bind="info.scheduleToTime | date: 'yyyy-MM-dd '"></span>
                 </td>
                 <td>
-                    <span ng-bind="info.updateBy.userName"></span>
-                    /
-                    <span ng-bind="info.updateDate | date: 'yyyy-MM-dd HH:mm:ss'"></span>
+                    <div>
+                        <a href="#">
+                            <i class="fa fa-user"></i>
+                            <span ng-bind="info.updateBy.userName"></span>
+                        </a>
+                    </div>
+                    <div>
+                        <a href="#">
+                            <span ng-bind="info.updateDate | date: 'yyyy-MM-dd HH:mm:ss'"></span>
+                        </a>
+                    </div>
+
+                </td>
+                <td>
+                    <a href="#" class="btn btn-success btn-sm" ng-if="info.planResult == 'ok'">
+                        <span>成功</span>
+                    </a>
+                    <a sweetalert
+                       sweet-options="{title: '排班错误信息',text: '线路：' + info.xl.name + '</br>开始时间：' + ctrl.toDateStr(info.scheduleFromTime) + '</br>结束时间：' + ctrl.toDateStr(info.scheduleToTime) + '</br>' + info.planResult, html: true,type: 'warning',showCancelButton: true,confirmButtonColor: '#DD6B55',confirmButtonText: '是',cancelButtonText: '取消'}"
+                       sweet-on-confirm=""
+                       class="btn btn-danger btn-sm"
+                       ng-if="info.planResult != 'ok'">点击查错</a>
                 </td>
                 <td>
                     <!--<a href="details.html?lineId={{obj.id}}" class="btn default blue-stripe btn-sm"> 详细 </a>-->
@@ -66,6 +66,7 @@
                 <td>
                     <div>
                         <a href="#">
+                            <i class="fa fa-user"></i>
                             <span ng-bind="info.updateBy.userName"></span>
                         </a>
                     </div>