From 93e50437dd2327d115a5050b2e328a88d517f813 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Sun, 27 Apr 2025 14:29:02 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9json=E6=A0=BC=E5=BC=8F?=
 =?UTF-8?q?=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/AiAnalysisDifyController.java  | 26 +++++++++++++++----
 1 file changed, 21 insertions(+), 5 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 51bc12c..30eceb0 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,9 +1,12 @@
 package com.volvo.ai.analytic.center.controller;
 
 
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.volvo.ai.analytic.center.dto.req.AnalysisQueryReq;
 import com.volvo.ai.analytic.center.dto.req.AnalysisReq;
-import com.volvo.ai.analytic.center.dto.resp.AnalysisDifyResultDTO;
 import com.volvo.ai.analytic.center.dto.resp.AnalysisResp;
 import com.volvo.ai.analytic.center.service.AiAnalysisDifyService;
 import com.volvo.common.core.util.ResultMsg;
@@ -14,7 +17,10 @@ import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.*;
+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;
 
 
 @RestController()
@@ -42,9 +48,19 @@ public class AiAnalysisDifyController {
 
     @PostMapping("/aiAnalyze")
     @ApiOperation(value = "Ai解析接口")
-    public AnalysisResp<Object> aiAnalyze(@Validated @RequestBody  AnalysisReq analysisReq) {
-        log.info("aiAnalyze data: {}",analysisReq);
-        return  aiAnalysisDifyService.aiAnalyze(analysisReq);
+    public AnalysisResp<Object> aiAnalyze(@Validated @RequestBody  String message) {
+        log.info("aiAnalyze data: {}",message);
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.configure(JsonParser.Feature.ALLOW_UNQUOTED_CONTROL_CHARS, true); // 允许未转义的控制字符
+        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+        try {
+            AnalysisReq analysisReq  = objectMapper.readValue(message, AnalysisReq.class);
+            analysisReq.validate();
+            return  aiAnalysisDifyService.aiAnalyze(analysisReq);
+        } catch (JsonProcessingException e) {
+            log.info("aiAnalyze data error: {}",e);
+            return AnalysisResp.failed("解析失败");
+        }
     }
 
     @PostMapping("/query")