.gitignore

@@ -47,5 +47,3 @@ tools/xlsx2binary/agc.go
 /ranksrv/ranksrv
 /schedulesrv/schedulesrv
 /machine/machine
-/statistics/statistics
-/statistics/task/task*

bin/build.bat

@@ -1,8 +1,8 @@
 @echo off
 
-xcopy ..\data\* .\data\ /s /e /y /exclude:..\exclude.txt
+xcopy ..\data\* .\data\ /s /e /y /exclude:..\shell\exclude.txt
 
-for /f %%i in (../programs.txt) do (
+for /f %%i in (../shell/programs.txt) do (
     echo go build %%i
     go build -o ./%%i/%%i.exe ../%%i/
 )

common/constant.go

@@ -898,7 +898,3 @@ var GuideIdToGainWay = map[int]int{
 	GuideIdNewPlayer: GainWayGuide,
 	GuideIdCustom:    GainWayGuide2,
 }
-
-func GetGameDifKey(gamedif string) string {
-	return fmt.Sprintf("gamedif-%v", gamedif)
-}

dbproxy/svc/l_gamedetailed.go

@@ -33,7 +33,6 @@ func GameDetailedLogsCollection(plt string) *mongo.Collection {
 			c_gamedetailed.EnsureIndex(mgo.Index{Key: []string{"ts", "cycleid"}, Background: true, Sparse: true})
 			c_gamedetailed.EnsureIndex(mgo.Index{Key: []string{"time", "cycleid"}, Background: true, Sparse: true})
 			c_gamedetailed.EnsureIndex(mgo.Index{Key: []string{"-time", "cycleid"}, Background: true, Sparse: true})
-			c_gamedetailed.EnsureIndex(mgo.Index{Key: []string{"gamedif"}, Background: true, Sparse: true})
 		}
 		return c_gamedetailed
 	}

dbproxy/svc/l_gameplayerlistlog.go

@@ -44,7 +44,6 @@ func GamePlayerListLogsCollection(plt string) *mongo.Collection {
 			c_gameplayerlistlog.EnsureIndex(mgo.Index{Key: []string{"-ts", "cycleid"}, Background: true, Sparse: true})
 			c_gameplayerlistlog.EnsureIndex(mgo.Index{Key: []string{"cycleid"}, Background: true, Sparse: true})
 			c_gameplayerlistlog.EnsureIndex(mgo.Index{Key: []string{"ts", "cycleid"}, Background: true, Sparse: true})
-			c_gameplayerlistlog.EnsureIndex(mgo.Index{Key: []string{"gamedif"}, Background: true, Sparse: true})
 		}
 		return c_gameplayerlistlog
 	}

dbproxy/svc/l_itemlog.go

@@ -30,7 +30,6 @@ func ItemLogsCollection(plt string) *mongo.Collection {
 			c_itemlog.EnsureIndex(mgo.Index{Key: []string{"typeid", "roomconfigid"}, Background: true, Sparse: true})
 			c_itemlog.EnsureIndex(mgo.Index{Key: []string{"ts"}, Background: true, Sparse: true})
 			c_itemlog.EnsureIndex(mgo.Index{Key: []string{"-ts"}, Background: true, Sparse: true})
-			c_itemlog.EnsureIndex(mgo.Index{Key: []string{"gamedif"}, Background: true, Sparse: true})
 		}
 		return c_itemlog
 	}

gamesrv/avengers/scenepolicy_avengers.go

