validplan.drl
3.39 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
package com.bsth.service.schedule.rules.validate;
import com.bsth.entity.schedule.SchedulePlanInfo;
import com.bsth.service.schedule.rules.ttinfo.LpInfoResult_output;
import com.bsth.service.schedule.rules.validate.ValidateResource;
import org.joda.time.*;
import java.util.*;
import org.slf4j.Logger;
// 全局日志类（一般使用调用此规则的service类）
global Logger log;
// 输出
global ValidateResults_output validResult;
//------------------------- 第一阶段、构造验证源 ----------------------------//
rule "Calcu_validate_resource"
salience 2000
when
$spi: SchedulePlanInfo($sd: scheduleDate)
$lpiList: ArrayList() from collect (LpInfoResult_output(dateTime.getMillis() == $sd.getTime()))
then
ValidateResource resource = new ValidateResource();
resource.setSd($sd);
resource.setSpi($spi);
resource.setLpiList($lpiList);
insert(resource);
end
//------------------------- 第二阶段、构造循环体 ----------------------------//
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))
$vrList: ArrayList() from collect (ValidateResource(sd.getTime() == $sd.getMillis()))
$infos: ArrayList() from accumulate ($vr: ValidateResource() from $vrList, vrb($vr.getSpi()))
$infos2: ArrayList() from accumulate ($vr: ValidateResource() from $vrList, vwrb($vr.getSpi()))
$infos3: ArrayList() from accumulate ($vr: ValidateResource() from $vrList, vwlp($vr))
then
// TODO：
// log.info("日期={}，班次重复错误数={}", $sd, $infos.size());
// log.info("班次数={}", $vrList.size());
validResult.getInfos().addAll($infos);
validResult.getInfos().addAll($infos2);
validResult.getInfos().addAll($infos3);
// 迭代
$lp.setStart_date($sd.plusDays(1));
update($lp);
end
//
//declare LpInfo_wrap
// sd: DateTime // 具体日期
// lpId: Long // 路牌Id
// isPlan: Boolean = false // 是否排班
//end
//
//rule "Calcu_LpInfo_wrap"
// salience 500
// when
// $lp: LpInfoResult_output()
// then
// LpInfo_wrap ll = new LpInfo_wrap();
// ll.setSd($lp.getDateTime());
// ll.setLpId(Long.parseLong($lp.getLpId()));
//
// insert(ll);
//end
//
//rule "Valid_Lp_plan" // 查看路牌是否被排班
// salience 400
// no-loop
// when
// $sp: SchedulePlanInfo($lp: lp)
// $ll: LpInfo_wrap(lpId == $lp)
// then
// $ll.setIsPlan(true);
// update($ll);
//end
//
//// TODO：