From 4ac3626b9200bf6ffc5ad379531d09290d0398be Mon Sep 17 00:00:00 2001 From: chenxing Date: Mon, 28 Sep 2026 17:26:30 +0800 Subject: [PATCH] =?UTF-8?q?refactor(flow):=20=E7=9B=AE=E5=BD=95=E9=94=AE?= =?UTF-8?q?=E5=BD=92=E4=B8=80=20flowcenter=E2=86=92flow-center=EF=BC=88D1?= =?UTF-8?q?=EF=BC=89=E2=80=94=E2=80=94PlatformService.FLOW=5FCENTER=20?= =?UTF-8?q?=E6=9C=BA=E6=A2=B0=E8=B7=9F=E9=9A=8F=EF=BC=8CFlowCenterClientTe?= =?UTF-8?q?st=20=E5=A4=B1=E8=B4=A5=E6=96=87=E6=A1=88=E6=96=AD=E8=A8=80?= =?UTF-8?q?=E5=90=8C=E6=AD=A5=E6=96=B0=E9=94=AE=EF=BC=9BNoticeFlowProperti?= =?UTF-8?q?es=20=E6=B3=A8=E9=87=8A=E6=AE=8B=E7=95=99=E9=9A=8F=E7=A7=BB?= =?UTF-8?q?=E5=8A=A8=E9=97=A8=E6=88=B7=E7=BA=BF=20WIP=20=E5=90=8E=E7=BB=AD?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/yunhai/notice/service/flow/FlowCenterClient.java | 6 +++--- .../yunhai/notice/service/flow/NoticeApprovalClient.java | 2 +- .../yunhai/notice/service/flow/FlowCenterClientTest.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/yunhai/notice/service/flow/FlowCenterClient.java b/src/main/java/com/yunhai/notice/service/flow/FlowCenterClient.java index 9e47673..566ba80 100644 --- a/src/main/java/com/yunhai/notice/service/flow/FlowCenterClient.java +++ b/src/main/java/com/yunhai/notice/service/flow/FlowCenterClient.java @@ -18,7 +18,7 @@ import java.util.Map; /** * FlowClient 默认实现：主路径走 SDK 类型化门面 {@link YschFlowOpenApi}（服务目录 key= - * {@code flowcenter}：yh.call.targets > yh.open.services > 枚举 base-host 兜底， + *{@code flow-center}：yh.call.targets > yh.open.services > 枚举 base-host 兜底， * 《子应用配置优化方案》§4.2 零专属地址配置）；目录未显式配置时回落本应用 legacy 键 * {@code notice.flow.base-url}（ad-hoc TargetSpec，迁移期兼容）。签名/信封解析/错误映射 * 全部由 SDK 统一承载（401/403→DException、code!=0→DException、传输错→OpenApiException）。 @@ -54,7 +54,7 @@ public class FlowCenterClient implements FlowClient { } this.openCall = call; // 服务目录显式配置（targets/services）则走门面命名目标；否则回落 legacy base-url ad-hoc - this.directoryResolved = call.hasTarget(com.yunhai.platform.openapi.core.PlatformService.FLOWCENTER.key()); + this.directoryResolved = call.hasTarget(com.yunhai.platform.openapi.core.PlatformService.FLOW_CENTER.key()); if (directoryResolved) { com.yunhai.platform.openapi.flow.YschFlowOpenApi.setCall(call); } @@ -64,7 +64,7 @@ public class FlowCenterClient implements FlowClient { // 避免静默打 localhost 把"地址没配"伪装成"流程中心不可达"。 // enabled=false（显式未接入）时不校验——地址本就不需要。 throw new IllegalStateException("流程中心调用地址未配置：请配置服务目录 yh.open.services." - + com.yunhai.platform.openapi.core.PlatformService.FLOWCENTER.key() + + com.yunhai.platform.openapi.core.PlatformService.FLOW_CENTER.key() + "（推荐，容器直连完整 URL）或回落键 notice.flow.base-url"); } } diff --git a/src/main/java/com/yunhai/notice/service/flow/NoticeApprovalClient.java b/src/main/java/com/yunhai/notice/service/flow/NoticeApprovalClient.java index 85036d2..e326a0a 100644 --- a/src/main/java/com/yunhai/notice/service/flow/NoticeApprovalClient.java +++ b/src/main/java/com/yunhai/notice/service/flow/NoticeApprovalClient.java @@ -26,7 +26,7 @@ import java.util.Map; @Service public class NoticeApprovalClient { - private static final String TARGET = PlatformService.FLOWCENTER.key(); + private static final String TARGET = PlatformService.FLOW_CENTER.key(); private static final String NOT_CONNECTED = "流程中心未接入，审批功能不可用"; private final NoticeFlowProperties properties; diff --git a/src/test/java/com/yunhai/notice/service/flow/FlowCenterClientTest.java b/src/test/java/com/yunhai/notice/service/flow/FlowCenterClientTest.java index 952270f..3fcd415 100644 --- a/src/test/java/com/yunhai/notice/service/flow/FlowCenterClientTest.java +++ b/src/test/java/com/yunhai/notice/service/flow/FlowCenterClientTest.java @@ -150,7 +150,7 @@ class FlowCenterClientTest { (host, basePath) -> java.util.Collections.emptyList()); IllegalStateException e = assertThrows(IllegalStateException.class, () -> new FlowCenterClient(props, new FixedProvider<>(openCall), null, objectMapper)); - assertTrue(e.getMessage().contains("yh.open.services.flowcenter"), e.getMessage()); + assertTrue(e.getMessage().contains("yh.open.services.flow-center"), e.getMessage()); assertTrue(e.getMessage().contains("notice.flow.base-url"), e.getMessage()); }