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 7f07b1b..c60055b 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
@@ -80,17 +80,17 @@ public class CorpusFailJob {
                         CorpusReportDTO corpusReportDTO = JSONObject.parseObject(oldAiAnalysisRequestLogs.getBusinessRequest(), CorpusReportDTO.class);
 
                         JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyReq);
-                        log.info("runDify execDifyFlow {}",execDifyFlow);
+                        log.info(" corpusFailTask runDify execDifyFlow {}",execDifyFlow);
                         if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
                             String text = execDifyFlow.getJSONObject("outputs").getString("text");
                             String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2");
                             String resultStrTwo = FlowResultSplitUtil.flowOutputTextSplit(text, "任务2", null);
                             if (StringUtils.isBlank(resultStrOne) || StringUtils.isBlank(resultStrTwo)) {
-                                log.info("企微语料解析为空，text:{}", text);
+                                log.info(" corpusFailTask 企微语料解析为空，text:{}", text);
                                 return;
                             }
                             Map<String, String> ltoMap = new HashMap<>();
-                            ltoMap.put("analysisRecordId", execDifyFlow.getString("aiAnalysisRequestId"));
+                            ltoMap.put("analysisRecordId", oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
                             ltoMap.put("analysisScene", corpusReportDTO.getAnalysisScene() + "");
                             String tag = "";
                             if (corpusReportDTO.getAnalysisScene() == 1) { //企微
@@ -106,7 +106,7 @@ public class CorpusFailJob {
                             ltoMap.put("analysisResult", resultStrOne.replace("#", ""));
                             ltoMap.put("analysisDetail", resultStrTwo);
                             // 发送MQ
-                            log.info("send mq  {}", ltoMap);
+                            log.info("corpusFailTask send mq  {}", ltoMap);
                             tmTelephoneCorpusService.sendMq(tag, JSONObject.toJSONString(ltoMap));
                             // 保存报告
                             tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder()
@@ -136,7 +136,7 @@ public class CorpusFailJob {
                     }
                 } catch (Exception e) {
                     aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0");
-                    aiAnalysisErrorsService.save(aiAnalysisErrors);
+                    aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors);
                 }
             });