From b87c5549fe471167882192944db3f2d6b729476c Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 15 Mar 2024 14:13:55 +0800 Subject: [PATCH] 抽奖 --- src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java | 62 +++++++++++------------------- 1 files changed, 23 insertions(+), 39 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java index cdadcb4..47bd6ee 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java @@ -1,13 +1,9 @@ package cc.mrbird.febs.rabbit.consumer; -import cc.mrbird.febs.mall.service.IAgentService; -import cc.mrbird.febs.mall.service.IApiMallOrderInfoService; -import cc.mrbird.febs.mall.service.IMemberProfitService; +import cc.mrbird.febs.mall.dto.OpenPrice; +import cc.mrbird.febs.mall.service.CJService; import cc.mrbird.febs.rabbit.constants.QueueConstants; -import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum; -import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; -import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -23,54 +19,42 @@ public class AgentConsumer { @Autowired - private IApiMallOrderInfoService orderInfoService; - @Autowired - private IAgentService agentService; - @Autowired - private IMemberProfitService memberProfitService; + private CJService cjService; - @RabbitListener(queues = QueueConstants.QUEUE_DEFAULT) - public void agentReturn(Message message, Channel channel) { - log.info("消费者:{}", new String(message.getBody())); - } + @RabbitListener(queues = QueueConstants.QUEUE_CHOU_JIANG_TIME) + public void getChouJiangDelayMsg(String kjNo) { - @RabbitListener(queues = "queue_order_delay") - public void orderCancelDelay(String id) { + log.info("收到延时开奖信息消息,编号:{}",kjNo); try { - orderInfoService.autoCancelOrder(Long.parseLong(id)); + cjService.getChouJiangDelayMsg(kjNo); } catch (Exception e) { - log.error("订单超时支付异常", e); + log.error("延时开奖异常", e); + // todo 更新表 + } } - @RabbitListener(queues = QueueConstants.AGENT_AUTO_LEVEL_UP) - public void agentAutoLevelUp(String id) { - log.info("收到代理自动升级消息:{}", id); + @RabbitListener(queues = QueueConstants.QUEUE_NO_TIME) + public void getNoTimeDelayMsg(String kjNo) { + log.info("收到停止下注消息,编号:{}",kjNo); try { - agentService.autoUpAgentLevel(Long.parseLong(id)); + cjService.getNoTimeDelayMsg(kjNo); } catch (Exception e) { - log.error("代理自动升级异常", e); + log.error("停止下注异常", e); + // todo 更新表 + } } - @RabbitListener(queues = QueueConstants.AGENT_RETURN_MONEY) - public void agentReturnMoney(String orderId) { - log.info("收到返利消息:{}", orderId); + @RabbitListener(queues = QueueConstants.QUEUE_OPEN_PRICE) + public void getOpenPriceMsg(OpenPrice openPrice) { + log.info("收到开奖信息:{}, {}", openPrice.getKjNo(), openPrice.getKjNum()); try { - agentService.returnMoneyToAgent(Long.parseLong(orderId)); + cjService.getOpenPriceMsg(openPrice.getKjNo(), openPrice.getKjNum()); } catch (Exception e) { - log.error("返利异常", e); - } - } + log.error("开奖信息异常", e); + // todo 更新表 - @RabbitListener(queues = QueueConstants.ORDER_RETURN_MONEY) - public void orderReturnMoney(String orderId) { - log.info("收到订单返利消息:{}", orderId); - - try { - memberProfitService.dynamicProfit(Long.parseLong(orderId)); - } catch (Exception e) { - log.error("订单返利异常:{}", e); } } } -- Gitblit v1.9.1