platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/controller/FlowCallBackController.java
@@ -1,7 +1,12 @@
package com.by4cloud.platformx.business.controller;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.by4cloud.platformx.business.constant.FlowNameEnum;
import com.by4cloud.platformx.business.entity.ContractDelayOut;
import com.by4cloud.platformx.business.service.ContractDelayOutService;
import com.by4cloud.platformx.business.service.ContractInvoiceService;
import com.by4cloud.platformx.business.service.ContractService;
import com.by4cloud.platformx.flow.task.constant.TaskStatusEnum;
import com.by4cloud.platformx.flow.task.dto.ProcessInstanceParamDto;
import com.by4cloud.platformx.flow.task.dto.ProcessNodeRecordParamDto;
import io.swagger.v3.oas.annotations.tags.Tag;
@@ -25,6 +30,8 @@
public class FlowCallBackController {
   private final ContractService contractService;
   private final ContractInvoiceService contractInvoiceService;
   private final ContractDelayOutService delayOutService;
   /**
     * 开始节点事件
@@ -33,7 +40,12 @@
     */
    @PostMapping("/startNodeEvent")
    public void startNodeEvent(@RequestBody ProcessNodeRecordParamDto recordParamDto){
      if (recordParamDto.getFlowName().equals(FlowNameEnum.合同审批.getName())) {
      }
      if (recordParamDto.getFlowName().equals(FlowNameEnum.销售挂账审批.getName())) {
      }
    }
    /**
     * 任务结束事件
@@ -43,8 +55,35 @@
    @PostMapping("/endProcess")
    public void endProcessEvent(@RequestBody ProcessInstanceParamDto processInstanceParamDto) {
        if (processInstanceParamDto.getFlowName().equals(FlowNameEnum.合同审批.getName())) {
         contractService.startApproval(Long.valueOf(processInstanceParamDto.getParamMap().get("id")+""));
         //通过后更新主表状态
         if (processInstanceParamDto.getTaskStatus()== TaskStatusEnum.YJS.getCode()){
            contractService.takeEffect(Long.valueOf(processInstanceParamDto.getParamMap().get("id")+""));
         }
         //拒绝后回退主表状态
         if (processInstanceParamDto.getTaskStatus()== TaskStatusEnum.JJ.getCode()){
            contractService.refuseApproval(Long.valueOf(processInstanceParamDto.getParamMap().get("id")+""));
         }
        }
      if (processInstanceParamDto.getFlowName().equals(FlowNameEnum.销售挂账审批.getName())) {
         //通过后更新主表状态
         if (processInstanceParamDto.getTaskStatus()== TaskStatusEnum.YJS.getCode()){
            contractInvoiceService.takeEffect(Long.valueOf(processInstanceParamDto.getParamMap().get("id")+""));
         }
         //拒绝后回退主表状态
         if (processInstanceParamDto.getTaskStatus()== TaskStatusEnum.JJ.getCode()){
            contractInvoiceService.refuseApproval(Long.valueOf(processInstanceParamDto.getParamMap().get("id")+""));
         }
      }
      if (processInstanceParamDto.getFlowName().equals(FlowNameEnum.延期出货审批.getName())) {
         //通过后更新主表状态
         if (processInstanceParamDto.getTaskStatus()== TaskStatusEnum.YJS.getCode()){
            delayOutService.approvalPass(Long.valueOf(processInstanceParamDto.getParamMap().get("contractId")+""));
         }
         //拒绝后回退主表状态
         if (processInstanceParamDto.getTaskStatus()== TaskStatusEnum.JJ.getCode()){
            delayOutService.refuseApproval(Long.valueOf(processInstanceParamDto.getParamMap().get("delayOutService")+""));
         }
      }
    }
}