From 5c4b88ba5e5ecdde1d8dec2901a04272fa95bd06 Mon Sep 17 00:00:00 2001 From: zren25 Date: Wed, 9 Apr 2025 10:33:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9dcc=E7=B1=BB=E5=9E=8B?= =?UTF-8?q?=E6=9E=9A=E4=B8=BE=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/job/CorpusFailJob.java | 14 ++++---------- .../center/mapper/AiAnalysisErrorsMapper.java | 4 ++-- .../center/service/AiAnalysisErrorsService.java | 4 ++-- .../service/impl/AiAnalysisErrorsServiceImpl.java | 4 ++-- .../service/impl/TmTelephoneCorpusServiceImpl.java | 2 +- .../resources/mapper/AiAnalysisErrorsMapper.xml | 12 ++++++++++-- 6 files changed, 21 insertions(+), 19 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java index 72ee77d..4275691 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java @@ -81,14 +81,14 @@ public class CorpusFailJob { public void corpusFailTask() { log.info(" 解析失败重试处理"); - Integer total = aiAnalysisErrorsService.queryCountAnalysisErrorList(BusinessTypeEnum.SMART_ASSISTANT.getCode()); + Integer total = aiAnalysisErrorsService.queryCountAnalysisErrorList(Arrays.asList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),BusinessTypeEnum.SMART_ASSISTANT_DCC.getCode())); log.info("语料解析失败重试处理数据量：{}", total); int totalPages = PageDto.getTotalPages(total, pageSize); log.info("语料解析失败重试处理数据量：{},总页数：{}", total, totalPages); for (int i = 1; i <= totalPages; i++) { int offset = (i - 1) * pageSize; - List aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),offset, pageSize); + List aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(Arrays.asList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),BusinessTypeEnum.SMART_ASSISTANT_DCC.getCode()),offset, pageSize); if(CollectionUtils.isNotEmpty(aiAnalysisErrorsListlist)) { log.info("语料解析失败重试处理 size:{}", aiAnalysisErrorsListlist.size()); aiAnalysisErrorsListlist.stream().forEach(aiAnalysisErrors -> { @@ -170,9 +170,6 @@ public class CorpusFailJob { }); } } - - - } @@ -195,14 +192,14 @@ public class CorpusFailJob { public void intelligentCustomer4in1() { log.info(" INTELLIGENT_CUSTOMER_4IN1 解析失败重试处理"); - Integer total = aiAnalysisErrorsService.queryCountAnalysisErrorList(BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode()); + Integer total = aiAnalysisErrorsService.queryCountAnalysisErrorList(Arrays.asList(BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode())); log.info("INTELLIGENT_CUSTOMER_4IN1 语料解析失败重试处理数据量：{}", total); int totalPages = PageDto.getTotalPages(total, pageSize); log.info("INTELLIGENT_CUSTOMER_4IN1 语料解析失败重试处理数据量：{},总页数：{}", total, totalPages); for (int i = 1; i <= totalPages; i++) { int offset = (i - 1) * pageSize; - List aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode(),offset, pageSize); + List aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(Arrays.asList(BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode()),offset, pageSize); if(CollectionUtils.isNotEmpty(aiAnalysisErrorsListlist)) { log.info("语料解析失败重试处理 size:{}", aiAnalysisErrorsListlist.size()); aiAnalysisErrorsListlist.stream().forEach(aiAnalysisErrors -> { @@ -237,8 +234,5 @@ public class CorpusFailJob { }); } } - - - } } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/AiAnalysisErrorsMapper.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/AiAnalysisErrorsMapper.java index c4c684f..9b5fdf7 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/AiAnalysisErrorsMapper.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/AiAnalysisErrorsMapper.java @@ -11,6 +11,6 @@ import java.util.List; public interface AiAnalysisErrorsMapper extends BaseMapper { - int queryCountAnalysisErrorList(@Param("businessType") String businessType); - List queryAnalysisErrorList( @Param("businessType") String businessType, @Param("offset") int offset, @Param("pageSize") int pageSize); + int queryCountAnalysisErrorList(@Param("businessType") List businessType); + List queryAnalysisErrorList( @Param("businessType") List businessType, @Param("offset") int offset, @Param("pageSize") int pageSize); } 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 d0d09b0..8328cd0 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 @@ -9,6 +9,6 @@ public interface AiAnalysisErrorsService extends IService { boolean saveAiAnalysisErrors(AiAnalysisErrors entity); boolean updateAiAnalysisErrors(AiAnalysisErrors entity); - int queryCountAnalysisErrorList(String businessType); - List queryAnalysisErrorList( String businessType, int offset,int pageSize); + int queryCountAnalysisErrorList(List businessType); + List queryAnalysisErrorList( List 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 bb37955..8e32a38 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 @@ -44,11 +44,11 @@ public class AiAnalysisErrorsServiceImpl extends ServiceImpl businessType) { return aiAnalysisErrorsMapper.queryCountAnalysisErrorList(businessType); } - public List queryAnalysisErrorList( String businessType, int offset,int pageSize) { + public List queryAnalysisErrorList( List businessType, int offset,int pageSize) { //捞取异常表中属于社区的异常数据 return aiAnalysisErrorsMapper.queryAnalysisErrorList(businessType, offset, pageSize); } 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 8d5b539..fa15719 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 @@ -152,7 +152,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl + #{businessType} + + ) AND ai_analysis_error_handling_status = '0' AND retry_count <= max_retry_count )tag @@ -31,7 +35,11 @@ tt_ai_analysis_errors WHERE is_deleted = 0 - AND ai_analysis_request_type=#{businessType} + AND ai_analysis_request_type in ( + + #{businessType} + + ) AND ai_analysis_error_handling_status = '0' AND retry_count <= max_retry_count LIMIT #{offset}, #{pageSize}