采购计划：提交审核

@@ -22,6 +22,7 @@ import com.lframework.xingyun.sc.procurement.entity.ProcurementDomesticCustomerC
 import com.lframework.xingyun.sc.procurement.entity.ProcurementForeignTradeCredit;
 import com.lframework.xingyun.sc.procurement.service.credit.ProcurementDomesticCustomerCreditService;
 import com.lframework.xingyun.sc.procurement.service.credit.ProcurementForeignTradeCreditService;
+import com.lframework.xingyun.sc.procurement.service.plan.ProcurementPlanService;
 import com.lframework.xingyun.sc.procurement.service.quotation.SalesmanQuotationService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
 import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
@@ -157,6 +158,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private ProcurementForeignTradeCreditService procurementForeignTradeCreditService;
     @Resource
     private SalesmanQuotationService salesmanQuotationService;
+    @Resource
+    private ProcurementPlanService procurementPlanService;
 
 
 
@@ -247,6 +250,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "SALESMAN_QUOTATION":
                 handleSalesmanQuotationData(flowStatus, businessId);
                 break;
+            case "PROCUREMENT_PLAN":
+                handleProcurementPlanData(flowStatus, businessId);
+                break;
             default:
                 break;
         }
@@ -1123,4 +1129,22 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             salesmanQuotationService.updateApprovalStatus(businessId, "REFUSE");
         }
     }
+
+    /**
+     * 采购计划审核业务数据处理
+     *
+     * @param flowStatus 审核结果
+     * @param businessId 业务ID
+     */
+    private void handleProcurementPlanData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
+                || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
+            procurementPlanService.updateApprovalStatus(businessId, "PASS");
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
+            procurementPlanService.updateApprovalStatus(businessId, "REFUSE");
+        }
+    }
+
 }

@@ -17,6 +17,7 @@ import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
 import com.lframework.xingyun.sc.entity.FundCoordination;
 import com.lframework.xingyun.sc.entity.ProductSampleConfirmationSlip;
 import com.lframework.xingyun.sc.handlers.TransactorHandler;
+import com.lframework.xingyun.sc.procurement.service.plan.ProcurementPlanService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
 import com.lframework.xingyun.sc.service.ledger.FundCoordinationService;
