From 2e4a25f76266f96918e14b74b51f964a5d4e79a9 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sun, 6 Jun 2021 13:40:33 +0800 Subject: [PATCH] =?UTF-8?q?=E8=81=9A=E5=90=88=E6=9C=8D=E5=8A=A1=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/rpc/services/service_node_log.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/internal/rpc/services/service_node_log.go b/internal/rpc/services/service_node_log.go index 16641e81..17a23e73 100644 --- a/internal/rpc/services/service_node_log.go +++ b/internal/rpc/services/service_node_log.go @@ -5,6 +5,7 @@ import ( "github.com/TeaOSLab/EdgeAPI/internal/db/models" rpcutils "github.com/TeaOSLab/EdgeAPI/internal/rpc/utils" "github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb" + "github.com/iwind/TeaGo/lists" "github.com/iwind/TeaGo/types" ) @@ -61,8 +62,18 @@ func (this *NodeLogService) ListNodeLogs(ctx context.Context, req *pb.ListNodeLo return nil, err } + hashList := []string{} + result := []*pb.NodeLog{} for _, log := range logs { + // 如果是需要修复的日志，我们需要去重 + if req.FixedState > 0 { + if lists.ContainsString(hashList, log.Hash) { + continue + } + hashList = append(hashList, log.Hash) + } + result = append(result, &pb.NodeLog{ Id: int64(log.Id), Role: log.Role,