From 40c7d471b69e10f4f3e70d5cf178a6840095cc72 Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Thu, 18 Sep 2025 14:41:43 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=AD=E6=96=99=E4=BF=A1=E6=81=AF=E4=B8=8D?=
 =?UTF-8?q?=E5=AE=8C=E6=95=B4=EF=BC=8Cdcc=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/service/impl/TmNameplateCorpusServiceImpl.java     | 4 ++--
 .../service/impl/TmOdsVdqwMessagearchivingServiceImpl.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

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 aebeeab..f5c1029 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
@@ -126,7 +126,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
         log.info("重跑铭牌语料铭牌数据跑批结束 耗时：{}", System.currentTimeMillis() - startTime);
     }
 
-    public void processItem(TmNameplateCorpus item) {
+    public synchronized void   processItem(TmNameplateCorpus item) {
 
         try {
             Optional.ofNullable(item).filter(tmNameplateCorpus -> tmNameplateCorpus.getCustomerFlowId() != null && tmNameplateCorpus.getNameplateContent() != null).orElseThrow(() -> new RuntimeException("铭牌语料为空"));
@@ -236,7 +236,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
     }
 
     @Override
-    public ResultMsg<Object> updateNameplate(String message) {
+    public synchronized ResultMsg<Object> updateNameplate(String message) {
         try {
 
             if (StringUtils.isNotEmpty(message)) {
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 ec77351..493800f 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
@@ -164,7 +164,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
 
 	}
 
-	private void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {
+	private synchronized void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {
 		log.info("企微语料内容：FromUserId：{}, AcceptUserId：{}", item.getFromUserId(), item.getAcceptUserId());
 		//  1，vdqw_workuserinfo 这个表对应是 B端认证中心userId
 		//  2，vdqw_externalcontact 这个表对应是 	企微客户unionId