From d68e2f99592dc982a722d031219f1d0b4f87ed00 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Tue, 02 Sep 2025 10:11:05 +0800 Subject: [PATCH] feat(ai): 新增 AI 流式回答功能 V3 版本 --- 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