From 317ba18e6bca479fa652e5a98bcf2943f9c75ee8 Mon Sep 17 00:00:00 2001
From: wsm <2746563060@qq.com>
Date: Thu, 6 Aug 2026 10:05:53 +0800
Subject: [PATCH] =?UTF-8?q?fix(fixcontact):=20=E4=BF=AE=E5=A4=8D=E5=BD=92?=
 =?UTF-8?q?=E6=A1=A3=E7=BD=91=E5=85=B3=E7=BC=BA=E7=9C=81=E5=80=BC=E3=80=81?=
 =?UTF-8?q?=E6=92=A4=E5=9B=9E=E5=9B=9E=E5=86=99=E7=8A=B6=E6=80=81=E5=8F=8A?=
 =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=B8=85=E7=90=86=E5=85=B3=E8=81=94=E6=B5=81?=
 =?UTF-8?q?=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- getIsNeedLeaderApprove 变量为空时默认按不需要处理，避免归档后网关无出边抛异常
- 撤回后回写业务表 bpm_status 为未开始，不再计入进行中统计
- 删除主表时一并终止运行中流程并软删除 task_task，消除孤儿数据
---
 .../FixedContact20260730Controller.java       | 35 +++++++++++++++++--
 .../bg/fixcontact/flow/FixContactFlow.java    |  5 +++
 2 files changed, 37 insertions(+), 3 deletions(-)

diff --git a/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/controller/FixedContact20260730Controller.java b/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/controller/FixedContact20260730Controller.java
index a1897a2..567ff94 100644
--- a/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/controller/FixedContact20260730Controller.java
+++ b/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/controller/FixedContact20260730Controller.java
@@ -133,6 +133,7 @@ public class FixedContact20260730Controller extends JeecgController<FixedContact
     @DeleteMapping(value = "/delete")
     public Result<String> delete(@RequestParam(name = "id", required = true) String id) {
         fixedContact20260730Service.delMain(id);
+        terminateRelatedProcess(id);
         return Result.OK("删除成功!");
     }
 
@@ -141,7 +142,13 @@ public class FixedContact20260730Controller extends JeecgController<FixedContact
     @RequiresPermissions("bg.fixcontact:fixed_contact_20260730:deleteBatch")
     @DeleteMapping(value = "/deleteBatch")
     public Result<String> deleteBatch(@RequestParam(name = "ids", required = true) String ids) {
-        this.fixedContact20260730Service.delBatchMain(Arrays.asList(ids.split(",")));
+        String[] idArr = ids.split(",");
+        this.fixedContact20260730Service.delBatchMain(Arrays.asList(idArr));
+        for (String id : idArr) {
+            if (oConvertUtils.isNotEmpty(id)) {
+                terminateRelatedProcess(id);
+            }
+        }
         return Result.OK("批量删除成功！");
     }
 
@@ -274,6 +281,29 @@ public class FixedContact20260730Controller extends JeecgController<FixedContact
             log.warn("【定点联系-删除关联流程】未找到关联流程, businessId: {}", id);
             return Result.error("未找到关联流程");
         }
+        terminateRelatedProcess(id);
+        FixedContact20260730 record = fixedContact20260730Service.getById(id);
+        if (record != null) {
+            FixedContact20260730 reset = new FixedContact20260730();
+            reset.setId(id);
+            reset.setBpmStatus(BpmStatus.NOT_START.getCode());
+            fixedContact20260730Service.updateById(reset);
+            log.info("【定点联系-删除关联流程】撤回后回写业务表单流程状态, businessId: {}, bpmStatus: {}",
+                    id, BpmStatus.NOT_START.getCode());
+        }
+        return Result.OK("删除关联流程成功");
+    }
+
+    /**
+     * 终止业务记录关联的运行中流程实例，并软删除关联的 taskTask 记录
+     */
+    private void terminateRelatedProcess(String businessId) {
+        LambdaQueryWrapper<TaskTask> queryWrapper = new LambdaQueryWrapper<TaskTask>()
+                .eq(TaskTask::getBusinessId, businessId);
+        List<TaskTask> taskTaskList = taskTaskServiceImpl.list(queryWrapper);
+        if (taskTaskList == null || taskTaskList.isEmpty()) {
+            return;
+        }
         for (TaskTask taskTask : taskTaskList) {
             if (taskTask.getProcessInstId() != null) {
                 long count = runtimeService.createProcessInstanceQuery()
@@ -281,7 +311,7 @@ public class FixedContact20260730Controller extends JeecgController<FixedContact
                         .count();
                 if (count > 0) {
                     runtimeService.deleteProcessInstance(taskTask.getProcessInstId(),
-                            "删除定点联系单关联流程, businessId: " + id);
+                            "删除定点联系单关联流程, businessId: " + businessId);
                     log.info("【定点联系-删除关联流程】已中止运行中的流程实例: {}", taskTask.getProcessInstId());
                 }
             }
@@ -294,6 +324,5 @@ public class FixedContact20260730Controller extends JeecgController<FixedContact
             taskTaskServiceImpl.removeByIds(ids);
             log.info("【定点联系-删除关联流程】已清理关联的taskTask记录, ids: {}", ids);
         }
-        return Result.OK("删除关联流程成功");
     }
 }
diff --git a/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/flow/FixContactFlow.java b/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/flow/FixContactFlow.java
index 8c318b4..c45c7c8 100644
--- a/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/flow/FixContactFlow.java
+++ b/jeecg-module-supervision/src/main/java/org/jeecg/modules/bg/fixcontact/flow/FixContactFlow.java
@@ -386,6 +386,11 @@ public class FixContactFlow {
     // ${fixContactFlow.getIsNeedLeaderApprove(execution)}
     public String getIsNeedLeaderApprove(DelegateExecution execution) {
         String value = this.getVar(execution, FixContactConstant.FlowVarName.IS_NEED_LEADER_APPROVE);
+        if (StringUtils.isBlank(value)) {
+            log.warn("【定点联系-流程表达式】流程未设置是否需要所领导审批变量, 默认按不需要处理, processInstanceId: {}",
+                    execution.getProcessInstanceId());
+            return "0";
+        }
         log.info("【定点联系-流程表达式】读取是否需要所领导审批, processInstanceId: {}, value: {}",
                 execution.getProcessInstanceId(), value);
         return value;