admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

结果更新

Browse Source
This commit is contained in:
zren25
2025-04-11 16:00:35 +08:00
parent 5df768a10e
commit 3702cc873e
3 changed files with 35 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiDifyResultController.java
View File

@@ -1,9 +1,7 @@
package com.volvo.ai.analytic.center.controller; package com.volvo.ai.analytic.center.controller;
import com.alibaba.fastjson.JSONObject; import com.volvo.ai.analytic.center.service.AiDifyResultService;
import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
import com.volvo.ai.analytic.center.service.AiAnalysisRequestLogsService;
import com.volvo.common.core.util.ResultMsg; import com.volvo.common.core.util.ResultMsg;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
@@ -19,7 +17,6 @@ import org.springframework.web.bind.annotation.RestController;
@RestController @RestController
@Api(tags = "测试类API") @Api(tags = "测试类API")
@RequestMapping("")
@Slf4j @Slf4j
@RefreshScope @RefreshScope
public class AiDifyResultController { public class AiDifyResultController {
@@ -28,18 +25,15 @@ public class AiDifyResultController {
private RocketMQTemplate rocketMQTemplate; private RocketMQTemplate rocketMQTemplate;
@Autowired @Autowired
private AiAnalysisRequestLogsService aiAnalysisRequestLogsService; private AiDifyResultService AiDifyResultService;
@PostMapping("/updateByAiId") @PostMapping("/updateByAiId")
@ApiOperation(value = "更新dify结果") @ApiOperation(value = "更新dify结果")
public ResultMsg<Object> updateByAiId(@RequestBody String message) { public ResultMsg<Object> updateByAiId(@RequestBody String message) {
JSONObject messageJson = JSONObject.parseObject(message); log.info("updateByAiId message: {}",message);
AiAnalysisRequestLogs aiAnalysisRequestLogs = new AiAnalysisRequestLogs(); AiDifyResultService.updateAiDifyResult(message);
aiAnalysisRequestLogs.setAiAnalysisRequestId(messageJson.getString("aiAnalysisRequestId"));
aiAnalysisRequestLogs.setDifyResponse(messageJson.getString("difyResponse"));
aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(aiAnalysisRequestLogs);
return ResultMsg.ok("ok"); return ResultMsg.ok("ok");
} }

9
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/AiDifyResultService.java Normal file
View File

@@ -0,0 +1,9 @@
package com.volvo.ai.analytic.center.service;
import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
public interface AiDifyResultService {
public boolean updateAiDifyResult(String message);
}

22
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiDifyResultServiceImpl.java Normal file
View File

@@ -0,0 +1,22 @@
package com.volvo.ai.analytic.center.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
import com.volvo.ai.analytic.center.service.AiDifyResultService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@Slf4j
@Service
public class AiDifyResultServiceImpl implements AiDifyResultService {
@Override
public boolean updateAiDifyResult(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 false;
}
}