有err||uid不在线才入库

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,注意闭包问题
+		// 记录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")