同步SKU改为降序查

data-base/base-sync-sku/src/main/java/com/bailuntec/job/SkuJsonHandle.java

@@ -97,7 +97,14 @@ public class SkuJsonHandle {
                     } catch (UnsupportedEncodingException e) {
                         throw new RuntimeException("同步SKU信息JSON解URL编码失败", e);
                     }
-                    totalPage = jsonObject1.getIntValue("TotalPages");
+                    //如果是0, 则保存总页数, 降序查
+                    if (jobPointLog.getPageIndex().equals(0)) {
+                        jobPointLog.setPageIndex(jsonObject1.getIntValue("TotalPages"));
+                    }
+                    /*
+                     * 转化JSON,
+                     * 去处理SKU信息
+                     */
                     List<CommonSkuProductInfo> allSkuProductInfoList = jsonObject1.getObject("Items", new TypeReference<List<CommonSkuProductInfo>>() {
                     });
                     if (allSkuProductInfoList != null && allSkuProductInfoList.size() > 0) {
@@ -109,8 +116,8 @@ public class SkuJsonHandle {
             } else {
                 throw new RuntimeException("调用同步SKU信息接口失败");
             }
-            jobPointLog.setPageIndex(jobPointLog.getPageIndex() + 1);
-            if (jobPointLog.getPageIndex() % 5 == 0) {
+            jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1);
+            if (jobPointLog.getPageIndex() % 10 == 0) {
                 try {
                     JobPointLogMapper jobPointLogMapper = SessionUtil.getSession().getMapper(JobPointLogMapper.class);
                     jobPointLogMapper.upsertSelective(jobPointLog);
@@ -122,12 +129,10 @@ public class SkuJsonHandle {
                     SessionUtil.closeSession();
                 }
             }
-        } while (jobPointLog.getPageIndex() <= totalPage);
-        if (jobPointLog.getPageIndex() > totalPage) {
-            jobPointLog.setPageIndex(1);
-            jobPointLog.setStartTime(jobPointLog.getEndTime());
-            jobPointLog.setEndTime(jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()).isAfter(LocalDateTime.now()) ? LocalDateTime.now() : jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()));
-        }
+        } while (jobPointLog.getPageIndex() > 0);
+        jobPointLog.setPageIndex(0);
+        jobPointLog.setStartTime(jobPointLog.getEndTime());
+        jobPointLog.setEndTime(jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()).isAfter(LocalDateTime.now()) ? LocalDateTime.now() : jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()));
     }
 
     static void handleSkuResultJSON(List<CommonSkuProductInfo> allSkuProductInfoList) {

data-base/base-sync-sku/src/main/java/com/bailuntec/job/SkuSyncByUpdateTimeJob.java

@@ -20,8 +20,6 @@ public class SkuSyncByUpdateTimeJob extends PointJob {
         skuConditionDto.setIsFinish(-1);
         //有ResultWare返回发货仓库信息
         skuConditionDto.setIsResultWare(1);
-        //有SKU只查提供的SKU
-//        skuConditionDto.setSkus("438396007");
         //有UpdateDate只查当天更新的数据-增量更新
         skuConditionDto.setUpdateDate(jobPointLog.getStartTime().format(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT)));
         SkuJsonHandle.skuMSRequest(skuConditionDto, jobPointLog);

data-base/base-sync-sku/src/main/java/com/bailuntec/job/SkuSyncJob.java

@@ -20,7 +20,6 @@ public class SkuSyncJob extends PointJob {
         //有SKU只查提供的SKU
 //        skuConditionDto.setSkus("909117825");
         //有UpdateDate只查当天更新的数据-增量更新
-//        skuConditionDto.setUpdateDate(jobPointLog.getStartTime().format(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT)));
         SkuJsonHandle.skuMSRequest(skuConditionDto, jobPointLog);
     }
 

data-base/base-sync-sku/src/test/java/SyncSkuTest.java

 import com.bailuntec.domain.entity.JobPointLog;
 import com.bailuntec.job.SkuSyncByCreateTimeJob;
+import com.bailuntec.job.SkuSyncByUpdateTimeJob;
 import com.bailuntec.job.SkuSyncJob;
 import org.junit.jupiter.api.Test;
 
@@ -9,7 +10,7 @@ public class SyncSkuTest {
     @Test
     public void test() {
         SkuSyncJob skuSyncJob = new SkuSyncJob();
-        skuSyncJob.executeJob(null, new JobPointLog("base-sku",1 ,100,1,1, LocalDateTime.now(),LocalDateTime.now()));
+        skuSyncJob.executeJob(null, new JobPointLog("base-sku",0 ,100,1,1, LocalDateTime.now(),LocalDateTime.now()));
     }
     @Test
     public void tes1() {
@@ -18,4 +19,11 @@ public class SyncSkuTest {
                 LocalDateTime.of(2019,03,01,0,0),
                 LocalDateTime.now()));
     }
+    @Test
+    public void tes2() {
+        SkuSyncByUpdateTimeJob skuSyncJob = new SkuSyncByUpdateTimeJob();
+        skuSyncJob.executeJob(null, new JobPointLog("base-sku",1 ,100,1,1,
+                LocalDateTime.of(2019,03,21,0,0),
+                LocalDateTime.now()));
+    }
 }