update

潘钊
2 parents edbc2ac2 c1567544
Showing 13 changed files with 859 additions and 830 deletions
src/main/java/com/bsth/repository/oil/YlbRepository.java
src/main/java/com/bsth/repository/oil/YlxxbRepository.java
src/main/java/com/bsth/repository/realcontrol/ScheduleRealInfoRepository.java
src/main/java/com/bsth/service/oil/impl/DlbServiceImpl.java
src/main/java/com/bsth/service/oil/impl/YlbServiceImpl.java
src/main/java/com/bsth/service/realcontrol/ScheduleRealInfoService.java
src/main/java/com/bsth/service/realcontrol/impl/ScheduleRealInfoServiceImpl.java
src/main/java/com/bsth/service/schedule/rules/plan/PlanCalcuParam_input.java
src/main/java/com/bsth/service/schedule/rules/plan/PlanResult.java
src/main/java/com/bsth/service/schedule/rules/plan/readme.txt
src/main/resources/rules/plan.drl
src/main/resources/rules/shiftloop_fb.drl
src/test/java/com/bsth/service/schedule/rules/DroolsRulesTest2.java
@@ -23,8 +23,9 @@ public interface YlbRepository extends BaseRepository&lt;Ylb, Integer&gt;{
 	@Modifying
 	@Query(value="SELECT a.*  FROM bsth_c_ylb a   where to_days(?1)-to_days(a.rq)=1"
 			+ " and jcsx=(select max(b.jcsx)  from  bsth_c_ylb b where a.nbbm=b.nbbm and "
-			+ " to_days(?1)-to_days(b.rq)=1 )",nativeQuery=true)
-	List<Ylb> obtainYlbefore(String rq);
+			+ " to_days(?1)-to_days(b.rq)=1 ) and ssgsdm like %?2%  and fgsdm like %?3% and "
+			+ " xlbm like %?4% and nbbm like %?5% ",nativeQuery=true)
+	List<Ylb> obtainYlbefore(String rq,String gsbm,String fgsbm,String xlbm,String nbbm);
 	/**
 	 * 当天YLB信息
@@ -50,6 +51,6 @@ public interface YlbRepository extends BaseRepository&lt;Ylb, Integer&gt;{
 	 */
 	@Transactional
 	@Modifying
-	@Query(value="select sum(jzl) as jzl,sum(zlc) as zlc ,sum(sh) as sh from bsth_c_ylb where  nbbm=?1 and rq=?2",nativeQuery=true)
-	List<Object[]> sumLcYl(String nbbm,Date rq);
+	@Query(value="select sum(jzl) as jzl,sum(zlc) as zlc ,sum(sh) as sh from bsth_c_ylb where  nbbm=?1 and rq=?2 and xlbm like %?3%",nativeQuery=true)
+	List<Object[]> sumLcYl(String nbbm,Date rq,String xlbm);
 }
@@ -19,8 +19,8 @@ public interface YlxxbRepository extends BaseRepository&lt;Ylxxb, Integer&gt;{
 	 */
 	@Transactional
 	@Modifying
-	@Query(value="SELECT * FROM bsth_c_ylxxb  where to_days(?1)=to_days(yyrq) and nylx=?2",nativeQuery=true)
-	List<Ylxxb> obtainYlxx(String rq,int nylx);
+	@Query(value="SELECT * FROM bsth_c_ylxxb  where to_days(?1)=to_days(yyrq) and nylx=?2 and gsdm like %?3%",nativeQuery=true)
+	List<Ylxxb> obtainYlxx(String rq,int nylx,String gsdm);
 	@Transactional
 	@Modifying
@@ -92,7 +92,7 @@ public interface ScheduleRealInfoRepository extends BaseRepository&lt;ScheduleRealI
 	@Query(value="select s from ScheduleRealInfo s where  s.clZbh = ?1  and s.scheduleDate = str_to_date(?2,'%Y-%m-%d') and xlBm =?3 order by realExecDate,fcsj")
 	List<ScheduleRealInfo> queryListWaybill2(String clZbh,String date,String line);
-	@Query(value="select s from ScheduleRealInfo s where s.jGh = ?1 and s.clZbh = ?2 and s.scheduleDate = str_to_date(?3,'%Y-%m-%d') order by realExecDate,fcsj")
+	@Query(value="select s from ScheduleRealInfo s where s.jGh like %?1% and s.clZbh like %?2% and s.scheduleDate = str_to_date(?3,'%Y-%m-%d') order by realExecDate,fcsj")
 	List<ScheduleRealInfo> queryListWaybill3(String jName,String clZbh,String date);
 	@Query(value="select s from ScheduleRealInfo s where s.jName = ?1 and s.clZbh = ?2  and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') between str_to_date(?3,'%Y-%m-%d') and str_to_date(?4,'%Y-%m-%d')  order by bcs")
@@ -127,8 +127,8 @@ public interface ScheduleRealInfoRepository extends BaseRepository&lt;ScheduleRealI
 	@Query(value="select s from ScheduleRealInfo s where s.xlBm like %?1%  and DATE_FORMAT(s.scheduleDate,'%Y-%m') = ?2 and s.bcType not in ('in','out') order by s.xlBm")
 	List<ScheduleRealInfo> scheduleByDateAndLine3(String line,String date);
-	@Query(value="select new map(s.scheduleDate as scheduleDate,s.xlBm as xlBm,s.clZbh as clZbh,s.jGh as jGh) from ScheduleRealInfo s where s.xlBm like %?1% and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 GROUP BY xlBm,clZbh,jGh,scheduleDate,jGh ORDER BY xlBm,clZbh")
-	List<Map<String,Object>> yesterdayDataList(String line,String date);
+	@Query(value="select new map(s.scheduleDate as scheduleDate,s.xlBm as xlBm,s.clZbh as clZbh,s.jGh as jGh) from ScheduleRealInfo s where s.xlBm like %?1% and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 and s.gsBm like %?3% and s.fgsBm like %?4%  GROUP BY xlBm,clZbh,jGh,scheduleDate,jGh ORDER BY xlBm,clZbh")
+	List<Map<String,Object>> yesterdayDataList(String line,String date,String gsbm,String fgsbm);
 	@Query(value="select s from ScheduleRealInfo s where DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?1 ORDER BY xlBm,lpName,clZbh,xlDir")
 	List<ScheduleRealInfo> setLD(String date);
@@ -77,6 +77,10 @@ public class DlbServiceImpl extends BaseServiceImpl&lt;Dlb,Integer&gt; implements DlbS
 			 Cars c=carsList.get(i);
 			 carsMap.put(c.getInsideCode(), c.getSfdc());
 		}
