支付邮件功能

RO_Server_Trunk-branch_0.1.39/roserver/baseserver/model/orm_common.go

@@ -37,6 +37,8 @@ const (
 	ServerPrefix            = "server:reg"
 	ServerCompetitionPrefix = "server:com"
 
+	//是否关闭了支付发邮件功能
+	ServerPayMailPrefix = "server:paymail"
 	//地图通关进度排名
 	MapRankPrefix = "rank:map"
 	//困难地图通关进度排名

RO_Server_Trunk-branch_0.1.39/roserver/db/model/orm_helper.go

@@ -234,6 +234,15 @@ func IsServerCloseRegister() bool {
 	return false
 }
 
+// 获取是否关闭支付邮件
+func IsServerClosePayMail() bool {
+	closeState, err := service.GetRedis().HGet(model.ServerPayMailPrefix, "registerclose").Result()
+	if err == nil && closeState == "1" {
+		return true
+	}
+	return false
+}
+
 func SetRoleListToRedis(openId string, zone int32, msg interface{}) error {
 	return model.SetMessageToRedis(AccountPrefix, strconv.Itoa(int(zone))+"_"+openId, msg)
 }

RO_Server_Trunk-branch_0.1.39/roserver/db/model/role_msg.go

@@ -68,6 +68,15 @@ func init() {
 		}
 	})
 
