From 97e647092c59192964b63ac3c524b098376c4171 Mon Sep 17 00:00:00 2001 From: icey-yu <1186114839@qq.com> Date: Mon, 2 Sep 2024 14:40:29 +0800 Subject: [PATCH] fix: rpc log print --- mw/rpc_client_interceptor.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/mw/rpc_client_interceptor.go b/mw/rpc_client_interceptor.go index bd2138e..25f9a87 100644 --- a/mw/rpc_client_interceptor.go +++ b/mw/rpc_client_interceptor.go @@ -16,6 +16,7 @@ package mw import ( "context" + "errors" "fmt" "strings" @@ -46,8 +47,11 @@ func RpcClientInterceptor(ctx context.Context, method string, req, resp any, cc if err == nil { log.ZInfo(ctx, fmt.Sprintf("RPC Client Response Success - %s", extractFunctionName(method)), "funcName", method, "resp", resp) return nil + } else if errors.Is(err, errs.ErrRecordNotFound) { + log.ZWarn(ctx, fmt.Sprintf("RPC Client Response Error - %s", extractFunctionName(method)), err, "funcName", method) + } else { + log.ZError(ctx, fmt.Sprintf("RPC Client Response Error - %s", extractFunctionName(method)), err, "funcName", method) } - log.ZError(ctx, fmt.Sprintf("RPC Client Response Error - %s", extractFunctionName(method)), err, "funcName", method) rpcErr, ok := err.(interface{ GRPCStatus() *status.Status }) if !ok { return errs.ErrInternalServer.WrapMsg(err.Error())