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 使用数据库生成的主键