diff --git a/src/main/java/com/example/demo/domain/vo/coin/Messages.java b/src/main/java/com/example/demo/domain/vo/coin/Messages.java index b53ccda..24bf0b3 100644 --- a/src/main/java/com/example/demo/domain/vo/coin/Messages.java +++ b/src/main/java/com/example/demo/domain/vo/coin/Messages.java @@ -33,6 +33,6 @@ public class Messages { private Integer market; private Integer flag; private String marketName; - private Integer menuId; + private Integer queryId; } diff --git a/src/main/java/com/example/demo/serviceImpl/coin/RechargeServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/RechargeServiceImpl.java index 9e43a57..deb1e6e 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/RechargeServiceImpl.java +++ b/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())); String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket())); message.setMarketName(marketName); - message.setMenuId(6); + message.setQueryId(6); // 发送到RabbitMQ rabbitTemplate.convertAndSend(RabbitMQConfig.COIN_RECHARGE_EXCHANGE, "coin.recharge.save", message); diff --git a/src/main/java/com/example/demo/serviceImpl/coin/RefundServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/coin/RefundServiceImpl.java index 58f64d3..7afef8e 100644 --- a/src/main/java/com/example/demo/serviceImpl/coin/RefundServiceImpl.java +++ b/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())); String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket())); message.setMarketName(marketName); - message.setMenuId(13); + message.setQueryId(13); // 发送到RabbitMQ rabbitTemplate.convertAndSend(RabbitMQConfig.COIN_REFUND_EXCHANGE, "coin.refund.save", message);