81 lines
1.9 KiB
Go
81 lines
1.9 KiB
Go
package model
|
|
|
|
import (
|
|
"github.com/globalsign/mgo"
|
|
"github.com/globalsign/mgo/bson"
|
|
"time"
|
|
)
|
|
|
|
var (
|
|
PrivateSceneLogDBName = "log"
|
|
PrivateSceneLogCollName = "log_privatescene"
|
|
)
|
|
|
|
type PrivateSceneLog struct {
|
|
LogId bson.ObjectId `bson:"_id"`
|
|
SnId int32 // 玩家id
|
|
Platform string // 平台名称
|
|
Channel string // 渠道名称
|
|
Promoter string // 推广员
|
|
PackageTag string // 推广包标识
|
|
GameFreeId int32 // 游戏id
|
|
SceneId int32 // 房间id
|
|
CreateFee int32 // 房费
|
|
CreateTime time.Time // 创建时间
|
|
DestroyTime time.Time // 销毁时间
|
|
}
|
|
|
|
func NewPrivateSceneLog() *PrivateSceneLog {
|
|
return &PrivateSceneLog{
|
|
LogId: bson.NewObjectId(),
|
|
}
|
|
}
|
|
|
|
func InsertPrivateSceneLog(log *PrivateSceneLog) error {
|
|
if rpcCli == nil {
|
|
return ErrRPClientNoConn
|
|
}
|
|
|
|
var ret bool
|
|
return rpcCli.CallWithTimeout("PrivateSceneLogSvc.InsertPrivateSceneLog", log, &ret, time.Second*30)
|
|
}
|
|
|
|
type GetPrivateSceneLogBySnIdArgs struct {
|
|
Plt string
|
|
SnId int32
|
|
Limit int
|
|
}
|
|
|
|
func GetPrivateSceneLogBySnId(plt string, snid int32, limit int) ([]*PrivateSceneLog, error) {
|
|
if rpcCli == nil {
|
|
return nil, ErrRPClientNoConn
|
|
}
|
|
args := &GetPrivateSceneLogBySnIdArgs{
|
|
Plt: plt,
|
|
SnId: snid,
|
|
Limit: limit,
|
|
}
|
|
var logs []*PrivateSceneLog
|
|
err := rpcCli.CallWithTimeout("PrivateSceneLogSvc.GetPrivateSceneLogBySnId", args, &logs, time.Second*30)
|
|
return logs, err
|
|
}
|
|
|
|
type RemovePrivateSceneLogsArgs struct {
|
|
Plt string
|
|
Ts time.Time
|
|
}
|
|
|
|
func RemovePrivateSceneLogs(plt string, ts time.Time) (*mgo.ChangeInfo, error) {
|
|
if rpcCli == nil {
|
|
return nil, ErrRPClientNoConn
|
|
}
|
|
|
|
args := &RemovePrivateSceneLogsArgs{
|
|
Plt: plt,
|
|
Ts: ts,
|
|
}
|
|
var ret *mgo.ChangeInfo
|
|
err := rpcCli.CallWithTimeout("PrivateSceneLogSvc.InsertPrivateSceneLog", args, &ret, time.Second*30)
|
|
return ret, err
|
|
}
|