code review:【工作流】—— 加签的实现

This commit is contained in:
zhijiantianya@gmail.com 2023-10-09 20:57:23 +08:00
parent 45a2cd70f0
commit 6388950ab2
11 changed files with 133 additions and 82 deletions

View File

@ -1,5 +1,6 @@
package cn.iocoder.yudao.framework.common.enums; package cn.iocoder.yudao.framework.common.enums;
// TODO 这种简单的暂时不用枚举哈直接代码里写死就好啦
/** /**
* 符号常量 * 符号常量
*/ */

View File

@ -54,6 +54,7 @@ public interface ErrorCodeConstants {
ErrorCode TASK_ADD_SIGN_TYPE_ERROR = new ErrorCode(1_009_005_010, "任务加签:当前任务已经{},不能{}"); ErrorCode TASK_ADD_SIGN_TYPE_ERROR = new ErrorCode(1_009_005_010, "任务加签:当前任务已经{},不能{}");
ErrorCode TASK_ADD_SIGN_USER_REPEAT = new ErrorCode(1_009_005_011, "任务加签失败,加签人与现有审批人[{}]重复"); ErrorCode TASK_ADD_SIGN_USER_REPEAT = new ErrorCode(1_009_005_011, "任务加签失败,加签人与现有审批人[{}]重复");
ErrorCode TASK_SUB_SIGN_NO_PARENT = new ErrorCode(1_009_005_011, "任务减签失败,被减签的任务必须是通过加签生成的任务"); ErrorCode TASK_SUB_SIGN_NO_PARENT = new ErrorCode(1_009_005_011, "任务减签失败,被减签的任务必须是通过加签生成的任务");
// ========== 流程任务分配规则 1-009-006-000 ========== // ========== 流程任务分配规则 1-009-006-000 ==========
ErrorCode TASK_ASSIGN_RULE_EXISTS = new ErrorCode(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, "流程任务分配规则不存在"); ErrorCode TASK_ASSIGN_RULE_NOT_EXISTS = new ErrorCode(1_009_006_001, "流程任务分配规则不存在");

View File

@ -14,6 +14,7 @@ public enum BpmCommentTypeEnum {
REJECT(2, "不通过"), REJECT(2, "不通过"),
CANCEL(3, "已取消"), CANCEL(3, "已取消"),
// TODO @海18 行可以去掉哈这个是之前为了 status 隔离用的
// ========== 流程任务独有的状态 ========== // ========== 流程任务独有的状态 ==========
BACK(4, "退回"), // 退回 BACK(4, "退回"), // 退回
@ -22,6 +23,7 @@ public enum BpmCommentTypeEnum {
SUB_SIGN(7,"减签"), SUB_SIGN(7,"减签"),
; ;
// TODO @海字段叫 type 更合适噢
/** /**
* 结果 * 结果
*/ */

View File

@ -26,20 +26,20 @@ public enum BpmProcessInstanceResultEnum {
BACK(5, "驳回"), // 退回 BACK(5, "驳回"), // 退回
DELEGATE(6, "委派"), DELEGATE(6, "委派"),
/** /**
* 源任务已经审批完成但是它使用了后加签后加签的任务未完成源任务就会是这个状态 * 加签源任务已经审批完成但是它使用了后加签后加签的任务未完成源任务就会是这个状态
* 例如A审批 A 后加签了 B 并且审批通过了任务但是 B 还未审批则当前任务状态为 待后加签任务完成 * 例如A审批 A 后加签了 B并且审批通过了任务但是 B 还未审批则当前任务状态为待后加签任务完成
*/ */
ADD_SIGN_AFTER(7, "待后加签任务完成"), ADD_SIGN_AFTER(7, "待后加签任务完成"), // TODO @海这个定义是不是 通过待后加签任务完成相当于是 APPROVE 的特殊状态
/** /**
* 源任务未审批但是向前加签了所以源任务状态变为 待前加签任务完成 * 加签源任务未审批但是向前加签了所以源任务状态变为待前加签任务完成
* 例如A审批 A 前加签了 B B 还未审核 * 例如A 审批 A 前加签了 BB 还未审核
*/ */
ADD_SIGN_BEFORE(8, "待前加签任务完成"), ADD_SIGN_BEFORE(8, "待前加签任务完成"), // TODO @海这个定义是不是 处理中待前加签任务审批相当于是 PROCESS 的特殊状态
/** /**
* 后加签任务被创建时的初始状态 * 加签后加签任务被创建时的初始状态
* 因为需要源任务先完成才能到后加签的人来审批所以加了一个状态区分 * 因为需要源任务先完成才能到后加签的人来审批所以加了一个状态区分
*/ */
WAIT_BEFORE_TASK(9, "待前置任务完成"); WAIT_BEFORE_TASK(9, "待前置任务完成"); // TODO @海这个定义是不是 处理中待前置任务审批相当于是 PROCESS 的特殊状态
/** /**
* 结果 * 结果
@ -66,6 +66,7 @@ public enum BpmProcessInstanceResultEnum {
ADD_SIGN_AFTER.getResult()); ADD_SIGN_AFTER.getResult());
} }
// TODO @海静态变量需要放到成员变量前面另外如果是复数可以加 S(ES) 或者 LIST
/** /**
* 能被减签的状态 * 能被减签的状态
*/ */

View File

@ -36,5 +36,6 @@ public enum BpmTaskAddSignTypeEnum {
} }
return null; return null;
} }
} }

