diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
index a05a5b4..e8a3ea2 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
@@ -34,8 +34,8 @@ public class NameplateKafkaConsumer {
 	private TmNameplateCorpusService tmNameplateCorpusService;
 
 
-	@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",
-			groupId = "${analyticCenterKafka.consumer.group}" ,
+	@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",  // = smart_assistant_nameplate_topic
+			groupId = "${analyticCenterKafka.consumer.group}" , //smart_assistant_nameplate_topic_group
 			containerFactory = "analyticCenterConsumerFactory",
 			concurrency = "3")
 	public void listen(String recordMessages, Acknowledgment ack,
@@ -53,7 +53,8 @@ public class NameplateKafkaConsumer {
 			NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class);
 			if (!"INSERT".equals(tmNameplateCorpus.getType()) || CollectionUtils.isEmpty(tmNameplateCorpus.getData())) {
 				ack.acknowledge();
-				return;
+//				return;
+				//TODO 临时去掉，uat联调
 			}
 
 			tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate));
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
index 3ba206a..affe2dd 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
@@ -165,9 +165,10 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
 			long startTime = System.currentTimeMillis();
 			CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> {
 				//第一个业务场景  开始：    总结和分类业务场景
-				JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(),
-						JSONObject.toJSONString(corpusReportDTO),null);
-				log.info("runDify execDifyFlow ,铭牌语料 ，总结和分类业务，返回： {}", execDifyFlow);
+//				JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(),
+//						JSONObject.toJSONString(corpusReportDTO),null);
+//				log.info("runDify execDifyFlow ,铭牌语料 ，总结和分类业务，返回： {}", execDifyFlow);
+				log.info("runDify execDifyFlow ,铭牌语料 ，总结和分类业务，开始： {}", diFyImageReq);
 			}, executorService);
 			long endTime = System.currentTimeMillis();
 			log.info("第一个业务场景（总结和分类）执行时间: {} ms", (endTime - startTime));
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
index dfcdb14..c0475ab 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
@@ -164,7 +164,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
 							JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
 
-					log.info("runDify execDifyFlow 返回 ,总结场景 ： {}", execDifyFlow);
+					log.info("runDify execDifyFlow 返回 ,总结场景 dcc： {}", execDifyFlow);
 					parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(),
 							BusinessTypeEnum.SMART_ASSISTANT.getCode());
 				} catch (Exception e) {
@@ -188,7 +188,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
 							JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
 
-					log.info("runDify execDifyFlow 返回 ,客户画像场景： {}", execDifyFlowForPortrait);
+					log.info("runDify execDifyFlow 返回 ,客户画像场景 dcc： {}", execDifyFlowForPortrait);
 
 					parseDfiyResult(execDifyFlowForPortrait, aicorpusTelephone.getSourceId(), formattedDateStartTime,
 							aicorpusTelephone.getAiAnalysisRequestId(), BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode());