Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
weixin_42566577
o2oa
提交
795308de
o2oa
项目概览
weixin_42566577
/
o2oa
与 Fork 源项目一致
Fork自
浙江兰德纵横网络技术股份有限公司 / o2oa
通知
1
Star
0
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,发现更多精彩内容 >>
提交
795308de
编写于
6月 08, 2022
作者:
Z
zhourui
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
UCDetector clean
上级
b269eecc
变更
45
展开全部
隐藏空白更改
内联
并排
Showing
45 changed file
with
332 addition
and
1571 deletion
+332
-1571
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/AbstractFactory.java
...x/processplatform/service/processing/AbstractFactory.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/BindingPair.java
...com/x/processplatform/service/processing/BindingPair.java
+0
-30
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/Processing.java
.../com/x/processplatform/service/processing/Processing.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/AttachmentFactory.java
...latform/service/processing/factory/AttachmentFactory.java
+9
-9
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/DocumentVersionFactory.java
...rm/service/processing/factory/DocumentVersionFactory.java
+9
-9
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/ReadCompletedFactory.java
...form/service/processing/factory/ReadCompletedFactory.java
+18
-18
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/ReadFactory.java
...ocessplatform/service/processing/factory/ReadFactory.java
+40
-40
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/ReviewFactory.java
...essplatform/service/processing/factory/ReviewFactory.java
+21
-21
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/TaskCompletedFactory.java
...form/service/processing/factory/TaskCompletedFactory.java
+29
-29
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/TaskFactory.java
...ocessplatform/service/processing/factory/TaskFactory.java
+36
-36
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/WorkCompletedFactory.java
...form/service/processing/factory/WorkCompletedFactory.java
+9
-9
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/WorkFactory.java
...ocessplatform/service/processing/factory/WorkFactory.java
+27
-27
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/WorkLogFactory.java
...ssplatform/service/processing/factory/WorkLogFactory.java
+118
-118
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/data/ExceptionEmptyData.java
...orm/service/processing/jaxrs/data/ExceptionEmptyData.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/data/ExceptionNotExistItem.java
.../service/processing/jaxrs/data/ExceptionNotExistItem.java
+0
-11
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/service/ExceptionService.java
...rm/service/processing/jaxrs/service/ExceptionService.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/service/ExceptionWorkLogWithActivityTokenNotExist.java
...rs/service/ExceptionWorkLogWithActivityTokenNotExist.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/task/ExceptionEmptyFilter.java
...m/service/processing/jaxrs/task/ExceptionEmptyFilter.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/task/ExceptionInvalidCount.java
.../service/processing/jaxrs/task/ExceptionInvalidCount.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/task/ExceptionResetEmpty.java
...rm/service/processing/jaxrs/task/ExceptionResetEmpty.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionSplittingCannotCallback.java
...ocessing/jaxrs/work/ExceptionSplittingCannotCallback.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionSplittingNotRollback.java
.../processing/jaxrs/work/ExceptionSplittingNotRollback.java
+0
-12
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionWorkLogNotExist.java
...rvice/processing/jaxrs/work/ExceptionWorkLogNotExist.java
+0
-13
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionWorkNotMatchWithWorkLog.java
...ocessing/jaxrs/work/ExceptionWorkNotMatchWithWorkLog.java
+0
-14
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/neural/NeuralAnalyzer.java
...essplatform/service/processing/neural/NeuralAnalyzer.java
+0
-186
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/AbstractBaseProcessor.java
...m/service/processing/processor/AbstractBaseProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/ExceptionProcessNotExist.java
...ervice/processing/processor/ExceptionProcessNotExist.java
+0
-13
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/agent/AbstractAgentProcessor.java
...ce/processing/processor/agent/AbstractAgentProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/agent/ExceptionInterrupt.java
...ervice/processing/processor/agent/ExceptionInterrupt.java
+0
-15
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/begin/AbstractBeginProcessor.java
...ce/processing/processor/begin/AbstractBeginProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/cancel/AbstractCancelProcessor.java
.../processing/processor/cancel/AbstractCancelProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/choice/AbstractChoiceProcessor.java
.../processing/processor/choice/AbstractChoiceProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/delay/AbstractDelayProcessor.java
...ce/processing/processor/delay/AbstractDelayProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/embed/AbstractEmbedProcessor.java
...ce/processing/processor/embed/AbstractEmbedProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/end/AbstractEndProcessor.java
...ervice/processing/processor/end/AbstractEndProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/invoke/AbstractInvokeProcessor.java
.../processing/processor/invoke/AbstractInvokeProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/AbstractManualProcessor.java
.../processing/processor/manual/AbstractManualProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/ExceptionManualModeError.java
...processing/processor/manual/ExceptionManualModeError.java
+0
-13
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/ManualProcessor2.java
...service/processing/processor/manual/ManualProcessor2.java
+0
-822
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/merge/AbstractMergeProcessor.java
...ce/processing/processor/merge/AbstractMergeProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/parallel/AbstractParallelProcessor.java
...cessing/processor/parallel/AbstractParallelProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/parallel/ExceptionParallelNotFoundRoute.java
...ng/processor/parallel/ExceptionParallelNotFoundRoute.java
+0
-13
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/service/AbstractServiceProcessor.java
...rocessing/processor/service/AbstractServiceProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/split/AbstractSplitProcessor.java
...ce/processing/processor/split/AbstractSplitProcessor.java
+1
-1
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/schedule/ExceptionTouchEmbedWaitUntilCompleted.java
...ssing/schedule/ExceptionTouchEmbedWaitUntilCompleted.java
+0
-13
未找到文件。
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/AbstractFactory.java
浏览文件 @
795308de
...
...
@@ -4,7 +4,7 @@ import com.x.base.core.container.EntityManagerContainer;
public
abstract
class
AbstractFactory
{
pr
otected
Business
business
;
pr
ivate
Business
business
;
public
AbstractFactory
(
Business
business
)
throws
Exception
{
try
{
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/BindingPair.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing
;
public
class
BindingPair
{
public
BindingPair
(
String
name
,
Object
value
)
{
this
.
name
=
name
;
this
.
value
=
value
;
}
private
String
name
;
private
Object
value
;
public
String
getName
()
{
return
name
;
}
public
void
setName
(
String
name
)
{
this
.
name
=
name
;
}
public
Object
getValue
()
{
return
value
;
}
public
void
setValue
(
Object
value
)
{
this
.
value
=
value
;
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/Processing.java
浏览文件 @
795308de
...
...
@@ -18,7 +18,7 @@ public class Processing extends BaseProcessing {
private
EntityManagerContainer
entityManagerContainer
;
pr
otected
ProcessingAttributes
processingAttributes
;
pr
ivate
ProcessingAttributes
processingAttributes
;
public
EntityManagerContainer
entityManagerContainer
()
{
return
this
.
entityManagerContainer
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/AttachmentFactory.java
浏览文件 @
795308de
...
...
@@ -29,13 +29,13 @@ public class AttachmentFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
Attachment
>
listWithJobObject
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Attachment
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
Attachment
>
cq
=
cb
.
createQuery
(
Attachment
.
class
);
Root
<
Attachment
>
root
=
cq
.
from
(
Attachment
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Attachment_
.
job
),
job
);
cq
.
select
(
root
).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<Attachment> listWithJobObject(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Attachment.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<Attachment> cq = cb.createQuery(Attachment.class);
//
Root<Attachment> root = cq.from(Attachment.class);
//
Predicate p = cb.equal(root.get(Attachment_.job), job);
//
cq.select(root).where(p);
//
return em.createQuery(cq).getResultList();
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/DocumentVersionFactory.java
浏览文件 @
795308de
...
...
@@ -20,13 +20,13 @@ public class DocumentVersionFactory extends AbstractFactory {
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
DocumentVersion
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
DocumentVersion
>
root
=
cq
.
from
(
DocumentVersion
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
DocumentVersion_
.
job
),
job
);
cq
.
select
(
root
.
get
(
DocumentVersion_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(DocumentVersion.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<DocumentVersion> root = cq.from(DocumentVersion.class);
//
Predicate p = cb.equal(root.get(DocumentVersion_.job), job);
//
cq.select(root.get(DocumentVersion_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/ReadCompletedFactory.java
浏览文件 @
795308de
...
...
@@ -29,24 +29,24 @@ public class ReadCompletedFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
ReadCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
ReadCompleted
>
root
=
cq
.
from
(
ReadCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
ReadCompleted_
.
job
),
job
);
cq
.
select
(
root
.
get
(
ReadCompleted_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(ReadCompleted.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<ReadCompleted> root = cq.from(ReadCompleted.class);
//
Predicate p = cb.equal(root.get(ReadCompleted_.job), job);
//
cq.select(root.get(ReadCompleted_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithActivityToken
(
String
activityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
ReadCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
ReadCompleted
>
root
=
cq
.
from
(
ReadCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
ReadCompleted_
.
activityToken
),
activityToken
);
cq
.
select
(
root
.
get
(
ReadCompleted_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityToken(String activityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(ReadCompleted.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<ReadCompleted> root = cq.from(ReadCompleted.class);
//
Predicate p = cb.equal(root.get(ReadCompleted_.activityToken), activityToken);
//
cq.select(root.get(ReadCompleted_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/ReadFactory.java
浏览文件 @
795308de
...
...
@@ -29,47 +29,47 @@ public class ReadFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Read
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Read
>
root
=
cq
.
from
(
Read
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Read_
.
job
),
job
);
cq
.
select
(
root
.
get
(
Read_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Read.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Read> root = cq.from(Read.class);
//
Predicate p = cb.equal(root.get(Read_.job), job);
//
cq.select(root.get(Read_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithPersonWithWork
(
String
person
,
String
work
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Read
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Read
>
root
=
cq
.
from
(
Read
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Read_
.
person
),
person
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
Read_
.
completed
),
false
));
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
Read_
.
work
),
work
));
cq
.
select
(
root
.
get
(
Read_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithPersonWithWork(String person, String work) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Read.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Read> root = cq.from(Read.class);
//
Predicate p = cb.equal(root.get(Read_.person), person);
//
p = cb.and(p, cb.equal(root.get(Read_.completed), false));
//
p = cb.and(p, cb.equal(root.get(Read_.work), work));
//
cq.select(root.get(Read_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithPersonWithWorkCompleted
(
String
person
,
String
workCompleted
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Read
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Read
>
root
=
cq
.
from
(
Read
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Read_
.
person
),
person
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
Read_
.
completed
),
true
));
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
Read_
.
workCompleted
),
workCompleted
));
cq
.
select
(
root
.
get
(
Read_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithPersonWithWorkCompleted(String person, String workCompleted) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Read.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Read> root = cq.from(Read.class);
//
Predicate p = cb.equal(root.get(Read_.person), person);
//
p = cb.and(p, cb.equal(root.get(Read_.completed), true));
//
p = cb.and(p, cb.equal(root.get(Read_.workCompleted), workCompleted));
//
cq.select(root.get(Read_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithActivityToken
(
String
activityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Read
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Read
>
root
=
cq
.
from
(
Read
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Read_
.
activityToken
),
activityToken
);
cq
.
select
(
root
.
get
(
Read_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityToken(String activityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Read.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Read> root = cq.from(Read.class);
//
Predicate p = cb.equal(root.get(Read_.activityToken), activityToken);
//
cq.select(root.get(Read_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/ReviewFactory.java
浏览文件 @
795308de
...
...
@@ -29,26 +29,26 @@ public class ReviewFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Review
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Review
>
root
=
cq
.
from
(
Review
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Review_
.
job
),
job
);
cq
.
select
(
root
.
get
(
Review_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
String
getWithPersonWithJob
(
String
person
,
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Review
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Review
>
root
=
cq
.
from
(
Review
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Review_
.
person
),
person
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
Review_
.
job
),
job
));
cq
.
select
(
root
.
get
(
Review_
.
id
)).
where
(
p
);
List
<
String
>
list
=
em
.
createQuery
(
cq
).
setMaxResults
(
1
).
getResultList
();
return
list
.
isEmpty
()
?
null
:
list
.
get
(
0
);
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Review.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Review> root = cq.from(Review.class);
//
Predicate p = cb.equal(root.get(Review_.job), job);
//
cq.select(root.get(Review_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
//
public String getWithPersonWithJob(String person, String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Review.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Review> root = cq.from(Review.class);
//
Predicate p = cb.equal(root.get(Review_.person), person);
//
p = cb.and(p, cb.equal(root.get(Review_.job), job));
//
cq.select(root.get(Review_.id)).where(p);
//
List<String> list = em.createQuery(cq).setMaxResults(1).getResultList();
//
return list.isEmpty() ? null : list.get(0);
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/TaskCompletedFactory.java
浏览文件 @
795308de
...
...
@@ -47,36 +47,36 @@ public class TaskCompletedFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
TaskCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
TaskCompleted
>
root
=
cq
.
from
(
TaskCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
TaskCompleted_
.
job
),
job
);
cq
.
select
(
root
.
get
(
TaskCompleted_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(TaskCompleted.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<TaskCompleted> root = cq.from(TaskCompleted.class);
//
Predicate p = cb.equal(root.get(TaskCompleted_.job), job);
//
cq.select(root.get(TaskCompleted_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithActivityTokenInIdentityList
(
String
activityToken
,
List
<
String
>
identites
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
TaskCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
TaskCompleted
>
root
=
cq
.
from
(
TaskCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
TaskCompleted_
.
activityToken
),
activityToken
);
p
=
cb
.
and
(
p
,
root
.
get
(
TaskCompleted_
.
identity
).
in
(
identites
));
cq
.
select
(
root
.
get
(
TaskCompleted_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityTokenInIdentityList(String activityToken, List<String> identites)
//
throws Exception {
//
EntityManager em = this.entityManagerContainer().get(TaskCompleted.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<TaskCompleted> root = cq.from(TaskCompleted.class);
//
Predicate p = cb.equal(root.get(TaskCompleted_.activityToken), activityToken);
//
p = cb.and(p, root.get(TaskCompleted_.identity).in(identites));
//
cq.select(root.get(TaskCompleted_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithActivityToken
(
String
activityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
TaskCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
TaskCompleted
>
root
=
cq
.
from
(
TaskCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
TaskCompleted_
.
activityToken
),
activityToken
);
cq
.
select
(
root
.
get
(
TaskCompleted_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityToken(String activityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(TaskCompleted.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<TaskCompleted> root = cq.from(TaskCompleted.class);
//
Predicate p = cb.equal(root.get(TaskCompleted_.activityToken), activityToken);
//
cq.select(root.get(TaskCompleted_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/TaskFactory.java
浏览文件 @
795308de
...
...
@@ -29,44 +29,44 @@ public class TaskFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
Task
>
listWithWorkObject
(
String
id
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Task
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
Task
>
cq
=
cb
.
createQuery
(
Task
.
class
);
Root
<
Task
>
root
=
cq
.
from
(
Task
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Task_
.
work
),
id
);
cq
.
select
(
root
).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<Task> listWithWorkObject(String id) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Task.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<Task> cq = cb.createQuery(Task.class);
//
Root<Task> root = cq.from(Task.class);
//
Predicate p = cb.equal(root.get(Task_.work), id);
//
cq.select(root).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Task
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Task
>
root
=
cq
.
from
(
Task
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Task_
.
job
),
job
);
cq
.
select
(
root
.
get
(
Task_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Task.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Task> root = cq.from(Task.class);
//
Predicate p = cb.equal(root.get(Task_.job), job);
//
cq.select(root.get(Task_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
Long
countWithActivityToken
(
String
activityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Task
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
Long
>
cq
=
cb
.
createQuery
(
Long
.
class
);
Root
<
Task
>
root
=
cq
.
from
(
Task
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Task_
.
activityToken
),
activityToken
);
cq
.
select
(
cb
.
count
(
root
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getSingleResult
();
}
//
public Long countWithActivityToken(String activityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Task.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<Long> cq = cb.createQuery(Long.class);
//
Root<Task> root = cq.from(Task.class);
//
Predicate p = cb.equal(root.get(Task_.activityToken), activityToken);
//
cq.select(cb.count(root)).where(p);
//
return em.createQuery(cq).getSingleResult();
//
}
public
List
<
String
>
listWithActivityToken
(
String
activityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Task
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Task
>
root
=
cq
.
from
(
Task
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Task_
.
activityToken
),
activityToken
);
cq
.
select
(
root
.
get
(
Task_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityToken(String activityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Task.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Task> root = cq.from(Task.class);
//
Predicate p = cb.equal(root.get(Task_.activityToken), activityToken);
//
cq.select(root.get(Task_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/WorkCompletedFactory.java
浏览文件 @
795308de
...
...
@@ -19,15 +19,15 @@ public class WorkCompletedFactory extends AbstractFactory {
super
(
business
);
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
WorkCompleted
>
root
=
cq
.
from
(
WorkCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
WorkCompleted_
.
job
),
job
);
cq
.
select
(
root
.
get
(
WorkCompleted_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
.
where
(
p
)).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(WorkCompleted.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<WorkCompleted> root = cq.from(WorkCompleted.class);
//
Predicate p = cb.equal(root.get(WorkCompleted_.job), job);
//
cq.select(root.get(WorkCompleted_.id)).where(p);
//
return em.createQuery(cq.where(p)).getResultList();
//
}
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/WorkFactory.java
浏览文件 @
795308de
...
...
@@ -29,15 +29,15 @@ public class WorkFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
.
where
(
p
)).
getResultList
();
}
public
List
<
String
>
listContainSplitToken
(
String
splitToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Work
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Work
>
root
=
cq
.
from
(
Work
.
class
);
Predicate
p
=
cb
.
isMember
(
splitToken
,
root
.
get
(
Work_
.
splitTokenList
));
cq
.
select
(
root
.
get
(
Work_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
.
where
(
p
)).
getResultList
();
}
//
public List<String> listContainSplitToken(String splitToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Work.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Work> root = cq.from(Work.class);
//
Predicate p = cb.isMember(splitToken, root.get(Work_.splitTokenList));
//
cq.select(root.get(Work_.id)).where(p);
//
return em.createQuery(cq.where(p)).getResultList();
//
}
// public Long countWithAttachment(String attachment) throws Exception {
// EntityManager em = this.entityManagerContainer().get(Work.class);
...
...
@@ -52,25 +52,25 @@ public class WorkFactory extends AbstractFactory {
/*
* 查找activityToken的Work,处于某一个ActivityToken的Work理论上只能有一个,但是在按值拆分的过程中可能临时产生多个
*/
public
List
<
String
>
listWithActivityToken
(
String
activityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Work
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Work
>
root
=
cq
.
from
(
Work
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Work_
.
activityToken
),
activityToken
);
cq
.
select
(
root
.
get
(
Work_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityToken(String activityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Work.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Work> root = cq.from(Work.class);
//
Predicate p = cb.equal(root.get(Work_.activityToken), activityToken);
//
cq.select(root.get(Work_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
public
List
<
String
>
listWithActivityToken
(
List
<
String
>
activityTokens
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
Work
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
Work
>
root
=
cq
.
from
(
Work
.
class
);
Predicate
p
=
root
.
get
(
Work_
.
activityToken
).
in
(
activityTokens
);
cq
.
select
(
root
.
get
(
Work_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithActivityToken(List<String> activityTokens) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(Work.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<Work> root = cq.from(Work.class);
//
Predicate p = root.get(Work_.activityToken).in(activityTokens);
//
cq.select(root.get(Work_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
// /* 添加一个hint */
// public void addHint(Work work, String hint) {
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/factory/WorkLogFactory.java
浏览文件 @
795308de
...
...
@@ -34,59 +34,59 @@ public class WorkLogFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithJob
(
String
job
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkLog
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
WorkLog
>
root
=
cq
.
from
(
WorkLog
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
WorkLog_
.
job
),
job
);
cq
.
select
(
root
.
get
(
WorkLog_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
//
public List<String> listWithJob(String job) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(WorkLog.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<WorkLog> root = cq.from(WorkLog.class);
//
Predicate p = cb.equal(root.get(WorkLog_.job), job);
//
cq.select(root.get(WorkLog_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
/* 从一个节点到另一个节点可能有多条 */
public
List
<
String
>
listWithFromActivityTokenWithConnected
(
String
fromActivityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkLog
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
WorkLog
>
root
=
cq
.
from
(
WorkLog
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
WorkLog_
.
fromActivityToken
),
fromActivityToken
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
WorkLog_
.
connected
),
true
));
cq
.
select
(
root
.
get
(
WorkLog_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
String
getWithFromActivityTokenWithNotConnected
(
String
fromActivityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkLog
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
WorkLog
>
root
=
cq
.
from
(
WorkLog
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
WorkLog_
.
fromActivityToken
),
fromActivityToken
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
WorkLog_
.
connected
),
false
));
cq
.
select
(
root
.
get
(
WorkLog_
.
id
)).
where
(
p
);
List
<
String
>
list
=
em
.
createQuery
(
cq
).
setMaxResults
(
1
).
getResultList
();
if
(!
list
.
isEmpty
())
{
return
list
.
get
(
0
);
}
else
{
return
null
;
}
}
public
String
getWithArrivedActivityTokenWithConnected
(
String
arrivedActivityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkLog
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
WorkLog
>
root
=
cq
.
from
(
WorkLog
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
WorkLog_
.
arrivedActivityToken
),
arrivedActivityToken
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
WorkLog_
.
connected
),
true
));
cq
.
select
(
root
.
get
(
WorkLog_
.
id
)).
where
(
p
);
List
<
String
>
list
=
em
.
createQuery
(
cq
).
setMaxResults
(
1
).
getResultList
();
if
(!
list
.
isEmpty
())
{
return
list
.
get
(
0
);
}
else
{
return
null
;
}
}
//
public List<String> listWithFromActivityTokenWithConnected(String fromActivityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(WorkLog.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<WorkLog> root = cq.from(WorkLog.class);
//
Predicate p = cb.equal(root.get(WorkLog_.fromActivityToken), fromActivityToken);
//
p = cb.and(p, cb.equal(root.get(WorkLog_.connected), true));
//
cq.select(root.get(WorkLog_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
//
public String getWithFromActivityTokenWithNotConnected(String fromActivityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(WorkLog.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<WorkLog> root = cq.from(WorkLog.class);
//
Predicate p = cb.equal(root.get(WorkLog_.fromActivityToken), fromActivityToken);
//
p = cb.and(p, cb.equal(root.get(WorkLog_.connected), false));
//
cq.select(root.get(WorkLog_.id)).where(p);
//
List<String> list = em.createQuery(cq).setMaxResults(1).getResultList();
//
if (!list.isEmpty()) {
//
return list.get(0);
//
} else {
//
return null;
//
}
//
}
//
public String getWithArrivedActivityTokenWithConnected(String arrivedActivityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(WorkLog.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<WorkLog> root = cq.from(WorkLog.class);
//
Predicate p = cb.equal(root.get(WorkLog_.arrivedActivityToken), arrivedActivityToken);
//
p = cb.and(p, cb.equal(root.get(WorkLog_.connected), true));
//
cq.select(root.get(WorkLog_.id)).where(p);
//
List<String> list = em.createQuery(cq).setMaxResults(1).getResultList();
//
if (!list.isEmpty()) {
//
return list.get(0);
//
} else {
//
return null;
//
}
//
}
public
List
<
String
>
listWithFromActivityToken
(
String
fromActivityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkLog
.
class
);
...
...
@@ -98,71 +98,71 @@ public class WorkLogFactory extends AbstractFactory {
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithArrivedActivityToken
(
String
arrivedActivityToken
)
throws
Exception
{
EntityManager
em
=
this
.
entityManagerContainer
().
get
(
WorkLog
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
WorkLog
>
root
=
cq
.
from
(
WorkLog
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
WorkLog_
.
arrivedActivityToken
),
arrivedActivityToken
);
cq
.
select
(
root
.
get
(
WorkLog_
.
id
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
public
List
<
String
>
listWithFromActivityTokenForwardNotConnected
(
String
activityToken
)
throws
Exception
{
List
<
String
>
results
=
SetUniqueList
.
setUniqueList
(
new
ArrayList
<
String
>());
this
.
listWithFromActivityTokenForwardNotConnected
(
activityToken
,
results
);
return
results
;
}
private
void
listWithFromActivityTokenForwardNotConnected
(
String
activityToken
,
List
<
String
>
results
)
throws
Exception
{
List
<
String
>
arrived
=
SetUniqueList
.
setUniqueList
(
new
ArrayList
<
String
>());
List
<
String
>
ids
=
this
.
listWithFromActivityToken
(
activityToken
);
if
(!
ids
.
isEmpty
())
{
for
(
WorkLog
o
:
this
.
entityManagerContainer
().
fetch
(
ids
,
WorkLog
.
class
,
ListTools
.
toList
(
WorkLog
.
arrivedActivityToken_FIELDNAME
,
WorkLog
.
connected_FIELDNAME
)))
{
if
(!
results
.
contains
(
o
.
getId
()))
{
if
(
o
.
getConnected
())
{
if
(
StringUtils
.
isNotEmpty
(
o
.
getArrivedActivityToken
()))
{
arrived
.
add
(
o
.
getArrivedActivityToken
());
}
}
else
{
results
.
add
(
o
.
getId
());
}
}
}
if
(!
arrived
.
isEmpty
())
{
for
(
String
str
:
arrived
)
{
this
.
listWithFromActivityTokenForwardNotConnected
(
str
,
results
);
}
}
}
}
public
List
<
String
>
listWithFromActivityTokenForward
(
String
activityToken
)
throws
Exception
{
List
<
String
>
results
=
SetUniqueList
.
setUniqueList
(
new
ArrayList
<
String
>());
this
.
listWithFromActivityTokenForward
(
activityToken
,
results
);
return
results
;
}
private
void
listWithFromActivityTokenForward
(
String
activityToken
,
List
<
String
>
results
)
throws
Exception
{
List
<
String
>
arrived
=
SetUniqueList
.
setUniqueList
(
new
ArrayList
<
String
>());
List
<
String
>
ids
=
this
.
listWithFromActivityToken
(
activityToken
);
if
(!
ids
.
isEmpty
())
{
for
(
WorkLog
o
:
this
.
entityManagerContainer
().
fetch
(
ids
,
WorkLog
.
class
,
ListTools
.
toList
(
WorkLog
.
arrivedActivityToken_FIELDNAME
,
WorkLog
.
connected_FIELDNAME
)))
{
if
(!
results
.
contains
(
o
.
getId
()))
{
results
.
add
(
o
.
getId
());
if
((
o
.
getConnected
())
&&
(
StringUtils
.
isNotEmpty
(
o
.
getArrivedActivityToken
())))
{
arrived
.
add
(
o
.
getArrivedActivityToken
());
}
}
}
if
(!
arrived
.
isEmpty
())
{
for
(
String
str
:
arrived
)
{
this
.
listWithFromActivityTokenForward
(
str
,
results
);
}
}
}
}
//
public List<String> listWithArrivedActivityToken(String arrivedActivityToken) throws Exception {
//
EntityManager em = this.entityManagerContainer().get(WorkLog.class);
//
CriteriaBuilder cb = em.getCriteriaBuilder();
//
CriteriaQuery<String> cq = cb.createQuery(String.class);
//
Root<WorkLog> root = cq.from(WorkLog.class);
//
Predicate p = cb.equal(root.get(WorkLog_.arrivedActivityToken), arrivedActivityToken);
//
cq.select(root.get(WorkLog_.id)).where(p);
//
return em.createQuery(cq).getResultList();
//
}
//
public List<String> listWithFromActivityTokenForwardNotConnected(String activityToken) throws Exception {
//
List<String> results = SetUniqueList.setUniqueList(new ArrayList<String>());
//
this.listWithFromActivityTokenForwardNotConnected(activityToken, results);
//
return results;
//
}
//
private void listWithFromActivityTokenForwardNotConnected(String activityToken, List<String> results)
//
throws Exception {
//
List<String> arrived = SetUniqueList.setUniqueList(new ArrayList<String>());
//
List<String> ids = this.listWithFromActivityToken(activityToken);
//
if (!ids.isEmpty()) {
//
for (WorkLog o : this.entityManagerContainer().fetch(ids, WorkLog.class,
//
ListTools.toList(WorkLog.arrivedActivityToken_FIELDNAME, WorkLog.connected_FIELDNAME))) {
//
if (!results.contains(o.getId())) {
//
if (o.getConnected()) {
//
if (StringUtils.isNotEmpty(o.getArrivedActivityToken())) {
//
arrived.add(o.getArrivedActivityToken());
//
}
//
} else {
//
results.add(o.getId());
//
}
//
}
//
}
//
if (!arrived.isEmpty()) {
//
for (String str : arrived) {
//
this.listWithFromActivityTokenForwardNotConnected(str, results);
//
}
//
}
//
}
//
}
//
public List<String> listWithFromActivityTokenForward(String activityToken) throws Exception {
//
List<String> results = SetUniqueList.setUniqueList(new ArrayList<String>());
//
this.listWithFromActivityTokenForward(activityToken, results);
//
return results;
//
}
//
private void listWithFromActivityTokenForward(String activityToken, List<String> results) throws Exception {
//
List<String> arrived = SetUniqueList.setUniqueList(new ArrayList<String>());
//
List<String> ids = this.listWithFromActivityToken(activityToken);
//
if (!ids.isEmpty()) {
//
for (WorkLog o : this.entityManagerContainer().fetch(ids, WorkLog.class,
//
ListTools.toList(WorkLog.arrivedActivityToken_FIELDNAME, WorkLog.connected_FIELDNAME))) {
//
if (!results.contains(o.getId())) {
//
results.add(o.getId());
//
if ((o.getConnected()) && (StringUtils.isNotEmpty(o.getArrivedActivityToken()))) {
//
arrived.add(o.getArrivedActivityToken());
//
}
//
}
//
}
//
if (!arrived.isEmpty()) {
//
for (String str : arrived) {
//
this.listWithFromActivityTokenForward(str, results);
//
}
//
}
//
}
//
}
}
\ No newline at end of file
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/data/ExceptionEmptyData.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.data
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionEmptyData
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
665095222445791960L
;
ExceptionEmptyData
()
{
super
(
"更新的数据不能为空."
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/data/ExceptionNotExistItem.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.data
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionNotExistItem
extends
PromptException
{
private
static
final
long
serialVersionUID
=
4865231321642600303L
;
ExceptionNotExistItem
(
String
itemName
)
{
super
(
"path路径无法找到,itemName:{}."
,
itemName
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/service/ExceptionService.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.service
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionService
extends
PromptException
{
private
static
final
long
serialVersionUID
=
1040883405179987063L
;
ExceptionService
(
String
workId
)
{
super
(
"服务执行失败,工作:{}."
,
workId
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/service/ExceptionWorkLogWithActivityTokenNotExist.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.service
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionWorkLogWithActivityTokenNotExist
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
9089355008820123519L
;
ExceptionWorkLogWithActivityTokenNotExist
(
String
str
)
{
super
(
"无法根据活动令牌获取工作日志:{}."
,
str
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/task/ExceptionEmptyFilter.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.task
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionEmptyFilter
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
3439770681867963457L
;
ExceptionEmptyFilter
()
{
super
(
"过滤条件为空."
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/task/ExceptionInvalidCount.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.task
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionInvalidCount
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
3439770681867963457L
;
ExceptionInvalidCount
(
Integer
count
)
{
super
(
"返回数量不正确: {}."
,
count
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/task/ExceptionResetEmpty.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.task
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionResetEmpty
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
3439770681867963457L
;
ExceptionResetEmpty
()
{
super
(
"重置处理人为空."
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionSplittingCannotCallback.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.work
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionSplittingCannotCallback
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
3439770681867963457L
;
ExceptionSplittingCannotCallback
(
String
workId
,
String
workLogId
)
{
super
(
"工作无法回滚到处于拆分的状态,work:{}, workLog:{}."
,
workId
,
workLogId
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionSplittingNotRollback.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.work
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionSplittingNotRollback
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
3439770681867963457L
;
ExceptionSplittingNotRollback
(
String
workId
,
String
workLogId
)
{
super
(
"工作无法回滚到处于拆分的状态,work:{}, workLog:{}."
,
workId
,
workLogId
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionWorkLogNotExist.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.work
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionWorkLogNotExist
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
7038279889683420366L
;
ExceptionWorkLogNotExist
(
String
workId
)
{
super
(
"workLog id:{}, not existed."
,
workId
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/work/ExceptionWorkNotMatchWithWorkLog.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.jaxrs.work
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionWorkNotMatchWithWorkLog
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
7038279889683420366L
;
ExceptionWorkNotMatchWithWorkLog
(
String
workTitle
,
String
workId
,
String
workJob
,
String
workLogId
,
String
workLogJob
)
{
super
(
"work title: {} id: {} job: {}, not match job with workLog: id: {}, job: {}."
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/neural/NeuralAnalyzer.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.neural
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.stream.Collectors
;
import
javax.persistence.EntityManager
;
import
javax.persistence.criteria.CriteriaBuilder
;
import
javax.persistence.criteria.CriteriaQuery
;
import
javax.persistence.criteria.Predicate
;
import
javax.persistence.criteria.Root
;
import
org.apache.commons.lang3.ArrayUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.neuroph.core.data.DataSet
;
import
org.neuroph.core.data.DataSetRow
;
import
org.neuroph.nnet.MultiLayerPerceptron
;
import
org.neuroph.util.TransferFunctionType
;
import
com.google.gson.JsonElement
;
import
com.x.base.core.entity.dataitem.DataItemConverter
;
import
com.x.base.core.project.gson.XGsonBuilder
;
import
com.x.base.core.project.tools.ListTools
;
import
com.x.processplatform.core.entity.content.Data
;
import
com.x.processplatform.core.entity.content.Task
;
import
com.x.processplatform.core.entity.content.TaskCompleted
;
import
com.x.processplatform.core.entity.content.TaskCompleted_
;
import
com.x.processplatform.core.entity.element.FormField
;
import
com.x.processplatform.core.entity.element.FormField_
;
import
com.x.processplatform.core.entity.element.Process
;
import
com.x.processplatform.core.entity.element.Route
;
import
com.x.processplatform.service.processing.Business
;
import
com.x.query.core.entity.Item
;
import
com.x.query.core.entity.Item_
;
public
class
NeuralAnalyzer
{
private
DataItemConverter
<
Item
>
itemConverter
=
new
DataItemConverter
<>(
Item
.
class
);
public
Route
analysis
(
Business
business
,
Task
task
)
throws
Exception
{
List
<
Route
>
routes
=
business
.
element
().
listRouteWithManual
(
task
.
getActivity
());
if
(
routes
.
size
()
==
0
)
{
return
null
;
}
if
(
routes
.
size
()
==
1
)
{
/** 如果只有一条路由就不用判断了 */
return
routes
.
get
(
0
);
}
Process
process
=
business
.
element
().
get
(
task
.
getProcess
(),
Process
.
class
);
List
<
TaskCompleted
>
taskCompleteds
=
listTaskCompleted
(
business
,
task
.
getActivity
(),
task
.
getPerson
());
if
(
null
==
process
||
ListTools
.
isEmpty
(
taskCompleteds
))
{
/** 如果流程不存在或者已办为空直接返回 */
return
routes
.
get
(
0
);
}
List
<
String
>
fields
=
this
.
listNumberFormField
(
business
,
process
);
if
(
fields
.
isEmpty
())
{
String
value
=
this
.
maxFromTaskCompleted
(
taskCompleteds
);
if
(
task
.
getRouteNameList
().
contains
(
value
))
{
for
(
Route
route
:
routes
)
{
if
(
StringUtils
.
equals
(
route
.
getName
(),
value
))
{
return
route
;
}
}
}
/** 如果没有可以用于分析的数据,那么返回第一条路由 */
return
routes
.
get
(
0
);
}
List
<
String
>
routeNames
=
ListTools
.
extractField
(
routes
,
Route
.
name_FIELDNAME
,
String
.
class
,
false
,
false
);
DataSet
trainingSet
=
new
DataSet
(
fields
.
size
(),
routeNames
.
size
());
for
(
TaskCompleted
o
:
taskCompleteds
)
{
if
(
ListTools
.
contains
(
routeNames
,
o
.
getRouteName
()))
{
/** 包含有需要的决策 */
Data
data
=
this
.
load_data
(
business
,
o
.
getJob
());
double
[]
input
=
new
double
[
fields
.
size
()];
for
(
int
i
=
0
;
i
<
fields
.
size
();
i
++)
{
Number
n
=
data
.
find
(
fields
.
get
(
i
),
Number
.
class
,
0
);
input
[
i
]
=
n
.
doubleValue
();
}
double
[]
desiredOutput
=
new
double
[
routeNames
.
size
()];
Arrays
.
fill
(
desiredOutput
,
0
);
int
index
=
routeNames
.
indexOf
(
o
.
getRouteName
());
if
(
index
>
-
1
)
{
desiredOutput
[
index
]
=
1.0
;
}
DataSetRow
row
=
new
DataSetRow
();
row
.
setInput
(
input
);
row
.
setDesiredOutput
(
desiredOutput
);
trainingSet
.
add
(
row
);
}
}
if
(
trainingSet
.
isEmpty
())
{
/* 没有产生可用的训练集 */
return
routes
.
get
(
0
);
}
MultiLayerPerceptron
perceptron
=
new
MultiLayerPerceptron
(
TransferFunctionType
.
SIGMOID
,
fields
.
size
(),
fields
.
size
()
*
2
,
routeNames
.
size
());
perceptron
.
getLearningRule
().
setMaxIterations
(
100
);
perceptron
.
learn
(
trainingSet
);
/* 输入当前值 */
Data
data
=
this
.
load_data
(
business
,
task
.
getJob
());
double
[]
input
=
new
double
[
fields
.
size
()];
for
(
int
i
=
0
;
i
<
fields
.
size
();
i
++)
{
Number
n
=
data
.
find
(
fields
.
get
(
i
),
Number
.
class
,
0
);
input
[
i
]
=
n
.
doubleValue
();
}
perceptron
.
setInput
(
input
);
perceptron
.
calculate
();
double
[]
networkOutput
=
perceptron
.
getOutput
();
networkOutput
=
this
.
competition
(
networkOutput
);
int
index
=
ArrayUtils
.
indexOf
(
networkOutput
,
1.0
);
if
(
index
<
0
)
{
index
=
0
;
}
Route
selected
=
ListTools
.
parallel
(
routeNames
,
routeNames
.
get
(
index
),
routes
);
return
selected
;
}
private
double
[]
competition
(
double
[]
d
)
{
double
[]
output
=
d
;
double
[]
re
=
new
double
[
output
.
length
];
int
maxIndex
=
0
;
double
maxValue
=
Double
.
MIN_VALUE
;
for
(
int
i
=
0
;
i
<
output
.
length
;
i
++)
{
if
(
output
[
i
]
>
maxValue
)
{
maxIndex
=
i
;
maxValue
=
output
[
i
];
}
}
for
(
int
i
=
0
;
i
<
re
.
length
;
i
++)
{
if
(
i
==
maxIndex
)
{
re
[
i
]
=
1
;
}
else
{
re
[
i
]
=
0
;
}
}
return
re
;
}
private
List
<
String
>
listNumberFormField
(
Business
business
,
Process
process
)
throws
Exception
{
List
<
String
>
formIds
=
business
.
element
().
listFormWithProcess
(
process
);
EntityManager
em
=
business
.
entityManagerContainer
().
get
(
FormField
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
String
>
cq
=
cb
.
createQuery
(
String
.
class
);
Root
<
FormField
>
root
=
cq
.
from
(
FormField
.
class
);
Predicate
p
=
root
.
get
(
FormField_
.
form
).
in
(
formIds
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
FormField_
.
dataType
),
"number"
));
cq
.
select
(
root
.
get
(
FormField_
.
name
)).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
().
stream
().
distinct
().
collect
(
Collectors
.
toList
());
}
private
List
<
TaskCompleted
>
listTaskCompleted
(
Business
business
,
String
activity
,
String
person
)
throws
Exception
{
EntityManager
em
=
business
.
entityManagerContainer
().
get
(
TaskCompleted
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
TaskCompleted
>
cq
=
cb
.
createQuery
(
TaskCompleted
.
class
);
Root
<
TaskCompleted
>
root
=
cq
.
from
(
TaskCompleted
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
TaskCompleted_
.
activity
),
activity
);
p
=
cb
.
and
(
p
,
cb
.
equal
(
root
.
get
(
TaskCompleted_
.
person
),
person
));
cq
.
select
(
root
).
where
(
p
);
return
em
.
createQuery
(
cq
).
getResultList
();
}
private
Data
load_data
(
Business
business
,
String
job
)
throws
Exception
{
EntityManager
em
=
business
.
entityManagerContainer
().
get
(
Item
.
class
);
CriteriaBuilder
cb
=
em
.
getCriteriaBuilder
();
CriteriaQuery
<
Item
>
cq
=
cb
.
createQuery
(
Item
.
class
);
Root
<
Item
>
root
=
cq
.
from
(
Item
.
class
);
Predicate
p
=
cb
.
equal
(
root
.
get
(
Item_
.
bundle
),
job
);
List
<
Item
>
list
=
em
.
createQuery
(
cq
.
where
(
p
)).
getResultList
();
if
(
list
.
isEmpty
())
{
return
new
Data
();
}
else
{
JsonElement
jsonElement
=
itemConverter
.
assemble
(
list
);
if
(
jsonElement
.
isJsonObject
())
{
return
XGsonBuilder
.
instance
().
fromJson
(
jsonElement
,
Data
.
class
);
}
else
{
return
new
Data
();
}
}
}
private
String
maxFromTaskCompleted
(
List
<
TaskCompleted
>
list
)
throws
Exception
{
List
<
String
>
values
=
ListTools
.
extractField
(
list
,
"routeName"
,
String
.
class
,
true
,
true
);
return
ListTools
.
maxCountElement
(
values
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/AbstractBaseProcessor.java
浏览文件 @
795308de
...
...
@@ -26,7 +26,7 @@ import com.x.processplatform.service.processing.Business;
/***
* 基础的Processor类,属性以及WorkLog处理
*/
public
abstract
class
AbstractBaseProcessor
{
abstract
class
AbstractBaseProcessor
{
private
EntityManagerContainer
entityManagerContainer
;
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/ExceptionProcessNotExist.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.processor
;
import
com.x.base.core.project.exception.RunningException
;
class
ExceptionProcessNotExist
extends
RunningException
{
private
static
final
long
serialVersionUID
=
9085364457175859374L
;
ExceptionProcessNotExist
(
String
id
)
{
super
(
"process:{} not exist."
,
id
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/agent/AbstractAgentProcessor.java
浏览文件 @
795308de
...
...
@@ -16,7 +16,7 @@ import com.x.processplatform.service.processing.Business;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractAgentProcessor
extends
AbstractProcessor
{
abstract
class
AbstractAgentProcessor
extends
AbstractProcessor
{
protected
AbstractAgentProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/agent/ExceptionInterrupt.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.processor.agent
;
import
com.x.base.core.project.exception.RunningException
;
class
ExceptionInterrupt
extends
RunningException
{
private
static
final
long
serialVersionUID
=
9085364457175859374L
;
ExceptionInterrupt
(
Exception
e
,
String
title
,
String
workId
,
String
agentName
,
String
agentId
,
String
processName
,
String
processId
)
{
super
(
e
,
"工作:{}, id:{}, 在Agent节点:{}, id:{}, 流程:{}, id:{},运行中断."
,
title
,
workId
,
agentName
,
agentId
,
processName
,
processId
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/begin/AbstractBeginProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractBeginProcessor
extends
AbstractProcessor
{
abstract
class
AbstractBeginProcessor
extends
AbstractProcessor
{
protected
AbstractBeginProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/cancel/AbstractCancelProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractCancelProcessor
extends
AbstractProcessor
{
abstract
class
AbstractCancelProcessor
extends
AbstractProcessor
{
protected
AbstractCancelProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/choice/AbstractChoiceProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractChoiceProcessor
extends
AbstractProcessor
{
abstract
class
AbstractChoiceProcessor
extends
AbstractProcessor
{
protected
AbstractChoiceProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/delay/AbstractDelayProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractDelayProcessor
extends
AbstractProcessor
{
abstract
class
AbstractDelayProcessor
extends
AbstractProcessor
{
protected
AbstractDelayProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/embed/AbstractEmbedProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractEmbedProcessor
extends
AbstractProcessor
{
abstract
class
AbstractEmbedProcessor
extends
AbstractProcessor
{
protected
AbstractEmbedProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/end/AbstractEndProcessor.java
浏览文件 @
795308de
...
...
@@ -13,7 +13,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractEndProcessor
extends
AbstractProcessor
{
abstract
class
AbstractEndProcessor
extends
AbstractProcessor
{
private
static
Logger
logger
=
LoggerFactory
.
getLogger
(
AbstractEndProcessor
.
class
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/invoke/AbstractInvokeProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractInvokeProcessor
extends
AbstractProcessor
{
abstract
class
AbstractInvokeProcessor
extends
AbstractProcessor
{
protected
AbstractInvokeProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/AbstractManualProcessor.java
浏览文件 @
795308de
...
...
@@ -19,7 +19,7 @@ import com.x.processplatform.service.processing.processor.AeiObjects;
/***
* Manual活动基础功能
*/
public
abstract
class
AbstractManualProcessor
extends
AbstractProcessor
{
abstract
class
AbstractManualProcessor
extends
AbstractProcessor
{
private
static
final
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
AbstractManualProcessor
.
class
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/ExceptionManualModeError.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.processor.manual
;
import
com.x.base.core.project.exception.RunningException
;
class
ExceptionManualModeError
extends
RunningException
{
private
static
final
long
serialVersionUID
=
9085364457175859374L
;
ExceptionManualModeError
(
String
activityId
)
{
super
(
"unknown manualMode, id:{}."
,
activityId
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/manual/ManualProcessor2.java
已删除
100644 → 0
浏览文件 @
b269eecc
此差异已折叠。
点击以展开。
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/merge/AbstractMergeProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractMergeProcessor
extends
AbstractProcessor
{
abstract
class
AbstractMergeProcessor
extends
AbstractProcessor
{
protected
AbstractMergeProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/parallel/AbstractParallelProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Route;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractParallelProcessor
extends
AbstractProcessor
{
abstract
class
AbstractParallelProcessor
extends
AbstractProcessor
{
protected
AbstractParallelProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/parallel/ExceptionParallelNotFoundRoute.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.processor.parallel
;
import
com.x.base.core.project.exception.RunningException
;
class
ExceptionParallelNotFoundRoute
extends
RunningException
{
private
static
final
long
serialVersionUID
=
6143035361950594561L
;
ExceptionParallelNotFoundRoute
(
String
name
,
String
title
,
String
id
,
String
job
)
{
super
(
"parallel:{} not found route, work:{}, id:{}, job:{}."
,
name
,
title
,
id
,
job
);
}
}
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/service/AbstractServiceProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Service;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractServiceProcessor
extends
AbstractProcessor
{
abstract
class
AbstractServiceProcessor
extends
AbstractProcessor
{
protected
AbstractServiceProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/processor/split/AbstractSplitProcessor.java
浏览文件 @
795308de
...
...
@@ -9,7 +9,7 @@ import com.x.processplatform.core.entity.element.Split;
import
com.x.processplatform.service.processing.processor.AbstractProcessor
;
import
com.x.processplatform.service.processing.processor.AeiObjects
;
public
abstract
class
AbstractSplitProcessor
extends
AbstractProcessor
{
abstract
class
AbstractSplitProcessor
extends
AbstractProcessor
{
protected
AbstractSplitProcessor
(
EntityManagerContainer
entityManagerContainer
)
throws
Exception
{
super
(
entityManagerContainer
);
...
...
o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/schedule/ExceptionTouchEmbedWaitUntilCompleted.java
已删除
100644 → 0
浏览文件 @
b269eecc
package
com.x.processplatform.service.processing.schedule
;
import
com.x.base.core.project.exception.PromptException
;
class
ExceptionTouchEmbedWaitUntilCompleted
extends
PromptException
{
private
static
final
long
serialVersionUID
=
-
7038279889683420366L
;
ExceptionTouchEmbedWaitUntilCompleted
(
Exception
e
,
String
id
,
String
job
)
{
super
(
e
,
"子流程结束工作触发失败, id:{}, job:{}."
,
id
,
job
);
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录