error状态更新
This commit is contained in:
@@ -26,6 +26,7 @@ public class AiAnalysisErrorsServiceImpl extends ServiceImpl<AiAnalysisErrorsMa
|
|||||||
if (oldAiAnalysisErrors == null) {
|
if (oldAiAnalysisErrors == null) {
|
||||||
return aiAnalysisErrorsMapper.insert(entity) > 0;
|
return aiAnalysisErrorsMapper.insert(entity) > 0;
|
||||||
} else {
|
} else {
|
||||||
|
oldAiAnalysisErrors.setRetryCount(oldAiAnalysisErrors.getRetryCount() + 1);
|
||||||
return aiAnalysisErrorsMapper.update(entity, queryWrapper) > 0;
|
return aiAnalysisErrorsMapper.update(entity, queryWrapper) > 0;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -170,7 +170,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
|
|||||||
try {
|
try {
|
||||||
AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
|
AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
|
||||||
aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestId);
|
aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestId);
|
||||||
aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1);
|
|
||||||
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
|
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
|
||||||
aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors);
|
aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors);
|
||||||
aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build());
|
aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build());
|
||||||
|
|||||||
Reference in New Issue
Block a user