From effab9619e17b97ac98b035eaa64ba99b27f5dc6 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 14 Apr 2026 11:13:28 +0800
Subject: [PATCH] 1
---
trading-order-service/src/main/java/com/yami/trading/service/c2c/impl/C2cOrderServiceImpl.java | 22 ++++++++++++++++++++++
1 files changed, 22 insertions(+), 0 deletions(-)
diff --git a/trading-order-service/src/main/java/com/yami/trading/service/c2c/impl/C2cOrderServiceImpl.java b/trading-order-service/src/main/java/com/yami/trading/service/c2c/impl/C2cOrderServiceImpl.java
index c7c437c..10173c6 100644
--- a/trading-order-service/src/main/java/com/yami/trading/service/c2c/impl/C2cOrderServiceImpl.java
+++ b/trading-order-service/src/main/java/com/yami/trading/service/c2c/impl/C2cOrderServiceImpl.java
@@ -34,6 +34,7 @@
import com.yami.trading.service.RealNameAuthRecordService;
import com.yami.trading.service.RechargeBlockchainOrderService;
import com.yami.trading.service.WalletService;
+import com.yami.trading.service.notify.WalletTransactionMailNotificationService;
import com.yami.trading.service.c2c.C2cAdvertService;
import com.yami.trading.service.c2c.C2cOrderService;
import com.yami.trading.service.c2c.C2cPaymentMethodService;
@@ -100,6 +101,9 @@
@Autowired
LogService logService;
+
+ @Autowired
+ private WalletTransactionMailNotificationService walletTransactionMailNotificationService;
@Autowired
C2cUserService c2cUserService;
@@ -627,6 +631,24 @@
log.setLog(logStr);
log.setCreateTime(new Date());
logService.save(log);
+
+ if (order_user != null) {
+ if ("recharge".equals(c2cOrder.getDirection())) {
+ String sym = StringUtils.isEmptyString(c2cOrder.getSymbol()) ? "USDT" : c2cOrder.getSymbol().toUpperCase();
+ walletTransactionMailNotificationService.sendRechargeSuccess(
+ order_user,
+ c2cOrder.getOrderNo(),
+ BigDecimal.valueOf(c2cOrder.getCoinAmount()),
+ sym);
+ } else if ("withdraw".equals(c2cOrder.getDirection())) {
+ walletTransactionMailNotificationService.sendWithdrawSuccess(
+ order_user,
+ c2cOrder.getOrderNo(),
+ BigDecimal.valueOf(c2cOrder.getCoinAmount()),
+ BigDecimal.ZERO,
+ "USDT");
+ }
+ }
}
/**
--
Gitblit v1.9.3