update 调整流程实例,流程定义检索

This commit is contained in:
gssong 2023-07-01 18:37:51 +08:00
parent f227c35fb4
commit ecbd2b046e
5 changed files with 51 additions and 1 deletions

View File

@ -24,6 +24,11 @@ public class ProcessInstanceBo extends PageEntity implements Serializable {
*/ */
private String name; private String name;
/**
* 流程key
*/
private String key;
/** /**
* 任务发起人 * 任务发起人
*/ */

View File

@ -23,4 +23,14 @@ public class TaskBo extends PageEntity implements Serializable {
* 任务名称 * 任务名称
*/ */
private String name; private String name;
/**
* 流程定义名称
*/
private String processDefinitionName;
/**
* 流程定义key
*/
private String processDefinitionKey;
} }

View File

@ -121,6 +121,16 @@ public class TaskVo {
*/ */
private String businessStatusName; private String businessStatusName;
/**
* 流程定义名称
*/
private String processDefinitionName;
/**
* 流程定义key
*/
private String processDefinitionKey;
/** /**
* 参与者 * 参与者
*/ */

View File

@ -85,6 +85,9 @@ public class ActProcessInstanceServiceImpl implements IActProcessInstanceService
if (StringUtils.isNotBlank(processInstanceBo.getName())) { if (StringUtils.isNotBlank(processInstanceBo.getName())) {
query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%"); query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%");
} }
if (StringUtils.isNotBlank(processInstanceBo.getKey())) {
query.processDefinitionKey(processInstanceBo.getKey());
}
if (StringUtils.isNotBlank(processInstanceBo.getStartUserId())) { if (StringUtils.isNotBlank(processInstanceBo.getStartUserId())) {
query.startedBy(processInstanceBo.getStartUserId()); query.startedBy(processInstanceBo.getStartUserId());
} }
@ -119,6 +122,9 @@ public class ActProcessInstanceServiceImpl implements IActProcessInstanceService
if (StringUtils.isNotEmpty(processInstanceBo.getName())) { if (StringUtils.isNotEmpty(processInstanceBo.getName())) {
query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%"); query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%");
} }
if (StringUtils.isNotBlank(processInstanceBo.getKey())) {
query.processDefinitionKey(processInstanceBo.getKey());
}
if (StringUtils.isNotEmpty(processInstanceBo.getStartUserId())) { if (StringUtils.isNotEmpty(processInstanceBo.getStartUserId())) {
query.startedBy(processInstanceBo.getStartUserId()); query.startedBy(processInstanceBo.getStartUserId());
} }
@ -459,11 +465,14 @@ public class ActProcessInstanceServiceImpl implements IActProcessInstanceService
if (StringUtils.isNotBlank(processInstanceBo.getName())) { if (StringUtils.isNotBlank(processInstanceBo.getName())) {
query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%"); query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%");
} }
if (StringUtils.isNotBlank(processInstanceBo.getKey())) {
query.processDefinitionKey(processInstanceBo.getKey());
}
if (StringUtils.isNotBlank(processInstanceBo.getBusinessKey())) { if (StringUtils.isNotBlank(processInstanceBo.getBusinessKey())) {
query.processInstanceBusinessKey(processInstanceBo.getBusinessKey()); query.processInstanceBusinessKey(processInstanceBo.getBusinessKey());
} }
if (StringUtils.isNotBlank(processInstanceBo.getCategoryCode())) { if (StringUtils.isNotBlank(processInstanceBo.getCategoryCode())) {
query.processInstanceBusinessKey(processInstanceBo.getCategoryCode()); query.processDefinitionCategory(processInstanceBo.getCategoryCode());
} }
query.orderByProcessInstanceStartTime().desc(); query.orderByProcessInstanceStartTime().desc();
List<HistoricProcessInstance> historicProcessInstanceList = query.listPage(processInstanceBo.getPageNum(), processInstanceBo.getPageSize()); List<HistoricProcessInstance> historicProcessInstanceList = query.listPage(processInstanceBo.getPageNum(), processInstanceBo.getPageSize());

View File