@@ -59,6 +60,8 @@ public class FlowTaskServiceImpl implements FlowTaskService {
     private SampleResultTrackingService sampleResultTrackingService;
     @Resource
     private ContractDistributorStandardService contractDistributorStandardService;
+    @Resource
+    private ProcurementPlanService procurementPlanService;
 
 
     @OpLog(type = OtherOpLogType.class, name = "修改客户资信，ID：{}", params = {"#id"})
@@ -437,6 +440,15 @@ public class FlowTaskServiceImpl implements FlowTaskService {
     }
 
     @Override
+    public void updateProcurementPlanMap(Map<String, Object> map) {
+        //主键
+        Object i = map.get("id");
+        String id = String.valueOf(i);
+
+        procurementPlanService.updateExamine(id);
+    }
+
+    @Override
     public Map<String, Object> findById(String s) {
         ProductSampleConfirmationSlip slip = productSampleConfirmationSlipService.findById(s);
         Map<String, Object> map = new HashMap<>();

@@ -133,6 +133,20 @@ public class ProcurementPlanController extends DefaultBaseController {
   }
 
   /**
+   * 发起审核
+   */
+  @ApiOperation("发起审核")
+  @ApiImplicitParam(value = "ID", name = "id", paramType = "query", required = true)
+  @HasPermission({"plan-manage:domestic-plan:goapprove"})
+  @PostMapping("/submitAudit")
+  public InvokeResult<Void> submitAudit(@NotBlank(message = "ID不能为空！") String id) {
+
+    procurementPlanService.submitAudit(id);
+
+    return InvokeResultBuilder.success();
+  }
+
+  /**
    * 删除
    */
   @ApiOperation("删除")

@@ -5,17 +5,19 @@ 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.service.FlowInstanceWrapperService;
 import com.lframework.starter.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.exceptions.impl.InputErrorException;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.starter.common.utils.CollectionUtil;
 import com.lframework.starter.common.utils.NumberUtil;
 import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.web.core.annotations.oplog.OpLog;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
 import com.lframework.starter.web.core.utils.IdUtil;
+import com.lframework.starter.web.core.utils.OpLogUtil;
 import com.lframework.starter.web.core.utils.PageHelperUtil;
-import com.lframework.starter.web.inner.entity.SysDept;
-import com.lframework.starter.web.inner.service.system.SysDeptService;
+import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
 import com.lframework.starter.web.core.components.resp.PageResult;
 import com.lframework.starter.web.core.utils.PageResultUtil;
 import com.lframework.xingyun.basedata.entity.Workshop;
@@ -53,10 +55,14 @@ import javax.annotation.Resource;
 public class ProcurementPlanServiceImpl extends BaseMpServiceImpl<ProcurementPlanMapper, ProcurementPlan>
     implements ProcurementPlanService {
 
+  private static final String BPM_FLAG = "PROCUREMENT_PLAN";
+
   @Autowired
   private ProcurementPlanLineService procurementPlanLineService;
   @Resource
   private WorkshopService workshopService;
+  @Resource
+  private FlowInstanceWrapperService flowInstanceWrapperService;
 
   @Override
   public PageResult<ProcurementPlan> query(Integer pageIndex, Integer pageSize,
@@ -353,6 +359,71 @@ public class ProcurementPlanServiceImpl extends BaseMpServiceImpl<ProcurementPla
     getBaseMapper().update(mainUpdateWrapper);
   }
 
+  @OpLog(type = OtherOpLogType.class, name = "发起采购计划审核，ID：{}", params = {"#id"})
+  @Transactional(rollbackFor = Exception.class)
+  @Override
+  public void submitAudit(String id) {
+    if (StringUtil.isBlank(id)) {
+      throw new InputErrorException("ID不能为空！");
+    }
+
+    ProcurementPlan plan = getBaseMapper().findById(id);
+    if (plan == null) {
+      throw new DefaultClientException("采购计划不存在！");
+    }
+
+    if (Boolean.TRUE.equals(plan.getFrozen())) {
+      throw new DefaultClientException("当前采购计划已冻结，无法发起审核！");
+    }
+
+    List<ProcurementPlanLine> planLineList = procurementPlanLineService.getByProcurementPlanId(id);
+    if (CollectionUtil.isEmpty(planLineList)) {
+      throw new DefaultClientException("采购计划明细为空，无法发起审核！");
+    }
+
+    // 更新主表审核状态/流程节点：标记为已发起审核中
+    LambdaUpdateWrapper<ProcurementPlan> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlan.class)
+            .set(ProcurementPlan::getApprovalStatus, "AUDIT")
+            .set(ProcurementPlan::getProcessStatus, "AUDIT")
+            .set(ProcurementPlan::getProcessNode, "GYBZG")
+            .eq(ProcurementPlan::getId, id);
+    getBaseMapper().update(updateWrapper);
+
+    ProcurementPlan freshPlan = getBaseMapper().findById(id);
+    flowInstanceWrapperService.startInstance(BPM_FLAG, freshPlan.getId(), BPM_FLAG, freshPlan);
+
+    OpLogUtil.setVariable("id", freshPlan.getId());
+    OpLogUtil.setExtra(freshPlan);
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  @Override
+  public void updateApprovalStatus(String id, String approvalStatus) {
+    if (StringUtils.isBlank(id) || StringUtils.isBlank(approvalStatus)) {
+      throw new DefaultClientException("采购计划ID、审核状态不能为空！");
+    }
+
+    Wrapper<ProcurementPlan> wrapper = Wrappers.lambdaUpdate(ProcurementPlan.class)
+            .set(ProcurementPlan::getApprovalStatus, approvalStatus)
+            .set(ProcurementPlan::getProcessStatus, approvalStatus.equals("PASS") ? "COMPLETED" : "REFUSE")
+            .set(ProcurementPlan::getProcessNode, approvalStatus.equals("PASS") ? null : "GYGLKZG")
+            .eq(ProcurementPlan::getId, id);
+    getBaseMapper().update(wrapper);
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  @Override
+  public void updateExamine(String id) {
+    if (StringUtils.isBlank(id)) {
+      throw new DefaultClientException("采购计划ID不能为空！");
+    }
+
+    Wrapper<ProcurementPlan> wrapper = Wrappers.lambdaUpdate(ProcurementPlan.class)
+            .set(ProcurementPlan::getProcessNode, "YSFG")
+            .eq(ProcurementPlan::getId, id);
+    getBaseMapper().update(wrapper);
+  }
+
   /**
    * 子计划创建：与 create() 逻辑一致，但不重新 buildPlanCode（因为子计划编号已按父code+后缀生成）
    */

@@ -72,4 +72,21 @@ public interface ProcurementPlanService extends BaseMpService<ProcurementPlan> {
    * @param id
    */
   void submit(String id);
+
+  /**
+   * 发起审核
+   *
+   * @param id
+   */
+  void submitAudit(String id);
+
+  /**
+   * 更新审核状态
+   *
+   * @param id
+   * @param approvalStatus
+   */
+  void updateApprovalStatus(String id, String approvalStatus);
+
+  void updateExamine(String id);
 }