商品同步es，新增记录表

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

@@ -67,7 +67,7 @@ public class SynItemToEsJob {
     /**
      * 隔2分钟运行一次
      */
-    @Scheduled(fixedDelay = 1000 * 60 * 1)
+    @Scheduled(fixedDelay = 1000 * 60 * 2)
     public void execute() {
         RLock lock = redissonClient.getLock(QUANKU_SYN_TO_ES_TASK_KEY);
         if (!lock.tryLock()) {
@@ -80,14 +80,14 @@ public class SynItemToEsJob {
             Date startTime;
             Date endTime;
             int page = 1;
-            int limit = 100;
+            int limit = 200;
             SynDataRecord synDataRecord = synDataRecordDao.find(SYN_ITEM_TO_ES_TYPE);
             if (synDataRecord.getIsEnd().intValue() != 1) {
                 startTime = synDataRecord.getQueryStartTime();
                 endTime = synDataRecord.getQueryEndTime();
                 page = synDataRecord.getPageIndex() + 1;
                 limit = synDataRecord.getPageSize();
-                logger.info("同步item增量数据到ES， 承接上次同步的时间范围执行， 时间范围 {} to {}", DateUtils.toString(startTime), DateUtils.toString(endTime));
+                logger.info("同步item增量数据到ES， 承接上次同步的时间范围执行， 时间范围 {} to {}, 页码 : {}", DateUtils.toString(startTime), DateUtils.toString(endTime), page);
             } else {
                 //查询es已有数据的最新修改时间
                 startTime = itemEsDao.getMaxTime();
@@ -107,7 +107,7 @@ public class SynItemToEsJob {
             coinRequestDto.setSortColumn("update_time");
             List<Item> itemList = itemDao.findListByPage(coinRequestDto);
             PageInfo<Item> pageInfo = new PageInfo<>(itemList);
-            logger.info("待同步增量数据总量 : {}, 当前查询 {} 条数据进行同步", pageInfo.getTotal(), itemList.size());
+            logger.info("待同步增量数据总量 : {}, 当前同步第 {} 页数据， 当前页共有 {} 条数据进行同步", pageInfo.getTotal(), page, itemList.size());
             for (Item item : itemList) {
                 executorService.submit(() -> {
                     itemEsDao.upsert(item);