From 46165ccd97bc48d84388da38290e640d6808ed58 Mon Sep 17 00:00:00 2001
From: wangxiaopeng <157894372@qq.com>
Date: Tue, 18 Apr 2023 14:43:38 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E4=BB=BB=E5=8A=A1=E6=89=A7?=
 =?UTF-8?q?=E8=A1=8C=E7=BB=93=E6=9E=9C=EF=BC=8C=E5=B9=B6=E5=B0=86=E7=BB=93?=
 =?UTF-8?q?=E6=9E=9C=E8=BF=94=E5=9B=9E=E7=BB=99=E6=8E=A7=E5=88=B6=E5=8F=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../samples/tester/SpringMethodProcessorService.java | 12 ++++++++++--
 .../worker/processor/MethodBasicProcessor.java       |  5 +++--
 2 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java b/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java
index 62138555..cf9282c4 100644
--- a/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java
+++ b/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java
@@ -9,9 +9,17 @@ import tech.powerjob.worker.log.OmsLogger;
 public class SpringMethodProcessorService {
 
     @PowerJob("test")
-    public void test(TaskContext context) {
+    public String test(TaskContext context) {
         OmsLogger omsLogger = context.getOmsLogger();
         omsLogger.warn("测试日志");
-        System.out.println("测试执行");
+        return null;
+    }
+
+
+    @PowerJob("test1")
+    public String test1(TaskContext context) {
+        OmsLogger omsLogger = context.getOmsLogger();
+        omsLogger.warn("测试日志");
+        return "测试日志";
     }
 }
diff --git a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java
index 84425ecc..b2634203 100644
--- a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java
+++ b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java
@@ -1,5 +1,6 @@
 package tech.powerjob.worker.processor;
 
+import tech.powerjob.common.serialize.JsonUtils;
 import tech.powerjob.worker.core.processor.ProcessResult;
 import tech.powerjob.worker.core.processor.TaskContext;
 import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
@@ -19,7 +20,7 @@ public class MethodBasicProcessor implements BasicProcessor {
 
     @Override
     public ProcessResult process(TaskContext context) throws Exception {
-        method.invoke(bean,context);
-        return new ProcessResult(true);
+        Object result = method.invoke(bean, context);
+        return new ProcessResult(true, JsonUtils.toJSONString(result));
     }
 }