From 4c4af75a766e8832dcfbd7c9c4092869027b9d36 Mon Sep 17 00:00:00 2001
From: sk <123456@qq.com>
Date: Thu, 10 Oct 2024 15:26:39 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E5=8D=87=E7=BA=A7?=
 =?UTF-8?q?=E5=A5=96=E5=8A=B1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 data/i18n/languages.json       |   4 +-
 dbproxy/svc/l_loginlog.go      |   4 +
 etcd/keyconf.go                |   1 +
 model/config.go                |   2 +
 model/gameparam.go             |   1 +
 model/loginlog.go              |   4 +-
 model/message.go               |   6 +-
 protocol/doc.md                |   4 +
 protocol/upgrade/upgrade.pb.go | 360 +++++++++++++++++++++++++++++++++
 protocol/upgrade/upgrade.proto |  27 +++
 protocol/webapi/common.pb.go   | 166 +++++++++++----
 protocol/webapi/common.proto   | 158 ++++++++-------
 worldsrv/action_bag.go         |  10 +-
 worldsrv/action_player.go      |  17 +-
 worldsrv/action_welfare.go     |  36 ++++
 worldsrv/addmail.go            | 127 ++++++++++++
 worldsrv/bagmgr.go             |  23 ---
 worldsrv/etcd.go               |  19 ++
 worldsrv/permitmgr.go          |   6 +-
 worldsrv/player.go             |  20 +-
 worldsrv/rankmatch.go          |  16 +-
 worldsrv/trascate_webapi.go    |   4 +-
 22 files changed, 845 insertions(+), 170 deletions(-)
 create mode 100644 protocol/upgrade/upgrade.pb.go
 create mode 100644 protocol/upgrade/upgrade.proto
 create mode 100644 worldsrv/addmail.go

diff --git a/data/i18n/languages.json b/data/i18n/languages.json
index 35281a4..660286c 100644
--- a/data/i18n/languages.json
+++ b/data/i18n/languages.json
@@ -9,5 +9,7 @@
 	"MatchAwardTitle": "{\"zh\":\"话费充值兑换码\",\"vi\":\"Mã nạp tiền ĐT\",\"en\":\"Phone recharge code\",\"kh\":\"កូដបញ្ចូលទូរស័ព្ទ\"}",
 	"MatchAward": "{\"zh\":\"恭喜您获得电话预付卡“%v$”话费充值奖励,兑换码:%v,请尽快使用\",\"vi\":\"Chúc mừng bạn đã nhận được Thẻ trả trước ĐT “%v$” phần thưởng nạp tiền tín dụng ĐT, mã đổi thưởng %v xin sử dụng ngay lập tức\",\"en\":\"Congratulations, you have received the phone prepaid card “%v$” mobile credit top-up reward, redemption code: %v please use it immediately.\",\"kh\":\"សូមអបអរសាទរ អ្នកទទួលបានរង្វាន់កាតបញ្ចូលទូរស័ព្ទ កាតទូរស័ព្ទបង់ប្រាក់ជាមុន “%v$”លេខកូដដោះដូរ %v សូមប្រើវាភ្លាមៗ\"}",
 	"PermitAwardTitle": "{\"zh\":\"通行证排行奖励\",\"vi\":\"Vượt qua phần thưởng xếp hạng\",\"en\":\"Pass Ranking Rewards\",\"kh\":\"រង្វាន់ចំណាត់ថ្នាក់ឆ្លងកាត់\"}",
-	"PermitAward": "{\"zh\":\"恭喜您在上个赛季通行证排行中名次达到%v名，排行奖励已发放，请查收\",\"vi\":\"Chúc mừng bạn đã đạt được %v trong bảng xếp hạng vượt qua. Phần thưởng xếp hạng đã được phân phối, vui lòng kiểm tra.\",\"en\":\"Congratulations on reaching %vth place in the pass ranking. Ranking rewards have been issued. Please check.\",\"kh\":\"សូមអបអរសាទរចំពោះការឈានដល់ចំណាត់ថ្នាក់ទី %v ក្នុងចំណាត់ថ្នាក់ឆ្លងកាត់។ រង្វាន់ចំណាត់ថ្នាក់ត្រូវបានចេញ។ សូមត្រួតពិនិត្យ។\"}"
+	"PermitAward": "{\"zh\":\"恭喜您在上个赛季通行证排行中名次达到%v名，排行奖励已发放，请查收\",\"vi\":\"Chúc mừng bạn đã đạt được %v trong bảng xếp hạng vượt qua. Phần thưởng xếp hạng đã được phân phối, vui lòng kiểm tra.\",\"en\":\"Congratulations on reaching %vth place in the pass ranking. Ranking rewards have been issued. Please check.\",\"kh\":\"សូមអបអរសាទរចំពោះការឈានដល់ចំណាត់ថ្នាក់ទី %v ក្នុងចំណាត់ថ្នាក់ឆ្លងកាត់។ រង្វាន់ចំណាត់ថ្នាក់ត្រូវបានចេញ។ សូមត្រួតពិនិត្យ។\"}",
+	"UpgradeTitle": "{\"zh\":\"更新奖励\",\"vi\":\"\",\"en\":\"\",\"kh\":\"\"}",
+	"Upgrade": "{\"zh\":\"感谢您更新客户端，更新奖励已发放至附近，请注意查收\",\"vi\":\"\",\"en\":\"\",\"kh\":\"\"}"
 }
\ No newline at end of file
diff --git a/dbproxy/svc/l_loginlog.go b/dbproxy/svc/l_loginlog.go
index 312b23d..219386d 100644
--- a/dbproxy/svc/l_loginlog.go
+++ b/dbproxy/svc/l_loginlog.go
@@ -20,7 +20,11 @@ func LoginLogsCollection(plt string) *mongo.Collection {
 			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"logtype"}, Background: true, Sparse: true})
 			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"ip"}, Background: true, Sparse: true})
 			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"time"}, Background: true, Sparse: true})
+			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"-time"}, Background: true, Sparse: true})
 			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"ts"}, Background: true, Sparse: true})
+			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"-ts"}, Background: true, Sparse: true})
+			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"appchannel"}, Background: true, Sparse: true})
+			c_loginlogrec.EnsureIndex(mgo.Index{Key: []string{"clientver"}, Background: true, Sparse: true})
 		}
 		return c_loginlogrec
 	}
diff --git a/etcd/keyconf.go b/etcd/keyconf.go
index 8adc927..093c2bb 100644
--- a/etcd/keyconf.go
+++ b/etcd/keyconf.go
@@ -45,4 +45,5 @@ const (
 	ETCDKEY_RoomType            = "/game/room_type"       // 房间类型配置
 	ETCDKEY_RoomConfig          = "/game/room_config"     // 房间配置
 	ETCDKEY_RoomConfigSystem    = "/game/room_system"     // 系统房间配置
+	ETCDKEY_ClientUpgrade = "/game/client_upgrade"        // 客户端升级奖励配置
 )
