From f46c08a6435cd2644037e699e143854fac8fa168 Mon Sep 17 00:00:00 2001 From: wangguorui <2069821375@qq.com> Date: Thu, 5 Mar 2026 17:42:58 +0800 Subject: [PATCH] =?UTF-8?q?20260305=E5=88=9B=E5=BB=BA=E9=92=B1=E5=8C=85?= =?UTF-8?q?=E6=98=8E=E7=BB=86=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/example/demo/mapper/cash/CashCollectionMapper.java | 10 +++++----- .../demo/serviceImpl/cash/CashCollectionServiceImpl.java | 14 ++++++++++++-- src/main/resources/cashMapper/CashCollectionMapper.xml | 10 ++++++++-- 3 files changed, 25 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/example/demo/mapper/cash/CashCollectionMapper.java b/src/main/java/com/example/demo/mapper/cash/CashCollectionMapper.java index 734fe37..b27d832 100644 --- a/src/main/java/com/example/demo/mapper/cash/CashCollectionMapper.java +++ b/src/main/java/com/example/demo/mapper/cash/CashCollectionMapper.java @@ -2,10 +2,7 @@ package com.example.demo.mapper.cash; //import com.example.demo.domain.DTO.PaymentDTO; import com.example.demo.domain.DTO.*; -import com.example.demo.domain.entity.CashRecord; -import com.example.demo.domain.entity.GOrder; -import com.example.demo.domain.entity.RechargeActivity; -import com.example.demo.domain.entity.UserRegionWallet; +import com.example.demo.domain.entity.*; import com.example.demo.domain.vo.cash.CashCollection; import com.example.demo.domain.vo.cash.PerformanceVO; import org.apache.ibatis.annotations.Mapper; @@ -32,7 +29,7 @@ public interface CashCollectionMapper { String getMarketByJwcode(@Param("jwcode") Integer jwcode); //新增收款订单 void add(CashRecord cashRecord); - //根据订单号获取订单id,状态 + //根据订单号获取订单id、状态、钱包id、永久金币数量、精网号和备注 CashRecord selectByOrderCode(@Param("orderCode") String orderCode); //更新订单状态 int updateStatus(@Param("orderCode") String orderCode, @@ -110,4 +107,7 @@ public interface CashCollectionMapper { // 插入或更新用户钱包记录 void insertUserWallet(UserRegionWallet userRegionWallet); + + // 插入用户钱包明细记录 + void insertUserWalletRecord(UserWalletRecord userWalletRecord); } diff --git a/src/main/java/com/example/demo/serviceImpl/cash/CashCollectionServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/cash/CashCollectionServiceImpl.java index 7b1db1b..43bef89 100644 --- a/src/main/java/com/example/demo/serviceImpl/cash/CashCollectionServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/cash/CashCollectionServiceImpl.java @@ -123,8 +123,6 @@ public class CashCollectionServiceImpl implements CashCollectionService { cashRecord.setPermanentGold(cashCollection.getPermanentGold()); //永久金币 cashRecord.setFreeGold(cashCollection.getFreeGold()); //免费金币 cashRecord.setWalletId(cashCollection.getWalletId()); // 钱包 ID - // 打印钱包 ID - log.info("钱包ID:{}", cashRecord.getWalletId()); cashRecord.setPaymentCurrency(cashCollection.getPaymentCurrency()); //付款币种 cashRecord.setPaymentAmount(cashCollection.getPaymentAmount()); //付款金额 cashRecord.setReceivedMarket(cashCollection.getReceivedMarket()); //到账地区 @@ -425,6 +423,18 @@ public class CashCollectionServiceImpl implements CashCollectionService { log.info("充值成功:jwcode={}, walletId={}, 增加金币={}", jwcode, walletId, permanentGold); } + + // 创建钱包明细记录 + UserWalletRecord walletRecord = new UserWalletRecord(); + walletRecord.setJwcode(jwcode); + walletRecord.setWalletId(walletId); + walletRecord.setType(0); // 0=充值 + walletRecord.setAmount(permanentGold); + walletRecord.setOrderCode(cashRecord.getOrderCode()); + walletRecord.setDescription(dbRecord.getRemark() != null ? dbRecord.getRemark() : "金币充值"); + walletRecord.setStatus(0); // 0=正常 + cashCollectionMapper.insertUserWalletRecord(walletRecord); + } catch (Exception e) { log.error("充值钱包失败:jwcode={}, walletId={}, error={}", jwcode, walletId, e.getMessage(), e); diff --git a/src/main/resources/cashMapper/CashCollectionMapper.xml b/src/main/resources/cashMapper/CashCollectionMapper.xml index 46fe61f..51e9800 100644 --- a/src/main/resources/cashMapper/CashCollectionMapper.xml +++ b/src/main/resources/cashMapper/CashCollectionMapper.xml @@ -119,9 +119,9 @@ - + @@ -414,6 +414,12 @@ update_time = NOW() + + + INSERT INTO user_wallet_record (jwcode, wallet_id, type, amount, order_code, description, status, create_time) + VALUES (#{jwcode}, #{walletId}, #{type}, #{amount}, #{orderCode}, #{description}, #{status}, NOW()) + + update cash_record_collection