package com.highdatas.mdm.service.act.impl;
|
|
import com.highdatas.mdm.entity.TUser;
|
import com.highdatas.mdm.pojo.NextTaskUserInfo;
|
import com.highdatas.mdm.util.DbUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.activiti.engine.*;
|
import org.activiti.engine.delegate.Expression;
|
import org.activiti.engine.identity.Group;
|
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
|
import org.activiti.engine.impl.pvm.process.ActivityImpl;
|
import org.activiti.engine.impl.task.TaskDefinition;
|
import org.activiti.engine.task.Task;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
public class TaskServiceImpl extends BaseServiceImpl implements com.highdatas.mdm.service.act.TaskService{
|
@Autowired
|
TaskService taskService;
|
@Autowired
|
RepositoryService repositoryService;
|
@Autowired
|
HistoryService historyService;
|
@Autowired
|
RuntimeService runtimeService;
|
@Autowired
|
IdentityService identityService;
|
/**
|
*
|
* @description: 检验节点是否已经被接收
|
* @param workflowId 流程id
|
* @return: 是否已被接收
|
*
|
*/
|
|
public boolean checkClaim(String workflowId) {
|
Task task = getTask(workflowId);
|
if (task == null) {
|
return true;
|
}
|
// 判断任务是否已经被签收
|
if (task.getAssignee() == null) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
/**
|
*
|
* @description: 接收任务
|
* @param workflowId 流程id
|
* @return: 任务id
|
*
|
*/
|
public String claimTask(String workflowId) {
|
Task task = getTask(workflowId);
|
if (task == null) {
|
return null;
|
}
|
TUser onlineUser = getOnlineUser();
|
//resultPool = serviceCaller.getResultPool();
|
if (onlineUser == null) {
|
return null;
|
}
|
try {
|
taskService.claim(task.getId(), onlineUser.getUserId());
|
//resultPool.setMessage("Task is claimed");
|
return task.getId();
|
}
|
catch (Exception e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
|
/**
|
*
|
* @description: 完成节点任务
|
* @param taskId 任务id
|
* @param pass 是否通过 true，false
|
* @param reason 原因
|
* @param other 其他参数
|
* @return: 是否完成成功
|
*
|
*/
|
public boolean completeTask(String taskId, Object pass, String reason, Map<String,Object> other) {
|
Map<String, Object> variables = new LinkedHashMap<String, Object>();
|
if(other != null){
|
variables.putAll(other);
|
}
|
variables.put("pass", pass);
|
variables.put("reason", reason);
|
try {
|
taskService.setVariables(taskId, variables);
|
taskService.complete(taskId,variables);
|
|
return true;
|
}
|
catch (Exception e) {
|
e.printStackTrace();
|
log.debug("can not complete task(" + taskId + "): " + e.getMessage());
|
return false;
|
}
|
}
|
/**
|
*
|
* @description: 完成节点任务
|
* @param taskId 任务id
|
* @param pass 是否通过 true，false
|
* @param reason 原因
|
* @return: 是否完成成功
|
*
|
*/
|
public boolean completeTask(String taskId, Object pass, String reason) {
|
return completeTask(taskId,pass,reason,null);
|
}
|
/**
|
*
|
* @description: 获取待审批任务列表
|
* @return: 待审批任务列表
|
*
|
*/
|
public List<String> getTodoTask() {
|
TUser onlineUser = getOnlineUser();
|
Set<String> result = new HashSet<>();
|
//List<Task> list1 = TimeTaskService.createTaskQuery().active().list();
|
List<Task> list = taskService.createTaskQuery().taskAssignee(onlineUser.getUserId()).active().list();
|
|
result.addAll(list.stream().map(task -> task.getProcessInstanceId()).collect(Collectors.toList()));
|
|
List<Task> toClaimList = taskService.createTaskQuery().taskCandidateUser(onlineUser.getUserId()).active().list();
|
|
result.addAll(toClaimList.stream().map(task -> task.getProcessInstanceId()).collect(Collectors.toList()));
|
|
|
List<Group> groups = identityService.createGroupQuery().groupMember(onlineUser.getUserId()).list();
|
if (groups.size() == 0) {
|
return new ArrayList<>(result);
|
}
|
List<String> groupIds = groups.stream().map(Group::getId).collect(Collectors.toList());
|
toClaimList = taskService.createTaskQuery().taskCandidateGroupIn(groupIds).active().list();
|
|
result.addAll(toClaimList.stream().map(task -> task.getProcessInstanceId()).collect(Collectors.toList()));
|
|
return new ArrayList<>(result);
|
}
|
/**
|
*
|
* @description: 通过流程获取当前任务节点
|
* @param processId 流程id
|
* @return: 当前任务节点
|
*
|
*/
|
public Task geTask(String processId) {
|
Task task = taskService.createTaskQuery().processInstanceId(processId).singleResult();
|
return task;
|
}
|
|
@Override
|
public NextTaskUserInfo getNestTaskAssignee(String workflowId) {
|
NextTaskUserInfo nextTaskUserInfo = new NextTaskUserInfo();
|
Task nextTask = geTask(workflowId);
|
if (nextTask == null) {
|
return null;
|
}
|
String nextTaskAssignee = nextTask.getAssignee();
|
if (!StringUtils.isEmpty(nextTaskAssignee)) {
|
nextTaskUserInfo.addOneUser(nextTaskAssignee);
|
return nextTaskUserInfo;
|
}
|
|
String processDefinitionId=nextTask.getProcessDefinitionId(); // 获取流程定义id
|
|
ProcessDefinitionEntity processDefinitionEntity= (ProcessDefinitionEntity) repositoryService.getProcessDefinition(processDefinitionId);
|
|
ActivityImpl activityImpl=processDefinitionEntity.findActivity(nextTask.getTaskDefinitionKey()); // 根据活动id获取活动实例
|
TaskDefinition taskDef = (TaskDefinition)activityImpl.getProperties().get("taskDefinition");
|
Set<Expression> userCodes = taskDef.getCandidateUserIdExpressions();//候选人
|
Set<Expression> roleCodes = taskDef.getCandidateGroupIdExpressions();//候选组
|
if (roleCodes != null) {
|
Set<String> roleList = roleCodes.stream().map(expression -> expression.getExpressionText()).collect(Collectors.toSet());
|
nextTaskUserInfo.addRoleList(roleList);
|
}
|
Set<String> userList = new HashSet<>();
|
if (userCodes != null) {
|
Set userSet = userCodes.stream().map(expression -> expression.getExpressionText()).collect(Collectors.toSet());
|
userList.addAll(userSet);
|
}
|
List<String> roleIdList = nextTaskUserInfo.getRoleIdList();
|
if (roleIdList == null || roleIdList.isEmpty()) {
|
nextTaskUserInfo.addUserList(userList);
|
return nextTaskUserInfo;
|
}
|
for (String roleId : roleIdList) {
|
Set<String> userByRole = DbUtils.getUserByRole(roleId);
|
userList.addAll(userByRole);
|
}
|
nextTaskUserInfo.addUserList(userList);
|
return nextTaskUserInfo;
|
|
}
|
|
}
|
