From e492c5f2db41ac604672e009eeaa066ae9bd9a89 Mon Sep 17 00:00:00 2001
From: wangguorui <2069821375@qq.com>
Date: Fri, 10 Apr 2026 14:18:39 +0800
Subject: [PATCH] =?UTF-8?q?20260410=20=E5=AE=A1=E6=A0=B8=E6=8F=90=E4=BA=A4?=
 =?UTF-8?q?=E6=94=AF=E4=BB=98=E5=B8=81=E7=A7=8D=E6=98=A0=E5=B0=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/example/demo/mapper/coin/RateMapper.java     |  2 ++
 .../example/demo/serviceImpl/cash/CashAuditServiceImpl.java    | 10 +++++++++-
 src/main/resources/mapper/RateMapper.xml                       |  3 +++
 3 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/example/demo/mapper/coin/RateMapper.java b/src/main/java/com/example/demo/mapper/coin/RateMapper.java
index 9000fe5..f836886 100644
--- a/src/main/java/com/example/demo/mapper/coin/RateMapper.java
+++ b/src/main/java/com/example/demo/mapper/coin/RateMapper.java
@@ -17,4 +17,6 @@ public interface RateMapper {
     void add(Rate rate);
     //获取货币名称列表
     List<Rate> listRateName();
+
+    Integer getIdByName(String rateName);
 }
diff --git a/src/main/java/com/example/demo/serviceImpl/cash/CashAuditServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/cash/CashAuditServiceImpl.java
index 8b305de..eb97fcc 100644
--- a/src/main/java/com/example/demo/serviceImpl/cash/CashAuditServiceImpl.java
+++ b/src/main/java/com/example/demo/serviceImpl/cash/CashAuditServiceImpl.java
@@ -10,6 +10,7 @@ import com.example.demo.mapper.cash.CashAuditMapper;
 import com.example.demo.mapper.cash.CashCollectionMapper;
 import com.example.demo.mapper.coin.AuditMapper;
 import com.example.demo.mapper.coin.MarketMapper;
+import com.example.demo.mapper.coin.RateMapper;
 import com.example.demo.mapper.coin.RechargeMapper;
 import com.example.demo.service.cash.CashAuditService;
 import lombok.extern.slf4j.Slf4j;
@@ -49,6 +50,8 @@ public class CashAuditServiceImpl implements CashAuditService {
     private RabbitTemplate rabbitTemplate;
     @Autowired
     private MarketMapper marketMapper;
+    @Autowired
+    private RateMapper rateMapper;
 
 
     @Transactional
@@ -92,7 +95,12 @@ public class CashAuditServiceImpl implements CashAuditService {
                     rechargeOrder.setFreeDecember(order.getFreeGold());
                 }
                 rechargeOrder.setSumGold(order.getPermanentGold() + order.getFreeGold());
-                rechargeOrder.setRateId(Integer.valueOf(order.getPaymentCurrency()));
+                Integer rateId = rateMapper.getIdByName(order.getPaymentCurrency());
+                if (rateId == null) {
+                    log.warn("未找到币种 '{}' 对应的ID，使用默认值0", order.getPaymentCurrency());
+                    rateId = 0;
+                }
+                rechargeOrder.setRateId(rateId);
                 rechargeOrder.setMoney(order.getPaymentAmount().intValue());
                 rechargeOrder.setRemark(order.getRemark());
                 rechargeOrder.setVoucher(order.getVoucher());
diff --git a/src/main/resources/mapper/RateMapper.xml b/src/main/resources/mapper/RateMapper.xml
index b6870ed..3e5e8da 100644
--- a/src/main/resources/mapper/RateMapper.xml
+++ b/src/main/resources/mapper/RateMapper.xml
@@ -16,6 +16,9 @@
         FROM rate
     </select>
 
+    <select id="getIdByName" resultType="java.lang.Integer">
+        SELECT id FROM rate WHERE rate_name = #{rateName}
+    </select>
 
     <update id="update">
         UPDATE