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;