xiaoyong931011
2022-11-14 5c53b4e1e7dc2bae956332a0dc446992725c80bb
src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
@@ -40,6 +40,13 @@
    @Resource
    TrxUsdtUpdateService trxUsdtUpdateService;
    @RabbitListener(queues = RabbitMqConfig.MEMBER_COIN_INSIDE_QUEUE)
    public void memberCoinInside(Long withdrawId) {
        log.info("处理用户内部转账的消息:{}#", withdrawId);
        apiIgtOnHookPlanService.memberCoinInsideMessage(withdrawId);
    }
    @RabbitListener(queues = RabbitMqConfig.END_ON_HOOK_QUEUE)
    public void endOnHook(Long orderId) {
        log.info("处理用户结束挂机的消息:{}#", orderId);