Commit 1f795387 by huluobin

oms sku sync

parent ba9ba879
...@@ -29,6 +29,7 @@ public class Application { ...@@ -29,6 +29,7 @@ public class Application {
public static void main(String[] args) { public static void main(String[] args) {
new JobScheduler(createRegistryCenter(), createJobConfiguration(), createJobEventConfiguration(), new OrderSyncJobListener()).init(); new JobScheduler(createRegistryCenter(), createJobConfiguration(), createJobEventConfiguration(), new OrderSyncJobListener()).init();
new JobScheduler(createRegistryCenter(), createJobConfiguration1(), createJobEventConfiguration(), new OrderSyncJobListener()).init(); new JobScheduler(createRegistryCenter(), createJobConfiguration1(), createJobEventConfiguration(), new OrderSyncJobListener()).init();
new JobScheduler(createRegistryCenter(), createJobConfiguration2(), createJobEventConfiguration(), new OrderSyncJobListener()).init();
} }
private static CoordinatorRegistryCenter createRegistryCenter() { private static CoordinatorRegistryCenter createRegistryCenter() {
......
...@@ -85,6 +85,8 @@ public class OrderSyncJob extends PointJob { ...@@ -85,6 +85,8 @@ public class OrderSyncJob extends PointJob {
if (omsResultInfo.getResult() != null && omsResultInfo.getResult().size() > 0) { if (omsResultInfo.getResult() != null && omsResultInfo.getResult().size() > 0) {
analyseOmsOrder(omsResultInfo.getResult()); analyseOmsOrder(omsResultInfo.getResult());
} }
log.info("同步百伦订单完成,总共:{}页, 还剩{}页", omsResultInfo.getTotalPages(), jobPointLog.getPageIndex());
} else { } else {
throw new RuntimeException("调用OMS接口同步百伦订单失败, 响应200, 请求参数" + map.toString()); throw new RuntimeException("调用OMS接口同步百伦订单失败, 响应200, 请求参数" + map.toString());
} }
...@@ -103,7 +105,6 @@ public class OrderSyncJob extends PointJob { ...@@ -103,7 +105,6 @@ public class OrderSyncJob extends PointJob {
SessionUtil.closeSession(); SessionUtil.closeSession();
} }
} }
log.info("同步百伦订单完成,还剩{}页", jobPointLog.getPageIndex());
jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1); jobPointLog.setPageIndex(jobPointLog.getPageIndex() - 1);
} while (0 < jobPointLog.getPageIndex()); } while (0 < jobPointLog.getPageIndex());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment