采购计划：中止

@@ -159,4 +159,18 @@ public class ProcurementPlanController extends DefaultBaseController {
 
     return InvokeResultBuilder.success();
   }
+
+  /**
+   * 中止
+   */
+  @ApiOperation("中止")
+  @ApiImplicitParam(value = "ID", name = "id", paramType = "query", required = true)
+  @HasPermission({"plan-manage:domestic-plan:stop"})
+  @PostMapping("/stop")
+  public InvokeResult<Void> stop(@NotBlank(message = "ID不能为空！") String id) {
+
+    procurementPlanService.abort(id);
+
+    return InvokeResultBuilder.success();
+  }
 }

@@ -5,7 +5,9 @@ import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
+import com.lframework.starter.bpm.entity.FlowInstanceWrapper;
 import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
+import com.lframework.starter.bpm.service.FlowTaskWrapperService;
 import com.lframework.starter.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.exceptions.impl.InputErrorException;
 import com.lframework.starter.common.utils.Assert;
@@ -63,6 +65,8 @@ public class ProcurementPlanServiceImpl extends BaseMpServiceImpl<ProcurementPla
   private WorkshopService workshopService;
   @Resource
   private FlowInstanceWrapperService flowInstanceWrapperService;
+  @Resource
+  private FlowTaskWrapperService flowTaskWrapperService;
 
   @Override
   public PageResult<ProcurementPlan> query(Integer pageIndex, Integer pageSize,
@@ -425,6 +429,107 @@ public class ProcurementPlanServiceImpl extends BaseMpServiceImpl<ProcurementPla
   }
 
   /**
+   * 中止采购计划
+   * 规则：
+   * 1. 选择分厂后的任意环节可发起中止
+   * 2. 子计划发起中止 → 对应主计划下所有子计划全部中止
+   * 3. 主计划下只要有1个已完成(COMPLETED)子计划，不允许中止
+   * 4. 审核中(AUDIT)的计划需要终止工作流
+   *
+   * @param id 采购计划ID（可以是主计划ID或任意子计划ID）
+   */
+  @OpLog(type = OtherOpLogType.class, name = "中止采购计划，ID：{}", params = {"#id"})
+  @Transactional(rollbackFor = Exception.class)
+  @Override
+  public void abort(String id) {
+    if (StringUtil.isBlank(id)) {
+      throw new InputErrorException("ID不能为空！");
+    }
+
+    //查询当前计划
+    ProcurementPlan currentPlan = getBaseMapper().findById(id);
+    if (currentPlan == null) {
+      throw new DefaultClientException("采购计划不存在！");
+    }
+
+    //确定主计划ID，并收集所有需要中止的子计划列表
+    String mainPlanId;
+    List<ProcurementPlan> allSubPlans;
+    if (StringUtil.isBlank(currentPlan.getParentId())) {
+      //当前是主计划
+      mainPlanId = currentPlan.getId();
+    } else {
+      //当前是子计划，向上追溯到主计划
+      mainPlanId = currentPlan.getParentId();
+    }
+    //查询主计划下的所有子计划(非冻结的)
+    allSubPlans = getBaseMapper().selectList(
+            Wrappers.lambdaQuery(ProcurementPlan.class)
+                    .eq(ProcurementPlan::getFrozen, false)
+                    .eq(ProcurementPlan::getParentId, mainPlanId)
+    );
+    //如果没有子计划（单分厂，没有拆分过，当前就是一个计划），把当前计划加入列表
+    if (CollectionUtil.isEmpty(allSubPlans)) {
+      allSubPlans = new ArrayList<>();
+      allSubPlans.add(currentPlan);
+    }
+
+
+    //前置校验：存在任意"已完成"子计划则不允许中止
+    long completedCount = allSubPlans.stream()
+            .filter(p -> "COMPLETED".equals(p.getProcessStatus()))
+            .count();
+    if (completedCount > 0) {
+      throw new DefaultClientException("存在已完成的计划（子计划），不允许发起中止！");
+    }
+
+    //收集所有需要中止的计划ID（用于批量查流程实例）
+    List<String> planIdsToAbort = allSubPlans.stream()
+            .map(ProcurementPlan::getId)
+            .collect(Collectors.toList());
+
+    //批量查询这些计划关联的流程实例（用于审核中的计划终止工作流）
+    List<FlowInstanceWrapper> flowList = flowInstanceWrapperService.getFlowByBusinessIdList(planIdsToAbort);
+    // businessId -> FlowInstanceWrapper
+    Map<String, FlowInstanceWrapper> flowMap = CollectionUtil.isEmpty(flowList)
+            ? new HashMap<>()
+            : flowList.stream()
+                .filter(f -> StringUtil.isNotBlank(f.getBusinessId()))
+                .collect(Collectors.toMap(FlowInstanceWrapper::getBusinessId, f -> f, (v1, v2) -> v1));
+
+    //逐个处理子计划：过滤掉已中止的，其余更新状态为ABORTED，审核中的同时终止工作流
+    for (ProcurementPlan subPlan : allSubPlans) {
+      String status = subPlan.getProcessStatus();
+      // 已中止：幂等跳过
+      if ("ABORTED".equals(status)) {
+        continue;
+      }
+      // 已完成：理论上前面已经校验，这里再兜底
+      if ("COMPLETED".equals(status)) {
+        throw new DefaultClientException(String.format("计划[%s]已完成，不允许中止！", subPlan.getCode()));
+      }
+
+      // 审核中(AUDIT)需要先终止工作流
+      if ("AUDIT".equals(status)) {
+        FlowInstanceWrapper flow = flowMap.get(subPlan.getId());
+        if (flow != null && flow.getId() != null) {
+          flowTaskWrapperService.termination(flow.getId());
+        }
+      }
+
+      // 更新计划状态为"已中止"
+      LambdaUpdateWrapper<ProcurementPlan> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlan.class)
+              .set(ProcurementPlan::getProcessStatus, "ABORTED")
+              .set(ProcurementPlan::getProcessNode, null)
+              .eq(ProcurementPlan::getId, subPlan.getId());
+      getBaseMapper().update(updateWrapper);
+    }
+
+    OpLogUtil.setVariable("id", id);
+    OpLogUtil.setExtra(currentPlan);
+  }
+
+  /**
    * 子计划创建：与 create() 逻辑一致，但不重新 buildPlanCode（因为子计划编号已按父code+后缀生成）
    */
   @Transactional(rollbackFor = Exception.class)

@@ -89,4 +89,11 @@ public interface ProcurementPlanService extends BaseMpService<ProcurementPlan> {
   void updateApprovalStatus(String id, String approvalStatus);
 
   void updateExamine(String id);
+
+  /**
+   * 中止采购计划
+   *
+   * @param id 采购计划ID（可以是主计划或子计划ID）
+   */
+  void abort(String id);
 }