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

修改dcc类型枚举值

Browse Source
This commit is contained in:
zren25
2025-04-09 10:33:52 +08:00
parent 34d4113fa9
commit 5c4b88ba5e
6 changed files with 21 additions and 19 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/job/CorpusFailJob.java
View File

@@ -81,14 +81,14 @@ public class CorpusFailJob {
public void corpusFailTask() { public void corpusFailTask() {
log.info(" 解析失败重试处理"); 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); log.info("语料解析失败重试处理数据量：{}", total);
int totalPages = PageDto.getTotalPages(total, pageSize); int totalPages = PageDto.getTotalPages(total, pageSize);
log.info("语料解析失败重试处理数据量：{},总页数：{}", total, totalPages); log.info("语料解析失败重试处理数据量：{},总页数：{}", total, totalPages);
for (int i = 1; i <= totalPages; i++) { for (int i = 1; i <= totalPages; i++) {
int offset = (i - 1) * pageSize; int offset = (i - 1) * pageSize;
List<AiAnalysisErrors> aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),offset, pageSize); List<AiAnalysisErrors> aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(Arrays.asList(BusinessTypeEnum.SMART_ASSISTANT.getCode(),BusinessTypeEnum.SMART_ASSISTANT_DCC.getCode()),offset, pageSize);
if(CollectionUtils.isNotEmpty(aiAnalysisErrorsListlist)) { if(CollectionUtils.isNotEmpty(aiAnalysisErrorsListlist)) {
log.info("语料解析失败重试处理 size:{}", aiAnalysisErrorsListlist.size()); log.info("语料解析失败重试处理 size:{}", aiAnalysisErrorsListlist.size());
aiAnalysisErrorsListlist.stream().forEach(aiAnalysisErrors -> { aiAnalysisErrorsListlist.stream().forEach(aiAnalysisErrors -> {
@@ -170,9 +170,6 @@ public class CorpusFailJob {
}); });
} }
} }
} }
@@ -195,14 +192,14 @@ public class CorpusFailJob {
public void intelligentCustomer4in1() { public void intelligentCustomer4in1() {
log.info(" INTELLIGENT_CUSTOMER_4IN1 解析失败重试处理"); 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); log.info("INTELLIGENT_CUSTOMER_4IN1 语料解析失败重试处理数据量：{}", total);
int totalPages = PageDto.getTotalPages(total, pageSize); int totalPages = PageDto.getTotalPages(total, pageSize);
log.info("INTELLIGENT_CUSTOMER_4IN1 语料解析失败重试处理数据量：{},总页数：{}", total, totalPages); log.info("INTELLIGENT_CUSTOMER_4IN1 语料解析失败重试处理数据量：{},总页数：{}", total, totalPages);
for (int i = 1; i <= totalPages; i++) { for (int i = 1; i <= totalPages; i++) {
int offset = (i - 1) * pageSize; int offset = (i - 1) * pageSize;
List<AiAnalysisErrors> aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode(),offset, pageSize); List<AiAnalysisErrors> aiAnalysisErrorsListlist = aiAnalysisErrorsService.queryAnalysisErrorList(Arrays.asList(BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode()),offset, pageSize);
if(CollectionUtils.isNotEmpty(aiAnalysisErrorsListlist)) { if(CollectionUtils.isNotEmpty(aiAnalysisErrorsListlist)) {
log.info("语料解析失败重试处理 size:{}", aiAnalysisErrorsListlist.size()); log.info("语料解析失败重试处理 size:{}", aiAnalysisErrorsListlist.size());
aiAnalysisErrorsListlist.stream().forEach(aiAnalysisErrors -> { aiAnalysisErrorsListlist.stream().forEach(aiAnalysisErrors -> {
@@ -237,8 +234,5 @@ public class CorpusFailJob {
}); });
} }
} }
} }
} }

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/AiAnalysisErrorsMapper.java
View File

