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