From 2a34323c5168841286208051fed6f033200f3a1a Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Mon, 22 Sep 2025 20:31:19 +0800
Subject: [PATCH] =?UTF-8?q?dcc=E9=87=8D=E6=9E=84=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java    | 6 +++---
 .../volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java | 2 +-
 .../center/service/impl/TmTelephoneCorpusServiceImpl.java   | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
index d583973..205a5e9 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
@@ -30,8 +30,8 @@ import java.util.Objects;
 @Component
 @RefreshScope
 @RestController
-@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",
-		topic = "${rocketmq.consumer.corpus.dcctopic}",
+@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",//ai_corpus_Dcc_topic_group
+		topic = "${rocketmq.consumer.corpus.dcctopic}", //ai_corpus_Dcc_topic
 		instanceName = "CorpusDccMqConsumer1",
 		consumeThreadNumber = 40,
 		enableMsgTrace = true)
@@ -52,7 +52,7 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {
 			AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
 			//DCC场景
 			if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_DCC)){
-				tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone);
+				 tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone);
 			}
 			//channel_4in1场景
 			if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_4IN1)){
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 93a949b..3b57a7a 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
@@ -62,7 +62,7 @@ public class NameplateKafkaConsumer {
 				return;
 			}
 
-			tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate));
+			// 临时去掉  tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate));
 			log.info("nameplateKafkaConsumeracknowledge：{}",partitionId, offset);
 			 // 手动提交 offset
 		} catch (Exception e) {
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 2186383..ead508f 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
@@ -181,7 +181,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
 							JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
 
-					log.info("dcc总结场景,总结和分类 runDify execDifyFlow 返回 ： {}", execDifyFlow);
+					log.info("dcc总结场景,总结和分类 runDify execDifyFlow  ： {}", execDifyFlow);
 					parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(),
 							BusinessTypeEnum.SMART_ASSISTANT.getCode());
 				} catch (Exception e) {
@@ -202,7 +202,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					diFyImageReq.setInputs(inputMap);
 
 					diFyImageReq.setFlowId(oneTokenPortrait);
-					log.info("dcc总结场景,客户画像runDify execDifyFlow 返回 ： {}", oneTokenPortrait);
+					log.info("dcc总结场景,客户画像runDify execDifyFlow ： {}", oneTokenPortrait);
 					JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
 							JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());