39 lines
1.0 KiB
Go
39 lines
1.0 KiB
Go
package logic
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/oylshe1314/framework/client/db"
|
|
"github.com/oylshe1314/framework/log"
|
|
"github.com/oylshe1314/framework/server"
|
|
"github.com/oylshe1314/framework/util"
|
|
)
|
|
|
|
type EventManager struct {
|
|
logger log.Logger
|
|
server server.Server
|
|
|
|
mongoClient *db.MongoClient
|
|
}
|
|
|
|
func NewEventManager(svr server.Server, mongoClient *db.MongoClient) *EventManager {
|
|
return &EventManager{logger: svr.Logger(), server: svr, mongoClient: mongoClient}
|
|
}
|
|
|
|
func (this *EventManager) Init() (err error) {
|
|
return nil
|
|
}
|
|
|
|
func (this *EventManager) Close() error {
|
|
return nil
|
|
}
|
|
|
|
func (this *EventManager) LogServerEvent(tableName string, log any) error {
|
|
_, err := this.mongoClient.Collection(fmt.Sprintf("%s_%s", tableName, util.TimeFormat("200601"))).InsertOne(this.mongoClient.Context(), log)
|
|
return err
|
|
}
|
|
|
|
func (this *EventManager) LogPlayerEvent(tableName string, log any) error {
|
|
_, err := this.mongoClient.Collection(fmt.Sprintf("%s_%s", tableName, util.TimeFormat("200601"))).InsertOne(this.mongoClient.Context(), log)
|
|
return err
|
|
}
|