From 22d87c7c9d6e35e2f7bc12da0a1eabfcb568108d Mon Sep 17 00:00:00 2001 From: 疯狂的狮子Li <15040126243@163.com> Date: 星期四, 07 三月 2024 14:09:30 +0800 Subject: [PATCH] update 优化 工作流代码与接口命名 --- ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/ActProcessInstanceServiceImpl.java | 89 ++++++++++++++++++++++---------------------- 1 files changed, 45 insertions(+), 44 deletions(-) diff --git a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/ActProcessInstanceServiceImpl.java b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/ActProcessInstanceServiceImpl.java index 0b18e9f..daf40ec 100644 --- a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/ActProcessInstanceServiceImpl.java +++ b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/ActProcessInstanceServiceImpl.java @@ -11,6 +11,7 @@ import org.dromara.common.core.exception.ServiceException; import org.dromara.common.core.utils.StreamUtils; import org.dromara.common.core.utils.StringUtils; +import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.satoken.utils.LoginHelper; import org.dromara.workflow.common.constant.FlowConstant; @@ -90,29 +91,29 @@ /** * 鍒嗛〉鏌ヨ姝e湪杩愯鐨勬祦绋嬪疄渚� * - * @param processInstanceBo 鍙傛暟 + * @param bo 鍙傛暟 */ @Override - public TableDataInfo<ProcessInstanceVo> getProcessInstanceRunningByPage(ProcessInstanceBo processInstanceBo) { + public TableDataInfo<ProcessInstanceVo> getPageByRunning(ProcessInstanceBo bo, PageQuery pageQuery) { List<ProcessInstanceVo> list = new ArrayList<>(); ProcessInstanceQuery query = QueryUtils.instanceQuery(); - if (StringUtils.isNotBlank(processInstanceBo.getName())) { - query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%"); + if (StringUtils.isNotBlank(bo.getName())) { + query.processInstanceNameLikeIgnoreCase("%" + bo.getName() + "%"); } - if (StringUtils.isNotBlank(processInstanceBo.getKey())) { - query.processDefinitionKey(processInstanceBo.getKey()); + if (StringUtils.isNotBlank(bo.getKey())) { + query.processDefinitionKey(bo.getKey()); } - if (StringUtils.isNotBlank(processInstanceBo.getStartUserId())) { - query.startedBy(processInstanceBo.getStartUserId()); + if (StringUtils.isNotBlank(bo.getStartUserId())) { + query.startedBy(bo.getStartUserId()); } - if (StringUtils.isNotBlank(processInstanceBo.getBusinessKey())) { - query.processInstanceBusinessKey(processInstanceBo.getBusinessKey()); + if (StringUtils.isNotBlank(bo.getBusinessKey())) { + query.processInstanceBusinessKey(bo.getBusinessKey()); } - if (StringUtils.isNotBlank(processInstanceBo.getCategoryCode())) { - query.processDefinitionCategory(processInstanceBo.getCategoryCode()); + if (StringUtils.isNotBlank(bo.getCategoryCode())) { + query.processDefinitionCategory(bo.getCategoryCode()); } query.orderByStartTime().desc(); - List<ProcessInstance> processInstances = query.listPage(processInstanceBo.getPageNum(), processInstanceBo.getPageSize()); + List<ProcessInstance> processInstances = query.listPage(pageQuery.getFirstNum(), pageQuery.getPageSize()); for (ProcessInstance processInstance : processInstances) { ProcessInstanceVo processInstanceVo = BeanUtil.toBean(processInstance, ProcessInstanceVo.class); processInstanceVo.setIsSuspended(processInstance.isSuspended()); @@ -126,29 +127,29 @@ /** * 鍒嗛〉鏌ヨ宸茬粨鏉熺殑娴佺▼瀹炰緥 * - * @param processInstanceBo 鍙傛暟 + * @param bo 鍙傛暟 */ @Override - public TableDataInfo<ProcessInstanceVo> getProcessInstanceFinishByPage(ProcessInstanceBo processInstanceBo) { + public TableDataInfo<ProcessInstanceVo> getPageByFinish(ProcessInstanceBo bo, PageQuery pageQuery) { List<ProcessInstanceVo> list = new ArrayList<>(); HistoricProcessInstanceQuery query = QueryUtils.hisInstanceQuery() .finished().orderByProcessInstanceEndTime().desc(); - if (StringUtils.isNotEmpty(processInstanceBo.getName())) { - query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%"); + if (StringUtils.isNotEmpty(bo.getName())) { + query.processInstanceNameLikeIgnoreCase("%" + bo.getName() + "%"); } - if (StringUtils.isNotBlank(processInstanceBo.getKey())) { - query.processDefinitionKey(processInstanceBo.getKey()); + if (StringUtils.isNotBlank(bo.getKey())) { + query.processDefinitionKey(bo.getKey()); } - if (StringUtils.isNotEmpty(processInstanceBo.getStartUserId())) { - query.startedBy(processInstanceBo.getStartUserId()); + if (StringUtils.isNotEmpty(bo.getStartUserId())) { + query.startedBy(bo.getStartUserId()); } - if (StringUtils.isNotBlank(processInstanceBo.getBusinessKey())) { - query.processInstanceBusinessKey(processInstanceBo.getBusinessKey()); + if (StringUtils.isNotBlank(bo.getBusinessKey())) { + query.processInstanceBusinessKey(bo.getBusinessKey()); } - if (StringUtils.isNotBlank(processInstanceBo.getCategoryCode())) { - query.processDefinitionCategory(processInstanceBo.getCategoryCode()); + if (StringUtils.isNotBlank(bo.getCategoryCode())) { + query.processDefinitionCategory(bo.getCategoryCode()); } - List<HistoricProcessInstance> historicProcessInstances = query.listPage(processInstanceBo.getPageNum(), processInstanceBo.getPageSize()); + List<HistoricProcessInstance> historicProcessInstances = query.listPage(pageQuery.getFirstNum(), pageQuery.getPageSize()); for (HistoricProcessInstance historicProcessInstance : historicProcessInstances) { ProcessInstanceVo processInstanceVo = BeanUtil.toBean(historicProcessInstance, ProcessInstanceVo.class); processInstanceVo.setBusinessStatusName(BusinessStatusEnum.findByStatus(historicProcessInstance.getBusinessStatus())); @@ -165,7 +166,7 @@ */ @SneakyThrows @Override - public String getHistoryProcessImage(String processInstanceId) { + public String getHistoryImage(String processInstanceId) { String processDefinitionId; // 鑾峰彇褰撳墠鐨勬祦绋嬪疄渚� ProcessInstance processInstance = QueryUtils.instanceQuery(processInstanceId).singleResult(); @@ -220,7 +221,7 @@ * @param processInstanceId 娴佺▼瀹炰緥id */ @Override - public Map<String, Object> getHistoryProcessList(String processInstanceId) { + public Map<String, Object> getHistoryList(String processInstanceId) { Map<String, Object> map = new HashMap<>(); List<Map<String, Object>> taskList = new ArrayList<>(); HistoricProcessInstance historicProcessInstance = QueryUtils.hisInstanceQuery(processInstanceId).singleResult(); @@ -449,7 +450,7 @@ */ @Override @Transactional(rollbackFor = Exception.class) - public boolean deleteRuntimeProcessInst(ProcessInvalidBo processInvalidBo) { + public boolean deleteRunInstance(ProcessInvalidBo processInvalidBo) { try { List<Task> list = QueryUtils.taskQuery(processInvalidBo.getProcessInstanceId()).list(); List<Task> subTasks = StreamUtils.filter(list, e -> StringUtils.isNotBlank(e.getParentTaskId())); @@ -487,7 +488,7 @@ */ @Override @Transactional(rollbackFor = Exception.class) - public boolean deleteRuntimeProcessAndHisInst(List<String> processInstanceIds) { + public boolean deleteRunAndHisInstance(List<String> processInstanceIds) { try { // 1.鍒犻櫎杩愯涓祦绋嬪疄渚� List<Task> list = QueryUtils.taskQuery(processInstanceIds).list(); @@ -515,7 +516,7 @@ */ @Override @Transactional(rollbackFor = Exception.class) - public boolean deleteRuntimeProcessAndHisInstByBusinessKeys(List<String> businessKeys) { + public boolean deleteRunAndHisInstanceByBusinessKeys(List<String> businessKeys) { try { // 1.鍒犻櫎杩愯涓祦绋嬪疄渚� List<ActHiProcinst> actHiProcinsts = actHiProcinstService.selectByBusinessKeyIn(businessKeys); @@ -549,7 +550,7 @@ */ @Override @Transactional(rollbackFor = Exception.class) - public boolean deleteFinishProcessAndHisInst(List<String> processInstanceIds) { + public boolean deleteFinishAndHisInstance(List<String> processInstanceIds) { try { historyService.bulkDeleteHistoricProcessInstances(processInstanceIds); return true; @@ -614,27 +615,27 @@ /** * 鍒嗛〉鏌ヨ褰撳墠鐧诲綍浜哄崟鎹� * - * @param processInstanceBo 鍙傛暟 + * @param bo 鍙傛暟 */ @Override - public TableDataInfo<ProcessInstanceVo> getCurrentSubmitByPage(ProcessInstanceBo processInstanceBo) { + public TableDataInfo<ProcessInstanceVo> getPageByCurrent(ProcessInstanceBo bo, PageQuery pageQuery) { List<ProcessInstanceVo> list = new ArrayList<>(); HistoricProcessInstanceQuery query = QueryUtils.hisInstanceQuery(); - query.startedBy(processInstanceBo.getStartUserId()); - if (StringUtils.isNotBlank(processInstanceBo.getName())) { - query.processInstanceNameLikeIgnoreCase("%" + processInstanceBo.getName() + "%"); + query.startedBy(bo.getStartUserId()); + if (StringUtils.isNotBlank(bo.getName())) { + query.processInstanceNameLikeIgnoreCase("%" + bo.getName() + "%"); } - if (StringUtils.isNotBlank(processInstanceBo.getKey())) { - query.processDefinitionKey(processInstanceBo.getKey()); + if (StringUtils.isNotBlank(bo.getKey())) { + query.processDefinitionKey(bo.getKey()); } - if (StringUtils.isNotBlank(processInstanceBo.getBusinessKey())) { - query.processInstanceBusinessKey(processInstanceBo.getBusinessKey()); + if (StringUtils.isNotBlank(bo.getBusinessKey())) { + query.processInstanceBusinessKey(bo.getBusinessKey()); } - if (StringUtils.isNotBlank(processInstanceBo.getCategoryCode())) { - query.processDefinitionCategory(processInstanceBo.getCategoryCode()); + if (StringUtils.isNotBlank(bo.getCategoryCode())) { + query.processDefinitionCategory(bo.getCategoryCode()); } query.orderByProcessInstanceStartTime().desc(); - List<HistoricProcessInstance> historicProcessInstanceList = query.listPage(processInstanceBo.getPageNum(), processInstanceBo.getPageSize()); + List<HistoricProcessInstance> historicProcessInstanceList = query.listPage(pageQuery.getFirstNum(), pageQuery.getPageSize()); List<TaskVo> taskVoList = new ArrayList<>(); if (CollUtil.isNotEmpty(historicProcessInstanceList)) { List<String> processInstanceIds = StreamUtils.toList(historicProcessInstanceList, HistoricProcessInstance::getId); -- Gitblit v1.9.3