admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加日志

Browse Source
This commit is contained in:
mliu71
2025-07-21 14:34:39 +08:00
parent 5f5a578612
commit 7780c7b37a
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiAnalysisDifyController.java
View File

@@ -11,6 +11,7 @@ import com.volvo.ai.analytic.center.dto.req.AnalysisReq;
import com.volvo.ai.analytic.center.dto.req.ConsultingRequestDTO;
import com.volvo.ai.analytic.center.dto.resp.AnalysisResp;
import com.volvo.ai.analytic.center.service.AiAnalysisDifyService;
import com.volvo.ai.analytic.center.service.CorpusQuestionService;
import com.volvo.ai.analytic.center.service.impl.CorpusQuestionServiceImpl;
import com.volvo.common.core.util.ResultMsg;
import io.swagger.annotations.Api;
@@ -37,7 +38,7 @@ public class AiAnalysisDifyController {
private AiAnalysisDifyService aiAnalysisDifyService;
@Autowired
private CorpusQuestionServiceImpl corpusQuestionServiceImpl;
private CorpusQuestionService corpusQuestionService;
@PostMapping("/updateByAiId")
@ApiOperation(value = "更新dify结果")
@@ -85,7 +86,7 @@ public class AiAnalysisDifyController {
@RequestBody ConsultingRequestDTO requestDTO) {
log.info("aiAnalyze corpusQuestion requestDTO: {} ,appKey:{}", JSON.toJSONString(requestDTO),appKey);
// 打印接收到的参数
corpusQuestionServiceImpl.runCorpusQuestionDify(requestDTO);
corpusQuestionService.runCorpusQuestionDify(requestDTO);
return AnalysisResp .success("ok");
}

6
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java
View File

@@ -1,5 +1,6 @@
package com.volvo.ai.analytic.center.mq;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.volvo.ai.analytic.center.constant.Constant;
import com.volvo.ai.analytic.center.feign.DiFyFeign;
@@ -21,7 +22,7 @@ import java.util.Map;
public class CorpusQuestionConsumer implements RocketMQListener<Map<String, Object>> {
@Value("${dify.corpusQuestion.token: app-erbXevAmaQiyg5QFPn2NpJ7G}")
@Value("${dify.corpusQuestion.token:app-erbXevAmaQiyg5QFPn2NpJ7G}")
private String corpusQuestionToken;
@@ -30,8 +31,9 @@ public class CorpusQuestionConsumer implements RocketMQListener<Map<String, Obje
@Override
public void onMessage(Map<String, Object> inputMap) {
inputMap.put("businessType", Constant.CHANNEL_4IN1);
log.info("corpusQuestionConsumer {}", JSON.toJSONString(inputMap));
log.info("corpusQuestionToken {}", corpusQuestionToken);
JSONObject difyResult = diFyFeign.runWorkflows("Bearer " + corpusQuestionToken, inputMap);
log.info("difyResult {}", difyResult.toJSONString());
}