From 203acef84d19ffc01bc8d5dd8ef85f90ba400f5c Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期日, 09 三月 2025 11:49:58 +0800
Subject: [PATCH] 容缺查询
---
business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java | 62 +++++++++++++++---------------
1 files changed, 31 insertions(+), 31 deletions(-)
diff --git a/business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java b/business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java
index ed72ccf..b39a37e 100644
--- a/business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java
+++ b/business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java
@@ -7,6 +7,7 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ycl.common.base.Result;
import com.ycl.common.constant.ProcessConstants;
import com.ycl.common.core.domain.AjaxResult;
import com.ycl.common.core.domain.entity.SysDept;
@@ -23,14 +24,11 @@
import com.ycl.domain.dto.FlowTaskDto;
import com.ycl.domain.dto.FlowViewerDto;
import com.ycl.domain.entity.ProcessCoding;
-import com.ycl.domain.entity.ProcessLog;
import com.ycl.domain.entity.ProjectProcess;
import com.ycl.domain.entity.SysForm;
import com.ycl.domain.json.RejectData;
-import com.ycl.domain.vo.DoFormDetailVO;
-import com.ycl.domain.vo.FlowQueryVo;
-import com.ycl.domain.vo.FlowTaskVo;
-import com.ycl.domain.vo.FormDetailVO;
+import com.ycl.domain.query.ProcessLogQuery;
+import com.ycl.domain.vo.*;
import com.ycl.event.event.TaskLogEvent;
import com.ycl.factory.FlowServiceFactory;
import com.ycl.flow.CustomProcessDiagramGenerator;
@@ -77,7 +75,6 @@
import java.io.InputStream;
import java.lang.reflect.Field;
-import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
@@ -138,11 +135,12 @@
*
* @param taskId 浠诲姟id
* @param variables 琛ㄥ崟鏁版嵁
+ * @param addLog
* @return
*/
@Override
@Transactional(rollbackFor = Exception.class)
- public AjaxResult completeSubmitForm(String taskId, Map<String, Object> variables) {
+ public AjaxResult completeSubmitForm(String taskId, Map<String, Object> variables, Boolean addLog) {
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
if (Objects.isNull(task)) {
return AjaxResult.error("浠诲姟涓嶅瓨鍦�");
@@ -176,15 +174,17 @@
taskService.complete(taskId, newV);
}
// 淇濆瓨鏃ュ織
- publisher.publishEvent(new TaskLogEvent(this, null,
- SecurityUtils.getUserId(),
- projectProcess.getProjectId(),
- projectProcess.getProcessInsId(),
- taskId,
- task.getTaskDefinitionKey(),
- task.getName(),
- ProcessLogEventTypeEnum.FINISHED,
- null));
+ if (addLog) {
+ publisher.publishEvent(new TaskLogEvent(this, null,
+ SecurityUtils.getUserId(),
+ projectProcess.getProjectId(),
+ projectProcess.getProcessInsId(),
+ taskId,
+ task.getTaskDefinitionKey(),
+ task.getName(),
+ ProcessLogEventTypeEnum.FINISHED,
+ null));
+ }
return AjaxResult.success("鎻愪氦鎴愬姛");
}
@@ -1304,11 +1304,11 @@
}
}
// 鍒ゆ柇浠诲姟鏄惁瀛樺湪鐗规畩鎿嶄綔(濡傝烦杩囥�佽浆鍔炵瓑)锛岄渶瑕佸湪鍓嶇灞曠ず鍑烘潵
- List<ProcessLog> logList = new LambdaQueryChainWrapper<>(processLogService.getBaseMapper())
- .eq(ProcessLog::getTaskDefKey, node.getBeforeNodeDefId())
- .eq(ProcessLog::getProcessInsId, finalProcessInsId)
- .orderByDesc(ProcessLog::getGmtCreate)
- .list();
+ ProcessLogQuery query = new ProcessLogQuery();
+ query.setTaskDefKey(node.getUserTask().getId());
+ query.setProcessInsId(finalProcessInsId);
+ Result result = processLogService.projectProcessLogPage(query);
+ List<ProcessLogVO> logList = (List<ProcessLogVO>) result.get("data");
DoFormDetailVO vo = new DoFormDetailVO();
BeanUtils.copyProperties(node, vo);
if (CollectionUtils.isNotEmpty(logList)) {
@@ -1375,11 +1375,11 @@
}
}
// 鍒ゆ柇浠诲姟鏄惁瀛樺湪鐗规畩鎿嶄綔(濡傝烦杩囥�佽浆鍔炵瓑)锛岄渶瑕佸湪鍓嶇灞曠ず鍑烘潵
- List<ProcessLog> logList = new LambdaQueryChainWrapper<>(processLogService.getBaseMapper())
- .eq(ProcessLog::getTaskId, hisTask.getId())
- .eq(ProcessLog::getProcessInsId, hisTask.getProcessInstanceId())
- .orderByDesc(ProcessLog::getGmtCreate)
- .list();
+ ProcessLogQuery query = new ProcessLogQuery();
+ query.setTaskDefKey(node.getUserTask().getId());
+ query.setProcessInsId(hisTask.getProcessInstanceId());
+ Result result = processLogService.projectProcessLogPage(query);
+ List<ProcessLogVO> logList = (List<ProcessLogVO>) result.get("data");
DoFormDetailVO vo = new DoFormDetailVO();
BeanUtils.copyProperties(node, vo);
if (CollectionUtils.isNotEmpty(logList)) {
@@ -1427,11 +1427,11 @@
}
}
// 鍒ゆ柇浠诲姟鏄惁瀛樺湪鐗规畩鎿嶄綔(濡傝烦杩囥�佽浆鍔炵瓑)锛岄渶瑕佸湪鍓嶇灞曠ず鍑烘潵
- List<ProcessLog> logList = new LambdaQueryChainWrapper<>(processLogService.getBaseMapper())
- .eq(ProcessLog::getTaskId, task.getId())
- .eq(ProcessLog::getProcessInsId, task.getProcessInstanceId())
- .orderByDesc(ProcessLog::getGmtCreate)
- .list();
+ ProcessLogQuery query = new ProcessLogQuery();
+ query.setTaskDefKey(node.getUserTask().getId());
+ query.setProcessInsId(task.getProcessInstanceId());
+ Result result = processLogService.projectProcessLogPage(query);
+ List<ProcessLogVO> logList = (List<ProcessLogVO>) result.get("data");
DoFormDetailVO vo = new DoFormDetailVO();
BeanUtils.copyProperties(node, vo);
if (CollectionUtils.isNotEmpty(logList)) {
--
Gitblit v1.8.0