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();