改为拿所有平台订单

data-base/base-sync-oms-order/src/main/java/com/bailuntec/job/OrderSyncJob.java

@@ -39,7 +39,7 @@ public class OrderSyncJob extends PointJob {
     public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
         LinkedHashMap<String, String> map = new LinkedHashMap<>(4);
         //临时处理速卖通数据
-        map.put("Type", "Aliexpress");
+//        map.put("Type", "3");
         map.put("pageCount", jobPointLog.getPageSize().toString());
         //时间回退一点, 避免服务器时间不一致而漏单
         map.put("BailunLastUpdateTimeFrom", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getStartTime().minusMinutes(3)));

data-base/base-sync-oms-order/src/test/java/OmsOrderTest.java

 import com.alibaba.fastjson.JSON;
 import com.bailuntec.domain.entity.JobPointLog;
-import com.bailuntec.domain.example.JobPointLogExample;
 import com.bailuntec.domain.pojo.OmsResultInfo;
 import com.bailuntec.domain.pojo.OmsResultRoot;
 import com.bailuntec.job.OrderSyncJob;
-import com.bailuntec.mapper.JobPointLogMapper;
 import com.bailuntec.utils.OkHttpUtil;
-import com.bailuntec.utils.SessionUtil;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.Response;
@@ -14,6 +11,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.junit.jupiter.api.Test;
 
 import java.io.IOException;
+import java.time.LocalDateTime;
 import java.util.LinkedHashMap;
 
 public class OmsOrderTest {
@@ -60,15 +58,12 @@ public class OmsOrderTest {
     @Test
     public void test4() {
         OrderSyncJob orderSyncJob = new OrderSyncJob();
-        JobPointLog jobPointLog = null;
-        try {
-            JobPointLogMapper mapper = SessionUtil.getSession().getMapper(JobPointLogMapper.class);
-            jobPointLog = mapper.selectOneByExample(JobPointLogExample.newAndCreateCriteria().andJobNameEqualTo("base-sync-oms-order").example());
-        } catch (Exception e) {
-            e.printStackTrace();
-        } finally {
-            SessionUtil.closeSession();
-        }
+        JobPointLog jobPointLog = new JobPointLog();
+        jobPointLog.setPageIndex(0);
+        jobPointLog.setPageSize(100);
+        jobPointLog.setStartTime(LocalDateTime.of(2019,04,01,0,0));
+        jobPointLog.setEndTime(LocalDateTime.of(2019,04,02,0,0));
+        jobPointLog.setIntervalTime(1);
         orderSyncJob.executeJob(null, jobPointLog);
     }