id == 151 svip升级

protocol/userProxy.proto

@@ -403,3 +403,9 @@ message CpUpgrade {
     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

rpc/user_center_coder.go

@@ -65,6 +65,7 @@ const (
 	MsgTypeSheepGameResult          = 148 // 羊羊游戏结果
 	MsgTypeCpInvite                 = 149 // cp邀请
 	MsgTypeCpUpgrade                = 150 // cp升级
+	MsgTypeSvipUpgrade              = 151 // svip升级
 )
 
 const (

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
+}