View File

@ -100,23 +100,29 @@ public class BpmTaskController {
return success(true); return success(true);
} }
// TODO @海权限统一使用 bpm:task:update是否可以加减签可以交给后续的权限配置实现
@PutMapping("/add-sign") @PutMapping("/add-sign")
@Operation(summary = "加签", description = "before, after为前加签后加签") @Operation(summary = "加签", description = "before 前加签after 后加签")
@PreAuthorize("@ss.hasPermission('bpm:task:add-sign')") @PreAuthorize("@ss.hasPermission('bpm:task:add-sign')")
public CommonResult<Boolean> addSign(@Valid @RequestBody BpmTaskAddSignReqVO reqVO) { public CommonResult<Boolean> addSign(@Valid @RequestBody BpmTaskAddSignReqVO reqVO) {
// TODO @海userId 建议作为第一个参数一般是谁做了什么操作另外addSignTask保持风格统一哈
taskService.addSign(reqVO,getLoginUserId()); taskService.addSign(reqVO,getLoginUserId());
return success(true); return success(true);
} }
// TODO @海权限统一使用 bpm:task:update是否可以加减签可以交给后续的权限配置实现
@PutMapping("/sub-sign") @PutMapping("/sub-sign")
@Operation(summary = "减签", description = "") @Operation(summary = "减签")
@PreAuthorize("@ss.hasPermission('bpm:task:sub-sign')") @PreAuthorize("@ss.hasPermission('bpm:task:sub-sign')")
// TODO @海 @RequestBody BpmTaskSubSignReqVO 应该是一个空格然后参数名可以简写成 reqVO
public CommonResult<Boolean> subSign(@Valid @RequestBody BpmTaskSubSignReqVO bpmTaskSubSignReqVO) { public CommonResult<Boolean> subSign(@Valid @RequestBody BpmTaskSubSignReqVO bpmTaskSubSignReqVO) {
taskService.subSign(bpmTaskSubSignReqVO,getLoginUserId()); taskService.subSign(bpmTaskSubSignReqVO,getLoginUserId());
return success(true); return success(true);
} }
// TODO @海是不是 url 和方法名 get-child-task-list更抽象和复用一些
@GetMapping("/get-sub-sign") @GetMapping("/get-sub-sign")
@Operation(summary = "获取能被减签的任务", description = "") @Operation(summary = "获取能被减签的任务")
@PreAuthorize("@ss.hasPermission('bpm:task:sub-sign')") @PreAuthorize("@ss.hasPermission('bpm:task:sub-sign')")
public CommonResult<List<BpmTaskSubSignRespVO>> getChildrenTaskList(@RequestParam("taskId") String taskId) { public CommonResult<List<BpmTaskSubSignRespVO>> getChildrenTaskList(@RequestParam("taskId") String taskId) {
return success(taskService.getChildrenTaskList(taskId)); return success(taskService.getChildrenTaskList(taskId));

View File

@ -12,7 +12,7 @@ import java.util.Set;
public class BpmTaskAddSignReqVO { public class BpmTaskAddSignReqVO {
@Schema(description = "加签的用户 ID") @Schema(description = "加签的用户 ID")
@NotEmpty(message = "加签用户ID不能为空") @NotEmpty(message = "加签用户 ID 不能为空")
private Set<Long> userIdList; private Set<Long> userIdList;
@Schema(description = "加签类型before 向前加签after 向后加签") @Schema(description = "加签类型before 向前加签after 向后加签")
@ -23,7 +23,9 @@ public class BpmTaskAddSignReqVO {
@NotEmpty(message = "加签原因不能为空") @NotEmpty(message = "加签原因不能为空")
private String reason; private String reason;
// TODO @海重要参数可以放到最前面哈
@Schema(description = "需要加签的任务 ID") @Schema(description = "需要加签的任务 ID")
@NotEmpty(message = "任务编号不能为空") @NotEmpty(message = "任务编号不能为空")
private String id; private String id;
} }

View File

@ -147,6 +147,7 @@ public interface BpmTaskConvert {
.setDefinitionKey(element.getId())); .setDefinitionKey(element.getId()));
} }
// TODO @海可以使用 mapstruct 映射么
default TaskEntityImpl convert(TaskEntityImpl task,TaskEntityImpl parentTask){ default TaskEntityImpl convert(TaskEntityImpl task,TaskEntityImpl parentTask){
task.setCategory(parentTask.getCategory()); task.setCategory(parentTask.getCategory());
task.setDescription(parentTask.getDescription()); task.setDescription(parentTask.getDescription());

View File

@ -32,7 +32,8 @@ public interface BpmTaskExtMapper extends BaseMapperX<BpmTaskExtDO> {
return selectOne(BpmTaskExtDO::getTaskId, taskId); return selectOne(BpmTaskExtDO::getTaskId, taskId);
} }
default void updateBatchByTaskIdList(List<String> taskIdList, BpmTaskExtDO entity){ default void updateBatchByTaskIdList(List<String> taskIdList, BpmTaskExtDO updateObj) {
update(entity,new LambdaQueryWrapper<BpmTaskExtDO>().in(BpmTaskExtDO::getTaskId, taskIdList)); update(updateObj, new LambdaQueryWrapper<BpmTaskExtDO>().in(BpmTaskExtDO::getTaskId, taskIdList));
} }
} }