+	serverproto.Handle_DB_SSGetServerPayMailReq = model.HandleBackendMessage(func(ev rocommon.ProcEvent, cliId model.ClientID) {
+		msg := ev.Msg().(*serverproto.SSGetServerPayMailReq)
+		util.InfoF("SSGetServerPayMailReq uid=%v", msg.Uid)
+
+		ack := &serverproto.SSGetServerPayMailAck{}
+		ack.IsTrue = IsServerClosePayMail()
+		model.ServiceReplay(ev, ack)
+	})
+
 	serverproto.Handle_DB_SSAddRoleBaseReq = model.HandleBackendMessage(func(ev rocommon.ProcEvent, cliId model.ClientID) {
 		msg := ev.Msg().(*serverproto.SSAddRoleBaseReq)
 		util.InfoF("uid=%v SSAddRoleBaseReq", cliId.SessID)

RO_Server_Trunk-branch_0.1.39/roserver/game/model/role.go

@@ -3603,6 +3603,11 @@ func (this *Role) PayInfoGet(goodsType, goodsId, count int32, rushStage, rushRou
 		GoodsId:   goodsId,
 		Count:     count,
 	}
+	msg33 := &serverproto.SSGetServerPayMailReq{
+		Uid: this.GetUUid(),
+		//ZoneId:    int32(service.GetServiceConfig().Node.Zone),
+	}
+	this.SendDb(msg33)
 	if ret == serverproto.ErrorCode_ERROR_OK {
 		// 如果是免费或者价格为0时直接购买成功
 		if payOrderInfo.Amount <= 0 {

RO_Server_Trunk-branch_0.1.39/roserver/game/msg/login_msg.go

@@ -356,6 +356,19 @@ func init() {
 		}
 	})
 
+	serverproto.Handle_GAME_SSGetServerPayMailAck = model.HandleBackendMessage(func(ev rocommon.ProcEvent, cliId model.ClientID) {
+		msg := ev.Msg().(*serverproto.SSGetServerPayMailAck)
+		util.InfoF("SSGetServerPayMailAck msg=%v", msg)
+		role := model2.RoleMag.GetRole(cliId)
+		if role == nil {
+			return
+		}
+		if !msg.IsTrue {
+			role.(*model2.Role).GetRoleMail().AddMail(model.GlobalMailIdArenaTopReward, serverproto.MailType_MailType_System,
+				map[int32]int32{}, []int32{}, "Exciting Events", "Dear players, thank you for your support and passion for our game. For more exciting events and recharge discounts, please check our official community! Event link:")
+		}
+	})
+
 	serverproto.Handle_GAME_SSGetRoleAck = model.HandleBackendMessage(func(ev rocommon.ProcEvent, cliId model.ClientID) {
 		msg := ev.Msg().(*serverproto.SSGetRoleAck)
 		role := model2.RoleMag.GetRole(cliId)

RO_Server_Trunk-branch_0.1.39/roserver/serverproto/db.pb.go

@@ -7400,6 +7400,92 @@ func (m *SSBTDataSaveNtf) GetBaseData() *BTBaseData {
 	return nil
 }
 
+type SSGetServerPayMailReq struct {
+	Uid                  uint64   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *SSGetServerPayMailReq) Reset()         { *m = SSGetServerPayMailReq{} }
+func (m *SSGetServerPayMailReq) String() string { return proto.CompactTextString(m) }
+func (*SSGetServerPayMailReq) ProtoMessage()    {}
+func (*SSGetServerPayMailReq) Descriptor() ([]byte, []int) {
+	return fileDescriptor_8817812184a13374, []int{140}
+}
+
+func (m *SSGetServerPayMailReq) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_SSGetServerPayMailReq.Unmarshal(m, b)
+}
+func (m *SSGetServerPayMailReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_SSGetServerPayMailReq.Marshal(b, m, deterministic)
+}
+func (m *SSGetServerPayMailReq) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_SSGetServerPayMailReq.Merge(m, src)
+}
+func (m *SSGetServerPayMailReq) XXX_Size() int {
+	return xxx_messageInfo_SSGetServerPayMailReq.Size(m)
+}
+func (m *SSGetServerPayMailReq) XXX_DiscardUnknown() {
+	xxx_messageInfo_SSGetServerPayMailReq.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_SSGetServerPayMailReq proto.InternalMessageInfo
+
+func (m *SSGetServerPayMailReq) GetUid() uint64 {
+	if m != nil {
+		return m.Uid
+	}
+	return 0
+}
+
+type SSGetServerPayMailAck struct {
+	Uid                  uint64   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
+	IsTrue               bool     `protobuf:"varint,2,opt,name=isTrue,proto3" json:"isTrue,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *SSGetServerPayMailAck) Reset()         { *m = SSGetServerPayMailAck{} }
+func (m *SSGetServerPayMailAck) String() string { return proto.CompactTextString(m) }
+func (*SSGetServerPayMailAck) ProtoMessage()    {}
+func (*SSGetServerPayMailAck) Descriptor() ([]byte, []int) {
+	return fileDescriptor_8817812184a13374, []int{141}
+}
+
+func (m *SSGetServerPayMailAck) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_SSGetServerPayMailAck.Unmarshal(m, b)
+}
+func (m *SSGetServerPayMailAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_SSGetServerPayMailAck.Marshal(b, m, deterministic)
+}
+func (m *SSGetServerPayMailAck) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_SSGetServerPayMailAck.Merge(m, src)
+}
+func (m *SSGetServerPayMailAck) XXX_Size() int {
+	return xxx_messageInfo_SSGetServerPayMailAck.Size(m)
+}
+func (m *SSGetServerPayMailAck) XXX_DiscardUnknown() {
+	xxx_messageInfo_SSGetServerPayMailAck.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_SSGetServerPayMailAck proto.InternalMessageInfo
+
+func (m *SSGetServerPayMailAck) GetUid() uint64 {
+	if m != nil {
+		return m.Uid
+	}
+	return 0
+}
+
+func (m *SSGetServerPayMailAck) GetIsTrue() bool {
+	if m != nil {
+		return m.IsTrue
+	}
+	return false
+}
+
 func init() {
 	proto.RegisterType((*SSAccountGetRoleListReq)(nil), "serverproto.SSAccountGetRoleListReq")
 	proto.RegisterType((*SSAccountGetRoleListAck)(nil), "serverproto.SSAccountGetRoleListAck")
@@ -7541,6 +7627,8 @@ func init() {
 	proto.RegisterType((*SSLoadCrossDataNtf)(nil), "serverproto.SSLoadCrossDataNtf")
 	proto.RegisterType((*SSWishBoxDataSaveReq)(nil), "serverproto.SSWishBoxDataSaveReq")
 	proto.RegisterType((*SSBTDataSaveNtf)(nil), "serverproto.SSBTDataSaveNtf")
+	proto.RegisterType((*SSGetServerPayMailReq)(nil), "serverproto.SSGetServerPayMailReq")
+	proto.RegisterType((*SSGetServerPayMailAck)(nil), "serverproto.SSGetServerPayMailAck")
 }
 
 func init() {
@@ -7548,7 +7636,7 @@ func init() {
 }
 
 var fileDescriptor_8817812184a13374 = []byte{
-	// 5133 bytes of a gzipped FileDescriptorProto
+	// 5163 bytes of a gzipped FileDescriptorProto
 	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x3b, 0x5d, 0x8f, 0x1c, 0x57,
 	0x56, 0xea, 0xef, 0xee, 0xd3, 0xd3, 0x33, 0xe3, 0x8a, 0x63, 0x8f, 0xe3, 0x4d, 0x76, 0x52, 0xd9,
 	0x04, 0xe7, 0x63, 0xe3, 0x5d, 0xdb, 0x38, 0x89, 0x63, 0x92, 0xcc, 0x8c, 0xed, 0xf1, 0x6c, 0x3c,
@@ -7867,7 +7955,9 @@ var fileDescriptor_8817812184a13374 = []byte{
 	0xce, 0xe3, 0xdb, 0x50, 0x7b, 0xea, 0x46, 0xa3, 0x68, 0xe1, 0x56, 0x71, 0x8e, 0xc5, 0x38, 0xe6,
 	0x0f, 0xe9, 0xb3, 0x97, 0xed, 0x43, 0x5d, 0xe8, 0x1f, 0xc0, 0x4a, 0x2f, 0xb6, 0x7b, 0x81, 0xe7,
 	0xea, 0x0c, 0xe5, 0x13, 0xd4, 0xed, 0xc3, 0xed, 0xc0, 0x73, 0xd9, 0x93, 0xf6, 0xe2, 0xe4, 0xbf,
-	0x71, 0x43, 0x45, 0x5a, 0xed, 0x5b, 0xb6, 0xb9, 0x79, 0x22, 0xe2, 0x4a, 0x84, 0x42, 0x30, 0xfe,
-	0xdb, 0x5e, 0xff, 0xfe, 0xea, 0xbb, 0x57, 0x3f, 0xd4, 0xd0, 0x7a, 0x75, 0xfa, 0xb9, 0xfe, 0xbf,
-	0x01, 0x00, 0x00, 0xff, 0xff, 0x72, 0xab, 0x6b, 0x8a, 0x35, 0x42, 0x00, 0x00,
+	0x71, 0x43, 0x45, 0x5a, 0xed, 0x5b, 0xb6, 0xb9, 0x79, 0x22, 0xe2, 0x4a, 0x84, 0x42, 0x30, 0xed,
+	0xe4, 0x4d, 0x75, 0xe3, 0xd9, 0x25, 0xc4, 0x03, 0x8c, 0x4f, 0xae, 0x57, 0xdc, 0x11, 0xb3, 0x55,
+	0x84, 0x5a, 0xfc, 0xae, 0x80, 0xba, 0xf6, 0x0f, 0xc3, 0xa9, 0x4c, 0xca, 0x3e, 0x7e, 0xda, 0x5e,
+	0xff, 0xfe, 0xea, 0xbb, 0x57, 0x3f, 0xd4, 0x98, 0xea, 0xd5, 0xe9, 0xe7, 0xfa, 0xff, 0x06, 0x00,
+	0x00, 0xff, 0xff, 0x67, 0xc8, 0xa4, 0x93, 0xa3, 0x42, 0x00, 0x00,
 }

RO_Server_Trunk-branch_0.1.39/roserver/serverproto/db.proto

@@ -798,4 +798,13 @@ message SSWishBoxDataSaveReq { //project db
 message SSBTDataSaveNtf {   //project db
    BTBoliData bt_boli_data              = 1; // 波利商城
    BTBaseData base_data                 = 2;
+}
+
+message SSGetServerPayMailReq { //project db
+    uint64 uid             =1;
+}
+
+message SSGetServerPayMailAck { //project db
+    uint64 uid             =1;
+    bool isTrue =2; //是否开启了
 }

RO_Server_Trunk-branch_0.1.39/roserver/serverproto/pbbind_gen.go

@@ -156,6 +156,7 @@ var (
 	Handle_DB_SSBTDataSaveNtf                   = func(e rocommon.ProcEvent) { panic("SSBTDataSaveNtf not implements") }
 	Handle_DB_SSActivitySmashEggsMsgSaveNtf     = func(e rocommon.ProcEvent) { panic("SSActivitySmashEggsMsgSaveNtf not implements") }
 	Handle_DB_SSCrossYuanHangTrialLogNtf        = func(e rocommon.ProcEvent) { panic("SSCrossYuanHangTrialLogNtf not implements") }
+	Handle_DB_SSGetServerPayMailReq             = func(e rocommon.ProcEvent) { panic("SSGetServerPayMailReq not implements") }
 	Handle_DB_Default                           func(e rocommon.ProcEvent)
 )
 
@@ -681,6 +682,7 @@ var (
 	Handle_GAME_SCClimbingTowerWjBossNtf                = func(e rocommon.ProcEvent) { panic("SCClimbingTowerWjBossNtf not implements") }
 	Handle_GAME_SSPayOrderCreateReq                     = func(e rocommon.ProcEvent) { panic("SSPayOrderCreateReq not implements") }
 	Handle_GAME_SSPayOrderCreateAck                     = func(e rocommon.ProcEvent) { panic("SSPayOrderCreateAck not implements") }
+	Handle_GAME_SSGetServerPayMailAck                   = func(e rocommon.ProcEvent) { panic("SSGetServerPayMailAck not implements") }
 	Handle_GAME_Default                                 func(e rocommon.ProcEvent)
 )
 
@@ -1200,6 +1202,8 @@ func GetMessageHandler(sreviceName string) rocommon.EventCallBack {
 				Handle_DB_SSActivitySmashEggsMsgSaveNtf(e)
 			case *SSCrossYuanHangTrialLogNtf:
 				Handle_DB_SSCrossYuanHangTrialLogNtf(e)
+			case *SSGetServerPayMailReq:
+				Handle_DB_SSGetServerPayMailReq(e)
 			default:
 				if Handle_DB_Default != nil {
 					Handle_DB_Default(e)
@@ -2250,6 +2254,8 @@ func GetMessageHandler(sreviceName string) rocommon.EventCallBack {
 				Handle_GAME_SSPayOrderCreateReq(e)
 			case *SSPayOrderCreateAck:
 				Handle_GAME_SSPayOrderCreateAck(e)
+			case *SSGetServerPayMailAck:
+				Handle_GAME_SSGetServerPayMailAck(e)
 			default:
 				if Handle_GAME_Default != nil {
 					Handle_GAME_Default(e)