diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiDifyResultController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiDifyResultController.java
new file mode 100644
index 0000000..ab11a96
--- /dev/null
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiDifyResultController.java
@@ -0,0 +1,48 @@
+package com.volvo.ai.analytic.center.controller;
+
+
+import com.alibaba.fastjson.JSONObject;
+import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
+import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService;
+import com.volvo.common.core.util.ResultMsg;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+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.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
+@Api(tags = "测试类API")
+@RequestMapping("")
+@Slf4j
+@RefreshScope
+public class AiDifyResultController {
+
+    @Autowired
+    private RocketMQTemplate rocketMQTemplate;
+
+    @Autowired
+    private AiAnalysisRequestLogsService aiAnalysisRequestLogsService;
+
+
+
+    @PostMapping("/updateByAiId")
+    @ApiOperation(value = "更新dify结果")
+    public ResultMsg<Object> updateByAiId(@RequestBody String message) {
+        JSONObject messageJson = JSONObject.parseObject(message);
+        AiAnalysisRequestLogs aiAnalysisRequestLogs = new AiAnalysisRequestLogs();
+        aiAnalysisRequestLogs.setAiAnalysisRequestId(messageJson.getString("aiAnalysisRequestId"));
+        aiAnalysisRequestLogs.setDifyResponse(messageJson.getString("difyResponse"));
+        aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(aiAnalysisRequestLogs);
+        return ResultMsg.ok("ok");
+    }
+
+
+}
+