Commit 16dee114 by huluobin

# 更新

parent 91a9ea54
package com.bailuntec;
import com.alibaba.druid.pool.DruidDataSource;
import com.bailuntec.domain.constant.Constant;
import com.bailuntec.job.AutoTurnoverJob;
import com.bailuntec.job.QueueConsumerJob;
import com.bailuntec.job.ReplaceLogisticJob;
......@@ -45,11 +46,37 @@ public class Application {
new JobScheduler(createRegistryCenter(),
createJobConfigurationNeNormal()).init();
// new JobScheduler(createRegistryCenter(),
// createJobConfigurationWeek()).init();
new JobScheduler(createRegistryCenter(),
createJobConfigurationOcean()).init();
new JobScheduler(createRegistryCenter(),
createJobConfigurationAir()).init();
}
private static LiteJobConfiguration createJobConfigurationAir() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
"auto_turnover_air",
"0 0 3 * * ?",
8)
.jobParameter(Constant.AIR_HEAD)
.build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, AutoTurnoverJob.class.getCanonicalName());
return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
}
private static LiteJobConfiguration createJobConfigurationOcean() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
"auto_turnover_ocean",
"0 0 3 * * ?",
8)
.jobParameter(Constant.OCEAN_HEAD)
.build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, AutoTurnoverJob.class.getCanonicalName());
return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
}
private static LiteJobConfiguration createQueueConsumer() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
"queueConsumer2",
......@@ -90,18 +117,6 @@ public class Application {
return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
}
private static LiteJobConfiguration createJobConfigurationWeek() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
propertiesUtil.getPropertyAsString("JOB_NAME_WEEK"),
propertiesUtil.getPropertyAsString("JOB_WEEK_CRON"),
propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT"))
.jobParameter("NORMAL")
.build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, AutoTurnoverJob.class.getCanonicalName());
return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
}
private static LiteJobConfiguration createJobConfigurationNeNormal() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
......
......@@ -49,6 +49,16 @@ public class AutoTurnoverJobTest {
autoTurnoverJob.executeJob(new ShardingContext(new ShardingContexts("x", null, 1, Constant.OCEAN_HEAD, new HashMap<>()), 0),
jobPointLog);
}
@Test
public void syncSpec2() {
JobPointLog jobPointLog = new JobPointLog();
jobPointLog.setPageIndex(1);
jobPointLog.setPageSize(1000);
AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
autoTurnoverJob.executeJob(new ShardingContext(new ShardingContexts("x", null, 1, Constant.AIR_HEAD, new HashMap<>()), 0),
jobPointLog);
}
@Test
......
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