package svc import ( "github.com/globalsign/mgo" "github.com/globalsign/mgo/bson" "mongo.games.com/game/dbproxy/mongo" "mongo.games.com/game/model" "mongo.games.com/goserver/core/logger" "net/rpc" ) func DbBagChangeDollLogCollection(plt string) *mongo.Collection { s := mongo.MgoSessionMgrSington.GetPltMgoSession(plt, model.BagChangeDollLogDBName) if s != nil { dollRec, first := s.DB().C(model.BagChangeDollLogCollName) if first { dollRec.EnsureIndex(mgo.Index{Key: []string{"snid"}, Background: true, Sparse: true}) } return dollRec } return nil } type DbBagChangeDollLogSvc struct { } func (svc *DbBagChangeDollLogSvc) InsertDbBagChangeDollLog(args *model.DbBagChangeDollLogArgs, ret *bool) (err error) { clog := DbBagChangeDollLogCollection(args.Log.Platform) if clog == nil { return } logger.Logger.Trace("DbBagChangeDollLogSvc.InsertDbBagChangeDollLog") err = clog.Insert(args.Log) if err != nil { logger.Logger.Error("DbBagChangeDollLogSvc.InsertDbBagChangeDollLog error:", err) return } *ret = true return } func (svc *DbBagChangeDollLogSvc) GetDbBagChangeDollLog(args *model.DbBagChangeDollLogArgs, dollLog *[]*model.BagChangeDollLog) (err error) { clog := DbBagChangeDollLogCollection(args.Log.Platform) if clog == nil { logger.Logger.Error("GetDbBagChangeDollLog == nil") return nil } logger.Logger.Trace("DbBagChangeDollLogSvc.GetDbBagChangeDollLog") err = clog.Find(bson.M{"snid": args.Log.Snid}).All(dollLog) if err != nil { logger.Logger.Error("DbBagChangeDollLogSvc.GetDbBagChangeDollLog error:", err) return nil } return } func (svc *DbBagChangeDollLogSvc) UpdateDbShopState(args *model.DbBagChangeDollLogArgs, ret *bool) (err error) { clog := DbBagChangeDollLogCollection(args.Log.Platform) if clog == nil { logger.Logger.Error("UpdateDbShopState == nil") return nil } logger.Logger.Trace("DbBagChangeDollLogSvc.UpdateDbShopState") err = clog.UpdateId(args.Log.LogId, bson.M{"$set": bson.M{"state": args.Log.State}}) if err != nil { logger.Logger.Error("DbBagChangeDollLogSvc.UpdateDbShopState error:", err) return nil } *ret = true return } func init() { rpc.Register(new(DbBagChangeDollLogSvc)) }