Browse Source

1月29日,消息推送金币收款退款跳转id-续

lijianlin/feature-20260128-金币日常优化V1.0
wangguorui 4 weeks ago
parent
commit
8aeace3973
  1. 1
      src/main/java/com/example/demo/RabbitMQ/CoinRechargeAspect.java
  2. 3
      src/main/java/com/example/demo/mapper/coin/OperationLogMapper.java

1
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 {

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

Loading…
Cancel
Save