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

修改失败补偿

Browse Source
This commit is contained in:
zren25
2025-03-17 11:08:09 +08:00
parent 890017d305
commit 54a8727c3c
2 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -22,6 +22,8 @@ import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.Date; import java.util.Date;
@@ -32,6 +34,7 @@ import java.util.Map;
@Slf4j @Slf4j
@Component @Component
@RestController
public class CorpusFailJob { public class CorpusFailJob {
@Autowired @Autowired
@@ -61,6 +64,7 @@ public class CorpusFailJob {
* 企微语料处理 * 企微语料处理
*/ */
@XxlJob("corpusFailTask") @XxlJob("corpusFailTask")
@GetMapping("corpusFailTask")
public void corpusFailTask() { public void corpusFailTask() {
log.info("语料解析失败重试处理"); log.info("语料解析失败重试处理");
@@ -93,7 +97,7 @@ public class CorpusFailJob {
ltoMap.put("analysisRecordId", oldAiAnalysisRequestLogs.getAiAnalysisRequestId()); ltoMap.put("analysisRecordId", oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
ltoMap.put("analysisScene", corpusReportDTO.getAnalysisScene() + ""); ltoMap.put("analysisScene", corpusReportDTO.getAnalysisScene() + "");
String tag = ""; String tag = "";
if (corpusReportDTO.getAnalysisScene() == 1) { //企微 if (null != corpusReportDTO && corpusReportDTO.getAnalysisScene() == 1) { //企微
ltoMap.put("unionId", corpusReportDTO.getUnionId()); ltoMap.put("unionId", corpusReportDTO.getUnionId());
ltoMap.put("consultantId", corpusReportDTO.getUserId()); ltoMap.put("consultantId", corpusReportDTO.getUserId());
tag = CategoryEnum.ENTERPRISE_WECHAT.getCode(); tag = CategoryEnum.ENTERPRISE_WECHAT.getCode();
@@ -136,6 +140,7 @@ public class CorpusFailJob {
} }
} catch (Exception e) { } catch (Exception e) {
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0");
aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount()+ 1);
updateAiAnalysisErrors(aiAnalysisErrors,aiAnalysisErrors.getAiAnalysisRequestId()); updateAiAnalysisErrors(aiAnalysisErrors,aiAnalysisErrors.getAiAnalysisRequestId());
} }
}); });
@@ -146,12 +151,11 @@ public class CorpusFailJob {
protected void updateDiFyRequest(AiAnalysisRequestLogs oldAiAnalysisRequestLogs, String aiAnalysisRequestId) { protected void updateDiFyRequest(AiAnalysisRequestLogs oldAiAnalysisRequestLogs, String aiAnalysisRequestId) {
aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(), aiAnalysisRequestLogsMapper.update(oldAiAnalysisRequestLogs,
new LambdaQueryWrapper<AiAnalysisRequestLogs>().setEntity(oldAiAnalysisRequestLogs) new LambdaQueryWrapper<AiAnalysisRequestLogs>().eq(AiAnalysisRequestLogs::getAiAnalysisRequestId, aiAnalysisRequestId));
.eq(AiAnalysisRequestLogs::getAiAnalysisRequestId, aiAnalysisRequestId));
} }
protected void updateAiAnalysisErrors(AiAnalysisErrors aiAnalysisErrors, String aiAnalysisRequestId) { protected void updateAiAnalysisErrors(AiAnalysisErrors aiAnalysisErrors, String aiAnalysisRequestId) {
aiAnalysisErrorsService.update( new LambdaQueryWrapper<AiAnalysisErrors>().setEntity(aiAnalysisErrors) aiAnalysisErrorsService.update(aiAnalysisErrors,
.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId)); new LambdaQueryWrapper<AiAnalysisErrors>().eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId));
} }
} }

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

@@ -140,6 +140,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
CorpusReportDTO corpusReportDTO = new CorpusReportDTO(); CorpusReportDTO corpusReportDTO = new CorpusReportDTO();
corpusReportDTO.setCorpusTime(formattedDateStartTime); corpusReportDTO.setCorpusTime(formattedDateStartTime);
corpusReportDTO.setRecordId(aicorpusTelephone.getSourceId()); corpusReportDTO.setRecordId(aicorpusTelephone.getSourceId());
corpusReportDTO.setAnalysisScene(2l);
// 获取配置 // 获取配置
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(), JSONObject.toJSONString(corpusReportDTO)); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(), JSONObject.toJSONString(corpusReportDTO));
log.info("runDify execDifyFlow {}",execDifyFlow); log.info("runDify execDifyFlow {}",execDifyFlow);