@@ -945,6 +945,8 @@ func AvengersCheckAndSaveLog(sceneEx *AvengersSceneData, playerEx *AvengersPlaye
 					LogId:             logid,
 					Platform:          playerEx.Platform,
 					Snid:              playerEx.SnId,
+					Channel:           playerEx.Channel,
+					ChannelId:         playerEx.ChannelId,
 					TotalIn:           totalin,
 					TotalOut:          totalout,
 					TaxCoin:           playerEx.taxCoin,

gamesrv/base/gamedetail.go

@@ -44,16 +44,13 @@ func (this *Scene) SaveGameDetailedLog(param *SaveGameDetailedParam) *SaveGameDe
 	f := func(plt string) {
 		log := &model.GameDetailedLog{
 			Id:               bson.NewObjectId(),
-			Platform:         plt,
 			LogId:            param.LogId,
-			GameDif:          this.GetDBGameFree().GetGameDif(),
+			GameId:           this.GameId,
-			GameId:           this.GetDBGameFree().GetGameId(),
+			Platform:         plt,
-			GameClass:        this.GetDBGameFree().GetGameClass(),
-			GameMode:         this.GetDBGameFree().GetGameMode(),
-			GameType:         this.GetDBGameFree().GetGameType(),
-			GameFreeId:       this.GetDBGameFree().GetId(),
 			MatchId:          this.GetMatch().GetMatchSortId(),
 			SceneId:          this.SceneId,
+			GameMode:         this.GameMode,
+			GameFreeid:       this.GetGameFreeId(),
 			PlayerCount:      int32(len(this.Players)),
 			GameTiming:       int32(param.GameTime),
 			GameBaseBet:      this.GetBaseScore(),
@@ -101,6 +98,8 @@ type SaveGamePlayerListLogParam struct {
 	Platform          string // 平台
 	Snid              int32  // 玩家id
 	PlayerName        string // 玩家名字
+	Channel           string // 渠道
+	ChannelId         string // 推广渠道
 	TotalIn           int64  // 总投入
 	TotalOut          int64  // 总产出(税前)
 	TaxCoin           int64  // 总税收
@@ -156,35 +155,33 @@ func (this *Scene) SaveGamePlayerListLog(param *SaveGamePlayerListLogParam) *Sav
 	now := time.Now()
 	log := &model.GamePlayerListLog{
 		LogId:             bson.NewObjectId(),
-		Platform:          param.Platform,
-		GameDif:           this.GetDBGameFree().GetGameDif(),
-		GameId:            this.GetDBGameFree().GetGameId(),
-		GameClass:         this.GetDBGameFree().GetGameClass(),
-		GameMode:          this.GetDBGameFree().GetGameMode(),
-		GameType:          this.GetDBGameFree().GetGameType(),
-		GameFreeId:        this.GetGameFreeId(),
-		BaseScore:         baseScore,
-		GameDetailedLogId: param.LogId,
-		Channel:           p.Channel,
-		ChannelId:         p.ChannelId,
-		RoomType:          this.SceneMode,
-		Ts:                now.Unix(),
-		Time:              now,
-		CycleId:           this.CycleID,
 		SnId:              p.SnId,
 		Name:              param.PlayerName,
-		SceneId:           this.SceneId,
+		GameId:            this.GameId,
-		MatchId:           this.GetMatch().GetMatchSortId(),
+		BaseScore:         baseScore,
-		MatchType:         int64(this.GetMatch().GetMatchType()),
-		WinAmountNoAnyTax: param.WinAmountNoAnyTax,
 		TaxCoin:           param.TaxCoin,
-		BetAmount:         param.BetAmount,
+		Platform:          param.Platform,
+		Channel:           param.Channel,
+		SceneId:           this.SceneId,
+		GameMode:          this.GameMode,
+		GameFreeid:        this.GetGameFreeId(),
+		GameDetailedLogId: param.LogId,
 		IsFirstGame:       param.IsFirstGame,
+		BetAmount:         param.BetAmount,
+		WinAmountNoAnyTax: param.WinAmountNoAnyTax,
 		TotalIn:           param.TotalIn,
 		TotalOut:          param.TotalOut,
+		Time:              now,
+		RoomType:          this.SceneMode,
+		GameDif:           this.GetDBGameFree().GetGameDif(),
+		GameClass:         this.GetDBGameFree().GetGameClass(),
+		MatchId:           this.GetMatch().GetMatchSortId(),
+		MatchType:         int64(this.GetMatch().GetMatchType()),
+		Ts:                now.Unix(),
 		IsFree:            param.IsFree,
 		WinSmallGame:      param.WinSmallGame,
 		WinTotal:          param.WinTotal,
+		CycleId:           this.CycleID,
 	}
 	if param.OnlyLog {
 		ret.Log = append(ret.Log, log)
@@ -226,11 +223,10 @@ func (s *SaveGameDetailedCopy) Save() {
 	}
 }
 
-// LabaLog 拉霸缓存游戏记录,为了统计游戏时长
+// LabaLog 拉霸缓存游戏记录
 type LabaLog struct {
 	PlayerListLog *SaveGamePlayerListLogCopy
 	GameDetailLog *SaveGameDetailedCopy
-	CacheTime     time.Time // 缓存时间
 }
 
 // Cache 临时缓存
@@ -242,31 +238,13 @@ func (l *LabaLog) Cache(s *Scene, detailLog *SaveGameDetailedParam, playerListLo
 	playerListLog.OnlyLog = true
 	l.GameDetailLog = s.SaveGameDetailedLog(detailLog)
 	l.PlayerListLog = s.SaveGamePlayerListLog(playerListLog)
-	l.CacheTime = time.Now()
 }
 
 // Save 保存
-func (l *LabaLog) Save(second int32) {
+func (l *LabaLog) Save(f func(log *LabaLog)) {
-	if second <= 0 {
+	f(l)
-		second = int32(time.Now().Sub(l.CacheTime).Seconds())
-	}
-
-	if l.PlayerListLog != nil {
-		if l.PlayerListLog.UpLog != nil {
-			for _, v := range l.PlayerListLog.UpLog.Log {
-				v.GamingTime = second
-			}
-		}
 	l.PlayerListLog.Save()
-	}
-
-	if l.GameDetailLog != nil {
-		for _, v := range l.GameDetailLog.Log {
-			v.GameTiming = second
-		}
 	l.GameDetailLog.Save()
-	}
-
 	l.Clear()
 }
 
@@ -274,5 +252,4 @@ func (l *LabaLog) Save(second int32) {
 func (l *LabaLog) Clear() {
 	l.PlayerListLog = nil
 	l.GameDetailLog = nil
-	l.CacheTime = time.Time{}
 }

gamesrv/base/player.go

@@ -638,8 +638,8 @@ type ReportGameEventOnly struct {
 
 func (this *Player) ReportGameEvent(param *ReportGameEventParam) *ReportGameEventOnly {
 	// 记录玩家 首次参与该场次的游戏时间 游戏次数
-	var gameFirstTime, gameFreeFirstTime, gamedifFirstTime time.Time
+	var gameFirstTime, gameFreeFirstTime time.Time
-	var gameTimes, gameFreeTimes, gamedifTimes int64
+	var gameTimes, gameFreeTimes int64
 	data, ok := this.GDatas[this.scene.KeyGamefreeId]
 	if ok {
 		gameFreeFirstTime = data.FirstTime
@@ -659,7 +659,7 @@ func (this *Player) ReportGameEvent(param *ReportGameEventParam) *ReportGameEven
 		isNew = 1
 	}
 
-	if param.GameTime <= 0 {
+	if param.GameTime < 0 {
 		param.GameTime = int64(time.Now().Sub(this.scene.GameNowTime).Seconds())
 	}
 	if param.GameTime < 0 {
@@ -670,31 +670,30 @@ func (this *Player) ReportGameEvent(param *ReportGameEventParam) *ReportGameEven
 	ret.Param = param
 	log := &model.PlayerGameRecEvent{
 		Id:        primitive.NewObjectID().Hex(),
+		Platform:  this.Platform,
 		RecordId:  this.scene.GetRecordId(),
 		SnId:      this.GetSnId(),
 		Channel:   this.Channel,
-		Platform:         this.Platform,
+		ChannelId: this.ChannelId,
+		//City:          this.City,
 		OS:            this.DeviceOS,
 		GameId:        this.scene.GameId,
 		ModeId:        this.scene.GameMode,
 		Tax:           param.Tax,
 		Amount:        param.Change,
-		CreateTime:       time.Now().Unix(),
+		CreateTime:    this.CreateTime.Unix(),
 		CreateDayTime: tCreateDay.Unix(),
 		Out:           param.Out,
 		In:            param.In,
 		IsNew:         isNew,
 		GameFreeID:    this.scene.GetGameFreeId(),
 		GamingTime:    int32(param.GameTime),
-		GameDif:          this.scene.GetDBGameFree().GetGameDif(),
-		FirstGameDifTime: gamedifFirstTime.Unix(),
-		GameDifTimes:     gamedifTimes,
 		FirstTime:     gameFreeFirstTime.Unix(),
 		PlayTimes:     gameFreeTimes,
 		FirstGameTime: gameFirstTime.Unix(),
 		PlayGameTimes: gameTimes,
 		LastLoginTime: this.LastLoginTime.Unix(),
-		ChannelId:        this.ChannelId,
+		//DeviceId:      this.DeviceId,
 	}
 	if param.OnlyLog {
 		ret.Log = append(ret.Log, log)

gamesrv/base/scene.go

@@ -2057,7 +2057,6 @@ func (this *Scene) IsControl(hasRobotGaming bool) bool {
 
 // Statistics 玩家游戏数据统计
 // 包含水池统计，黑白名单统计，新手调控统计，个人水池统计
-// 拉霸游戏数据统计,一次下注记录一次 StaticsLaba
 func (this *Scene) Statistics(param *StaticParam) {
 	if param == nil {
 		return
@@ -2111,7 +2110,6 @@ func (this *Scene) Statistics(param *StaticParam) {
 	var statics []*model.PlayerGameStatics
 	keyGameId := strconv.Itoa(this.GetGameId())
 	keyGameFreeId := strconv.Itoa(int(this.GetGameFreeId()))
-	keyGameDif := common.GetGameDifKey(this.GetDBGameFree().GetGameDif())
 	// 当天数据统计
 	// 按场次分
 	if data, ok := p.TodayGameData.CtrlData[keyGameFreeId]; ok {
@@ -2129,14 +2127,6 @@ func (this *Scene) Statistics(param *StaticParam) {
 		p.TodayGameData.CtrlData[keyGameId] = data
 		statics = append(statics, data)
 	}
-	// 按游戏组分
-	if data, ok := p.TodayGameData.CtrlData[keyGameDif]; ok {
-		statics = append(statics, data)
-	} else {
-		data = model.NewPlayerGameStatics()
-		p.TodayGameData.CtrlData[keyGameDif] = data
-		statics = append(statics, data)
-	}
 	// 按场次分
 	if data, ok := p.GDatas[keyGameFreeId]; ok {
 		if data.FirstTime.IsZero() {
@@ -2159,27 +2149,6 @@ func (this *Scene) Statistics(param *StaticParam) {
 		p.GDatas[keyGameId] = data
 		statics = append(statics, &data.Statics)
 	}
-	//按游戏组分
-	getMinTime := func() time.Time {
-		var minTime = time.Now()
-		for _, v := range srvdata.GameFreeMgr.GetGameId(this.GetDBGameFree().GetGameDif()) {
-			vv := p.GDatas[strconv.Itoa(int(v))]
-			if vv != nil && vv.FirstTime.Before(minTime) {
-				minTime = vv.FirstTime
-			}
-		}
-		return minTime
-	}
-	if data, ok := p.GDatas[keyGameDif]; ok {
-		if data.FirstTime.IsZero() {
-			data.FirstTime = getMinTime()
-		}
-		statics = append(statics, &data.Statics)
-	} else {
-		data = &model.PlayerGameInfo{FirstTime: getMinTime()}
-		p.GDatas[keyGameDif] = data
-		statics = append(statics, &data.Statics)
-	}
 
 	// 新手输赢统计
 	if !model.GameParamData.CloseNovice && !common.InSliceInt(model.GameParamData.CloseNoviceGame, int(this.GameId)) && isControl && wbLevel == 0 && isNovice {
@@ -2350,7 +2319,6 @@ func (this *Scene) StaticsLaba(param *StaticLabaParam) {
 	var statics []*model.PlayerGameStatics
 	keyGameId := strconv.Itoa(this.GetGameId())
 	keyGameFreeId := strconv.Itoa(int(this.GetGameFreeId()))
-	keyGameDif := common.GetGameDifKey(this.GetDBGameFree().GetGameDif())
 	// 当天数据统计
 	// 按场次分
 	if data, ok := p.TodayGameData.CtrlData[keyGameFreeId]; ok {
@@ -2368,14 +2336,6 @@ func (this *Scene) StaticsLaba(param *StaticLabaParam) {
 		p.TodayGameData.CtrlData[keyGameId] = data
 		statics = append(statics, data)
 	}
-	// 按游戏组
-	if data, ok := p.TodayGameData.CtrlData[keyGameDif]; ok {
-		statics = append(statics, data)
-	} else {
-		data = model.NewPlayerGameStatics()
-		p.TodayGameData.CtrlData[keyGameDif] = data
-		statics = append(statics, data)
-	}
 	// 按场次分
 	if data, ok := p.GDatas[keyGameFreeId]; ok {
 		if data.FirstTime.IsZero() {
@@ -2398,27 +2358,6 @@ func (this *Scene) StaticsLaba(param *StaticLabaParam) {
 		p.GDatas[keyGameId] = data
 		statics = append(statics, &data.Statics)
 	}
-	// 按游戏组
-	getMinTime := func() time.Time {
-		var minTime = time.Now()
-		for _, v := range srvdata.GameFreeMgr.GetGameId(this.GetDBGameFree().GetGameDif()) {
-			vv := p.GDatas[strconv.Itoa(int(v))]
-			if vv != nil && vv.FirstTime.Before(minTime) {
-				minTime = vv.FirstTime
-			}
-		}
-		return minTime
-	}
-	if data, ok := p.GDatas[keyGameDif]; ok {
-		if data.FirstTime.IsZero() {
-			data.FirstTime = getMinTime()
-		}
-		statics = append(statics, &data.Statics)
-	} else {
-		data = &model.PlayerGameInfo{FirstTime: getMinTime()}
-		p.GDatas[keyGameDif] = data
-		statics = append(statics, &data.Statics)
-	}
 
 	for _, data := range statics {
 		if data != nil {

gamesrv/caishen/scenepolicy_caishen.go

@@ -1035,6 +1035,8 @@ func CaiShenCheckAndSaveLog(sceneEx *CaiShenSceneData, playerEx *CaiShenPlayerDa
 					Platform:          playerEx.Platform,
 					Snid:              playerEx.SnId,
 					PlayerName:        playerEx.Name,
+					Channel:           playerEx.Channel,
+					ChannelId:         playerEx.ChannelId,
 					TotalIn:           totalin,
 					TotalOut:          totalout,
 					TaxCoin:           playerEx.taxCoin,

gamesrv/chess/scenepolicy.go

@@ -1315,6 +1315,8 @@ func (this *SceneStateBilled) OnEnter(s *base.Scene) {
 					Platform:          o_player.Platform,
 					Snid:              o_player.UserId,
 					PlayerName:        "",
+					Channel:           o_player.Channel,
+					ChannelId:         o_player.ChannelId,
 					TotalIn:           totalin,
 					TotalOut:          totalout,
 					TaxCoin:           o_player.GainTaxCoin,

gamesrv/clawdoll/scenepolicy_clawdoll.go

@@ -795,6 +795,8 @@ func (this *StateBilled) OnEnter(s *base.Scene) {
 				Platform:    playerEx.Platform,
 				Snid:        playerEx.SnId,
 				PlayerName:  playerEx.Name,
+				Channel:     playerEx.Channel,
+				ChannelId:   playerEx.ChannelId,
 				TotalIn:     totalin,
 				TotalOut:    totalout,
 				TaxCoin:     playerEx.taxCoin,

gamesrv/easterisland/scenepolicy_easterisland.go

@@ -904,6 +904,8 @@ func EasterIslandCheckAndSaveLog(sceneEx *EasterIslandSceneData, playerEx *Easte
 					Platform:          playerEx.Platform,
 					Snid:              playerEx.SnId,
 					PlayerName:        playerEx.Name,
+					Channel:           playerEx.Channel,
+					ChannelId:         playerEx.ChannelId,
 					TotalIn:           totalin,
 					TotalOut:          totalout,
 					TaxCoin:           playerEx.taxCoin,

gamesrv/fishing/playerdata_fishing.go

@@ -267,6 +267,8 @@ func (this *FishingPlayerData) SaveDetailedLog(s *base.Scene) {
 				Platform:          this.Platform,
 				Snid:              this.SnId,
 				PlayerName:        this.Name,
+				Channel:           this.Channel,
+				ChannelId:         this.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           int64(this.sTaxCoin),

gamesrv/fortunedragon/scenepolicy_fortunedragon.go

@@ -537,6 +537,8 @@ func FortuneDragonAndSaveLog(sceneEx *FortuneDragonSceneData, playerEx *FortuneD
 				Platform:          playerEx.Platform,
 				Snid:              playerEx.SnId,
 				PlayerName:        playerEx.Name,
+				Channel:           playerEx.Channel,
+				ChannelId:         playerEx.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           playerEx.taxCoin,

gamesrv/fortunemouse/scenepolicy_fortunemouse.go

@@ -548,6 +548,8 @@ func FortuneMouseAndSaveLog(sceneEx *FortuneMouseSceneData, playerEx *FortuneMou
 				Platform:          playerEx.Platform,
 				Snid:              playerEx.SnId,
 				PlayerName:        playerEx.Name,
+				Channel:           playerEx.Channel,
+				ChannelId:         playerEx.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           playerEx.taxCoin,

gamesrv/fortuneox/scenepolicy_fortuneox.go

@@ -548,6 +548,8 @@ func FortuneOxAndSaveLog(sceneEx *FortuneOxSceneData, playerEx *FortuneOxPlayerD
 				Platform:          playerEx.Platform,
 				Snid:              playerEx.SnId,
 				PlayerName:        playerEx.Name,
+				Channel:           playerEx.Channel,
+				ChannelId:         playerEx.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           playerEx.taxCoin,

gamesrv/fortunerabbit/scenepolicy_fortunerabbit.go

@@ -535,6 +535,8 @@ func FortuneRabbitAndSaveLog(sceneEx *FortuneRabbitSceneData, playerEx *FortuneR
 				Platform:          playerEx.Platform,
 				Snid:              playerEx.SnId,
 				PlayerName:        playerEx.Name,
+				Channel:           playerEx.Channel,
+				ChannelId:         playerEx.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           playerEx.taxCoin,

gamesrv/fortunetiger/scenepolicy_fortunetiger.go

@@ -548,6 +548,8 @@ func FortuneTigerAndSaveLog(sceneEx *FortuneTigerSceneData, playerEx *FortuneTig
 				Platform:          playerEx.Platform,
 				Snid:              playerEx.SnId,
 				PlayerName:        playerEx.Name,
+				Channel:           playerEx.Channel,
+				ChannelId:         playerEx.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           playerEx.taxCoin,

gamesrv/fruits/scenedata_fruits.go

@@ -345,6 +345,8 @@ func (s *FruitsSceneData) SaveLog(p *FruitsPlayerData, isOffline int) {
 			Platform:          p.Platform,
 			Snid:              p.SnId,
 			PlayerName:        p.Name,
+			Channel:           p.Channel,
+			ChannelId:         p.ChannelId,
 			TotalIn:           totalIn,
 			TotalOut:          totalOut,
 			TaxCoin:           p.taxCoin,

gamesrv/iceage/scenepolicy_iceage.go

@@ -954,6 +954,8 @@ func IceAgeCheckAndSaveLog(sceneEx *IceAgeSceneData, playerEx *IceAgePlayerData)
 					Platform:          playerEx.Platform,
 					Snid:              playerEx.SnId,
 					PlayerName:        playerEx.Name,
+					Channel:           playerEx.Channel,
+					ChannelId:         playerEx.ChannelId,
 					TotalIn:           totalin,
 					TotalOut:          totalout,
 					TaxCoin:           playerEx.taxCoin,

gamesrv/richblessed/scenedata_richblessed.go

@@ -367,6 +367,8 @@ func (s *RichBlessedSceneData) SaveLog(p *RichBlessedPlayerData, isOffline int)
 			Platform:          p.Platform,
 			Snid:              p.SnId,
 			PlayerName:        p.Name,
+			Channel:           p.Channel,
+			ChannelId:         p.ChannelId,
 			TotalIn:           totalIn,
 			TotalOut:          totalOut,
 			TaxCoin:           p.taxCoin,

gamesrv/smallrocket/scenepolicy.go

@@ -1179,6 +1179,8 @@ func (this *StateBilled) OnEnter(s *base.Scene) {
 							Platform:          playerEx.Platform,
 							Snid:              playerEx.SnId,
 							PlayerName:        playerEx.Name,
+							Channel:           playerEx.Channel,
+							ChannelId:         playerEx.ChannelId,
 							TotalIn:           totalin,
 							TotalOut:          totalout,
 							TaxCoin:           playerEx.taxCoin,
@@ -1256,6 +1258,8 @@ func (this *StateBilled) OnEnter(s *base.Scene) {
 						Platform:          playerEx.Platform,
 						Snid:              playerEx.SnId,
 						PlayerName:        playerEx.Name,
+						Channel:           playerEx.Channel,
+						ChannelId:         playerEx.ChannelId,
 						TotalIn:           totalin,
 						TotalOut:          totalout,
 						TaxCoin:           playerEx.taxCoin,

gamesrv/tamquoc/scenepolicy_tamquoc.go

@@ -790,6 +790,8 @@ func TamQuocCheckAndSaveLog(sceneEx *TamQuocSceneData, playerEx *TamQuocPlayerDa
 					Platform:          playerEx.Platform,
 					Snid:              playerEx.SnId,
 					PlayerName:        playerEx.Name,
+					Channel:           playerEx.Channel,
+					ChannelId:         playerEx.ChannelId,
 					TotalIn:           totalin,
 					TotalOut:          totalout,
 					TaxCoin:           playerEx.taxCoin,

gamesrv/thirteen/scenepolicy.go

@@ -188,6 +188,8 @@ func (this *PolicyThirteen) OnPlayerLeave(s *base.Scene, p *base.Player, reason
 				Platform:          playerEx.Platform,
 				Snid:              playerEx.SnId,
 				PlayerName:        playerEx.Name,
+				Channel:           playerEx.Channel,
+				ChannelId:         playerEx.ChannelId,
 				TotalIn:           totalin,
 				TotalOut:          totalout,
 				TaxCoin:           playerEx.taxCoin,
@@ -1436,6 +1438,8 @@ func (this *StateBilled) OnEnter(s *base.Scene) {
 								Platform:          o_player.Platform,
 								Snid:              o_player.SnId,
 								PlayerName:        o_player.Name,
+								Channel:           o_player.Channel,
+								ChannelId:         o_player.ChannelId,
 								TotalIn:           totalin,
 								TotalOut:          totalout,
 								TaxCoin:           o_player.taxCoin,

gamesrv/tienlen/scenepolicy_tienlen.go

@@ -2761,6 +2761,8 @@ func (this *SceneBilledStateTienLen) OnEnter(s *base.Scene) {
 						LogId:             sceneEx.recordId,
 						Platform:          o_player.Platform,
 						Snid:              o_player.UserId,
+						Channel:           o_player.Channel,
+						ChannelId:         o_player.ChannelId,
 						TotalIn:           totalin,
 						TotalOut:          totalout,
 						TaxCoin:           o_player.BillTaxCoin,

model/dataevent.go

@@ -263,7 +263,7 @@ type PlayerGameRecEvent struct {
 	GameFreeID    int32  //游戏freeid
 	GamingTime    int32  //游戏开始到玩家结算的时长 单位：秒
 
-	GameDif          string // 游戏分组
+	GameDif          int32 // 游戏分组
 	FirstGameDifTime int64 // 首次游戏分组时间
 	GameDifTimes     int64 // 游戏分组游戏次数
 

model/gamedetailedlog.go

@@ -23,33 +23,9 @@ type CoinPoolCtx struct {
 	Controlled bool  //被水池控制了
 }
 
-type GameDetailedLog struct {
+type GameDetailedLogRet struct {
-	Id               bson.ObjectId `bson:"_id"`
+	Gplt GameDetailedLogType
-	Platform         string        // 平台
-	LogId            string        // 记录ID，每局游戏唯一
-	GameDif          string        // 游戏组
-	GameId           int32         // 游戏id
-	GameClass        int32         // 游戏类型
-	GameMode         int32         // 游戏模式，弃用
-	GameType         int32         // 游戏类型
-	GameFreeId       int32         // 场次id
-	CycleId          string        // 房卡场id，多轮有相同的id
-	MatchId          int64         // 比赛ID，应该用字符串的
-	SceneId          int32         // 房间id，会重复
-	PlayerCount      int32         // 玩家数量
-	GameTiming       int32         // 游戏用时，秒
-	GameBaseBet      int32         // 游戏底分
-	Ts               int64         // 时间戳
-	Time             time.Time     // 记录时间
-	GameDetailedNote string        // 游戏详情
-	GameDetailVer    int32         // 游戏详情版本
-
-	CpCtx         CoinPoolCtx // 水池上下文信息
-	Trend20Lately string      // 最近游戏走势
-	CtrlType      int         // 1控赢 2控输 0不控
-	PlayerPool    map[int]int // 个人水池分 玩家id:分
 }
-
 type GameDetailedLogType struct {
 	PageNo   int                //当前页码
 	PageSize int                //每页数量
@@ -57,8 +33,64 @@ type GameDetailedLogType struct {
 	Data     []*GameDetailedLog //当页数据
 }
 
-type GameDetailedLogRet struct {
+type GameDetailedLog struct {
-	Gplt GameDetailedLogType
+	Id               bson.ObjectId `bson:"_id"` //记录ID
+	LogId            string        //记录ID，每局游戏唯一
+	GameId           int32         //游戏id
+	ClubId           int32         //俱乐部Id
+	ClubRoom         string        //俱乐部包间
+	Platform         string        //平台id
+	Channel          string        //渠道
+	Promoter         string        //推广员
+	MatchId          int64         //比赛ID，应该用字符串的
+	SceneId          int32         //房间id，会重复
+	GameMode         int32         //游戏类型
+	GameFreeid       int32         //游戏类型房间号
+	PlayerCount      int32         //玩家数量
+	GameTiming       int32         //本局游戏用时(mm)
+	GameBaseBet      int32         //游戏单位低分
+	GameDetailedNote string        //游戏详情
+	GameDetailVer    int32         //游戏详情版本
+	CpCtx            CoinPoolCtx   //水池上下文信息
+	Time             time.Time     //记录时间
+	Trend20Lately    string        //最近游戏走势
+	Ts               int64         //时间戳
+	CtrlType         int           // 1控赢 2控输 0不控
+	PlayerPool       map[int]int   // 个人水池分
+	CycleId          string        // 本轮id，打一轮有多局
+}
+
+func NewGameDetailedLog() *GameDetailedLog {
+	log := &GameDetailedLog{Id: bson.NewObjectId()}
+	return log
+}
+
+func NewGameDetailedLogEx(logid string, gameid, sceneid, gamemode, gamefreeid, playercount, gametiming, gamebasebet int32,
+	gamedetailednote string, platform string, clubId int32, clubRoom string, cpCtx CoinPoolCtx, ver int32,
+	trend20Lately string, ctrlType int, playerPool map[int]int, cycleId string) *GameDetailedLog {
+	cl := NewGameDetailedLog()
+	cl.LogId = logid
+	cl.GameId = gameid
+	cl.ClubId = clubId
+	cl.ClubRoom = clubRoom
+	cl.SceneId = sceneid
+	cl.GameMode = gamemode
+	cl.GameFreeid = gamefreeid
+	cl.PlayerCount = playercount
+	cl.GameTiming = gametiming
+	cl.GameBaseBet = gamebasebet
+	cl.GameDetailedNote = gamedetailednote
+	cl.Platform = platform
+	tNow := time.Now()
+	cl.Time = tNow
+	cl.CpCtx = cpCtx
+	cl.GameDetailVer = ver
+	cl.Trend20Lately = trend20Lately
+	cl.Ts = time.Now().Unix()
+	cl.CtrlType = ctrlType
+	cl.PlayerPool = playerPool
+	cl.CycleId = cycleId
+	return cl
 }
 
 func InsertGameDetailedLog(log *GameDetailedLog) (err error) {

model/gameplayerlistlog.go

@@ -21,36 +21,86 @@ type GameTotalRecord struct {
 
 type GamePlayerListLog struct {
 	LogId             bson.ObjectId `bson:"_id"` //记录ID
-	Platform          string        // 平台
-	GameDif           string        // 游戏组
-	GameId            int32         // 游戏id
-	GameClass         int32         // 游戏类型
-	GameMode          int32         // 游戏模式，弃用
-	GameType          int32         // 游戏类型
-	GameFreeId        int32         // 场次id
-	BaseScore         int32         // 游戏底注
-	GameDetailedLogId string        // 游戏记录Id
-	Channel           string        // 包类型
-	ChannelId         string        // 推广渠道
-	RoomType          int32         // 房间类型
-	Ts                int64         // 记录时间
-	Time              time.Time     // 记录时间
-	CycleId           string        // 本轮id，打一轮有多局
-
 	SnId              int32         //用户Id
 	Name              string        //名称
-	SceneId           int32  // 房间id，会重复
+	GameId            int32         //游戏id
-	MatchId           int64  // 比赛ID，应该用字符串的
+	BaseScore         int32         //游戏底注
-	MatchType         int64  // 0.普通场 1.锦标赛 2.冠军赛 3.vip专属
+	ClubId            int32         //俱乐部Id
-	WinAmountNoAnyTax int64  // 盈利金额，不包含任何税
+	ClubRoom          string        //俱乐部包间
 	TaxCoin           int64         //税收
-	BetAmount         int64  // 下注金额
+	ClubPumpCoin      int64         //俱乐部额外抽水
+	Platform          string        //平台id
+	Channel           string        //渠道
+	Promoter          string        //推广员
+	PackageTag        string        //包标识
+	SceneId           int32         //场景ID
+	GameMode          int32         //游戏类型
+	GameFreeid        int32         //游戏类型房间号
+	GameDetailedLogId string        //游戏记录Id
 	IsFirstGame       bool          //是否第一次游戏
+	//对于拉霸类：BetAmount=100	WinAmountNoAnyTax=0	（表示投入多少、收益多少，值>=0）
+	//拉霸类小游戏会是：BetAmount=0		WinAmountNoAnyTax=100	（投入0、收益多少，值>=0）
+	//对战场：BetAmount=0		WinAmountNoAnyTax=100	（投入会有是0、收益有正负，WinAmountNoAnyTax=100则盈利，WinAmountNoAnyTax=-100则输100）
+	BetAmount         int64     //下注金额
+	WinAmountNoAnyTax int64     //盈利金额，不包含任何税
 	TotalIn           int64     //本局投入
 	TotalOut          int64     //本局产出
+	Time              time.Time //记录时间
+	RoomType          int32     //房间类型
+	GameDif           string    //游戏标识
+	GameClass         int32     //游戏类型 1棋牌	2电子	3百人	4捕鱼	5视讯	6彩票	7体育
+	MatchId           int64
+	MatchType         int64 //0.普通场 1.锦标赛 2.冠军赛 3.vip专属
+	Ts                int64
 	IsFree            bool   //拉霸专用 是否免费
 	WinSmallGame      int64  //拉霸专用 小游戏奖励
 	WinTotal          int64  //拉霸专用 输赢
+	CycleId           string // 本轮id，打一轮有多局
+}
+
+func NewGamePlayerListLog() *GamePlayerListLog {
+	log := &GamePlayerListLog{LogId: bson.NewObjectId()}
+	return log
+}
+func NewGamePlayerListLogEx(snid int32, gamedetailedlogid string, platform, channel, promoter, packageTag string, gameid, baseScore,
+	sceneid, gamemode, gamefreeid int32, totalin, totalout int64, clubId int32, clubRoom string, taxCoin, pumpCoin int64, roomType int32,
+	betAmount, winAmountNoAnyTax int64, key, name string, gameClass int32, isFirst bool, matchid, matchType int64,
+	isFree bool, winSmallGame, winTotal int64, cycleId string) *GamePlayerListLog {
+	cl := NewGamePlayerListLog()
+	cl.SnId = snid
+	cl.GameDetailedLogId = gamedetailedlogid
+	cl.Platform = platform
+	cl.Name = name
+	cl.Channel = channel
+	cl.Promoter = promoter
+	cl.PackageTag = packageTag
+	cl.GameFreeid = gamefreeid
+	cl.GameId = gameid
+	cl.BaseScore = baseScore
+	cl.ClubId = clubId
+	cl.GameMode = gamemode
+	cl.SceneId = sceneid
+	cl.TotalIn = totalin
+	cl.TotalOut = totalout
+	cl.ClubRoom = clubRoom
+	cl.TaxCoin = taxCoin
+	cl.IsFirstGame = isFirst
+	cl.ClubPumpCoin = pumpCoin
+	cl.RoomType = roomType
+	cl.BetAmount = betAmount
+	cl.WinAmountNoAnyTax = winAmountNoAnyTax
+	cl.GameDif = key
+	cl.GameClass = gameClass
+	cl.IsFree = isFree
+	cl.WinSmallGame = winSmallGame
+	cl.WinTotal = winTotal
+	tNow := time.Now()
+	cl.Ts = tNow.Unix()
+	cl.Time = tNow
+	cl.MatchId = matchid
+	cl.MatchType = matchType
+	cl.CycleId = cycleId
+	return cl
 }
 
 type GamePlayerListRet struct {

model/itemdatalog.go

@@ -28,7 +28,6 @@ type ItemLog struct {
 	TypeId       int32         // 变化类型
 	GameId       int64         // 游戏id,游戏中获得时有值
 	GameFreeId   int64         // 场次id,游戏中获得时有值
-	GameDif      string        // 游戏分组
 	Cost         []*Item       // 消耗的道具
 	Id           string        // 撤销的id，兑换失败
 	RoomConfigId int32         // 房间配置id
@@ -51,7 +50,6 @@ type ItemParam struct {
 	TypeId       int32   // 变化类型
 	GameId       int64   // 游戏id,游戏中获得时有值
 	GameFreeId   int64   // 场次id,游戏中获得时有值
-	GameDif      string  // 游戏分组
 	Cost         []*Item // 消耗的道具
 	LogId        string  // 撤销的id，兑换失败
 	RoomConfigId int32   // 房间配置id
@@ -73,7 +71,6 @@ func NewItemLogEx(param ItemParam) *ItemLog {
 	itemLog.TypeId = param.TypeId
 	itemLog.GameId = param.GameId
 	itemLog.GameFreeId = param.GameFreeId
-	itemLog.GameDif = param.GameDif
 	itemLog.Cost = param.Cost
 	itemLog.Id = param.LogId
 	itemLog.RoomConfigId = param.RoomConfigId
@@ -249,7 +246,7 @@ type InsertItemLogReq struct {
 	Logs []*ItemLog
 }
 
-func InsertItemLog(configItems map[int32]*server.DB_GameItem, param *AddItemParam, gamedif string, isOffline bool) error {
+func InsertItemLog(configItems map[int32]*server.DB_GameItem, param *AddItemParam, isOffline bool) error {
 	if rpcCli == nil {
 		logger.Logger.Warnf("rpcCli is nil")
 		return errors.New("rpcCli is nil")
@@ -283,7 +280,6 @@ func InsertItemLog(configItems map[int32]*server.DB_GameItem, param *AddItemPara
 			TypeId:       param.GainWay,
 			GameId:       param.GameId,
 			GameFreeId:   param.GameFreeId,
-			GameDif:      gamedif,
 			Cost:         param.Cost,
 			LogId:        param.LogId,
 			RoomConfigId: param.RoomConfigId,

worldsrv/bagmgr.go

@@ -690,15 +690,6 @@ func (this *BagMgr) AddItems(param *model.AddItemParam) (*BagInfo, bag.OpResultC
 			logType = ItemConsume
 			num = -v.ItemNum
 		}
-		gamedif := ""
-		plt := PlatformMgrSingleton.GetPlatform(p.Platform)
-		if plt != nil {
-			gf := plt.GameConfig.GetGameConfig(int32(param.GameFreeId))
-			if gf != nil {
-				gamedif = gf.GetDbGameFree().GetGameDif()
-			}
-		}
-
 		// 日志
 		log := model.NewItemLogEx(model.ItemParam{
 			Platform:     p.Platform,
@@ -711,7 +702,6 @@ func (this *BagMgr) AddItems(param *model.AddItemParam) (*BagInfo, bag.OpResultC
 			TypeId:       param.GainWay,
 			GameId:       param.GameId,
 			GameFreeId:   param.GameFreeId,
-			GameDif:      gamedif,
 			Cost:         param.Cost,
 			LogId:        param.LogId,
 			RoomConfigId: param.RoomConfigId,
@@ -775,15 +765,6 @@ func (this *BagMgr) AddItemsOffline(param *model.AddItemParam, callback func(err
 		return
 	}
 
-	gamedif := ""
-	plt := PlatformMgrSingleton.GetPlatform(param.Platform)
-	if plt != nil && param.GameFreeId > 0 {
-		gf := plt.GameConfig.GetGameConfig(int32(param.GameFreeId))
-		if gf != nil {
-			gamedif = gf.GetDbGameFree().GetGameDif()
-		}
-	}
-
 	// 玩家离线时
 	var findPlayer *model.PlayerBaseInfo
 	task.New(nil, task.CallableWrapper(func(o *basic.Object) interface{} {
@@ -812,7 +793,7 @@ func (this *BagMgr) AddItemsOffline(param *model.AddItemParam, callback func(err
 			return err
 		}
 		// 保存日志
-		if err := model.InsertItemLog(srvdata.GameItemMgr.GetItems(param.Platform), param, gamedif, true); err != nil {
+		if err := model.InsertItemLog(srvdata.GameItemMgr.GetItems(param.Platform), param, true); err != nil {
 			logger.Logger.Errorf("离线保存道具变更日志错误 %v", err)
 			return err
 		}