View File

@ -65,8 +65,8 @@ public interface BpmTaskService {
/** /**
* 通过任务 ID 集合获取任务扩展表信息集合 * 通过任务 ID 集合获取任务扩展表信息集合 // TODO @海洋方法注释和下面的参数需要空一行
* @param taskIdList 任务 ID * @param taskIdList 任务 ID 集合
* @return 任务列表 * @return 任务列表
*/ */
List<BpmTaskExtDO> getTaskListByTaskIdList(List<String> taskIdList); List<BpmTaskExtDO> getTaskListByTaskIdList(List<String> taskIdList);
@ -158,22 +158,26 @@ public interface BpmTaskService {
/** /**
* 任务加签 * 任务加签
* @param reqVO 被加签的用户和任务ID加签类型 *
* @param reqVO 被加签的用户和任务 ID加签类型
* @param userId 当前用户 ID * @param userId 当前用户 ID
*/ */
void addSign(BpmTaskAddSignReqVO reqVO, Long userId); void addSign(BpmTaskAddSignReqVO reqVO, Long userId);
/** /**
* 减签 * 任务减签名
* @param bpmTaskSubSignReqVO 被减签的任务ID理由 *
* @param bpmTaskSubSignReqVO 被减签的任务 ID理由
* @param loginUserId 当前用户ID * @param loginUserId 当前用户ID
*/ */
void subSign(BpmTaskSubSignReqVO bpmTaskSubSignReqVO, Long loginUserId); void subSign(BpmTaskSubSignReqVO bpmTaskSubSignReqVO, Long loginUserId);
/** /**
* 获取指定任务的子任务和审批人信息 * 获取指定任务的子任务和审批人信息
*
* @param taskId 指定任务ID * @param taskId 指定任务ID
* @return 子任务列表 * @return 子任务列表
*/ */
List<BpmTaskSubSignRespVO> getChildrenTaskList(String taskId); List<BpmTaskSubSignRespVO> getChildrenTaskList(String taskId);
} }

View File

