diff --git a/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/oneTimeService/OneTimeServiceFactory.java b/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/oneTimeService/OneTimeServiceFactory.java index 2a40de1..1ce3b32 100644 --- a/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/oneTimeService/OneTimeServiceFactory.java +++ b/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/oneTimeService/OneTimeServiceFactory.java @@ -39,9 +39,6 @@ public class OneTimeServiceFactory { private OnetimeTaskHelper taskHelper = null; - //服务器编号 - private int runServer = SwConsts.SysParam.machineId; - public OneTimeServiceFactory() { } @@ -82,7 +79,7 @@ public class OneTimeServiceFactory { * @throws Exception */ public void push(String type, String key, String name, long bizId, String inparams, UserSession us) { - if (taskHelper.isExistByKey(type, key)) { + if (getTasksHelper().isExistByKey(type, key)) { throw new BizException("该任务已经存在,不能新增!"); } OnetimeTask task = new OnetimeTask(); @@ -114,7 +111,7 @@ public class OneTimeServiceFactory { * @throws Exception */ public void restart(String type, String key) { - OnetimeTask task = taskHelper.findOneByTk(type, key); + OnetimeTask task = getTasksHelper().findOneByTk(type, key); if (task != null && !task.isNew()) { schedule.schedule(new OneTimeSysService(task), 1L, TimeUnit.MILLISECONDS); } @@ -125,7 +122,7 @@ public class OneTimeServiceFactory { if (schedule != null) { stop(); } - List listService = taskHelper.findWaiting(); + List listService = getTasksHelper().findWaiting(); schedule = Executors.newScheduledThreadPool(max_thread_size); for (OnetimeTask task : listService) { schedule.schedule(new OneTimeSysService(task), 10L, TimeUnit.SECONDS);