From 8af8d1282f148deabc7ad4b435d719dba827d57b Mon Sep 17 00:00:00 2001
From: wangliwen <wangliwen@hisense.com>
Date: Mon, 13 Jun 2022 15:26:34 +0800
Subject: [PATCH] ...

---
 .../modules/resource/service/impl/ResourceServiceImpl.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/renren-admin/src/main/java/io/renren/modules/resource/service/impl/ResourceServiceImpl.java b/renren-admin/src/main/java/io/renren/modules/resource/service/impl/ResourceServiceImpl.java
index ecdf6bf7..956b0324 100644
--- a/renren-admin/src/main/java/io/renren/modules/resource/service/impl/ResourceServiceImpl.java
+++ b/renren-admin/src/main/java/io/renren/modules/resource/service/impl/ResourceServiceImpl.java
@@ -586,7 +586,6 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn
                 jdbcTemplate.queryForList("SELECT note1 FROM tb_data_resource WHERE type ='知识库';", String.class)
                         .stream().distinct().collect(Collectors.toList());
         final int pageSize = 100;
-        final long timestamp = LocalDateTime.now().toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
         final OkHttpClient client = new OkHttpClient();
         Arrays.stream(catalogIds).map(index -> {
             logger.info("处理：" + index);
@@ -595,6 +594,7 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn
             AtomicInteger pageIndex = new AtomicInteger(1);
             AtomicInteger maxPage = new AtomicInteger(100); // 防止死循环
             do {
+                final long timestamp = LocalDateTime.now().toInstant(ZoneOffset.ofHours(8)).toEpochMilli();
                 int page = pageIndex.getAndIncrement();
                 logger.info("处理：" + index + " 分页{}", page);
                 task.add(CompletableFuture.supplyAsync(() -> {
@@ -651,7 +651,7 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn
                         }
                         if (!infos.isEmpty()) { // 不为空则数据分页还没传输结束
                             logger.info("--继续分页--");
-                            end.set(true); // TODO
+                            end.set(true);
                         } else {
                             end.set(false);
                         }
@@ -716,7 +716,7 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn
                     });
                 }));
                 try {
-                    Thread.sleep(500L);
+                    Thread.sleep(300L);
                 } catch (InterruptedException e) {
                     throw new RuntimeException(e);
                 }