package com.ycl.service.impl;
|
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
|
import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
|
import com.ycl.common.constant.ProcessConstants;
|
import com.ycl.common.core.domain.AjaxResult;
|
import com.ycl.common.core.domain.entity.SysDept;
|
import com.ycl.common.core.domain.entity.SysRole;
|
import com.ycl.common.core.domain.entity.SysUser;
|
import com.ycl.common.enums.FlowComment;
|
import com.ycl.common.enums.business.HandlerTypeEnum;
|
import com.ycl.common.enums.business.TaskStatusEnum;
|
import com.ycl.common.utils.SecurityUtils;
|
import com.ycl.constant.TaskTypeConstant;
|
import com.ycl.domain.dto.FlowTaskDto;
|
import com.ycl.domain.entity.ProjectInfo;
|
import com.ycl.domain.entity.ProjectProcess;
|
import com.ycl.domain.vo.CustomerTaskVO;
|
import com.ycl.domain.vo.ProjectProcessDetailVO;
|
import com.ycl.mapper.ProjectInfoMapper;
|
import com.ycl.mapper.ProjectProcessMapper;
|
import com.ycl.service.ProjectProcessService;
|
import com.ycl.common.base.Result;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ycl.domain.form.ProjectProcessForm;
|
import com.ycl.domain.vo.ProjectProcessVO;
|
import com.ycl.domain.query.ProjectProcessQuery;
|
import com.ycl.service.common.TaskCommonService;
|
import com.ycl.system.service.ISysDeptService;
|
import com.ycl.system.service.ISysRoleService;
|
import com.ycl.system.service.ISysUserService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.flowable.bpmn.model.*;
|
import org.flowable.bpmn.model.Process;
|
import org.flowable.common.engine.impl.util.CollectionUtil;
|
import org.flowable.engine.*;
|
import org.flowable.engine.history.HistoricProcessInstance;
|
import org.flowable.engine.repository.ProcessDefinition;
|
import org.flowable.engine.runtime.ProcessInstance;
|
import org.flowable.identitylink.api.IdentityLink;
|
import org.flowable.identitylink.api.IdentityLinkInfo;
|
import org.flowable.identitylink.api.history.HistoricIdentityLink;
|
import org.flowable.task.api.Task;
|
import org.flowable.task.api.TaskQuery;
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
import org.flowable.task.api.history.HistoricTaskInstanceQuery;
|
import org.springframework.stereotype.Service;
|
import lombok.RequiredArgsConstructor;
|
import com.ycl.framework.utils.PageUtil;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.Assert;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 项目流程关系表 服务实现类
|
*
|
* @author xp
|
* @since 2024-11-26
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class ProjectProcessServiceImpl extends ServiceImpl<ProjectProcessMapper, ProjectProcess> implements ProjectProcessService {
|
|
private final ProjectProcessMapper projectProcessMapper;
|
private final RuntimeService runtimeService;
|
private final TaskService taskService;
|
private final IdentityService identityService;
|
private final RepositoryService repositoryService;
|
private final ProjectInfoMapper projectInfoMapper;
|
private final HistoryService historyService;
|
private final ISysUserService sysUserService;
|
private final ISysRoleService sysRoleService;
|
private final ISysDeptService sysDeptService;
|
private final TaskCommonService taskCommonService;
|
|
/**
|
* 分页查询
|
*
|
* @param query
|
* @return
|
*/
|
@Override
|
public Result page(ProjectProcessQuery query) {
|
IPage<ProjectProcessVO> page = PageUtil.getPage(query, ProjectProcessVO.class);
|
baseMapper.getPage(page, query);
|
for (ProjectProcessVO vo : page.getRecords()) {
|
if (Objects.nonNull(vo.getProcessDefId())) {
|
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(vo.getProcessDefId()).singleResult();
|
if (Objects.nonNull(processDefinition)) {
|
vo.setSuspended(processDefinition.isSuspended());
|
}
|
}
|
}
|
return Result.ok().data(page.getRecords()).total(page.getTotal());
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Result projectSetProcess(ProjectProcessForm form) {
|
// 查询该项目是否已经绑定过流程了，检查绑定的流程是否在运行，在运行就删了
|
ProjectProcess pp = new LambdaQueryChainWrapper<>(baseMapper)
|
.eq(ProjectProcess::getProjectId, form.getProjectId())
|
.one();
|
if (Objects.isNull(pp)) {
|
throw new RuntimeException("该项目未绑定流程");
|
}
|
if (Objects.nonNull(pp.getProcessInsId())) {
|
HistoricProcessInstance historicProcessInstance =
|
historyService.createHistoricProcessInstanceQuery().processInstanceId(pp.getProcessInsId()).singleResult();
|
if (Objects.nonNull(historicProcessInstance)) {
|
// 删除之前流程的数据
|
if (historicProcessInstance.getEndTime() != null) {
|
historyService.deleteHistoricProcessInstance(historicProcessInstance.getId());
|
} else {
|
// 删除流程实例
|
runtimeService.deleteProcessInstance(pp.getProcessInsId(), "");
|
// 删除历史流程实例
|
historyService.deleteHistoricProcessInstance(pp.getProcessInsId());
|
}
|
}
|
}
|
String processInsId = this.startPro(form.getProjectId(), form.getProcessDefId());
|
new LambdaUpdateChainWrapper<>(baseMapper)
|
.eq(ProjectProcess::getProjectId, form.getProjectId())
|
.set(ProjectProcess::getProcessDefId, form.getProcessDefId())
|
.set(ProjectProcess::getProcessInsId, processInsId)
|
.update();
|
return Result.ok("流程变更成功");
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Result startProcess(Long projectId, String processDefId) {
|
String processInsId = this.startPro(projectId, processDefId);
|
ProjectProcess entity = new ProjectProcess();
|
entity.setProjectId(projectId);
|
entity.setProcessDefId(processDefId);
|
entity.setProcessInsId(processInsId);
|
baseMapper.insert(entity);
|
return Result.ok("流程启动成功");
|
}
|
|
/**
|
* 启动流程
|
*
|
* @param projectId
|
* @param processDefId
|
* @return
|
*/
|
private String startPro(Long projectId, String processDefId) {
|
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefId)
|
.latestVersion().singleResult();
|
if (Objects.nonNull(processDefinition) && processDefinition.isSuspended()) {
|
throw new RuntimeException("该流程已被挂起,请先激活流程");
|
}
|
Map<String, Object> variables = new HashMap<>(2);
|
// 设置流程发起人Id到流程中
|
SysUser sysUser = SecurityUtils.getLoginUser().getUser();
|
identityService.setAuthenticatedUserId(sysUser.getUserId().toString());
|
variables.put(ProcessConstants.PROCESS_INITIATOR, sysUser.getUserId());
|
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefId, projectId + "", variables);
|
return processInstance.getId();
|
}
|
|
/**
|
* 获取流程详情
|
*
|
* @param projectId
|
* @return
|
*/
|
@Override
|
public Result detail(Long projectId, String processDefId) {
|
// 项目信息
|
ProjectInfo projectInfo = new LambdaQueryChainWrapper<>(projectInfoMapper)
|
.select(ProjectInfo::getId, ProjectInfo::getProjectName, ProjectInfo::getProjectCode)
|
.eq(ProjectInfo::getId, projectId)
|
.one();
|
|
if (Objects.isNull(projectInfo)) {
|
return Result.error("该项目不存在");
|
}
|
|
ProjectProcess projectProcess = new LambdaQueryChainWrapper<>(baseMapper)
|
.eq(ProjectProcess::getProjectId, projectId)
|
.eq(ProjectProcess::getProcessDefId, processDefId)
|
.one();
|
if (Objects.isNull(projectProcess)) {
|
return Result.error("该项目未设置流程");
|
}
|
|
ProjectProcessDetailVO detail = new ProjectProcessDetailVO();
|
detail.setProjectId(projectId);
|
detail.setProjectName(projectInfo.getProjectName());
|
detail.setProjectCode(projectInfo.getProjectCode());
|
|
ProjectProcessDetailVO.TaskStatistics taskStatistics = new ProjectProcessDetailVO.TaskStatistics();
|
// 状态统计
|
taskStatistics.setTotalTaskNum(this.getTotalTaskNum(processDefId));
|
taskStatistics.setTodoTaskNum(this.getTodoTaskNum(projectProcess.getProcessInsId()));
|
taskStatistics.setRemainingTaskNum(this.getRemainingTaskNum(processDefId, projectProcess.getProcessInsId()));
|
// taskStatistics.setCurrentTask(this.getCurrentNodeTaskList(projectProcess.getProcessInstanceId()));
|
taskStatistics.setRemainingTaskNum(this.getRemainingTaskNum(projectProcess.getProcessDefId(), projectProcess.getProcessInsId()));
|
detail.setStatistics(taskStatistics);
|
|
Result result = Result.ok();
|
|
// 代办任务
|
this.getTodoTaskList(projectProcess.getProcessInsId(), "", 5, 1, result);
|
return result.data(detail);
|
}
|
|
@Override
|
public Result taskList(com.ycl.domain.query.TaskQuery query) {
|
// 获取项目对应的流程实例id
|
ProjectProcess projectProcess = new LambdaQueryChainWrapper<>(baseMapper)
|
.eq(ProjectProcess::getProjectId, query.getProjectId())
|
.eq(ProjectProcess::getProcessDefId, query.getProcessDefId())
|
.one();
|
if (Objects.isNull(projectProcess)) {
|
throw new RuntimeException("该项目未配置流程");
|
}
|
Result ok = Result.ok();
|
switch (query.getTaskType()) {
|
case TaskTypeConstant.ALL:
|
this.getAllUserTask(query.getProcessDefId(), projectProcess.getProcessInsId(), query.getTaskName(), (int) query.getCurrentPage(), (int) query.getPageSize(), ok);
|
break;
|
case TaskTypeConstant.TODO:
|
this.getTodoTaskList(projectProcess.getProcessInsId(), query.getTaskName(), (int) query.getPageSize(), (int) query.getCurrentPage(), ok);
|
ok.data(ok.get("taskList"));
|
break;
|
case TaskTypeConstant.CURRENT:
|
break;
|
case TaskTypeConstant.REMAINING:
|
this.getRemainingTask(query.getProcessDefId(), projectProcess.getProcessInsId(), query.getTaskName(), (int) query.getCurrentPage(), (int) query.getPageSize(), ok);
|
break;
|
default:
|
break;
|
|
}
|
return ok;
|
}
|
|
@Override
|
public void getAllTodoTask(String taskName, int pageSize, int pageNum, Result result) {
|
TaskQuery taskQuery = taskService.createTaskQuery()
|
.active()
|
.includeProcessVariables()
|
.orderByTaskCreateTime().desc();
|
|
if (StringUtils.isNotBlank(taskName)) {
|
taskQuery.processDefinitionNameLike(taskName);
|
}
|
result.total(taskQuery.count());
|
List<Task> taskList = taskQuery.listPage(pageSize * (pageNum - 1), pageSize);
|
List<CustomerTaskVO> vos = new ArrayList<>();
|
for (Task task : taskList) {
|
CustomerTaskVO taskVO = new CustomerTaskVO();
|
// 当前流程信息
|
taskVO.setTaskId(task.getId());
|
taskVO.setCreateTime(task.getCreateTime());
|
taskVO.setProcessDefId(task.getProcessDefinitionId());
|
taskVO.setExecutionId(task.getExecutionId());
|
taskVO.setTaskName(task.getName());
|
taskVO.setTaskStatus(TaskStatusEnum.TODO);
|
// 流程定义信息
|
ProcessDefinition pd = repositoryService.createProcessDefinitionQuery()
|
.processDefinitionId(task.getProcessDefinitionId())
|
.singleResult();
|
taskVO.setDeployId(pd.getDeploymentId());
|
taskVO.setProcessName(pd.getName());
|
taskVO.setProcessInsId(task.getProcessInstanceId());
|
taskVO.setTaskDefinitionKey(task.getTaskDefinitionKey());
|
|
// 流程发起人信息
|
this.setPromoterInfo(taskVO);
|
|
// 流程处理人信息
|
List<IdentityLink> identityLinksForTask = taskService.getIdentityLinksForTask(task.getId());
|
for (IdentityLink identityLink : identityLinksForTask) {
|
// 绑定的是用户，查出用户姓名、部门
|
if (StringUtils.isNotBlank(identityLink.getUserId())) {
|
taskVO.setHandlerType(HandlerTypeEnum.USER);
|
SysUser sysUser = sysUserService.selectUserById(Long.parseLong(identityLink.getUserId()));
|
if (Objects.nonNull(sysUser)) {
|
taskVO.setHandlerId(sysUser.getUserId());
|
if (Objects.nonNull(sysUser.getDept())) {
|
taskVO.setHandlerUnitId(sysUser.getDept().getDeptId());
|
taskVO.setHandlerUnitName(sysUser.getDept().getDeptName());
|
}
|
taskVO.setHandlerName(sysUser.getNickName());
|
}
|
// 绑定的是角色或者部门
|
} else if (StringUtils.isNotBlank(identityLink.getGroupId())) {
|
if (identityLink.getGroupId().startsWith("dept")) { // 部门的id是加了前缀的如：dept:1
|
taskVO.setHandlerType(HandlerTypeEnum.DEPT);
|
String[] split = identityLink.getGroupId().split(":");
|
if (split.length > 1) {
|
// 部门
|
SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
|
if (Objects.nonNull(dept)) {
|
taskVO.setHandlerUnitId(dept.getDeptId());
|
taskVO.setHandlerUnitName(dept.getDeptName());
|
taskVO.setHandlerName("暂未处理");
|
taskVO.setHandlerId(null);
|
}
|
}
|
} else {
|
taskVO.setHandlerType(HandlerTypeEnum.ROLE);
|
SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
|
if (Objects.nonNull(role)) {
|
taskVO.setHandlerUnitId(Long.parseLong(identityLink.getGroupId()));
|
taskVO.setHandlerUnitName("由拥有角色：【" + role.getRoleName() + "】的人处理");
|
taskVO.setHandlerName("暂未处理");
|
taskVO.setHandlerId(null);
|
}
|
}
|
}
|
}
|
vos.add(taskVO);
|
}
|
result.put("taskList", vos);
|
}
|
|
@Override
|
public Result detailByProcessInsId(com.ycl.domain.query.TaskQuery query) {
|
List<ProjectProcess> list = new LambdaQueryChainWrapper<>(baseMapper)
|
.eq(ProjectProcess::getProcessInsId, query.getProcessInsId())
|
.eq(ProjectProcess::getProcessDefId, query.getProcessDefId())
|
.list();
|
return Result.ok().data(list);
|
}
|
|
@Override
|
public Result taskIsAuditing(String processDefinitionId, String taskId) {
|
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
|
BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
|
Collection<Process> processes = bpmnModel.getProcesses();
|
Boolean needAuditing = Boolean.FALSE;
|
for (Process process : processes) {
|
Collection<FlowElement> flowElements = process.getFlowElements();
|
for (FlowElement flowElement : flowElements) {
|
if (flowElement instanceof UserTask && flowElement.getId().equals(task.getTaskDefinitionKey())) {
|
UserTask userTask = (UserTask) flowElement;
|
needAuditing = taskCommonService.checkTaskNeedAuditing(userTask.getExtensionElements().get("properties"));
|
break;
|
}
|
|
}
|
}
|
return Result.ok().data(needAuditing);
|
}
|
|
/**
|
* 查询待办任务
|
*
|
* @param processInsId
|
* @param taskName
|
* @param pageSize
|
* @param pageNum
|
* @param result
|
*/
|
public void getTodoTaskList(String processInsId, String taskName, int pageSize, int pageNum, Result result) {
|
TaskQuery taskQuery = taskService.createTaskQuery()
|
.active()
|
.processInstanceId(processInsId)
|
.includeProcessVariables()
|
.orderByTaskCreateTime().desc();
|
|
if (StringUtils.isNotBlank(taskName)) {
|
taskQuery.processDefinitionNameLike(taskName);
|
}
|
result.total(taskQuery.count());
|
List<Task> taskList = taskQuery.listPage(pageSize * (pageNum - 1), pageSize);
|
List<CustomerTaskVO> vos = new ArrayList<>();
|
for (Task task : taskList) {
|
CustomerTaskVO taskVO = new CustomerTaskVO();
|
// 当前流程信息
|
taskVO.setTaskId(task.getId());
|
taskVO.setCreateTime(task.getCreateTime());
|
taskVO.setProcessDefId(task.getProcessDefinitionId());
|
taskVO.setExecutionId(task.getExecutionId());
|
taskVO.setTaskName(task.getName());
|
taskVO.setTaskStatus(TaskStatusEnum.TODO);
|
// 流程定义信息
|
ProcessDefinition pd = repositoryService.createProcessDefinitionQuery()
|
.processDefinitionId(task.getProcessDefinitionId())
|
.singleResult();
|
taskVO.setDeployId(pd.getDeploymentId());
|
taskVO.setProcessName(pd.getName());
|
taskVO.setProcessInsId(task.getProcessInstanceId());
|
taskVO.setTaskDefinitionKey(task.getTaskDefinitionKey());
|
|
// 流程发起人信息
|
this.setPromoterInfo(taskVO);
|
|
// 流程处理人信息
|
List<IdentityLink> identityLinksForTask = taskService.getIdentityLinksForTask(task.getId());
|
for (IdentityLink identityLink : identityLinksForTask) {
|
// 绑定的是用户，查出用户姓名、部门
|
if (StringUtils.isNotBlank(identityLink.getUserId())) {
|
taskVO.setHandlerType(HandlerTypeEnum.USER);
|
SysUser sysUser = sysUserService.selectUserById(Long.parseLong(identityLink.getUserId()));
|
if (Objects.nonNull(sysUser)) {
|
taskVO.setHandlerId(sysUser.getUserId());
|
if (Objects.nonNull(sysUser.getDept())) {
|
taskVO.setHandlerUnitId(sysUser.getDept().getDeptId());
|
taskVO.setHandlerUnitName(sysUser.getDept().getDeptName());
|
}
|
taskVO.setHandlerName(sysUser.getNickName());
|
}
|
// 绑定的是角色或者部门
|
} else if (StringUtils.isNotBlank(identityLink.getGroupId())) {
|
if (identityLink.getGroupId().startsWith("dept")) { // 部门的id是加了前缀的如：dept:1
|
taskVO.setHandlerType(HandlerTypeEnum.DEPT);
|
String[] split = identityLink.getGroupId().split(":");
|
if (split.length > 1) {
|
// 部门
|
SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
|
if (Objects.nonNull(dept)) {
|
taskVO.setHandlerUnitId(dept.getDeptId());
|
taskVO.setHandlerUnitName(dept.getDeptName());
|
taskVO.setHandlerName("暂未处理");
|
taskVO.setHandlerId(null);
|
}
|
}
|
} else {
|
taskVO.setHandlerType(HandlerTypeEnum.ROLE);
|
SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
|
if (Objects.nonNull(role)) {
|
taskVO.setHandlerUnitId(Long.parseLong(identityLink.getGroupId()));
|
taskVO.setHandlerUnitName("由拥有角色：【" + role.getRoleName() + "】的人处理");
|
taskVO.setHandlerName("暂未处理");
|
taskVO.setHandlerId(null);
|
}
|
}
|
}
|
}
|
vos.add(taskVO);
|
}
|
result.put("taskList", vos);
|
}
|
|
/**
|
* 获取所有任务
|
*
|
* @param processDefinitionId 流程运行id
|
* @param processInsId 流程实例id
|
* @param pageNum
|
* @param pageSize
|
* @param result
|
* @return
|
*/
|
private List<CustomerTaskVO> getAllUserTask(String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) {
|
int startNum = pageSize * (pageNum - 1);
|
int endNum = startNum + pageSize;
|
List<UserTask> allUserTaskElement = this.getAllUserTaskElement(processDefinitionId);
|
if (startNum >= allUserTaskElement.size()) {
|
// 如果起始索引超出了列表的大小，返回一个空列表
|
return new ArrayList<>();
|
}
|
if (StringUtils.isNotBlank(taskName)) {
|
// 模拟模糊查询
|
allUserTaskElement = allUserTaskElement.stream().filter(taskEl -> taskEl.getName().contains(taskName)).collect(Collectors.toList());
|
}
|
result.total(allUserTaskElement.size());
|
int end = Math.min(endNum, allUserTaskElement.size());
|
List<UserTask> userTasks = allUserTaskElement.subList(startNum, end);
|
// 查出流程
|
ProcessInstance process = runtimeService.createProcessInstanceQuery().processInstanceId(processInsId).singleResult();
|
// 判断任务状态
|
List<CustomerTaskVO> vos = userTasks.stream().map(userTask -> {
|
CustomerTaskVO vo = new CustomerTaskVO();
|
vo.setProcessInsId(process.getId());
|
vo.setProcessDefId(processDefinitionId);
|
vo.setDeployId(process.getDeploymentId());
|
vo.setTaskName(userTask.getName());
|
vo.setProcessName(process.getProcessDefinitionName());
|
Task task = taskService.createTaskQuery().processInstanceId(process.getId()).taskDefinitionKey(userTask.getId()).singleResult();
|
if (Objects.isNull(task)) {
|
// 如果任务在运行时没找到，那么可能为未开始或者已完成，需要从历史任务中再找一下
|
HistoricTaskInstance historicTask = historyService.createHistoricTaskInstanceQuery()
|
.processInstanceId(process.getProcessInstanceId())
|
.taskDefinitionKey(userTask.getId())
|
.includeIdentityLinks()
|
.singleResult();
|
if (Objects.isNull(historicTask)) {
|
vo.setPromoterName("暂无");
|
vo.setPromoterUnitName("暂无");
|
// 未开始的任务，其关联的用户组这些都可以从UserTask中拿到，因为本身未开始的任务是没有task的，所以这里直接查
|
if (StringUtils.isNotBlank(userTask.getAssignee())) {
|
vo.setHandlerType(HandlerTypeEnum.USER);
|
SysUser sysUser = sysUserService.selectUserById(Long.parseLong(userTask.getAssignee()));
|
if (Objects.nonNull(sysUser)) {
|
vo.setHandlerId(sysUser.getUserId());
|
vo.setHandlerName(sysUser.getNickName());
|
vo.setHandlerUnitId(Objects.nonNull(sysUser.getDept()) ? sysUser.getDept().getDeptId() : null);
|
vo.setHandlerUnitName(Objects.nonNull(sysUser.getDept()) ? sysUser.getDept().getDeptName() : null);
|
}
|
} else if (CollectionUtil.isNotEmpty(userTask.getCandidateGroups())) {
|
String groupId = userTask.getCandidateGroups().get(0);
|
if (groupId.startsWith("dept")) { // 部门的id是加了前缀的如：dept:1
|
vo.setHandlerType(HandlerTypeEnum.DEPT);
|
String[] split = groupId.split(":");
|
if (split.length > 1) {
|
// 部门
|
SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
|
if (Objects.nonNull(dept)) {
|
vo.setHandlerUnitId(dept.getDeptId());
|
vo.setHandlerUnitName(dept.getDeptName());
|
vo.setHandlerName("未开始");
|
vo.setHandlerId(null);
|
}
|
}
|
} else {
|
vo.setHandlerType(HandlerTypeEnum.ROLE);
|
SysRole role = sysRoleService.selectRoleById(Long.parseLong(groupId));
|
if (Objects.nonNull(role)) {
|
vo.setHandlerUnitId(Long.parseLong(groupId));
|
vo.setHandlerUnitName("由拥有角色：【" + role.getRoleName() + "】的人处理");
|
vo.setHandlerName("未开始");
|
vo.setHandlerId(null);
|
}
|
}
|
}
|
vo.setTaskStatus(TaskStatusEnum.NOT_START);
|
} else {
|
vo.setTaskStatus(TaskStatusEnum.FINISHED);
|
// 如果是已完成的，信息需要单独赋值
|
vo.setTaskId(historicTask.getId());
|
vo.setExecutionId(historicTask.getExecutionId());
|
vo.setCreateTime(historicTask.getStartTime());
|
// 查询实际处理人
|
long handlerUserId = Long.parseLong(historicTask.getAssignee());
|
SysUser handlerUser = sysUserService.selectUserById(handlerUserId);
|
if (Objects.nonNull(handlerUser)) {
|
vo.setHandlerId(handlerUserId);
|
vo.setHandlerName(handlerUser.getNickName());
|
}
|
vo.setTaskDefinitionKey(historicTask.getTaskDefinitionKey());
|
this.setPromoterAndHandler(vo, historicTask.getIdentityLinks());
|
}
|
} else {
|
vo.setTaskStatus(TaskStatusEnum.TODO);
|
vo.setTaskId(task.getId());
|
vo.setExecutionId(task.getExecutionId());
|
vo.setCreateTime(task.getCreateTime());
|
vo.setTaskDefinitionKey(task.getTaskDefinitionKey());
|
|
this.setPromoterAndHandler(vo, null);
|
}
|
return vo;
|
}).collect(Collectors.toList());
|
result.data(vos);
|
return vos;
|
}
|
|
/**
|
* 查询剩余事项（未开始的任务）
|
*
|
* @param processDefinitionId
|
* @param processInsId
|
* @param taskName
|
* @param pageNum
|
* @param pageSize
|
* @param result
|
* @return
|
*/
|
private List<CustomerTaskVO> getRemainingTask(String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) {
|
int startNum = pageSize * (pageNum - 1);
|
int endNum = startNum + pageSize;
|
List<UserTask> allUserTaskElement = this.getAllUserTaskElement(processDefinitionId);
|
|
if (startNum >= allUserTaskElement.size()) {
|
// 如果起始索引超出了列表的大小，返回一个空列表
|
return new ArrayList<>();
|
}
|
if (StringUtils.isNotBlank(taskName)) {
|
// 模拟模糊查询
|
allUserTaskElement = allUserTaskElement.stream().filter(taskEl -> taskEl.getName().contains(taskName)).collect(Collectors.toList());
|
}
|
result.total(allUserTaskElement.size());
|
int end = Math.min(endNum, allUserTaskElement.size());
|
List<UserTask> userTasks = allUserTaskElement.subList(startNum, end);
|
// 查出流程
|
ProcessInstance process = runtimeService.createProcessInstanceQuery().processInstanceId(processInsId).singleResult();
|
// 判断任务状态
|
List<CustomerTaskVO> vos = userTasks.stream().map(userTask -> {
|
CustomerTaskVO vo = new CustomerTaskVO();
|
vo.setProcessInsId(process.getId());
|
vo.setProcessDefId(processDefinitionId);
|
vo.setDeployId(process.getDeploymentId());
|
vo.setTaskName(userTask.getName());
|
vo.setProcessName(process.getProcessDefinitionName());
|
Task task = taskService.createTaskQuery().processInstanceId(process.getId()).taskDefinitionKey(userTask.getId()).singleResult();
|
if (Objects.isNull(task)) {
|
// 如果任务在运行时没找到，那么可能为未开始或者已完成，只查询未开始的
|
HistoricTaskInstance historicTask = historyService.createHistoricTaskInstanceQuery()
|
.processInstanceId(process.getProcessInstanceId())
|
.taskDefinitionKey(userTask.getId())
|
.includeIdentityLinks()
|
.singleResult();
|
if (Objects.isNull(historicTask)) {
|
// 未开始的任务，其关联的用户组这些都可以从UserTask中拿到，因为本身未开始的任务是没有task的，所以这里直接查
|
if (StringUtils.isNotBlank(userTask.getAssignee())) {
|
vo.setHandlerType(HandlerTypeEnum.USER);
|
SysUser sysUser = sysUserService.selectUserById(Long.parseLong(userTask.getAssignee()));
|
if (Objects.nonNull(sysUser)) {
|
vo.setHandlerId(sysUser.getUserId());
|
vo.setHandlerName(sysUser.getNickName());
|
vo.setHandlerUnitId(Objects.nonNull(sysUser.getDept()) ? sysUser.getDept().getDeptId() : null);
|
vo.setHandlerUnitName(Objects.nonNull(sysUser.getDept()) ? sysUser.getDept().getDeptName() : null);
|
}
|
} else if (CollectionUtil.isNotEmpty(userTask.getCandidateGroups())) {
|
String groupId = userTask.getCandidateGroups().get(0);
|
if (groupId.startsWith("dept")) { // 部门的id是加了前缀的如：dept:1
|
vo.setHandlerType(HandlerTypeEnum.DEPT);
|
String[] split = groupId.split(":");
|
if (split.length > 1) {
|
// 部门
|
SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
|
if (Objects.nonNull(dept)) {
|
vo.setHandlerUnitId(dept.getDeptId());
|
vo.setHandlerUnitName(dept.getDeptName());
|
vo.setHandlerName("未开始");
|
vo.setHandlerId(null);
|
}
|
}
|
} else {
|
vo.setHandlerType(HandlerTypeEnum.ROLE);
|
SysRole role = sysRoleService.selectRoleById(Long.parseLong(groupId));
|
if (Objects.nonNull(role)) {
|
vo.setHandlerUnitId(Long.parseLong(groupId));
|
vo.setHandlerUnitName("由拥有角色：【" + role.getRoleName() + "】的人处理");
|
vo.setHandlerName("未开始");
|
vo.setHandlerId(null);
|
}
|
}
|
}
|
vo.setTaskStatus(TaskStatusEnum.NOT_START);
|
return vo;
|
} else {
|
return null;
|
}
|
} else {
|
return null;
|
}
|
}).filter(Objects::nonNull).collect(Collectors.toList());
|
result.data(vos);
|
return vos;
|
}
|
|
/**
|
* 查询剩余事项（未开始的任务）数量
|
*
|
* @param processDefinitionId 流程定义id
|
* @param processInsId 流程实例id
|
* @return
|
*/
|
private Long getRemainingTaskNum(String processDefinitionId, String processInsId) {
|
|
List<UserTask> allUserTaskElement = this.getAllUserTaskElement(processDefinitionId);
|
// 查出流程
|
ProcessInstance process = runtimeService.createProcessInstanceQuery().processInstanceId(processInsId).singleResult();
|
long num = 0L;
|
// 判断任务状态
|
for (UserTask userTask : allUserTaskElement) {
|
Task task = taskService.createTaskQuery().processInstanceId(process.getId()).taskDefinitionKey(userTask.getId()).singleResult();
|
if (Objects.isNull(task)) {
|
// 如果任务在运行时没找到，那么可能为未开始或者已完成，只查询未开始的
|
HistoricTaskInstance historicTask = historyService.createHistoricTaskInstanceQuery()
|
.processInstanceId(process.getProcessInstanceId())
|
.taskDefinitionKey(userTask.getId())
|
.includeIdentityLinks()
|
.singleResult();
|
if (Objects.isNull(historicTask)) {
|
num++;
|
}
|
}
|
}
|
return num;
|
}
|
|
|
/**
|
* 设置任务的发起人&处理人 只有待办任务和已完成任务才会掉这个方法
|
*
|
* @param taskVO
|
* @param identityLinkInfos 如果是已完成的任务，用这个去取关联的用户/用户组
|
*/
|
private void setPromoterAndHandler(CustomerTaskVO taskVO, List<? extends IdentityLinkInfo> identityLinkInfos) {
|
this.setPromoterInfo(taskVO);
|
// 流程处理人信息
|
if (TaskStatusEnum.TODO.equals(taskVO.getTaskStatus())) {
|
List<IdentityLink> identityLinksForTask = taskService.getIdentityLinksForTask(taskVO.getTaskId());
|
for (IdentityLink identityLink : identityLinksForTask) {
|
// 绑定的是用户，查出用户姓名、部门
|
if (StringUtils.isNotBlank(identityLink.getUserId())) {
|
SysUser sysUser = sysUserService.selectUserById(Long.parseLong(identityLink.getUserId()));
|
if (Objects.nonNull(sysUser)) {
|
taskVO.setHandlerType(HandlerTypeEnum.USER);
|
taskVO.setHandlerId(sysUser.getUserId());
|
if (Objects.nonNull(sysUser.getDept())) {
|
taskVO.setHandlerUnitId(sysUser.getDept().getDeptId());
|
taskVO.setHandlerUnitName(sysUser.getDept().getDeptName());
|
}
|
taskVO.setHandlerName(sysUser.getNickName());
|
}
|
// 绑定的是角色或者是部门，需要根据id判断
|
} else if (StringUtils.isNotBlank(identityLink.getGroupId())) {
|
if (identityLink.getGroupId().startsWith("dept")) { // 部门的id是加了前缀的如：dept:1
|
taskVO.setHandlerType(HandlerTypeEnum.DEPT);
|
String[] split = identityLink.getGroupId().split(":");
|
if (split.length > 1) {
|
// 部门
|
SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
|
if (Objects.nonNull(dept)) {
|
taskVO.setHandlerUnitId(dept.getDeptId());
|
taskVO.setHandlerUnitName(dept.getDeptName());
|
taskVO.setHandlerName("暂未处理");
|
taskVO.setHandlerId(null);
|
}
|
}
|
} else {
|
taskVO.setHandlerType(HandlerTypeEnum.ROLE);
|
SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
|
if (Objects.nonNull(role)) {
|
taskVO.setHandlerUnitId(Long.parseLong(identityLink.getGroupId()));
|
taskVO.setHandlerUnitName("由拥有角色：【" + role.getRoleName() + "】的人处理");
|
taskVO.setHandlerName("暂未处理");
|
taskVO.setHandlerId(null);
|
}
|
}
|
}
|
}
|
} else if (TaskStatusEnum.FINISHED.equals(taskVO.getTaskStatus())) {
|
for (IdentityLinkInfo identityLink : identityLinkInfos) {
|
// 绑定的是用户，查出用户姓名、部门
|
if (StringUtils.isNotBlank(identityLink.getUserId())) {
|
taskVO.setHandlerType(HandlerTypeEnum.USER);
|
SysUser sysUser = sysUserService.selectUserById(Long.parseLong(identityLink.getUserId()));
|
if (Objects.nonNull(sysUser)) {
|
// taskVO.setHandlerId(sysUser.getUserId());
|
if (Objects.nonNull(sysUser.getDept())) {
|
taskVO.setHandlerUnitId(sysUser.getDept().getDeptId());
|
taskVO.setHandlerUnitName(sysUser.getDept().getDeptName());
|
}
|
// taskVO.setHandlerName(sysUser.getNickName());
|
}
|
// 绑定的是角色，查出角色名称
|
} else if (StringUtils.isNotBlank(identityLink.getGroupId())) {
|
if (identityLink.getGroupId().startsWith("dept")) {
|
taskVO.setHandlerType(HandlerTypeEnum.DEPT);
|
String[] split = identityLink.getGroupId().split(":");
|
if (split.length > 1) {
|
// 部门
|
SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
|
if (Objects.nonNull(dept)) {
|
taskVO.setHandlerUnitId(dept.getDeptId());
|
taskVO.setHandlerUnitName(dept.getDeptName());
|
}
|
}
|
} else {
|
taskVO.setHandlerType(HandlerTypeEnum.ROLE);
|
SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
|
if (Objects.nonNull(role)) {
|
taskVO.setHandlerUnitId(Long.parseLong(identityLink.getGroupId()));
|
taskVO.setHandlerUnitName("由拥有角色：【" + role.getRoleName() + "】的人处理");
|
// taskVO.setHandlerName(role.getRoleName());
|
// taskVO.setHandlerId(null);
|
}
|
}
|
}
|
}
|
}
|
|
}
|
|
/**
|
* 设置任务发起人
|
*
|
* @param taskVO
|
*/
|
private void setPromoterInfo(CustomerTaskVO taskVO) {
|
// 发起人应为上一节点的处理人
|
List<String> beforeNodeKey = taskCommonService.getBeforeNodeInfo(taskVO.getProcessDefId(), taskVO.getTaskDefinitionKey());
|
List<SysUser> userList = beforeNodeKey.stream().map(key -> {
|
HistoricTaskInstance historicTaskInstance = historyService.createHistoricTaskInstanceQuery().taskDefinitionKey(key).singleResult();
|
if (Objects.nonNull(historicTaskInstance)) {
|
// 实际领取这个任务的人，也就是处理人
|
String assignee = historicTaskInstance.getAssignee();
|
SysUser startUser = sysUserService.selectUserById(Long.parseLong(assignee));
|
return startUser;
|
} else {
|
return null;
|
}
|
}).filter(user -> Objects.nonNull(user)).collect(Collectors.toList());
|
if (CollectionUtils.isEmpty(userList)) {
|
taskVO.setPromoterName("暂无");
|
taskVO.setPromoterUnitName("暂无");
|
} else {
|
taskVO.setPromoterId(userList.stream().map(user -> { return user.getUserId() + ""; }).collect(Collectors.joining("、")));
|
taskVO.setPromoterName(userList.stream().map(user -> { return user.getNickName(); }).collect(Collectors.joining("、")));
|
taskVO.setPromoterUnitId(userList.stream().filter(user -> Objects.nonNull(user.getDept())).map(user -> { return user.getDept().getDeptId() + "";}).collect(Collectors.joining("、")));
|
taskVO.setPromoterUnitName(userList.stream().filter(user -> Objects.nonNull(user.getDept())).map(user -> { return user.getDept().getDeptName() + "";}).collect(Collectors.joining("、")));
|
}
|
}
|
|
/**
|
* 获取某个流程的所有任务节点
|
*
|
* @param processDefinitionId
|
* @return
|
*/
|
private List<UserTask> getAllUserTaskElement(String processDefinitionId) {
|
// 获取流程定义
|
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
|
.processDefinitionId(processDefinitionId)
|
.singleResult();
|
|
if (processDefinition == null) {
|
throw new IllegalArgumentException("流程定义ID无效: " + processDefinitionId);
|
}
|
|
// 获取BPMN模型
|
BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
|
if (bpmnModel == null) {
|
throw new IllegalStateException("无法获取BPMN模型: " + processDefinitionId);
|
}
|
|
// 获取流程对象
|
Process process = bpmnModel.getProcessById(processDefinition.getKey());
|
if (process == null) {
|
throw new IllegalStateException("无法获取流程对象: " + processDefinition.getKey());
|
}
|
|
List<FlowElement> flowElements = process.getFlowElements().stream().toList();
|
List<UserTask> userTaskElements = flowElements.stream().filter(flowElement -> flowElement instanceof UserTask).map(flowElement -> {
|
return (UserTask) flowElement;
|
}).collect(Collectors.toList());
|
return userTaskElements;
|
}
|
|
/**
|
* 获取流程节点数（总任务数，不包含开始、结束等特殊的，只统计UserTask类型的）
|
*
|
* @param processDefinitionId 流程定义id
|
* @return
|
*/
|
private Long getTotalTaskNum(String processDefinitionId) {
|
return Long.valueOf(this.getAllUserTaskElement(processDefinitionId).size());
|
}
|
|
/**
|
* 获取待办任务数
|
*
|
* @param processInstanceId
|
* @return
|
*/
|
private Long getTodoTaskNum(String processInstanceId) {
|
return taskService.createTaskQuery().active().processInstanceId(processInstanceId).count();
|
}
|
|
/**
|
* 获取当前环节的所有任务数
|
*
|
* @param processInstanceId
|
* @return
|
*/
|
private List<Task> getCurrentNodeTaskList(String processInstanceId) {
|
return taskService.createTaskQuery().processDefinitionId(processInstanceId).list();
|
}
|
}
|
