|
@@ -8,11 +8,13 @@ import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.fjhx.common.constant.SourceConstant;
|
|
import com.fjhx.common.constant.SourceConstant;
|
|
import com.fjhx.common.enums.CodingRuleEnum;
|
|
import com.fjhx.common.enums.CodingRuleEnum;
|
|
|
|
+import com.fjhx.common.enums.FlowStatusEnum1;
|
|
import com.fjhx.common.service.coding.CodingRuleService;
|
|
import com.fjhx.common.service.coding.CodingRuleService;
|
|
import com.fjhx.common.utils.Assert;
|
|
import com.fjhx.common.utils.Assert;
|
|
import com.fjhx.file.utils.ObsFileUtil;
|
|
import com.fjhx.file.utils.ObsFileUtil;
|
|
import com.fjhx.flow.core.FlowDelegate;
|
|
import com.fjhx.flow.core.FlowDelegate;
|
|
import com.fjhx.flow.core.FlowThreadLocalUtil;
|
|
import com.fjhx.flow.core.FlowThreadLocalUtil;
|
|
|
|
+import com.fjhx.flow.enums.FlowStatusEnum;
|
|
import com.fjhx.purchase.entity.purchase.dto.PurchaseDto;
|
|
import com.fjhx.purchase.entity.purchase.dto.PurchaseDto;
|
|
import com.fjhx.purchase.entity.purchase.enums.PurchaseDataResourceEnum;
|
|
import com.fjhx.purchase.entity.purchase.enums.PurchaseDataResourceEnum;
|
|
import com.fjhx.purchase.entity.purchase.enums.PurchaseDetailStatusEnum;
|
|
import com.fjhx.purchase.entity.purchase.enums.PurchaseDetailStatusEnum;
|
|
@@ -28,7 +30,9 @@ import com.fjhx.purchase.service.subscribe.SubscribeDetailService;
|
|
import com.fjhx.purchase.service.subscribe.SubscribeService;
|
|
import com.fjhx.purchase.service.subscribe.SubscribeService;
|
|
import com.fjhx.sale.entity.contract.po.ContractProduct;
|
|
import com.fjhx.sale.entity.contract.po.ContractProduct;
|
|
import com.fjhx.sale.service.contract.ContractProductService;
|
|
import com.fjhx.sale.service.contract.ContractProductService;
|
|
|
|
+import com.ruoyi.common.core.domain.BasePo;
|
|
import com.ruoyi.common.exception.ServiceException;
|
|
import com.ruoyi.common.exception.ServiceException;
|
|
|
|
+import com.ruoyi.common.utils.SecurityUtils;
|
|
import com.ruoyi.common.utils.wrapper.IWrapper;
|
|
import com.ruoyi.common.utils.wrapper.IWrapper;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
@@ -220,6 +224,34 @@ public class PurchaseFlowByWdly extends FlowDelegate {
|
|
.lambda().eq(PurchaseDetail::getPurchaseId, purchase.getId()));
|
|
.lambda().eq(PurchaseDetail::getPurchaseId, purchase.getId()));
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public void relaunch(Long flowId, Long businessId, FlowStatusEnum flowStatus, JSONObject submitData) {
|
|
|
|
+ super.relaunch(flowId, businessId, flowStatus, submitData);
|
|
|
|
+ reStart();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void reject(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
|
|
|
|
+ super.reject(flowId, businessId, flowStatus);
|
|
|
|
+ purchaseService.update(q -> q
|
|
|
|
+ .eq(Purchase::getId, businessId)
|
|
|
|
+ .set(Purchase::getPurchaseStatus, FlowStatusEnum1.REJECT.getKey())
|
|
|
|
+ .set(BasePo::getUpdateTime, new Date())
|
|
|
|
+ .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
|
|
|
|
+ );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @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())
|
|
|
|
+ );
|
|
|
|
+ }
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 重新发起编辑方法
|
|
* 重新发起编辑方法
|
|
*/
|
|
*/
|