From 168d11b8e3fba7c5c0c4ef0e1d126172146ba502 Mon Sep 17 00:00:00 2001 From: dushixiang Date: Wed, 17 Nov 2021 18:25:29 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=9F=A5=E8=AF=A2=E6=8E=A5?= =?UTF-8?q?=E5=85=A5=E7=BD=91=E5=85=B3=E5=88=97=E8=A1=A8=E7=A9=BA=E6=8C=87?= =?UTF-8?q?=E9=92=88=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/service/access_gateway.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/server/service/access_gateway.go b/server/service/access_gateway.go index 09530c5..705c60a 100644 --- a/server/service/access_gateway.go +++ b/server/service/access_gateway.go @@ -31,6 +31,13 @@ func (r AccessGatewayService) GetGatewayAndReconnectById(accessGatewayId string) func (r AccessGatewayService) GetGatewayById(accessGatewayId string) (g *gateway.Gateway, err error) { g = gateway.GlobalGatewayManager.GetById(accessGatewayId) + if g == nil { + accessGateway, err := r.accessGatewayRepository.FindById(accessGatewayId) + if err != nil { + return nil, err + } + g = r.ReConnect(&accessGateway) + } return g, nil }