From 0e3de9db246bdb48e20ce9589e01e78136a673ea Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Tue, 11 Mar 2025 16:46:12 +0800
Subject: [PATCH] =?UTF-8?q?log=E8=A1=A8=E8=AE=B0=E5=BD=95=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/service/impl/MqMessageRecordServiceImpl.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
index ba2b2ba..b2d3bd7 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
@@ -123,7 +123,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
                     .orElse(Collections.emptyList()).stream()
                     .filter(contentNode -> NodeTypeEnum.TEXT.getCode().equals(contentNode.getNodeType()))
                     .map(CommunityTargetDTO.ContentNode::getNodeContent)
-                    .collect(Collectors.joining(""));
+                    .collect(Collectors.joining(" "));
 
             //构建舆情分析请求对象
             DifyCommunityTargetDTO difyCommunityTargetDTO = new DifyCommunityTargetDTO();
@@ -161,7 +161,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
                 syncUpdateDiFyResponse(difResult, aiAnalysisRequestId);
             }
         } catch (Exception e) {
-            log.error("请求DiFy异常:{}", e.getMessage());
+            log.error("舆情自动化异常:{}", e.getMessage());
             //保存错误日志
             aiAnalysisErrorsMapper.insert(AiAnalysisErrors.builder()
                     .aiAnalysisRequestId(aiAnalysisRequestId)
@@ -182,7 +182,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
     @Async
     protected void syncUpdateDiFyResponse(JSONObject difResult, String aiAnalysisRequestId) {
         aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(),
-                new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_response", difResult)
+                new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_response", difResult.toJSONString())
                         .eq("ai_analysis_request_id", aiAnalysisRequestId));
     }