third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

获取任务执行结果，并将结果返回给控制台

Browse Source
This commit is contained in:
wangxiaopeng 2023-04-18 14:43:38 +08:00
parent b9bd8079f2
commit 46165ccd97
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java
View File

@ -9,9 +9,17 @@ import tech.powerjob.worker.log.OmsLogger;
public class SpringMethodProcessorService { public class SpringMethodProcessorService {
@PowerJob("test") @PowerJob("test")
public void test(TaskContext context) { public String test(TaskContext context) {
OmsLogger omsLogger = context.getOmsLogger(); OmsLogger omsLogger = context.getOmsLogger();
omsLogger.warn("测试日志"); omsLogger.warn("测试日志");
System.out.println("测试执行"); return null;
}
@PowerJob("test1")
public String test1(TaskContext context) {
OmsLogger omsLogger = context.getOmsLogger();
omsLogger.warn("测试日志");
return "测试日志";
} }
} }

5
powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java
View File

@ -1,5 +1,6 @@
package tech.powerjob.worker.processor; package tech.powerjob.worker.processor;
import tech.powerjob.common.serialize.JsonUtils;
import tech.powerjob.worker.core.processor.ProcessResult; import tech.powerjob.worker.core.processor.ProcessResult;
import tech.powerjob.worker.core.processor.TaskContext; import tech.powerjob.worker.core.processor.TaskContext;
import tech.powerjob.worker.core.processor.sdk.BasicProcessor; import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
@ -19,7 +20,7 @@ public class MethodBasicProcessor implements BasicProcessor {
@Override @Override
public ProcessResult process(TaskContext context) throws Exception { public ProcessResult process(TaskContext context) throws Exception {
method.invoke(bean,context); Object result = method.invoke(bean, context);
return new ProcessResult(true); return new ProcessResult(true, JsonUtils.toJSONString(result));
} }
} }