Ver código fonte

企业黑名单同步

yaodaoseng 2 semanas atrás
pai
commit
7cc26db38a

+ 3 - 0
risk-control-core/src/main/java/com/tzld/piaoquan/risk/control/service/sync/impl/BlacklistSyncServiceImpl.java

@@ -39,6 +39,8 @@ public class BlacklistSyncServiceImpl implements BlacklistSyncService {
     
     @Autowired
     private RedisDistributedLockService lockService;
+
+    private static final int SLEEP_TIME = 1500; // 1.5秒
     
     @Override
     public void intelligentSyncCheck() {
@@ -54,6 +56,7 @@ public class BlacklistSyncServiceImpl implements BlacklistSyncService {
         // 2. 遍历企业ID,进行智能决策
         for (Long corpId : corpIds) {
             try {
+                Thread.sleep(SLEEP_TIME);
                 // 3. 判断是否需要同步
                 SyncDecision decision = syncTimeStrategy.shouldSync(corpId);