add 各游戏破产金额

data/DB_GameBankruptcy.dat

@@ -0,0 +1,23 @@
+
+
Tienlen207 Àš
+欢ä¹<C3A4>æ<EFBFBD>•é±¼401 Àš
+高棉象棋521 Àš
+	å<><C3A5>三水211 Àš
+愤怒的大å<C2A7>”606 Àš
+	å°<C3A5>ç<EFBFBD>«ç®­607 Àš
+	è´¢è¿<C3A8>神301 à§
+å¤<C3A5>仇者è<E280A6>”盟302 à§
+	å¤<C3A5>活节岛303 à§
+
+冰河世纪304 à§
+百战æˆ<C3A6>神305 à§
+水果拉霸306 à§
+
多ç¦<C3A7>多财307 à§
+FortuneTiger308 à§
+
FortuneDragon309 à§
+
FortuneRabbit310 à§
+	FortuneOx311 à§
+FortuneMouse312 à§
+	CashMania313 à§
+GatesOfOlympus314 à§
+	娃娃机608

data/DB_GameBankruptcy.json

@@ -0,0 +1,129 @@
+{
+	"Arr": [
+		{
+			"Id": 1,
+			"GameName": "Tienlen",
+			"GameDif": "207",
+			"LimitNum": 200000
+		},
+		{
+			"Id": 2,
+			"GameName": "欢乐捕鱼",
+			"GameDif": "401",
+			"LimitNum": 200000
+		},
+		{
+			"Id": 3,
+			"GameName": "高棉象棋",
+			"GameDif": "521",
+			"LimitNum": 200000
+		},
+		{
+			"Id": 4,
+			"GameName": "十三水",
+			"GameDif": "211",
+			"LimitNum": 200000
+		},
+		{
+			"Id": 5,
+			"GameName": "愤怒的大叔",
+			"GameDif": "606",
+			"LimitNum": 200000
+		},
+		{
+			"Id": 6,
+			"GameName": "小火箭",
+			"GameDif": "607",
+			"LimitNum": 200000
+		},
+		{
+			"Id": 7,
+			"GameName": "财运神",
+			"GameDif": "301",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 8,
+			"GameName": "复仇者联盟",
+			"GameDif": "302",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 9,
+			"GameName": "复活节岛",
+			"GameDif": "303",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 10,
+			"GameName": "冰河世纪",
+			"GameDif": "304",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 11,
+			"GameName": "百战成神",
+			"GameDif": "305",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 12,
+			"GameName": "水果拉霸",
+			"GameDif": "306",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 13,
+			"GameName": "多福多财",
+			"GameDif": "307",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 14,
+			"GameName": "FortuneTiger",
+			"GameDif": "308",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 15,
+			"GameName": "FortuneDragon",
+			"GameDif": "309",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 16,
+			"GameName": "FortuneRabbit",
+			"GameDif": "310",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 17,
+			"GameName": "FortuneOx",
+			"GameDif": "311",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 18,
+			"GameName": "FortuneMouse",
+			"GameDif": "312",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 19,
+			"GameName": "CashMania",
+			"GameDif": "313",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 20,
+			"GameName": "GatesOfOlympus",
+			"GameDif": "314",
+			"LimitNum": 300000
+		},
+		{
+			"Id": 21,
+			"GameName": "娃娃机",
+			"GameDif": "608"
+		}
+	]
+}

protocol/server/pbdata.proto

@@ -659,6 +659,22 @@ message DB_GamMatchLVArray {
     repeated DB_GamMatchLV Arr = 1;
 }
 
