From 8aeace39730be9a37b656fde59de912156e14f51 Mon Sep 17 00:00:00 2001 From: wangguorui <2069821375@qq.com> Date: Thu, 29 Jan 2026 15:46:38 +0800 Subject: [PATCH] =?UTF-8?q?1=E6=9C=8829=E6=97=A5=EF=BC=8C=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=8E=A8=E9=80=81=E9=87=91=E5=B8=81=E6=94=B6=E6=AC=BE?= =?UTF-8?q?=E9=80=80=E6=AC=BE=E8=B7=B3=E8=BD=ACid-=E7=BB=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/example/demo/RabbitMQ/CoinRechargeAspect.java | 1 + src/main/java/com/example/demo/mapper/coin/OperationLogMapper.java | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/example/demo/RabbitMQ/CoinRechargeAspect.java b/src/main/java/com/example/demo/RabbitMQ/CoinRechargeAspect.java index 897aaf3..61bc9b4 100644 --- a/src/main/java/com/example/demo/RabbitMQ/CoinRechargeAspect.java +++ b/src/main/java/com/example/demo/RabbitMQ/CoinRechargeAspect.java @@ -81,6 +81,7 @@ public class CoinRechargeAspect { messageDTO.setName(name); messageDTO.setTitle(action); messageDTO.setDesc(username + "有一条金币充值消息需要处理"); + messageDTO.setQueryId(6); // ✅ 发送消息到 RabbitMQ（不等待） try { diff --git a/src/main/java/com/example/demo/mapper/coin/OperationLogMapper.java b/src/main/java/com/example/demo/mapper/coin/OperationLogMapper.java index 5f55848..a107ed5 100644 --- a/src/main/java/com/example/demo/mapper/coin/OperationLogMapper.java +++ b/src/main/java/com/example/demo/mapper/coin/OperationLogMapper.java @@ -10,7 +10,8 @@ public interface OperationLogMapper { @Insert("INSERT INTO operation_log (user_id, username, action, ip, method, args, create_time) " + "VALUES (#{userId}, #{username}, #{action}, #{ip}, #{method}, #{args}, NOW())") void insertLog(OperationLog log); - @Insert("INSERT INTO message (jwcode, name, title, `desc`, status,type,type_id,market) "+" VALUES (#{jwcode}, #{name}, #{title}, #{desc},#{status},#{type},#{typeId},#{market})") + @Insert("INSERT INTO message (jwcode, name, title, `desc`, status, type, type_id, market, query_id) " + + "VALUES (#{jwcode}, #{name}, #{title}, #{desc}, #{status}, #{type}, #{typeId}, #{market}, #{queryId})") void insertMessage(Messages message); @Options( useGeneratedKeys = true, // ✅ 告诉 MyBatis 使用数据库生成的主键