Update

徐烜
1 parent 0b686385
Showing 4 changed files with 95 additions and 4 deletions
src/main/java/com/bsth/service/schedule/rules/shiftloop/GidFbFcnoFunction.java
src/main/java/com/bsth/service/schedule/rules/shiftloop/readme.txt
src/main/resources/rules/functions.drl
src/main/resources/rules/plan.drl
+package com.bsth.service.schedule.rules.shiftloop;
+
+import com.bsth.entity.schedule.TTInfoDetail;
+import org.kie.api.runtime.rule.AccumulateFunction;
+
+import java.io.*;
+
+/**
+ * 时刻表路牌下的分班班次发车顺序号。
+ */
+public class GidFbFcnoFunction implements AccumulateFunction {
+    @Override
+    public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+    }
+
+    @Override
+    public void writeExternal(ObjectOutput out) throws IOException {
+    }
+
+    protected static class GidFbInfoData implements Externalizable {
+        public Integer fbfcno;
+        public TTInfoDetail ttInfoDetail;
+
+        public GidFbInfoData() {}
+
+        @Override
+        public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+            fbfcno = (Integer) in.readObject();
+            ttInfoDetail = (TTInfoDetail) in.readObject();
+        }
+
+        @Override
+        public void writeExternal(ObjectOutput out) throws IOException {
+            out.writeObject(fbfcno);
+            out.writeObject(ttInfoDetail);
+        }
+    }
+
+    @Override
+    public Serializable createContext() {
+        return new GidFbInfoData();
+    }
+
+    @Override
+    public void init(Serializable context) throws Exception {
+        GidFbInfoData gidFbInfoData = (GidFbInfoData) context;
+        gidFbInfoData.fbfcno = 999;
+    }
+
+    @Override
+    public void accumulate(Serializable context, Object value) {
+        GidFbInfoData gidFbInfoData = (GidFbInfoData) context;
+        TTInfoDetail ttInfoDetail = (TTInfoDetail) value;
+
+        // 1块路牌有多个分班班次，取最早的时间作为起始分班班次发车顺序号
+        if (ttInfoDetail.getIsFB()) {
+            if (ttInfoDetail.getFcno() <= gidFbInfoData.fbfcno) {
+                gidFbInfoData.fbfcno = ttInfoDetail.getFcno();
+            }
+        }
+    }
+
+    @Override
+    public void reverse(Serializable serializable, Object o) throws Exception {
+
+    }
+
+    @Override
+    public boolean supportsReverse() {
+        return false;
+    }
+
+    @Override
+    public Class<?> getResultType() {
+        return Integer.class;
+    }
+
+    @Override
+    public Object getResult(Serializable context) throws Exception {
+        GidFbInfoData gidFbInfoData = (GidFbInfoData) context;
+
+        return gidFbInfoData.fbfcno;
+    }
+
+}
-翻班循环规则
 \ No newline at end of file
@@ -3,6 +3,7 @@ package com.bsth.service.schedule;
 import accumulate com.bsth.service.schedule.rules.ttinfo2.ErrorBcCountFunction ecount;
 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.shiftloop.GidFbFcnoFunction gidfbfcno;
 import accumulate com.bsth.service.schedule.rules.ttinfo.LpInfoResultsFunction lpinforesult;
 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
@@ -224,6 +224,7 @@ declare TTInfo_gid_stat
     maxFcno: Integer // 最大发车顺序号
  
     fbTime: LocalTime // 分班时间
+    fbfcno: Integer // 分班发车顺序号
 end
  
 rule "calcu_TTInfo_gid_stat"
@@ -234,6 +235,7 @@ rule &quot;calcu_TTInfo_gid_stat&quot;
         $gids: List() from accumulate ($ttd: TTInfoDetail() from tTInfoDetailRepository.findByTtinfoId(Long.parseLong($ttInfoId)), gidscount($ttd))
         $gid: String() from $gids
         $fbtime_str: String() from accumulate ($ttd: TTInfoDetail(lp.id.toString() == $gid) from tTInfoDetailRepository.findByTtinfoId(Long.parseLong($ttInfoId)), gidfbtime($ttd))
+        $fbfcno: Integer() from accumulate ($ttd: TTInfoDetail(lp.id.toString() == $gid) from tTInfoDetailRepository.findByTtinfoId(Long.parseLong($ttInfoId)), gidfbfcno($ttd))
         $maxfcno: Double() from accumulate ($ttd: TTInfoDetail(lp.id.toString() == $gid) from tTInfoDetailRepository.findByTtinfoId(Long.parseLong($ttInfoId)), max($ttd.getFcno()))
     then
         TTInfo_gid_stat ttInfo_gid_stat = new TTInfo_gid_stat();
@@ -243,11 +245,12 @@ rule &quot;calcu_TTInfo_gid_stat&quot;
  
         ttInfo_gid_stat.setMaxFcno($maxfcno.intValue());
         ttInfo_gid_stat.setFbTime(fcsjTime($fbtime_str));
+        ttInfo_gid_stat.setFbfcno($fbfcno);
  
         insert(ttInfo_gid_stat);
  
-//        log.info("xlid={},ttid={},gid={},maxfcno={},fbtime={}",
-//            $xlId, $ttInfoId, $gid, ttInfo_gid_stat.getMaxFcno(), ttInfo_gid_stat.getFbTime());
+//        log.info("xlid={},ttid={},gid={},maxfcno={},fbtime={},fbfcno={}",
+//            $xlId, $ttInfoId, $gid, ttInfo_gid_stat.getMaxFcno(), ttInfo_gid_stat.getFbTime(), ttInfo_gid_stat.getFbfcno());
  
 end
  
@@ -304,7 +307,10 @@ rule &quot;calcu_TTInfoDetail_Wraps&quot;
  
             LocalTime fcsj = fcsjTime(ttInfoDetail.getFcsj());
             LocalTime fbsj = ttInfo_gid_stat.getFbTime();
-            ttInfoDetail_wrap.setIsFb(fbsj == null ? false : (fcsj.isEqual(fbsj) || fcsj.isAfter(fbsj)));
+            Integer fbfcno = ttInfo_gid_stat.getFbfcno();
+            // 不用时间判定，因为有的路牌，后面的班次都是凌晨的，时间反而比分班时间早，不合理，所以使用发车顺序号做第二次比较
+//            ttInfoDetail_wrap.setIsFb(fbsj == null ? false : (fcsj.isEqual(fbsj) || fcsj.isAfter(fbsj)));
+            ttInfoDetail_wrap.setIsFb(fbsj == null ? false : ttInfoDetail.getFcno() >= fbfcno);
  
             ttInfoDetail_wrap.setSelf(ttInfoDetail);