From 04b5793c3a72667f5534f1365986b6ea66fe1154 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Tue, 1 Apr 2025 10:32:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=BC=82=E5=B8=B8=E8=A1=A8?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/service/AiAnalysisErrorsService.java      |  2 +-
 .../service/impl/AiAnalysisErrorsServiceImpl.java    | 12 ++++++++++++
 .../service/impl/TmTelephoneCorpusServiceImpl.java   |  9 ++++++++-
 3 files changed, 21 insertions(+), 2 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/AiAnalysisErrorsService.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/AiAnalysisErrorsService.java
index fdb949d..d0d09b0 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/AiAnalysisErrorsService.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/AiAnalysisErrorsService.java
@@ -2,13 +2,13 @@ package com.volvo.ai.analytic.center.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.volvo.ai.analytic.center.entity.AiAnalysisErrors;
-import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
 public interface AiAnalysisErrorsService extends IService<AiAnalysisErrors> {
 
 	boolean saveAiAnalysisErrors(AiAnalysisErrors entity);
+	boolean updateAiAnalysisErrors(AiAnalysisErrors entity);
 	int queryCountAnalysisErrorList(String businessType);
 	List<AiAnalysisErrors> queryAnalysisErrorList( String businessType, int offset,int pageSize);
 }
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java
index dc86393..bb37955 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java
@@ -31,6 +31,18 @@ public class AiAnalysisErrorsServiceImpl  extends ServiceImpl<AiAnalysisErrorsMa
 		}
 	}
 
+	public boolean updateAiAnalysisErrors(AiAnalysisErrors entity) {
+
+		LambdaQueryWrapper<AiAnalysisErrors> queryWrapper = new LambdaQueryWrapper<>();
+		queryWrapper.eq(AiAnalysisErrors::getAiAnalysisRequestId, entity.getAiAnalysisRequestId());
+		AiAnalysisErrors oldAiAnalysisErrors = aiAnalysisErrorsMapper.selectOne(queryWrapper);
+		if (oldAiAnalysisErrors != null) {
+			oldAiAnalysisErrors.setRetryCount(oldAiAnalysisErrors.getRetryCount() + 1);
+			return aiAnalysisErrorsMapper.update(entity, queryWrapper) > 0;
+		}
+		return false;
+	}
+
 	@Override
 	public int queryCountAnalysisErrorList(String businessType) {
 		return	aiAnalysisErrorsMapper.queryCountAnalysisErrorList(businessType);
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
index b922d39..dfa055c 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
@@ -21,6 +21,7 @@ import com.volvo.ai.analytic.center.enums.BizEnum;
 import com.volvo.ai.analytic.center.enums.BusinessTypeEnum;
 import com.volvo.ai.analytic.center.enums.CategoryEnum;
 import com.volvo.ai.analytic.center.feign.RemoteCarModelClient;
+import com.volvo.ai.analytic.center.mapper.AiAnalysisErrorsMapper;
 import com.volvo.ai.analytic.center.mapper.TmTelephoneCorpusMapper;
 import com.volvo.ai.analytic.center.service.*;
 import com.volvo.ai.analytic.center.utils.ConstantStr;
@@ -80,6 +81,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 	@Autowired
 	private  AiAnalysisErrorsService aiAnalysisErrorsService;
 
+	@Autowired
+	private AiAnalysisErrorsMapper aiAnalysisErrorsMapper;
+
 	@Override
 	@Transactional
 	public void saveTelephoneCorpus(TmTelephoneCorpus tmTelephoneCorpus) {
@@ -171,7 +175,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
 					aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestId);
 					aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
-					aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors);
+					aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors);
 					aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build());
 
 				} catch (Exception e) {
@@ -223,4 +227,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 
 
 
+
+
+
 }
\ No newline at end of file