diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java index b9fcfb38..dced3522 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java @@ -8,7 +8,7 @@ import tech.powerjob.worker.log.OmsLogger; import com.google.common.base.Stopwatch; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.exception.ExceptionUtils; -import tech.powerjob.official.processors.util.CommonUtils; +import tech.powerjob.official.processors.util.SimpleUtils; /** * CommonBasicProcessor @@ -33,7 +33,7 @@ public abstract class CommonBasicProcessor implements BasicProcessor { String status = "unknown"; Stopwatch sw = Stopwatch.createStarted(); - omsLogger.info("using params: {}", CommonUtils.parseParams(ctx)); + omsLogger.info("using params: {}", SimpleUtils.parseParams(ctx)); try { ProcessResult result = process0(ctx); diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/HttpProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/HttpProcessor.java index 3a8851aa..68e833b8 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/HttpProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/HttpProcessor.java @@ -10,7 +10,7 @@ import lombok.Data; import okhttp3.*; import org.apache.commons.lang3.StringUtils; import tech.powerjob.official.processors.CommonBasicProcessor; -import tech.powerjob.official.processors.util.CommonUtils; +import tech.powerjob.official.processors.util.SimpleUtils; import java.time.Duration; import java.util.Map; @@ -36,7 +36,7 @@ public class HttpProcessor extends CommonBasicProcessor { @Override public ProcessResult process0(TaskContext taskContext) throws Exception { OmsLogger omsLogger = taskContext.getOmsLogger(); - HttpParams httpParams = JSON.parseObject(CommonUtils.parseParams(taskContext), HttpParams.class); + HttpParams httpParams = JSON.parseObject(SimpleUtils.parseParams(taskContext), HttpParams.class); if (httpParams == null) { String message = "httpParams is null, please check jobParam configuration."; diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/SleepProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/SleepProcessor.java new file mode 100644 index 00000000..47113ee6 --- /dev/null +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/SleepProcessor.java @@ -0,0 +1,38 @@ +package tech.powerjob.official.processors.impl; + +import com.alibaba.fastjson.JSONObject; +import com.google.common.base.Stopwatch; +import lombok.Data; +import tech.powerjob.common.utils.CommonUtils; +import tech.powerjob.official.processors.CommonBasicProcessor; +import tech.powerjob.official.processors.util.SimpleUtils; +import tech.powerjob.worker.core.processor.ProcessResult; +import tech.powerjob.worker.core.processor.TaskContext; + +/** + * just sleep and wait time flies + * eg, can use for workflow delay process + * + * @author KFC·D·Fans + * @since 2021/4/11 + */ +public class SleepProcessor extends CommonBasicProcessor { + + @Override + protected ProcessResult process0(TaskContext ctx) throws Exception { + + Stopwatch sw = Stopwatch.createStarted(); + SleepParams sleepParams = JSONObject.parseObject(SimpleUtils.parseParams(ctx), SleepParams.class); + + if (sleepParams.sleepMillions != null) { + CommonUtils.easySleep(sleepParams.sleepMillions); + } + + return new ProcessResult(true, "total sleep: " + sw.toString()); + } + + @Data + public static class SleepParams { + private Long sleepMillions; + } +} diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/AbstractScriptProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/AbstractScriptProcessor.java index b344f703..d9c91a33 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/AbstractScriptProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/script/AbstractScriptProcessor.java @@ -9,7 +9,7 @@ import org.apache.commons.io.FileUtils; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.SystemUtils; import tech.powerjob.official.processors.CommonBasicProcessor; -import tech.powerjob.official.processors.util.CommonUtils; +import tech.powerjob.official.processors.util.SimpleUtils; import java.io.*; import java.net.URL; @@ -36,7 +36,7 @@ public abstract class AbstractScriptProcessor extends CommonBasicProcessor { @Override protected ProcessResult process0(TaskContext context) throws Exception { OmsLogger omsLogger = context.getOmsLogger(); - String scriptParams = CommonUtils.parseParams(context); + String scriptParams = SimpleUtils.parseParams(context); omsLogger.info("[SYSTEM] ScriptProcessor start to process, params: {}", scriptParams); if (scriptParams == null) { String message = "[SYSTEM] ScriptParams is null, please check jobParam configuration."; diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/AbstractSqlProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/AbstractSqlProcessor.java index 175f614d..03dc6ced 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/AbstractSqlProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/AbstractSqlProcessor.java @@ -9,7 +9,7 @@ import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.springframework.util.StopWatch; import tech.powerjob.official.processors.CommonBasicProcessor; -import tech.powerjob.official.processors.util.CommonUtils; +import tech.powerjob.official.processors.util.SimpleUtils; import tech.powerjob.worker.core.processor.ProcessResult; import tech.powerjob.worker.core.processor.TaskContext; import tech.powerjob.worker.log.OmsLogger; @@ -173,7 +173,7 @@ public abstract class AbstractSqlProcessor extends CommonBasicProcessor { * @return SqlParams */ protected SqlParams extractParams(TaskContext taskContext) { - return JSON.parseObject(CommonUtils.parseParams(taskContext), SqlParams.class); + return JSON.parseObject(SimpleUtils.parseParams(taskContext), SqlParams.class); } /** diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/DynamicDatasourceSqlProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/DynamicDatasourceSqlProcessor.java index 368a0022..3fe477a9 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/DynamicDatasourceSqlProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/sql/DynamicDatasourceSqlProcessor.java @@ -2,7 +2,7 @@ package tech.powerjob.official.processors.impl.sql; import com.alibaba.fastjson.JSONObject; import org.apache.commons.lang3.StringUtils; -import tech.powerjob.official.processors.util.CommonUtils; +import tech.powerjob.official.processors.util.SimpleUtils; import tech.powerjob.official.processors.util.SecurityUtils; import tech.powerjob.worker.core.processor.TaskContext; @@ -29,7 +29,7 @@ public class DynamicDatasourceSqlProcessor extends AbstractSqlProcessor { @Override Connection getConnection(SqlParams sqlParams, TaskContext taskContext) throws SQLException { - JSONObject params = JSONObject.parseObject(CommonUtils.parseParams(taskContext)); + JSONObject params = JSONObject.parseObject(SimpleUtils.parseParams(taskContext)); Properties properties = new Properties(); // normally at least a "user" and "password" property should be included diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/util/CommonUtils.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/util/SimpleUtils.java similarity index 91% rename from powerjob-official-processors/src/main/java/tech/powerjob/official/processors/util/CommonUtils.java rename to powerjob-official-processors/src/main/java/tech/powerjob/official/processors/util/SimpleUtils.java index 714610c4..814d2ecf 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/util/CommonUtils.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/util/SimpleUtils.java @@ -9,9 +9,9 @@ import org.apache.commons.lang3.StringUtils; * @author tjq * @since 2021/2/1 */ -public class CommonUtils { +public class SimpleUtils { - private CommonUtils() { + private SimpleUtils() { }