From 5df768a10e5cdeeabf4b1939f6e431c65fcd0524 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Wed, 9 Apr 2025 10:59:20 +0800
Subject: [PATCH] =?UTF-8?q?=E9=AA=8C=E8=AF=81dify?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/AiDifyResultController.java    | 48 +++++++++++++++++++
 1 file changed, 48 insertions(+)
 create mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiDifyResultController.java

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");
+    }
+
+
+}
+