From 17e9ad4bbbbd0129e8da4dc0cfeee0028d7121e0 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期一, 24 二月 2025 17:40:23 +0800
Subject: [PATCH] 资金类型和重点分类多选

---
 business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java |   38 +++++++++++++++++++++++++++++++++-----
 1 files changed, 33 insertions(+), 5 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 c8fd1ba..d638720 100644
--- a/business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java
+++ b/business/src/main/java/com/ycl/service/impl/FlowTaskServiceImpl.java
@@ -150,6 +150,7 @@
         if (Objects.isNull(projectProcess)) {
             return AjaxResult.error("椤圭洰娴佺▼鏈粦瀹�");
         }
+
         Map<String, Object> processVariables = new HashMap<>();
         //鏌ュ嚭瀛楀吀涓渶瑕佹敞鍏ョ殑瀛楁淇℃伅
         List<String> dictList = sysDictDService.selectDictDataByType("flow_variables").stream().map(SysDictData::getDictValue).collect(Collectors.toList());
@@ -1248,17 +1249,30 @@
         Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
         // 娴佺▼鍙橀噺
         Map<String, Object> parameters = new HashMap<>();
+        List<FormDetailVO> beforeNodes = new ArrayList<>();
+        String processInsId = "";
         HistoricTaskInstance historicTaskInstance = historyService.createHistoricTaskInstanceQuery().includeProcessVariables().finished().taskId(taskId).singleResult();
         if (Objects.nonNull(historicTaskInstance)) {
             parameters = historicTaskInstance.getProcessVariables();
+            processInsId = historicTaskInstance.getProcessInstanceId();
+            beforeNodes = this.getBeforeNodeForm(parameters, historicTaskInstance.getFormKey(), historicTaskInstance.getName(), historicTaskInstance.getProcessDefinitionId(), historicTaskInstance.getTaskDefinitionKey(), Boolean.FALSE);
         } else {
             parameters = taskService.getVariables(taskId);
+            processInsId = task.getProcessInstanceId();
+            beforeNodes = this.getBeforeNodeForm(parameters, task.getFormKey(), task.getName(), task.getProcessDefinitionId(), task.getTaskDefinitionKey(), Boolean.FALSE);
         }
-        List<FormDetailVO> beforeNodes = this.getBeforeNodeForm(parameters, task.getFormKey(), task.getName(), task.getProcessDefinitionId(), task.getTaskDefinitionKey(), Boolean.FALSE);
+        // 鍒ゆ柇鍓嶇疆浠诲姟鏄笉鏄拰褰撳墠浠诲姟涓哄悓涓�涓猠xecuteId
         // 鍒ゆ柇褰撳墠浠诲姟鏄惁琚寕璧蜂腑
-        beforeNodes.stream().forEach(node -> {
+        String finalProcessInsId = processInsId;
+        beforeNodes.stream().filter(node -> {
             if (node.getCurrent()) {
-                if (processLogService.taskIsHangup(taskId, task.getProcessInstanceId())) {
+                return Boolean.TRUE;
+            }
+            HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(finalProcessInsId).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();
+            return Objects.nonNull(beforeTask);
+        }).forEach(node -> {
+            if (node.getCurrent()) {
+                if (processLogService.taskIsHangup(taskId, finalProcessInsId)) {
                     node.setTaskStatus(TaskStatusEnum.HANGUP);
                 }
             }
@@ -1279,11 +1293,25 @@
             }
             parameters = hisTask.getProcessVariables();
             List<FormDetailVO> beforeNodes = this.getBeforeNodeForm(parameters, hisTask.getFormKey(), hisTask.getName(), hisTask.getProcessDefinitionId(), hisTask.getTaskDefinitionKey(), Boolean.TRUE);
-            return AjaxResult.success(beforeNodes);
+            List<FormDetailVO> dataList = beforeNodes.stream().filter(node -> {
+                if (node.getCurrent()) {
+                    return Boolean.TRUE;
+                }
+                HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(hisTask.getProcessInstanceId()).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();
+                return Objects.nonNull(beforeTask);
+            }).collect(Collectors.toList());
+            return AjaxResult.success(dataList);
         } else {
             parameters = taskService.getVariables(taskId);
             List<FormDetailVO> beforeNodes = this.getBeforeNodeForm(parameters, task.getFormKey(), task.getName(), task.getProcessDefinitionId(), task.getTaskDefinitionKey(), Boolean.TRUE);
-            return AjaxResult.success(beforeNodes);
+            List<FormDetailVO> dataList = beforeNodes.stream().filter(node -> {
+                if (node.getCurrent()) {
+                    return Boolean.TRUE;
+                }
+                HistoricTaskInstance beforeTask = historyService.createHistoricTaskInstanceQuery().processInstanceId(task.getProcessInstanceId()).finished().taskDefinitionKey(node.getBeforeNodeDefId()).singleResult();
+                return Objects.nonNull(beforeTask);
+            }).collect(Collectors.toList());
+            return AjaxResult.success(dataList);
         }
     }
 

--
Gitblit v1.8.0