zianxin/pigx
1
0 Fork 0
mirror of http://git.pig4cloud.com/pig/pigx.git synced 2026-11-10 21:19:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(flow-engine): 完善ApprovalCreateListener代码注释

Browse Source
This commit is contained in:
冷冷 authored and PIG AI committed 2025-06-23 16:06:17 +08:00
1 parent 6b48ccf74a
commit d0f89b7917
1 file changed
+43 -27
Download Patch File Download Diff File Expand all files Collapse all files
pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/listeners/ApprovalCreateListener.java
+43 -27
View File
@@ -18,74 +18,90 @@ import org.flowable.task.service.impl.persistence.entity.TaskEntityImpl;
/**
* 审批创建监听器
* 用于处理任务创建时的逻辑，特别是针对没有指定执行人的任务进行自动处理
* 根据节点配置的"无人处理策略"执行不同的操作：自动通过、指派给管理员、指派给特定用户或自动拒绝
*/
@Slf4j
public class ApprovalCreateListener implements TaskListener {
/**
* 当任务被触发时，执行该方法
* @param delegateTask 委派的任务对象
* 当任务被创建时触发该方法
* 根据任务的配置和状态决定如何处理无人执行的任务
*
* @param delegateTask 委派的任务对象，包含任务的所有信息
*/
@Override
public void notify(DelegateTask delegateTask) {
log.debug(delegateTask.getClass().getCanonicalName());
log.debug("任务类型: {}", delegateTask.getClass().getCanonicalName());
TaskService taskService = SpringUtil.getBean(TaskService.class);
String assignee = delegateTask.getAssignee();
String name = delegateTask.getName();
log.debug("任务{}-执行人:{}", name, assignee);
TaskEntityImpl taskEntity = (TaskEntityImpl) delegateTask;
String nodeId = taskEntity.getTaskDefinitionKey();
String processDefinitionId = taskEntity.getProcessDefinitionId();
// 获取任务的基本信息
String assignee = delegateTask.getAssignee(); // 执行人
String name = delegateTask.getName(); // 任务名称
log.debug("任务创建事件 - 任务名称:{}, 执行人:{}", name, assignee);
// 获取流程id
// 转换为TaskEntity以获取更多信息
TaskEntityImpl taskEntity = (TaskEntityImpl) delegateTask;
String nodeId = taskEntity.getTaskDefinitionKey(); // 节点ID
String processDefinitionId = taskEntity.getProcessDefinitionId(); // 流程定义ID
// 从流程定义ID中提取流程ID
String flowId = NodeUtil.getFlowId(processDefinitionId);
// 判断任务是否没有分配执行人或执行人为空标记
// 如果没有执行人，需要根据无人处理策略决定下一步操作
if (StrUtil.isBlank(assignee)
|| StrUtil.equals(ProcessInstanceConstant.DEFAULT_EMPTY_ASSIGN.toString(), assignee)) {
log.debug("任务无执行人，开始处理无人执行策略");
RemoteFlowTaskService remoteFlowTaskService = SpringUtil.getBean(RemoteFlowTaskService.class);
// 查询节点原始数据
// 查询节点原始配置数据，获取无人处理策略
Node node = remoteFlowTaskService.queryNodeOriData(flowId, nodeId).getData();
Nobody nobody = node.getNobody(); // 获取无人处理配置
String handler = nobody.getHandler(); // 获取无人处理的处理方式
Nobody nobody = node.getNobody();
String handler = nobody.getHandler();
// 根据无人处理策略执行不同操作
// 策略1: 自动通过任务
if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_PASS)) {
// 直接通过
log.info("无人处理策略: 自动通过 - 任务ID: {}", taskEntity.getId());
// 设置条件变量为true并完成任务，让流程继续执行
Dict param = Dict.create().set(StrUtil.format("{}_approve_condition", nodeId), true);
taskService.complete(taskEntity.getId(), param);
}
// 策略2: 指派给管理员
if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_ADMIN)) {
// 指派给管理员
log.info("无人处理策略: 指派给管理员 - 任务ID: {}", taskEntity.getId());
// 查询流程的管理员ID
R<Long> longR = remoteFlowTaskService.queryProcessAdmin(flowId);
Long adminId = longR.getData();
// 将任务分配给管理员
taskService.setAssignee(taskEntity.getId(), String.valueOf(adminId));
log.debug("任务已指派给管理员, 管理员ID: {}", adminId);
}
// 策略3: 指派给特定用户
if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_USER)) {
// 指定用户
log.info("无人处理策略: 指派给特定用户 - 任务ID: {}", taskEntity.getId());
// 获取配置中指定的用户
NodeUser nodeUser = nobody.getAssignedUser().get(0);
// 将任务分配给指定用户
taskService.setAssignee(taskEntity.getId(), nodeUser.getId().toString());
log.debug("任务已指派给特定用户, 用户ID: {}", nodeUser.getId());
}
// 策略4: 自动拒绝任务
if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_REFUSE)) {
// 结束
log.info("无人处理策略: 自动拒绝 - 任务ID: {}", taskEntity.getId());
// 设置条件变量为false并完成任务，通常会导致流程走向拒绝分支
Dict param = Dict.create().set(StrUtil.format("{}_approve_condition", nodeId), false);
taskService.complete(taskEntity.getId(), param);
}
} else {
log.debug("任务已有执行人，无需处理无人执行策略");
}
}
}
}