倒序抓取、日志记录

data-base/base-sync-semi-order/src/main/java/com/bailuntec/job/SemiStockReportSyncJob.java

@@ -63,6 +63,9 @@ public class SemiStockReportSyncJob extends PointJob {
             if (StringUtils.isNoneBlank(palResultStr)) {
                 SemiStockReportInfo<DcSemiStockReport> stockResultRoot = JSONObject.parseObject(palResultStr, new TypeReference<SemiStockReportInfo<DcSemiStockReport>>(){});
                 if (stockResultRoot != null && stockResultRoot.getSuccess().booleanValue()) {
+                    if (jobPointLog.getPageIndex().equals(0)) {
+                        jobPointLog.setPageIndex(stockResultRoot.getData().getTotalPages() + 1);
+                    }
                     List<DcSemiStockReport> resultData = stockResultRoot.getData() == null ? null : stockResultRoot.getData().getItems();
                     totalPage = stockResultRoot.getData().getTotalPages();
                     if (resultData != null && resultData.size() > 0) {
@@ -73,6 +76,7 @@ public class SemiStockReportSyncJob extends PointJob {
                         }
                     }
                 } else {
+                    log.warn("返回数据错误："+ palResultStr);
                     throw new RuntimeException("调用库存流水报表接口同步百伦库存流水失败, 响应200, 请求参数" + map.toString());
                 }
             } else {
@@ -89,8 +93,8 @@ public class SemiStockReportSyncJob extends PointJob {
                     SessionUtil.closeSession();
                 }
             }
-            jobPointLog.setPageIndex(jobPointLog.getPageIndex() + 1);
-        } while (jobPointLog.getPageIndex() <= totalPage);
+            jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1);
+        } while (0 < jobPointLog.getPageIndex());
         jobPointLog.setPageIndex(0);
         jobPointLog.setStartTime(jobPointLog.getEndTime());
         jobPointLog.setEndTime(jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()).isAfter(LocalDateTime.now()) ? LocalDateTime.now() : jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()));