From 720f01de2da536fbd926711dce3091596b8866b0 Mon Sep 17 00:00:00 2001
From: mliu71 <min.liu.3@volvocars.com>
Date: Thu, 24 Jul 2025 18:06:58 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=AD=E6=96=99=E7=BB=93=E6=9E=9C=E5=88=86?=
 =?UTF-8?q?=E6=9E=90=E5=85=A5=E5=8F=82=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/AiAnalysisDifyController.java  | 24 +++++++++++++------
 1 file changed, 17 insertions(+), 7 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiAnalysisDifyController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiAnalysisDifyController.java
index ffb5f4e..8cf1dd9 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiAnalysisDifyController.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiAnalysisDifyController.java
@@ -1,7 +1,6 @@
 package com.volvo.ai.analytic.center.controller;
 
 
-import com.alibaba.fastjson.JSON;
 import com.fasterxml.jackson.core.JsonParser;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.DeserializationFeature;
@@ -17,12 +16,11 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 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.messaging.handler.annotation.Header;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 
 @RestController()
@@ -38,6 +36,9 @@ public class AiAnalysisDifyController {
     @Autowired
     private UserQuestionSummaryService userQuestionSummaryService;
 
+    @Value("${rocketmq.producer.corpus.dcctopic}")
+    private String corpusQuestionAppKey;
+
     @PostMapping("/updateByAiId")
     @ApiOperation(value = "更新dify结果")
     public ResultMsg<Object> updateByAiId(@RequestBody String message) {
@@ -80,9 +81,18 @@ public class AiAnalysisDifyController {
 
     @PostMapping("/corpusSummaryQuestion")
     @ApiOperation(value = "单条语料分析结论入库")
-    public AnalysisResp<Object> corpusSummaryQuestion(@RequestBody SummaryQuestionRequestDTO requestDTO) {
-        log.info("aiAnalyze corpusSummaryQuestion requestDTO: {}", JSON.toJSONString(requestDTO));
+    public AnalysisResp<Object> corpusSummaryQuestion(
+            @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);
         return AnalysisResp.success("ok");
     }