添加流程作废

hx-account/src/main/java/com/fjhx/account/flow/AccountRequestFundsFlow.java

@@ -127,6 +127,18 @@ public class AccountRequestFundsFlow extends FlowDelegate {
         );
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+
+        accountRequestFundsService.update(q -> q
+                .eq(AccountRequestFunds::getId, businessId)
+                .set(AccountRequestFunds::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 开始公共代码抽取
      *

hx-purchase/src/main/java/com/fjhx/purchase/flow/PayFlow.java

@@ -12,7 +12,6 @@ import com.fjhx.account.service.account.AccountPaymentService;
 import com.fjhx.common.constant.SourceConstant;
 import com.fjhx.common.enums.FlowStatusEnum1;
 import com.fjhx.common.utils.Assert;
-import com.fjhx.common.utils.ExchangeRateUtil;
 import com.fjhx.file.utils.ObsFileUtil;
 import com.fjhx.flow.core.FlowDelegate;
 import com.fjhx.flow.enums.FlowStatusEnum;
@@ -26,8 +25,8 @@ import com.fjhx.purchase.service.purchase.PurchaseService;
 import com.ruoyi.common.core.domain.BasePo;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.exception.ServiceException;
-import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.wrapper.IWrapper;
 import com.ruoyi.system.service.ISysUserService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -197,6 +196,17 @@ public class PayFlow extends FlowDelegate {
         );
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        payService.update(q -> q
+                .eq(Pay::getId, businessId)
+                .set(Pay::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 修改合同付款状态
      *

hx-purchase/src/main/java/com/fjhx/purchase/flow/RefundFlow.java

@@ -122,4 +122,15 @@ public class RefundFlow extends FlowDelegate {
                 .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
         );
     }
+
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        refundService.update(q -> q
+                .eq(Refund::getId, businessId)
+                .set(Refund::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
 }

hx-purchase/src/main/java/com/fjhx/purchase/flow/SalesReturnFlow.java

@@ -168,4 +168,15 @@ public class SalesReturnFlow extends FlowDelegate {
         );
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+
+        salesReturnService.update(q -> q
+                .eq(SalesReturn::getId, businessId)
+                .set(SalesReturn::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
 }

hx-purchase/src/main/java/com/fjhx/purchase/flow/SubscribeFlow.java

@@ -118,6 +118,17 @@ public class SubscribeFlow extends FlowDelegate {
         );
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        subscribeService.update(q -> q
+                .eq(Subscribe::getId, businessId)
+                .set(Subscribe::getSubcribeStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 开始公共代码抽取
      *

hx-sale/src/main/java/com/fjhx/sale/flow/ContractFlow.java

@@ -79,7 +79,7 @@ public class ContractFlow extends FlowDelegate {
         if (StringUtils.isEmpty(contract.getCurrency())) {
             throw new ServiceException("币种不能为空");
         }
-        if(ObjectUtil.isEmpty(contract.getBuyCorporationId())){
+        if (ObjectUtil.isEmpty(contract.getBuyCorporationId())) {
             throw new ServiceException("客户不能为空");
         }
 
@@ -133,6 +133,17 @@ public class ContractFlow extends FlowDelegate {
         reject();
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        contractService.update(q -> q
+                .eq(Contract::getId, businessId)
+                .set(Contract::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 开始公共代码抽取
      *

hx-sale/src/main/java/com/fjhx/sale/flow/ContractUpdateFlow.java

@@ -2,7 +2,10 @@ package com.fjhx.sale.flow;
 
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.toolkit.*;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.fjhx.account.entity.account.po.AccountRunningWater;
 import com.fjhx.account.service.account.AccountRunningWaterService;
 import com.fjhx.area.utils.CustomizeAreaUtil;
@@ -360,6 +363,17 @@ public class ContractUpdateFlow extends FlowDelegate {
         reject(businessId);
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        contractService.update(q -> q
+                .eq(Contract::getId, businessId)
+                .set(Contract::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 变更合同时执行的数据操作公共代码
      */

hx-sale/src/main/java/com/fjhx/sale/flow/PurchaseFlow.java

@@ -175,6 +175,17 @@ public class PurchaseFlow extends FlowDelegate {
         reject();
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        purchaseService.update(q -> q
+                .eq(Purchase::getId, businessId)
+                .set(Purchase::getPurchaseStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 开始公共代码抽取
      *

hx-sale/src/main/java/com/fjhx/sale/flow/SaleQuotationFlow.java

@@ -107,6 +107,17 @@ public class SaleQuotationFlow extends FlowDelegate {
         );
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        saleQuotationService.update(q -> q
+                .eq(SaleQuotation::getId, businessId)
+                .set(SaleQuotation::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 开始公共代码抽取
      *

hx-sale/src/main/java/com/fjhx/sale/flow/ServiceContractFlow.java

@@ -111,6 +111,17 @@ public class ServiceContractFlow extends FlowDelegate {
         );
     }
 
+    @Override
+    public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
+        super.cancellation(flowId, businessId, flowStatus);
+        serviceContractService.update(q -> q
+                .eq(ServiceContract::getId, businessId)
+                .set(ServiceContract::getStatus, FlowStatusEnum1.CANCELLATION.getKey())
+                .set(BasePo::getUpdateTime, new Date())
+                .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
+        );
+    }
+
     /**
      * 开始公共代码抽取
      *