From 5d2545c1755115a756f1db9a9ed19dce4c675b5e Mon Sep 17 00:00:00 2001
From: hujiebin <iamhujiebin@users.noreply.github.com>
Date: Thu, 29 Jun 2023 11:30:55 +0800
Subject: [PATCH] =?UTF-8?q?id=20=3D=3D=20151=20svip=E5=8D=87=E7=BA=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 protocol/userProxy.proto |  6 ++++++
 rpc/user_center_coder.go |  1 +
 rpc/user_center_func.go  | 27 +++++++++++++++++++++++++++
 3 files changed, 34 insertions(+)

diff --git a/protocol/userProxy.proto b/protocol/userProxy.proto
index 7503b54..f3c141c 100644
--- a/protocol/userProxy.proto
+++ b/protocol/userProxy.proto
@@ -402,4 +402,10 @@ message CpUpgrade {
     User user2 = 2;
     uint32 cp_level = 3;
     string group_id = 4;
+}
+
+/* id == 151 svip升级 */
+message SvipUpgrade {
+    User user = 1;
+    uint32 svip_level = 2;
 }
\ No newline at end of file
diff --git a/rpc/user_center_coder.go b/rpc/user_center_coder.go
index 7971594..4caea3f 100644
--- a/rpc/user_center_coder.go
+++ b/rpc/user_center_coder.go
@@ -65,6 +65,7 @@ const (
 	MsgTypeSheepGameResult          = 148 // 羊羊游戏结果
 	MsgTypeCpInvite                 = 149 // cp邀请
 	MsgTypeCpUpgrade                = 150 // cp升级
+	MsgTypeSvipUpgrade              = 151 // svip升级
 )
 
 const (
diff --git a/rpc/user_center_func.go b/rpc/user_center_func.go
index 3741418..fbccb4f 100644
--- a/rpc/user_center_func.go
+++ b/rpc/user_center_func.go
@@ -359,3 +359,30 @@ func SendCpUpgrade(nick1, nick2, avatar1, avatar2 string, cpLevel uint32, groupI
 	}
 	return nil
 }
+
+// svip升级
+func SendSvipUpgrade(nick, avatar string, svipLevel uint32) error {
+	msg := &userProxy.SvipUpgrade{
+		User:      &userProxy.User{Nick: nick, Avatar: avatar},
+		SvipLevel: svipLevel,
+	}
+	if buffer, err := proto.Marshal(msg); err == nil {
+		rspUids, err := broadcast(MsgTypeSvipUpgrade, buffer)
+
+		//记录socket,注意闭包问题
+		go func(userId uint64, msg *userProxy.SvipUpgrade, rspUids []uint64, err error) {
+			buf, _ := json.Marshal(msg)
+			AddRpcLog(MsgTypeSvipUpgrade, userId, string(buf[:]), rspUids, err)
+		}(0, msg, rspUids, err)
+
+		if err != nil {
+			mylogrus.MyLog.Errorf("grpc SendSvipUpgrade send fail")
+			return err
+		} else {
+			mylogrus.MyLog.Info("grpc SendSvipUpgrade send success")
+		}
+	} else {
+		return err
+	}
+	return nil
+}
-- 
2.22.0