From dd569475b4ec1bbffc40af2feb024919791b33a7 Mon Sep 17 00:00:00 2001
From: Lius <Lius2225@163.com>
Date: 星期一, 07 四月 2025 15:45:42 +0800
Subject: [PATCH] 修改查询条件数据类型

---
 lxzn-module-flowable/src/main/java/org/jeecg/modules/flowable/service/impl/FlowTaskServiceImpl.java |   62 +++++++++++++++++++++++++++++-
 1 files changed, 59 insertions(+), 3 deletions(-)

diff --git a/lxzn-module-flowable/src/main/java/org/jeecg/modules/flowable/service/impl/FlowTaskServiceImpl.java b/lxzn-module-flowable/src/main/java/org/jeecg/modules/flowable/service/impl/FlowTaskServiceImpl.java
index ab62a88..dc9b5ec 100644
--- a/lxzn-module-flowable/src/main/java/org/jeecg/modules/flowable/service/impl/FlowTaskServiceImpl.java
+++ b/lxzn-module-flowable/src/main/java/org/jeecg/modules/flowable/service/impl/FlowTaskServiceImpl.java
@@ -916,6 +916,63 @@
         return Result.OK();
     }
 
+
+    /**
+     * 鍒ゆ柇澶氫釜浠诲姟鏄惁澶勪簬鍚屼竴娴佺▼鑺傜偣
+     * @param taskIds 閫楀彿鍒嗛殧鐨勪换鍔D瀛楃涓�
+     * @return 缁熶竴缁撴灉灏佽
+     */
+    @Override
+    public Result isSameNode(String taskIds) {
+        // 1. 鍙傛暟鏍¢獙
+        if (StringUtils.isBlank(taskIds)) {
+            return Result.error("浠诲姟ID涓嶈兘涓虹┖");
+        }
+
+        // 2. 鍒嗗壊浠诲姟ID
+        String[] taskIdArray = taskIds.split(",");
+        if (taskIdArray.length == 0) {
+            return Result.error("鏈彁渚涙湁鏁堢殑浠诲姟ID");
+        }
+
+        // 3. 鍗曚换鍔$洿鎺ヨ繑鍥瀟rue
+        if (taskIdArray.length == 1) {
+            return Result.ok(true);
+        }
+
+        // 4. 澶氫换鍔℃鏌ラ�昏緫
+        String referenceNodeId = null;
+        String currentNodeId = null;
+        for (String taskId : taskIdArray) {
+            // 4.1 鏌ヨ浠诲姟瀹炰緥
+            Task task = taskService.createTaskQuery()
+                    .taskId(taskId.trim())
+                    .singleResult();
+
+            // 4.2 浠诲姟涓嶅瓨鍦ㄥ鐞�
+            if (task == null) {
+                return Result.error("浠诲姟涓嶅瓨鍦�: " + taskId);
+            }
+
+            // 4.3 鑾峰彇鑺傜偣鏍囪瘑锛圱askDefinitionKey锛�
+            currentNodeId = task.getTaskDefinitionKey();
+
+            // 4.4 棣栨閬嶅巻鍒濆鍖栧弬鑰冭妭鐐�
+            if (referenceNodeId == null) {
+                referenceNodeId = currentNodeId;
+                continue;
+            }
+
+            // 4.5 鑺傜偣涓嶄竴鑷寸洿鎺ヨ繑鍥�
+            if (!referenceNodeId.equals(currentNodeId)) {
+                return Result.ok("鑺傜偣涓嶄竴鑷�");
+            }
+        }
+
+        // 5. 鎵�鏈変换鍔¤妭鐐逛竴鑷�
+        return Result.ok(currentNodeId);
+    }
+
     /**
      * 浠e姙浠诲姟鍒楄〃
      *
@@ -994,16 +1051,15 @@
             flowTaskDto.setCategory(pd.getCategory());
             // 娴佺▼鍙戣捣浜轰俊鎭�
             HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery()
-                    .processInstanceId(flowTaskDto.getTaskId())
+                    .processInstanceId(flowTaskDto.getProcInsId())
                     .singleResult();
             SysUser startUser = iFlowThirdService.getUserByUsername(historicProcessInstance.getStartUserId());
             flowTaskDto.setStartUserId(startUser.getUsername());
             flowTaskDto.setStartUserName(startUser.getRealname());
             List<String> departNamesByUsername = iFlowThirdService.getDepartNamesByUsername(historicProcessInstance.getStartUserId());
             flowTaskDto.setStartDeptName(CollUtil.join(departNamesByUsername,"锛�"));
-            flowTaskDto.setTaskId(flowTaskDto.getHisProcInsId());
         });
-        return Result.OK(page);
+        return Result.OK(flowTaskDtoIPage);
     }
 
     private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {

--
Gitblit v1.9.3