RevokeService.java
3.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package com.hotent.runtime.service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import com.hotent.base.util.BeanUtils;
import com.hotent.base.util.StringUtil;
import com.hotent.bpm.api.constant.BpmConstants;
import com.hotent.bpm.api.context.ContextThreadUtil;
import com.hotent.bpm.api.model.process.task.BpmTask;
import com.hotent.bpm.persistence.manager.BpmReadRecordManager;
import com.hotent.bpm.persistence.model.DefaultBpmCheckOpinion;
import com.hotent.runtime.params.CustomSignRevokeParam;
import com.hotent.uc.api.impl.util.ContextUtil;
/**
* 撤回服务接口
*
* @company 广州宏天软件股份有限公司
* @author heyifan
* @email heyf@jee-soft.cn
* @date 2020年3月11日
*/
public interface RevokeService {
/**
* 根据是否允许已阅撤回来设置撤回属性
* @param map
* @param taskId
* @param isReadRevoke
* @param bpmReadRecordManager
*/
default void setRevoke(Map<String, Object> map, String taskId, String isReadRevoke, BpmReadRecordManager bpmReadRecordManager) {
// 不允许已阅撤回
if("false".equals(isReadRevoke)) {
// 直接后代任务是否已阅
Boolean taskReadByOwner = bpmReadRecordManager.isTaskReadByOwner(taskId);
map.put("revoke", !taskReadByOwner);
}
// 允许已阅撤回时无需查询是否已阅
else {
map.put("revoke", true);
}
}
/**
* 在审批记录列表中，过滤出指定signType的记录
* @param list
* @param signType
* @return
*/
default List<DefaultBpmCheckOpinion> getOpinionBySignType(List<DefaultBpmCheckOpinion> list, String signType) {
List<DefaultBpmCheckOpinion> newList = new ArrayList<>();
if(BeanUtils.isEmpty(list) || StringUtil.isEmpty(signType)) {
return newList;
}
for(DefaultBpmCheckOpinion opinion : list) {
if(signType.equals(opinion.getSignType())) {
newList.add(opinion);
}
}
return newList;
}
/**
* 从审批记录列表中获取指定taskId的那条记录
* @param list
* @param taskId
* @return
*/
default DefaultBpmCheckOpinion getOpinionByTaskId(List<DefaultBpmCheckOpinion> list, String taskId) {
if(BeanUtils.isEmpty(list) || StringUtil.isEmpty(taskId)) {
return null;
}
for(DefaultBpmCheckOpinion opinion : list) {
if(taskId.equals(opinion.getTaskId())) {
return opinion;
}
}
return null;
}
default String getNewCreateTaskId() {
String createTaskId = null;
Object commuVar = ContextThreadUtil.getCommuVar(BpmConstants.CREATE_BPM_TASK+ContextUtil.getCurrentUserId(), null);
if(BeanUtils.isNotEmpty(commuVar)) {
createTaskId = ((BpmTask)commuVar).getId();
}
return createTaskId;
};
/**
* 判断审批记录列表中是否至少有一条为指定状态
* @param list
* @param opinionStatusList
* @return
*/
default Boolean hasOpinionWithStatus(List<DefaultBpmCheckOpinion> list, List<String> opinionStatusList) {
Boolean result = false;
if(BeanUtils.isEmpty(list) || BeanUtils.isEmpty(opinionStatusList)) {
return result;
}
for(DefaultBpmCheckOpinion opinion : list) {
if(opinionStatusList.contains(opinion.getStatus())) {
result = true;
break;
}
}
return result;
}
/**
* 判断已办是否可以撤回
* @param map 已办
* @param list 审批记录
* @param isReadRevoke 是否允许已阅撤回
*/
void canRevoke(Map<String, Object> map, List<DefaultBpmCheckOpinion> list, String isReadRevoke);
/**
* 执行撤回操作
* @param revokeParamObject 撤回操作参数
*/
void doRevoke(CustomSignRevokeParam revokeParam) throws Exception;
}