..

src/main/java/com/budwk/app/flow/service/ProcessTaskService.java

@@ -201,4 +201,14 @@ public interface ProcessTaskService extends BaseService<ProcessTask> {
      * @param transferUserId 转办用户ID
      */
     void transfer(Long taskId, String transferUserId);
+
+    /**
+     * 获取正在进行的任务
+     *
+     * @param bizIds   业务ID
+     * @param taskName 任务名称
+     * @return
+     */
+    List<ProcessTask> getDoingTaskByBizIdTaskName(List<String> bizIds, String taskName);
+
 }

src/main/java/com/budwk/app/flow/service/impl/ProcessTaskServiceImpl.java

@@ -485,7 +485,17 @@ public class ProcessTaskServiceImpl extends BaseServiceImpl<ProcessTask> impleme
         processTaskList.forEach(processTask -> {
             ProcessPublisher.notify(ProcessEvent.builder().eventType(ProcessEventTypeEnum.PROCESS_TASK_START).sourceId(processTask.getId()).build());
         });
+    }
 
+
+    @Override
+    public List<ProcessTask> getDoingTaskByBizIdTaskName(List<String> bizIds, String taskName) {
+        List<ProcessInstance> instances = dao().query(ProcessInstance.class, Cnd.where(ProcessInstance::getBusinessNo, "in", bizIds));
+        List<Long> instanceIds = instances.stream().map(ProcessInstance::getId).toList();
+        List<ProcessTask> tasks = dao().query(ProcessTask.class, Cnd.where(ProcessTask::getProcessInstanceId, "in", instanceIds)
+                .and(ProcessTask::getTaskName, "=", taskName)
+                .and(ProcessTask::getTaskState, "=", ProcessTaskStateEnum.DOING.getCode()));
+        return tasks;
     }
 
     /**