@ -165,6 +165,12 @@ public class ActTaskServiceImpl implements IActTaskService {
if (StringUtils.isNotBlank(taskBo.getName())) { if (StringUtils.isNotBlank(taskBo.getName())) {
query.taskNameLike("%" + taskBo.getName() + "%"); query.taskNameLike("%" + taskBo.getName() + "%");
} }
if (StringUtils.isNotBlank(taskBo.getProcessDefinitionName())) {
query.processDefinitionNameLike("%" + taskBo.getProcessDefinitionName() + "%");
}
if (StringUtils.isNotBlank(taskBo.getProcessDefinitionKey())) {
query.processDefinitionKey(taskBo.getProcessDefinitionKey() );
}
List<Task> taskList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize()); List<Task> taskList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize());
List<ProcessInstance> processInstanceList = null; List<ProcessInstance> processInstanceList = null;
if (CollUtil.isNotEmpty(taskList)) { if (CollUtil.isNotEmpty(taskList)) {
@ -178,6 +184,8 @@ public class ActTaskServiceImpl implements IActTaskService {
processInstanceList.stream().filter(e -> e.getId().equals(task.getProcessInstanceId())).findFirst().ifPresent(e -> { processInstanceList.stream().filter(e -> e.getId().equals(task.getProcessInstanceId())).findFirst().ifPresent(e -> {
taskVo.setBusinessStatus(e.getBusinessStatus()); taskVo.setBusinessStatus(e.getBusinessStatus());
taskVo.setBusinessStatusName(BusinessStatusEnum.getEumByStatus(taskVo.getBusinessStatus())); taskVo.setBusinessStatusName(BusinessStatusEnum.getEumByStatus(taskVo.getBusinessStatus()));
taskVo.setProcessDefinitionKey(e.getProcessDefinitionKey());
taskVo.setProcessDefinitionName(e.getProcessDefinitionName());
}); });
} }
taskVo.setAssignee(StringUtils.isNotBlank(task.getAssignee()) ? Long.valueOf(task.getAssignee()) : null); taskVo.setAssignee(StringUtils.isNotBlank(task.getAssignee()) ? Long.valueOf(task.getAssignee()) : null);
@ -201,6 +209,12 @@ public class ActTaskServiceImpl implements IActTaskService {
if (StringUtils.isNotBlank(taskBo.getName())) { if (StringUtils.isNotBlank(taskBo.getName())) {
query.taskNameLike("%" + taskBo.getName() + "%"); query.taskNameLike("%" + taskBo.getName() + "%");
} }
if (StringUtils.isNotBlank(taskBo.getProcessDefinitionName())) {
query.processDefinitionNameLike("%" + taskBo.getProcessDefinitionName() + "%");
}
if (StringUtils.isNotBlank(taskBo.getProcessDefinitionKey())) {
query.processDefinitionKey( taskBo.getProcessDefinitionKey() );
}
List<HistoricTaskInstance> taskInstanceList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize()); List<HistoricTaskInstance> taskInstanceList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize());
List<HistoricProcessInstance> historicProcessInstanceList = null; List<HistoricProcessInstance> historicProcessInstanceList = null;
if (CollUtil.isNotEmpty(taskInstanceList)) { if (CollUtil.isNotEmpty(taskInstanceList)) {
@ -214,6 +228,8 @@ public class ActTaskServiceImpl implements IActTaskService {
historicProcessInstanceList.stream().filter(e -> e.getId().equals(task.getProcessInstanceId())).findFirst().ifPresent(e -> { historicProcessInstanceList.stream().filter(e -> e.getId().equals(task.getProcessInstanceId())).findFirst().ifPresent(e -> {
taskVo.setBusinessStatus(e.getBusinessStatus()); taskVo.setBusinessStatus(e.getBusinessStatus());
taskVo.setBusinessStatusName(BusinessStatusEnum.getEumByStatus(taskVo.getBusinessStatus())); taskVo.setBusinessStatusName(BusinessStatusEnum.getEumByStatus(taskVo.getBusinessStatus()));
taskVo.setProcessDefinitionKey(e.getProcessDefinitionKey());
taskVo.setProcessDefinitionName(e.getProcessDefinitionName());
}); });
} }
taskVo.setAssignee(StringUtils.isNotBlank(task.getAssignee()) ? Long.valueOf(task.getAssignee()) : null); taskVo.setAssignee(StringUtils.isNotBlank(task.getAssignee()) ? Long.valueOf(task.getAssignee()) : null);