348 lines
8.1 KiB
Go
348 lines
8.1 KiB
Go
package main
|
|
|
|
import (
|
|
"mongo.games.com/game/common"
|
|
"mongo.games.com/game/gamesrv/base"
|
|
"mongo.games.com/game/model"
|
|
"mongo.games.com/game/protocol/activity"
|
|
"mongo.games.com/game/protocol/pushcoin"
|
|
"mongo.games.com/game/srvdata"
|
|
"mongo.games.com/goserver/core/logger"
|
|
"mongo.games.com/goserver/core/netlib"
|
|
"sort"
|
|
)
|
|
|
|
const (
|
|
PowerMax = 700000
|
|
PowerInit = 400000
|
|
ValueInit = 50 * 5000
|
|
)
|
|
|
|
var BaseCoins = []int64{5000, 10000, 15000}
|
|
|
|
func init() {
|
|
// 推币机活动信息
|
|
common.Register(int(activity.PushCoinPacketID_PACKET_CSPushCoinInfo), activity.CSPushCoinInfo{}, CSPushCoinInfo)
|
|
// 推币机玩家操作
|
|
common.Register(int(activity.PushCoinPacketID_PACKET_CSPushCoinPlayerOp), activity.CSPushCoinPlayerOp{}, CSPushCoinPlayerOp)
|
|
}
|
|
|
|
func CSPushCoinInfo(s *netlib.Session, packetid int, data interface{}, sid int64) error {
|
|
_, ok := data.(*activity.CSPushCoinInfo)
|
|
if !ok {
|
|
return nil
|
|
}
|
|
|
|
p := PlayerMgrSington.GetOnlinePlayer(sid)
|
|
if p == nil {
|
|
logger.Logger.Warn("CSPushCoinInfo p == nil")
|
|
return nil
|
|
}
|
|
|
|
if p.WelfData == nil {
|
|
logger.Logger.Warn("CSPushCoinInfo p.WelfData == nil")
|
|
return nil
|
|
}
|
|
|
|
if p.WelfData.PushCoin == nil {
|
|
p.WelfData.PushCoin = &model.PushCoinData{
|
|
Power: PowerInit,
|
|
Base: BaseCoins[0],
|
|
Value: ValueInit,
|
|
Exchange: make(map[int32]int32),
|
|
}
|
|
}
|
|
|
|
pack := &activity.SCPushCoinInfo{
|
|
ShakeTimes: p.WelfData.PushCoin.Shake,
|
|
BaseCoin: p.WelfData.PushCoin.Base,
|
|
PowerLine: p.WelfData.PushCoin.Power,
|
|
PowerLineMax: PowerMax,
|
|
RefreshTimes: p.WelfData.PushCoin.Refresh,
|
|
BetList: BaseCoins,
|
|
}
|
|
|
|
for _, v := range srvdata.PBDB_PropExchangeMgr.Datas.Arr {
|
|
if v.GetGroup() == 2 {
|
|
info := &activity.ExchangeInfo{
|
|
Id: v.GetId(),
|
|
TotalTimes: int64(v.GetTimes()),
|
|
}
|
|
for kk, vv := range v.GetCost() {
|
|
info.Cost = append(info.Cost, &activity.ItemInfo{
|
|
ItemId: int32(kk),
|
|
ItemNum: int32(vv),
|
|
})
|
|
}
|
|
sort.Slice(info.Cost, func(i, j int) bool {
|
|
return info.Cost[i].ItemId < info.Cost[j].ItemId
|
|
})
|
|
for kk, vv := range v.GetGain() {
|
|
info.Gain = append(info.Gain, &activity.ItemInfo{
|
|
ItemId: int32(kk),
|
|
ItemNum: int32(vv),
|
|
})
|
|
}
|
|
sort.Slice(info.Gain, func(i, j int) bool {
|
|
return info.Gain[i].ItemId < info.Gain[j].ItemId
|
|
})
|
|
for kk, vv := range v.GetCustom() {
|
|
if kk == 1 {
|
|
info.ShakeTimes = int32(vv)
|
|
}
|
|
}
|
|
|
|
info.Times = int64(v.GetTimes() - p.WelfData.PushCoin.Exchange[v.Id])
|
|
if v.GetTimes() == 0 {
|
|
info.Times = -1
|
|
info.TotalTimes = -1
|
|
}
|
|
|
|
pack.ExchangeList = append(pack.ExchangeList, info)
|
|
}
|
|
}
|
|
|
|
// 转盘
|
|
for _, v := range srvdata.PBDB_ACTPushCoinMgr.Datas.Arr {
|
|
for kk, vv := range v.GetGain() {
|
|
pack.DrawList = append(pack.DrawList, &activity.DrawInfo{
|
|
Id: v.GetId(),
|
|
ItemId: int32(kk),
|
|
ItemNum: int32(vv),
|
|
Coin: v.GetValue(),
|
|
})
|
|
}
|
|
}
|
|
|
|
p.SendToClient(int(activity.PushCoinPacketID_PACKET_SCPushCoinInfo), pack)
|
|
logger.Logger.Trace("SCPushCoinInfo: ", pack)
|
|
return nil
|
|
}
|
|
|
|
func CSPushCoinPlayerOp(s *netlib.Session, packetid int, data interface{}, sid int64) error {
|
|
logger.Logger.Trace("CSPushCoinPlayerOpHandler Process recv ", data)
|
|
msg, ok := data.(*activity.CSPushCoinPlayerOp)
|
|
if !ok {
|
|
return nil
|
|
}
|
|
|
|
p := PlayerMgrSington.GetOnlinePlayer(sid)
|
|
if p == nil {
|
|
logger.Logger.Warn("CSPushCoinPlayerOp p == nil")
|
|
return nil
|
|
}
|
|
|
|
if p.WelfData == nil {
|
|
logger.Logger.Warn("CSPushCoinPlayerOp p.WelfData == nil")
|
|
return nil
|
|
}
|
|
|
|
if p.WelfData.PushCoin == nil {
|
|
logger.Logger.Warn("CSPushCoinPlayerOp p.WelfData.PushCoin == nil")
|
|
return nil
|
|
}
|
|
|
|
pack := &activity.SCPushCoinPlayerOp{
|
|
OpRetCode: activity.OpResultPushCoinCode_OPRC_PushCoin_Error,
|
|
OpCode: msg.GetOpCode(),
|
|
}
|
|
|
|
switch msg.GetOpCode() {
|
|
case activity.OpCodes_OP_Bet:
|
|
if p.GetCoin() < msg.GetOpParam() {
|
|
goto here
|
|
}
|
|
p.AddCoin(-msg.GetOpParam(), common.GainWayPushCoinCost, base.SyncFlag_ToClient, "system", "推币机下注")
|
|
// 增加能量条
|
|
AddPower(p, msg.GetOpParam())
|
|
|
|
case activity.OpCodes_OP_Gain:
|
|
// todo校验
|
|
|
|
for _, v := range msg.GetOpItem() {
|
|
BagMgrSingleton.AddItems(&model.AddItemParam{
|
|
Platform: p.Platform,
|
|
SnId: p.SnId,
|
|
Change: []*model.Item{{ItemId: v.GetItemId(), ItemNum: int64(v.GetItemNum())}},
|
|
GainWay: common.GainWayPushCoinGain,
|
|
Operator: "system",
|
|
Remark: "推币机掉落获得",
|
|
})
|
|
}
|
|
|
|
case activity.OpCodes_OP_Shake:
|
|
if p.WelfData.PushCoin.Shake < int32(msg.GetOpParam()) {
|
|
goto here
|
|
}
|
|
p.WelfData.PushCoin.Shake -= int32(msg.GetOpParam())
|
|
|
|
case activity.OpCodes_OP_Refresh:
|
|
p.WelfData.PushCoin.Refresh++
|
|
p.WelfData.PushCoin.Value = ValueInit
|
|
|
|
case activity.OpCodes_OP_Exchange:
|
|
d := srvdata.PBDB_PropExchangeMgr.GetData(int32(msg.GetOpParam()))
|
|
if d == nil {
|
|
goto here
|
|
}
|
|
// 兑换次数
|
|
if d.GetTimes() > 0 && p.WelfData.PushCoin.Exchange[d.Id] >= d.GetTimes() {
|
|
goto here
|
|
}
|
|
|
|
pack.Exchange = &activity.ExchangeInfo{
|
|
Id: d.Id,
|
|
}
|
|
var cost, gain []*model.Item
|
|
for k, v := range d.GetCost() {
|
|
pack.Exchange.Cost = append(pack.Exchange.Cost, &activity.ItemInfo{
|
|
ItemId: int32(k),
|
|
ItemNum: int32(v),
|
|
})
|
|
if k == 10001 && p.GetCoin() < v {
|
|
goto here
|
|
}
|
|
cost = append(cost, &model.Item{
|
|
ItemId: int32(k),
|
|
ItemNum: -v,
|
|
})
|
|
}
|
|
|
|
_, _, ok := BagMgrSingleton.AddItems(&model.AddItemParam{
|
|
Platform: p.Platform,
|
|
SnId: p.SnId,
|
|
Change: cost,
|
|
Add: 0,
|
|
GainWay: common.GainWayPushCoinExchangeCost,
|
|
Operator: "system",
|
|
Remark: "推币机活动兑换消耗",
|
|
})
|
|
if !ok {
|
|
goto here
|
|
}
|
|
|
|
for k, v := range d.GetGain() {
|
|
pack.Exchange.Gain = append(pack.Exchange.Gain, &activity.ItemInfo{
|
|
ItemId: int32(k),
|
|
ItemNum: int32(v),
|
|
})
|
|
gain = append(gain, &model.Item{
|
|
ItemId: int32(k),
|
|
ItemNum: v,
|
|
})
|
|
}
|
|
BagMgrSingleton.AddItems(&model.AddItemParam{
|
|
Platform: p.Platform,
|
|
SnId: p.SnId,
|
|
Change: gain,
|
|
Cost: cost,
|
|
Add: 0,
|
|
GainWay: common.GainWatPushCoinExchangeGain,
|
|
Operator: "system",
|
|
Remark: "推币机活动兑换获得",
|
|
})
|
|
for k, v := range d.GetCustom() {
|
|
if k == 1 {
|
|
pack.Exchange.ShakeTimes = int32(v)
|
|
}
|
|
}
|
|
|
|
if p.WelfData.PushCoin.Exchange == nil {
|
|
p.WelfData.PushCoin.Exchange = make(map[int32]int32)
|
|
}
|
|
p.WelfData.PushCoin.Exchange[d.Id]++
|
|
|
|
default:
|
|
return nil
|
|
}
|
|
|
|
pack.OpRetCode = activity.OpResultPushCoinCode_OPRC_PushCoin_Success
|
|
|
|
here:
|
|
p.SendToClient(int(pushcoin.PushCoinPacketID_PACKET_SCPushCoinPlayerOp), pack)
|
|
logger.Logger.Trace("SCPushCoinPlayerOp: ", pack)
|
|
|
|
return nil
|
|
}
|
|
|
|
func AddPower(p *Player, value int64) {
|
|
if value < 0 {
|
|
return
|
|
}
|
|
p.WelfData.PushCoin.Power += value
|
|
if p.WelfData.PushCoin.Power > PowerMax {
|
|
p.WelfData.PushCoin.Power = PowerMax
|
|
}
|
|
p.SendToClient(int(activity.PushCoinPacketID_PACKET_NotifyPowerLine), &activity.NotifyPowerLine{
|
|
PowerLine: p.WelfData.PushCoin.Power,
|
|
PowerLineMax: PowerMax,
|
|
})
|
|
if value <= 0 {
|
|
return
|
|
}
|
|
// 抽奖
|
|
Draw(p)
|
|
}
|
|
|
|
func Draw(p *Player) {
|
|
if p.WelfData.PushCoin.Power < PowerMax {
|
|
return
|
|
}
|
|
p.WelfData.PushCoin.Power = 0
|
|
var index int32 = -1
|
|
switch p.WelfData.PushCoin.Dram {
|
|
case 0:
|
|
// 必中大金币
|
|
for _, v := range srvdata.PBDB_ACTPushCoinMgr.Datas.Arr {
|
|
for kk := range v.GetGain() {
|
|
if kk == common.ItemIDBigCoin {
|
|
index = v.GetId()
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
case 1:
|
|
// 必中v卡
|
|
for _, v := range srvdata.PBDB_ACTPushCoinMgr.Datas.Arr {
|
|
for kk := range v.GetGain() {
|
|
if kk == common.ItemIDVCard {
|
|
index = v.GetId()
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
default:
|
|
var n int32
|
|
rand := common.RandInt(10000)
|
|
for _, v := range srvdata.PBDB_ACTPushCoinMgr.Datas.Arr {
|
|
if rand < int(n+v.GetRate()) {
|
|
index = v.GetId()
|
|
break
|
|
}
|
|
n += v.GetRate()
|
|
}
|
|
}
|
|
p.WelfData.PushCoin.Dram++
|
|
|
|
if index >= 0 {
|
|
d := srvdata.PBDB_ACTPushCoinMgr.GetData(index)
|
|
if d != nil {
|
|
pack := &activity.DrawInfo{
|
|
Id: d.GetId(),
|
|
Coin: d.GetValue(),
|
|
}
|
|
for k, v := range d.GetGain() {
|
|
pack.ItemId = int32(k)
|
|
pack.ItemNum = int32(v)
|
|
}
|
|
if pack.Coin > 0 || pack.ItemId > 0 {
|
|
p.SendToClient(int(activity.PushCoinPacketID_PACKET_NotifyDrawInfo), pack)
|
|
// 增加能量条
|
|
AddPower(p, d.GetValue())
|
|
}
|
|
}
|
|
}
|
|
}
|