From ed2cab2506b6a7b47b2582292f2c9d94f17500bc Mon Sep 17 00:00:00 2001
From: chenhc <2369838784@qq.com>
Date: Tue, 26 Nov 2024 15:58:17 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/glxp/api/service/collect/RelCodeBatchService.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/main/java/com/glxp/api/service/collect/RelCodeBatchService.java b/src/main/java/com/glxp/api/service/collect/RelCodeBatchService.java
index 89869d7d2..a5c17173a 100644
--- a/src/main/java/com/glxp/api/service/collect/RelCodeBatchService.java
+++ b/src/main/java/com/glxp/api/service/collect/RelCodeBatchService.java
@@ -20,6 +20,7 @@ import com.glxp.api.entity.basic.UdiProductEntity;
 import com.glxp.api.entity.collect.RelCodeDetail;
 import com.glxp.api.entity.inout.IoCodeTempEntity;
 import com.glxp.api.entity.system.CompanyEntity;
+import com.glxp.api.entity.system.SyncDataSetEntity;
 import com.glxp.api.exception.JsonException;
 import com.glxp.api.http.sync.SpGetHttpClient;
 import com.glxp.api.http.sync.SpsDirectClient;
@@ -33,6 +34,7 @@ import com.glxp.api.service.auth.CustomerService;
 import com.glxp.api.service.basic.ProductInfoService;
 import com.glxp.api.service.basic.UdiProductService;
 import com.glxp.api.service.basic.impl.BasicCorpServiceImpl;
+import com.glxp.api.service.sync.SyncDataSetService;
 import com.glxp.api.service.system.impl.CompanyServiceImpl;
 import com.glxp.api.util.StringUtils;
 import com.glxp.api.util.udi.FilterUdiUtils;
@@ -298,8 +300,14 @@ public class RelCodeBatchService extends ServiceImpl<RelCodeBatchMapper, RelCode
     IoCodeTempDao ioCodeTempDao;
     @Resource
     UdiProductService udiProductService;
+    @Resource
+    SyncDataSetService syncDataSetService;
 
     public void threadUpdateIoCodeTempEntity(String parentCode) {
+        SyncDataSetEntity syncDataSetEntity = syncDataSetService.findSet();
+        if(syncDataSetEntity == null || StrUtil.isEmpty(syncDataSetEntity.getSyncIp())){
+            return;
+        }
 
         ThreadUtil.execAsync(() -> {
             List<IoCodeTempEntity> ioCodeTempEntities = ioCodeTempDao.selectList(new LambdaQueryWrapper<IoCodeTempEntity>().eq(IoCodeTempEntity::getCode, parentCode));