From 31d6215a83875a3b82c0691fc05791bf01b790dc Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Fri, 19 Sep 2025 13:34:41 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3sonar=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai/analytic/center/mq/NameplateKafkaConsumer.java      | 6 +-----
 .../service/impl/TmOdsVdqwMessagearchivingServiceImpl.java | 7 +++----
 2 files changed, 4 insertions(+), 9 deletions(-)

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 7140dad..0412de5 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
@@ -16,13 +16,9 @@ import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.RestController;
-
 import javax.annotation.Resource;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Semaphore;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
+
 
 /**
  * @ClassName NameplateKafkaConsumer
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 e4f0c45..6e3cca1 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
@@ -158,7 +158,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
         }
 
 	}
-
+String consultantIdStr ="consultantId";
 	private  void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {
 		log.info("企微语料内容：FromUserId：{}, AcceptUserId：{}", item.getFromUserId(), item.getAcceptUserId());
 		DiFyReq diFyImageReq = new DiFyReq();
@@ -224,7 +224,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
 				inputMap.put("chat", chatList.toString());
 				inputMap.put("analysisScene", "1");
 				inputMap.put("unionId", unionId);
-				inputMap.put("consultantId", userId);
+				inputMap.put(consultantIdStr, userId);
 				inputMap.put("communicateDate", DateUtil.format(finalMaxMsgTimeItem.getMsgTime(), DatePattern.NORM_DATETIME_PATTERN));
 				inputMap.put("version", 2);
 				diFyImageReq.setInputs(inputMap);
@@ -326,10 +326,9 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
 			diFyImageReq2.setUser(ConstantStr.corpus_user);
 			Map<String, Object> inputMap2 = new HashMap<>();
 			inputMap2.put("businessId", unionId);
-			inputMap2.put("consultantId", corpusReportDTO.getUserId());//顾问id
+			inputMap2.put(consultantIdStr, corpusReportDTO.getUserId());//顾问id
 			inputMap2.put("communicateDate",  DateUtil.format(maxMsgTimeItem.getMsgTime(), DatePattern.NORM_DATETIME_PATTERN));
 			inputMap2.put("analysisScene", "1");
-			inputMap2.put("consultantId", corpusReportDTO.getUserId());
 			inputMap2.put("version", 2);
 			inputMap2.put("chat", chatList.toString());
 			diFyImageReq2.setInputs(inputMap2);