From d0f1eb13ee4a9bfdc1732da97f0d71c029140512 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Sat, 3 Sep 2022 12:43:06 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=8A=82=E7=82=B9=E6=B4=BB?= =?UTF-8?q?=E8=B7=83=E6=A3=80=E6=B5=8B=E6=9C=BA=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/rpc/services/service_node_stream.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/internal/rpc/services/service_node_stream.go b/internal/rpc/services/service_node_stream.go index 9133b91b..189b281c 100644 --- a/internal/rpc/services/service_node_stream.go +++ b/internal/rpc/services/service_node_stream.go @@ -124,6 +124,7 @@ func (this *NodeService) NodeStream(server pb.NodeService_NodeStreamServer) erro return err } if inactiveNotifiedAt > 0 { + // 设置为活跃 err = models.SharedNodeDAO.UpdateNodeActive(tx, nodeId, true) if err != nil { return err @@ -144,6 +145,12 @@ func (this *NodeService) NodeStream(server pb.NodeService_NodeStreamServer) erro if err != nil { return err } + } else { + // 设置为活跃 + err = models.SharedNodeDAO.UpdateNodeActive(tx, nodeId, true) + if err != nil { + return err + } } }