diff --git a/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/enums/SymbolConstant.java b/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/enums/SymbolConstant.java
new file mode 100644
index 000000000..a73ff7d30
--- /dev/null
+++ b/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/enums/SymbolConstant.java
@@ -0,0 +1,48 @@
+package cn.iocoder.yudao.framework.common.enums;
+
+/**
+ * 符号常量
+ */
+public interface SymbolConstant {
+
+ String D =",";
+
+ /**
+ * _
+ */
+ String XH="_";
+ /**
+ * -
+ */
+ String HG="-";
+
+ /**
+ * /
+ */
+ String XG="/";
+
+ /**
+ * 箭头
+ */
+ String ARROWHEAD="->";
+
+ /**
+ * 数组的开始元素
+ */
+ String ARRAY_START="[";
+
+ /**
+ * 数组的结束元素
+ */
+ String ARRAY_END="]";
+
+ /**
+ * null 字符串
+ */
+ String NULL_STRING="null";
+
+ /**
+ * 点号
+ */
+ String DIAN="\\.";
+}
diff --git a/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/ErrorCodeConstants.java b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/ErrorCodeConstants.java
index b84781ed6..55a2330c2 100644
--- a/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/ErrorCodeConstants.java
+++ b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/ErrorCodeConstants.java
@@ -50,7 +50,9 @@ public interface ErrorCodeConstants {
ErrorCode TASK_RETURN_FAIL_SOURCE_TARGET_ERROR = new ErrorCode(1_009_005_006, "回退任务失败，目标节点是在并行网关上或非同一路线上，不可跳转");
ErrorCode TASK_DELEGATE_FAIL_USER_REPEAT = new ErrorCode(1_009_005_007, "任务委派失败，委派人和当前审批人为同一人");
ErrorCode TASK_DELEGATE_FAIL_USER_NOT_EXISTS = new ErrorCode(1_009_005_008, "任务委派失败，被委派人不存在");
-
+ ErrorCode TASK_ADD_SIGN_USER_NOT_EXIST = new ErrorCode(1_009_005_009, "任务加签：选择的用户不存在");
+ ErrorCode TASK_ADD_SIGN_TYPE_ERROR = new ErrorCode(1_009_005_010, "任务加签：当前任务已经{}，不能{}");
+ ErrorCode TASK_ADD_SIGN_USER_REPEAT = new ErrorCode(1_009_005_011, "任务加签失败，加签人与现有审批人[{}]重复");
// ========== 流程任务分配规则 1-009-006-000 ==========
ErrorCode TASK_ASSIGN_RULE_EXISTS = new ErrorCode(1_009_006_000, "流程({}) 的任务({}) 已经存在分配规则");
ErrorCode TASK_ASSIGN_RULE_NOT_EXISTS = new ErrorCode(1_009_006_001, "流程任务分配规则不存在");
diff --git a/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmCommentTypeEnum.java b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmCommentTypeEnum.java
new file mode 100644
index 000000000..98e175e3f
--- /dev/null
+++ b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmCommentTypeEnum.java
@@ -0,0 +1,33 @@
+package cn.iocoder.yudao.module.bpm.enums.task;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 流程任务 -- comment类型枚举
+ */
+@Getter
+@AllArgsConstructor
+public enum BpmCommentTypeEnum {
+
+ APPROVE(1, "通过"),
+ REJECT(2, "不通过"),
+ CANCEL(3, "已取消"),
+
+ // ========== 流程任务独有的状态 ==========
+
+ BACK(4, "退回"), // 退回
+ DELEGATE(5, "委派"),
+ ADD_SIGN(6, "加签"),
+ SUB_SIGN(7,"减签"),
+ ;
+
+ /**
+ * 结果
+ */
+ private final Integer result;
+ /**
+ * 描述
+ */
+ private final String desc;
+}
diff --git a/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmProcessInstanceResultEnum.java b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmProcessInstanceResultEnum.java
index a19c68ba8..62b18f54a 100644
--- a/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmProcessInstanceResultEnum.java
+++ b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmProcessInstanceResultEnum.java
@@ -21,11 +21,26 @@ public enum BpmProcessInstanceResultEnum {
// ========== 流程任务独有的状态 ==========
BACK(5, "驳回"), // 退回
- DELEGATE(6, "委派");
+ DELEGATE(6, "委派"),
+ /**
+ * 源任务已经审批完成，但是它使用了后加签，后加签的任务未完成，源任务就会是这个状态
+ * 例如：A审批， A 后加签了 B ，并且审批通过了任务，但是 B 还未审批，则当前任务状态为 待后加签任务完成
+ */
+ ADD_SIGN_AFTER(7, "待后加签任务完成"),
+ /**
+ * 源任务未审批，但是向前加签了，所以源任务状态变为 待前加签任务完成
+ * 例如：A审批， A 前加签了 B ，B 还未审核
+ */
+ ADD_SIGN_BEFORE(8, "待前加签任务完成"),
+ /**
+ * 后加签任务被创建时的初始状态
+ * 因为需要源任务先完成，才能到后加签的人来审批，所以加了一个状态区分
+ */
+ WAIT_BEFORE_TASK(9, "待前置任务完成");
/**
* 结果
- *
+ *
* 如果新增时，注意 {@link #isEndResult(Integer)} 是否需要变更
*/
private final Integer result;
@@ -36,14 +51,16 @@ public enum BpmProcessInstanceResultEnum {
/**
* 判断该结果是否已经处于 End 最终结果
- *
+ *
* 主要用于一些结果更新的逻辑，如果已经是最终结果，就不再进行更新
*
* @param result 结果
* @return 是否
*/
public static boolean isEndResult(Integer result) {
- return ObjectUtils.equalsAny(result, APPROVE.getResult(), REJECT.getResult(), CANCEL.getResult(), BACK.getResult());
+ return ObjectUtils.equalsAny(result, APPROVE.getResult(), REJECT.getResult(),
+ CANCEL.getResult(), BACK.getResult(),
+ ADD_SIGN_AFTER.getResult());
}
}
diff --git a/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmTaskAddSignTypeEnum.java b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmTaskAddSignTypeEnum.java
new file mode 100644
index 000000000..3b46b6f25
--- /dev/null
+++ b/yudao-module-bpm/yudao-module-bpm-api/src/main/java/cn/iocoder/yudao/module/bpm/enums/task/BpmTaskAddSignTypeEnum.java
@@ -0,0 +1,40 @@
+package cn.iocoder.yudao.module.bpm.enums.task;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+
+/**
+ * 流程任务 -- 加签类型枚举类型
+ */
+@Getter
+@AllArgsConstructor
+public enum BpmTaskAddSignTypeEnum {
+
+ /**
+ * 向前加签，需要前置任务审批完成，才回到原审批人
+ */
+ BEFORE("before", "向前加签"),
+ /**
+ * 向后加签，需要后置任务全部审批完，才会通过原审批人节点
+ */
+ AFTER("after", "向后加签"),
+ /**
+ * 创建后置加签时的过度状态，用于控制向后加签生成的任务状态
+ */
+ AFTER_CHILDREN_TASK("afterChildrenTask", "向后加签生成的子任务");
+
+ private final String type;
+
+ private final String desc;
+
+ public static String formatDesc(String type) {
+ for (BpmTaskAddSignTypeEnum value : values()) {
+ if (value.type.equals(type)) {
+ return value.desc;
+ }
+ }
+ return null;
+ }
+}
+
\ No newline at end of file
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/BpmTaskController.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/BpmTaskController.java
index e980fddcf..e442d7aad 100644
--- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/BpmTaskController.java
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/BpmTaskController.java
@@ -100,4 +100,11 @@ public class BpmTaskController {
return success(true);
}
+ @PutMapping("/add-sign")
+ @Operation(summary = "加签", description = "before, after为前加签后加签")
+ @PreAuthorize("@ss.hasPermission('bpm:task:add-sign')")
+ public CommonResult addSign(@RequestBody @Valid BpmTaskAddSignReqVO reqVO) {
+ taskService.addSign(reqVO,getLoginUserId());
+ return success(true);
+ }
}
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskAddSignReqVO.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskAddSignReqVO.java
new file mode 100644
index 000000000..88b123ce8
--- /dev/null
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskAddSignReqVO.java
@@ -0,0 +1,29 @@
+package cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import javax.validation.constraints.NotEmpty;
+import java.util.List;
+import java.util.Set;
+
+@Schema(description = "管理后台 - 加签流程任务的 Request VO")
+@Data
+public class BpmTaskAddSignReqVO {
+
+ @Schema(description = "加签的用户 ID")
+ @NotEmpty(message = "加签用户ID不能为空")
+ private Set userIdList;
+
+ @Schema(description = "加签类型，before 向前加签，after 向后加签")
+ @NotEmpty(message = "加签类型不能为空")
+ private String type;
+
+ @Schema(description = "加签原因")
+ @NotEmpty(message = "加签原因不能为空")
+ private String reason;
+
+ @Schema(description = "需要加签的任务 ID")
+ @NotEmpty(message = "任务编号不能为空")
+ private String id;
+}
\ No newline at end of file
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/convert/task/BpmTaskConvert.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/convert/task/BpmTaskConvert.java
index ce693e468..ebbcf11fc 100644
--- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/convert/task/BpmTaskConvert.java
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/convert/task/BpmTaskConvert.java
@@ -18,9 +18,11 @@ import org.flowable.engine.history.HistoricProcessInstance;
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.Task;
import org.flowable.task.api.history.HistoricTaskInstance;
+import org.flowable.task.service.impl.persistence.entity.TaskEntityImpl;
import org.mapstruct.*;
import org.mapstruct.factory.Mappers;
+import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -145,4 +147,19 @@ public interface BpmTaskConvert {
.setName(element.getName())
.setDefinitionKey(element.getId()));
}
+
+ default TaskEntityImpl convert(TaskEntityImpl task,TaskEntityImpl parentTask){
+ task.setCategory(parentTask.getCategory());
+ task.setDescription(parentTask.getDescription());
+ task.setTenantId(parentTask.getTenantId());
+ task.setName(parentTask.getName());
+ task.setParentTaskId(parentTask.getId());
+ task.setProcessDefinitionId(parentTask.getProcessDefinitionId());
+ task.setProcessInstanceId(parentTask.getProcessInstanceId());
+ task.setTaskDefinitionKey(parentTask.getTaskDefinitionKey());
+ task.setTaskDefinitionId(parentTask.getTaskDefinitionId());
+ task.setPriority(parentTask.getPriority());
+ task.setCreateTime(new Date());
+ return task;
+ }
}
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmTaskExtMapper.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmTaskExtMapper.java
index 6683b536d..7d4d18d8f 100644
--- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmTaskExtMapper.java
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmTaskExtMapper.java
@@ -23,4 +23,7 @@ public interface BpmTaskExtMapper extends BaseMapperX {
return selectOne(BpmTaskExtDO::getTaskId, taskId);
}
+ default void updateBatchByTaskIdList(List taskIdList, BpmTaskExtDO entity){
+ update(entity,new LambdaQueryWrapper().in(BpmTaskExtDO::getTaskId, taskIdList));
+ }
}
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskService.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskService.java
index 99699d791..2eb222b7c 100644
--- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskService.java
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskService.java
@@ -3,6 +3,7 @@ package cn.iocoder.yudao.module.bpm.service.task;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.*;
+import cn.iocoder.yudao.module.bpm.dal.dataobject.task.BpmTaskExtDO;
import org.flowable.task.api.Task;
import javax.validation.Valid;
@@ -62,6 +63,14 @@ public interface BpmTaskService {
*/
List getTaskListByProcessInstanceId(String processInstanceId);
+
+ /**
+ * 通过任务 ID 集合，获取任务扩展表信息集合
+ * @param taskIdList 任务 ID
+ * @return 任务列表
+ */
+ List getTaskListByTaskIdList(List taskIdList);
+
/**
* 通过任务
*
@@ -147,4 +156,11 @@ public interface BpmTaskService {
*/
void delegateTask(BpmTaskDelegateReqVO reqVO, Long userId);
+ /**
+ * 任务加签
+ * @param reqVO 被加签的用户和任务ID，加签类型
+ * @param userId 当前用户 ID
+ */
+ void addSign(BpmTaskAddSignReqVO reqVO, Long userId);
+
}
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskServiceImpl.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskServiceImpl.java
index 86f1ea4ff..6e57fcff4 100644
--- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskServiceImpl.java
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/service/task/BpmTaskServiceImpl.java
@@ -2,7 +2,9 @@ package cn.iocoder.yudao.module.bpm.service.task;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
+import cn.iocoder.yudao.framework.common.enums.SymbolConstant;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.date.DateUtils;
import cn.iocoder.yudao.framework.common.util.number.NumberUtils;
@@ -13,8 +15,7 @@ import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.*;
import cn.iocoder.yudao.module.bpm.convert.task.BpmTaskConvert;
import cn.iocoder.yudao.module.bpm.dal.dataobject.task.BpmTaskExtDO;
import cn.iocoder.yudao.module.bpm.dal.mysql.task.BpmTaskExtMapper;
-import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceDeleteReasonEnum;
-import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceResultEnum;
+import cn.iocoder.yudao.module.bpm.enums.task.*;
import cn.iocoder.yudao.module.bpm.service.definition.BpmModelService;
import cn.iocoder.yudao.module.bpm.service.message.BpmMessageService;
import cn.iocoder.yudao.module.system.api.dept.DeptApi;
@@ -26,6 +27,7 @@ import org.flowable.bpmn.model.BpmnModel;
import org.flowable.bpmn.model.FlowElement;
import org.flowable.bpmn.model.UserTask;
import org.flowable.engine.HistoryService;
+import org.flowable.engine.ManagementService;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.TaskService;
import org.flowable.engine.history.HistoricProcessInstance;
@@ -35,6 +37,8 @@ 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.flowable.task.service.impl.persistence.entity.TaskEntity;
+import org.flowable.task.service.impl.persistence.entity.TaskEntityImpl;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionSynchronization;
@@ -82,6 +86,9 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Resource
private BpmTaskExtMapper taskExtMapper;
+ @Resource
+ private ManagementService managementService;
+
@Override
public PageResult getTodoTaskPage(Long userId, BpmTaskTodoPageReqVO pageVO) {
// 查询待办任务
@@ -186,6 +193,11 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return BpmTaskConvert.INSTANCE.convertList3(tasks, bpmTaskExtDOMap, processInstance, userMap, deptMap);
}
+ @Override
+ public List getTaskListByTaskIdList(List taskIdList) {
+ return taskExtMapper.selectListByTaskIds(taskIdList);
+ }
+
@Override
@Transactional(rollbackFor = Exception.class)
public void approveTask(Long userId, @Valid BpmTaskApproveReqVO reqVO) {
@@ -202,14 +214,151 @@ public class BpmTaskServiceImpl implements BpmTaskService {
approveDelegateTask(reqVO, task);
return;
}
-
- // 情况二：自己审批的任务，调用 complete 去完成任务
+ // 情况二：后加签的任务
+ if(BpmTaskAddSignTypeEnum.AFTER.getType().equals(task.getScopeType())) {
+ //后加签处理
+ handleAfterSignTask(task, reqVO);
+ return;
+ }
+ // 情况三：自己审批的任务，调用 complete 去完成任务
// 完成任务，审批通过
taskService.complete(task.getId(), instance.getProcessVariables());
// 更新任务拓展表为通过
taskExtMapper.updateByTaskId(
new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.APPROVE.getResult())
.setReason(reqVO.getReason()));
+ //处理加签任务
+ this.approveTask0(task);
+ }
+
+ /**
+ * 当前任务存在后加签任务，则不能马上完成，需要一个中间状态，并激活剩余所有子任务
+ * @param task 当前任务
+ * @param reqVO 前端请求参数
+ */
+ private void handleAfterSignTask(Task task,BpmTaskApproveReqVO reqVO){
+ //1.有向后加签，则该任务状态临时设置为 等待后加签任务完成 状态
+ taskExtMapper.updateByTaskId(
+ new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.ADD_SIGN_AFTER.getResult())
+ .setReason(reqVO.getReason()).setEndTime(LocalDateTime.now()));
+ //2. 激活子任务
+ List childrenTaskIdList = getChildrenTaskIdList(task.getId());
+ for (String childrenTaskId : childrenTaskIdList) {
+ taskService.resolveTask(childrenTaskId);
+ }
+ //更新任务扩展表中子任务为进行中
+ taskExtMapper.updateBatchByTaskIdList(childrenTaskIdList,
+ new BpmTaskExtDO().setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()));
+ }
+
+
+ /**
+ * 处理当前任务的父任务
+ *
+ * @param task 当前任务
+ */
+ private void approveTask0(Task task) {
+ String parentTaskId = task.getParentTaskId();
+ if (StrUtil.isNotBlank(parentTaskId)) {
+ //1. 判断当前任务的父任务是否还有子任务
+ long subTaskCount = getSubTaskCount(parentTaskId);
+ if (subTaskCount == 0) {
+ //2. 获取父任务
+ Task parentTask = getTask(parentTaskId);
+ String scopeType = parentTask.getScopeType();
+ //3. 处理向前加签
+ if (BpmTaskAddSignTypeEnum.BEFORE.getType().equals(scopeType)) {
+ //3.1 如果是向前加签的任务，则调用 resolveTask 指派父任务，将 owner 重新赋值给父任务的 assignee
+ taskService.resolveTask(parentTaskId);
+ //3.2 更新任务拓展表为处理中
+ taskExtMapper.updateByTaskId(
+ new BpmTaskExtDO().setTaskId(parentTask.getId()).setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()));
+ }
+ //4. 处理向后加签
+ if (BpmTaskAddSignTypeEnum.AFTER.getType().equals(scopeType)) {
+ handleAfterSign(parentTask, parentTaskId);
+ }
+ //5. 子任务已处理完成，清空 scopeType 字段，修改 parentTask 信息，方便后续可以继续向前后向后加签
+ // 再查询一次的原因是避免报错：Task was updated by another transaction concurrently
+ // 因为前面处理后可能会导致 parentTask rev 字段被修改，需要重新获取最新的
+ parentTask = getTask(parentTaskId);
+ if(parentTask !=null){
+ //为空的情况是：已经通过 handleAfterSign 方法将任务完成了，所以 ru_task 表会查不到数据
+ clearTaskScopeTypeAndSave(parentTask);
+ }
+
+ }
+ }
+ }
+
+ /**
+ * 处理后加签任务
+ *
+ * @param parentTask 当前审批任务的父任务
+ * @param parentTaskId 当前审批任务的父ID
+ */
+ private void handleAfterSign(Task parentTask, String parentTaskId) {
+ //4.1 更新 parentTask 的任务拓展表为通过
+ BpmTaskExtDO currentTaskExt = taskExtMapper.selectByTaskId(parentTask.getId());
+ BpmTaskExtDO currentTaskUpdateEntity = new BpmTaskExtDO().setTaskId(parentTask.getId())
+ .setResult(BpmProcessInstanceResultEnum.APPROVE.getResult());
+ if (currentTaskExt.getEndTime() == null) {
+ //有这个判断是因为
+ //4.2 以前没设置过结束时间，才去设置
+ currentTaskUpdateEntity.setEndTime(LocalDateTime.now());
+ }
+ taskExtMapper.updateByTaskId(currentTaskUpdateEntity);
+ //5. 继续往上处理，父任务继续往上查询
+ if (StrUtil.isEmpty(parentTask.getParentTaskId())) {
+ //5.1 该父任务为最顶级的祖先任务（没有父级ID）， 则直接完成父任务流转到下一步
+ taskService.complete(parentTaskId);
+ } else {
+ //5.2 如果有父级，递归查询上级任务是否都已经完成
+ //判断整条链路的任务是否完成
+ //例如从 A 任务加签了一个 B 任务， B 任务又加签了一个 C 任务，C任务加签了 D 任务
+ //此时，D 任务完成，要一直往上找到祖先任务 A ，调用 complete 方法完成 A 任务
+ boolean allChildrenTaskFinish = true;
+ while (StrUtil.isNotBlank(parentTask.getParentTaskId())) {
+ parentTask = getTask(parentTask.getParentTaskId());
+ BpmTaskExtDO bpmTaskExtDO = taskExtMapper.selectByTaskId(parentTask.getId());
+ if (bpmTaskExtDO == null) {
+ break;
+ }
+ //任务已完成
+ allChildrenTaskFinish = BpmProcessInstanceResultEnum.isEndResult(bpmTaskExtDO.getResult());
+ if (!allChildrenTaskFinish) {
+ //有一个未完成，则退出循环
+ break;
+ }
+ }
+ if (allChildrenTaskFinish) {
+ //完成最后的顶级祖先任务
+ taskService.complete(parentTask.getId());
+ }
+ }
+ }
+
+ /**
+ * 清空 scopeType 字段，用于任务没有子任务时使用该方法，方便任务可以再次被不同的方式加签
+ *
+ * @param task 需要被清空的任务
+ */
+ private void clearTaskScopeTypeAndSave(Task task) {
+ TaskEntityImpl taskImpl = (TaskEntityImpl) task;
+ taskImpl.setScopeType(null);
+ taskService.saveTask(task);
+ }
+
+ /**
+ * 获取子任务个数
+ *
+ * @param parentTaskId 父类ID
+ * @return 剩余子任务个数
+ */
+ private Long getSubTaskCount(String parentTaskId) {
+ String tableName = managementService.getTableName(TaskEntity.class);
+ String sql = "select count(1) from " + tableName + " where PARENT_TASK_ID_=#{parentTaskId}";
+ return taskService.createNativeTaskQuery().sql(sql).parameter("parentTaskId", parentTaskId).count();
}
/**
@@ -226,7 +375,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
String comment = StrUtil.format("[{}]完成委派任务，任务重新回到[{}]手中，审批意见为:{}", currentUser.getNickname(),
sourceApproveUser.getNickname(), reqVO.getReason());
taskService.addComment(reqVO.getId(), task.getProcessInstanceId(),
- BpmProcessInstanceResultEnum.DELEGATE.getResult().toString(), comment);
+ BpmCommentTypeEnum.DELEGATE.getDesc(), comment);
// 2.1 调用 resolveTask 完成任务。
// 底层调用 TaskHelper.changeTaskAssignee(task, task.getOwner())：将 owner 设置为 assignee
@@ -290,6 +439,10 @@ public class BpmTaskServiceImpl implements BpmTaskService {
public void createTaskExt(Task task) {
BpmTaskExtDO taskExtDO =
BpmTaskConvert.INSTANCE.convert2TaskExt(task).setResult(BpmProcessInstanceResultEnum.PROCESS.getResult());
+ //向后加签生成的任务，状态不能为进行中，需要等前面父任务完成
+ if(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType().equals(task.getScopeType())){
+ taskExtDO.setResult(BpmProcessInstanceResultEnum.WAIT_BEFORE_TASK.getResult());
+ }
taskExtMapper.insert(taskExtDO);
}
@@ -343,21 +496,19 @@ public class BpmTaskServiceImpl implements BpmTaskService {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override
public void afterCommit() {
- ProcessInstance processInstance =
- processInstanceService.getProcessInstance(task.getProcessInstanceId());
- AdminUserRespDTO startUser = adminUserApi.getUser(Long.valueOf(processInstance.getStartUserId()));
- messageService.sendMessageWhenTaskAssigned(
- BpmTaskConvert.INSTANCE.convert(processInstance, startUser, task));
+ if(StrUtil.isNotEmpty(task.getAssignee())){
+ ProcessInstance processInstance =
+ processInstanceService.getProcessInstance(task.getProcessInstanceId());
+ AdminUserRespDTO startUser = adminUserApi.getUser(Long.valueOf(processInstance.getStartUserId()));
+ messageService.sendMessageWhenTaskAssigned(
+ BpmTaskConvert.INSTANCE.convert(processInstance, startUser, task));
+ }
}
});
}
private Task getTask(String id) {
- Task task = taskService.createTaskQuery().taskId(id).singleResult();
- if (null == task) {
- throw exception(TASK_NOT_EXISTS);
- }
- return task;
+ return taskService.createTaskQuery().taskId(id).singleResult();
}
private HistoricTaskInstance getHistoricTask(String id) {
@@ -437,7 +588,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
/**
* 执行回退逻辑
*
- * @param currentTask 当前回退的任务
+ * @param currentTask 当前回退的任务
* @param targetElement 需要回退到的目标任务
* @param reqVO 前端参数封装
*/
@@ -458,7 +609,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return;
}
taskService.addComment(task.getId(), currentTask.getProcessInstanceId(),
- BpmProcessInstanceResultEnum.BACK.getResult().toString(), reqVO.getReason());
+ BpmCommentTypeEnum.BACK.getDesc(), reqVO.getReason());
});
// 3. 执行驳回
@@ -485,9 +636,8 @@ public class BpmTaskServiceImpl implements BpmTaskService {
String comment = StrUtil.format("[{}]将任务委派给[{}]，委派理由为:{}", currentUser.getNickname(),
delegateUser.getNickname(), reqVO.getReason());
String taskId = reqVO.getId();
- // TODO 海：后面改；感觉 comment 应该 type 做个枚举；不和 result 耦合在一起；
taskService.addComment(taskId, task.getProcessInstanceId(),
- BpmProcessInstanceResultEnum.DELEGATE.getResult().toString(), comment);
+ BpmCommentTypeEnum.DELEGATE.getDesc(), comment);
// 3.1 设置任务所有人 (owner) 为原任务的处理人 (assignee)
taskService.setOwner(taskId, task.getAssignee());
@@ -503,7 +653,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
* 校验任务委派参数
*
* @param userId 用户编号
- * @param reqVO 任务编号，接收人ID
+ * @param reqVO 任务编号，接收人ID
* @return 当前任务信息
*/
private Task validateTaskCanDelegate(Long userId, BpmTaskDelegateReqVO reqVO) {
@@ -516,4 +666,125 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return task;
}
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void addSign(BpmTaskAddSignReqVO reqVO, Long userId) {
+ //1.获取和校验任务
+ TaskEntityImpl taskEntity = validateAddSign(userId, reqVO);
+ AdminUserRespDTO currentUser = adminUserApi.getUser(userId);
+ List userList = adminUserApi.getUserList(reqVO.getUserIdList());
+ if (CollUtil.isEmpty(userList)) {
+ throw exception(TASK_ADD_SIGN_USER_NOT_EXIST);
+ }
+ //2.处理当前任务
+ //2.1 开启计数功能
+ taskEntity.setCountEnabled(true);
+ boolean addSignToBefore = reqVO.getType().equals(BpmTaskAddSignTypeEnum.BEFORE.getType());
+ if (addSignToBefore) {
+ //2.2 向前加签，设置 owner ，置空 assign ,等子任务都完成后，再调用 resolveTask 重新将 owner 设置为 assign
+ //原因是：不能和向前加签的子任务一起审批，需要等前面的子任务都完成才能审批
+ taskEntity.setOwner(taskEntity.getAssignee());
+ taskEntity.setAssignee(null);
+ //2.3 更新扩展表状态
+ taskExtMapper.updateByTaskId(
+ new BpmTaskExtDO().setTaskId(taskEntity.getId())
+ .setResult(BpmProcessInstanceResultEnum.ADD_SIGN_BEFORE.getResult())
+ .setReason(reqVO.getReason()));
+ }
+ //2.4 记录加签方式，完成任务时需要用到判断
+ taskEntity.setScopeType(reqVO.getType());
+ //2.5 保存当前任务修改后的值
+ taskService.saveTask(taskEntity);
+
+ //3. 处理加签任务
+ this.createSignSubTasks(convertList(reqVO.getUserIdList(), String::valueOf), taskEntity);
+ //4. 记录加签 comment，拼接结果为： [当前用户]向前加签/向后加签给了[多个用户],理由为：reason
+ String comment = StrUtil.format("[{}]{}给了[{}],理由为：{}", currentUser.getNickname(), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType()),
+ String.join(SymbolConstant.D, convertList(userList, AdminUserRespDTO::getNickname)), reqVO.getReason());
+ taskService.addComment(reqVO.getId(), taskEntity.getProcessInstanceId(),
+ BpmCommentTypeEnum.ADD_SIGN.getDesc(), comment);
+ }
+
+
+ /**
+ * 校验任务存在和 存在 向前加签 的任务，则不能 向后加签，存在 向后加签 则不能 向前加签
+ *
+ * @param userId 当前用户 ID
+ * @param reqVO 请求参数，包含任务 ID 和加签类型
+ * @return 当前任务
+ */
+ private TaskEntityImpl validateAddSign(Long userId, BpmTaskAddSignReqVO reqVO) {
+ TaskEntityImpl taskEntity = (TaskEntityImpl) validateTask(userId, reqVO.getId());
+ //向前加签和向后加签不能同时存在
+ if (StrUtil.isNotBlank(taskEntity.getScopeType())
+ && !BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getDesc().equals(taskEntity.getScopeType())) {
+ if (!taskEntity.getScopeType().equals(reqVO.getType())) {
+ throw exception(TASK_ADD_SIGN_TYPE_ERROR,
+ BpmTaskAddSignTypeEnum.formatDesc(taskEntity.getScopeType()), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType()));
+ }
+ }
+ //同一个 key 的任务，审批人不重复
+ List taskList = taskService.createTaskQuery().processInstanceId(taskEntity.getProcessInstanceId())
+ .taskDefinitionKey(taskEntity.getTaskDefinitionKey()).list();
+ List currentAssigneeList = convertList(taskList, Task::getAssignee);
+ List frontAssigneeList = convertList(reqVO.getUserIdList(), String::valueOf);
+ currentAssigneeList.retainAll(frontAssigneeList);
+ if (CollUtil.isNotEmpty(currentAssigneeList)) {
+ List userList = adminUserApi.getUserList(convertList(currentAssigneeList, NumberUtils::parseLong));
+ throw exception(TASK_ADD_SIGN_USER_REPEAT, String.join(SymbolConstant.D, convertList(userList, AdminUserRespDTO::getNickname)));
+ }
+ return taskEntity;
+ }
+
+ /**
+ * 创建加签子任务
+ *
+ * @param addSingUserIdList 被加签的用户ID
+ * @param taskEntity 被加签的任务
+ */
+ private void createSignSubTasks(List addSingUserIdList, TaskEntityImpl taskEntity) {
+ if (CollUtil.isNotEmpty(addSingUserIdList)) {
+ // 创建加签人的新任务,全部基于 taskEntity 为父任务来创建
+ addSingUserIdList.forEach(addSignId -> {
+ if (StrUtil.isNotBlank(addSignId)) {
+ this.createSubTask(taskEntity, addSignId);
+ }
+ });
+ }
+ }
+
+ /**
+ * 创建子任务
+ *
+ * @param parentTask 父任务
+ * @param assignee 子任务的执行人
+ * @return
+ */
+ private void createSubTask(TaskEntityImpl parentTask, String assignee) {
+ //1.生成子任务
+ TaskEntityImpl task = (TaskEntityImpl) taskService.newTask(IdUtil.fastSimpleUUID());
+ task = BpmTaskConvert.INSTANCE.convert(task,parentTask);
+ if (BpmTaskAddSignTypeEnum.BEFORE.getType().equals(parentTask.getScopeType())) {
+ // 2. 前加签，才设置审批人，否则设置 owner
+ task.setAssignee(assignee);
+ } else {
+ //2.2 设置 owner 不设置 assignee 是因为不能同时审批，需要等父任务完成
+ task.setOwner(assignee);
+ //2.3 设置向后加签任务的 scopeType 为 afterChildrenTask，用于设置任务扩展表的状态
+ task.setScopeType(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType());
+ }
+ taskService.saveTask(task);
+ }
+
+ /**
+ * 获取指定父级任务的所有子任务 ID 集合
+ * @param parentTaskId 父任务 ID
+ * @return 所有子任务的 ID 集合
+ */
+ private List getChildrenTaskIdList(String parentTaskId){
+ String tableName = managementService.getTableName(TaskEntity.class);
+ String sql = "select ID_ from " + tableName + " where PARENT_TASK_ID_=#{parentTaskId}";
+ List childrenTaskList = taskService.createNativeTaskQuery().sql(sql).parameter("parentTaskId", parentTaskId).list();
+ return convertList(childrenTaskList, Task::getId);
+ }
}