From 80b6deaed2c30fb50dc8b927bfba43ae6a250a5c Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Wed, 4 Mar 2026 18:58:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B6=85=E7=BA=A7=E5=B8=81=E5=95=86=E5=8F=91?=
 =?UTF-8?q?=E8=B4=A7=E7=BB=99=E5=B8=81=E5=95=86=20=E6=96=B0=E5=A2=9E?=
 =?UTF-8?q?=E8=B4=A7=E8=BF=90=E4=BB=A3=E7=90=86=E8=BF=9B=E8=B4=A7=E6=B5=81?=
 =?UTF-8?q?=E6=B0=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../command/freight/SendFreightShipCmdExe.java  | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java b/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java
index d2d6a692..fd81cbc5 100644
--- a/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java
+++ b/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java
@@ -139,6 +139,8 @@ public class SendFreightShipCmdExe {
                 cmd.getAcceptUserId(),
                 cmd.getQuantity()));
 
+        saveFreightInComeRunningWater(cmd, balance);
+
         String noticeContent = getNoticeContent2(cmd, cmd.getQuantity());
         officialNoticeClient.send(
                 NoticeExtTemplateCustomizeCmd.builder()
@@ -323,6 +325,21 @@ public class SendFreightShipCmdExe {
     return freightBalanceRunningWater;
   }
 
+  private FreightBalanceRunningWater saveFreightInComeRunningWater(FreightShipSendCmd cmd, BigDecimal balance) {
+    FreightBalanceRunningWater freightBalanceRunningWater = new FreightBalanceRunningWater()
+            .setSysOrigin(cmd.requireReqSysOrigin())
+            .setUserId(cmd.requiredReqUserId())
+            .setAcceptUserId(cmd.getAcceptUserId())
+            .setType(IncomeExpenditureEnum.INCOME.getValue())
+            .setQuantity(cmd.getQuantity())
+            .setOrigin(FreightBalanceOrigin.SHIPMENT.name())
+            .setBalance(balance)
+            .setUsdQuantity(getGoldToSUD(cmd))
+            .setRemark("货运代理进货");
+    freightBalanceRunningWaterService.save(freightBalanceRunningWater);
+    return freightBalanceRunningWater;
+  }
+
   private String getLockKey(FreightShipSendCmd cmd) {
     return "FREIGHT_SHIP_SEND_" + cmd.getAcceptUserId() + "_"
         + cmd.getReqUserId();