From 713d0220783b4ee843b9da61e7b85779ae4ce404 Mon Sep 17 00:00:00 2001
From: zhenggm <zhenggm@jujiatech.com>
Date: Wed, 14 Sep 2022 10:35:03 +0800
Subject: [PATCH] =?UTF-8?q?=E7=B3=BB=E7=BB=9F=EF=BC=9A=E5=AE=9A=E6=97=B6?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/cc/smtweb/system/bpm/web/BpmStartedListener.java  |  3 +++
 .../cc/smtweb/system/bpm/web/sys/base/job/TestJob.java     | 14 ++++++++++++++
 .../smtweb/framework/core/systask/SingleRequestHelper.java |  1 +
 3 files changed, 18 insertions(+)
 create mode 100644 smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/base/job/TestJob.java

diff --git a/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/BpmStartedListener.java b/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/BpmStartedListener.java
index f640834..88be51b 100644
--- a/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/BpmStartedListener.java
+++ b/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/BpmStartedListener.java
@@ -9,6 +9,7 @@ import cc.smtweb.framework.core.mvc.controller.IStartListener;
 import cc.smtweb.framework.core.mvc.service.TreeHelper;
 import cc.smtweb.framework.core.systask.SysServiceFactory;
 import cc.smtweb.system.bpm.web.design.db.ModelCatalogTreeHelper;
+import cc.smtweb.system.bpm.web.sys.base.job.JobUtils;
 import cc.smtweb.system.bpm.web.sys.oneTimeService.OneTimeServiceFactory;
 import cc.smtweb.system.bpm.web.sys.oneTimeService.OneTimeTaskCleanService;
 
@@ -36,10 +37,12 @@ public class BpmStartedListener implements IStartListener {
         //初始化缓存
         CacheManager.getIntance().init();
         OneTimeServiceFactory.getInstance().start();
+        JobUtils.getInstance().start();
     }
 
     @Override
     public void close() {
         OneTimeServiceFactory.getInstance().stop();
+        JobUtils.getInstance().stop();
     }
 }
diff --git a/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/base/job/TestJob.java b/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/base/job/TestJob.java
new file mode 100644
index 0000000..c358aa7
--- /dev/null
+++ b/smtweb-framework/bpm/src/main/java/cc/smtweb/system/bpm/web/sys/base/job/TestJob.java
@@ -0,0 +1,14 @@
+package cc.smtweb.system.bpm.web.sys.base.job;
+
+import cc.smtweb.framework.core.util.DateUtil;
+
+/**
+ * Created by Akmm at 2022-09-14 10:32
+ */
+public class TestJob extends BaseJob {
+    @Override
+    protected String work() {
+        System.out.println("执行了" + DateUtil.nowDateTimeString());
+        return "哈哈，成功了";
+    }
+}
diff --git a/smtweb-framework/core/src/main/java/cc/smtweb/framework/core/systask/SingleRequestHelper.java b/smtweb-framework/core/src/main/java/cc/smtweb/framework/core/systask/SingleRequestHelper.java
index d701938..01c5516 100644
--- a/smtweb-framework/core/src/main/java/cc/smtweb/framework/core/systask/SingleRequestHelper.java
+++ b/smtweb-framework/core/src/main/java/cc/smtweb/framework/core/systask/SingleRequestHelper.java
@@ -5,6 +5,7 @@ import cc.smtweb.framework.core.exception.SwException;
 import cc.smtweb.framework.core.util.DateUtil;
 import cc.smtweb.framework.core.util.StringUtil;
 
+//redis控制的互斥执行，一般用于定时任务，避免多服务器重复执行
 public class SingleRequestHelper {
 
     public static interface ISingleWork {