| | |
| | | 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; |
| | |
| | | private HappyActivityService happyActivityService; |
| | | @Autowired |
| | | private AiKnowledgeFileService aiKnowledgeFileService; |
| | | @Autowired |
| | | private AiProductQuestionService aiProductQuestionService; |
| | | |
| | | // @RabbitListener(queues = QueueConstants.QUEUE_DEFAULT) |
| | | // public void agentReturn(Message message, Channel channel) { |
| | |
| | | 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); |
| | | } |
| | | } |
| | | } |