后台修改

KKSU

2024-03-26 152b3c50a6cb3c433b033b551e09d6f2249f5d60

 src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java

@@ -39,4 +39,28 @@
        log.info("收到用户购买奖励消息:{}", id);
        dappSystemService.userBuyReward(Long.parseLong(id));
    }

    @RabbitListener(queues = QueueConstants.QUEUE_GFA_ZY_TIME)
    public void getZhiYaDelayMsg(Long achieveId) {
        log.info("收到延时质押消息,编号:{}",achieveId);
        try {
            dappSystemService.getZhiYaDelayMsg(achieveId);
        } catch (Exception e) {
            log.error("延时开奖异常", e);
            // todo 更新表

        }
    }

    @RabbitListener(queues = QueueConstants.QUEUE_GFA_ZY_TIME_FLOW)
    public void getZhiYaDelayMsgFlow(Long flowId) {
        log.info("收到延时质押流水消息,编号:{}",flowId);
        try {
            dappSystemService.getZhiYaDelayMsgFlow(flowId);
        } catch (Exception e) {
            log.error("延时开奖异常", e);
            // todo 更新表

        }
    }
}