修改job任务启动类

data-base/base-sync-sku/Dockerfile

@@ -20,4 +20,4 @@ RUN cd /usr/app/data-parent && mvn -T 1C install  -pl ../data-base/base-sync-sku
 
 #指定容器启动程序及参数   <ENTRYPOINT> "<CMD>"
 EXPOSE 8080
-ENTRYPOINT ["java","-Xms30m","-Xmx80m","-jar","/usr/app/data-base/base-sync-sku/target/base-sync-sku-1.0-SNAPSHOT.jar"]
\ No newline at end of file
+ENTRYPOINT ["java","-Xms80m","-Xmx130m","-jar","/usr/app/data-base/base-sync-sku/target/base-sync-sku-1.0-SNAPSHOT.jar"]
\ No newline at end of file

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

@@ -2,6 +2,7 @@ package com.bailuntec;
 
 import com.alibaba.druid.pool.DruidDataSource;
 import com.bailuntec.job.SkuMSSyncJob;
+import com.bailuntec.job.SkuMappingSyncJob;
 import com.bailuntec.job.SkuSimpleCategoryJob;
 import com.bailuntec.listener.SkuMSSyncJobListener;
 import com.bailuntec.utils.PropertiesUtil;
@@ -28,6 +29,7 @@ public class Application {
     public static void main(String[] args) {
         new JobScheduler(createRegistryCenter(), createJobConfiguration(),createJobEventConfiguration(), new SkuMSSyncJobListener()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration1()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration2()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
@@ -49,6 +51,13 @@ public class Application {
         return simpleJobRootConfig;
     }
 
+    private static LiteJobConfiguration createJobConfiguration2() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_MAPPING_NAME"), propertiesUtil.getPropertyAsString("JOB_MAPPING_CRON"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, SkuMappingSyncJob.class.getCanonicalName());
+        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+        return simpleJobRootConfig;
+    }
+
     private static JobEventConfiguration createJobEventConfiguration() {
         JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
         return jobEventRdbConfig;

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

@@ -96,8 +96,4 @@ public class SkuMappingSyncJob extends PointJob {
         jobPointLog.setStartTime(jobPointLog.getEndTime());
         jobPointLog.setEndTime(jobPointLog.getStartTime().plusDays(jobPointLog.getIntervalTime().longValue()).isAfter(LocalDateTime.now()) ? LocalDateTime.now() : jobPointLog.getStartTime().plusDays(jobPointLog.getIntervalTime().longValue()));
     }
-
-
-
-
 }