|
@@ -229,7 +229,7 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
if (ObjectUtils.isEmpty(newContract)) {
|
|
|
throw new ServiceException("合同不存在");
|
|
|
}
|
|
|
- long oldContractId = newContract.getOldContractId();//取出旧的合同ID
|
|
|
+ long oldContractId = newContract.getOldContractId();//取出旧的合同ID
|
|
|
Contract oldContract = contractService.getById(oldContractId);
|
|
|
if (oldContract == null) {
|
|
|
throw new ServiceException("原合同不存在");
|
|
@@ -249,15 +249,15 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
|
|
|
|
|
|
//查询新数据产品、收费、出货
|
|
|
- List<Long> newContractProductIds = contractProductService.list(Wrappers.<ContractProduct>query().lambda().select(ContractProduct::getId).eq(ContractProduct::getContractId,businessId)).stream().map(ContractProduct::getId).collect(Collectors.toList());
|
|
|
- List<Long> newContractProjectIds = contractProjectService.list(Wrappers.<ContractProject>query().lambda().select(ContractProject::getId).eq(ContractProject::getContractId,businessId)).stream().map(ContractProject::getId).collect(Collectors.toList());
|
|
|
- List<Long> newContractShipmentIds = contractShipmentService.list(Wrappers.<ContractShipment>query().lambda().select(ContractShipment::getId).eq(ContractShipment::getContractId,businessId)).stream().map(ContractShipment::getId).collect(Collectors.toList());
|
|
|
+ List<Long> newContractProductIds = contractProductService.list(Wrappers.<ContractProduct>query().lambda().select(ContractProduct::getId).eq(ContractProduct::getContractId, businessId)).stream().map(ContractProduct::getId).collect(Collectors.toList());
|
|
|
+ List<Long> newContractProjectIds = contractProjectService.list(Wrappers.<ContractProject>query().lambda().select(ContractProject::getId).eq(ContractProject::getContractId, businessId)).stream().map(ContractProject::getId).collect(Collectors.toList());
|
|
|
+ List<Long> newContractShipmentIds = contractShipmentService.list(Wrappers.<ContractShipment>query().lambda().select(ContractShipment::getId).eq(ContractShipment::getContractId, businessId)).stream().map(ContractShipment::getId).collect(Collectors.toList());
|
|
|
|
|
|
|
|
|
//查询旧数据产品、收费、出货
|
|
|
- List<Long> oldContractProductIds = contractProductService.list(Wrappers.<ContractProduct>query().lambda().select(ContractProduct::getId).eq(ContractProduct::getContractId,oldContractId)).stream().map(ContractProduct::getId).collect(Collectors.toList());
|
|
|
- List<Long> oldContractProjectIds = contractProjectService.list(Wrappers.<ContractProject>query().lambda().select(ContractProject::getId).eq(ContractProject::getContractId,oldContractId)).stream().map(ContractProject::getId).collect(Collectors.toList());
|
|
|
- List<Long> oldContractShipmentIds = contractShipmentService.list(Wrappers.<ContractShipment>query().lambda().select(ContractShipment::getId).eq(ContractShipment::getContractId,oldContractId)).stream().map(ContractShipment::getId).collect(Collectors.toList());
|
|
|
+ List<Long> oldContractProductIds = contractProductService.list(Wrappers.<ContractProduct>query().lambda().select(ContractProduct::getId).eq(ContractProduct::getContractId, oldContractId)).stream().map(ContractProduct::getId).collect(Collectors.toList());
|
|
|
+ List<Long> oldContractProjectIds = contractProjectService.list(Wrappers.<ContractProject>query().lambda().select(ContractProject::getId).eq(ContractProject::getContractId, oldContractId)).stream().map(ContractProject::getId).collect(Collectors.toList());
|
|
|
+ List<Long> oldContractShipmentIds = contractShipmentService.list(Wrappers.<ContractShipment>query().lambda().select(ContractShipment::getId).eq(ContractShipment::getContractId, oldContractId)).stream().map(ContractShipment::getId).collect(Collectors.toList());
|
|
|
|
|
|
|
|
|
/**
|
|
@@ -271,16 +271,16 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
newContract.setIsShow(0);//显示新合同
|
|
|
contractService.updateContract(newContract);
|
|
|
//修改合同产品相关数据
|
|
|
- if(CollectionUtils.isNotEmpty(newContractProductIds)){
|
|
|
- contractProductService.update(Wrappers.<ContractProduct>update().lambda().set(ContractProduct::getContractId,oldContractId).in(ContractProduct::getId,newContractProductIds));
|
|
|
+ if (CollectionUtils.isNotEmpty(newContractProductIds)) {
|
|
|
+ contractProductService.update(Wrappers.<ContractProduct>update().lambda().set(ContractProduct::getContractId, oldContractId).in(ContractProduct::getId, newContractProductIds));
|
|
|
}
|
|
|
//修改合同收费相关数据
|
|
|
- if(CollectionUtils.isNotEmpty(newContractProjectIds)){
|
|
|
- contractProjectService.update(Wrappers.<ContractProject>update().lambda().set(ContractProject::getContractId,oldContractId).in(ContractProject::getId,newContractProjectIds));
|
|
|
+ if (CollectionUtils.isNotEmpty(newContractProjectIds)) {
|
|
|
+ contractProjectService.update(Wrappers.<ContractProject>update().lambda().set(ContractProject::getContractId, oldContractId).in(ContractProject::getId, newContractProjectIds));
|
|
|
}
|
|
|
//修改合同出货相关数据
|
|
|
- if(CollectionUtils.isNotEmpty(newContractShipmentIds)){
|
|
|
- contractShipmentService.update(Wrappers.<ContractShipment>update().lambda().set(ContractShipment::getContractId,oldContractId).in(ContractShipment::getId,newContractShipmentIds));
|
|
|
+ if (CollectionUtils.isNotEmpty(newContractShipmentIds)) {
|
|
|
+ contractShipmentService.update(Wrappers.<ContractShipment>update().lambda().set(ContractShipment::getContractId, oldContractId).in(ContractShipment::getId, newContractShipmentIds));
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -292,7 +292,7 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
contractService.updateById(oldContract);
|
|
|
|
|
|
|
|
|
- List<ClaimContract> claimContractList = claimContractService.list(Wrappers.<ClaimContract>query().lambda().eq(ClaimContract::getContractId,oldContractId));
|
|
|
+ List<ClaimContract> claimContractList = claimContractService.list(Wrappers.<ClaimContract>query().lambda().eq(ClaimContract::getContractId, oldContractId));
|
|
|
if (ObjectUtil.isNotEmpty(claimContractList)) {
|
|
|
List<Long> claimIds = claimContractList.stream().map(ClaimContract::getClaimId).collect(Collectors.toList());
|
|
|
List<Long> claimContractIds = claimContractList.stream().map(ClaimContract::getId).collect(Collectors.toList());
|
|
@@ -323,20 +323,20 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
oldContract.setIsShow(1);//隐藏旧合同
|
|
|
contractService.updateContract(oldContract);
|
|
|
//修改合同产品相关数据
|
|
|
- if(CollectionUtils.isNotEmpty(oldContractProductIds)){
|
|
|
- contractProductService.update(Wrappers.<ContractProduct>update().lambda().set(ContractProduct::getContractId,businessId).in(ContractProduct::getId,oldContractProductIds));
|
|
|
+ if (CollectionUtils.isNotEmpty(oldContractProductIds)) {
|
|
|
+ contractProductService.update(Wrappers.<ContractProduct>update().lambda().set(ContractProduct::getContractId, businessId).in(ContractProduct::getId, oldContractProductIds));
|
|
|
}
|
|
|
//修改合同出货相关数据
|
|
|
- if(CollectionUtils.isNotEmpty(oldContractProjectIds)){
|
|
|
+ if (CollectionUtils.isNotEmpty(oldContractProjectIds)) {
|
|
|
//修改合同收费相关数据
|
|
|
- contractProjectService.update(Wrappers.<ContractProject>update().lambda().set(ContractProject::getContractId,businessId).in(ContractProject::getId,oldContractProjectIds));
|
|
|
+ contractProjectService.update(Wrappers.<ContractProject>update().lambda().set(ContractProject::getContractId, businessId).in(ContractProject::getId, oldContractProjectIds));
|
|
|
}
|
|
|
//修改合同出货相关数据
|
|
|
- if(CollectionUtils.isNotEmpty(oldContractShipmentIds)){
|
|
|
+ if (CollectionUtils.isNotEmpty(oldContractShipmentIds)) {
|
|
|
//修改合同出货相关数据
|
|
|
- contractShipmentService.update(Wrappers.<ContractShipment>update().lambda().set(ContractShipment::getContractId,businessId).in(ContractShipment::getId,oldContractShipmentIds));
|
|
|
+ contractShipmentService.update(Wrappers.<ContractShipment>update().lambda().set(ContractShipment::getContractId, businessId).in(ContractShipment::getId, oldContractShipmentIds));
|
|
|
}
|
|
|
- ObsFileUtil.exchangeBusinessId(oldContractId,businessId);
|
|
|
+ ObsFileUtil.exchangeBusinessId(oldContractId, businessId);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -356,6 +356,7 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
|
|
|
/**
|
|
|
* 驳回
|
|
|
+ *
|
|
|
* @param flowId
|
|
|
* @param businessId
|
|
|
* @param flowStatus
|
|
@@ -366,6 +367,13 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
reject(businessId);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 作废
|
|
|
+ *
|
|
|
+ * @param flowId 流程id
|
|
|
+ * @param businessId 业务id
|
|
|
+ * @param flowStatus 流程状态枚举
|
|
|
+ */
|
|
|
@Override
|
|
|
public void cancellation(Long flowId, Long businessId, FlowStatusEnum flowStatus) {
|
|
|
super.cancellation(flowId, businessId, flowStatus);
|
|
@@ -375,6 +383,14 @@ public class ContractUpdateFlow extends FlowDelegate {
|
|
|
.set(BasePo::getUpdateTime, new Date())
|
|
|
.set(BasePo::getUpdateUser, SecurityUtils.getUserId())
|
|
|
);
|
|
|
+ //合同变更作废需要还原旧合同状态 为审批通过
|
|
|
+ Contract contract = contractService.getById(businessId);
|
|
|
+ contractService.update(q -> q
|
|
|
+ .eq(Contract::getId, contract.getOldContractId())
|
|
|
+ .set(Contract::getStatus, FlowStatusEnum1.PASS.getKey())
|
|
|
+ .set(BasePo::getUpdateTime, new Date())
|
|
|
+ .set(BasePo::getUpdateUser, SecurityUtils.getUserId())
|
|
|
+ );
|
|
|
}
|
|
|
|
|
|
/**
|