feat:rpc多加一个socket命令给你

rpc/user_center_coder.go

@@ -58,6 +58,8 @@ const (
 	MsgTypeMatchV2Confirm           = 141 // 匹配-v2-确认
 	MsgTypeMatchV2CallReady         = 142 // 匹配-v2-callReady
 	MsgTypeMatchV2AddTimeGift       = 143 // 匹配-v2-送礼加时长
+	MsgRoomInviteMember             = 144 // 邀请用户成为房间会员
+	MsgDiamondChange                = 145 // 钻石数变化
 )
 
 const (

rpc/user_center_func.go

@@ -65,3 +65,19 @@ func SendGlobalRocketNotice(groupId string, period string, round uint32, stage u
 	}
 	return nil
 }
+
+func SendDiamondChange(userId uint64) error {
+	rspUids, err := multicast([]uint64{userId}, MsgDiamondChange, []byte(""))
+	//记录socket,注意闭包问题
+	go func(userId uint64, rspUids []uint64, err error) {
+		AddRpcLog(MsgDiamondChange, userId, "", rspUids, err)
+	}(userId, rspUids, err)
+
+	if err != nil {
+		mylogrus.MyLog.Errorf("grpc SendDiamondChange send fail")
+		return err
+	} else {
+		mylogrus.MyLog.Info("grpc SendDiamondChange send success")
+	}
+	return nil
+}