+		 String gsbm="";
+			if(map2.get("ssgsdm_like")!=null){
+				gsbm=map2.get("ssgsdm_like").toString();
+			}
 		String rq=map2.get("rq").toString();
 		String line="";
 		if(map2.get("xlbm_eq")!=null){
@@ -91,14 +95,14 @@ public class DlbServiceImpl extends BaseServiceImpl&lt;Dlb,Integer&gt; implements DlbS
 		//当天DLB信息
 		List<Dlb> dlList=repository.obtainDl(rq);
 		//当天YLXXB信息
-		List<Ylxxb> ylxxList=ylxxbRepository.obtainYlxx(rq,1);
+		List<Ylxxb> ylxxList=ylxxbRepository.obtainYlxx(rq,1,gsbm);
 		//当天加电信息表
 		List<Jdl> jdlList=jdlRepository.JdlList(rq);
 		//前一天所有车辆最后进场班次信息
 		List<Dlb> dlListBe=repository.obtainYlbefore(rq);
 		List<Cdl> cdyList=cdlRepository.obtainCdl();
 		//从排班表中计算出行驶的总里程
-		List<Map<String,Object>> listpb=scheduleRealInfoService.yesterdayDataList(line,rq);
+		List<Map<String,Object>> listpb=scheduleRealInfoService.yesterdayDataList(line,rq,"","","","");
 		List<Ylb> addList=new ArrayList<Ylb>();
 		List<Ylb> updateList=new ArrayList<Ylb>();
 		for(int x=0;x<listpb.size();x++){
@@ -244,14 +248,17 @@ public class DlbServiceImpl extends BaseServiceImpl&lt;Dlb,Integer&gt; implements DlbS
 	public Map<String, Object> checkDl(Map<String, Object> map) {
 		Map<String, Object> newMap=new HashMap<String,Object>();
 		String xlbm=map.get("xlbm_eq").toString();
-		
+		String gsbm="";
+		if(map.get("ssgsdm_like")!=null){
+			gsbm=map.get("ssgsdm_like").toString();
+		}
 		// TODO Auto-generated method stub
 		try{
 			//获取车辆存油信息
 //			List<Cyl> cylList=cylRepository.findAll(new CustomerSpecs<Cyl>(newMap));
 			String rq=map.get("rq").toString();
 			List<Dlb> dlbList=repository.obtainDl(rq);
-			List<Ylxxb> ylxxbList=ylxxbRepository.obtainYlxx(rq,1);
+			List<Ylxxb> ylxxbList=ylxxbRepository.obtainYlxx(rq,1,gsbm);
 			//当天加电信息表
 			List<Jdl> jdlList=jdlRepository.JdlList(rq);
 			for (int i = 0; i < ylxxbList.size(); i++) {
@@ -97,10 +97,10 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 			//当天YLXXB信息
 	//		List<Ylxxb> ylxxList=ylxxbRepository.obtainYlxx(rq);
 			//前一天所有车辆最后进场班次信息
-			List<Ylb> ylListBe=repository.obtainYlbefore(rq);
+			List<Ylb> ylListBe=repository.obtainYlbefore(rq,"","","","");
 			List<Cyl> clyList=cylRepository.obtainCyl("","");
 			//从排班表中计算出行驶的总里程
-			List<Map<String,Object>> listpb=scheduleRealInfoService.yesterdayDataList("",rq);
+			List<Map<String,Object>> listpb=scheduleRealInfoService.yesterdayDataList("", rq, "", "", "", "");
 			for(int x=0;x<listpb.size();x++){
 				boolean sfdc=true;
@@ -222,14 +222,15 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 			// 当天YLB信息
 			List<Ylb> ylList = repository.obtainYl(rq,gsbm,fgsbm,line,nbbm,"nbbm");
 			// 当天YLXXB信息
-			List<Ylxxb> ylxxList = ylxxbRepository.obtainYlxx(rq, 0);
+			List<Ylxxb> ylxxList = ylxxbRepository.obtainYlxx(rq, 0,gsbm);
 			// 前一天所有车辆最后进场班次信息
-			List<Ylb> ylListBe = repository.obtainYlbefore(rq);
+			List<Ylb> ylListBe = repository.obtainYlbefore(rq, gsbm, fgsbm, line, nbbm);
 			List<Cyl> clyList = cylRepository.obtainCyl(nbbm,gsbm);
 			// 从排班表中计算出行驶的总里程
-			List<Map<String, Object>> listpb = scheduleRealInfoService.yesterdayDataList(line, rq);
+			List<Map<String, Object>> listpb = scheduleRealInfoService.yesterdayDataList(line, rq, gsbm, fgsbm, "", nbbm);
 			List<Ylb> addList = new ArrayList<Ylb>();
 			List<Ylb> updateList = new ArrayList<Ylb>();
+			String ins="";
 			for (int x = 0; x < listpb.size(); x++) {
 				String type = "add";
 				boolean sfdc = true;
@@ -312,29 +313,34 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 					t.setSsgsdm(map.get("company") == null ? "" : map.get("company").toString());
 					t.setFgsdm(map.get("bCompany") == null ? "" : map.get("bCompany").toString());
 					t.setRq(sdf.parse(rq));
-					/*
-					 * if(type.equals("add")){ addList.add(t); }else{
-					 * updateList.add(t); }
-					 */
-					repository.save(t);
+					
+					 if(type.equals("add")){
+						 addList.add(t); 
+					 }else{
+					     updateList.add(t); 
+					     ins += t.getId().toString()+",";
+					  }
+//					repository.save(t);
 					newMap.put("status", ResponseCode.SUCCESS);
 				}
 			}
+			if(addList.size()>0){ 
+				new BatchSaveUtils<Ylb>().saveList(addList, Ylb.class); 
+			}
+			
+			if(updateList.size()>0){
+				for (int i = 0; i < updateList.size(); i++) {
+					repository.save(updateList.get(i));
+				}
+			}
+			newMap.put("status", ResponseCode.SUCCESS);
 		} catch (ParseException e) {
 			// TODO Auto-generated catch block
 			newMap.put("status", ResponseCode.ERROR);
 			throw e;
 		}
-		/*
-		 * try { if(addList.size()>0){ new
-		 * BatchSaveUtils<Ylb>().saveList(addList, Ylb.class); }
-		 * 
-		 * if(updateList.size()>0){
-		 * 
-		 * } newMap.put("status", ResponseCode.SUCCESS); } catch (Exception e) {
-		 * // TODO: handle exception newMap.put("status", ResponseCode.ERROR); }
-		 */
+
 		return newMap;
 	}
@@ -383,7 +389,7 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 					String nbbm_eq = ylb.getNbbm();
 					Date rq_eq = ylb.getRq();
 					// 得到一天总的加油和里程（根据车，时间）
-					List<Object[]> sumList = repository.sumLcYl(nbbm_eq, rq_eq);
+					List<Object[]> sumList = repository.sumLcYl(nbbm_eq, rq_eq,ylb.getXlbm());
 					// 保存总的加油量
 					Double jzl = Double.valueOf(sumList.get(0)[0].toString());
 					// 保存总的里程
@@ -484,7 +490,7 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 			String nbbm_eq = ylb.getNbbm();
 			Date rq_eq = ylb.getRq();
 			// 得到一天总的加油和里程（根据车，时间）
-			List<Object[]> sumList = repository.sumLcYl(nbbm_eq, rq_eq);
+			List<Object[]> sumList = repository.sumLcYl(nbbm_eq, rq_eq,ylb.getXlbm());
 			// 保存总的加油量
 			Double jzl = Double.valueOf(sumList.get(0)[0].toString());
 			// 保存总的里程
@@ -610,7 +616,7 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 				nbbm=map.get("nbbm_eq").toString();
 			}
 			List<Ylb> ylbList=repository.obtainYl(rq,gsbm,fgsbm,xlbm,nbbm,"nbbm");
-			List<Ylxxb> ylxxbList=ylxxbRepository.obtainYlxx(rq,0);
+			List<Ylxxb> ylxxbList=ylxxbRepository.obtainYlxx(rq,0,gsbm);
 			for (int i = 0; i < ylxxbList.size(); i++) {
 				Boolean fage=true;
 				Ylxxb y1=ylxxbList.get(i);
@@ -126,7 +126,7 @@ public interface ScheduleRealInfoService extends BaseService&lt;ScheduleRealInfo, L
 	List<ScheduleRealInfo> realScheduleList(String line,String date);
 	List<ScheduleRealInfo> realScheduleListQp(String line,String date);
-	List<Map<String,Object>> yesterdayDataList(String line,String date);
+	List<Map<String,Object>> yesterdayDataList(String line,String date,String gsbm,String fgsbm,String jGh,String nbbm);
 	List<Map<String,Object>> yesterdayDataList(String line);
@@ -1291,7 +1291,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 //		int ljbc = scheduleRealInfoRepository.findLjbc(jName, clZbh, lpName);
         int jhbc = 0, cjbc = 0, ljbc = 0;
         double jhlc = 0, yygl = 0, ksgl = 0, tempJhlc = 0, jcclc = 0;
-        float addMileage = 0l, remMileage = 0l;
+        float addMileage = 0l, remMileage = 0l,addMileageYy = 0l,addMileageJc =0l;
         Map<String, Object> map = new HashMap<String, Object>();
         for (ScheduleRealInfo scheduleRealInfo : list) {
             if (scheduleRealInfo != null) {
@@ -1302,7 +1302,14 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                 tempJhlc = scheduleRealInfo.getJhlc() == null ? 0 : scheduleRealInfo.getJhlc();
                 if (scheduleRealInfo.isSflj()) {
                     addMileage += tempJhlc;
-                    ljbc++;
+                    if (scheduleRealInfo.getBcType().equals("in")
+                            || scheduleRealInfo.getBcType().equals("out")) {
+                    	addMileageJc +=tempJhlc;
+                    }else{
+                    	 ljbc++;
+                    	addMileageYy +=tempJhlc;
+                    }
+                   
                 } else {
                     if (!(scheduleRealInfo.getBcType().equals("in")
                             || scheduleRealInfo.getBcType().equals("out"))) {
@@ -1359,15 +1366,15 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
         map.put("jhlc", format.format(jhlc));
         map.put("remMileage", format.format(remMileage));
         map.put("addMileage", format.format(addMileage));
-        map.put("yygl", format.format(yygl));
+        map.put("yygl", format.format(yygl+addMileageYy));
         map.put("ksgl", format.format(ksgl));
-        map.put("realMileage", format.format(yygl + ksgl + jcclc));
+        map.put("realMileage", format.format(yygl + ksgl + jcclc+addMileage));
         map.put("jhbc", jhbc);
         map.put("cjbc", cjbc);
         map.put("ljbc", ljbc);
         map.put("sjbc", jhbc - cjbc + ljbc);
         map.put("jcclc", jcclc);
-        map.put("zkslc", format.format(ksgl + jcclc));
+        map.put("zkslc", format.format(ksgl + jcclc+addMileageJc));
         return map;
     }
@@ -1501,6 +1508,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
             if (!childTaskPlans.isEmpty()) {
                 s.setFcsjActual("");
                 s.setZdsjActual("");
+                s.setJhlc(0.0);
             }
             if (s.isDestroy()) {
@@ -2332,86 +2340,91 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
         return list;
     }
-    public List<Map<String, Object>> yesterdayDataList(String line, String date) {
+    public List<Map<String, Object>> yesterdayDataList(String line, String date,String gsbm,String fgsbm,String jGh,String nbbm) {
         //前一天日期
 //		String date = sdfMonth.format(org.apache.commons.lang.time.DateUtils.addDays(new Date(), -1));
 //		String date = "2016-09-20";
-        List<Map<String, Object>> yesterdayDataList = scheduleRealInfoRepository.yesterdayDataList(line, date);
+        List<Map<String, Object>> yesterdayDataList = scheduleRealInfoRepository.yesterdayDataList(line, date,gsbm,fgsbm);
 //		List<ScheduleRealInfo> list = scheduleRealInfoRepository.scheduleByDateAndLine(line, date);
+        List<ScheduleRealInfo> lists = scheduleRealInfoRepository.queryListWaybill3(jGh, nbbm, date);
         for (int x = 0; x < yesterdayDataList.size(); x++) {
             String jName = yesterdayDataList.get(x).get("jGh").toString();
             String clZbh = yesterdayDataList.get(x).get("clZbh").toString();
-            List<ScheduleRealInfo> lists = scheduleRealInfoRepository.queryListWaybill3(jName, clZbh, date);
+           
             double jhlc = 0, yygl = 0, ksgl = 0, tempJhlc = 0, jcclc = 0;
             float addMileage = 0l, remMileage = 0l;
             Map<String, Object> map = new HashMap<String, Object>();
             boolean fage = true;
+            String company="";
+            String bCompany="";
             for (ScheduleRealInfo scheduleRealInfo : lists) {
-                if (fage) {
-                    //根据线路代码获取公司
-                    Line li = lineRepository.findByLineCode(scheduleRealInfo.getXlBm());
-                    yesterdayDataList.get(x).put("company", li.getCompany());
-                    yesterdayDataList.get(x).put("bCompany", li.getBrancheCompany());
-                    fage = false;
-                }
-                if (scheduleRealInfo != null) {
-                    //计划里程（主任务过滤掉临加班次），
-                    //烂班里程（主任务烂班），
-                    //临加里程（主任务临加），
-                    //计划班次，烂班班次，增加班次
-                    tempJhlc = scheduleRealInfo.getJhlc() == null ? 0 : scheduleRealInfo.getJhlc();
-                    if (scheduleRealInfo.isSflj()) {
-                        addMileage += tempJhlc;
-                    } else {
-                        if (!(scheduleRealInfo.getBcType().equals("in")
-                                || scheduleRealInfo.getBcType().equals("out"))) {
-                            jhlc += tempJhlc;
-                        }
-
-                        if (scheduleRealInfo.getStatus() == -1) {
-                            remMileage += tempJhlc;
-                        }
-                    }
-                    Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
-                    //计算营运里程，空驶里程
-                    if (childTaskPlans.isEmpty()) {
-                        if (scheduleRealInfo.getBcType().equals("in") ||
-                                scheduleRealInfo.getBcType().equals("out")) {
-                        	if (scheduleRealInfo.getStatus() != -1) {
-                        		jcclc += tempJhlc;
-                        	}
-                        }
-                        //主任务 放空班次属于营运
-//						else if(scheduleRealInfo.getBcType().equals("venting")){
-//							ksgl += tempJhlc;
-//						}
-                        else {
-                            if (scheduleRealInfo.getStatus() != -1) {
-                                yygl += tempJhlc;
-                            }
-                        }
-                    } else {
-                        Iterator<ChildTaskPlan> it = childTaskPlans.iterator();
-                        while (it.hasNext()) {
-                            ChildTaskPlan childTaskPlan = it.next();
-                            if (childTaskPlan.getMileageType().equals("empty")) {
-                                if (childTaskPlan.isDestroy()) {
-                                    remMileage += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
-                                } else {
-                                    ksgl += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
-                                }
-                            } else {
-                                if (childTaskPlan.isDestroy()) {
-                                    remMileage += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
-                                } else {
-                                    yygl += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
-                                }
-                            }
-                        }
-                    }
-                }
-            }
-
+            	if(scheduleRealInfo.getjGh().equals(jName) && scheduleRealInfo.getClZbh().equals(clZbh)){
+	                if (fage) {
+	                    //根据线路代码获取公司
+	                	company=scheduleRealInfo.getGsBm();
+	                	bCompany=scheduleRealInfo.getFgsBm();
+	                    fage = false;
+	                }
+	                if (scheduleRealInfo != null) {
+	                    //计划里程（主任务过滤掉临加班次），
+	                    //烂班里程（主任务烂班），
+	                    //临加里程（主任务临加），
+	                    //计划班次，烂班班次，增加班次
+	                    tempJhlc = scheduleRealInfo.getJhlc() == null ? 0 : scheduleRealInfo.getJhlc();
+	                    if (scheduleRealInfo.isSflj()) {
+	                        addMileage += tempJhlc;
+	                    } else {
+	                        if (!(scheduleRealInfo.getBcType().equals("in")
+	                                || scheduleRealInfo.getBcType().equals("out"))) {
+	                            jhlc += tempJhlc;
+	                        }
+	
+	                        if (scheduleRealInfo.getStatus() == -1) {
+	                            remMileage += tempJhlc;
+	                        }
+	                    }
+	                    Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
+	                    //计算营运里程，空驶里程
+	                    if (childTaskPlans.isEmpty()) {
+	                        if (scheduleRealInfo.getBcType().equals("in") ||
+	                                scheduleRealInfo.getBcType().equals("out")) {
+	                        	if (scheduleRealInfo.getStatus() != -1) {
+	                        		jcclc += tempJhlc;
+	                        	}
+	                        }
+	                        //主任务 放空班次属于营运
+	//						else if(scheduleRealInfo.getBcType().equals("venting")){
+	//							ksgl += tempJhlc;
+	//						}
+	                        else {
+	                            if (scheduleRealInfo.getStatus() != -1) {
+	                                yygl += tempJhlc;
+	                            }
+	                        }
+	                    } else {
+	                        Iterator<ChildTaskPlan> it = childTaskPlans.iterator();
+	                        while (it.hasNext()) {
+	                            ChildTaskPlan childTaskPlan = it.next();
+	                            if (childTaskPlan.getMileageType().equals("empty")) {
+	                                if (childTaskPlan.isDestroy()) {
+	                                    remMileage += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
+	                                } else {
+	                                    ksgl += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
+	                                }
+	                            } else {
+	                                if (childTaskPlan.isDestroy()) {
+	                                    remMileage += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
+	                                } else {
+	                                    yygl += childTaskPlan.getMileage() == null ? 0 : childTaskPlan.getMileage();
+	                                }
+	                            }
+	                        }
+	                    }
+	                }
+	            }
+            }
+            yesterdayDataList.get(x).put("company", company);
+            yesterdayDataList.get(x).put("bCompany", bCompany);
             yesterdayDataList.get(x).put("totalKilometers", yygl + ksgl + jcclc);
         }
@@ -3119,7 +3132,9 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                         }
                         if (!c.isDestroy()) {
-                            sjlc += c.getMileage() == null ? 0 : c.getMileage();
+                        	if(c.getMileageType().equals("service")){
+                        		sjlc += c.getMileage() == null ? 0 : c.getMileage();
+                        	}
                         }
                     }
-package com.bsth.service.schedule.rules.plan;
-
-import com.bsth.entity.schedule.SchedulePlan;
-import com.bsth.service.schedule.rules.shiftloop.ScheduleResults_output;
-import com.bsth.service.schedule.rules.ttinfo.TTInfoResults_output;
-
-/**
- * 排班规则-规则输入参数。
- */
-public class PlanCalcuParam_input {
-    /** 线路id */
-    private Integer xlId;
-    /** 循环规则输出 */
-    private ScheduleResults_output scheduleResults_output;
-    /** 时刻表选择规则输出 */
-    private TTInfoResults_output ttInfoResults_output;
-
-    public PlanCalcuParam_input() {
-    }
-    public PlanCalcuParam_input(
-            SchedulePlan schedulePlan,
-            ScheduleResults_output scheduleResults_output,
-            TTInfoResults_output ttInfoResults_output) {
-        this.xlId = schedulePlan.getXl().getId();
-        this.scheduleResults_output = scheduleResults_output;
-        this.ttInfoResults_output = ttInfoResults_output;
-    }
-
-    public Integer getXlId() {
-        return xlId;
-    }
-
-    public void setXlId(Integer xlId) {
-        this.xlId = xlId;
-    }
-
-    public ScheduleResults_output getScheduleResults_output() {
-        return scheduleResults_output;
-    }
-
-    public void setScheduleResults_output(ScheduleResults_output scheduleResults_output) {
-        this.scheduleResults_output = scheduleResults_output;
-    }
-
-    public TTInfoResults_output getTtInfoResults_output() {
-        return ttInfoResults_output;
-    }
-
-    public void setTtInfoResults_output(TTInfoResults_output ttInfoResults_output) {
-        this.ttInfoResults_output = ttInfoResults_output;
-    }
-}
+package com.bsth.service.schedule.rules.plan;
+
+import com.bsth.entity.schedule.SchedulePlan;
+import com.bsth.service.schedule.rules.shiftloop.ScheduleResults_output;
+import com.bsth.service.schedule.rules.ttinfo.TTInfoResults_output;
+
+/**
+ * 排班规则-规则输入参数。
+ */
+public class PlanCalcuParam_input {
+    /** 线路id */
+    private Integer xlId;
+    /** 循环规则输出 */
+    private ScheduleResults_output scheduleResults_output;
+    /** 时刻表选择规则输出 */
+    private TTInfoResults_output ttInfoResults_output;
+
+    public PlanCalcuParam_input() {
+    }
+    public PlanCalcuParam_input(
+            SchedulePlan schedulePlan,
+            ScheduleResults_output scheduleResults_output,
+            TTInfoResults_output ttInfoResults_output) {
+        this.xlId = schedulePlan.getXl().getId();
+        this.scheduleResults_output = scheduleResults_output;
+        this.ttInfoResults_output = ttInfoResults_output;
+    }
+
+    public Integer getXlId() {
+        return xlId;
+    }
+
+    public void setXlId(Integer xlId) {
+        this.xlId = xlId;
+    }
+
+    public ScheduleResults_output getScheduleResults_output() {
+        return scheduleResults_output;
+    }
+
+    public void setScheduleResults_output(ScheduleResults_output scheduleResults_output) {
+        this.scheduleResults_output = scheduleResults_output;
+    }
+
+    public TTInfoResults_output getTtInfoResults_output() {
+        return ttInfoResults_output;
+    }
+
+    public void setTtInfoResults_output(TTInfoResults_output ttInfoResults_output) {
+        this.ttInfoResults_output = ttInfoResults_output;
+    }
+}
-package com.bsth.service.schedule.rules.plan;
-
-import com.bsth.entity.schedule.SchedulePlanInfo;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 计划输出。
- */
-public class PlanResult {
-    private List<SchedulePlanInfo> schedulePlanInfos = new ArrayList<>();
-
-    public PlanResult() {
-    }
-
-    public void add(SchedulePlanInfo schedulePlanInfo) {
-        schedulePlanInfos.add(schedulePlanInfo);
-    }
-
-    public List<SchedulePlanInfo> getSchedulePlanInfos() {
-        return schedulePlanInfos;
-    }
-
-    public void setSchedulePlanInfos(List<SchedulePlanInfo> schedulePlanInfos) {
-        this.schedulePlanInfos = schedulePlanInfos;
-    }
-}
+package com.bsth.service.schedule.rules.plan;
+
+import com.bsth.entity.schedule.SchedulePlanInfo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 计划输出。
+ */
+public class PlanResult {
+    private List<SchedulePlanInfo> schedulePlanInfos = new ArrayList<>();
+
+    public PlanResult() {
+    }
+
+    public void add(SchedulePlanInfo schedulePlanInfo) {
+        schedulePlanInfos.add(schedulePlanInfo);
+    }
+
+    public List<SchedulePlanInfo> getSchedulePlanInfos() {
+        return schedulePlanInfos;
+    }
+
+    public void setSchedulePlanInfos(List<SchedulePlanInfo> schedulePlanInfos) {
+        this.schedulePlanInfos = schedulePlanInfos;
+    }
+}
-排班计划规则，构造计划明细输出
-1、使用shiftloop.drl和ttinfo.drl的输出作为输入，进行规则计算
+排班计划规则，构造计划明细输出
+1、使用shiftloop.drl和ttinfo.drl的输出作为输入，进行规则计算
 2、计算后输出排班明细列表
 \ No newline at end of file
-package com.bsth.service.schedule.plan;
-
-import org.joda.time.*;
-import java.util.*;
-
-import com.bsth.service.schedule.rules.plan.PlanCalcuParam_input;
-import com.bsth.service.schedule.rules.plan.PlanResult;
-
-import com.bsth.service.schedule.TTInfoService;
-import com.bsth.service.schedule.TTInfoDetailService;
-import com.bsth.service.schedule.CarConfigInfoService;
-import com.bsth.service.schedule.EmployeeConfigInfoService;
-import com.bsth.service.schedule.rules.shiftloop.ScheduleResult_output;
-import com.bsth.service.schedule.rules.shiftloop.ScheduleResults_output;
-import com.bsth.service.schedule.rules.ttinfo.TTInfoResult_output;
-import com.bsth.service.schedule.rules.ttinfo.TTInfoResults_output;
-
-import com.bsth.entity.schedule.CarConfigInfo;
-import com.bsth.entity.schedule.EmployeeConfigInfo;
-import com.bsth.entity.schedule.TTInfo;
-import com.bsth.entity.schedule.TTInfoDetail;
-import com.bsth.entity.schedule.SchedulePlanInfo;
-
-import org.slf4j.Logger;
-
-
-// 全局日志类（一般使用调用此规则的service类）
-global Logger log;
-global TTInfoDetailService tTInfoDetailService;
-global TTInfoService tTInfoService;
-global CarConfigInfoService carConfigInfoService;
-global EmployeeConfigInfoService employeeConfigInfoService;
-
-// 输出
-global PlanResult planResult;
-
-function Map ttidParams(String ttid) {
-    Map param = new HashMap();
-    param.put("ttinfo.id_eq", Long.parseLong(ttid));
-    return param;
-}
-
-function Map xlidParams(Integer xlid) {
-    Map param = new HashMap();
-    param.put("xl.id_eq", xlid);
-    return param;
-}
-
-/*
-    规则说明：
-    1、根据循环规则输出，时刻表选择规则输出，计算排班明细
-*/
-
-//-------------------- 第一阶段、计算迭代数据 -----------------//
-declare Loop_result
-    xlId: Integer // 线路id
-    ruleLoop: List // 每天分配的规则 List<ScheduleResult_output>
-    ttInfoMapLoop_temp: Map // 每天分配的时刻表 Map<DataTime, Collection<TTInfoResult_output>>
-    ttInfoMapLoop: Map // 每天分配的时刻表 Map<DataTime, TTInfoResult_output>
-
-    ttInfoMap: Map // 总共用到的时刻表 Map<id, TTInfoResult_output>
-end
-
-rule "calcu_step1_Loop_result"
-    salience 1000
-    when
-        $param: PlanCalcuParam_input($xlId: xlId)
-    then
-        Loop_result loop_result = new Loop_result();
-        loop_result.setXlId($xlId);
-        loop_result.setRuleLoop($param.getScheduleResults_output().getResults());
-
-        loop_result.setTtInfoMapLoop(new HashMap());
-        loop_result.setTtInfoMap(new HashMap());
-
-        com.google.common.collect.Multimap ttInfoMap_temp =
-                    (com.google.common.collect.Multimap)
-                        $param.getTtInfoResults_output().getResults().get(
-                            String.valueOf($xlId));
-
-        loop_result.setTtInfoMapLoop_temp(ttInfoMap_temp.asMap());
-
-        insert(loop_result);
-
-        log.info("calcu_step1_Loop_result");
-end
-
-rule "calcu_step2_loop_result"
-    salience 1000
-    no-loop
-    when
-        $param: PlanCalcuParam_input($xlId: xlId)
-        $lr: Loop_result(xlId == $xlId)
-        $sd: DateTime() from $lr.ttInfoMapLoop_temp.keySet()
-    then
-        // 当天时刻表只取第一张 TODO：
-        Collection col = (Collection) $lr.getTtInfoMapLoop_temp().get($sd);
-        Iterator iter = col.iterator();
-        TTInfoResult_output ttInfo_result = (TTInfoResult_output) iter.next();
-        $lr.getTtInfoMapLoop().put($sd, ttInfo_result);
-
-        // 总共使用的时刻表
-        $lr.getTtInfoMap().put(ttInfo_result.getTtInfoId(), ttInfo_result);
-
-        update($lr);
-end
-
-//-------------------- 第二阶段、将时刻表班次，车辆配置，人员配置信息载入 -----------------//
-
-declare TTInfoDetail_Wrap
-    ttInfoId: String // 时刻表id（cast字符串-方便比较）
-    gid: String // 路牌id（cast字符串-方便比较）
-
-    self: TTInfoDetail // 原始数据
-end
-
-rule "calcu_TTInfoDetail_Wrap"
-    salience 800
-    when
-        $lr: Loop_result($xlId: xlId)
-        $ttInfoId: String() from $lr.getTtInfoMap().keySet()
-        $ttInfoDetail: TTInfoDetail() from tTInfoDetailService.list(ttidParams($ttInfoId))
-    then
-        TTInfoDetail_Wrap ttInfoDetail_wrap = new TTInfoDetail_Wrap();
-        ttInfoDetail_wrap.setTtInfoId($ttInfoId);
-        ttInfoDetail_wrap.setGid(String.valueOf($ttInfoDetail.getLp().getId()));
-        ttInfoDetail_wrap.setSelf($ttInfoDetail);
-
-//        log.info("时刻表id={}", $ttInfoId);
-//        log.info("时刻表明细id={}", $ttInfoDetail.getId());
-
-        insert(ttInfoDetail_wrap);
-end
-
-declare CarConfig_Wrap
-    id: String // 车辆配置id（cast字符串-方便比较）
-
-    self: CarConfigInfo // 原始数据
-end
-
-rule "calcu_CarConfig_Wrap"
-    salience 800
-    when
-        $lr: Loop_result($xlId: xlId)
-        $ccf: CarConfigInfo() from carConfigInfoService.list(xlidParams($xlId))
-    then
-        CarConfig_Wrap carConfig_wrap = new CarConfig_Wrap();
-        carConfig_wrap.setId(String.valueOf($ccf.getId()));
-        carConfig_wrap.setSelf($ccf);
-
-        insert(carConfig_wrap);
-end
-
-declare EmployeeConfig_Wrap
-    id: String // 人员配置id（cast字符串-方便比较）
-
-    self: EmployeeConfigInfo // 原始数据
-end
-
-rule "calcu_EmployeeConfig_Wrap"
-    salience 800
-    when
-        $lr: Loop_result($xlId: xlId)
-        $eci: EmployeeConfigInfo() from employeeConfigInfoService.list(xlidParams($xlId))
-    then
-        EmployeeConfig_Wrap employeeConfig_wrap = new EmployeeConfig_Wrap();
-        employeeConfig_wrap.setId(String.valueOf($eci.getId()));
-        employeeConfig_wrap.setSelf($eci);
-
-        insert(employeeConfig_wrap);
-end
-
-declare ScheduleResult_output_Wrap
-    xlId: Integer // 线路id
-    sd: DateTime // 日期
-    ruleId: String // 规则Id
-    eciIds: List // 人员配置ids
-
-    self: ScheduleResult_output // 原始数据
-end
-
-rule "calcu_ScheduleResult_output_Wrap"
-    salience 800
-    when
-        $lr: Loop_result($xlId: xlId)
-        $sro: ScheduleResult_output() from $lr.getRuleLoop()
-    then
-        ScheduleResult_output_Wrap scheduleResult_output_wrap = new ScheduleResult_output_Wrap();
-        scheduleResult_output_wrap.setXlId($xlId);
-        scheduleResult_output_wrap.setSd($sro.getSd());
-        scheduleResult_output_wrap.setRuleId($sro.getRuleId());
-        scheduleResult_output_wrap.setEciIds(Arrays.asList(
-            $sro.getEmployeeConfigId().split("-")));
-        scheduleResult_output_wrap.setSelf($sro);
-
-        insert(scheduleResult_output_wrap);
-end
-
-//-------------------- 第三阶段、合并计算SchedulePlanInfo -----------------//
-
-// TODO：暂时不考虑分班
-
-//rule "Calcu_SchedulePlanInfo"
-//    salience 600
-//    when
-//        $lr: Loop_result($xlId: xlId)
-//        $sro: ScheduleResult_output($sd: sd) from $lr.getRuleLoop()
-//        ScheduleResult_output_Wrap(
-//            xlId == $xlId, sd == $sro.sd, ruleId == $sro.ruleId,
-//            $eciIds: eciIds, $sr: self)
-//        $ecId: String() from $eciIds
-//        CarConfig_Wrap(id == $sro.carConfigId, $cc: self)
-//        EmployeeConfig_Wrap(id == $ecId, $ec: self)
-//        TTInfoDetail_Wrap(
-//            ttInfoId == ((TTInfoResult_output) $lr.getTtInfoMapLoop($sd)).,
-//            gid == $sr.guideboardId,
-//            $ttInfoDetail: self
-//        )
-//    then
-//        log.info("Calcu_SchedulePlanInfo");
-//
-//end
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+package com.bsth.service.schedule.plan;
+
+import org.joda.time.*;
+import java.util.*;
+
+import com.bsth.service.schedule.rules.plan.PlanCalcuParam_input;
+import com.bsth.service.schedule.rules.plan.PlanResult;
+
+import com.bsth.service.schedule.TTInfoService;
+import com.bsth.service.schedule.TTInfoDetailService;
+import com.bsth.service.schedule.CarConfigInfoService;
+import com.bsth.service.schedule.EmployeeConfigInfoService;
+import com.bsth.service.schedule.rules.shiftloop.ScheduleResult_output;
+import com.bsth.service.schedule.rules.shiftloop.ScheduleResults_output;
+import com.bsth.service.schedule.rules.ttinfo.TTInfoResult_output;
+import com.bsth.service.schedule.rules.ttinfo.TTInfoResults_output;
+
+import com.bsth.entity.schedule.CarConfigInfo;
+import com.bsth.entity.schedule.EmployeeConfigInfo;
+import com.bsth.entity.schedule.TTInfo;
+import com.bsth.entity.schedule.TTInfoDetail;
+import com.bsth.entity.schedule.SchedulePlanInfo;
+
+import org.slf4j.Logger;
+
+
+// 全局日志类（一般使用调用此规则的service类）
+global Logger log;
+global TTInfoDetailService tTInfoDetailService;
+global TTInfoService tTInfoService;
+global CarConfigInfoService carConfigInfoService;
+global EmployeeConfigInfoService employeeConfigInfoService;
+
+// 输出
+global PlanResult planResult;
+
+function Map ttidParams(String ttid) {
+    Map param = new HashMap();
+    param.put("ttinfo.id_eq", Long.parseLong(ttid));
+    return param;
+}
+
+function Map xlidParams(Integer xlid) {
+    Map param = new HashMap();
+    param.put("xl.id_eq", xlid);
+    return param;
+}
+
+/*
+    规则说明：
+    1、根据循环规则输出，时刻表选择规则输出，计算排班明细
+*/
+
+//-------------------- 第一阶段、计算迭代数据 -----------------//
+declare Loop_result
+    xlId: Integer // 线路id
+    ruleLoop: List // 每天分配的规则 List<ScheduleResult_output>
+    ttInfoMapLoop_temp: Map // 每天分配的时刻表 Map<DataTime, Collection<TTInfoResult_output>>
+    ttInfoMapLoop: Map // 每天分配的时刻表 Map<DataTime, TTInfoResult_output>
+
+    ttInfoMap: Map // 总共用到的时刻表 Map<id, TTInfoResult_output>
+end
+
+rule "calcu_step1_Loop_result"
+    salience 1000
+    when
+        $param: PlanCalcuParam_input($xlId: xlId)
+    then
+        Loop_result loop_result = new Loop_result();
+        loop_result.setXlId($xlId);
+        loop_result.setRuleLoop($param.getScheduleResults_output().getResults());
+
+        loop_result.setTtInfoMapLoop(new HashMap());
+        loop_result.setTtInfoMap(new HashMap());
+
+        com.google.common.collect.Multimap ttInfoMap_temp =
+                    (com.google.common.collect.Multimap)
+                        $param.getTtInfoResults_output().getResults().get(
+                            String.valueOf($xlId));
+
+        loop_result.setTtInfoMapLoop_temp(ttInfoMap_temp.asMap());
+
+        insert(loop_result);
+
+        log.info("calcu_step1_Loop_result");
+end
+
+rule "calcu_step2_loop_result"
+    salience 1000
+    no-loop
+    when
+        $param: PlanCalcuParam_input($xlId: xlId)
+        $lr: Loop_result(xlId == $xlId)
+        $sd: DateTime() from $lr.ttInfoMapLoop_temp.keySet()
+    then
+        // 当天时刻表只取第一张 TODO：
+        Collection col = (Collection) $lr.getTtInfoMapLoop_temp().get($sd);
+        Iterator iter = col.iterator();
+        TTInfoResult_output ttInfo_result = (TTInfoResult_output) iter.next();
+        $lr.getTtInfoMapLoop().put($sd, ttInfo_result);
+
+        // 总共使用的时刻表
+        $lr.getTtInfoMap().put(ttInfo_result.getTtInfoId(), ttInfo_result);
+
+        update($lr);
+end
+
+//-------------------- 第二阶段、将时刻表班次，车辆配置，人员配置信息载入 -----------------//
+
+declare TTInfoDetail_Wrap
+    ttInfoId: String // 时刻表id（cast字符串-方便比较）
+    gid: String // 路牌id（cast字符串-方便比较）
+
+    self: TTInfoDetail // 原始数据
+end
+
+rule "calcu_TTInfoDetail_Wrap"
+    salience 800
+    when
+        $lr: Loop_result($xlId: xlId)
+        $ttInfoId: String() from $lr.getTtInfoMap().keySet()
+        $ttInfoDetail: TTInfoDetail() from tTInfoDetailService.list(ttidParams($ttInfoId))
+    then
+        TTInfoDetail_Wrap ttInfoDetail_wrap = new TTInfoDetail_Wrap();
+        ttInfoDetail_wrap.setTtInfoId($ttInfoId);
+        ttInfoDetail_wrap.setGid(String.valueOf($ttInfoDetail.getLp().getId()));
+        ttInfoDetail_wrap.setSelf($ttInfoDetail);
+
+//        log.info("时刻表id={}", $ttInfoId);
+//        log.info("时刻表明细id={}", $ttInfoDetail.getId());
+
+        insert(ttInfoDetail_wrap);
+end
+
+declare CarConfig_Wrap
+    id: String // 车辆配置id（cast字符串-方便比较）
+
+    self: CarConfigInfo // 原始数据
+end
+
+rule "calcu_CarConfig_Wrap"
+    salience 800
+    when
+        $lr: Loop_result($xlId: xlId)
+        $ccf: CarConfigInfo() from carConfigInfoService.list(xlidParams($xlId))
+    then
+        CarConfig_Wrap carConfig_wrap = new CarConfig_Wrap();
+        carConfig_wrap.setId(String.valueOf($ccf.getId()));
+        carConfig_wrap.setSelf($ccf);
+
+        insert(carConfig_wrap);
+end
+
+declare EmployeeConfig_Wrap
+    id: String // 人员配置id（cast字符串-方便比较）
+
+    self: EmployeeConfigInfo // 原始数据
+end
+
+rule "calcu_EmployeeConfig_Wrap"
+    salience 800
+    when
+        $lr: Loop_result($xlId: xlId)
+        $eci: EmployeeConfigInfo() from employeeConfigInfoService.list(xlidParams($xlId))
+    then
+        EmployeeConfig_Wrap employeeConfig_wrap = new EmployeeConfig_Wrap();
+        employeeConfig_wrap.setId(String.valueOf($eci.getId()));
+        employeeConfig_wrap.setSelf($eci);
+
+        insert(employeeConfig_wrap);
+end
+
+declare ScheduleResult_output_Wrap
+    xlId: Integer // 线路id
+    sd: DateTime // 日期
+    ruleId: String // 规则Id
+    eciIds: List // 人员配置ids
+
+    self: ScheduleResult_output // 原始数据
+end
+
+rule "calcu_ScheduleResult_output_Wrap"
+    salience 800
+    when
+        $lr: Loop_result($xlId: xlId)
+        $sro: ScheduleResult_output() from $lr.getRuleLoop()
+    then
+        ScheduleResult_output_Wrap scheduleResult_output_wrap = new ScheduleResult_output_Wrap();
+        scheduleResult_output_wrap.setXlId($xlId);
+        scheduleResult_output_wrap.setSd($sro.getSd());
+        scheduleResult_output_wrap.setRuleId($sro.getRuleId());
+        scheduleResult_output_wrap.setEciIds(Arrays.asList(
+            $sro.getEmployeeConfigId().split("-")));
+        scheduleResult_output_wrap.setSelf($sro);
+
+        insert(scheduleResult_output_wrap);
+end
+
+//-------------------- 第三阶段、合并计算SchedulePlanInfo -----------------//
+
+// TODO：暂时不考虑分班
+
+//rule "Calcu_SchedulePlanInfo"
+//    salience 600
+//    when
+//        $lr: Loop_result($xlId: xlId)
+//        $sro: ScheduleResult_output($sd: sd) from $lr.getRuleLoop()
+//        ScheduleResult_output_Wrap(
+//            xlId == $xlId, sd == $sro.sd, ruleId == $sro.ruleId,
+//            $eciIds: eciIds, $sr: self)
+//        $ecId: String() from $eciIds
+//        CarConfig_Wrap(id == $sro.carConfigId, $cc: self)
+//        EmployeeConfig_Wrap(id == $ecId, $ec: self)
+//        TTInfoDetail_Wrap(
+//            ttInfoId == ((TTInfoResult_output) $lr.getTtInfoMapLoop($sd)).,
+//            gid == $sr.guideboardId,
+//            $ttInfoDetail: self
+//        )
+//    then
+//        log.info("Calcu_SchedulePlanInfo");
+//
+//end
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-package com.bsth.service.schedule.shiftloop;
-
-import org.joda.time.*;
-import java.util.*;
-
-import com.bsth.service.schedule.rules.shiftloop.ScheduleCalcuParam_input;
-import com.bsth.service.schedule.rules.shiftloop.ScheduleRule_input;
-import com.bsth.service.schedule.rules.shiftloop.ScheduleResult_output;
-import com.bsth.service.schedule.rules.shiftloop.ScheduleResults_output;
-
-import org.slf4j.Logger;
-
-global Logger log;
-
-/*
-    存在（翻班格式）
-*/
-
-//------------------------- 第一阶段、计算规则准备数据（天数） ----------------------------//
-
-declare Calcu_days_result
-    ruleId : String // 规则Id
-    qyrq_days : Integer // 开始日期离启用日期的天数
-    sdays : Integer // 总共需要排班的天数
-    calcu_start_date : DateTime // 开始计算日期
-    calcu_end_date : DateTime // 结束计算日期
-end
-
-/*
-    计算启用日期，开始计算日期，结束计算日期，相差天数
-    1、规则启用日期小于开始计算日期
-    2、规则启用日期大于等于开始日期，小于等于结束日期
-*/
-rule "calcu_days_1"
-    salience 100
-    when
-        ScheduleCalcuParam_input(
-            fromDate.isBefore(toDate) || fromDate.isEqual(toDate),
-            $fromDate : fromDate,
-            $toDate : toDate
-        )
-        ScheduleRule_input($ruleId : ruleId, $qyrq : qyrq)
-        eval($qyrq.isBefore($fromDate))
-    then
-        // 构造Calcu_days_result对象，进行下一阶段计算
-        Calcu_days_result cdr = new Calcu_days_result();
-        cdr.setRuleId($ruleId);
-        Period p1 = new Period($qyrq, $fromDate, PeriodType.days());
-        cdr.setQyrq_days(p1.getDays());
-        Period p2 = new Period($fromDate, $toDate, PeriodType.days());
-        cdr.setSdays(p2.getDays() + 1);
-        cdr.setCalcu_start_date($fromDate);
-        cdr.setCalcu_end_date($toDate);
-
-        log.info("开始日期离启用日期的天数 qyrq_days={}", p1.getDays());
-        log.info("总共需要排班的天数 sdays={}", (p2.getDays() + 1));
-
-        insert(cdr); // 插入fact数据，进入下一个阶段
-end
-
-rule "calcu_days_2"
-    salience 100
-    when
-        ScheduleCalcuParam_input(
-            fromDate.isBefore(toDate) || fromDate.isEqual(toDate),
-            $fromDate : fromDate,
-            $toDate : toDate
-        )
-        ScheduleRule_input($ruleId : ruleId, $qyrq : qyrq)
-        eval((!$qyrq.isBefore($fromDate)) && (!$qyrq.isAfter($toDate)))
-    then
-        // 构造Calcu_days_result对象，进行下一阶段计算
-        Calcu_days_result cdr = new Calcu_days_result();
-        cdr.setRuleId($ruleId);
-        cdr.setQyrq_days(0);
-        Period p2 = new Period($qyrq, $toDate, PeriodType.days());
-        cdr.setSdays(Integer.valueOf(p2.getDays() + 1));
-        cdr.setCalcu_start_date($qyrq);
-        cdr.setCalcu_end_date($toDate);
-
-        log.info("开始日期离启用日期的天数 qyrq_days=0");
-        log.info("总共需要排班的天数 sdays={}", (p2.getDays() + 1));
-
-        insert(cdr); // 插入fact数据，进入下一个阶段
-end
-
-//------------------------- 第二阶段、计算规则准备数据2（起始索引） ----------------------------//
-
-//----------------------- 路牌范围循环计算 ------------------------//
-
-declare Calcu_guideboard_index_result
-    ruleId : String // 规则Id
-    calcu_index : Integer // 计算之后的起始索引
-end
-
-// 启用日期等于开始日期
-rule "calcu_guideboard_index_qyrq_eq_startrq"
-    when
-        $calcu_days_result : Calcu_days_result(
-            qyrq_days == 0,
-            $ruleId: ruleId
-        )
-        $scheduleRule_input : ScheduleRule_input(
-            ruleId == $ruleId,
-            $oindex : startGbdIndex
-        )
-    then
-        Calcu_guideboard_index_result cgir = new Calcu_guideboard_index_result();
-        cgir.setRuleId($ruleId);
-        cgir.setCalcu_index($oindex);
-
-        log.info("calcu_guideboard_index_qyrq_eq_startrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
-
-        insert(cgir);
-end
-
-// 开始日期大于启用日期
-rule "calcu_guideboard_index_startrq_gt_qyrq"
-    when
-        $calcu_days_result : Calcu_days_result(
-            qyrq_days > 0,
-            $ruleId: ruleId, $qyrq_days: qyrq_days,
-            $calcu_start_date: calcu_start_date
-        )
-        $scheduleRule_input : ScheduleRule_input(
-            ruleId == $ruleId,
-            $qyrq: qyrq,
-            $rangesize : guideboardIds.size(),
-            $oindex : startGbdIndex,
-            $weekdays: weekdays
-        )
-    then
-        // 开始时间
-        DateTime initDate = $qyrq;
-        int index = $oindex;
-        int resultIndex = index;
-
-        while (!initDate.isAfter($calcu_start_date)) {
-            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
-                resultIndex = index;
-                index = (index + 1) % $rangesize;
-            }
-            initDate = initDate.plusDays(1);
-        }
-
-        Calcu_guideboard_index_result cgir = new Calcu_guideboard_index_result();
-        cgir.setRuleId($ruleId);
-        cgir.setCalcu_index(resultIndex);
-
-        log.info("calcu_guideboard_index_startrq_gt_qyrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
-
-        insert(cgir);
-end
-
-//----------------------- 人员范围循环计算 ------------------------//
-
-declare Calcu_employee_index_result
-    ruleId : String // 规则Id
-    calcu_index : Integer // 计算之后的起始索引
-end
-
-// 启用日期等于开始日期
-rule "calcu_employee_index_qyrq_eq_startrq"
-    when
-        $calcu_days_result : Calcu_days_result(
-            qyrq_days == 0,
-            $ruleId: ruleId)
-        $scheduleRule_input : ScheduleRule_input(
-            ruleId == $ruleId,
-            $oindex : startEIndex)
-    then
-        Calcu_employee_index_result cgir = new Calcu_employee_index_result();
-        cgir.setRuleId($ruleId);
-        cgir.setCalcu_index($oindex);
-
-        log.info("calcu_employee_index_qyrq_eq_startrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
-
-        insert(cgir);
-end
-
-// 开始日期大于启用日期
-rule "calcu_employee_index_startrq_gt_qyrq"
-    when
-        $calcu_days_result : Calcu_days_result(
-            qyrq_days > 0,
-            $ruleId: ruleId, $qyrq_days: qyrq_days,
-            $calcu_start_date: calcu_start_date
-        )
-        $scheduleRule_input : ScheduleRule_input(
-            ruleId == $ruleId,
-            $qyrq: qyrq,
-            $rangesize : employeeConfigIds.size(),
-            $oindex : startEIndex,
-            $weekdays: weekdays
-        )
-    then
-        // 开始时间
-        DateTime initDate = $qyrq;
-        int index = $oindex;
-        int resultIndex = index;
-
-        while (!initDate.isAfter($calcu_start_date)) {
-            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
-                resultIndex = index;
-                index = (index + 1) % $rangesize;
-            }
-            initDate = initDate.plusDays(1);
-        }
-
-        Calcu_employee_index_result cgir = new Calcu_employee_index_result();
-        cgir.setRuleId($ruleId);
-        cgir.setCalcu_index(resultIndex);
-
-        log.info("calcu_employee_index_startrq_gt_qyrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
-
-        insert(cgir);
-
-end
-
-//------------------------- 第三阶段、循环计算 ------------------------//
-
-//----------------------- 路牌范围循环计算 ------------------------//
-declare loop_guideboard_result
-    ruleId : String // 规则id
-    go_list : List // 路牌循环的列表
-end
-
-// 循环路牌计算
-rule "Calcu_loop_guideboard_result"
-    when
-        Calcu_days_result(
-            $ruleId: ruleId,
-            $startDate : calcu_start_date,
-            $calcu_end_date: calcu_end_date
-        )
-        $ruleData : ScheduleRule_input(
-            ruleId == $ruleId,
-            $rangesize : guideboardIds.size(),
-            $weekdays: weekdays
-        )
-        $indexData : Calcu_guideboard_index_result(
-            ruleId == $ruleId
-        )
-    then
-        DateTime initDate = $startDate; // 开始时间
-        DateTime endDate = $calcu_end_date; // 结束实际
-        List<ScheduleResult_output> scheduleResult_outputs =
-            new ArrayList<ScheduleResult_output>();
-
-        int i = $indexData.getCalcu_index();
-        if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue() == false) {
-            i = (i + 1) % $rangesize;
-        }
-
-        while (!initDate.isAfter(endDate)) {
-            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
-                ScheduleResult_output ro = new ScheduleResult_output();
-                ro.setRuleId($ruleId);
-                ro.setSd(initDate);
-                ro.setGuideboardId($ruleData.getGuideboardIds().get(i));
-                ro.setCarConfigId($ruleData.getCarConfigId());
-                scheduleResult_outputs.add(ro);
-
-                i = (i + 1) % $rangesize;
-            }
-
-            initDate = initDate.plusDays(1);
-        }
-
-        loop_guideboard_result clgr = new loop_guideboard_result();
-        clgr.setRuleId($ruleId);
-        clgr.setGo_list(scheduleResult_outputs);
-
-        log.info(String.valueOf(scheduleResult_outputs.size()));
-
-        insert(clgr);
-
-end
-
-//----------------------- 人员范围循环计算 ------------------------//
-declare loop_employee_result
-    ruleId : String // 规则id
-    eo_list : List // 人员循环的列表
-end
-
-// 循环人员计算
-rule "Calcu_loop_employee_result"
-    when
-        Calcu_days_result(
-            $ruleId: ruleId,
-            $startDate : calcu_start_date,
-            $calcu_end_date: calcu_end_date
-        )
-        $ruleData : ScheduleRule_input(
-            ruleId == $ruleId,
-            $rangesize : employeeConfigIds.size(),
-            $weekdays: weekdays
-        )
-        $indexData : Calcu_employee_index_result(
-            ruleId == $ruleId
-        )
-    then
-        DateTime initDate = $startDate; // 开始时间
-        DateTime endDate = $calcu_end_date; // 结束实际
-        List<ScheduleResult_output> scheduleResult_outputs =
-            new ArrayList<ScheduleResult_output>();
-
-        int i = $indexData.getCalcu_index();
-        if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue() == false) {
-            i = (i + 1) % $rangesize;
-        }
-
-        while (!initDate.isAfter(endDate)) {
-            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
-                ScheduleResult_output ro = new ScheduleResult_output();
-                ro.setRuleId($ruleId);
-                ro.setSd(initDate);
-                ro.setEmployeeConfigId($ruleData.getEmployeeConfigIds().get(i));
-                ro.setCarConfigId($ruleData.getCarConfigId());
-                scheduleResult_outputs.add(ro);
-
-                i = (i + 1) % $rangesize;
-            }
-
-            initDate = initDate.plusDays(1);
-        }
-
-        loop_employee_result clgr = new loop_employee_result();
-        clgr.setRuleId($ruleId);
-        clgr.setEo_list(scheduleResult_outputs);
-
-        log.info(String.valueOf(scheduleResult_outputs.size()));
-
-        insert(clgr);
-end
-
-//------------------------- 第四阶段、范围组循环计算 ----------------------------//
-
-global ScheduleResults_output scheduleResult;
-
-rule "output"
-    when
-        loop_guideboard_result(
-            go_list.size() > 0,
-            $ruleId : ruleId, $go_list : go_list
-        )
-        loop_employee_result(
-            ruleId == $ruleId,
-            eo_list.size() == $go_list.size(),
-            $eo_list : eo_list
-        )
-    then
-        for (int i = 0; i < $go_list.size(); i++) {
-            ScheduleResult_output go = (ScheduleResult_output) $go_list.get(i);
-            ScheduleResult_output eo = (ScheduleResult_output) $eo_list.get(i);
-            go.setEmployeeConfigId(eo.getEmployeeConfigId());
-            scheduleResult.getResults().add(go);
-        }
-
-end
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+package com.bsth.service.schedule.shiftloop;
+
+import org.joda.time.*;
+import java.util.*;
+
+import com.bsth.service.schedule.rules.shiftloop.ScheduleCalcuParam_input;
+import com.bsth.service.schedule.rules.shiftloop.ScheduleRule_input;
+import com.bsth.service.schedule.rules.shiftloop.ScheduleResult_output;
+import com.bsth.service.schedule.rules.shiftloop.ScheduleResults_output;
+
+import org.slf4j.Logger;
+
+global Logger log;
+
+/*
+    存在（翻班格式）
+*/
+
+//------------------------- 第一阶段、计算规则准备数据（天数） ----------------------------//
+
+declare Calcu_days_result
+    ruleId : String // 规则Id
+    qyrq_days : Integer // 开始日期离启用日期的天数
+    sdays : Integer // 总共需要排班的天数
+    calcu_start_date : DateTime // 开始计算日期
+    calcu_end_date : DateTime // 结束计算日期
+end
+
+/*
+    计算启用日期，开始计算日期，结束计算日期，相差天数
+    1、规则启用日期小于开始计算日期
+    2、规则启用日期大于等于开始日期，小于等于结束日期
+*/
+rule "calcu_days_1"
+    salience 100
+    when
+        ScheduleCalcuParam_input(
+            fromDate.isBefore(toDate) || fromDate.isEqual(toDate),
+            $fromDate : fromDate,
+            $toDate : toDate
+        )
+        ScheduleRule_input($ruleId : ruleId, $qyrq : qyrq)
+        eval($qyrq.isBefore($fromDate))
+    then
+        // 构造Calcu_days_result对象，进行下一阶段计算
+        Calcu_days_result cdr = new Calcu_days_result();
+        cdr.setRuleId($ruleId);
+        Period p1 = new Period($qyrq, $fromDate, PeriodType.days());
+        cdr.setQyrq_days(p1.getDays());
+        Period p2 = new Period($fromDate, $toDate, PeriodType.days());
+        cdr.setSdays(p2.getDays() + 1);
+        cdr.setCalcu_start_date($fromDate);
+        cdr.setCalcu_end_date($toDate);
+
+        log.info("开始日期离启用日期的天数 qyrq_days={}", p1.getDays());
+        log.info("总共需要排班的天数 sdays={}", (p2.getDays() + 1));
+
+        insert(cdr); // 插入fact数据，进入下一个阶段
+end
+
+rule "calcu_days_2"
+    salience 100
+    when
+        ScheduleCalcuParam_input(
+            fromDate.isBefore(toDate) || fromDate.isEqual(toDate),
+            $fromDate : fromDate,
+            $toDate : toDate
+        )
+        ScheduleRule_input($ruleId : ruleId, $qyrq : qyrq)
+        eval((!$qyrq.isBefore($fromDate)) && (!$qyrq.isAfter($toDate)))
+    then
+        // 构造Calcu_days_result对象，进行下一阶段计算
+        Calcu_days_result cdr = new Calcu_days_result();
+        cdr.setRuleId($ruleId);
+        cdr.setQyrq_days(0);
+        Period p2 = new Period($qyrq, $toDate, PeriodType.days());
+        cdr.setSdays(Integer.valueOf(p2.getDays() + 1));
+        cdr.setCalcu_start_date($qyrq);
+        cdr.setCalcu_end_date($toDate);
+
+        log.info("开始日期离启用日期的天数 qyrq_days=0");
+        log.info("总共需要排班的天数 sdays={}", (p2.getDays() + 1));
+
+        insert(cdr); // 插入fact数据，进入下一个阶段
+end
+
+//------------------------- 第二阶段、计算规则准备数据2（起始索引） ----------------------------//
+
+//----------------------- 路牌范围循环计算 ------------------------//
+
+declare Calcu_guideboard_index_result
+    ruleId : String // 规则Id
+    calcu_index : Integer // 计算之后的起始索引
+end
+
+// 启用日期等于开始日期
+rule "calcu_guideboard_index_qyrq_eq_startrq"
+    when
+        $calcu_days_result : Calcu_days_result(
+            qyrq_days == 0,
+            $ruleId: ruleId
+        )
+        $scheduleRule_input : ScheduleRule_input(
+            ruleId == $ruleId,
+            $oindex : startGbdIndex
+        )
+    then
+        Calcu_guideboard_index_result cgir = new Calcu_guideboard_index_result();
+        cgir.setRuleId($ruleId);
+        cgir.setCalcu_index($oindex);
+
+        log.info("calcu_guideboard_index_qyrq_eq_startrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
+
+        insert(cgir);
+end
+
+// 开始日期大于启用日期
+rule "calcu_guideboard_index_startrq_gt_qyrq"
+    when
+        $calcu_days_result : Calcu_days_result(
+            qyrq_days > 0,
+            $ruleId: ruleId, $qyrq_days: qyrq_days,
+            $calcu_start_date: calcu_start_date
+        )
+        $scheduleRule_input : ScheduleRule_input(
+            ruleId == $ruleId,
+            $qyrq: qyrq,
+            $rangesize : guideboardIds.size(),
+            $oindex : startGbdIndex,
+            $weekdays: weekdays
+        )
+    then
+        // 开始时间
+        DateTime initDate = $qyrq;
+        int index = $oindex;
+        int resultIndex = index;
+
+        while (!initDate.isAfter($calcu_start_date)) {
+            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
+                resultIndex = index;
+                index = (index + 1) % $rangesize;
+            }
+            initDate = initDate.plusDays(1);
+        }
+
+        Calcu_guideboard_index_result cgir = new Calcu_guideboard_index_result();
+        cgir.setRuleId($ruleId);
+        cgir.setCalcu_index(resultIndex);
+
+        log.info("calcu_guideboard_index_startrq_gt_qyrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
+
+        insert(cgir);
+end
+
+//----------------------- 人员范围循环计算 ------------------------//
+
+declare Calcu_employee_index_result
+    ruleId : String // 规则Id
+    calcu_index : Integer // 计算之后的起始索引
+end
+
+// 启用日期等于开始日期
+rule "calcu_employee_index_qyrq_eq_startrq"
+    when
+        $calcu_days_result : Calcu_days_result(
+            qyrq_days == 0,
+            $ruleId: ruleId)
+        $scheduleRule_input : ScheduleRule_input(
+            ruleId == $ruleId,
+            $oindex : startEIndex)
+    then
+        Calcu_employee_index_result cgir = new Calcu_employee_index_result();
+        cgir.setRuleId($ruleId);
+        cgir.setCalcu_index($oindex);
+
+        log.info("calcu_employee_index_qyrq_eq_startrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
+
+        insert(cgir);
+end
+
+// 开始日期大于启用日期
+rule "calcu_employee_index_startrq_gt_qyrq"
+    when
+        $calcu_days_result : Calcu_days_result(
+            qyrq_days > 0,
+            $ruleId: ruleId, $qyrq_days: qyrq_days,
+            $calcu_start_date: calcu_start_date
+        )
+        $scheduleRule_input : ScheduleRule_input(
+            ruleId == $ruleId,
+            $qyrq: qyrq,
+            $rangesize : employeeConfigIds.size(),
+            $oindex : startEIndex,
+            $weekdays: weekdays
+        )
+    then
+        // 开始时间
+        DateTime initDate = $qyrq;
+        int index = $oindex;
+        int resultIndex = index;
+
+        while (!initDate.isAfter($calcu_start_date)) {
+            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
+                resultIndex = index;
+                index = (index + 1) % $rangesize;
+            }
+            initDate = initDate.plusDays(1);
+        }
+
+        Calcu_employee_index_result cgir = new Calcu_employee_index_result();
+        cgir.setRuleId($ruleId);
+        cgir.setCalcu_index(resultIndex);
+
+        log.info("calcu_employee_index_startrq_gt_qyrq ruleId={}, calcu_index={}", $ruleId, cgir.getCalcu_index());
+
+        insert(cgir);
+
+end
+
+//------------------------- 第三阶段、循环计算 ------------------------//
+
+//----------------------- 路牌范围循环计算 ------------------------//
+declare loop_guideboard_result
+    ruleId : String // 规则id
+    go_list : List // 路牌循环的列表
+end
+
+// 循环路牌计算
+rule "Calcu_loop_guideboard_result"
+    when
+        Calcu_days_result(
+            $ruleId: ruleId,
+            $startDate : calcu_start_date,
+            $calcu_end_date: calcu_end_date
+        )
+        $ruleData : ScheduleRule_input(
+            ruleId == $ruleId,
+            $rangesize : guideboardIds.size(),
+            $weekdays: weekdays
+        )
+        $indexData : Calcu_guideboard_index_result(
+            ruleId == $ruleId
+        )
+    then
+        DateTime initDate = $startDate; // 开始时间
+        DateTime endDate = $calcu_end_date; // 结束实际
+        List<ScheduleResult_output> scheduleResult_outputs =
+            new ArrayList<ScheduleResult_output>();
+
+        int i = $indexData.getCalcu_index();
+        if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue() == false) {
+            i = (i + 1) % $rangesize;
+        }
+
+        while (!initDate.isAfter(endDate)) {
+            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
+                ScheduleResult_output ro = new ScheduleResult_output();
+                ro.setRuleId($ruleId);
+                ro.setSd(initDate);
+                ro.setGuideboardId($ruleData.getGuideboardIds().get(i));
+                ro.setCarConfigId($ruleData.getCarConfigId());
+                scheduleResult_outputs.add(ro);
+
+                i = (i + 1) % $rangesize;
+            }
+
+            initDate = initDate.plusDays(1);
+        }
+
+        loop_guideboard_result clgr = new loop_guideboard_result();
+        clgr.setRuleId($ruleId);
+        clgr.setGo_list(scheduleResult_outputs);
+
+        log.info(String.valueOf(scheduleResult_outputs.size()));
+
+        insert(clgr);
+
+end
+
+//----------------------- 人员范围循环计算 ------------------------//
+declare loop_employee_result
+    ruleId : String // 规则id
+    eo_list : List // 人员循环的列表
+end
+
+// 循环人员计算
+rule "Calcu_loop_employee_result"
+    when
+        Calcu_days_result(
+            $ruleId: ruleId,
+            $startDate : calcu_start_date,
+            $calcu_end_date: calcu_end_date
+        )
+        $ruleData : ScheduleRule_input(
+            ruleId == $ruleId,
+            $rangesize : employeeConfigIds.size(),
+            $weekdays: weekdays
+        )
+        $indexData : Calcu_employee_index_result(
+            ruleId == $ruleId
+        )
+    then
+        DateTime initDate = $startDate; // 开始时间
+        DateTime endDate = $calcu_end_date; // 结束实际
+        List<ScheduleResult_output> scheduleResult_outputs =
+            new ArrayList<ScheduleResult_output>();
+
+        int i = $indexData.getCalcu_index();
+        if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue() == false) {
+            i = (i + 1) % $rangesize;
+        }
+
+        while (!initDate.isAfter(endDate)) {
+            if (((Boolean) $weekdays.get(initDate.getDayOfWeek() - 1)).booleanValue()) {
+                ScheduleResult_output ro = new ScheduleResult_output();
+                ro.setRuleId($ruleId);
+                ro.setSd(initDate);
+                ro.setEmployeeConfigId($ruleData.getEmployeeConfigIds().get(i));
+                ro.setCarConfigId($ruleData.getCarConfigId());
+                scheduleResult_outputs.add(ro);
+
+                i = (i + 1) % $rangesize;
+            }
+
+            initDate = initDate.plusDays(1);
+        }
+
+        loop_employee_result clgr = new loop_employee_result();
+        clgr.setRuleId($ruleId);
+        clgr.setEo_list(scheduleResult_outputs);
+
+        log.info(String.valueOf(scheduleResult_outputs.size()));
+
+        insert(clgr);
+end
+
+//------------------------- 第四阶段、范围组循环计算 ----------------------------//
+
+global ScheduleResults_output scheduleResult;
+
+rule "output"
+    when
+        loop_guideboard_result(
+            go_list.size() > 0,
+            $ruleId : ruleId, $go_list : go_list
+        )
+        loop_employee_result(
+            ruleId == $ruleId,
+            eo_list.size() == $go_list.size(),
+            $eo_list : eo_list
+        )
+    then
+        for (int i = 0; i < $go_list.size(); i++) {
+            ScheduleResult_output go = (ScheduleResult_output) $go_list.get(i);
+            ScheduleResult_output eo = (ScheduleResult_output) $eo_list.get(i);
+            go.setEmployeeConfigId(eo.getEmployeeConfigId());
+            scheduleResult.getResults().add(go);
+        }
+
+end
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-package com.bsth.service.schedule.rules;
-
-import com.bsth.Application;
-import org.junit.runner.RunWith;
-import org.kie.api.KieBase;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.SpringApplicationConfiguration;
-import org.springframework.context.annotation.ComponentScan;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-/**
- * 测试类。
- */
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringApplicationConfiguration(classes = {Application.class})
-@ComponentScan(basePackages = {"com.bsth.entity"})
-public class DroolsRulesTest2 {
-    @Autowired
-    private KieBase kieBase;
-
-    @org.junit.Test
-    public void test1() throws Exception {
-        System.out.println("dfdfdfdfd");
-    }
-
-}
+package com.bsth.service.schedule.rules;
+
+import com.bsth.Application;
+import org.junit.runner.RunWith;
+import org.kie.api.KieBase;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.SpringApplicationConfiguration;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * 测试类。
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringApplicationConfiguration(classes = {Application.class})
+@ComponentScan(basePackages = {"com.bsth.entity"})
+public class DroolsRulesTest2 {
+    @Autowired
+    private KieBase kieBase;
+
+    @org.junit.Test
+    public void test1() throws Exception {
+        System.out.println("dfdfdfdfd");
+    }
+
+}