116 lines
4.8 KiB
Java
116 lines
4.8 KiB
Java
package com.ruoyi.flowable.utils;
|
|
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
import com.ruoyi.common.utils.StringUtils;
|
|
import com.ruoyi.flowable.core.domain.ProcessQuery;
|
|
import org.flowable.common.engine.api.query.Query;
|
|
import org.flowable.common.engine.impl.db.SuspensionState;
|
|
import org.flowable.engine.history.HistoricProcessInstanceQuery;
|
|
import org.flowable.engine.repository.ProcessDefinitionQuery;
|
|
import org.flowable.task.api.TaskQuery;
|
|
import org.flowable.task.api.history.HistoricTaskInstanceQuery;
|
|
|
|
import java.util.Map;
|
|
|
|
/**
|
|
* 流程工具类
|
|
*
|
|
* @author konbai
|
|
* @since 2022/12/11 03:35
|
|
*/
|
|
public class ProcessUtils {
|
|
|
|
public static void buildProcessSearch(Query<?, ?> query, ProcessQuery process) {
|
|
if (query instanceof ProcessDefinitionQuery) {
|
|
buildProcessDefinitionSearch((ProcessDefinitionQuery) query, process);
|
|
} else if (query instanceof TaskQuery) {
|
|
buildTaskSearch((TaskQuery) query, process);
|
|
} else if (query instanceof HistoricTaskInstanceQuery) {
|
|
buildHistoricTaskInstanceSearch((HistoricTaskInstanceQuery) query, process);
|
|
} else if (query instanceof HistoricProcessInstanceQuery) {
|
|
buildHistoricProcessInstanceSearch((HistoricProcessInstanceQuery) query, process);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 构建流程定义搜索
|
|
*/
|
|
public static void buildProcessDefinitionSearch(ProcessDefinitionQuery query, ProcessQuery process) {
|
|
// 流程标识
|
|
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
|
query.processDefinitionKeyLike("%" + process.getProcessKey() + "%");
|
|
}
|
|
// 流程名称
|
|
if (StringUtils.isNotBlank(process.getProcessName())) {
|
|
query.processDefinitionNameLike("%" + process.getProcessName() + "%");
|
|
}
|
|
// 流程分类
|
|
if (StringUtils.isNotBlank(process.getCategory())) {
|
|
query.processDefinitionCategory(process.getCategory());
|
|
}
|
|
// 流程状态
|
|
if (StringUtils.isNotBlank(process.getState())) {
|
|
if (SuspensionState.ACTIVE.toString().equals(process.getState())) {
|
|
query.active();
|
|
} else if (SuspensionState.SUSPENDED.toString().equals(process.getState())) {
|
|
query.suspended();
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 构建任务搜索
|
|
*/
|
|
public static void buildTaskSearch(TaskQuery query, ProcessQuery process) {
|
|
Map<String, Object> params = process.getParams();
|
|
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
|
query.processDefinitionKeyLike("%" + process.getProcessKey() + "%");
|
|
}
|
|
if (StringUtils.isNotBlank(process.getProcessName())) {
|
|
query.processDefinitionNameLike("%" + process.getProcessName() + "%");
|
|
}
|
|
if (params.get("beginTime") != null && params.get("endTime") != null) {
|
|
query.taskCreatedAfter(DateUtils.parseDate(params.get("beginTime")));
|
|
query.taskCreatedBefore(DateUtils.parseDate(params.get("endTime")));
|
|
}
|
|
}
|
|
|
|
private static void buildHistoricTaskInstanceSearch(HistoricTaskInstanceQuery query, ProcessQuery process) {
|
|
Map<String, Object> params = process.getParams();
|
|
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
|
query.processDefinitionKeyLike("%" + process.getProcessKey() + "%");
|
|
}
|
|
if (StringUtils.isNotBlank(process.getProcessName())) {
|
|
query.processDefinitionNameLike("%" + process.getProcessName() + "%");
|
|
}
|
|
if (params.get("beginTime") != null && params.get("endTime") != null) {
|
|
query.taskCompletedAfter(DateUtils.parseDate(params.get("beginTime")));
|
|
query.taskCompletedBefore(DateUtils.parseDate(params.get("endTime")));
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 构建历史流程实例搜索
|
|
*/
|
|
public static void buildHistoricProcessInstanceSearch(HistoricProcessInstanceQuery query, ProcessQuery process) {
|
|
Map<String, Object> params = process.getParams();
|
|
// 流程标识
|
|
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
|
query.processDefinitionKey(process.getProcessKey());
|
|
}
|
|
// 流程名称
|
|
if (StringUtils.isNotBlank(process.getProcessName())) {
|
|
query.processDefinitionName(process.getProcessName());
|
|
}
|
|
// 流程名称
|
|
if (StringUtils.isNotBlank(process.getCategory())) {
|
|
query.processDefinitionCategory(process.getCategory());
|
|
}
|
|
if (params.get("beginTime") != null && params.get("endTime") != null) {
|
|
query.startedAfter(DateUtils.parseDate(params.get("beginTime")));
|
|
query.startedBefore(DateUtils.parseDate(params.get("endTime")));
|
|
}
|
|
}
|
|
|
|
}
|