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-24 18:06:58 +08:00
parent 88407e3fd7
commit 720f01de2d
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,7 +1,6 @@
package com.volvo.ai.analytic.center.controller; package com.volvo.ai.analytic.center.controller;
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.core.JsonParser; import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationFeature; import com.fasterxml.jackson.databind.DeserializationFeature;
@@ -17,12 +16,11 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController() @RestController()
@@ -38,6 +36,9 @@ public class AiAnalysisDifyController {
@Autowired @Autowired
private UserQuestionSummaryService userQuestionSummaryService; private UserQuestionSummaryService userQuestionSummaryService;
@Value("${rocketmq.producer.corpus.dcctopic}")
private String corpusQuestionAppKey;
@PostMapping("/updateByAiId") @PostMapping("/updateByAiId")
@ApiOperation(value = "更新dify结果") @ApiOperation(value = "更新dify结果")
public ResultMsg<Object> updateByAiId(@RequestBody String message) { public ResultMsg<Object> updateByAiId(@RequestBody String message) {
@@ -80,9 +81,18 @@ public class AiAnalysisDifyController {
@PostMapping("/corpusSummaryQuestion") @PostMapping("/corpusSummaryQuestion")
@ApiOperation(value = "单条语料分析结论入库") @ApiOperation(value = "单条语料分析结论入库")
public AnalysisResp<Object> corpusSummaryQuestion(@RequestBody SummaryQuestionRequestDTO requestDTO) { public AnalysisResp<Object> corpusSummaryQuestion(
log.info("aiAnalyze corpusSummaryQuestion requestDTO: {}", JSON.toJSONString(requestDTO)); @Header String appKey,
@RequestParam("summaryReportId") String summaryReportId,
@RequestParam("preliminarySummaryResults") String preliminarySummaryResults) {
log.info("aiAnalyze corpusSummaryQuestion appKey={},summaryReportId={},preliminarySummaryResults={}", appKey, summaryReportId, preliminarySummaryResults);
if (!corpusQuestionAppKey.equals(appKey)) {
return AnalysisResp.failed("appKey 不正确 ");
}
// 打印接收到的参数 // 打印接收到的参数
SummaryQuestionRequestDTO requestDTO = new SummaryQuestionRequestDTO();
requestDTO.setSummaryReportId(summaryReportId);
requestDTO.setPreliminarySummaryResults(preliminarySummaryResults);
userQuestionSummaryService.updateSummery(requestDTO); userQuestionSummaryService.updateSummery(requestDTO);
return AnalysisResp.success("ok"); return AnalysisResp.success("ok");
} }