diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java
index 2803dd5..9fc1e49 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java
@@ -134,7 +134,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
                 int offset = (i - 1) * pageSize;
                 List<OdsVdqwMessageOTD> messageList = tmOdsVdqwMessagearchivingMapper.queryOdsVdqwMessageByData(statTime, endTime, offset, pageSize, retry);
                 // 处理查询到的数据
-				log.info("待处理企微聊天列表messageList",messageList.toString());
+				log.info("待处理企微聊天列表messageList,{}",messageList.toString());
 				// 使用 CompletableFuture 并行处理
 				messageList.forEach(item -> {
 					long startTime2 = System.currentTimeMillis();
@@ -205,7 +205,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
 					runMaskingRuleInput.setOldStr(chat);
 					String corpusChat = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
 					chatList.append(corpusChat).append("\n");
-					log.info("第几循环次数{} ，掩码前：{} ,掩码后：{}", externalcontactCount.get(),  chat,chatList.toString());
+					log.info("第几循环次数{} ，掩码前：{} ,掩码后：{},合并后的总语料数据 ：{}", externalcontactCount.get(),  chat,corpusChat,chatList.toString());
 				});
 				if (externalcontactCount.get() < 1) {
 					log.info("没有客户回复的语料，无需解析");