CAN_SUB_SIGN_STATUS_LIST = Arrays.asList(PROCESS.result, WAIT_BEFORE_TASK.result);
/**
* 结果
- *
+ *
* 如果新增时，注意 {@link #isEndResult(Integer)} 是否需要变更
*/
private final Integer result;
@@ -36,14 +62,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..3bf41a153
--- /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,41 @@
+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..a67af2eeb 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
@@ -4,16 +4,15 @@ import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.*;
import cn.iocoder.yudao.module.bpm.service.task.BpmTaskService;
-import io.swagger.v3.oas.annotations.tags.Tag;
-import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
-
import java.util.List;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
@@ -95,9 +94,31 @@ public class BpmTaskController {
@Operation(summary = "委派任务", description = "用于【流程详情】的【委派】按钮。和向前【加签】有点像，唯一区别是【委托】没有单独创立任务")
@PreAuthorize("@ss.hasPermission('bpm:task:update')")
public CommonResult delegateTask(@Valid @RequestBody BpmTaskDelegateReqVO reqVO) {
- // TODO @海：, 后面要有空格
- taskService.delegateTask(reqVO,getLoginUserId());
+ taskService.delegateTask(getLoginUserId(), reqVO);
return success(true);
}
+ @PutMapping("/add-sign")
+ @Operation(summary = "加签", description = "before 前加签，after 后加签")
+ @PreAuthorize("@ss.hasPermission('bpm:task:update')")
+ public CommonResult addSignTask(@Valid @RequestBody BpmTaskAddSignReqVO reqVO) {
+ taskService.addSignTask(getLoginUserId(), reqVO);
+ return success(true);
+ }
+
+ @PutMapping("/sub-sign")
+ @Operation(summary = "减签")
+ @PreAuthorize("@ss.hasPermission('bpm:task:update')")
+ public CommonResult subSignTask(@Valid @RequestBody BpmTaskSubSignReqVO reqVO) {
+ taskService.subSignTask(getLoginUserId(), reqVO);
+ return success(true);
+ }
+
+ @GetMapping("/get-children-task-list")
+ @Operation(summary = "获取能被减签的任务")
+ @PreAuthorize("@ss.hasPermission('bpm:task:update')")
+ public CommonResult> getChildrenTaskList(@RequestParam("taskId") String taskId) {
+ return success(taskService.getChildrenTaskList(taskId));
+ }
+
}
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..93b95d3fd
--- /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.Set;
+
+@Schema(description = "管理后台 - 加签流程任务的 Request VO")
+@Data
+public class BpmTaskAddSignReqVO {
+
+ @Schema(description = "需要加签的任务 ID")
+ @NotEmpty(message = "任务编号不能为空")
+ private String id;
+
+ @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;
+
+}
\ 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/vo/task/BpmTaskRespVO.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskRespVO.java
index 3c404678f..1af839e26 100644
--- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskRespVO.java
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskRespVO.java
@@ -5,6 +5,8 @@ import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;
+import java.util.List;
+
@Schema(description = "管理后台 - 流程任务的 Response VO")
@Data
@EqualsAndHashCode(callSuper = true)
@@ -19,6 +21,14 @@ public class BpmTaskRespVO extends BpmTaskDonePageItemRespVO {
*/
private User assigneeUser;
+ /**
+ * 父任务ID
+ */
+ private String parentTaskId;
+
+ @Schema(description = "子任务（由加签生成）", requiredMode = Schema.RequiredMode.REQUIRED, example = "childrenTask")
+ private List children;
+
@Schema(description = "用户信息")
@Data
public static class User {
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskSubSignReqVO.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskSubSignReqVO.java
new file mode 100644
index 000000000..665a9aec8
--- /dev/null
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskSubSignReqVO.java
@@ -0,0 +1,19 @@
+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;
+
+@Schema(description = "管理后台 - 减签流程任务的 Request VO")
+@Data
+public class BpmTaskSubSignReqVO {
+
+ @Schema(description = "被减签的任务 ID")
+ @NotEmpty(message = "任务编号不能为空")
+ private String id;
+
+ @Schema(description = "加签原因")
+ @NotEmpty(message = "加签原因不能为空")
+ private String reason;
+}
diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskSubSignRespVO.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskSubSignRespVO.java
new file mode 100644
index 000000000..efecbf582
--- /dev/null
+++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/controller/admin/task/vo/task/BpmTaskSubSignRespVO.java
@@ -0,0 +1,15 @@
+package cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Schema(description = "管理后台 - 减签流程任务的 Response VO")
+@Data
+public class BpmTaskSubSignRespVO {
+ @Schema(description = "审核的用户信息", requiredMode = Schema.RequiredMode.REQUIRED, example = "小李")
+ private BpmTaskRespVO.User assigneeUser;
+ @Schema(description = "任务 ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "12312")
+ private String id;
+ @Schema(description = "任务名称", requiredMode = Schema.RequiredMode.REQUIRED, example = "经理审批")
+ private String name;
+}
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..0d55a82eb 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
@@ -1,13 +1,12 @@
package cn.iocoder.yudao.module.bpm.convert.task;
+import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.LocalDateTimeUtil;
+import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
import cn.iocoder.yudao.framework.common.util.date.DateUtils;
import cn.iocoder.yudao.framework.common.util.number.NumberUtils;
-import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskDonePageItemRespVO;
-import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskRespVO;
-import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskSimpleRespVO;
-import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskTodoPageItemRespVO;
+import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.*;
import cn.iocoder.yudao.module.bpm.dal.dataobject.task.BpmTaskExtDO;
import cn.iocoder.yudao.module.bpm.service.message.dto.BpmMessageSendWhenTaskCreatedReqDTO;
import cn.iocoder.yudao.module.system.api.dept.dto.DeptRespDTO;
@@ -18,9 +17,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 +146,53 @@ public interface BpmTaskConvert {
.setName(element.getName())
.setDefinitionKey(element.getId()));
}
+
+ //此处不用 mapstruct 映射，因为 TaskEntityImpl 还有很多其他属性，这里我们只设置我们需要的
+ //使用 mapstruct 会将里面嵌套的各个属性值都设置进去，会出现意想不到的问题
+ 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;
+ }
+
+ default List convertList(List bpmTaskExtDOList,
+ Map userMap,
+ Map idTaskMap){
+ return CollectionUtils.convertList(bpmTaskExtDOList, task->{
+ BpmTaskSubSignRespVO bpmTaskSubSignRespVO = new BpmTaskSubSignRespVO();
+ bpmTaskSubSignRespVO.setName(task.getName());
+ bpmTaskSubSignRespVO.setId(task.getTaskId());
+ Task sourceTask = idTaskMap.get(task.getTaskId());
+ // 后加签任务不会直接设置 assignee ,所以不存在 assignee 的情况，则去取 owner
+ String assignee = StrUtil.isNotEmpty(sourceTask.getAssignee()) ? sourceTask.getAssignee() : sourceTask.getOwner();
+ AdminUserRespDTO assignUser = userMap.get(NumberUtils.parseLong(assignee));
+ if (assignUser != null) {
+ bpmTaskSubSignRespVO.setAssigneeUser(convert3(assignUser));
+ }
+ return bpmTaskSubSignRespVO;
+ });
+ }
+
+ /**
+ * 转换任务为父子级
+ * @param sourceList 原始数据
+ * @return 转换后的父子级数组
+ */
+ default List convertChildrenList(List sourceList){
+ List childrenTaskList = CollectionUtils.filterList(sourceList, r -> StrUtil.isNotEmpty(r.getParentTaskId()));
+ Map> parentChildrenTaskListMap = CollectionUtils.convertMultiMap(childrenTaskList, BpmTaskRespVO::getParentTaskId);
+ for (BpmTaskRespVO bpmTaskRespVO : sourceList) {
+ bpmTaskRespVO.setChildren(parentChildrenTaskListMap.get(bpmTaskRespVO.getId()));
+ }
+ return CollectionUtils.filterList(sourceList, r -> StrUtil.isEmpty(r.getParentTaskId()));
+ }
}
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..852ccb2e0 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
@@ -1,7 +1,9 @@
package cn.iocoder.yudao.module.bpm.dal.mysql.task;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.bpm.dal.dataobject.task.BpmTaskExtDO;
+import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceResultEnum;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import org.apache.ibatis.annotations.Mapper;
@@ -19,8 +21,19 @@ public interface BpmTaskExtMapper extends BaseMapperX {
return selectList(BpmTaskExtDO::getTaskId, taskIds);
}
+ default List selectProcessListByTaskIds(Collection taskIds) {
+ return selectList(new LambdaQueryWrapperX()
+ .in(BpmTaskExtDO::getTaskId, taskIds)
+ .in(BpmTaskExtDO::getResult, BpmProcessInstanceResultEnum.CAN_SUB_SIGN_STATUS_LIST));
+ }
+
+
default BpmTaskExtDO selectByTaskId(String taskId) {
return selectOne(BpmTaskExtDO::getTaskId, taskId);
}
+ default void updateBatchByTaskIdList(List taskIdList, BpmTaskExtDO updateObj) {
+ update(updateObj, 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..772425b66 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,15 @@ public interface BpmTaskService {
*/
List getTaskListByProcessInstanceId(String processInstanceId);
+
+ /**
+ * 通过任务 ID 集合，获取任务扩展表信息集合
+ *
+ * @param taskIdList 任务 ID 集合
+ * @return 任务列表
+ */
+ List getTaskListByTaskIdList(List taskIdList);
+
/**
* 通过任务
*
@@ -134,17 +144,41 @@ public interface BpmTaskService {
* 将任务回退到指定的 targetDefinitionKey 位置
*
* @param userId 用户编号
- * @param reqVO 回退的任务key和当前所在的任务ID
+ * @param reqVO 回退的任务key和当前所在的任务ID
*/
void returnTask(Long userId, BpmTaskReturnReqVO reqVO);
- // TODO @海：userId 放前面
+
/**
* 将指定任务委派给其他人处理，等接收人处理后再回到原审批人手中审批
*
- * @param reqVO 被委派人和被委派的任务编号理由参数
* @param userId 用户编号
+ * @param reqVO 被委派人和被委派的任务编号理由参数
*/
- void delegateTask(BpmTaskDelegateReqVO reqVO, Long userId);
+ void delegateTask(Long userId, BpmTaskDelegateReqVO reqVO);
+
+ /**
+ * 任务加签
+ *
+ * @param userId 被加签的用户和任务 ID，加签类型
+ * @param reqVO 当前用户 ID
+ */
+ void addSignTask(Long userId, BpmTaskAddSignReqVO reqVO);
+
+ /**
+ * 任务减签名
+ *
+ * @param userId 当前用户ID
+ * @param reqVO 被减签的任务 ID，理由
+ */
+ void subSignTask(Long userId, BpmTaskSubSignReqVO reqVO);
+
+ /**
+ * 获取指定任务的子任务和审批人信息
+ *
+ * @param taskId 指定任务ID
+ * @return 子任务列表
+ */
+ List getChildrenTaskList(String taskId);
}
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..6bf2fb5b8 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,6 +2,8 @@ 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.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.date.DateUtils;
@@ -13,8 +15,10 @@ 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.BpmCommentTypeEnum;
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.BpmTaskAddSignTypeEnum;
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,15 +30,19 @@ 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;
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.DelegationState;
import org.flowable.task.api.Task;
+import org.flowable.task.api.TaskInfo;
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;
@@ -45,6 +53,8 @@ import javax.annotation.Resource;
import javax.validation.Valid;
import java.time.LocalDateTime;
import java.util.*;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.*;
@@ -82,6 +92,9 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Resource
private BpmTaskExtMapper taskExtMapper;
+ @Resource
+ private ManagementService managementService;
+
@Override
public PageResult getTodoTaskPage(Long userId, BpmTaskTodoPageReqVO pageVO) {
// 查询待办任务
@@ -183,7 +196,13 @@ public class BpmTaskServiceImpl implements BpmTaskService {
Map deptMap = deptApi.getDeptMap(convertSet(userMap.values(), AdminUserRespDTO::getDeptId));
// 拼接数据
- return BpmTaskConvert.INSTANCE.convertList3(tasks, bpmTaskExtDOMap, processInstance, userMap, deptMap);
+ List result = BpmTaskConvert.INSTANCE.convertList3(tasks, bpmTaskExtDOMap, processInstance, userMap, deptMap);
+ return BpmTaskConvert.INSTANCE.convertChildrenList(result);
+ }
+
+ @Override
+ public List getTaskListByTaskIdList(List taskIdList) {
+ return taskExtMapper.selectListByTaskIds(taskIdList);
}
@Override
@@ -203,13 +222,182 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return;
}
- // 情况二：自己审批的任务，调用 complete 去完成任务
+ // 情况二：后加签的任务
+ if (BpmTaskAddSignTypeEnum.AFTER.getType().equals(task.getScopeType())) {
+ // 后加签处理
+ approveAfterSignTask(task, reqVO);
+ return;
+ }
+
+ // 情况三：自己审批的任务，调用 complete 去完成任务
// 完成任务，审批通过
taskService.complete(task.getId(), instance.getProcessVariables());
// 更新任务拓展表为通过
taskExtMapper.updateByTaskId(
new BpmTaskExtDO().setTaskId(task.getId()).setResult(BpmProcessInstanceResultEnum.APPROVE.getResult())
.setReason(reqVO.getReason()));
+ // 处理加签任务
+ handleParentTask(task);
+ }
+
+ /**
+ * 审批通过存在“后加签”的任务。
+ *
+ * 注意：该任务不能马上完成，需要一个中间状态（ADD_SIGN_AFTER），并激活剩余所有子任务（PROCESS）为可审批处理
+ *
+ * @param task 当前任务
+ * @param reqVO 前端请求参数
+ */
+ private void approveAfterSignTask(Task task, BpmTaskApproveReqVO reqVO) {
+ // 1. 有向后加签，则该任务状态临时设置为 ADD_SIGN_AFTER 状态
+ 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);
+ }
+ // 2.1 更新任务扩展表中子任务为进行中
+ taskExtMapper.updateBatchByTaskIdList(childrenTaskIdList,
+ new BpmTaskExtDO().setResult(BpmProcessInstanceResultEnum.PROCESS.getResult()));
+ }
+
+ /**
+ * 处理当前任务的父任务
+ *
+ * @param task 当前任务
+ */
+ private void handleParentTask(Task task) {
+ String parentTaskId = task.getParentTaskId();
+ if (StrUtil.isBlank(parentTaskId)) {
+ return;
+ }
+ if (StrUtil.isNotBlank(parentTaskId)) {
+ // 1. 判断当前任务的父任务是否还有子任务
+ Long childrenTaskCount = getChildrenTaskCount(parentTaskId);
+ if (childrenTaskCount > 0) {
+ return;
+ }
+ // 2. 获取父任务
+ Task parentTask = validateTaskExist(parentTaskId);
+
+ // 3. 情况一：处理向前加签
+ String scopeType = parentTask.getScopeType();
+ 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()));
+ } else if (BpmTaskAddSignTypeEnum.AFTER.getType().equals(scopeType)) {
+ // 3. 情况二：处理向后加签
+ handleAfterSign(parentTask);
+ }
+
+ // 4. 子任务已处理完成，清空 scopeType 字段，修改 parentTask 信息，方便后续可以继续向前后向后加签
+ // 再查询一次的原因是避免报错：Task was updated by another transaction concurrently
+ // 因为前面处理后可能会导致 parentTask rev 字段被修改，需要重新获取最新的
+ parentTask = getTask(parentTaskId);
+ if (parentTask == null) {
+ // 为空的情况是：已经通过 handleAfterSign 方法将任务完成了，所以 ru_task 表会查不到数据
+ return;
+ }
+ clearTaskScopeTypeAndSave(parentTask);
+ }
+ }
+
+ /**
+ * 处理后加签任务
+ *
+ * @param parentTask 当前审批任务的父任务
+ */
+ private void handleAfterSign(Task parentTask) {
+ String parentTaskId = parentTask.getId();
+ //1. 更新 parentTask 的任务拓展表为通过，并调用 complete 完成自己
+ BpmTaskExtDO currentTaskExt = taskExtMapper.selectByTaskId(parentTask.getId());
+ BpmTaskExtDO currentTaskUpdateEntity = new BpmTaskExtDO().setTaskId(parentTask.getId())
+ .setResult(BpmProcessInstanceResultEnum.APPROVE.getResult());
+ if (currentTaskExt.getEndTime() == null) {
+ // 1.1 有这个判断是因为,以前没设置过结束时间，才去设置
+ currentTaskUpdateEntity.setEndTime(LocalDateTime.now());
+ }
+ // 1.2 完成自己
+ taskExtMapper.updateByTaskId(currentTaskUpdateEntity);
+ taskService.complete(parentTaskId);
+
+ // 2. 如果有父级，递归查询上级任务是否都已经完成
+ if (StrUtil.isEmpty(parentTask.getParentTaskId())) {
+ return;
+ }
+ // TODO @海：这块待讨论，脑子略乱；感觉 handleAfterSign 的后半段，和 handleParentTask 有点重叠？？？
+ // 2.1 判断整条链路的任务是否完成
+ // 例如从 A 任务加签了一个 B 任务，B 任务又加签了一个 C 任务，C 任务加签了 D 任务
+ // 此时，D 任务完成，要一直往上找到祖先任务 A调用 complete 方法完成 A 任务
+ boolean allChildrenTaskFinish = true;
+ while (StrUtil.isNotBlank(parentTask.getParentTaskId())) {
+ parentTask = validateTaskExist(parentTask.getParentTaskId());
+ BpmTaskExtDO bpmTaskExtDO = taskExtMapper.selectByTaskId(parentTask.getId());
+ if (bpmTaskExtDO == null) {
+ break;
+ }
+ boolean currentTaskFinish = BpmProcessInstanceResultEnum.isEndResult(bpmTaskExtDO.getResult());
+ // 2.2 如果 allChildrenTaskFinish 已经被赋值为 false ,则不会再赋值为 true，因为整个链路没有完成
+ if (allChildrenTaskFinish) {
+ allChildrenTaskFinish = currentTaskFinish;
+ }
+ // 2.3 任务已完成则不处理
+ if (currentTaskFinish) {
+ continue;
+ }
+
+ // 3 处理非完成状态的任务
+ // 3.1 判断当前任务的父任务是否还有子任务
+ Long childrenTaskCount = getChildrenTaskCount(bpmTaskExtDO.getTaskId());
+ if (childrenTaskCount > 0) {
+ continue;
+ }
+ // 3.2 没有子任务，判断当前任务状态是否为 ADD_SIGN_BEFORE 待前加签任务完成
+ if (BpmProcessInstanceResultEnum.ADD_SIGN_BEFORE.getResult().equals(bpmTaskExtDO.getResult())) {
+ // 3.3 需要修改该任务状态为处理中
+ taskService.resolveTask(bpmTaskExtDO.getTaskId());
+ bpmTaskExtDO.setResult(BpmProcessInstanceResultEnum.PROCESS.getResult());
+ taskExtMapper.updateByTaskId(bpmTaskExtDO);
+ }
+ // 3.4 清空 scopeType 字段，用于任务没有子任务时使用该方法，方便任务可以再次被不同的方式加签
+ parentTask = validateTaskExist(bpmTaskExtDO.getTaskId());
+ clearTaskScopeTypeAndSave(parentTask);
+ }
+
+ // 4. 完成最后的顶级祖先任务
+ 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 getChildrenTaskCount(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 +414,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.getType().toString(), comment);
// 2.1 调用 resolveTask 完成任务。
// 底层调用 TaskHelper.changeTaskAssignee(task, task.getOwner())：将 owner 设置为 assignee
@@ -276,10 +464,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
* @param taskId task id
*/
private Task validateTask(Long userId, String taskId) {
- Task task = getTask(taskId);
- if (task == null) {
- throw exception(TASK_NOT_EXISTS);
- }
+ Task task = validateTaskExist(taskId);
if (!Objects.equals(userId, NumberUtils.parseLong(task.getAssignee()))) {
throw exception(TASK_OPERATE_FAIL_ASSIGN_NOT_SELF);
}
@@ -288,8 +473,12 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Override
public void createTaskExt(Task task) {
- BpmTaskExtDO taskExtDO =
- BpmTaskConvert.INSTANCE.convert2TaskExt(task).setResult(BpmProcessInstanceResultEnum.PROCESS.getResult());
+ 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,23 +532,29 @@ 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) {
+ private Task validateTaskExist(String id) {
+ Task task = getTask(id);
+ if (task == null) {
throw exception(TASK_NOT_EXISTS);
}
return task;
}
+ private Task getTask(String id) {
+ return taskService.createTaskQuery().taskId(id).singleResult();
+ }
+
private HistoricTaskInstance getHistoricTask(String id) {
return historyService.createHistoricTaskInstanceQuery().taskId(id).singleResult();
}
@@ -367,10 +562,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Override
public List getReturnTaskList(String taskId) {
// 1. 校验当前任务 task 存在
- Task task = getTask(taskId);
- if (task == null) {
- throw exception(TASK_NOT_EXISTS);
- }
+ Task task = validateTaskExist(taskId);
// 根据流程定义获取流程模型信息
BpmnModel bpmnModel = bpmModelService.getBpmnModelByDefinitionId(task.getProcessDefinitionId());
FlowElement source = BpmnModelUtils.getFlowElementById(bpmnModel, task.getTaskDefinitionKey());
@@ -437,7 +629,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
/**
* 执行回退逻辑
*
- * @param currentTask 当前回退的任务
+ * @param currentTask 当前回退的任务
* @param targetElement 需要回退到的目标任务
* @param reqVO 前端参数封装
*/
@@ -458,7 +650,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return;
}
taskService.addComment(task.getId(), currentTask.getProcessInstanceId(),
- BpmProcessInstanceResultEnum.BACK.getResult().toString(), reqVO.getReason());
+ BpmCommentTypeEnum.BACK.getType().toString(), reqVO.getReason());
});
// 3. 执行驳回
@@ -471,7 +663,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
@Override
@Transactional(rollbackFor = Exception.class)
- public void delegateTask(BpmTaskDelegateReqVO reqVO, Long userId) {
+ public void delegateTask(Long userId, BpmTaskDelegateReqVO reqVO) {
// 1.1 校验任务
Task task = validateTaskCanDelegate(userId, reqVO);
// 1.2 校验目标用户存在
@@ -485,9 +677,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.getType().toString(), comment);
// 3.1 设置任务所有人 (owner) 为原任务的处理人 (assignee)
taskService.setOwner(taskId, task.getAssignee());
@@ -503,7 +694,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
* 校验任务委派参数
*
* @param userId 用户编号
- * @param reqVO 任务编号，接收人ID
+ * @param reqVO 任务编号，接收人ID
* @return 当前任务信息
*/
private Task validateTaskCanDelegate(Long userId, BpmTaskDelegateReqVO reqVO) {
@@ -516,4 +707,228 @@ public class BpmTaskServiceImpl implements BpmTaskService {
return task;
}
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void addSignTask(Long userId, BpmTaskAddSignReqVO reqVO) {
+ // 1. 获取和校验任务
+ TaskEntityImpl taskEntity = validateAddSign(userId, reqVO);
+ List userList = adminUserApi.getUserList(reqVO.getUserIdList());
+ if (CollUtil.isEmpty(userList)) {
+ throw exception(TASK_ADD_SIGN_USER_NOT_EXIST);
+ }
+
+ // 2. 处理当前任务
+ // 2.1 开启计数功能，主要用于为了让表 ACT_RU_TASK 中的 SUB_TASK_COUNT_ 字段记录下总共有多少子任务，后续可能有用
+ taskEntity.setCountEnabled(true);
+ if (reqVO.getType().equals(BpmTaskAddSignTypeEnum.BEFORE.getType())) {
+ // 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. 创建加签任务
+ createAddSignChildrenTasks(convertList(reqVO.getUserIdList(), String::valueOf), taskEntity);
+
+ // 4. 记录加签 comment，拼接结果为： [当前用户]向前加签/向后加签给了[多个用户]，理由为：reason
+ AdminUserRespDTO currentUser = adminUserApi.getUser(userId);
+ String comment = StrUtil.format(BpmCommentTypeEnum.ADD_SIGN.getTemplateComment(), currentUser.getNickname(), BpmTaskAddSignTypeEnum.formatDesc(reqVO.getType()),
+ String.join(",", convertList(userList, AdminUserRespDTO::getNickname)), reqVO.getReason());
+ taskService.addComment(reqVO.getId(), taskEntity.getProcessInstanceId(),
+ BpmCommentTypeEnum.ADD_SIGN.getType().toString(), comment);
+ }
+
+
+ /**
+ * 校验任务的加签是否一致
+ *
+ * 1. 如果存在“向前加签”的任务，则不能“向后加签”
+ * 2. 如果存在“向后加签”的任务，则不能“向前加签”
+ *
+ * @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())
+ && ObjectUtil.notEqual(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType(), taskEntity.getScopeType())
+ && ObjectUtil.notEqual(taskEntity.getScopeType(), 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 -> NumberUtils.parseLong(task.getAssignee()));
+ // 保留交集在 currentAssigneeList 中
+ currentAssigneeList.retainAll(reqVO.getUserIdList());
+ if (CollUtil.isNotEmpty(currentAssigneeList)) {
+ List userList = adminUserApi.getUserList(currentAssigneeList);
+ throw exception(TASK_ADD_SIGN_USER_REPEAT, String.join(",", convertList(userList, AdminUserRespDTO::getNickname)));
+ }
+ return taskEntity;
+ }
+
+ /**
+ * 创建加签子任务
+ *
+ * @param addSingUserIdList 被加签的用户 ID
+ * @param taskEntity 被加签的任务
+ */
+ private void createAddSignChildrenTasks(List addSingUserIdList, TaskEntityImpl taskEntity) {
+ if (CollUtil.isEmpty(addSingUserIdList)) {
+ return;
+ }
+ // 创建加签人的新任务，全部基于 taskEntity 为父任务来创建
+ for (String addSignId : addSingUserIdList) {
+ if (StrUtil.isBlank(addSignId)) {
+ continue;
+ }
+ createChildrenTask(taskEntity, addSignId);
+ }
+ }
+
+ /**
+ * 创建子任务
+ *
+ * @param parentTask 父任务
+ * @param assignee 子任务的执行人
+ * @return
+ */
+ private void createChildrenTask(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.1 前加签，才设置审批人，否则设置 owner
+ task.setAssignee(assignee);
+ } else {
+ // 2.2.1 设置 owner 不设置 assignee 是因为不能同时审批，需要等父任务完成
+ task.setOwner(assignee);
+ // 2.2.2 设置向后加签任务的 scopeType 为 afterChildrenTask，用于设置任务扩展表的状态
+ task.setScopeType(BpmTaskAddSignTypeEnum.AFTER_CHILDREN_TASK.getType());
+ }
+ // 2. 保存子任务
+ taskService.saveTask(task);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void subSignTask(Long userId, BpmTaskSubSignReqVO reqVO) {
+ Task task = validateSubSign(reqVO.getId());
+ AdminUserRespDTO user = adminUserApi.getUser(userId);
+ AdminUserRespDTO cancelUser = null;
+ if (StrUtil.isNotBlank(task.getAssignee())) {
+ cancelUser = adminUserApi.getUser(NumberUtils.parseLong(task.getAssignee()));
+ }
+ if (cancelUser == null && StrUtil.isNotBlank(task.getOwner())) {
+ cancelUser = adminUserApi.getUser(NumberUtils.parseLong(task.getOwner()));
+ }
+ Assert.notNull(cancelUser, "任务中没有所有者和审批人，数据错误");
+ //1. 获取所有需要删除的任务 ID ，包含当前任务和所有子任务
+ List allTaskIdList = getAllChildTaskIds(task.getId());
+ //2. 删除任务和所有子任务
+ taskService.deleteTasks(allTaskIdList);
+ //3. 修改扩展表状态为取消
+ taskExtMapper.updateBatchByTaskIdList(allTaskIdList, new BpmTaskExtDO().setResult(BpmProcessInstanceResultEnum.CANCEL.getResult())
+ .setReason(StrUtil.format("由于{}操作[减签]，任务被取消", user.getNickname())));
+ //4.记录日志到父任务中 先记录日志是因为，通过 handleParentTask 方法之后，任务可能被完成了，并且不存在了，会报异常，所以先记录
+ String comment = StrUtil.format(BpmCommentTypeEnum.SUB_SIGN.getTemplateComment(), user.getNickname(), cancelUser.getNickname());
+ taskService.addComment(task.getParentTaskId(), task.getProcessInstanceId(),
+ BpmCommentTypeEnum.SUB_SIGN.getType().toString(), comment);
+ //5. 处理当前任务的父任务
+ this.handleParentTask(task);
+
+ }
+
+ /**
+ * 校验任务是否能被减签
+ *
+ * @param id 任务ID
+ * @return 任务信息
+ */
+ private Task validateSubSign(String id) {
+ Task task = validateTaskExist(id);
+ //必须有parentId
+ if (StrUtil.isEmpty(task.getParentTaskId())) {
+ throw exception(TASK_SUB_SIGN_NO_PARENT);
+ }
+ return task;
+ }
+
+ /**
+ * 获取所有要被取消的删除的任务 ID 集合
+ *
+ * @param parentTaskId 父级任务ID
+ * @return 所有任务ID
+ */
+ public List getAllChildTaskIds(String parentTaskId) {
+ List allChildTaskIds = new ArrayList<>();
+ //1. 先将自己放入
+ allChildTaskIds.add(parentTaskId);
+ //2. 递归获取子级
+ recursiveGetChildTaskIds(parentTaskId, allChildTaskIds);
+ return allChildTaskIds;
+ }
+
+ /**
+ * 递归处理子级任务
+ *
+ * @param taskId 当前任务ID
+ * @param taskIds 结果
+ */
+ private void recursiveGetChildTaskIds(String taskId, List taskIds) {
+ List childrenTaskIdList = getChildrenTaskIdList(taskId);
+ for (String childTaskId : childrenTaskIdList) {
+ taskIds.add(childTaskId); // 将子任务的ID添加到集合中
+ recursiveGetChildTaskIds(childTaskId, taskIds); // 递归获取子任务的子任务
+ }
+ }
+
+ /**
+ * 获取指定父级任务的所有子任务 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);
+ }
+
+ @Override
+ public List getChildrenTaskList(String taskId) {
+ List childrenTaskIdList = getChildrenTaskIdList(taskId);
+ if (CollUtil.isEmpty(childrenTaskIdList)) {
+ return Collections.emptyList();
+ }
+ //1. 只查询进行中的任务
+ List bpmTaskExtDOList = taskExtMapper.selectProcessListByTaskIds(childrenTaskIdList);
+ //2. 后加签的任务，可能不存在 assignee,所以还需要查询 owner
+ List taskList = taskService.createTaskQuery().taskIds(childrenTaskIdList).list();
+ Map idTaskMap = convertMap(taskList, TaskInfo::getId);
+ //3. 将 owner 和 assignee 统一到一个集合中
+ List userIds = taskList.stream()
+ .flatMap(control ->
+ Stream.of(control.getAssignee(), control.getOwner())
+ .filter(Objects::nonNull))
+ .distinct()
+ .map(NumberUtils::parseLong)
+ .collect(Collectors.toList());
+ Map userMap = adminUserApi.getUserMap(userIds);
+ return BpmTaskConvert.INSTANCE.convertList(bpmTaskExtDOList, userMap, idTaskMap);
+ }
}
diff --git a/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/controller/admin/trade/TradeStatisticsController.java b/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/controller/admin/trade/TradeStatisticsController.java
index 77c740760..b46a9c2a3 100644
--- a/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/controller/admin/trade/TradeStatisticsController.java
+++ b/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/controller/admin/trade/TradeStatisticsController.java
@@ -108,6 +108,7 @@ public class TradeStatisticsController {
// 订单统计
Long undeliveredCount = tradeOrderStatisticsService.getCountByStatusAndDeliveryType(
TradeOrderStatusEnum.UNDELIVERED.getStatus(), DeliveryTypeEnum.EXPRESS.getType());
+ // TODO @疯狂：订单支付后，如果是门店自提的，需要 update 成 DELIVERED；；目前还没搞~~突然反应过来
Long pickUpCount = tradeOrderStatisticsService.getCountByStatusAndDeliveryType(
TradeOrderStatusEnum.DELIVERED.getStatus(), DeliveryTypeEnum.PICK_UP.getType());
// 售后统计
diff --git a/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/job/trade/TradeStatisticsJob.java b/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/job/trade/TradeStatisticsJob.java
index 96338b987..228f4d548 100644
--- a/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/job/trade/TradeStatisticsJob.java
+++ b/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/job/trade/TradeStatisticsJob.java
@@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.statistics.job.trade;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.NumberUtil;
+import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
import cn.iocoder.yudao.framework.tenant.core.job.TenantJob;
@@ -10,6 +11,7 @@ import org.springframework.stereotype.Component;
import javax.annotation.Resource;
+// TODO 芋艿：缺个 Job 的配置；等和 Product 一起配置
/**
* 交易统计 Job
*
@@ -30,10 +32,10 @@ public class TradeStatisticsJob implements JobHandler {
@Override
@TenantJob
public String execute(String param) {
- // 默认 昨日
- if (StrUtil.isBlank(param)) {
- param = "1";
- } else if (!NumberUtil.isInteger(param)) {
+ // 默认昨日
+ param = ObjUtil.defaultIfBlank(param, "1");
+ // 校验参数的合理性
+ if (!NumberUtil.isInteger(param)) {
throw new RuntimeException("交易统计任务的参数只能为是正整数");
}
Integer days = Convert.toInt(param, 0);
diff --git a/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/service/trade/TradeStatisticsServiceImpl.java b/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/service/trade/TradeStatisticsServiceImpl.java
index 930389152..22436c78b 100644
--- a/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/service/trade/TradeStatisticsServiceImpl.java
+++ b/yudao-module-mall/yudao-module-statistics-biz/src/main/java/cn/iocoder/yudao/module/statistics/service/trade/TradeStatisticsServiceImpl.java
@@ -129,7 +129,6 @@ public class TradeStatisticsServiceImpl implements TradeStatisticsService {
entity = TradeStatisticsConvert.INSTANCE.convert(date, orderSummary, afterSaleSummary, brokerageSettlementPrice,
walletSummary);
tradeStatisticsMapper.insert(entity);
- // TODO @疯狂：这里是不是也要把日期带上？类似 108 那边; 110 已经带上了
return stopWatch.prettyPrint();
}
diff --git a/yudao-module-mall/yudao-module-trade-api/src/main/java/cn/iocoder/yudao/module/trade/enums/order/TradeOrderOperateTypeEnum.java b/yudao-module-mall/yudao-module-trade-api/src/main/java/cn/iocoder/yudao/module/trade/enums/order/TradeOrderOperateTypeEnum.java
index 9bae36588..8973ff973 100644
--- a/yudao-module-mall/yudao-module-trade-api/src/main/java/cn/iocoder/yudao/module/trade/enums/order/TradeOrderOperateTypeEnum.java
+++ b/yudao-module-mall/yudao-module-trade-api/src/main/java/cn/iocoder/yudao/module/trade/enums/order/TradeOrderOperateTypeEnum.java
@@ -21,7 +21,6 @@ public enum TradeOrderOperateTypeEnum {
MEMBER_RECEIVE(30, "用户已收货"),
SYSTEM_RECEIVE(31, "到期未收货，系统自动确认收货"),
ADMIN_PICK_UP_RECEIVE(32, "管理员自提收货"),
- MEMBER_PICK_UP_RECEIVE(32, "用户自提收货"),
MEMBER_COMMENT(33, "用户评价"),
SYSTEM_COMMENT(34, "到期未评价，系统自动评价"),
MEMBER_CANCEL(40, "取消订单"),
diff --git a/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/admin/order/TradeOrderController.java b/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/admin/order/TradeOrderController.java
index e2650be43..5d4e07e78 100644
--- a/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/admin/order/TradeOrderController.java
+++ b/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/controller/admin/order/TradeOrderController.java
@@ -143,7 +143,7 @@ public class TradeOrderController {
@Parameter(name = "id", description = "交易订单编号")
@PreAuthorize("@ss.hasPermission('trade:order:pick-up')")
public CommonResult pickUpOrderById(@RequestParam("id") Long id) {
- tradeOrderUpdateService.pickUpOrderByMember(id);
+ tradeOrderUpdateService.pickUpOrderByAdmin(id);
return success(true);
}
diff --git a/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateService.java b/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateService.java
index 5876f1104..31a810e77 100644
--- a/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateService.java
+++ b/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateService.java
@@ -122,7 +122,7 @@ public interface TradeOrderUpdateService {
*
* @param id 订单编号
*/
- void pickUpOrderByMember(Long id);
+ void pickUpOrderByAdmin(Long id);
/**
* 【管理员】核销订单
diff --git a/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateServiceImpl.java b/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateServiceImpl.java
index 6083d9cc7..6a7f9631c 100644
--- a/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateServiceImpl.java
+++ b/yudao-module-mall/yudao-module-trade-biz/src/main/java/cn/iocoder/yudao/module/trade/service/order/TradeOrderUpdateServiceImpl.java
@@ -669,8 +669,8 @@ public class TradeOrderUpdateServiceImpl implements TradeOrderUpdateService {
}
@Override
- @TradeOrderLog(operateType = TradeOrderOperateTypeEnum.MEMBER_PICK_UP_RECEIVE)
- public void pickUpOrderByMember(Long id) {
+ @TradeOrderLog(operateType = TradeOrderOperateTypeEnum.ADMIN_PICK_UP_RECEIVE)
+ public void pickUpOrderByAdmin(Long id) {
getSelf().pickUpOrder(tradeOrderMapper.selectById(id));
}