105 lines
3.1 KiB
Go
105 lines
3.1 KiB
Go
package task
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"go.mongodb.org/mongo-driver/bson"
|
|
"go.mongodb.org/mongo-driver/mongo"
|
|
"go.mongodb.org/mongo-driver/mongo/options"
|
|
"mongo.games.com/game/common"
|
|
mongomodel "mongo.games.com/game/statistics/modelmongo"
|
|
"mongo.games.com/goserver/core/logger"
|
|
mymongo "mongo.games.com/goserver/core/mongox"
|
|
)
|
|
|
|
// 新用户平均游戏时长
|
|
|
|
// 返回 总游戏时长，总局数，错误
|
|
func NewPlayerGameTime(plt string, ids []int, startTime, endTime string, gamefreeid int) (int, int, error) {
|
|
s, e := common.StrRFC3339TimeToTime(startTime), common.StrRFC3339TimeToTime(endTime)
|
|
c, err := mymongo.GetLogCollection(plt, mongomodel.LogGamePlayerListLog)
|
|
if err != nil {
|
|
return 0, 0, err
|
|
}
|
|
|
|
c2, err := mymongo.GetLogCollection(plt, "log_gamedetailed")
|
|
if err != nil {
|
|
return 0, 0, err
|
|
}
|
|
|
|
var ret int
|
|
var total int
|
|
for _, v := range ids {
|
|
// 查询玩家游戏时长
|
|
where := bson.M{"snid": v, "time": bson.M{"$gte": s, "$lt": e}}
|
|
if gamefreeid > 0 {
|
|
where["gamefreeid"] = gamefreeid
|
|
}
|
|
cur, err := c.Find(context.TODO(), where, options.Find().SetProjection(bson.M{"gamedetailedlogid": 1}))
|
|
if err != nil {
|
|
logger.Logger.Errorf("find player gamedetailedlogid get err: %v", err)
|
|
return 0, 0, err
|
|
}
|
|
for cur.TryNext(context.TODO()) {
|
|
var vv struct{ Gamedetailedlogid string }
|
|
if err = cur.Decode(&vv); err != nil {
|
|
logger.Logger.Errorf("find player gamedetailedlogid decode err: %v", err)
|
|
cur.Close(context.Background())
|
|
return 0, 0, err
|
|
}
|
|
// 查询游戏时长
|
|
var res2 struct{ Gametiming int }
|
|
r := c2.FindOne(context.TODO(), bson.M{"logid": vv.Gamedetailedlogid}, options.FindOne().SetProjection(bson.M{"gametiming": 1}))
|
|
if r.Err() != nil && !errors.Is(r.Err(), mongo.ErrNoDocuments) {
|
|
logger.Logger.Errorf("find game time get err: %v", err)
|
|
cur.Close(context.Background())
|
|
return 0, 0, err
|
|
}
|
|
if err := r.Decode(&res2); err != nil {
|
|
logger.Logger.Errorf("find game time decode err: %v", err)
|
|
cur.Close(context.Background())
|
|
return 0, 0, err
|
|
}
|
|
ret += res2.Gametiming
|
|
total++
|
|
}
|
|
cur.Close(context.Background())
|
|
}
|
|
|
|
return ret, total, nil
|
|
}
|
|
|
|
// NewPlayerGameTimeAvg 新用户平均游戏时长
|
|
// 新用户平均游戏时长(不算大厅时间)：当天注册的玩家在房间中的总时长/当天注册总人数
|
|
// 返回 参与人数，游戏时长
|
|
func NewPlayerGameTimeAvg(plt string, startTime, endTime string, gamefreeid int) (int, int, error) {
|
|
s, e := common.StrRFC3339TimeToTime(startTime), common.StrRFC3339TimeToTime(endTime)
|
|
if s.IsZero() || e.IsZero() {
|
|
return 0, 0, fmt.Errorf("time format error")
|
|
}
|
|
ids, err := GetNewPayerIds(plt, startTime, endTime)
|
|
if err != nil {
|
|
return 0, 0, err
|
|
}
|
|
if len(ids) == 0 {
|
|
return 0, 0, nil
|
|
}
|
|
a, _, err := NewPlayerGameTime(plt, ids, startTime, endTime, gamefreeid)
|
|
if err != nil {
|
|
return 0, 0, err
|
|
}
|
|
if len(ids) == 0 {
|
|
return 0, 0, nil
|
|
}
|
|
|
|
b, err := PlayingGameCount(plt, ids, startTime, endTime, gamefreeid)
|
|
if err != nil {
|
|
return 0, 0, err
|
|
}
|
|
if b == 0 {
|
|
return 0, 0, nil
|
|
}
|
|
return b, a, err
|
|
}
|