forked from github/dataease
refactor: 删掉不必要的打印
This commit is contained in:
parent
e6cee9d845
commit
e6653fcb3f
@ -62,7 +62,6 @@ public class DsTaskHandler extends TaskHandler implements Job {
|
|||||||
public void execute(JobExecutionContext context) throws JobExecutionException {
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
||||||
JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
|
JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
|
||||||
GlobalTaskEntity taskEntity = (GlobalTaskEntity) jobDataMap.get("taskEntity");
|
GlobalTaskEntity taskEntity = (GlobalTaskEntity) jobDataMap.get("taskEntity");
|
||||||
System.out.println(new Gson().toJson(taskEntity));
|
|
||||||
taskEntity.getJobKey();
|
taskEntity.getJobKey();
|
||||||
|
|
||||||
if (isRunning(taskEntity.getJobKey())) {
|
if (isRunning(taskEntity.getJobKey())) {
|
||||||
@ -93,8 +92,6 @@ public class DsTaskHandler extends TaskHandler implements Job {
|
|||||||
|
|
||||||
private Boolean isRunning(String taskId) {
|
private Boolean isRunning(String taskId) {
|
||||||
ExtTaskInstanceMapper extTaskInstanceMapper = CommonBeanFactory.getBean(ExtTaskInstanceMapper.class);
|
ExtTaskInstanceMapper extTaskInstanceMapper = CommonBeanFactory.getBean(ExtTaskInstanceMapper.class);
|
||||||
System.out.println(extTaskInstanceMapper.runningCount(taskId));
|
|
||||||
|
|
||||||
return extTaskInstanceMapper.runningCount(taskId) > 0;
|
return extTaskInstanceMapper.runningCount(taskId) > 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user