更新同步WMS库存方法, 新增结束时间, 避免漏数据问题

data-base/base-sync-stock-wms/src/main/java/com/bailuntec/job/WmsStockJob.java

@@ -38,9 +38,8 @@ public class WmsStockJob extends PointJob {
         root.setData(data);
         page.setRows(jobPointLog.getPageSize());
         search.setWarehouseCodes(listWmsStockWarehouse());
-        //不传时间查全表
-        search.setLastModificationTime_start(jobPointLog.getStartTime().minusMinutes(5));
-        LocalDateTime now = LocalDateTime.now();
+        search.setLastModificationTime_start(jobPointLog.getStartTime().minusHours(1));
+        search.setLastModificationTime_end(jobPointLog.getEndTime());
         do {
             OkHttpClient client = OkHttpUtil.getInstance();
             MediaType mediaType = MediaType.parse("application/json");
@@ -109,8 +108,8 @@ public class WmsStockJob extends PointJob {
             jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1);
         } while (jobPointLog.getPageIndex() > 0);
         jobPointLog.setPageIndex(0);
-        jobPointLog.setStartTime(now.minusMinutes(3));
-        jobPointLog.setEndTime(LocalDateTime.now());
+        jobPointLog.setStartTime(jobPointLog.getEndTime());
+        jobPointLog.setEndTime(jobPointLog.getStartTime().plusDays(jobPointLog.getIntervalTime()).isAfter(LocalDateTime.now()) ? LocalDateTime.now() : jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()));
     }
 
     private List<String> listWmsStockWarehouse() {