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

sonar

Browse Source
This commit is contained in:
zren25
2025-03-13 13:57:59 +08:00
parent a321fc60ff
commit 44980b9104
3 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java
View File

@@ -44,7 +44,7 @@ public class CorpusFailJob {
} catch (Exception e) { } catch (Exception e) {
log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage()); log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage());
throw new RuntimeException(e);
} }
return ResultMsg.ok(); return ResultMsg.ok();
} }

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

@@ -32,12 +32,7 @@ public class AiAnalysisErrorsServiceImpl extends ServiceImpl<AiAnalysisErrorsMa
public List<AiAnalysisErrors> queryAnalysisErrorList(String businessType) { public List<AiAnalysisErrors> queryAnalysisErrorList(String businessType) {
//捞取异常表中属于社区的异常数据 //捞取异常表中属于社区的异常数据
List<AiAnalysisErrors> aiAnalysisErrors = aiAnalysisErrorsMapper.selectList(new LambdaQueryWrapper<AiAnalysisErrors>() return null;
.eq(AiAnalysisErrors::getAiAnalysisRequestType, businessType)
.eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0")
.eq(AiAnalysisErrors::getIsDeleted, 0)
.lt(AiAnalysisErrors::getRetryCount, 4));
return aiAnalysisErrors;
} }
} }

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

@@ -154,8 +154,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
log.info("电话语料解析为空，text:{}", text); log.info("电话语料解析为空，text:{}", text);
return; return;
} }
String aiAnalysisRequestId = execDifyFlow.getString("aiAnalysisRequestId");
Map<String, String> ltoMap = new HashMap(); Map<String, String> ltoMap = new HashMap();
ltoMap.put("aiAnalysisRequestId", execDifyFlow.getString("aiAnalysisRequestId")); ltoMap.put("aiAnalysisRequestId", aiAnalysisRequestId);
ltoMap.put("analysisScene", "2"); ltoMap.put("analysisScene", "2");
// ltoMap.put("unionId", aicorpusTelephone.getSourceId()); // ltoMap.put("unionId", aicorpusTelephone.getSourceId());
ltoMap.put("recordId", aicorpusTelephone.getSourceId()); ltoMap.put("recordId", aicorpusTelephone.getSourceId());
@@ -180,7 +181,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
// 保存报告 // 保存报告
Date corpusTime = DateUtil.parseUTC(jsonObject.getString("start_time")); Date corpusTime = DateUtil.parseUTC(jsonObject.getString("start_time"));
tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder()
.aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")) .aiAnalysisRequestId(aiAnalysisRequestId)
.corpusType(2l) .corpusType(2l)
.corpusTime(corpusTime) .corpusTime(corpusTime)
.userId( aicorpusTelephone.getSourceId()) .userId( aicorpusTelephone.getSourceId())