diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/oem/OemCustomerSyncProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/oem/OemCustomerSyncProcessor.java
index 12c82ccd..dd8ca920 100644
--- a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/oem/OemCustomerSyncProcessor.java
+++ b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/oem/OemCustomerSyncProcessor.java
@@ -31,23 +31,13 @@ public class OemCustomerSyncProcessor implements BasicProcessor {
 		log.info("========== 开始执行外协厂家管理数据同步定时任务 ==========");
 		log.info("任务参数: {}", context.getJobParams());
 
-		CompletableFuture<Void> runFuture = CompletableFuture.runAsync(() -> {
-			try {
-				oemCustomerTaskClient.syncCustomerFromErp();
-				log.info("外协厂家管理数据同步成功");
-			} catch (Exception e) {
-				log.error("外协厂家管理数据同步异常", e);
-			}
-		});
-
-		runFuture.whenComplete((result, exception) -> {
-			if (exception != null) {
-				log.error("========== 外协厂家管理数据同步定时任务执行失败 ==========", exception);
-			} else {
-				log.info("========== 外协厂家管理数据同步定时任务执行完毕 ==========");
-			}
-		});
-
-		return new ProcessResult(true);
+		try {
+			oemCustomerTaskClient.syncCustomerFromErp();
+			log.info("========== 外协厂家管理数据同步定时任务执行成功 ==========");
+			return new ProcessResult(true, "同步成功");
+		} catch (Exception e) {
+			log.error("========== 外协厂家管理数据同步定时任务执行失败 ==========", e);
+			throw new RuntimeException("外协厂家管理数据同步定时任务执行失败 :" + e.getMessage());
+		}
 	}
 }