Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
ghsby
o2oa
提交
afaad21a
o2oa
项目概览
ghsby
/
o2oa
落后 Fork 源项目 2880 个版本
Fork自
浙江兰德纵横网络技术股份有限公司 / o2oa
通知
1
Star
1
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
o2oa
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
afaad21a
编写于
9月 08, 2020
作者:
Z
zhourui
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
add name alias
上级
76e966e3
变更
15
展开全部
隐藏空白更改
内联
并排
Showing
15 changed file
with
170 addition
and
229 deletion
+170
-229
o2server/x_processplatform_core_entity/src/main/java/com/x/processplatform/core/entity/log/Signal.java
...in/java/com/x/processplatform/core/entity/log/Signal.java
+110
-185
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/agent/AgentProcessor.java
...rm/service/processing/processor/agent/AgentProcessor.java
+3
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/begin/BeginProcessor.java
...rm/service/processing/processor/begin/BeginProcessor.java
+3
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/cancel/CancelProcessor.java
.../service/processing/processor/cancel/CancelProcessor.java
+5
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/choice/ChoiceProcessor.java
.../service/processing/processor/choice/ChoiceProcessor.java
+7
-5
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/delay/DelayProcessor.java
...rm/service/processing/processor/delay/DelayProcessor.java
+3
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/embed/EmbedProcessor.java
...rm/service/processing/processor/embed/EmbedProcessor.java
+3
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/end/EndProcessor.java
...atform/service/processing/processor/end/EndProcessor.java
+3
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/invoke/InvokeProcessor.java
.../service/processing/processor/invoke/InvokeProcessor.java
+5
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/ManualProcessor.java
.../service/processing/processor/manual/ManualProcessor.java
+4
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/merge/MergeProcessor.java
...rm/service/processing/processor/merge/MergeProcessor.java
+3
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/message/MessageProcessor.java
...ervice/processing/processor/message/MessageProcessor.java
+6
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/parallel/ParallelProcessor.java
...vice/processing/processor/parallel/ParallelProcessor.java
+6
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/service/ServiceProcessor.java
...ervice/processing/processor/service/ServiceProcessor.java
+6
-3
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/split/SplitProcessor.java
...rm/service/processing/processor/split/SplitProcessor.java
+3
-3
未找到文件。
o2server/x_processplatform_core_entity/src/main/java/com/x/processplatform/core/entity/log/Signal.java
浏览文件 @
afaad21a
此差异已折叠。
点击以展开。
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/agent/AgentProcessor.java
浏览文件 @
afaad21a
...
...
@@ -28,7 +28,7 @@ public class AgentProcessor extends AbstractAgentProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Agent
agent
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
agentArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
agentArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
agent
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -39,7 +39,7 @@ public class AgentProcessor extends AbstractAgentProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Agent
agent
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
agentExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
agentExecute
(
aeiObjects
.
getWork
().
getActivityToken
()
,
agent
));
List
<
Work
>
results
=
new
ArrayList
<>();
if
(
StringUtils
.
isNotEmpty
(
agent
.
getScript
())
||
StringUtils
.
isNotEmpty
(
agent
.
getScriptText
()))
{
CompiledScript
compiledScript
=
aeiObjects
.
business
().
element
().
getCompiledScript
(
...
...
@@ -58,7 +58,7 @@ public class AgentProcessor extends AbstractAgentProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Agent
agent
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
agentInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
agentInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
agent
));
List
<
Route
>
results
=
new
ArrayList
<>();
Route
o
=
aeiObjects
.
getRoutes
().
get
(
0
);
results
.
add
(
o
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/begin/BeginProcessor.java
浏览文件 @
afaad21a
...
...
@@ -36,7 +36,7 @@ public class BeginProcessor extends AbstractBeginProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Begin
begin
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
beginArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
beginArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
begin
));
// 创建创建者的review
String
person
=
this
.
business
().
organization
().
person
().
get
(
aeiObjects
.
getWork
().
getCreatorPerson
());
if
(
StringUtils
.
isNotEmpty
(
person
))
{
...
...
@@ -53,7 +53,7 @@ public class BeginProcessor extends AbstractBeginProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Begin
begin
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
beginExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
beginExecute
(
aeiObjects
.
getWork
().
getActivityToken
()
,
begin
));
List
<
Work
>
list
=
new
ArrayList
<>();
// 如果是再次进入begin节点那么就不需要设置开始时间
if
(
aeiObjects
.
getWork
().
getStartTime
()
==
null
)
{
...
...
@@ -78,7 +78,7 @@ public class BeginProcessor extends AbstractBeginProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Begin
begin
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
beginInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
beginInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
begin
));
List
<
Route
>
list
=
new
ArrayList
<>();
Route
o
=
aeiObjects
.
getRoutes
().
get
(
0
);
list
.
add
(
o
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/cancel/CancelProcessor.java
浏览文件 @
afaad21a
...
...
@@ -30,7 +30,7 @@ public class CancelProcessor extends AbstractCancelProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Cancel
cancel
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
cancelArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
cancelArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
cancel
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -42,7 +42,8 @@ public class CancelProcessor extends AbstractCancelProcessor {
@Override
public
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Cancel
cancel
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
cancelExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
cancelExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
cancel
));
// 唯一work处理
if
(
aeiObjects
.
getWorks
().
size
()
>
1
)
{
aeiObjects
.
getDeleteWorks
().
add
(
aeiObjects
.
getWork
());
...
...
@@ -84,7 +85,8 @@ public class CancelProcessor extends AbstractCancelProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Cancel
cancel
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
cancelInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
cancelInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
cancel
));
return
new
ArrayList
<>();
}
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/choice/ChoiceProcessor.java
浏览文件 @
afaad21a
...
...
@@ -31,19 +31,20 @@ public class ChoiceProcessor extends AbstractChoiceProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Choice
choice
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
choiceArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
choiceArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
choice
));
return
aeiObjects
.
getWork
();
}
@Override
protected
void
arrivingCommitted
(
AeiObjects
aeiObjects
,
Choice
choice
)
throws
Exception
{
//nothing
//
nothing
}
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Choice
choice
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
choiceExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
choiceExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
choice
));
List
<
Work
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getWork
());
return
results
;
...
...
@@ -51,13 +52,14 @@ public class ChoiceProcessor extends AbstractChoiceProcessor {
@Override
protected
void
executingCommitted
(
AeiObjects
aeiObjects
,
Choice
choice
)
throws
Exception
{
//nothing
//
nothing
}
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Choice
choice
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
choiceInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
choiceInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
choice
));
List
<
Route
>
results
=
new
ArrayList
<>();
// 多条路由进行判断
for
(
Route
o
:
aeiObjects
.
getRoutes
())
{
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/delay/DelayProcessor.java
浏览文件 @
afaad21a
...
...
@@ -32,7 +32,7 @@ public class DelayProcessor extends AbstractDelayProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Delay
delay
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
delayArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
delayArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
delay
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -43,7 +43,7 @@ public class DelayProcessor extends AbstractDelayProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Delay
delay
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
delayExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
delayExecute
(
aeiObjects
.
getWork
().
getActivityToken
()
,
delay
));
List
<
Work
>
results
=
new
ArrayList
<>();
Date
limit
=
null
;
if
(
null
!=
delay
.
getDelayMode
()
&&
Objects
.
equals
(
DelayMode
.
until
,
delay
.
getDelayMode
()))
{
...
...
@@ -122,7 +122,7 @@ public class DelayProcessor extends AbstractDelayProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Delay
delay
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
delayInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
delayInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
delay
));
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
return
results
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/embed/EmbedProcessor.java
浏览文件 @
afaad21a
...
...
@@ -37,7 +37,7 @@ public class EmbedProcessor extends AbstractEmbedProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Embed
embed
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
embedArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
embedArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
embed
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -48,7 +48,7 @@ public class EmbedProcessor extends AbstractEmbedProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Embed
embed
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
embedExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
embedExecute
(
aeiObjects
.
getWork
().
getActivityToken
()
,
embed
));
AssginData
assginData
=
new
AssginData
();
String
targetApplication
=
embed
.
getTargetApplication
();
String
targetProcess
=
embed
.
getTargetProcess
();
...
...
@@ -113,7 +113,7 @@ public class EmbedProcessor extends AbstractEmbedProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Embed
embed
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
embedInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
embedInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
embed
));
// 驱动上个环节新产生的work
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/end/EndProcessor.java
浏览文件 @
afaad21a
...
...
@@ -33,7 +33,7 @@ public class EndProcessor extends AbstractEndProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
End
end
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
endArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
endArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
end
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -45,7 +45,7 @@ public class EndProcessor extends AbstractEndProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
End
end
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
endExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
endExecute
(
aeiObjects
.
getWork
().
getActivityToken
()
,
end
));
List
<
Work
>
results
=
new
ArrayList
<>();
Work
other
=
aeiObjects
.
getWorks
().
stream
().
filter
(
o
->
o
!=
aeiObjects
.
getWork
())
...
...
@@ -156,7 +156,7 @@ public class EndProcessor extends AbstractEndProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
End
end
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
endInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
endInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
end
));
return
new
ArrayList
<>();
}
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/invoke/InvokeProcessor.java
浏览文件 @
afaad21a
...
...
@@ -43,14 +43,15 @@ public class InvokeProcessor extends AbstractInvokeProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Invoke
invoke
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
invokeArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
invokeArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
invoke
));
return
aeiObjects
.
getWork
();
}
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Invoke
invoke
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
invokeExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
invokeExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
invoke
));
List
<
Work
>
results
=
new
ArrayList
<>();
switch
(
invoke
.
getInvokeMode
())
{
case
jaxws:
...
...
@@ -69,7 +70,8 @@ public class InvokeProcessor extends AbstractInvokeProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Invoke
invoke
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
invokeInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
invokeInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
invoke
));
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
return
results
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/ManualProcessor.java
浏览文件 @
afaad21a
...
...
@@ -60,7 +60,7 @@ public class ManualProcessor extends AbstractManualProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Manual
manual
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
manualArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
manualArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
manual
));
// 根据manual计算出来的活动处理人
List
<
String
>
identities
=
calculateTaskIdentities
(
aeiObjects
,
manual
);
// 启用同类工作相同活动节点合并,如果有合并的工作,那么直接返回这个工作.
...
...
@@ -297,7 +297,7 @@ public class ManualProcessor extends AbstractManualProcessor {
}
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
manualExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
manualExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
manual
,
Objects
.
toString
(
manual
.
getManualMode
(),
""
),
identities
));
switch
(
manual
.
getManualMode
())
{
...
...
@@ -331,7 +331,8 @@ public class ManualProcessor extends AbstractManualProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Manual
manual
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
manualInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
manualInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
manual
));
List
<
Route
>
results
=
new
ArrayList
<>();
// 仅有单条路由
if
(
aeiObjects
.
getRoutes
().
size
()
==
1
)
{
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/merge/MergeProcessor.java
浏览文件 @
afaad21a
...
...
@@ -27,7 +27,7 @@ public class MergeProcessor extends AbstractMergeProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Merge
merge
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
mergeArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
mergeArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
merge
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -38,7 +38,7 @@ public class MergeProcessor extends AbstractMergeProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Merge
merge
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
mergeExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
mergeExecute
(
aeiObjects
.
getWork
().
getActivityToken
()
,
merge
));
List
<
Work
>
results
=
new
ArrayList
<>();
if
(
BooleanUtils
.
isNotTrue
(
aeiObjects
.
getWork
().
getSplitting
()))
{
/* 如果不是一个拆分文档,直接通过 */
...
...
@@ -220,7 +220,7 @@ public class MergeProcessor extends AbstractMergeProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Merge
merge
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
mergeInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
mergeInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
merge
));
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
return
results
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/message/MessageProcessor.java
浏览文件 @
afaad21a
...
...
@@ -24,7 +24,8 @@ public class MessageProcessor extends AbstractMessageProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Message
message
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
messageArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
messageArrive
(
aeiObjects
.
getWork
().
getActivityToken
(),
message
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -36,7 +37,8 @@ public class MessageProcessor extends AbstractMessageProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Message
message
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
messageExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
messageExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
message
));
MessageFactory
.
activity_message
(
aeiObjects
.
getWork
(),
null
);
List
<
Work
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getWork
());
...
...
@@ -51,7 +53,8 @@ public class MessageProcessor extends AbstractMessageProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Message
message
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
messageInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
messageInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
message
));
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
return
results
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/parallel/ParallelProcessor.java
浏览文件 @
afaad21a
...
...
@@ -33,7 +33,8 @@ public class ParallelProcessor extends AbstractParallelProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Parallel
parallel
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
parallelArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
parallelArrive
(
aeiObjects
.
getWork
().
getActivityToken
(),
parallel
));
logger
.
info
(
"parallel arrvie processing, work title:{}, id:{}, actvity name:{}, id:{}, activityToken:{}, process name:{}, id{}."
,
aeiObjects
.
getWork
().
getTitle
(),
aeiObjects
.
getWork
().
getId
(),
parallel
.
getName
(),
parallel
.
getId
(),
...
...
@@ -50,7 +51,8 @@ public class ParallelProcessor extends AbstractParallelProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Parallel
parallel
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
parallelExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
parallelExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
parallel
));
List
<
Work
>
results
=
new
ArrayList
<>();
aeiObjects
.
getWork
().
setSplitting
(
true
);
aeiObjects
.
getWork
().
setSplitToken
(
StringTools
.
uniqueToken
());
...
...
@@ -110,7 +112,8 @@ public class ParallelProcessor extends AbstractParallelProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Parallel
parallel
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
parallelInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
parallelInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
parallel
));
List
<
Route
>
results
=
new
ArrayList
<>();
aeiObjects
.
getRoutes
().
stream
().
forEach
(
o
->
{
if
(
StringUtils
.
equals
(
o
.
getId
(),
aeiObjects
.
getWork
().
getDestinationRoute
()))
{
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/service/ServiceProcessor.java
浏览文件 @
afaad21a
...
...
@@ -31,7 +31,8 @@ public class ServiceProcessor extends AbstractServiceProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Service
service
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
serviceArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
serviceArrive
(
aeiObjects
.
getWork
().
getActivityToken
(),
service
));
// 清空上一次调用值
aeiObjects
.
getWork
().
getProperties
().
setServiceValue
(
new
LinkedHashMap
<>());
return
aeiObjects
.
getWork
();
...
...
@@ -45,7 +46,8 @@ public class ServiceProcessor extends AbstractServiceProcessor {
@Override
protected
List
<
Work
>
executing
(
AeiObjects
aeiObjects
,
Service
service
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
parallelExecute
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
parallelExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
service
));
List
<
Work
>
results
=
new
ArrayList
<>();
boolean
passThrough
=
false
;
if
(
StringUtils
.
isNotEmpty
(
service
.
getScript
())
||
StringUtils
.
isNotEmpty
(
service
.
getScriptText
()))
{
...
...
@@ -73,7 +75,8 @@ public class ServiceProcessor extends AbstractServiceProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Service
service
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
parallelInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
parallelInquire
(
aeiObjects
.
getWork
().
getActivityToken
(),
service
));
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
return
results
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/split/SplitProcessor.java
浏览文件 @
afaad21a
...
...
@@ -32,7 +32,7 @@ public class SplitProcessor extends AbstractSplitProcessor {
@Override
protected
Work
arriving
(
AeiObjects
aeiObjects
,
Split
split
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
splitArrive
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
splitArrive
(
aeiObjects
.
getWork
().
getActivityToken
()
,
split
));
return
aeiObjects
.
getWork
();
}
...
...
@@ -55,7 +55,7 @@ public class SplitProcessor extends AbstractSplitProcessor {
}
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
()
.
push
(
Signal
.
splitExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
splitValues
));
.
push
(
Signal
.
splitExecute
(
aeiObjects
.
getWork
().
getActivityToken
(),
split
,
split
Values
));
// 先将当前文档标志拆分值
aeiObjects
.
getWork
().
setSplitValue
(
splitValues
.
get
(
0
));
aeiObjects
.
getWork
().
getSplitValueList
().
add
(
splitValues
.
get
(
0
));
...
...
@@ -100,7 +100,7 @@ public class SplitProcessor extends AbstractSplitProcessor {
@Override
protected
List
<
Route
>
inquiring
(
AeiObjects
aeiObjects
,
Split
split
)
throws
Exception
{
// 发送ProcessingSignal
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
splitInquire
(
aeiObjects
.
getWork
().
getActivityToken
()));
aeiObjects
.
getProcessingAttributes
().
push
(
Signal
.
splitInquire
(
aeiObjects
.
getWork
().
getActivityToken
()
,
split
));
List
<
Route
>
results
=
new
ArrayList
<>();
results
.
add
(
aeiObjects
.
getRoutes
().
get
(
0
));
return
results
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录