@@ -11,6 +11,6 @@ import java.util.List;
public interface AiAnalysisErrorsMapper extends BaseMapper<AiAnalysisErrors> { public interface AiAnalysisErrorsMapper extends BaseMapper<AiAnalysisErrors> {
int queryCountAnalysisErrorList(@Param("businessType") String businessType); int queryCountAnalysisErrorList(@Param("businessType") List<String> businessType);
List<AiAnalysisErrors> queryAnalysisErrorList( @Param("businessType") String businessType, @Param("offset") int offset, @Param("pageSize") int pageSize); List<AiAnalysisErrors> queryAnalysisErrorList( @Param("businessType") List<String> businessType, @Param("offset") int offset, @Param("pageSize") int pageSize);
} }

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/AiAnalysisErrorsService.java
View File

@@ -9,6 +9,6 @@ public interface AiAnalysisErrorsService extends IService<AiAnalysisErrors> {
boolean saveAiAnalysisErrors(AiAnalysisErrors entity); boolean saveAiAnalysisErrors(AiAnalysisErrors entity);
boolean updateAiAnalysisErrors(AiAnalysisErrors entity); boolean updateAiAnalysisErrors(AiAnalysisErrors entity);
int queryCountAnalysisErrorList(String businessType); int queryCountAnalysisErrorList(List<String> businessType);
List<AiAnalysisErrors> queryAnalysisErrorList( String businessType, int offset,int pageSize); List<AiAnalysisErrors> queryAnalysisErrorList( List<String> businessType, int offset,int pageSize);
} }

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisErrorsServiceImpl.java
View File

@@ -44,11 +44,11 @@ public class AiAnalysisErrorsServiceImpl extends ServiceImpl<AiAnalysisErrorsMa
} }
@Override @Override
public int queryCountAnalysisErrorList(String businessType) { public int queryCountAnalysisErrorList(List<String> businessType) {
return aiAnalysisErrorsMapper.queryCountAnalysisErrorList(businessType); return aiAnalysisErrorsMapper.queryCountAnalysisErrorList(businessType);
} }
public List<AiAnalysisErrors> queryAnalysisErrorList( String businessType, int offset,int pageSize) { public List<AiAnalysisErrors> queryAnalysisErrorList( List<String> businessType, int offset,int pageSize) {
//捞取异常表中属于社区的异常数据 //捞取异常表中属于社区的异常数据
return aiAnalysisErrorsMapper.queryAnalysisErrorList(businessType, offset, pageSize); return aiAnalysisErrorsMapper.queryAnalysisErrorList(businessType, offset, pageSize);
} }

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
View File

@@ -152,7 +152,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
corpusReportDTO.setRecordId(aicorpusTelephone.getSourceId()); corpusReportDTO.setRecordId(aicorpusTelephone.getSourceId());
corpusReportDTO.setAnalysisScene(2l); corpusReportDTO.setAnalysisScene(2l);
// 获取配置 // 获取配置
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(), JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId()); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_DCC.getCode(), JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
log.info("runDify execDifyFlow {}",execDifyFlow); log.info("runDify execDifyFlow {}",execDifyFlow);
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){

12
ai-analytic-center-biz/src/main/resources/mapper/AiAnalysisErrorsMapper.xml
View File

@@ -13,7 +13,11 @@
tt_ai_analysis_errors tt_ai_analysis_errors
WHERE WHERE
is_deleted = 0 is_deleted = 0
AND ai_analysis_request_type=#{businessType} AND ai_analysis_request_type in (
<foreach collection="businessType" item="businessType" separator=",">
#{businessType}
</foreach>
)
AND ai_analysis_error_handling_status = '0' AND ai_analysis_error_handling_status = '0'
AND retry_count &lt;= max_retry_count AND retry_count &lt;= max_retry_count
)tag )tag
@@ -31,7 +35,11 @@
tt_ai_analysis_errors tt_ai_analysis_errors
WHERE WHERE
is_deleted = 0 is_deleted = 0
AND ai_analysis_request_type=#{businessType} AND ai_analysis_request_type in (
<foreach collection="businessType" item="businessType" separator=",">
#{businessType}
</foreach>
)
AND ai_analysis_error_handling_status = '0' AND ai_analysis_error_handling_status = '0'
AND retry_count &lt;= max_retry_count AND retry_count &lt;= max_retry_count
LIMIT #{offset}, #{pageSize} LIMIT #{offset}, #{pageSize}