Browse Source

1月29日,消息推送金币收款退款

huangqizheng/feature-20260129114800-验证码
wangguorui 4 weeks ago
parent
commit
4e48bda18f
  1. 2
      src/main/java/com/example/demo/domain/vo/coin/Messages.java
  2. 2
      src/main/java/com/example/demo/serviceImpl/coin/RechargeServiceImpl.java
  3. 2
      src/main/java/com/example/demo/serviceImpl/coin/RefundServiceImpl.java

2
src/main/java/com/example/demo/domain/vo/coin/Messages.java

@ -33,6 +33,6 @@ public class Messages {
private Integer market; private Integer market;
private Integer flag; private Integer flag;
private String marketName; private String marketName;
private Integer menuId;
private Integer queryId;
} }

2
src/main/java/com/example/demo/serviceImpl/coin/RechargeServiceImpl.java

@ -164,7 +164,7 @@ public class RechargeServiceImpl implements RechargeService {
message.setMarket(Integer.valueOf(goldUser.getMarket())); message.setMarket(Integer.valueOf(goldUser.getMarket()));
String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket())); String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
message.setMarketName(marketName); message.setMarketName(marketName);
message.setMenuId(6);
message.setQueryId(6);
// 发送到RabbitMQ // 发送到RabbitMQ
rabbitTemplate.convertAndSend(RabbitMQConfig.COIN_RECHARGE_EXCHANGE, "coin.recharge.save", message); rabbitTemplate.convertAndSend(RabbitMQConfig.COIN_RECHARGE_EXCHANGE, "coin.recharge.save", message);

2
src/main/java/com/example/demo/serviceImpl/coin/RefundServiceImpl.java

@ -239,7 +239,7 @@ public class RefundServiceImpl implements RefundService {
message.setMarket(Integer.valueOf(goldUser.getMarket())); message.setMarket(Integer.valueOf(goldUser.getMarket()));
String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket())); String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
message.setMarketName(marketName); message.setMarketName(marketName);
message.setMenuId(13);
message.setQueryId(13);
// 发送到RabbitMQ // 发送到RabbitMQ
rabbitTemplate.convertAndSend(RabbitMQConfig.COIN_REFUND_EXCHANGE, "coin.refund.save", message); rabbitTemplate.convertAndSend(RabbitMQConfig.COIN_REFUND_EXCHANGE, "coin.refund.save", message);

Loading…
Cancel
Save