From 4fc4e894889df418824f95c7bafb934c37b06365 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Mon, 04 Aug 2025 10:58:03 +0800 Subject: [PATCH] feat(ai): 添加角色列表接口并调整数据库连接 --- src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java | 20 ++++++++++++++++++++ 1 files changed, 20 insertions(+), 0 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 306ae07..bc97182 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java @@ -138,4 +138,24 @@ log.error("核销活动门票异常", e); } } + + @RabbitListener(queues = QueueConstants.CLOTHES_ADD_LIKE) + public void getAddLike(Long socialId) { + log.info("点赞:{}", socialId); + try { + happyActivityService.getAddLike(socialId); + } catch (Exception e) { + log.error("点赞异常", e); + } + } + + @RabbitListener(queues = QueueConstants.CLOTHES_ADD_COLLECT) + public void getAddCollect(Long socialId) { + log.info("收藏:{}", socialId); + try { + happyActivityService.getAddCollect(socialId); + } catch (Exception e) { + log.error("收藏异常", e); + } + } } -- Gitblit v1.9.1