|
@@ -87,6 +87,7 @@ import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.dubbo.config.annotation.DubboReference;
|
|
import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
import org.jetbrains.annotations.NotNull;
|
|
import org.jetbrains.annotations.NotNull;
|
|
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.cloud.stream.function.StreamBridge;
|
|
import org.springframework.cloud.stream.function.StreamBridge;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
@@ -136,7 +137,8 @@ public class KwoTradeOrderService {
|
|
|
@DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
|
|
@DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
|
|
|
protected RemoteFleetService remoteFleetService;
|
|
protected RemoteFleetService remoteFleetService;
|
|
|
|
|
|
|
|
- private final OfflineWalletFeignService offlineWalletFeignService;
|
|
|
|
|
|
|
+ @Autowired(required = false)
|
|
|
|
|
+ private OfflineWalletFeignService offlineWalletFeignService;
|
|
|
|
|
|
|
|
private final KwoTradeOrderMapper kwoTradeOrderMapper;
|
|
private final KwoTradeOrderMapper kwoTradeOrderMapper;
|
|
|
private final StreamBridge streamBridge;
|
|
private final StreamBridge streamBridge;
|
|
@@ -2185,6 +2187,9 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
private void walletFreeze(TradeOrderParam tradeOrderParam, KwoTradeOrder order,WalletFreezeDto freezeDto) {
|
|
private void walletFreeze(TradeOrderParam tradeOrderParam, KwoTradeOrder order,WalletFreezeDto freezeDto) {
|
|
|
|
|
+ if (offlineWalletFeignService == null) {
|
|
|
|
|
+ throw new BusinessException("线下钱包服务未配置,无法执行冻结操作");
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
freezeDto.setFreezeAmount(tradeOrderParam.getAmount());
|
|
freezeDto.setFreezeAmount(tradeOrderParam.getAmount());
|
|
|
freezeDto.setOrderNo(order.getTOrderNo());
|
|
freezeDto.setOrderNo(order.getTOrderNo());
|
|
@@ -2206,6 +2211,9 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
private void checkWallet(KwoTradeOrder order) {
|
|
private void checkWallet(KwoTradeOrder order) {
|
|
|
|
|
+ if (offlineWalletFeignService == null) {
|
|
|
|
|
+ throw new BusinessException("线下钱包服务未配置,无法查询余额");
|
|
|
|
|
+ }
|
|
|
BaseResult<BigDecimal> balanceResult;
|
|
BaseResult<BigDecimal> balanceResult;
|
|
|
try {
|
|
try {
|
|
|
balanceResult = offlineWalletFeignService.queryPrepaidBalance(LoginUserHolder.getEntId());
|
|
balanceResult = offlineWalletFeignService.queryPrepaidBalance(LoginUserHolder.getEntId());
|
|
@@ -2256,6 +2264,9 @@ public class KwoTradeOrderService {
|
|
|
freezeDto.setFreezeAmount(param.getFreezeAmount());
|
|
freezeDto.setFreezeAmount(param.getFreezeAmount());
|
|
|
freezeDto.setOrderNo(order.getTOrderNo());
|
|
freezeDto.setOrderNo(order.getTOrderNo());
|
|
|
|
|
|
|
|
|
|
+ if (offlineWalletFeignService == null) {
|
|
|
|
|
+ throw new BusinessException("线下钱包服务未配置,无法执行解冻操作");
|
|
|
|
|
+ }
|
|
|
BaseResult<Boolean> balanceResult;
|
|
BaseResult<Boolean> balanceResult;
|
|
|
try {
|
|
try {
|
|
|
balanceResult = offlineWalletFeignService.unfreezeBalance(freezeDto);
|
|
balanceResult = offlineWalletFeignService.unfreezeBalance(freezeDto);
|