+message DB_GameBankruptcy {
+
+	int32 Id = 1;
+
+	string GameName = 2;
+
+	string GameDif = 3;
+
+	int32 LimitNum = 4;
+
+}
+
+message DB_GameBankruptcyArray {
+    repeated DB_GameBankruptcy Arr = 1;
+}
+
 message DB_GameCoinPool {
 
 	int32 Id = 1;

srvdata/db_game_bankruptcy.go

@@ -0,0 +1,77 @@
+
+// Code generated by xlsx2proto.
+// DO NOT EDIT!
+
+package srvdata
+
+import (
+	"google.golang.org/protobuf/proto"
+
+    "mongo.games.com/game/protocol/server"
+)
+
+var PBDB_Game_bankruptcyMgr = &DB_Game_bankruptcyMgr{
+    Datas: &server.DB_Game_bankruptcyArray{},
+    pool: make(map[int32]*server.DB_Game_bankruptcy),
+    
+}
+
+type DB_Game_bankruptcyMgr struct {
+	Datas *server.DB_Game_bankruptcyArray
+	pool  map[int32]*server.DB_Game_bankruptcy
+	
+}
+
+func (this *DB_Game_bankruptcyMgr) unmarshal(data []byte) error {
+	err := proto.Unmarshal(data, this.Datas)
+	if err == nil {
+		this.arrangeData()
+	}
+	return err
+}
+
+func (this *DB_Game_bankruptcyMgr) reunmarshal(data []byte) error {
+	newDatas := &server.DB_Game_bankruptcyArray{}
+	err := proto.Unmarshal(data, newDatas)
+	if err == nil {
+		for _, item := range newDatas.Arr {
+			existItem := this.GetData(item.GetId())
+			if existItem == nil {
+				this.pool[item.GetId()] = item
+				this.Datas.Arr = append(this.Datas.Arr, item)
+				
+			} else {
+				*existItem = *item
+			}
+		}
+	}
+	return err
+}
+
+func (this *DB_Game_bankruptcyMgr) arrangeData() {
+	if this.Datas == nil {
+		return
+	}
+
+	dataArr := this.Datas.GetArr()
+	if dataArr == nil {
+		return
+	}
+
+	for _, data := range dataArr {
+		this.pool[data.GetId()] = data
+		
+	}
+}
+
+func (this *DB_Game_bankruptcyMgr) GetData(id int32) *server.DB_Game_bankruptcy {
+	if data, ok := this.pool[id]; ok {
+		return data
+	}
+	return nil
+}
+
+
+func init() {
+	DataMgr.register("DB_Game_bankruptcy.dat", &ProtobufDataLoader{dh: PBDB_Game_bankruptcyMgr})
+}

srvdata/db_gamebankruptcy.go

@@ -0,0 +1,77 @@
+
+// Code generated by xlsx2proto.
+// DO NOT EDIT!
+
+package srvdata
+
+import (
+	"google.golang.org/protobuf/proto"
+
+    "mongo.games.com/game/protocol/server"
+)
+
+var PBDB_GameBankruptcyMgr = &DB_GameBankruptcyMgr{
+    Datas: &server.DB_GameBankruptcyArray{},
+    pool: make(map[int32]*server.DB_GameBankruptcy),
+    
+}
+
+type DB_GameBankruptcyMgr struct {
+	Datas *server.DB_GameBankruptcyArray
+	pool  map[int32]*server.DB_GameBankruptcy
+	
+}
+
+func (this *DB_GameBankruptcyMgr) unmarshal(data []byte) error {
+	err := proto.Unmarshal(data, this.Datas)
+	if err == nil {
+		this.arrangeData()
+	}
+	return err
+}
+
+func (this *DB_GameBankruptcyMgr) reunmarshal(data []byte) error {
+	newDatas := &server.DB_GameBankruptcyArray{}
+	err := proto.Unmarshal(data, newDatas)
+	if err == nil {
+		for _, item := range newDatas.Arr {
+			existItem := this.GetData(item.GetId())
+			if existItem == nil {
+				this.pool[item.GetId()] = item
+				this.Datas.Arr = append(this.Datas.Arr, item)
+				
+			} else {
+				*existItem = *item
+			}
+		}
+	}
+	return err
+}
+
+func (this *DB_GameBankruptcyMgr) arrangeData() {
+	if this.Datas == nil {
+		return
+	}
+
+	dataArr := this.Datas.GetArr()
+	if dataArr == nil {
+		return
+	}
+
+	for _, data := range dataArr {
+		this.pool[data.GetId()] = data
+		
+	}
+}
+
+func (this *DB_GameBankruptcyMgr) GetData(id int32) *server.DB_GameBankruptcy {
+	if data, ok := this.pool[id]; ok {
+		return data
+	}
+	return nil
+}
+
+
+func init() {
+	DataMgr.register("DB_GameBankruptcy.dat", &ProtobufDataLoader{dh: PBDB_GameBankruptcyMgr})
+}

worldsrv/action_server.go

@@ -128,17 +128,24 @@ func init() {
 		//比赛场不处理下面的内容
 		if !scene.IsMatchScene() && !scene.IsCustom() {
 			// 破产检测
-			sdata := srvdata.PBDB_GameSubsidyMgr.GetData(GameSubsidyid)
-			if sdata != nil {
-				if !p.IsRob && p.takeCoin > msg.GetReturnCoin() && p.takeCoin >= int64(sdata.LimitNum) && msg.GetReturnCoin() < int64(sdata.LimitNum) {
-					CostCoin := p.takeCoin - msg.GetReturnCoin()
-
-					logger.Logger.Infof("NewBankruptLogEx: snid:%v GetReturnCoin:%v coin:%v CostCoin:%v", p.SnId, msg.GetReturnCoin(), p.takeCoin, CostCoin)
-					log := model.NewBankruptLogEx(p.SnId, scene.dbGameFree.GetId(), p.CreateTime.Unix(), CostCoin,
-						p.Platform, p.Channel, p.ChannelId, scene.dbGameFree.GetGameDif(), scene.gameId)
-					if log != nil {
-						mq.Write(log)
+			if !p.IsRob {
+				for _, v := range srvdata.PBDB_GameBankruptcyMgr.Datas.GetArr() {
+					if v.GetGameDif() == "" || v.GetLimitNum() <= 0 {
+						continue
 					}
+					if v.GetGameDif() != scene.dbGameFree.GetGameDif() {
+						continue
+					}
+					if p.takeCoin > msg.GetReturnCoin() && p.takeCoin >= int64(v.GetLimitNum()) && msg.GetReturnCoin() < int64(v.GetLimitNum()) {
+						CostCoin := p.takeCoin - msg.GetReturnCoin()
+						logger.Logger.Infof("NewBankruptLogEx: snid:%v GetReturnCoin:%v coin:%v CostCoin:%v", p.SnId, msg.GetReturnCoin(), p.takeCoin, CostCoin)
+						log := model.NewBankruptLogEx(p.SnId, scene.dbGameFree.GetId(), p.CreateTime.Unix(), CostCoin,
+							p.Platform, p.Channel, p.ChannelId, scene.dbGameFree.GetGameDif(), scene.gameId)
+						if log != nil {
+							mq.Write(log)
+						}
+					}
+					break
 				}
 			}
 			// 破产检测