From 5be194e5717c84ac4f51c5bb8c6ca48bf687a466 Mon Sep 17 00:00:00 2001 From: hujiebin Date: Mon, 7 Aug 2023 12:01:31 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9C=89err||uid=E4=B8=8D=E5=9C=A8=E7=BA=BF?= =?UTF-8?q?=E6=89=8D=E5=85=A5=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/user_center_func.go | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/rpc/user_center_func.go b/rpc/user_center_func.go index 15a99b1..4c2804e 100644 --- a/rpc/user_center_func.go +++ b/rpc/user_center_func.go @@ -76,11 +76,14 @@ func SendDiamondChange(userId uint64, diamond, pinkDiamond uint32) error { } if buffer, err := proto.Marshal(msg); err == nil { rspUids, err := multicast([]uint64{userId}, MsgDiamondChange, buffer) - //记录socket,注意闭包问题 - go func(userId uint64, msg *userProxy.DiamondChange, rspUids []uint64, err error) { - buf, _ := json.Marshal(msg) - AddRpcLog(MsgDiamondChange, userId, string(buf[:]), rspUids, err) - }(userId, msg, rspUids, err) + // 记录socket + // 有err||uid不在线才入库 + if err != nil || len(rspUids) > 0 { + go func(userId uint64, msg *userProxy.DiamondChange, rspUids []uint64, err error) { + buf, _ := json.Marshal(msg) + AddRpcLog(MsgDiamondChange, userId, string(buf[:]), rspUids, err) + }(userId, msg, rspUids, err) + } if err != nil { mylogrus.MyLog.Errorf("grpc SendDiamondChange send fail") -- 2.22.0