From 2223a0496621469ee57d8b1ae6b586b552d299ad Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E4=B9=BE=E7=BF=94?= Date: Wed, 29 Apr 2026 17:31:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5ERP=E4=BE=9B=E5=BA=94?= =?UTF-8?q?=E5=95=86=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../oem/OemCustomerSyncProcessor.java | 26 ++++++------------- 1 file changed, 8 insertions(+), 18 deletions(-) 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 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()); + } } }