修改更新参数
This commit is contained in:
@@ -3,6 +3,7 @@ package com.volvo.ai.analytic.center.controller;
|
||||
|
||||
import com.volvo.ai.analytic.center.dto.req.AnalysisQueryReq;
|
||||
import com.volvo.ai.analytic.center.dto.req.AnalysisReq;
|
||||
import com.volvo.ai.analytic.center.dto.resp.AnalysisDifyResultDTO;
|
||||
import com.volvo.ai.analytic.center.dto.resp.AnalysisResp;
|
||||
import com.volvo.ai.analytic.center.service.AiAnalysisDifyService;
|
||||
import com.volvo.common.core.util.ResultMsg;
|
||||
@@ -36,9 +37,9 @@ public class AiAnalysisDifyController {
|
||||
|
||||
@PostMapping("/updateByAiId")
|
||||
@ApiOperation(value = "更新dify结果")
|
||||
public ResultMsg<Object> updateByAiId(@RequestBody String message) {
|
||||
log.info("updateByAiId message: {}",message);
|
||||
aiAnalysisDifyService.updateAiDifyResult(message);
|
||||
public ResultMsg<Object> updateByAiId(@RequestBody AnalysisDifyResultDTO analysisResp) {
|
||||
log.info("updateByAiId message: {}",analysisResp.getAiAnalysisRequestId());
|
||||
aiAnalysisDifyService.updateAiDifyResult(analysisResp);
|
||||
return ResultMsg.ok("ok");
|
||||
}
|
||||
|
||||
|
||||
@@ -2,11 +2,12 @@ package com.volvo.ai.analytic.center.service;
|
||||
|
||||
import com.volvo.ai.analytic.center.dto.req.AnalysisQueryReq;
|
||||
import com.volvo.ai.analytic.center.dto.req.AnalysisReq;
|
||||
import com.volvo.ai.analytic.center.dto.resp.AnalysisDifyResultDTO;
|
||||
import com.volvo.ai.analytic.center.dto.resp.AnalysisResp;
|
||||
|
||||
public interface AiAnalysisDifyService {
|
||||
|
||||
public boolean updateAiDifyResult(String message);
|
||||
public boolean updateAiDifyResult(AnalysisDifyResultDTO analysisResp);
|
||||
|
||||
|
||||
AnalysisResp aiAnalyze(AnalysisReq analysisReq);
|
||||
|
||||
@@ -61,13 +61,12 @@ public class AiAnalysisDifyServiceImpl implements AiAnalysisDifyService {
|
||||
@Autowired
|
||||
private RedisCounterRateLimiter redisCounterRateLimiter;
|
||||
@Override
|
||||
public boolean updateAiDifyResult(String message) {
|
||||
public boolean updateAiDifyResult(AnalysisDifyResultDTO analysisResp) {
|
||||
|
||||
// 计数-1
|
||||
redisCounterRateLimiter.decrement(ConstantStr.DIFY_COUNTERRATELIMIT);
|
||||
log.info("redisdecrement计数数量: " + redisCounterRateLimiter.getCurrentCount(ConstantStr.DIFY_COUNTERRATELIMIT));
|
||||
if(StringUtils.isNotEmpty(message)){
|
||||
AnalysisDifyResultDTO analysisResp = JSONObject.parseObject(message, AnalysisDifyResultDTO.class);
|
||||
if(null != analysisResp){
|
||||
|
||||
Optional.ofNullable(aiAnalysisRequestLogsService.queryByAiAnalysisRequestId(analysisResp.getAiAnalysisRequestId()))
|
||||
.orElseThrow(() -> new IllegalArgumentException("AiAnalysisRequestId查询对象为空!"));
|
||||
|
||||
Reference in New Issue
Block a user