From 83e10079d5c3a209078612998ad6737231c06ad5 Mon Sep 17 00:00:00 2001 From: jinqiao Date: Thu, 20 Aug 2026 09:12:27 +0800 Subject: [PATCH] =?UTF-8?q?fix(=E5=8D=8F=E8=AE=AE=E7=AE=A1=E7=90=86):=20?= =?UTF-8?q?=E8=A1=A5=E9=BD=90=E5=8D=8F=E8=AE=AE=E5=8C=85=E8=A3=85=E5=99=A8?= =?UTF-8?q?=E6=96=B9=E6=B3=95=E5=A7=94=E6=89=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --- .../protocol/RenameProtocolSupport.java | 17 +++++++++ .../local/LocalFileProtocolSupport.java | 36 +++++++++++++++++++ 2 files changed, 53 insertions(+) diff --git a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java index 5b63b143f..c8e6418d3 100755 --- a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java +++ b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java @@ -22,10 +22,12 @@ import org.jetlinks.core.device.*; import org.jetlinks.core.event.EventBus; import org.jetlinks.core.message.codec.DeviceMessageCodec; +import org.jetlinks.core.message.codec.MessageParserFactory; import org.jetlinks.core.message.codec.TraceDeviceMessageCodec; import org.jetlinks.core.message.codec.Transport; import org.jetlinks.core.message.interceptor.DeviceMessageSenderInterceptor; import org.jetlinks.core.metadata.*; +import org.jetlinks.core.principal.PrincipalMetadata; import org.jetlinks.core.route.Route; import org.jetlinks.core.server.ClientConnection; import org.jetlinks.core.server.DeviceGatewayContext; @@ -156,6 +158,11 @@ public Mono getConfigMetadata(Transport transport) { return target.getConfigMetadata(transport); } + @Override + public Flux getAllConfigMetadata(Transport transport) { + return target.getAllConfigMetadata(transport); + } + @Override public void init(Map configuration) { target.init(configuration); @@ -244,6 +251,16 @@ public Mono doBeforeDeviceCreate(Transport transport, DeviceInfo dev return target.doBeforeDeviceCreate(transport, deviceInfo); } + @Override + public Flux getDevicePrincipalMetadata(Transport transport, DeviceInfo deviceInfo) { + return target.getDevicePrincipalMetadata(transport, deviceInfo); + } + + @Override + public Mono getMessageParser(Transport transport) { + return target.getMessageParser(transport); + } + @Override public int getOrder() { return target.getOrder(); diff --git a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java index c53057acd..b36209af8 100644 --- a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java +++ b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java @@ -22,14 +22,17 @@ import org.jetlinks.core.ProtocolSupport; import org.jetlinks.core.device.*; import org.jetlinks.core.message.codec.DeviceMessageCodec; +import org.jetlinks.core.message.codec.MessageParserFactory; import org.jetlinks.core.message.codec.Transport; import org.jetlinks.core.message.interceptor.DeviceMessageSenderInterceptor; import org.jetlinks.core.metadata.*; +import org.jetlinks.core.principal.PrincipalMetadata; import org.jetlinks.core.route.Route; import org.jetlinks.core.server.ClientConnection; import org.jetlinks.core.server.DeviceGatewayContext; import org.jetlinks.core.spi.ProtocolSupportProvider; import org.jetlinks.core.spi.ServiceContext; +import org.jetlinks.core.things.ThingRpcSupportChain; import org.jetlinks.supports.protocol.management.jar.ProtocolClassLoader; import org.springframework.util.ClassUtils; import org.springframework.util.StringUtils; @@ -231,6 +234,11 @@ public Mono getConfigMetadata(Transport transport) { return loaded.getConfigMetadata(transport); } + @Override + public Flux getAllConfigMetadata(Transport transport) { + return loaded.getAllConfigMetadata(transport); + } + @Override public Mono getInitConfigMetadata() { return loaded.getInitConfigMetadata(); @@ -325,6 +333,21 @@ public Mono doBeforeDeviceCreate(Transport transport, DeviceInfo dev return loaded.doBeforeDeviceCreate(transport, deviceInfo); } + @Override + public Flux getDevicePrincipalMetadata(Transport transport, DeviceInfo deviceInfo) { + return loaded.getDevicePrincipalMetadata(transport, deviceInfo); + } + + @Override + public ThingRpcSupportChain getRpcChain() { + return loaded.getRpcChain(); + } + + @Override + public Mono getMessageParser(Transport transport) { + return loaded.getMessageParser(transport); + } + @Override public int getOrder() { return loaded.getOrder(); @@ -349,4 +372,17 @@ public String getDocument(Transport transport) { public boolean isEmbedded() { return loaded.isEmbedded(); } + + @Override + public boolean isWrapperFor(Class type) { + return type.isInstance(this) || loaded.isWrapperFor(type); + } + + @Override + public T unwrap(Class type) { + if (type.isInstance(this)) { + return type.cast(this); + } + return loaded.unwrap(type); + } }