es同步和田玉

ch-admin-api/src/main/java/com/wwdz/ch/admin/job/SynCoinJob.java

@@ -43,7 +43,7 @@ public class SynCoinJob {
 
     private static final Logger logger = LoggerFactory.getLogger(SynCoinJob.class);
 
-    private String QUANKU_SYN_TO_ES_TASK_KEY = "QUANKU_SYN_TO_ES_TASK_KEY";
+    private String SYN_NEPHRITE_TO_ES_TASK_KEY = "SYN_NEPHRITE_TO_ES_TASK_KEY";
 
     @Autowired
     ItemDao itemDao;
@@ -188,6 +188,11 @@ public class SynCoinJob {
 
 
     public void synItemToEs() {
+        RLock lock = redissonClient.getLock(SYN_NEPHRITE_TO_ES_TASK_KEY);
+        if (!lock.tryLock()) {
+            logger.warn("当前服务实例: {} 获取锁失败，锁被占用, 不允许执行同步和田玉数据到ES作业",  Thread.currentThread().getId());
+            return;
+        }
         try {
             ExecutorService executorService = Executors.newFixedThreadPool(10);
             CoinRequestDto coinRequestDto = new CoinRequestDto();
@@ -211,12 +216,17 @@ public class SynCoinJob {
             logger.info(">>>>>>>>>>>>>>>>>数据同步es 完成 SUCCESS!!!!! <<<<<<<<<<<<<<<<<");
         } catch (Exception e) {
             logger.error("同步数据到es error {}", e);
+        } finally {
+            if (lock != null && lock.isHeldByCurrentThread()) {
+                lock.unlock();
+                logger.info("======================== 线程id: {} , 同步和田玉数据到ES作业 释放锁成功 ========================", Thread.currentThread().getId());
+            }
         }
     }
 
 
     public void syn(){
-        RLock lock = redissonClient.getLock(QUANKU_SYN_TO_ES_TASK_KEY);
+       /* RLock lock = redissonClient.getLock(SYN_NEPHRITE_TO_ES_TASK_KEY);
         if (!lock.tryLock()) {
             logger.warn("当前服务实例获取锁成功: {} 获取锁失败，锁被占用, 不允许执行同步订单作业",  Thread.currentThread().getId());
             return;
@@ -230,6 +240,6 @@ public class SynCoinJob {
                 lock.unlock();
                 logger.info("======================== 线程id: {} , 释放锁成功 ========================", Thread.currentThread().getId());
             }
-        }
+        }*/
     }
 }