diff --git a/model/config.go b/model/config.go
index 8cc0b9a..ebcca5d 100644
--- a/model/config.go
+++ b/model/config.go
@@ -152,6 +152,8 @@ type AllConfig struct {
 	RoomTypeMap map[int32][]*webapi.RoomConfig // key: 房间类型id:房间配置
 	// 系统房间配置
 	RoomConfigSystem map[int32]*webapi.RoomConfigSystem
+	// 客户端升级奖励配置
+	*webapi.ClientUpgrade
 }
 
 type GlobalConfig struct {
diff --git a/model/gameparam.go b/model/gameparam.go
index 62b1e22..751c401 100644
--- a/model/gameparam.go
+++ b/model/gameparam.go
@@ -91,6 +91,7 @@ type GameParam struct {
 	UseAdminPassword           bool     // 是否使用管理员密码
 	CloseCustomRoomCreate      bool     // 关闭自定义房间创建
 	ClientVersion              int32    // 客户端版本号
+	ClientVersionChannel []string       // 客户端版本号包渠道
 }
 
 var GameParamPath = "../data/gameparam.json"
diff --git a/model/loginlog.go b/model/loginlog.go
index d61f152..6a16581 100644
--- a/model/loginlog.go
+++ b/model/loginlog.go
@@ -55,11 +55,12 @@ type LoginLog struct {
 	BuildVersion string
 	AppChannel   string
 	DeviceOS     string
+	ClientVer int32
 }
 
 func NewLoginLog(snId, logType int32, tel, ip, platform, channel, promoter, packageId, city string,
 	clog *ClientLoginInfo, totalCoin int64, gameId, lastGameId int,
-	DeviceName, PackageName, AppVersion, BuildVersion, AppChannel, channelId string) *LoginLog {
+	DeviceName, PackageName, AppVersion, BuildVersion, AppChannel, channelId string, clientVer int32) *LoginLog {
 	now := time.Now()
 	cl := &LoginLog{LogId: bson.NewObjectId()}
 	cl.SnId = snId
@@ -95,6 +96,7 @@ func NewLoginLog(snId, logType int32, tel, ip, platform, channel, promoter, pack
 	cl.AppVersion = AppVersion
 	cl.BuildVersion = BuildVersion
 	cl.AppChannel = AppChannel
+	cl.ClientVer = clientVer
 
 	return cl
 }
diff --git a/model/message.go b/model/message.go
index b8e99e4..53724a8 100644
--- a/model/message.go
+++ b/model/message.go
@@ -73,14 +73,14 @@ type Message struct {
 	CreatTs     int64         //创建时间戳
 	AttachState int32         //附件状态
 	GiftId      string        //
-	Params      []int32       //额外参数
+	Params      []int64       //额外参数
 	Platform    string        //平台信息
 	ShowId      int64         //区分主子游戏大厅
 	Channel     []string      //渠道
 }
 
 func NewMessage(pid string, srcId int32, srcName string, snid, mType int32, title, content string, coin, diamond int64,
-	state int32, addTime int64, attachState int32, giftId string, params []int32, platform string, showId int64, channel []string) *Message {
+	state int32, addTime int64, attachState int32, giftId string, params []int64, platform string, showId int64, channel []string) *Message {
 	if srcName == "" {
 		srcName = "{\"zh\":\"系统\",\"vi\":\"GM\",\"en\":\"GM\",\"kh\":\"GM\"}"
 	}
@@ -110,7 +110,7 @@ func NewMessage(pid string, srcId int32, srcName string, snid, mType int32, titl
 	return msg
 }
 func NewMessageByPlayer(pid string, oper, srcId int32, srcName string, snid, mType int32, title, content string, coin, diamond int64,
-	state int32, addTime int64, attachState int32, giftId string, params []int32, platform string, showId int64) *Message {
+	state int32, addTime int64, attachState int32, giftId string, params []int64, platform string, showId int64) *Message {
 
 	msg := &Message{
 		Id:          bson.NewObjectId(),
diff --git a/protocol/doc.md b/protocol/doc.md
index 6d8f4f4..4c46a7b 100644
--- a/protocol/doc.md
+++ b/protocol/doc.md
@@ -75,6 +75,10 @@
 - 2580~2599
 - 2900~2999
 
+### upgrade.proto
+
+- 3100~3199
+
 ## gamesrv
 
 ### fish
diff --git a/protocol/upgrade/upgrade.pb.go b/protocol/upgrade/upgrade.pb.go
new file mode 100644
index 0000000..91923ae
--- /dev/null
+++ b/protocol/upgrade/upgrade.pb.go
@@ -0,0 +1,360 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.27.1-devel
+// 	protoc        v3.19.4
+// source: upgrade.proto
+
+package upgrade
+
+import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	reflect "reflect"
+	sync "sync"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type PacketID int32
+
+const (
+	// 3100~3199
+	PacketID_PacketID_Zero           PacketID = 0
+	PacketID_PACKET_CSClientUpgrades PacketID = 3100
+	PacketID_PACKET_SCClientUpgrades PacketID = 3101
+)
+
+// Enum value maps for PacketID.
+var (
+	PacketID_name = map[int32]string{
+		0:    "PacketID_Zero",
+		3100: "PACKET_CSClientUpgrades",
+		3101: "PACKET_SCClientUpgrades",
+	}
+	PacketID_value = map[string]int32{
+		"PacketID_Zero":           0,
+		"PACKET_CSClientUpgrades": 3100,
+		"PACKET_SCClientUpgrades": 3101,
+	}
+)
+
+func (x PacketID) Enum() *PacketID {
+	p := new(PacketID)
+	*p = x
+	return p
+}
+
+func (x PacketID) String() string {
+	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
+}
+
+func (PacketID) Descriptor() protoreflect.EnumDescriptor {
+	return file_upgrade_proto_enumTypes[0].Descriptor()
+}
+
+func (PacketID) Type() protoreflect.EnumType {
+	return &file_upgrade_proto_enumTypes[0]
+}
+
+func (x PacketID) Number() protoreflect.EnumNumber {
+	return protoreflect.EnumNumber(x)
+}
+
+// Deprecated: Use PacketID.Descriptor instead.
+func (PacketID) EnumDescriptor() ([]byte, []int) {
+	return file_upgrade_proto_rawDescGZIP(), []int{0}
+}
+
+type PropInfo struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	ItemId  int32 `protobuf:"varint,1,opt,name=ItemId,proto3" json:"ItemId,omitempty"`   //物品ID
+	ItemNum int64 `protobuf:"varint,2,opt,name=ItemNum,proto3" json:"ItemNum,omitempty"` //物品数量
+}
+
+func (x *PropInfo) Reset() {
+	*x = PropInfo{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_upgrade_proto_msgTypes[0]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *PropInfo) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*PropInfo) ProtoMessage() {}
+
+func (x *PropInfo) ProtoReflect() protoreflect.Message {
+	mi := &file_upgrade_proto_msgTypes[0]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use PropInfo.ProtoReflect.Descriptor instead.
+func (*PropInfo) Descriptor() ([]byte, []int) {
+	return file_upgrade_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *PropInfo) GetItemId() int32 {
+	if x != nil {
+		return x.ItemId
+	}
+	return 0
+}
+
+func (x *PropInfo) GetItemNum() int64 {
+	if x != nil {
+		return x.ItemNum
+	}
+	return 0
+}
+
+// 客户端升级奖励
+//PACKET_CSClientUpgrades
+type CSClientUpgrades struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+}
+
+func (x *CSClientUpgrades) Reset() {
+	*x = CSClientUpgrades{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_upgrade_proto_msgTypes[1]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *CSClientUpgrades) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*CSClientUpgrades) ProtoMessage() {}
+
+func (x *CSClientUpgrades) ProtoReflect() protoreflect.Message {
+	mi := &file_upgrade_proto_msgTypes[1]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use CSClientUpgrades.ProtoReflect.Descriptor instead.
+func (*CSClientUpgrades) Descriptor() ([]byte, []int) {
+	return file_upgrade_proto_rawDescGZIP(), []int{1}
+}
+
+//PACKET_SCClientUpgrades
+type SCClientUpgrades struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	On      bool        `protobuf:"varint,1,opt,name=On,proto3" json:"On,omitempty"`           // 是否开启
+	OnForce bool        `protobuf:"varint,2,opt,name=OnForce,proto3" json:"OnForce,omitempty"` // 是否强制升级(没有关闭按钮)
+	Award   []*PropInfo `protobuf:"bytes,3,rep,name=Award,proto3" json:"Award,omitempty"`      // 奖励
+	Version int32       `protobuf:"varint,4,opt,name=Version,proto3" json:"Version,omitempty"` // 版本号
+}
+
+func (x *SCClientUpgrades) Reset() {
+	*x = SCClientUpgrades{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_upgrade_proto_msgTypes[2]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *SCClientUpgrades) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SCClientUpgrades) ProtoMessage() {}
+
+func (x *SCClientUpgrades) ProtoReflect() protoreflect.Message {
+	mi := &file_upgrade_proto_msgTypes[2]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use SCClientUpgrades.ProtoReflect.Descriptor instead.
+func (*SCClientUpgrades) Descriptor() ([]byte, []int) {
+	return file_upgrade_proto_rawDescGZIP(), []int{2}
+}
+
+func (x *SCClientUpgrades) GetOn() bool {
+	if x != nil {
+		return x.On
+	}
+	return false
+}
+
+func (x *SCClientUpgrades) GetOnForce() bool {
+	if x != nil {
+		return x.OnForce
+	}
+	return false
+}
+
+func (x *SCClientUpgrades) GetAward() []*PropInfo {
+	if x != nil {
+		return x.Award
+	}
+	return nil
+}
+
+func (x *SCClientUpgrades) GetVersion() int32 {
+	if x != nil {
+		return x.Version
+	}
+	return 0
+}
+
+var File_upgrade_proto protoreflect.FileDescriptor
+
+var file_upgrade_proto_rawDesc = []byte{
+	0x0a, 0x0d, 0x75, 0x70, 0x67, 0x72, 0x61, 0x64, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12,
+	0x07, 0x75, 0x70, 0x67, 0x72, 0x61, 0x64, 0x65, 0x22, 0x3c, 0x0a, 0x08, 0x50, 0x72, 0x6f, 0x70,
+	0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x49, 0x74, 0x65, 0x6d, 0x49, 0x64, 0x18, 0x01,
+	0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x49, 0x74, 0x65, 0x6d, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07,
+	0x49, 0x74, 0x65, 0x6d, 0x4e, 0x75, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x49,
+	0x74, 0x65, 0x6d, 0x4e, 0x75, 0x6d, 0x22, 0x12, 0x0a, 0x10, 0x43, 0x53, 0x43, 0x6c, 0x69, 0x65,
+	0x6e, 0x74, 0x55, 0x70, 0x67, 0x72, 0x61, 0x64, 0x65, 0x73, 0x22, 0x7f, 0x0a, 0x10, 0x53, 0x43,
+	0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x67, 0x72, 0x61, 0x64, 0x65, 0x73, 0x12, 0x0e,
+	0x0a, 0x02, 0x4f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x02, 0x4f, 0x6e, 0x12, 0x18,
+	0x0a, 0x07, 0x4f, 0x6e, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52,
+	0x07, 0x4f, 0x6e, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x12, 0x27, 0x0a, 0x05, 0x41, 0x77, 0x61, 0x72,
+	0x64, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x75, 0x70, 0x67, 0x72, 0x61, 0x64,
+	0x65, 0x2e, 0x50, 0x72, 0x6f, 0x70, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x05, 0x41, 0x77, 0x61, 0x72,
+	0x64, 0x12, 0x18, 0x0a, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01,
+	0x28, 0x05, 0x52, 0x07, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x2a, 0x59, 0x0a, 0x08, 0x50,
+	0x61, 0x63, 0x6b, 0x65, 0x74, 0x49, 0x44, 0x12, 0x11, 0x0a, 0x0d, 0x50, 0x61, 0x63, 0x6b, 0x65,
+	0x74, 0x49, 0x44, 0x5f, 0x5a, 0x65, 0x72, 0x6f, 0x10, 0x00, 0x12, 0x1c, 0x0a, 0x17, 0x50, 0x41,
+	0x43, 0x4b, 0x45, 0x54, 0x5f, 0x43, 0x53, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x67,
+	0x72, 0x61, 0x64, 0x65, 0x73, 0x10, 0x9c, 0x18, 0x12, 0x1c, 0x0a, 0x17, 0x50, 0x41, 0x43, 0x4b,
+	0x45, 0x54, 0x5f, 0x53, 0x43, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x55, 0x70, 0x67, 0x72, 0x61,
+	0x64, 0x65, 0x73, 0x10, 0x9d, 0x18, 0x42, 0x27, 0x5a, 0x25, 0x6d, 0x6f, 0x6e, 0x67, 0x6f, 0x2e,
+	0x67, 0x61, 0x6d, 0x65, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x61, 0x6d, 0x65, 0x2f, 0x70,
+	0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2f, 0x75, 0x70, 0x67, 0x72, 0x61, 0x64, 0x65, 0x62,
+	0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+	file_upgrade_proto_rawDescOnce sync.Once
+	file_upgrade_proto_rawDescData = file_upgrade_proto_rawDesc
+)
+
+func file_upgrade_proto_rawDescGZIP() []byte {
+	file_upgrade_proto_rawDescOnce.Do(func() {
+		file_upgrade_proto_rawDescData = protoimpl.X.CompressGZIP(file_upgrade_proto_rawDescData)
+	})
+	return file_upgrade_proto_rawDescData
+}
+
+var file_upgrade_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
+var file_upgrade_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
+var file_upgrade_proto_goTypes = []interface{}{
+	(PacketID)(0),            // 0: upgrade.PacketID
+	(*PropInfo)(nil),         // 1: upgrade.PropInfo
+	(*CSClientUpgrades)(nil), // 2: upgrade.CSClientUpgrades
+	(*SCClientUpgrades)(nil), // 3: upgrade.SCClientUpgrades
+}
+var file_upgrade_proto_depIdxs = []int32{
+	1, // 0: upgrade.SCClientUpgrades.Award:type_name -> upgrade.PropInfo
+	1, // [1:1] is the sub-list for method output_type
+	1, // [1:1] is the sub-list for method input_type
+	1, // [1:1] is the sub-list for extension type_name
+	1, // [1:1] is the sub-list for extension extendee
+	0, // [0:1] is the sub-list for field type_name
+}
+
+func init() { file_upgrade_proto_init() }
+func file_upgrade_proto_init() {
+	if File_upgrade_proto != nil {
+		return
+	}
+	if !protoimpl.UnsafeEnabled {
+		file_upgrade_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*PropInfo); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_upgrade_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*CSClientUpgrades); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_upgrade_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*SCClientUpgrades); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: file_upgrade_proto_rawDesc,
+			NumEnums:      1,
+			NumMessages:   3,
+			NumExtensions: 0,
+			NumServices:   0,
+		},
+		GoTypes:           file_upgrade_proto_goTypes,
+		DependencyIndexes: file_upgrade_proto_depIdxs,
+		EnumInfos:         file_upgrade_proto_enumTypes,
+		MessageInfos:      file_upgrade_proto_msgTypes,
+	}.Build()
+	File_upgrade_proto = out.File
+	file_upgrade_proto_rawDesc = nil
+	file_upgrade_proto_goTypes = nil
+	file_upgrade_proto_depIdxs = nil
+}
diff --git a/protocol/upgrade/upgrade.proto b/protocol/upgrade/upgrade.proto
new file mode 100644
index 0000000..f44997e
--- /dev/null
+++ b/protocol/upgrade/upgrade.proto
@@ -0,0 +1,27 @@
+syntax = "proto3";
+package upgrade;
+option go_package = "mongo.games.com/game/protocol/upgrade";
+
+enum PacketID {
+  // 3100~3199
+  PacketID_Zero = 0;
+  PACKET_CSClientUpgrades = 3100;
+  PACKET_SCClientUpgrades = 3101;
+}
+
+message PropInfo{
+  int32 ItemId = 1;//物品ID
+  int64 ItemNum = 2;//物品数量
+}
+
+// 客户端升级奖励
+//PACKET_CSClientUpgrades
+message CSClientUpgrades{
+}
+//PACKET_SCClientUpgrades
+message SCClientUpgrades{
+  bool On = 1; // 是否开启
+  bool OnForce = 2; // 是否强制升级(没有关闭按钮)
+  repeated PropInfo Award = 3; // 奖励
+  int32 Version = 4; // 版本号
+}
\ No newline at end of file
diff --git a/protocol/webapi/common.pb.go b/protocol/webapi/common.pb.go
index 5a17a03..c26ae0b 100644
--- a/protocol/webapi/common.pb.go
+++ b/protocol/webapi/common.pb.go
@@ -8921,6 +8921,78 @@ func (x *RoomConfigSystem) GetOn() int32 {
 	return 0
 }
 
+// etcd /game/client_upgrade
+type ClientUpgrade struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Platform string      `protobuf:"bytes,1,opt,name=Platform,proto3" json:"Platform,omitempty"` // 平台
+	On       int32       `protobuf:"varint,2,opt,name=On,proto3" json:"On,omitempty"`            // 开关 1开启 2关闭
+	OnForce  int32       `protobuf:"varint,3,opt,name=OnForce,proto3" json:"OnForce,omitempty"`  // 强制升级开关 1开启 2关闭
+	Reward   []*ItemInfo `protobuf:"bytes,4,rep,name=Reward,proto3" json:"Reward,omitempty"`     // 奖励
+}
+
+func (x *ClientUpgrade) Reset() {
+	*x = ClientUpgrade{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_common_proto_msgTypes[93]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *ClientUpgrade) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ClientUpgrade) ProtoMessage() {}
+
+func (x *ClientUpgrade) ProtoReflect() protoreflect.Message {
+	mi := &file_common_proto_msgTypes[93]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use ClientUpgrade.ProtoReflect.Descriptor instead.
+func (*ClientUpgrade) Descriptor() ([]byte, []int) {
+	return file_common_proto_rawDescGZIP(), []int{93}
+}
+
+func (x *ClientUpgrade) GetPlatform() string {
+	if x != nil {
+		return x.Platform
+	}
+	return ""
+}
+
+func (x *ClientUpgrade) GetOn() int32 {
+	if x != nil {
+		return x.On
+	}
+	return 0
+}
+
+func (x *ClientUpgrade) GetOnForce() int32 {
+	if x != nil {
+		return x.OnForce
+	}
+	return 0
+}
+
+func (x *ClientUpgrade) GetReward() []*ItemInfo {
+	if x != nil {
+		return x.Reward
+	}
+	return nil
+}
+
 var File_common_proto protoreflect.FileDescriptor
 
 var file_common_proto_rawDesc = []byte{
@@ -10319,10 +10391,18 @@ var file_common_proto_rawDesc = []byte{
 	0x26, 0x0a, 0x0e, 0x41, 0x75, 0x74, 0x6f, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d,
 	0x65, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0e, 0x41, 0x75, 0x74, 0x6f, 0x43, 0x72, 0x65,
 	0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x4f, 0x6e, 0x18, 0x0e, 0x20,
-	0x01, 0x28, 0x05, 0x52, 0x02, 0x4f, 0x6e, 0x42, 0x26, 0x5a, 0x24, 0x6d, 0x6f, 0x6e, 0x67, 0x6f,
-	0x2e, 0x67, 0x61, 0x6d, 0x65, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x61, 0x6d, 0x65, 0x2f,
-	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2f, 0x77, 0x65, 0x62, 0x61, 0x70, 0x69, 0x62,
-	0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x01, 0x28, 0x05, 0x52, 0x02, 0x4f, 0x6e, 0x22, 0x7f, 0x0a, 0x0d, 0x43, 0x6c, 0x69, 0x65, 0x6e,
+	0x74, 0x55, 0x70, 0x67, 0x72, 0x61, 0x64, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x50, 0x6c, 0x61, 0x74,
+	0x66, 0x6f, 0x72, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x50, 0x6c, 0x61, 0x74,
+	0x66, 0x6f, 0x72, 0x6d, 0x12, 0x0e, 0x0a, 0x02, 0x4f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05,
+	0x52, 0x02, 0x4f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x4f, 0x6e, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x18,
+	0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x4f, 0x6e, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x12, 0x28,
+	0x0a, 0x06, 0x52, 0x65, 0x77, 0x61, 0x72, 0x64, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x10,
+	0x2e, 0x77, 0x65, 0x62, 0x61, 0x70, 0x69, 0x2e, 0x49, 0x74, 0x65, 0x6d, 0x49, 0x6e, 0x66, 0x6f,
+	0x52, 0x06, 0x52, 0x65, 0x77, 0x61, 0x72, 0x64, 0x42, 0x26, 0x5a, 0x24, 0x6d, 0x6f, 0x6e, 0x67,
+	0x6f, 0x2e, 0x67, 0x61, 0x6d, 0x65, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x61, 0x6d, 0x65,
+	0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2f, 0x77, 0x65, 0x62, 0x61, 0x70, 0x69,
+	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
@@ -10337,7 +10417,7 @@ func file_common_proto_rawDescGZIP() []byte {
 	return file_common_proto_rawDescData
 }
 
-var file_common_proto_msgTypes = make([]protoimpl.MessageInfo, 103)
+var file_common_proto_msgTypes = make([]protoimpl.MessageInfo, 104)
 var file_common_proto_goTypes = []interface{}{
 	(*MysqlDbSetting)(nil),               // 0: webapi.MysqlDbSetting
 	(*MongoDbSetting)(nil),               // 1: webapi.MongoDbSetting
@@ -10432,32 +10512,33 @@ var file_common_proto_goTypes = []interface{}{
 	(*RoomType)(nil),                     // 90: webapi.RoomType
 	(*RoomConfig)(nil),                   // 91: webapi.RoomConfig
 	(*RoomConfigSystem)(nil),             // 92: webapi.RoomConfigSystem
-	nil,                                  // 93: webapi.Platform.BindTelRewardEntry
-	nil,                                  // 94: webapi.PlayerData.RankScoreEntry
-	nil,                                  // 95: webapi.ItemShop.AwardEntry
-	nil,                                  // 96: webapi.VIPcfg.AwardEntry
-	nil,                                  // 97: webapi.VIPcfg.Privilege1Entry
-	nil,                                  // 98: webapi.VIPcfg.Privilege7Entry
-	nil,                                  // 99: webapi.VIPcfg.Privilege9Entry
-	nil,                                  // 100: webapi.ActInviteConfig.PayScoreEntry
-	nil,                                  // 101: webapi.SkinLevel.UpItemEntry
-	nil,                                  // 102: webapi.SkinItem.UnlockParamEntry
-	(*server.DB_GameFree)(nil),           // 103: server.DB_GameFree
-	(*server.DB_GameItem)(nil),           // 104: server.DB_GameItem
+	(*ClientUpgrade)(nil),                // 93: webapi.ClientUpgrade
+	nil,                                  // 94: webapi.Platform.BindTelRewardEntry
+	nil,                                  // 95: webapi.PlayerData.RankScoreEntry
+	nil,                                  // 96: webapi.ItemShop.AwardEntry
+	nil,                                  // 97: webapi.VIPcfg.AwardEntry
+	nil,                                  // 98: webapi.VIPcfg.Privilege1Entry
+	nil,                                  // 99: webapi.VIPcfg.Privilege7Entry
+	nil,                                  // 100: webapi.VIPcfg.Privilege9Entry
+	nil,                                  // 101: webapi.ActInviteConfig.PayScoreEntry
+	nil,                                  // 102: webapi.SkinLevel.UpItemEntry
+	nil,                                  // 103: webapi.SkinItem.UnlockParamEntry
+	(*server.DB_GameFree)(nil),           // 104: server.DB_GameFree
+	(*server.DB_GameItem)(nil),           // 105: server.DB_GameItem
 }
 var file_common_proto_depIdxs = []int32{
 	2,   // 0: webapi.Platform.Leaderboard:type_name -> webapi.RankSwitch
 	3,   // 1: webapi.Platform.ClubConfig:type_name -> webapi.ClubConfig
 	4,   // 2: webapi.Platform.ThirdGameMerchant:type_name -> webapi.ThirdGame
-	93,  // 3: webapi.Platform.BindTelReward:type_name -> webapi.Platform.BindTelRewardEntry
+	94,  // 3: webapi.Platform.BindTelReward:type_name -> webapi.Platform.BindTelRewardEntry
 	6,   // 4: webapi.GameConfigGlobal.GameStatus:type_name -> webapi.GameStatus
-	103, // 5: webapi.GameFree.DbGameFree:type_name -> server.DB_GameFree
+	104, // 5: webapi.GameFree.DbGameFree:type_name -> server.DB_GameFree
 	8,   // 6: webapi.PlatformGameConfig.DbGameFrees:type_name -> webapi.GameFree
 	0,   // 7: webapi.PlatformDbConfig.Mysql:type_name -> webapi.MysqlDbSetting
 	1,   // 8: webapi.PlatformDbConfig.MongoDb:type_name -> webapi.MongoDbSetting
 	1,   // 9: webapi.PlatformDbConfig.MongoDbLog:type_name -> webapi.MongoDbSetting
-	103, // 10: webapi.GameConfigGroup.DbGameFree:type_name -> server.DB_GameFree
-	94,  // 11: webapi.PlayerData.RankScore:type_name -> webapi.PlayerData.RankScoreEntry
+	104, // 10: webapi.GameConfigGroup.DbGameFree:type_name -> server.DB_GameFree
+	95,  // 11: webapi.PlayerData.RankScore:type_name -> webapi.PlayerData.RankScoreEntry
 	32,  // 12: webapi.PlayerData.Items:type_name -> webapi.ItemInfo
 	14,  // 13: webapi.PlayerData.RoleUnlockList:type_name -> webapi.ModInfo
 	14,  // 14: webapi.PlayerData.PetUnlockList:type_name -> webapi.ModInfo
@@ -10470,7 +10551,7 @@ var file_common_proto_depIdxs = []int32{
 	32,  // 21: webapi.ExchangeShop.Items:type_name -> webapi.ItemInfo
 	25,  // 22: webapi.ExchangeShopList.List:type_name -> webapi.ExchangeShop
 	29,  // 23: webapi.ExchangeShopList.Weight:type_name -> webapi.ShopWeight
-	95,  // 24: webapi.ItemShop.Award:type_name -> webapi.ItemShop.AwardEntry
+	96,  // 24: webapi.ItemShop.Award:type_name -> webapi.ItemShop.AwardEntry
 	30,  // 25: webapi.ItemShopList.List:type_name -> webapi.ItemShop
 	32,  // 26: webapi.MatchInfoAward.ItemId:type_name -> webapi.ItemInfo
 	33,  // 27: webapi.GameMatchDate.Award:type_name -> webapi.MatchInfoAward
@@ -10491,14 +10572,14 @@ var file_common_proto_depIdxs = []int32{
 	38,  // 42: webapi.WelfareSpree.Item:type_name -> webapi.WelfareDate
 	48,  // 43: webapi.WelfareFirstPayDataList.List:type_name -> webapi.WelfareSpree
 	48,  // 44: webapi.WelfareContinuousPayDataList.List:type_name -> webapi.WelfareSpree
-	96,  // 45: webapi.VIPcfg.Award:type_name -> webapi.VIPcfg.AwardEntry
-	97,  // 46: webapi.VIPcfg.Privilege1:type_name -> webapi.VIPcfg.Privilege1Entry
-	98,  // 47: webapi.VIPcfg.Privilege7:type_name -> webapi.VIPcfg.Privilege7Entry
-	99,  // 48: webapi.VIPcfg.Privilege9:type_name -> webapi.VIPcfg.Privilege9Entry
+	97,  // 45: webapi.VIPcfg.Award:type_name -> webapi.VIPcfg.AwardEntry
+	98,  // 46: webapi.VIPcfg.Privilege1:type_name -> webapi.VIPcfg.Privilege1Entry
+	99,  // 47: webapi.VIPcfg.Privilege7:type_name -> webapi.VIPcfg.Privilege7Entry
+	100, // 48: webapi.VIPcfg.Privilege9:type_name -> webapi.VIPcfg.Privilege9Entry
 	51,  // 49: webapi.VIPcfgDataList.List:type_name -> webapi.VIPcfg
 	38,  // 50: webapi.ChessRankConfig.Item:type_name -> webapi.WelfareDate
 	55,  // 51: webapi.ChessRankcfgData.Datas:type_name -> webapi.ChessRankConfig
-	100, // 52: webapi.ActInviteConfig.PayScore:type_name -> webapi.ActInviteConfig.PayScoreEntry
+	101, // 52: webapi.ActInviteConfig.PayScore:type_name -> webapi.ActInviteConfig.PayScoreEntry
 	62,  // 53: webapi.ActInviteConfig.Awards1:type_name -> webapi.RankAward
 	62,  // 54: webapi.ActInviteConfig.Awards2:type_name -> webapi.RankAward
 	62,  // 55: webapi.ActInviteConfig.Awards3:type_name -> webapi.RankAward
@@ -10515,12 +10596,12 @@ var file_common_proto_depIdxs = []int32{
 	69,  // 66: webapi.DiamondLotteryData.Info:type_name -> webapi.DiamondLotteryInfo
 	70,  // 67: webapi.DiamondLotteryData.Players:type_name -> webapi.DiamondLotteryPlayers
 	72,  // 68: webapi.DiamondLotteryConfig.LotteryData:type_name -> webapi.DiamondLotteryData
-	104, // 69: webapi.ItemConfig.Items:type_name -> server.DB_GameItem
+	105, // 69: webapi.ItemConfig.Items:type_name -> server.DB_GameItem
 	32,  // 70: webapi.RankAwardInfo.Item:type_name -> webapi.ItemInfo
 	75,  // 71: webapi.RankTypeInfo.Award:type_name -> webapi.RankAwardInfo
 	76,  // 72: webapi.RankTypeConfig.Info:type_name -> webapi.RankTypeInfo
-	101, // 73: webapi.SkinLevel.UpItem:type_name -> webapi.SkinLevel.UpItemEntry
-	102, // 74: webapi.SkinItem.UnlockParam:type_name -> webapi.SkinItem.UnlockParamEntry
+	102, // 73: webapi.SkinLevel.UpItem:type_name -> webapi.SkinLevel.UpItemEntry
+	103, // 74: webapi.SkinItem.UnlockParam:type_name -> webapi.SkinItem.UnlockParamEntry
 	78,  // 75: webapi.SkinItem.Levels:type_name -> webapi.SkinLevel
 	79,  // 76: webapi.SkinConfig.Items:type_name -> webapi.SkinItem
 	82,  // 77: webapi.AwardLogConfig.AwardLog:type_name -> webapi.AwardLogData
@@ -10529,11 +10610,12 @@ var file_common_proto_depIdxs = []int32{
 	87,  // 80: webapi.MachineConfig.Info:type_name -> webapi.MachineInfo
 	32,  // 81: webapi.RoomConfig.Cost:type_name -> webapi.ItemInfo
 	32,  // 82: webapi.RoomConfig.Reward:type_name -> webapi.ItemInfo
-	83,  // [83:83] is the sub-list for method output_type
-	83,  // [83:83] is the sub-list for method input_type
-	83,  // [83:83] is the sub-list for extension type_name
-	83,  // [83:83] is the sub-list for extension extendee
-	0,   // [0:83] is the sub-list for field type_name
+	32,  // 83: webapi.ClientUpgrade.Reward:type_name -> webapi.ItemInfo
+	84,  // [84:84] is the sub-list for method output_type
+	84,  // [84:84] is the sub-list for method input_type
+	84,  // [84:84] is the sub-list for extension type_name
+	84,  // [84:84] is the sub-list for extension extendee
+	0,   // [0:84] is the sub-list for field type_name
 }
 
 func init() { file_common_proto_init() }
@@ -11658,6 +11740,18 @@ func file_common_proto_init() {
 				return nil
 			}
 		}
+		file_common_proto_msgTypes[93].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*ClientUpgrade); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
 	}
 	type x struct{}
 	out := protoimpl.TypeBuilder{
@@ -11665,7 +11759,7 @@ func file_common_proto_init() {
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: file_common_proto_rawDesc,
 			NumEnums:      0,
-			NumMessages:   103,
+			NumMessages:   104,
 			NumExtensions: 0,
 			NumServices:   0,
 		},
diff --git a/protocol/webapi/common.proto b/protocol/webapi/common.proto
index 02a6e8b..f2986c8 100644
--- a/protocol/webapi/common.proto
+++ b/protocol/webapi/common.proto
@@ -90,7 +90,7 @@ message Platform {
   bool IsCanUserBindPromoter = 33;  //是否允许用户手动绑定推广员
   int32 UserBindPromoterPrize = 34; //手动绑定奖励
   string MerchantKey = 35;//商户秘钥
-  map<int32,int64> BindTelReward = 36; // 绑定手机奖励；奖励id：数量
+  map<int32, int64> BindTelReward = 36; // 绑定手机奖励；奖励id：数量
 }
 
 // 游戏状态结构
@@ -190,7 +190,7 @@ message PlayerData{
   int64 PlayerPoolUpper = 41; // 个人水池上限值
   int64 PlayerPoolLower = 42; // 个人水池下限值
   int64 PlayerPoolRate = 43; // 个人水池控制值
-  map<int64,int64> RankScore = 44; // 排位积分 1 tienlen排位积分
+  map<int64, int64> RankScore = 44; // 排位积分 1 tienlen排位积分
   int64 RoleAdded = 45;//人物加成
   int64 VipAdded = 46;//VIP加成
   int64 VipExp = 47;//VIP经验
@@ -298,7 +298,7 @@ message CoinPoolSetting{
   int32 LowerOddsMax = 12; // 下线最大概率
   int32 ProfitRate = 13;//营收比例，千分比
   int64 ResetTime = 14; // 重置时间
-  int32 Switch =15; // 开关 0开启 1关闭
+  int32 Switch = 15; // 开关 0开启 1关闭
   int64 CoinValue = 16; // 当前水位
   int64 ProfitPool = 17; // 收益池水位
   int32 CtrlRate = 18; //调节赔率，万分比
@@ -364,8 +364,8 @@ message CommonNotice {
   int32  CategoryType = 9;
   string ImgUrl = 10;
   int32  NoticeId = 11;
-  int32  IsLoop=12;
-  int32  LoopTime=13;
+  int32  IsLoop = 12;
+  int32  LoopTime = 13;
   repeated string OnChannelName = 14;
   string Url = 15;
 }
@@ -390,15 +390,15 @@ message ExchangeShop {
   int32 NotVipDayMaxLimit = 13;//非VIP每日限购
   int32 VipShopLimit = 14;//VIP限购总数
   int32 NotVipShopLimit = 15;//非VIP限购总数
-  int32 ShopType = 16;	//商品类型
+  int32 ShopType = 16;  //商品类型
   repeated TelChargeData TelData = 17;
   repeated ItemInfo Items = 18;
 }
 
 message TelChargeData{
-	int32 Id = 1;
-	string Name = 2;
-	string Url = 3;
+  int32 Id = 1;
+  string Name = 2;
+  string Url = 3;
 }
 
 //兑换类型
@@ -406,7 +406,7 @@ message ExchangeType{
   int32 Price = 1;    // 消耗V卡数量
   int32 JPrice = 2;        //消耗金券数量
   int32 Cash = 3;          //消耗现金数量
-  int32 DPrice = 4;	//消耗娃娃卡数量
+  int32 DPrice = 4;  //消耗娃娃卡数量
   int32 Id = 5; //行数
 }
 
@@ -418,11 +418,11 @@ message ExchangeShopList{
 }
 
 message ShopWeight{
-	int32 ShopType = 1;
-	int32 Weight = 2;
-	string Name = 3;
-	int32 IsShow = 4;
-   repeated int32 Location = 5; // 显示位置
+  int32 ShopType = 1;
+  int32 Weight = 2;
+  string Name = 3;
+  int32 IsShow = 4;
+  repeated int32 Location = 5; // 显示位置
 }
 
 
@@ -444,8 +444,8 @@ message ItemShop {
   int32 Amount = 15;               // 货币金额
   int32 ConstType = 16;            // 购买消耗类型 1，金币 2，钻石 3，美金 4，柬埔寨币
   repeated int32 CostArea = 17;    //消耗区间
-  map<int64,int64> Award = 18;     //加赠物品
-  int32 VipLevel =19;              //Vip等级限制
+  map<int64, int64> Award = 18;     //加赠物品
+  int32 VipLevel = 19;              //Vip等级限制
   int32 Ratio = 20;                //权重
   int32 EndTime = 21;              //新手礼包结束时间间隔
   bool FirstSwitch = 22;           //首冲翻倍开关
@@ -499,7 +499,7 @@ message GameMatchDate {
   repeated string OnChannelName = 23; // 开启的渠道名称
   int32 CardType = 24; // 手机卡类型
   int32 ShowId = 25; // 比赛区分
-  int32 AwardNum = 26;	//比赛奖励剩余数量
+  int32 AwardNum = 26;  //比赛奖励剩余数量
   int32 AudienceSwitch = 27; // 观战开关 1开启 2关闭
 }
 
@@ -624,23 +624,23 @@ message WelfareContinuousPayDataList{
 
 message VIPcfg  {
   int32 VipId = 1;                    // 序号
-  map<int64,int64> Award = 2;      // 道具
+  map<int64, int64> Award = 2;      // 道具
   int32  VipEx = 3;                   // VIP经验
   int64  Price = 4;                   // 金额
-  map<int64,int64> Privilege1 = 5;               //特权1 VIP比赛场免费次数
+  map<int64, int64> Privilege1 = 5;               //特权1 VIP比赛场免费次数
   repeated int32 Privilege2 = 6; //每日金币 0金币值 1充值金额
   repeated int32 Privilege3 = 7;
   int32 Privilege4 = 8;
   int32 Privilege5 = 9;
   int32 Privilege6 = 10;
-  map<int64,int64> Privilege7 = 11;
+  map<int64, int64> Privilege7 = 11;
   int32 Privilege7Price = 12;
   int32 Privilege8 = 13;
   repeated int32 RewardOutlineID = 14;
   int32 ShopId2 = 15;
   int32 ShopId7 = 16;
   int32 MatchFreeTimes = 17; // vip比赛场免费次数
-  map<int64,int64> Privilege9 = 18; // vip免费礼包，每个vip等级领取一次
+  map<int64, int64> Privilege9 = 18; // vip免费礼包，每个vip等级领取一次
 }
 
 // etcd /game/VIPcfg VIP配置
@@ -667,9 +667,9 @@ message EntrySwitch{
 }
 
 message ChessRankConfig {
-    string Name = 1; // 段位名称
-    int32 Score = 2; // 积分
-    repeated WelfareDate Item = 3; // 道具
+  string Name = 1; // 段位名称
+  int32 Score = 2; // 积分
+  repeated WelfareDate Item = 3; // 道具
 }
 
 message ChessRankcfgData{
@@ -735,7 +735,7 @@ message ActInviteConfig {
   string Platform = 1;
   int64 BindScore = 2; // 绑定积分
   int64 RechargeScore = 3; // 充值积分，一个玩家最多给上级贡献一次
-  map<int64,int64> PayScore = 4; // 充值积分；充值金额：获得积分
+  map<int64, int64> PayScore = 4; // 充值积分；充值金额：获得积分
   repeated int64 Rates = 5; // 返佣比例；多级按顺序给
   repeated RankAward Awards1 = 6; // 周榜奖励列表
   repeated RankAward Awards2 = 7; // 周榜奖励列表
@@ -787,36 +787,36 @@ message ActPermitConfig{
 
 //钻石抽奖
 message DiamondLotteryInfo{
-	int32 Id = 1;
-	int32 Type = 2;
-	string Name = 3;
-	int32 ItemId = 4;
-	int32 Grade = 5;
-	int32 Oddrate =6;
+  int32 Id = 1;
+  int32 Type = 2;
+  string Name = 3;
+  int32 ItemId = 4;
+  int32 Grade = 5;
+  int32 Oddrate = 6;
 }
 //钻石抽奖白名单
 message DiamondLotteryPlayers{
-	int32 uid = 1;
-	int32  Count = 2;	//抽奖次数
-	repeated AwardData Award = 3;	//配置表里的奖励ID
+  int32 uid = 1;
+  int32  Count = 2;  //抽奖次数
+  repeated AwardData Award = 3;  //配置表里的奖励ID
 }
 message AwardData{
-	int32 AwardId = 1;
-	int32 Weight = 2;
+  int32 AwardId = 1;
+  int32 Weight = 2;
 }
 message DiamondLotteryData{
-	string Channel = 1;	//渠道
-	repeated DiamondLotteryInfo Info = 2;
-	int32 MaxScore = 3;	//保底奖励最大值
-	int32 DiamondNum = 4;	//单次抽奖消耗钻石数量
-	repeated DiamondLotteryPlayers Players = 5;//白名单
-	
+  string Channel = 1;  //渠道
+  repeated DiamondLotteryInfo Info = 2;
+  int32 MaxScore = 3;  //保底奖励最大值
+  int32 DiamondNum = 4;  //单次抽奖消耗钻石数量
+  repeated DiamondLotteryPlayers Players = 5;//白名单
+
 }
 
 // etcd /game/diamond_lottery
 message DiamondLotteryConfig{
-	string Platform = 1; // 平台
-	repeated DiamondLotteryData  LotteryData = 2;
+  string Platform = 1; // 平台
+  repeated DiamondLotteryData  LotteryData = 2;
 }
 
 // etcd /game/item
@@ -826,19 +826,19 @@ message ItemConfig {
 }
 
 message RankAwardInfo{
-	int32 Id =1;
-	int32 RankType =2;
-	int32 RankLevelId = 3;
-	repeated ItemInfo Item = 4;          // 道具
+  int32 Id = 1;
+  int32 RankType = 2;
+  int32 RankLevelId = 3;
+  repeated ItemInfo Item = 4;          // 道具
 }
 
 message RankTypeInfo{
-	int32 Id =1;
-	int32 Order = 2;
-	string RankName = 3;
-	int32 RankType = 4;
-	int32 TurnOff = 5; //奖励开关
-	repeated RankAwardInfo Award= 6;
+  int32 Id = 1;
+  int32 Order = 2;
+  string RankName = 3;
+  int32 RankType = 4;
+  int32 TurnOff = 5; //奖励开关
+  repeated RankAwardInfo Award = 6;
 }
 //etcd /game/RankType
 message RankTypeConfig{
@@ -847,7 +847,7 @@ message RankTypeConfig{
 }
 message SkinLevel {
   int32 Level = 1; // 等级
-  map<int32,int64> UpItem = 2; // 升级所需道具
+  map<int32, int64> UpItem = 2; // 升级所需道具
   int32 SkillId = 3; // 技能id
   int32 SkillLevel = 4; // 技能等级
   int32 SkillValue = 5; // 技能属性值
@@ -856,7 +856,7 @@ message SkinLevel {
 message SkinItem {
   int32 Id = 1; // 皮肤id
   int32 UnlockType = 2; // 解锁类型 0默认使用 1自动使用道具解锁并使用 2使用道具解锁
-  map<int32,int64> UnlockParam = 3; // 解锁所需道具
+  map<int32, int64> UnlockParam = 3; // 解锁所需道具
   int32 IsUpgrade = 4; // 升级开关 1开启 2关闭
   int32 SkillType = 5; // 技能生效类型 0获得后生效 1穿戴生效
   repeated SkinLevel Levels = 6; // 等级列表
@@ -864,27 +864,27 @@ message SkinItem {
 
 // etcd /game/skin_config
 message SkinConfig {
-   string Platform = 1; // 平台
-   repeated SkinItem Items = 2; // 皮肤列表
+  string Platform = 1; // 平台
+  repeated SkinItem Items = 2; // 皮肤列表
 }
 
 // etcd /game/awardlog_config
 message AwardLogConfig{
-	string Platform = 1; // 平台
-	repeated AwardLogData AwardLog =2;
-	repeated AnnouncerLogInfo AnnouncerLog = 3;
-	
+  string Platform = 1; // 平台
+  repeated AwardLogData AwardLog = 2;
+  repeated AnnouncerLogInfo AnnouncerLog = 3;
+
 }
 message AwardLogData{
-	int32 TypeId = 1; //1话费 2实物
-	int32 SortId = 2;	//排序類型   1-数量 2-序号
-	repeated AwardLogInfo AwardLog =3;
+  int32 TypeId = 1; //1话费 2实物
+  int32 SortId = 2;  //排序類型   1-数量 2-序号
+  repeated AwardLogInfo AwardLog = 3;
 }
 message AwardLogInfo{
   int32 ItemId = 2; //道具ID
-  int64 Num  = 4;   //数量
-  string Url = 5;	//话费icon
-  int32 Order = 6;	//序号
+  int64 Num = 4;   //数量
+  string Url = 5;  //话费icon
+  int32 Order = 6;  //序号
 }
 
 //实时播报
@@ -893,7 +893,7 @@ message AnnouncerLogInfo{
   string Name = 2; //玩家名字
   string Phone = 3;  //电话
   int32 ItemId = 4; //获得物品ID
-  int32 TypeId = 5;	//1-话费 2-实物
+  int32 TypeId = 5;  //1-话费 2-实物
 }
 
 // etcd /game/guide_config
@@ -906,17 +906,17 @@ message GuideConfig {
 //娃娃机配置视频
 // etcd /game/machine_config
 message MachineConfig{
-	string Platform = 1; // 平台
-	repeated MachineInfo Info = 2;
+  string Platform = 1; // 平台
+  repeated MachineInfo Info = 2;
 }
 message MachineInfo{
   int32 MachineId = 1; //娃娃机Id
   int64 AppId = 2;
   string ServerSecret = 3;
   string StreamId = 4;
-  int32 CostItemNum = 5;	//消耗道具数量
-  int32 ItemId = 6;		//获得道具Id
-  int32 ItemNum = 7;		//获得道具数量
+  int32 CostItemNum = 5;  //消耗道具数量
+  int32 ItemId = 6;    //获得道具Id
+  int32 ItemNum = 7;    //获得道具数量
   string IconAddr = 8;//图片地址
   string Name = 9;//场次名字
 }
@@ -979,4 +979,12 @@ message RoomConfigSystem{
   int32 AutoCreate = 12; // 自动创建开关 1开启 2关闭
   int32 AutoCreateTime = 13; // 自动创建时间间隔，单位秒
   int32 On = 14; // 开关 1开启 2关闭
+}
+
+// etcd /game/client_upgrade
+message ClientUpgrade{
+  string Platform = 1; // 平台
+  int32 On = 2; // 开关 1开启 2关闭
+  int32 OnForce = 3; // 强制升级开关 1开启 2关闭
+  repeated ItemInfo Reward = 4; // 奖励
 }
\ No newline at end of file
diff --git a/worldsrv/action_bag.go b/worldsrv/action_bag.go
index 8b3463f..4712c73 100644
--- a/worldsrv/action_bag.go
+++ b/worldsrv/action_bag.go
@@ -280,7 +280,10 @@ func CSUpBagInfo(s *netlib.Session, packetid int, data interface{}, sid int64) e
 		if acceptPlayer != nil {
 			logger.Logger.Trace("道具赠送成功", msg.ItemId)
 			remark := fmt.Sprintf("赠送给玩家(%v)", msg.AcceptSnId)
-			BagMgrSingleton.AddMailByItem(p.Platform, p.SnId, p.Name, msg.AcceptSnId, msg.ShowId, []int32{msg.ItemId, msg.ItemNum})
+			AddMailByItem(p.Platform, p.SnId, p.Name, msg.AcceptSnId, msg.ShowId, []*model.Item{{
+				ItemId:  msg.GetItemId(),
+				ItemNum: int64(msg.GetItemNum()),
+			}})
 			BagMgrSingleton.AddItems(&model.AddItemParam{
 				Platform: p.Platform,
 				SnId:     p.SnId,
@@ -305,7 +308,10 @@ func CSUpBagInfo(s *netlib.Session, packetid int, data interface{}, sid int64) e
 				if data != nil && aPlayer != nil {
 					logger.Logger.Trace("道具赠送成功", msg.ItemId)
 					remark := fmt.Sprintf("赠送给玩家(%v)", msg.AcceptSnId)
-					BagMgrSingleton.AddMailByItem(p.Platform, p.SnId, p.Name, msg.AcceptSnId, msg.ShowId, []int32{msg.ItemId, msg.ItemNum})
+					AddMailByItem(p.Platform, p.SnId, p.Name, msg.AcceptSnId, msg.ShowId, []*model.Item{{
+						ItemId:  msg.GetItemId(),
+						ItemNum: int64(msg.GetItemNum()),
+					}})
 					BagMgrSingleton.AddItems(&model.AddItemParam{
 						Platform: p.Platform,
 						SnId:     p.SnId,
diff --git a/worldsrv/action_player.go b/worldsrv/action_player.go
index ca2d252..e7791e2 100644
--- a/worldsrv/action_player.go
+++ b/worldsrv/action_player.go
@@ -10,6 +10,7 @@ import (
 	"math/rand"
 	"net/url"
 	"regexp"
+	"slices"
 	"strconv"
 	"strings"
 	"time"
@@ -84,7 +85,7 @@ func (this *CSInviteCodePlayerHandler) Process(s *netlib.Session, packetid int,
 			}
 
 			//发送邮件
-			var otherParams []int32
+			var otherParams []int64
 			newMsg := model.NewMessage("", p.SnId, "", p.SnId, model.MSGTYPE_INVITECODE, p.Name, inviteCode, coin, 0,
 				model.MSGSTATE_UNREAD, time.Now().Unix(), 0, "", otherParams, p.Platform, model.HallAll, nil)
 			err = model.InsertMessage(p.Platform, newMsg)
@@ -1983,11 +1984,15 @@ func CSPlayerData(s *netlib.Session, packetid int, data interface{}, sid int64)
 		}
 
 		// 老版本升级
-		if p.ClientVer < model.GameParamData.ClientVersion {
-			if cspl.GetClientVer() == model.GameParamData.ClientVersion {
-				// 升级了
-				p.ClientVer = model.GameParamData.ClientVersion
-				//todo 发奖
+		clientUpgradeConfig := PlatformMgrSingleton.GetConfig(p.Platform).ClientUpgrade
+		if clientUpgradeConfig != nil && clientUpgradeConfig.GetOn() == common.On &&
+			(len(model.GameParamData.ClientVersionChannel) == 0 || slices.Contains(model.GameParamData.ClientVersionChannel, p.LastChannel)) {
+			if p.ClientVer < model.GameParamData.ClientVersion {
+				if cspl.GetClientVer() == model.GameParamData.ClientVersion {
+					// 升级了
+					p.ClientVer = model.GameParamData.ClientVersion
+					AddMailClientUpgrade(p.SnId, clientUpgradeConfig.GetReward())
+				}
 			}
 		}
 	}
diff --git a/worldsrv/action_welfare.go b/worldsrv/action_welfare.go
index 8f1c5b1..1afccc6 100644
--- a/worldsrv/action_welfare.go
+++ b/worldsrv/action_welfare.go
@@ -14,6 +14,7 @@ import (
 	"mongo.games.com/game/model"
 	"mongo.games.com/game/mq"
 	"mongo.games.com/game/proto"
+	"mongo.games.com/game/protocol/upgrade"
 	webapiproto "mongo.games.com/game/protocol/webapi"
 	"mongo.games.com/game/protocol/welfare"
 	"mongo.games.com/game/srvdata"
@@ -1309,6 +1310,39 @@ func (this *CSDiamondBankTakeDiamondHandler) Process(s *netlib.Session, packetid
 	return nil
 }*/
 
+func CSClientUpgrades(s *netlib.Session, packetid int, data interface{}, sid int64) error {
+	logger.Logger.Tracef("CSClientUpgrades Process recv %v", data)
+	_, ok := data.(*upgrade.CSClientUpgrades)
+	if !ok {
+		return nil
+	}
+
+	p := PlayerMgrSington.GetPlayer(sid)
+	if p == nil {
+		return nil
+	}
+
+	cfg := PlatformMgrSingleton.GetConfig(p.Platform).ClientUpgrade
+	if cfg == nil {
+		return nil
+	}
+
+	pack := &upgrade.SCClientUpgrades{
+		On:      cfg.GetOn() == common.On,
+		OnForce: cfg.GetOnForce() == common.On,
+		Version: model.GameParamData.ClientVersion,
+	}
+	for _, v := range cfg.GetReward() {
+		pack.Award = append(pack.Award, &upgrade.PropInfo{
+			ItemId:  v.GetItemId(),
+			ItemNum: v.GetItemNum(),
+		})
+	}
+	p.SendToClient(int(upgrade.PacketID_PACKET_SCClientUpgrades), pack)
+	logger.Logger.Tracef("SCClientUpgrades: %v", pack)
+	return nil
+}
+
 func init() {
 	// 领取救济金
 	common.RegisterHandler(int(welfare.SPacketID_PACKET_CS_WELF_GETRELIEFFUND), &CSGetReliefFundHandler{})
@@ -1374,4 +1408,6 @@ func init() {
 	common.Register(int(welfare.SPacketID_PACKET_CSPermitExchange), welfare.CSPermitExchange{}, CSPermitExchange)
 	// 赛季典藏通行证商品信息
 	common.Register(int(welfare.SPacketID_PACKET_CSPermitShop), welfare.CSPermitShop{}, CSPermitShop)
+	// 客户端升级奖励信息
+	common.Register(int(upgrade.PacketID_PACKET_CSClientUpgrades), upgrade.CSClientUpgrades{}, CSClientUpgrades)
 }
diff --git a/worldsrv/addmail.go b/worldsrv/addmail.go
new file mode 100644
index 0000000..8faf733
--- /dev/null
+++ b/worldsrv/addmail.go
@@ -0,0 +1,127 @@
+package main
+
+import (
+	"mongo.games.com/game/protocol/webapi"
+	"time"
+
+	"github.com/globalsign/mgo/bson"
+	"mongo.games.com/goserver/core/basic"
+	"mongo.games.com/goserver/core/i18n"
+	"mongo.games.com/goserver/core/logger"
+	"mongo.games.com/goserver/core/task"
+
+	"mongo.games.com/game/model"
+)
+
+type AddMailParam struct {
+	Platform string        // 平台
+	Tp       int32         // 邮件类型
+	SrcId    int32         // 发送人
+	SrcName  string        // 发送人名字
+	SnId     int32         // 收件人玩家id
+	Title    string        // 标题
+	Content  string        // 内容
+	Items    []*model.Item // 道具
+	ShowId   int64         // 显示位置
+	Channel  []string      // 包渠道
+}
+
+func AddMail(param *AddMailParam) {
+	logger.Logger.Tracef("AddMail %+v", *param)
+	if param.SnId <= 0 || param.Title == "" || param.Content == "" {
+		return
+	}
+
+	p := PlayerMgrSington.GetPlayerBySnId(param.SnId)
+	if p != nil {
+		param.Platform = p.Platform
+	}
+
+	if param.Platform == "" {
+		return
+	}
+
+	opener := int32(1)
+	if param.SrcId <= 0 {
+		opener = 0
+	}
+
+	var params []int64
+	for _, v := range param.Items {
+		params = append(params, int64(v.ItemId))
+		params = append(params, v.ItemNum)
+	}
+
+	var msg *model.Message
+	task.New(nil, task.CallableWrapper(func(o *basic.Object) interface{} {
+		msg = &model.Message{
+			Id:          bson.NewObjectId(),
+			MType:       param.Tp,
+			Title:       param.Title,
+			Content:     param.Content,
+			Oper:        opener,
+			SrcId:       param.SrcId,
+			SrcName:     param.SrcName,
+			SnId:        param.SnId,
+			State:       model.MSGSTATE_UNREAD,
+			CreatTs:     time.Now().Unix(),
+			AttachState: model.MSGATTACHSTATE_DEFAULT,
+			Params:      params,
+			Platform:    param.Platform,
+			ShowId:      param.ShowId,
+			Channel:     param.Channel,
+		}
+		if msg.Pid == "" {
+			msg.Pid = msg.Id.Hex()
+		}
+		return model.InsertMessage(param.Platform, msg)
+	}), task.CompleteNotifyWrapper(func(data interface{}, t task.Task) {
+		if data == nil {
+			if p := PlayerMgrSington.GetPlayerBySnId(param.SnId); p != nil {
+				p.AddMessage(msg)
+			}
+		} else {
+			logger.Logger.Errorf("AddMail Error %v", data)
+		}
+	}), "AddMail").Start()
+}
+
+// AddMailByItem 赠送道具到邮件
+// srcId 发送人 srcName发送人名字
+// showId 显示位置
+func AddMailByItem(platform string, srcId int32, srcName string, snid int32, showId int64, items []*model.Item) {
+	content := i18n.Tr("languages", "GiftMail", srcName, srcName, srcName, srcName)
+	title := i18n.Tr("languages", "GiftMailTitle")
+	AddMail(&AddMailParam{
+		Platform: platform,
+		Tp:       model.MSGTYPE_ITEM,
+		SrcId:    srcId,
+		SrcName:  srcName,
+		SnId:     snid,
+		Title:    title,
+		Content:  content,
+		Items:    items,
+		ShowId:   showId,
+	})
+}
+
+func AddMailClientUpgrade(snid int32, items []*webapi.ItemInfo) {
+	var arr []*model.Item
+	for _, v := range items {
+		arr = append(arr, &model.Item{
+			ItemId:  v.ItemId,
+			ItemNum: v.ItemNum,
+		})
+	}
+
+	content := i18n.Tr("languages", "UpgradeTitle")
+	title := i18n.Tr("languages", "Upgrade")
+
+	AddMail(&AddMailParam{
+		Tp:      model.MSGTYPE_ITEM,
+		SnId:    snid,
+		Title:   title,
+		Content: content,
+		Items:   arr,
+	})
+}
diff --git a/worldsrv/bagmgr.go b/worldsrv/bagmgr.go
index cdba9d6..2422c0c 100644
--- a/worldsrv/bagmgr.go
+++ b/worldsrv/bagmgr.go
@@ -806,29 +806,6 @@ func (this *BagMgr) AddItemsOffline(param *model.AddItemParam, callback func(err
 	})).StartByExecutor(fmt.Sprintf("Player%v", param.SnId))
 }
 
-// AddMailByItem 赠送道具到邮件
-// srcId 发送人 srcName发送人名字
-// showId 显示位置
-// items[0]:道具id items[1]:道具数量 items[2]:道具id items[3]:道具数量
-func (this *BagMgr) AddMailByItem(platform string, srcId int32, srcName string, snid int32, showId int64, items []int32) {
-	logger.Logger.Trace("AddMailByItem:", srcId, srcName, items)
-	var newMsg *model.Message
-	task.New(nil, task.CallableWrapper(func(o *basic.Object) interface{} {
-		content := i18n.Tr("languages", "GiftMail", srcName, srcName, srcName, srcName)
-		title := i18n.Tr("languages", "GiftMailTitle")
-		newMsg = model.NewMessageByPlayer("", 1, srcId, srcName, snid, model.MSGTYPE_ITEM, title, content,
-			0, 0, model.MSGSTATE_UNREAD, time.Now().Unix(), 0, "", items, platform, showId)
-		return model.InsertMessage(platform, newMsg)
-	}), task.CompleteNotifyWrapper(func(data interface{}, t task.Task) {
-		if data == nil {
-			p := PlayerMgrSington.GetPlayerBySnId(snid)
-			if p != nil {
-				p.AddMessage(newMsg)
-			}
-		}
-	}), "AddMailByItem").Start()
-}
-
 // VerifyUpJybInfo 兑换礼包
 func (this *BagMgr) VerifyUpJybInfo(p *Player, args *model.VerifyUpJybInfoArgs) {
 
diff --git a/worldsrv/etcd.go b/worldsrv/etcd.go
index 4bf2b08..128a87b 100644
--- a/worldsrv/etcd.go
+++ b/worldsrv/etcd.go
@@ -100,6 +100,8 @@ func init() {
 	etcd.Register(etcd.ETCDKEY_RoomType, webapi.RoomType{}, handlerEvent)
 	//娃娃机配置
 	etcd.Register(etcd.ETCDKEY_MACHINE, webapi.MachineConfig{}, platformConfigEvent)
+	//客户端升级奖励配置
+	etcd.Register(etcd.ETCDKEY_ClientUpgrade, webapi.ClientUpgrade{}, platformConfigEvent)
 }
 
 func platformConfigEvent(ctx context.Context, completeKey string, isInit bool, event *clientv3.Event, data interface{}) {
@@ -334,9 +336,26 @@ func platformConfigEvent(ctx context.Context, completeKey string, isInit bool, e
 		if !isInit {
 			PlayerMgrSington.BroadcastDataConfigToPlatform(config.Platform, common.DataConfigSprite)
 		}
+	case *webapi.ClientUpgrade:
+		PlatformMgrSingleton.GetConfig(config.Platform).ClientUpgrade = config
 	default:
 		logger.Logger.Errorf("etcd completeKey:%s, Not processed", completeKey)
 	}
+	PlatformMgrSingleton.GetConfig("1").ClientUpgrade = &webapi.ClientUpgrade{
+		Platform: "1",
+		On:       1,
+		OnForce:  0,
+		Reward: []*webapi.ItemInfo{
+			{
+				ItemId:  100001,
+				ItemNum: 100,
+			},
+			{
+				ItemId:  100002,
+				ItemNum: 100,
+			},
+		},
+	}
 }
 
 func handlerEvent(ctx context.Context, completeKey string, isInit bool, event *clientv3.Event, data interface{}) {
diff --git a/worldsrv/permitmgr.go b/worldsrv/permitmgr.go
index 759bde8..ffd96fd 100644
--- a/worldsrv/permitmgr.go
+++ b/worldsrv/permitmgr.go
@@ -92,14 +92,14 @@ func (r *PermitMgr) OnDayTimer() {
 					rank := k + 1
 					for _, rankInfo := range cfg {
 						var has bool
-						var items []int32
+						var items []int64
 						for r := rankInfo.GetStart(); r <= rankInfo.GetEnd(); r++ {
 							if rank == int(r) {
 								has = true
 								var awards []model.AwardItem
 								for _, item := range rankInfo.GetItemId() {
-									items = append(items, item.GetItemId())
-									items = append(items, int32(item.GetItemNum()))
+									items = append(items, int64(item.GetItemId()))
+									items = append(items, item.GetItemNum())
 									awards = append(awards, model.AwardItem{
 										Id:  item.GetItemId(),
 										Num: item.GetItemNum(),
diff --git a/worldsrv/player.go b/worldsrv/player.go
index cd1d6bd..f8f267a 100644
--- a/worldsrv/player.go
+++ b/worldsrv/player.go
@@ -358,7 +358,7 @@ func (this *Player) OnLogined() {
 		}
 		mq.Write(model.NewLoginLog(this.SnId, common.LoginLogTypeLogin, this.Tel, this.Ip,
 			this.Platform, this.Channel, this.BeUnderAgentCode, this.PackageID, this.City, clog, this.GetTotalCoin(), 0, 0,
-			this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId))
+			this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId, this.ClientVer))
 
 		this.OnlineLogLogin()
 
@@ -431,7 +431,7 @@ func (this *Player) OnRehold() {
 		}
 		mq.Write(model.NewLoginLog(this.SnId, common.LoginLogTypeRehold, this.Tel, this.Ip,
 			this.Platform, this.Channel, this.BeUnderAgentCode, this.PackageID, this.City, clog, this.GetTotalCoin(),
-			gameid, 0, this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId))
+			gameid, 0, this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId, this.ClientVer))
 
 		this.OnlineLogRehold()
 	}
@@ -683,7 +683,7 @@ func (this *Player) SendMessage(showId int64) {
 					Grade:       proto.Int64(msg.Grade),
 					State:       proto.Int32(msg.State),
 					Ts:          proto.Int32(int32(msg.CreatTs)),
-					Params:      msg.Params,
+					Params:      common.CopySliceInt64ToInt32(msg.Params), //todo 修改协议
 					AttachState: proto.Int32(msg.AttachState),
 					GiftId:      proto.String(msg.GiftId),
 					GiftState:   proto.Int32(giftState),
@@ -1039,7 +1039,7 @@ func (this *Player) TestMail() {
 	var newMsg *model.Message
 
 	task.New(nil, task.CallableWrapper(func(o *basic.Object) interface{} {
-		var otherParams []int32
+		var otherParams []int64
 		otherParams = append(otherParams, 10001, 3)
 		otherParams = append(otherParams, 20001, 3)
 		otherParams = append(otherParams, 20002, 3)
@@ -1059,7 +1059,7 @@ func (this *Player) TestSubMail() {
 	var newMsg *model.Message
 
 	task.New(nil, task.CallableWrapper(func(o *basic.Object) interface{} {
-		var otherParams []int32
+		var otherParams []int64
 		otherParams = append(otherParams, 10001, 3)
 		otherParams = append(otherParams, 20001, 3)
 		otherParams = append(otherParams, 20002, 3)
@@ -1106,8 +1106,8 @@ func (this *Player) GetMessageAttach(id string) {
 						if num := len(msg.Params); num > 0 && num%2 == 0 {
 							for i := 0; i < num; i += 2 {
 								items = append(items, &model.Item{
-									ItemId:     msg.Params[i],          // 物品id
-									ItemNum:    int64(msg.Params[i+1]), // 数量
+									ItemId:     int32(msg.Params[i]), // 物品id
+									ItemNum:    msg.Params[i+1],      // 数量
 									ObtainTime: time.Now().Unix(),
 								})
 								if gainWay == common.GainWayItemPermitRank {
@@ -1119,7 +1119,7 @@ func (this *Player) GetMessageAttach(id string) {
 									}
 									if tp != -1 {
 										mq.Write(model.GenerateSystemFreeGive(this.SnId, this.Name, this.Platform, this.Channel,
-											model.SystemFreeGive_GiveType_TaskPermitRank, tp, int64(msg.Params[i+1])))
+											model.SystemFreeGive_GiveType_TaskPermitRank, tp, msg.Params[i+1]))
 									}
 								}
 							}
@@ -1283,7 +1283,7 @@ func (this *Player) DropLine() {
 		}
 		mq.Write(model.NewLoginLog(this.SnId, common.LoginLogTypeDrop, this.Tel, this.Ip,
 			this.Platform, this.Channel, this.BeUnderAgentCode, this.PackageID, this.City, clog, this.GetTotalCoin(),
-			gameid, this.LastGameId, this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId))
+			gameid, this.LastGameId, this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId, this.ClientVer))
 
 		this.SendPlayerCoin()
 		this.OnlineLogDrop()
@@ -1408,7 +1408,7 @@ func (this *Player) OnLogouted() {
 	if !this.IsRob {
 		mq.Write(model.NewLoginLog(this.SnId, common.LoginLogTypeLogout, this.Tel, this.Ip,
 			this.Platform, this.Channel, this.BeUnderAgentCode, this.PackageID, this.City, clog, this.GetTotalCoin(),
-			0, 0, this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId))
+			0, 0, this.DeviceName, this.PackageName, this.AppVersion, this.BuildVersion, this.AppChannel, this.ChannelId, this.ClientVer))
 		this.OnlineLogLogout()
 	}
 
diff --git a/worldsrv/rankmatch.go b/worldsrv/rankmatch.go
index dfdccf7..b847046 100644
--- a/worldsrv/rankmatch.go
+++ b/worldsrv/rankmatch.go
@@ -61,7 +61,7 @@ func (this *PlayerRankSeason) sendEmailAward(rankType int32) {
 
 				var coin int64
 				var diamond int64
-				var otherParams []int32
+				var otherParams []int64
 				for _, v := range item.Awards {
 					switch v.Id {
 					case 1: // 金币
@@ -70,7 +70,7 @@ func (this *PlayerRankSeason) sendEmailAward(rankType int32) {
 						diamond = int64(v.Num)
 					default:
 						// 道具
-						otherParams = []int32{v.Id, v.Num}
+						otherParams = []int64{int64(v.Id), int64(v.Num)}
 					}
 				}
 
@@ -767,12 +767,12 @@ func (r *RankMatchMgr) RankAward() {
 							logger.Logger.Errorf("RankMatchMgr OnDayTimer FindPlayerPermitList player is nil %v", list.List[k].SnId)
 							continue
 						}
-						var items []int32
+						var items []int64
 						for _, award := range rankAward {
 							if award.RankLevelId == rankId {
 								for _, itemInfo := range award.Item {
-									items = append(items, itemInfo.ItemId)
-									items = append(items, int32(itemInfo.ItemNum))
+									items = append(items, int64(itemInfo.ItemId))
+									items = append(items, itemInfo.ItemNum)
 								}
 								break
 							}
@@ -839,12 +839,12 @@ func (r *RankMatchMgr) RankAward() {
 							logger.Logger.Errorf("RankMatchMgr OnDayTimer FindWinCoinListTienlen player is nil %v", ret.List[k].SnId)
 							continue
 						}
-						var items []int32
+						var items []int64
 						for _, award := range rankAward {
 							if award.RankLevelId == rankId {
 								for _, itemInfo := range award.Item {
-									items = append(items, itemInfo.ItemId)
-									items = append(items, int32(itemInfo.ItemNum))
+									items = append(items, int64(itemInfo.ItemId))
+									items = append(items, itemInfo.ItemNum)
 								}
 								break
 							}
diff --git a/worldsrv/trascate_webapi.go b/worldsrv/trascate_webapi.go
index 5732296..4e50e4c 100644
--- a/worldsrv/trascate_webapi.go
+++ b/worldsrv/trascate_webapi.go
@@ -1439,7 +1439,7 @@ func init() {
 				// var otherParams []int32
 
 				newMsg = model.NewMessage("", int32(srcSnid), "", int32(destSnid), int32(messageType), title, content, coin, diamond,
-					model.MSGSTATE_UNREAD, time.Now().Unix(), model.MSGATTACHSTATE_DEFAULT, "", otherParams, platform, showId, channel)
+					model.MSGSTATE_UNREAD, time.Now().Unix(), model.MSGATTACHSTATE_DEFAULT, "", common.CopySliceInt32ToInt64(otherParams), platform, showId, channel)
 				if newMsg != nil {
 					err := model.InsertMessage(platform, newMsg)
 					if err != nil {
@@ -1452,7 +1452,7 @@ func init() {
 				if destSnid == 0 {
 					for _, psnid := range onlinePlayerSnid {
 						newMsg := model.NewMessage(newMsg.Id.Hex(), newMsg.SrcId, "", psnid, newMsg.MType, newMsg.Title, newMsg.Content, newMsg.Coin, newMsg.Diamond,
-							newMsg.State, newMsg.CreatTs, newMsg.AttachState, newMsg.GiftId, otherParams, platform, newMsg.ShowId, channel)
+							newMsg.State, newMsg.CreatTs, newMsg.AttachState, newMsg.GiftId, common.CopySliceInt32ToInt64(otherParams), platform, newMsg.ShowId, channel)
 						if newMsg != nil {
 							dbMsgs = append(dbMsgs, newMsg)
 						}