|
@@ -30,6 +30,7 @@ import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
|
|
|
+import java.math.BigDecimal;
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
@@ -133,7 +134,7 @@ public class MerchantServiceImpl implements IMerchantService {
|
|
|
}
|
|
}
|
|
|
VaultsResponse<String> openModifyVault = this.merchantOpenModify(dto);
|
|
VaultsResponse<String> openModifyVault = this.merchantOpenModify(dto);
|
|
|
|
|
|
|
|
- VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt(),basicConfig.getCode());
|
|
|
|
|
|
|
+ VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt(),basicConfig.getCode(),dto.getProportion());
|
|
|
if(!stringVault.validate()){
|
|
if(!stringVault.validate()){
|
|
|
log.info("stringVault==="+stringVault);
|
|
log.info("stringVault==="+stringVault);
|
|
|
return stringVault;
|
|
return stringVault;
|
|
@@ -175,7 +176,7 @@ public class MerchantServiceImpl implements IMerchantService {
|
|
|
return entregisterVault;
|
|
return entregisterVault;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),3,dto.getRemained_amt(),basicConfig.getCode());
|
|
|
|
|
|
|
+ updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),3,dto.getRemained_amt(),basicConfig.getCode(),dto.getProportion());
|
|
|
}else{
|
|
}else{
|
|
|
VaultsResponse<String> indvmodifyVault = this.modifyVault(dto);
|
|
VaultsResponse<String> indvmodifyVault = this.modifyVault(dto);
|
|
|
if(!indvmodifyVault.validate()){
|
|
if(!indvmodifyVault.validate()){
|
|
@@ -191,7 +192,7 @@ public class MerchantServiceImpl implements IMerchantService {
|
|
|
return openVault;
|
|
return openVault;
|
|
|
}
|
|
}
|
|
|
// if(status != 2){
|
|
// if(status != 2){
|
|
|
- VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt(),basicConfig.getCode());
|
|
|
|
|
|
|
+ VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt(),basicConfig.getCode(),dto.getProportion());
|
|
|
|
|
|
|
|
if(!stringVault.validate()){
|
|
if(!stringVault.validate()){
|
|
|
log.info("stringVault==="+stringVault);
|
|
log.info("stringVault==="+stringVault);
|
|
@@ -255,7 +256,7 @@ public class MerchantServiceImpl implements IMerchantService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if(YmUtil.SUCCESS.equals(back.getResult().getId())){
|
|
if(YmUtil.SUCCESS.equals(back.getResult().getId())){
|
|
|
- VaultsResponse vaultsResponse = updateMerchantId(dto.getId(), dto.getSourceId(), back.getMerchant_id(),0,dto.getRemained_amt(),bc.getCode());
|
|
|
|
|
|
|
+ VaultsResponse vaultsResponse = updateMerchantId(dto.getId(), dto.getSourceId(), back.getMerchant_id(),0,dto.getRemained_amt(),bc.getCode(),dto.getProportion());
|
|
|
if(!vaultsResponse.validate()){
|
|
if(!vaultsResponse.validate()){
|
|
|
return vaultsResponse;
|
|
return vaultsResponse;
|
|
|
}
|
|
}
|
|
@@ -264,7 +265,7 @@ public class MerchantServiceImpl implements IMerchantService {
|
|
|
return VaultsResponse.failed(back.getResult().getComment());
|
|
return VaultsResponse.failed(back.getResult().getComment());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private VaultsResponse updateMerchantId(Integer id, Integer source, String merchantId,Integer status,Long remainedAmt,String code) {
|
|
|
|
|
|
|
+ private VaultsResponse updateMerchantId(Integer id, Integer source, String merchantId, Integer status, Long remainedAmt, String code, BigDecimal proportion) {
|
|
|
VaultsResponse vaultsResponse;
|
|
VaultsResponse vaultsResponse;
|
|
|
OperatorIdParams operatorIdParams = new OperatorIdParams();
|
|
OperatorIdParams operatorIdParams = new OperatorIdParams();
|
|
|
operatorIdParams.setOperatorId(TokenContext.cureOperatorId());
|
|
operatorIdParams.setOperatorId(TokenContext.cureOperatorId());
|
|
@@ -277,6 +278,7 @@ public class MerchantServiceImpl implements IMerchantService {
|
|
|
if(source.equals(3)){
|
|
if(source.equals(3)){
|
|
|
vaultsResponse = customerFeignClient.updateMerchantId(operatorIdParams);
|
|
vaultsResponse = customerFeignClient.updateMerchantId(operatorIdParams);
|
|
|
}else{
|
|
}else{
|
|
|
|
|
+ operatorIdParams.setProportion(proportion);
|
|
|
vaultsResponse = partnerFeignClient.updateMerchantId(operatorIdParams);
|
|
vaultsResponse = partnerFeignClient.updateMerchantId(operatorIdParams);
|
|
|
}
|
|
}
|
|
|
|
|
|