diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmProcessInstanceExtMapper.java b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmProcessInstanceExtMapper.java index 8128614e..b41f90e9 100644 --- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmProcessInstanceExtMapper.java +++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/java/cn/iocoder/yudao/module/bpm/dal/mysql/task/BpmProcessInstanceExtMapper.java @@ -18,6 +18,8 @@ public interface BpmProcessInstanceExtMapper extends BaseMapperX selectCCPage(Long userId, BpmProcessInstanceMyPageReqVO reqVO) { return selectPage(reqVO, new LambdaQueryWrapperX() // .eqIfPresent(BpmProcessInstanceExtDO::getStartUserId, userId) + //只能查询流程标识定义为oa开头的流程 + .likeIfPresent(BpmProcessInstanceExtDO::getProcessDefinitionId, "oa_") .likeIfPresent(BpmProcessInstanceExtDO::getCcids, "[" + userId + "]") .eqIfPresent(BpmProcessInstanceExtDO::getProcessDefinitionId, reqVO.getProcessDefinitionId()) .eqIfPresent(BpmProcessInstanceExtDO::getCategory, reqVO.getCategory()) @@ -30,6 +32,8 @@ public interface BpmProcessInstanceExtMapper extends BaseMapperX selectPage(Long userId, BpmProcessInstanceMyPageReqVO reqVO) { return selectPage(reqVO, new LambdaQueryWrapperX() + //只能查询流程标识定义为oa开头的流程 + .likeIfPresent(BpmProcessInstanceExtDO::getProcessDefinitionId, "oa_") .eqIfPresent(BpmProcessInstanceExtDO::getStartUserId, userId) .likeIfPresent(BpmProcessInstanceExtDO::getName, reqVO.getName()) .eqIfPresent(BpmProcessInstanceExtDO::getProcessDefinitionId, reqVO.getProcessDefinitionId()) @@ -57,6 +61,8 @@ public interface BpmProcessInstanceExtMapper extends BaseMapperX selectStatisticePage(BpmProcessInstanceMyPageReqVO reqVO) { //如果为空,那么查询全部 return selectPage(reqVO, new LambdaQueryWrapperX() + //只能查询流程标识定义为oa开头的流程 + .likeIfPresent(BpmProcessInstanceExtDO::getProcessDefinitionId, "oa_leave") .likeIfPresent(BpmProcessInstanceExtDO::getName, reqVO.getName()) .eqIfPresent(BpmProcessInstanceExtDO::getProcessDefinitionId, reqVO.getProcessDefinitionId()) .eqIfPresent(BpmProcessInstanceExtDO::getCategory, reqVO.getCategory()) 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 3e125832..8a17dabb 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 @@ -138,10 +138,13 @@ public class BpmTaskServiceImpl implements BpmTaskService { public PageResult getTodoTaskPage(Long userId, BpmTaskTodoPageReqVO pageVO) { // 查询待办任务 TaskQuery taskQuery = taskService.createTaskQuery().taskAssignee(String.valueOf(userId)) // 分配给自己 + //只能查询流程标识定义为oa开头的流程 + .processDefinitionKeyLike("oa_%") .orderByTaskCreateTime().desc(); // 创建时间倒序 if (StrUtil.isNotBlank(pageVO.getName())) { //流程定义的名称 taskQuery.processDefinitionName(pageVO.getName()); + // taskQuery.taskNameLike("%" + pageVO.getName() + "%"); } if (ArrayUtil.get(pageVO.getCreateTime(), 0) != null) { @@ -178,6 +181,8 @@ public class BpmTaskServiceImpl implements BpmTaskService { queryWrapperX.eq(BpmTaskExtDO::getDeleted, false); queryWrapperX.groupBy(BpmTaskExtDO::getName); queryWrapperX.select(BpmTaskExtDO::getName); + //只能查询流程标识定义为oa开头的流程 + queryWrapperX.likeIfPresent(BpmTaskExtDO::getProcessDefinitionId,"oa_"); List list = taskExtMapper.selectList(queryWrapperX); List taskNames = list.stream().map(BpmTaskExtDO::getName) .collect(Collectors.toList()); @@ -185,6 +190,7 @@ public class BpmTaskServiceImpl implements BpmTaskService { // 查询已办任务 HistoricTaskInstanceQuery taskQuery = historyService.createHistoricTaskInstanceQuery().finished() // 已完成 .taskAssignee(String.valueOf(userId)) // 分配给自己 + .processDefinitionKeyLike("oa_%") .orderByHistoricTaskInstanceEndTime().desc(); // 审批时间倒序 if (taskNames != null && !taskNames.isEmpty()) { /** diff --git a/yudao-module-bpm/yudao-module-bpm-biz/src/main/resources/mapper/task/BpmProcessInstanceExtMapper.xml b/yudao-module-bpm/yudao-module-bpm-biz/src/main/resources/mapper/task/BpmProcessInstanceExtMapper.xml index 35470cec..47175070 100644 --- a/yudao-module-bpm/yudao-module-bpm-biz/src/main/resources/mapper/task/BpmProcessInstanceExtMapper.xml +++ b/yudao-module-bpm/yudao-module-bpm-biz/src/main/resources/mapper/task/BpmProcessInstanceExtMapper.xml @@ -19,6 +19,7 @@ #{id} + AND process_definition_id like 'oa_%' GROUP BY name @@ -42,6 +43,7 @@ #{id} + AND process_definition_id like 'oa_%' GROUP BY result @@ -55,6 +57,7 @@ WHERE end_time IS NOT NULL AND reason != '自动审批' AND deleted = FALSE + AND process_definition_id like 'oa_%' GROUP BY assignee_user_id order by userTime desc limit 0, 10 @@ -72,6 +75,7 @@ #{id} + AND process_definition_id like 'oa_%' GROUP BY assignee_user_id