Administrator
1 days ago d3492864ec22a30e9fcc99b2b174cf6eb9531399
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -1,6 +1,7 @@
package cc.mrbird.febs.rabbit.consumer;
import cc.mrbird.febs.ai.service.AiKnowledgeFileService;
import cc.mrbird.febs.ai.service.AiProductQuestionService;
import cc.mrbird.febs.mall.service.*;
import cc.mrbird.febs.rabbit.constants.QueueConstants;
import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum;
@@ -37,6 +38,8 @@
    private HappyActivityService happyActivityService;
    @Autowired
    private AiKnowledgeFileService aiKnowledgeFileService;
    @Autowired
    private AiProductQuestionService aiProductQuestionService;
//    @RabbitListener(queues = QueueConstants.QUEUE_DEFAULT)
//    public void agentReturn(Message message, Channel channel) {
@@ -173,4 +176,14 @@
            log.error("知识库异常", e);
        }
    }
    @RabbitListener(queues = QueueConstants.QUESTION_ADD_ALI)
    public void getAddQuestion(String id) {
        log.info("题目生成:{}", id);
        try {
            aiProductQuestionService.getAddQuestion(id);
        } catch (Exception e) {
            log.error("知识库异常", e);
        }
    }
}