Преглед изворни кода

新增物流结算更新对账已结算金额字段

sptkw пре 2 година
родитељ
комит
30ce6c656b

+ 8 - 0
sckw-modules/sckw-payment/src/main/java/com/sckw/payment/service/KwpSettlementOfflineService.java

@@ -12,6 +12,7 @@ import com.sckw.core.utils.IdWorker;
 import com.sckw.core.web.context.LoginUserHolder;
 import com.sckw.order.api.dubbo.TradeOrderInfoService;
 import com.sckw.order.api.model.UpdateOrderStatusParam;
+import com.sckw.payment.dao.KwpLedgerLogisticsMapper;
 import com.sckw.payment.dao.KwpSettlementLogisticsMapper;
 import com.sckw.payment.dao.KwpSettlementLogisticsTrackMapper;
 import com.sckw.payment.dao.KwpSettlementOfflineMapper;
@@ -53,6 +54,7 @@ import java.util.stream.Collectors;
 @Slf4j
 @RequiredArgsConstructor
 public class KwpSettlementOfflineService {
+    private final KwpLedgerLogisticsMapper kwpLedgerLogisticsMapper;
     private final KwpSettlementOfflineMapper settlementOfflineMapper;
     private final KwpSettlementTradeService settlementTradeService;
     private final KwpLedgerTradeOrderService tradeOrderService;
@@ -199,6 +201,12 @@ public class KwpSettlementOfflineService {
             kwpSettlementLogisticsTrack.setDelFlag(0);
             kwpSettlementLogisticsTrackMapper.insert(kwpSettlementLogisticsTrack);
 
+            //需要将更新金额同步到对应的对账表中
+            KwpLedgerLogistics kwpLedgerLogistics = new KwpLedgerLogistics();
+            kwpLedgerLogistics.setId(settlementLogisticsDto.getLLedgerId());
+            kwpLedgerLogistics.setActualPrice(settlementLogistics.getActualPrice());
+            kwpLedgerLogisticsMapper.updateById(kwpLedgerLogistics);
+
             //新增一条线下结算记录
             //当前剩余金额
             remainingReceivables = remainingReceivables.subtract(price);

+ 8 - 0
sckw-modules/sckw-payment/src/main/java/com/sckw/payment/service/KwpSettlementWalletService.java

@@ -16,6 +16,7 @@ import com.sckw.order.api.model.UpdateOrderStatusParam;
 import com.sckw.payment.api.model.constant.ChannelEnum;
 import com.sckw.payment.api.model.dto.WalletDto;
 import com.sckw.payment.api.model.dto.common.R;
+import com.sckw.payment.dao.KwpLedgerLogisticsMapper;
 import com.sckw.payment.dao.KwpSettlementLogisticsMapper;
 import com.sckw.payment.dao.KwpSettlementLogisticsTrackMapper;
 import com.sckw.payment.dao.KwpSettlementWalletMapper;
@@ -59,6 +60,7 @@ import java.util.stream.Collectors;
 @Slf4j
 @RequiredArgsConstructor
 public class KwpSettlementWalletService {
+    private final KwpLedgerLogisticsMapper kwpLedgerLogisticsMapper;
     private final KwpSettlementWalletMapper settlementWalletMapper;
     private final KwpSettlementLogisticsMapper kwpSettlementLogisticsMapper;
     private final KwpLedgerTradeOrderService tradeOrderService;
@@ -229,6 +231,12 @@ public class KwpSettlementWalletService {
             kwpSettlementWallet.setDelFlag(0);
             Integer insertKwpSettlementWallet = settlementWalletMapper.insert(kwpSettlementWallet);
             log.info("新增一条电子钱包结算记录:" + insertKwpSettlementWallet);
+            //需要将金额同步到对应的对账表中
+            KwpLedgerLogistics kwpLedgerLogistics = new KwpLedgerLogistics();
+            kwpLedgerLogistics.setId(settlementLogisticsDto.getLLedgerId());
+            kwpLedgerLogistics.setActualPrice(settlementLogistics.getActualPrice());
+            kwpLedgerLogisticsMapper.updateById(kwpLedgerLogistics);
+
             //物流货到付款电子钱包逻辑
             //todo 待处理费电子钱包逻辑