From 95f0a202876379ca52eb8d65c1355485eb7e673f Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Wed, 5 Mar 2025 19:25:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8=E5=8C=96?=
 =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=BC=80=E5=8F=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/dto/req/CommunityTargetDTO.java    | 32 +++++++------------
 .../dto/req/DifyCommunityTargetDTO.java       | 32 +++++++++++++++++++
 .../impl/MqMessageRecordServiceImpl.java      |  2 +-
 3 files changed, 44 insertions(+), 22 deletions(-)
 create mode 100644 ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java

diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java
index e068b39..3a49270 100644
--- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java
+++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/CommunityTargetDTO.java
@@ -1,32 +1,22 @@
 package com.volvo.ai.analytic.center.dto.req;
 
 import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
 
-import javax.validation.constraints.NotBlank;
+import java.util.List;
 
 @Data
 public class CommunityTargetDTO {
 
-    /**
-     * 社区目标id
-     */
-    @NotBlank(message = "社区目标id不能为空")
-    private String targetId;
-
-    /**
-     * 社区目标内容
-     */
-    @NotBlank(message = "社区目标内容不能为空")
-    private String targetContent;
-
-    /**
-     * 社区目标类型
-     */
-    @NotBlank(message = "社区目标类型不能为空")
     private String targetType;
+    private String targetId;
+    private List<ContentNode> content;
 
-    /**
-     * 社区请求id
-     */
-    private String communityRequestId;
+    @Setter
+    @Getter
+    class ContentNode {
+        private String nodeType;
+        private String nodeContent;
+    }
 }
diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java
new file mode 100644
index 0000000..2832598
--- /dev/null
+++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/dto/req/DifyCommunityTargetDTO.java
@@ -0,0 +1,32 @@
+package com.volvo.ai.analytic.center.dto.req;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+
+@Data
+public class DifyCommunityTargetDTO {
+
+    /**
+     * 社区目标id
+     */
+    @NotBlank(message = "社区目标id不能为空")
+    private String targetId;
+
+    /**
+     * 社区目标内容
+     */
+    @NotBlank(message = "社区目标内容不能为空")
+    private String targetContent;
+
+    /**
+     * 社区目标类型
+     */
+    @NotBlank(message = "社区目标类型不能为空")
+    private String targetType;
+
+    /**
+     * 社区请求id
+     */
+    private String communityRequestId;
+}
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 fafd592..0baf3ca 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
@@ -78,7 +78,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
     @Transactional
     public boolean processMessageByMQ(String message) {
         log.info("communityProcessMessageByMQ message: {}", message);
-        CommunityTargetDTO communityTargetDTO = JSON.parseObject(message, CommunityTargetDTO.class);
+        DifyCommunityTargetDTO communityTargetDTO = JSON.parseObject(message, DifyCommunityTargetDTO.class);
         if (communityTargetDTO == null) {
             log.error("communityProcessMessageByMQ message is null");
             return false;