@ -218,12 +218,15 @@ public class BpmTaskServiceImpl implements BpmTaskService {
approveDelegateTask(reqVO, task); approveDelegateTask(reqVO, task);
return; return;
} }
// 情况二后加签的任务 // 情况二后加签的任务
if(BpmTaskAddSignTypeEnum.AFTER.getType().equals(task.getScopeType())) { if (BpmTaskAddSignTypeEnum.AFTER.getType().equals(task.getScopeType())) {
//后加签处理 // 后加签处理
// TODO @海洋这个是不是 approveAfterSignTask
handleAfterSignTask(task, reqVO); handleAfterSignTask(task, reqVO);
return; return;
} }
// 情况三自己审批的任务调用 complete 去完成任务 // 情况三自己审批的任务调用 complete 去完成任务
// 完成任务审批通过 // 完成任务审批通过
taskService.complete(task.getId(), instance.getProcessVariables()); taskService.complete(task.getId(), instance.getProcessVariables());
@ -231,31 +234,34 @@ public class BpmTaskServiceImpl implements BpmTaskService {
taskExtMapper.updateByTaskId( taskExtMapper.updateByTaskId(
new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.APPROVE.getResult()) new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.APPROVE.getResult())
.setReason(reqVO.getReason())); .setReason(reqVO.getReason()));
//处理加签任务 // 处理加签任务
this.handleParentTask(task); handleParentTask(task);
} }
/** /**
* 当前任务存在后加签任务则不能马上完成需要一个中间状态并激活剩余所有子任务 * 审批通过存在后加签的任务
*
* 注意该任务不能马上完成需要一个中间状态ADD_SIGN_AFTER并激活剩余所有子任务PROCESS为可审批处理
*
* @param task 当前任务 * @param task 当前任务
* @param reqVO 前端请求参数 * @param reqVO 前端请求参数
*/ */
private void handleAfterSignTask(Task task,BpmTaskApproveReqVO reqVO){ private void handleAfterSignTask(Task task,BpmTaskApproveReqVO reqVO){
//1.有向后加签则该任务状态临时设置为 等待后加签任务完成 状态 // 1. 有向后加签则该任务状态临时设置为 ADD_SIGN_AFTER 状态
taskExtMapper.updateByTaskId( taskExtMapper.updateByTaskId(
new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.ADD_SIGN_AFTER.getResult()) new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.ADD_SIGN_AFTER.getResult())
.setReason(reqVO.getReason()).setEndTime(LocalDateTime.now())); .setReason(reqVO.getReason()).setEndTime(LocalDateTime.now()));
//2. 激活子任务
// 2. 激活子任务
List<String> childrenTaskIdList = getChildrenTaskIdList(task.getId()); List<String> childrenTaskIdList = getChildrenTaskIdList(task.getId());
for (String childrenTaskId : childrenTaskIdList) { for (String childrenTaskId : childrenTaskIdList) {
taskService.resolveTask(childrenTaskId); taskService.resolveTask(childrenTaskId);
} }
//更新任务扩展表中子任务为进行中 // 更新任务扩展表中子任务为进行中
taskExtMapper.updateBatchByTaskIdList(childrenTaskIdList, taskExtMapper.updateBatchByTaskIdList(childrenTaskIdList,
new BpmTaskExtDO().setResult(BpmProcessInstanceResultEnum.PROCESS.getResult())); new BpmTaskExtDO().setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()));
} }
/** /**
* 处理当前任务的父任务 * 处理当前任务的父任务
* *
@ -263,62 +269,70 @@ public class BpmTaskServiceImpl implements BpmTaskService {
*/ */
private void handleParentTask(Task task) { private void handleParentTask(Task task) {
String parentTaskId = task.getParentTaskId(); String parentTaskId = task.getParentTaskId();
// TODO @ if return 原则
if (StrUtil.isNotBlank(parentTaskId)) { if (StrUtil.isNotBlank(parentTaskId)) {
//1. 判断当前任务的父任务是否还有子任务 // 1. 判断当前任务的父任务是否还有子任务
long subTaskCount = getSubTaskCount(parentTaskId); long subTaskCount = getSubTaskCount(parentTaskId);
// TODO @ if >= 0 return这样括号又可以少一层
if (subTaskCount == 0) { if (subTaskCount == 0) {
//2. 获取父任务 // 2. 获取父任务
Task parentTask = validateTaskExist(parentTaskId); Task parentTask = validateTaskExist(parentTaskId);
// 3. 情况一处理向前加签
String scopeType = parentTask.getScopeType(); String scopeType = parentTask.getScopeType();
//3. 处理向前加签
if (BpmTaskAddSignTypeEnum.BEFORE.getType().equals(scopeType)) { if (BpmTaskAddSignTypeEnum.BEFORE.getType().equals(scopeType)) {
//3.1 如果是向前加签的任务则调用 resolveTask 指派父任务 owner 重新赋值给父任务的 assignee // 3.1 如果是向前加签的任务则调用 resolveTask 指派父任务 owner 重新赋值给父任务的 assignee
taskService.resolveTask(parentTaskId); taskService.resolveTask(parentTaskId);
//3.2 更新任务拓展表为处理中 // 3.2 更新任务拓展表为处理中
taskExtMapper.updateByTaskId( taskExtMapper.updateByTaskId(
new BpmTaskExtDO().setTaskId(parentTask.getId()).setResult(BpmProcessInstanceResultEnum.PROCESS.getResult())); new BpmTaskExtDO().setTaskId(parentTask.getId()).setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()));
}else if (BpmTaskAddSignTypeEnum.AFTER.getType().equals(scopeType)) { } else if (BpmTaskAddSignTypeEnum.AFTER.getType().equals(scopeType)) {
//4. 处理向后加签 // 3. 情况二处理向后加签
handleAfterSign(parentTask); handleAfterSign(parentTask);
} }
//5. 子任务已处理完成清空 scopeType 字段修改 parentTask 信息方便后续可以继续向前后向后加签
// 4. 子任务已处理完成清空 scopeType 字段修改 parentTask 信息方便后续可以继续向前后向后加签
// 再查询一次的原因是避免报错Task was updated by another transaction concurrently // 再查询一次的原因是避免报错Task was updated by another transaction concurrently
// 因为前面处理后可能会导致 parentTask rev 字段被修改需要重新获取最新的 // 因为前面处理后可能会导致 parentTask rev 字段被修改需要重新获取最新的
parentTask = getTask(parentTaskId); parentTask = getTask(parentTaskId);
if(parentTask !=null){ // TODO @ if return 原则
//为空的情况是已经通过 handleAfterSign 方法将任务完成了所以 ru_task 表会查不到数据 if (parentTask != null) {
// 为空的情况是已经通过 handleAfterSign 方法将任务完成了所以 ru_task 表会查不到数据
clearTaskScopeTypeAndSave(parentTask); clearTaskScopeTypeAndSave(parentTask);
} }
} }
} }
} }
// TODO @海这个方法的 4.1 1 开始计数哈另外看看能不能用 if return 进一步简化代码的层级
/** /**
* 处理后加签任务 * 处理后加签任务
* *
* @param parentTask 当前审批任务的父任务 * @param parentTask 当前审批任务的父任务
*/ */
private void handleAfterSign(Task parentTask) { private void handleAfterSign(Task parentTask) {
// TODO @海这个方法在注释下感觉整体是先完成自己然后递归处理父节点但是完成机子被放到了 5.1就感觉上有点割裂
String parentTaskId = parentTask.getId(); String parentTaskId = parentTask.getId();
//4.1 更新 parentTask 的任务拓展表为通过 //4.1 更新 parentTask 的任务拓展表为通过
BpmTaskExtDO currentTaskExt = taskExtMapper.selectByTaskId(parentTask.getId()); BpmTaskExtDO currentTaskExt = taskExtMapper.selectByTaskId(parentTask.getId());
BpmTaskExtDO currentTaskUpdateEntity = new BpmTaskExtDO().setTaskId(parentTask.getId()) BpmTaskExtDO currentTaskUpdateEntity = new BpmTaskExtDO().setTaskId(parentTask.getId())
.setResult(BpmProcessInstanceResultEnum.APPROVE.getResult()); .setResult(BpmProcessInstanceResultEnum.APPROVE.getResult());
if (currentTaskExt.getEndTime() == null) { if (currentTaskExt.getEndTime() == null) {
//有这个判断是因为 // 有这个判断是因为
//4.2 以前没设置过结束时间才去设置 // 4.2 以前没设置过结束时间才去设置
currentTaskUpdateEntity.setEndTime(LocalDateTime.now()); currentTaskUpdateEntity.setEndTime(LocalDateTime.now());
} }
taskExtMapper.updateByTaskId(currentTaskUpdateEntity); taskExtMapper.updateByTaskId(currentTaskUpdateEntity);
//5. 继续往上处理父任务继续往上查询
//5.1 先完成自己 // 5. 继续往上处理父任务继续往上查询
// 5.1 先完成自己
taskService.complete(parentTaskId); taskService.complete(parentTaskId);
// 5.2 如果有父级递归查询上级任务是否都已经完成
// TODO @海这块待讨论脑子略乱感觉 handleAfterSign 的后半段 handleParentTask 有点重叠
if (StrUtil.isNotEmpty(parentTask.getParentTaskId())) { if (StrUtil.isNotEmpty(parentTask.getParentTaskId())) {
//5.2 如果有父级递归查询上级任务是否都已经完成 // 判断整条链路的任务是否完成
//判断整条链路的任务是否完成 // 例如从 A 任务加签了一个 B 任务B 任务又加签了一个 C 任务C 任务加签了 D 任务
//例如从 A 任务加签了一个 B 任务 B 任务又加签了一个 C 任务C任务加签了 D 任务 // 此时D 任务完成要一直往上找到祖先任务 A调用 complete 方法完成 A 任务
//此时D 任务完成要一直往上找到祖先任务 A 调用 complete 方法完成 A 任务
boolean allChildrenTaskFinish = true; boolean allChildrenTaskFinish = true;
while (StrUtil.isNotBlank(parentTask.getParentTaskId())) { while (StrUtil.isNotBlank(parentTask.getParentTaskId())) {
parentTask = validateTaskExist(parentTask.getParentTaskId()); parentTask = validateTaskExist(parentTask.getParentTaskId());
@ -327,23 +341,23 @@ public class BpmTaskServiceImpl implements BpmTaskService {
break; break;
} }
boolean currentTaskFinish = BpmProcessInstanceResultEnum.isEndResult(bpmTaskExtDO.getResult()); boolean currentTaskFinish = BpmProcessInstanceResultEnum.isEndResult(bpmTaskExtDO.getResult());
//5.3 如果 allChildrenTaskFinish 已经被赋值为 false ,则不会再赋值为 true因为整个链路没有完成 // 5.3 如果 allChildrenTaskFinish 已经被赋值为 false ,则不会再赋值为 true因为整个链路没有完成
if (allChildrenTaskFinish) { if (allChildrenTaskFinish) {
allChildrenTaskFinish = currentTaskFinish; allChildrenTaskFinish = currentTaskFinish;
} }
if (!currentTaskFinish) { if (!currentTaskFinish) {
//6 处理非完成状态的任务 // 6 处理非完成状态的任务
//6.1 判断当前任务的父任务是否还有子任务 // 6.1 判断当前任务的父任务是否还有子任务
Long subTaskCount = getSubTaskCount(bpmTaskExtDO.getTaskId()); Long subTaskCount = getSubTaskCount(bpmTaskExtDO.getTaskId());
if (subTaskCount == 0) { if (subTaskCount == 0) {
//6.2 没有子任务判断当前任务状态是否为 ADD_SIGN_BEFORE 待前加签任务完成 // 6.2 没有子任务判断当前任务状态是否为 ADD_SIGN_BEFORE 待前加签任务完成
if (BpmProcessInstanceResultEnum.ADD_SIGN_BEFORE.getResult().equals(bpmTaskExtDO.getResult())) { if (BpmProcessInstanceResultEnum.ADD_SIGN_BEFORE.getResult().equals(bpmTaskExtDO.getResult())) {
//6.3 需要修改该任务状态为处理中 // 6.3 需要修改该任务状态为处理中
taskService.resolveTask(bpmTaskExtDO.getTaskId()); taskService.resolveTask(bpmTaskExtDO.getTaskId());
bpmTaskExtDO.setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()); bpmTaskExtDO.setResult(BpmProcessInstanceResultEnum.PROCESS.getResult());
taskExtMapper.updateByTaskId(bpmTaskExtDO); taskExtMapper.updateByTaskId(bpmTaskExtDO);
} }
//6.4 清空 scopeType 字段用于任务没有子任务时使用该方法方便任务可以再次被不同的方式加签 // 6.4 清空 scopeType 字段用于任务没有子任务时使用该方法方便任务可以再次被不同的方式加签
parentTask = getTask(bpmTaskExtDO.getTaskId()); parentTask = getTask(bpmTaskExtDO.getTaskId());
if (parentTask != null) { if (parentTask != null) {
clearTaskScopeTypeAndSave(parentTask); clearTaskScopeTypeAndSave(parentTask);
@ -352,7 +366,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
} }
} }
if (allChildrenTaskFinish) { if (allChildrenTaskFinish) {
//7. 完成最后的顶级祖先任务 // 7. 完成最后的顶级祖先任务
taskService.complete(parentTask.getId()); taskService.complete(parentTask.getId());
} }
} }
@ -369,15 +383,16 @@ public class BpmTaskServiceImpl implements BpmTaskService {
taskService.saveTask(task); taskService.saveTask(task);
} }
// TODO @海Sub 还有 Child 感觉整体用词不是很统一是不是要统一下然后 Sub 还可以指的减签看看是不是名词确实得一致哈
/** /**
* 获取子任务个数 * 获取子任务个数
* *
* @param parentTaskId ID * @param parentTaskId 任务 ID
* @return 剩余子任务个数 * @return 剩余子任务个数
*/ */
private Long getSubTaskCount(String parentTaskId) { private Long getSubTaskCount(String parentTaskId) {
String tableName = managementService.getTableName(TaskEntity.class); String tableName = managementService.getTableName(TaskEntity.class);
String sql = "select count(1) from " + tableName + " where PARENT_TASK_ID_=#{parentTaskId}"; String sql = "SELECT COUNT(1) from " + tableName + " WHERE PARENT_TASK_ID_=#{parentTaskId}";
return taskService.createNativeTaskQuery().sql(sql).parameter("parentTaskId", parentTaskId).count(); return taskService.createNativeTaskQuery().sql(sql).parameter("parentTaskId", parentTaskId).count();
} }
@ -454,10 +469,10 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Override @Override
public void createTaskExt(Task task) { public void createTaskExt(Task task) {
BpmTaskExtDO taskExtDO = BpmTaskExtDO taskExtDO = BpmTaskConvert.INSTANCE.convert2TaskExt(task)
BpmTaskConvert.INSTANCE.convert2TaskExt(task).setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()); .setResult(BpmProcessInstanceResultEnum.PROCESS.getResult());
//向后加签生成的任务状态不能为进行中需要等前面父任务完成 // 向后加签生成的任务状态不能为进行中需要等前面父任务完成
if(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType().equals(task.getScopeType())){ if (BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType().equals(task.getScopeType())) {
taskExtDO.setResult(BpmProcessInstanceResultEnum.WAIT_BEFORE_TASK.getResult()); taskExtDO.setResult(BpmProcessInstanceResultEnum.WAIT_BEFORE_TASK.getResult());
} }
taskExtMapper.insert(taskExtDO); taskExtMapper.insert(taskExtDO);
@ -526,7 +541,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
private Task validateTaskExist(String id){ private Task validateTaskExist(String id){
Task task = taskService.createTaskQuery().taskId(id).singleResult(); Task task = taskService.createTaskQuery().taskId(id).singleResult();
if(task == null){ if (task == null) {
throw exception(TASK_NOT_EXISTS); throw exception(TASK_NOT_EXISTS);
} }
return task; return task;
@ -691,37 +706,43 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void addSign(BpmTaskAddSignReqVO reqVO, Long userId) { public void addSign(BpmTaskAddSignReqVO reqVO, Long userId) {
// TODO @海// 后面要有个空格中英文之间也要有空格例如说// 1. 获取和校验任务
//1.获取和校验任务 //1.获取和校验任务
TaskEntityImpl taskEntity = validateAddSign(userId, reqVO); TaskEntityImpl taskEntity = validateAddSign(userId, reqVO);
// TODO @海每个变量以及相关逻辑一定要和自己的逻辑块呆在一起例如说这里的 currentUser 获取应该在 4. 那块
AdminUserRespDTO currentUser = adminUserApi.getUser(userId); AdminUserRespDTO currentUser = adminUserApi.getUser(userId);
List<AdminUserRespDTO> userList = adminUserApi.getUserList(reqVO.getUserIdList()); List<AdminUserRespDTO> userList = adminUserApi.getUserList(reqVO.getUserIdList());
if (CollUtil.isEmpty(userList)) { if (CollUtil.isEmpty(userList)) {
throw exception(TASK_ADD_SIGN_USER_NOT_EXIST); throw exception(TASK_ADD_SIGN_USER_NOT_EXIST);
} }
//2.处理当前任务 // TODO @海大的逻辑块之间最好有一个空格这样的目的是避免逻辑堆砌在一起方便流量
//2.1 开启计数功能 // 2.处理当前任务
// 2.1 开启计数功能 // TODO @海这个目的可以写下
taskEntity.setCountEnabled(true); taskEntity.setCountEnabled(true);
// TODO @海可以直接 if不搞一个变量哈
boolean addSignToBefore = reqVO.getType().equals(BpmTaskAddSignTypeEnum.BEFORE.getType()); boolean addSignToBefore = reqVO.getType().equals(BpmTaskAddSignTypeEnum.BEFORE.getType());
if (addSignToBefore) { if (addSignToBefore) {
//2.2 向前加签设置 owner 置空 assign ,等子任务都完成后再调用 resolveTask 重新将 owner 设置为 assign // 2.2 向前加签设置 owner置空 assign等子任务都完成后再调用 resolveTask 重新将 owner 设置为 assign
//原因是不能和向前加签的子任务一起审批需要等前面的子任务都完成才能审批 // 原因是不能和向前加签的子任务一起审批需要等前面的子任务都完成才能审批
taskEntity.setOwner(taskEntity.getAssignee()); taskEntity.setOwner(taskEntity.getAssignee());
taskEntity.setAssignee(null); taskEntity.setAssignee(null);
//2.3 更新扩展表状态 // 2.3 更新扩展表状态
taskExtMapper.updateByTaskId( taskExtMapper.updateByTaskId(
new BpmTaskExtDO().setTaskId(taskEntity.getId()) new BpmTaskExtDO().setTaskId(taskEntity.getId())
.setResult(BpmProcessInstanceResultEnum.ADD_SIGN_BEFORE.getResult()) .setResult(BpmProcessInstanceResultEnum.ADD_SIGN_BEFORE.getResult())
.setReason(reqVO.getReason())); .setReason(reqVO.getReason()));
} }
//2.4 记录加签方式完成任务时需要用到判断 // 2.4 记录加签方式完成任务时需要用到判断
taskEntity.setScopeType(reqVO.getType()); taskEntity.setScopeType(reqVO.getType());
//2.5 保存当前任务修改后的值 // 2.5 保存当前任务修改后的值
taskService.saveTask(taskEntity); taskService.saveTask(taskEntity);
//3. 处理加签任务 // 3. 创建加签任务
this.createSignSubTasks(convertList(reqVO.getUserIdList(), String::valueOf), taskEntity); createSignSubTasks(convertList(reqVO.getUserIdList(), String::valueOf), taskEntity);
//4. 记录加签 comment拼接结果为 [当前用户]向前加签/向后加签给了[多个用户],理由为reason
String comment = StrUtil.format("[{}]{}给了[{}],理由为:{}", currentUser.getNickname(), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType()), // 4. 记录加签 comment拼接结果为 [当前用户]向前加签/向后加签给了[多个用户]理由为reason
// TODO @海BpmCommentTypeEnum 可以加一个 comment 字段作为评论模版统一管理
String comment = StrUtil.format("[{}]{}给了[{}],理由为:{}", currentUser.getNickname(), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType()),
String.join(SymbolConstant.D, convertList(userList, AdminUserRespDTO::getNickname)), reqVO.getReason()); String.join(SymbolConstant.D, convertList(userList, AdminUserRespDTO::getNickname)), reqVO.getReason());
taskService.addComment(reqVO.getId(), taskEntity.getProcessInstanceId(), taskService.addComment(reqVO.getId(), taskEntity.getProcessInstanceId(),
BpmCommentTypeEnum.ADD_SIGN.getResult().toString(), comment); BpmCommentTypeEnum.ADD_SIGN.getResult().toString(), comment);
@ -729,7 +750,10 @@ public class BpmTaskServiceImpl implements BpmTaskService {
/** /**
* 校验任务存在和 存在 向前加签 的任务则不能 向后加签存在 向后加签 则不能 向前加签 * 校验任务的加签是否一致
*
* 1. 如果存在向前加签的任务则不能向后加签
* 2. 如果存在向后加签的任务则不能向前加签
* *
* @param userId 当前用户 ID * @param userId 当前用户 ID
* @param reqVO 请求参数包含任务 ID 和加签类型 * @param reqVO 请求参数包含任务 ID 和加签类型
@ -737,18 +761,22 @@ public class BpmTaskServiceImpl implements BpmTaskService {
*/ */
private TaskEntityImpl validateAddSign(Long userId, BpmTaskAddSignReqVO reqVO) { private TaskEntityImpl validateAddSign(Long userId, BpmTaskAddSignReqVO reqVO) {
TaskEntityImpl taskEntity = (TaskEntityImpl) validateTask(userId, reqVO.getId()); TaskEntityImpl taskEntity = (TaskEntityImpl) validateTask(userId, reqVO.getId());
//向前加签和向后加签不能同时存在 // 向前加签和向后加签不能同时存在
if (StrUtil.isNotBlank(taskEntity.getScopeType()) if (StrUtil.isNotBlank(taskEntity.getScopeType())
&& !BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getDesc().equals(taskEntity.getScopeType())) { && !BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getDesc().equals(taskEntity.getScopeType())) {
// TODO @海下面这个判断是不是可以写上面这个判断后面
// TODO @海一个小技巧如果写不等于的时候一般可以用 ObjectUtil.notEquals这样少一层取反理解起来简单点
if (!taskEntity.getScopeType().equals(reqVO.getType())) { if (!taskEntity.getScopeType().equals(reqVO.getType())) {
throw exception(TASK_ADD_SIGN_TYPE_ERROR, throw exception(TASK_ADD_SIGN_TYPE_ERROR,
BpmTaskAddSignTypeEnum.formatDesc(taskEntity.getScopeType()), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType())); BpmTaskAddSignTypeEnum.formatDesc(taskEntity.getScopeType()), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType()));
} }
} }
//同一个 key 的任务审批人不重复 // 同一个 key 的任务审批人不重复
List<Task> taskList = taskService.createTaskQuery().processInstanceId(taskEntity.getProcessInstanceId()) List<Task> taskList = taskService.createTaskQuery().processInstanceId(taskEntity.getProcessInstanceId())
.taskDefinitionKey(taskEntity.getTaskDefinitionKey()).list(); .taskDefinitionKey(taskEntity.getTaskDefinitionKey()).list();
// TODO @海这里是不是 Task::getAssignee 解析成 List<Long> 下面会更简洁一点
List<String> currentAssigneeList = convertList(taskList, Task::getAssignee); List<String> currentAssigneeList = convertList(taskList, Task::getAssignee);
// TODO @海frontAssigneeList 改成 addAssigneeList新增的避免和 front 前端这样界面耦合的名词哈
List<String> frontAssigneeList = convertList(reqVO.getUserIdList(), String::valueOf); List<String> frontAssigneeList = convertList(reqVO.getUserIdList(), String::valueOf);
currentAssigneeList.retainAll(frontAssigneeList); currentAssigneeList.retainAll(frontAssigneeList);
if (CollUtil.isNotEmpty(currentAssigneeList)) { if (CollUtil.isNotEmpty(currentAssigneeList)) {
@ -761,20 +789,22 @@ public class BpmTaskServiceImpl implements BpmTaskService {
/** /**
* 创建加签子任务 * 创建加签子任务
* *
* @param addSingUserIdList 被加签的用户ID * @param addSingUserIdList 被加签的用户 ID
* @param taskEntity 被加签的任务 * @param taskEntity 被加签的任务
*/ */
private void createSignSubTasks(List<String> addSingUserIdList, TaskEntityImpl taskEntity) { private void createSignSubTasks(List<String> addSingUserIdList, TaskEntityImpl taskEntity) {
// TODO @海可以 if return这样括号层级少一点下面的 if (StrUtil.isNotBlank(addSignId)) { 也是类似
if (CollUtil.isNotEmpty(addSingUserIdList)) { if (CollUtil.isNotEmpty(addSingUserIdList)) {
// 创建加签人的新任务,全部基于 taskEntity 为父任务来创建 // 创建加签人的新任务全部基于 taskEntity 为父任务来创建
addSingUserIdList.forEach(addSignId -> { addSingUserIdList.forEach(addSignId -> {
if (StrUtil.isNotBlank(addSignId)) { if (StrUtil.isNotBlank(addSignId)) {
this.createSubTask(taskEntity, addSignId); createSubTask(taskEntity, addSignId);
} }
}); });
} }
} }
// TODO @海这个是不是命名上要和 createSignSubTasks 保持一致
/** /**
* 创建子任务 * 创建子任务
* *
@ -783,18 +813,19 @@ public class BpmTaskServiceImpl implements BpmTaskService {
* @return * @return
*/ */
private void createSubTask(TaskEntityImpl parentTask, String assignee) { private void createSubTask(TaskEntityImpl parentTask, String assignee) {
//1.生成子任务 // 1. 生成子任务
TaskEntityImpl task = (TaskEntityImpl) taskService.newTask(IdUtil.fastSimpleUUID()); TaskEntityImpl task = (TaskEntityImpl) taskService.newTask(IdUtil.fastSimpleUUID());
task = BpmTaskConvert.INSTANCE.convert(task,parentTask); task = BpmTaskConvert.INSTANCE.convert(task,parentTask);
if (BpmTaskAddSignTypeEnum.BEFORE.getType().equals(parentTask.getScopeType())) { if (BpmTaskAddSignTypeEnum.BEFORE.getType().equals(parentTask.getScopeType())) {
// 2. 前加签才设置审批人否则设置 owner // 2.1 前加签才设置审批人否则设置 owner
task.setAssignee(assignee); task.setAssignee(assignee);
} else { } else {
//2.2 设置 owner 不设置 assignee 是因为不能同时审批需要等父任务完成 // 2.2.1 设置 owner 不设置 assignee 是因为不能同时审批需要等父任务完成
task.setOwner(assignee); task.setOwner(assignee);
//2.3 设置向后加签任务的 scopeType afterChildrenTask用于设置任务扩展表的状态 // 2.2.2 设置向后加签任务的 scopeType afterChildrenTask用于设置任务扩展表的状态
task.setScopeType(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType()); task.setScopeType(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType());
} }
// 2. 保存子任务
taskService.saveTask(task); taskService.saveTask(task);
} }