oms 订单

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

 package com.bailuntec;
 
 import com.alibaba.druid.pool.DruidDataSource;
+import com.bailuntec.job.OrderSyncJob;
 import com.bailuntec.job.OrderSyncJob30;
 import com.bailuntec.listener.OrderSyncJobListener;
-import com.bailuntec.job.OrderSyncJob;
 import com.bailuntec.utils.PropertiesUtil;
 import com.dangdang.ddframe.job.config.JobCoreConfiguration;
 import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
@@ -25,25 +25,27 @@ public class Application {
     private static final String EVENT_RDB_STORAGE_URL = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_URL");
     private static final String EVENT_RDB_STORAGE_USERNAME = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_USERNAME");
     private static final String EVENT_RDB_STORAGE_PASSWORD = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_PASSWORD");
+
     public static void main(String[] args) {
-        new JobScheduler(createRegistryCenter(), createJobConfiguration(),createJobEventConfiguration(), new OrderSyncJobListener()).init();
-        new JobScheduler(createRegistryCenter(), createJobConfiguration1(),createJobEventConfiguration(), new OrderSyncJobListener()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration(), createJobEventConfiguration(), new OrderSyncJobListener()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration1(), createJobEventConfiguration(), new OrderSyncJobListener()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
-         CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(
-                 propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"), propertiesUtil.getPropertyAsString("NAME_SPACE")));
+        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(
+                propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"),
+                propertiesUtil.getPropertyAsString("NAME_SPACE")));
         regCenter.init();
         return regCenter;
     }
 
     private static LiteJobConfiguration createJobConfiguration() {
         JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
-                propertiesUtil.getPropertyAsString("JOB_NAME"), propertiesUtil.getPropertyAsString("JOB_CRON"),
+                propertiesUtil.getPropertyAsString("JOB_NAME"),
+                propertiesUtil.getPropertyAsString("JOB_CRON"),
                 propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
         SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, OrderSyncJob.class.getCanonicalName());
-        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
-        return simpleJobRootConfig;
+        return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
     }
 
     private static LiteJobConfiguration createJobConfiguration1() {
@@ -51,14 +53,21 @@ public class Application {
                 propertiesUtil.getPropertyAsString("JOB_NAME30"),
                 propertiesUtil.getPropertyAsString("JOB_CRON30"),
                 propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
-        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, OrderSyncJob30.class.getCanonicalName());
-        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
-        return simpleJobRootConfig;
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, OrderSyncJob.class.getCanonicalName());
+        return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+    }
+
+    private static LiteJobConfiguration createJobConfiguration2() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
+                propertiesUtil.getPropertyAsString("JOB_COROUTINE_NAME"),
+                propertiesUtil.getPropertyAsString("JOB_COROUTINE_CRON"),
+                propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, OrderSyncJob.class.getCanonicalName());
+        return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
     }
 
     private static JobEventConfiguration createJobEventConfiguration() {
-        JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
-        return jobEventRdbConfig;
+        return new JobEventRdbConfiguration(setUpEventTraceDataSource());
     }
 
     private static DataSource setUpEventTraceDataSource() {

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

@@ -53,7 +53,7 @@ public class OrderSyncJob extends PointJob {
         map.put("DateType", "purchaseTime");*/
         map.put("BailunLastUpdateTimeFrom", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getStartTime().minusMinutes(3)));
         map.put("BailunLastUpdateTimeTo", DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT).format(jobPointLog.getEndTime()));
-
+//        b262eb1bd38f9821dee2dda2ad70c42ed9a9dd77
 //        map.put("BailunLastUpdateTimeFrom", "2020-07-24 00:00:00");
 //        map.put("BailunLastUpdateTimeTo", "2020-07-25 00:00:00");
         do {

data-base/base-sync-oms-order/src/main/resources/const.properties

-BAILUNORDER_URL=http://10.0.0.39/oms/apiV2/bailunOrder/getBailunOrders
-#BAILUNORDER_URL=http://oms.bailuntec.com/apiV2/bailunOrder/getBailunOrders
+#BAILUNORDER_URL=http://10.0.0.39/oms/apiV2/bailunOrder/getBailunOrders
+BAILUNORDER_URL=http://oms.bailuntec.com/apiV2/bailunOrder/getBailunOrders

data-base/base-sync-oms-order/src/main/resources/job.properties

  #EVENT_RDB_STORAGE_DRIVER=com.mysql.jdbc.Driver
-#EVENT_RDB_STORAGE_URL=jdbc:mysql://192.168.6.140:3306/bailun_datacenter?serverTimezone=GMT%2B8&characterEncoding=utf-8
+EVENT_RDB_STORAGE_URL=jdbc:mysql://gz-cdb-kp7s5i79.sql.tencentcdb.com:61691/bailun_datacenter?serverTimezone=GMT%2B8&characterEncoding=utf-8
 #EVENT_RDB_STORAGE_USERNAME=root
 #EVENT_RDB_STORAGE_PASSWORD=123456
+
 #ZOOKEEPER_SERVER=127.0.0.1:2181
 EVENT_RDB_STORAGE_DRIVER=com.mysql.jdbc.Driver
-EVENT_RDB_STORAGE_URL=jdbc:mysql://10.0.8.15:3306/bailun_datacenter?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
+#EVENT_RDB_STORAGE_URL=jdbc:mysql://10.0.8.15:3306/bailun_datacenter?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
 EVENT_RDB_STORAGE_USERNAME=root
 EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf
 ZOOKEEPER_SERVER=172.31.255.120:2181
@@ -15,4 +16,7 @@ JOB_CRON=0/1 * * * * ? *
 JOB_NAME30=base-sync-oms-skus30
 #JOB_NAME=base-sync-oms-order
 JOB_CRON30=0 0 22,23,00 * * ? *
+
+JOB_COROUTINE_NAME=base-sync-oms-order-coroutine
+JOB_COROUTINE_CRON=0 1 12 * * ?
 SHARDING_TOTAL_COUNT=1