Commit 013a03db by Ren Ping

feat:任务执行分布式改造

1 parent f1b376d5
...@@ -28,7 +28,6 @@ public class AutoDispatchJob extends QuartzJobBean { ...@@ -28,7 +28,6 @@ public class AutoDispatchJob extends QuartzJobBean {
@Override @Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try { try {
System.out.println(this);
JobKey jobKey = jobExecutionContext.getJobDetail().getKey(); JobKey jobKey = jobExecutionContext.getJobDetail().getKey();
String name = jobKey.getName(); String name = jobKey.getName();
String teamId = name.substring(TEAM_JOB_PREFIX.length()); String teamId = name.substring(TEAM_JOB_PREFIX.length());
......
...@@ -3,7 +3,7 @@ server: ...@@ -3,7 +3,7 @@ server:
dispatch: dispatch:
cron: cron:
expr: 0 20 8-19 * * ? expr: 0 26 8-19 * * ?
next-day-limit: 2 next-day-limit: 2
# expr: 0 */10 8-18 * * ? # expr: 0 */10 8-18 * * ?
......
...@@ -73,7 +73,7 @@ spring: ...@@ -73,7 +73,7 @@ spring:
job-store-type: jdbc job-store-type: jdbc
#初始化表结构,初始化:always,再次重启改为 embedded #初始化表结构,初始化:always,再次重启改为 embedded
jdbc: jdbc:
initialize-schema: always initialize-schema: embedded
seata: seata:
application-id: ${spring.application.name} application-id: ${spring.application.name}
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!