DB

Oct 14, 2020

Changes in this version

+ var ActivityMap map[uint32][]*ActivityDBData

+ var ActivityObj *ActivityObject

+ var MaxId uint32

+ func Initialize()

+ func LoadActivityDetails(idx uint32, datas *[]*proto.ST_ActivityContent_PB)

+ func LoadActivityScores(activityIdx uint32, serial uint32, res *[]*proto.ST_ActivityScore_User)

+ func UpsertActivityData(idx uint32, doc interface{}) error

+ func UpsertActivityDetailData(_id string, idx, contentID uint32, doc interface{}) error

+ func UpsertActivityScoreNormal(_id string, idx uint32, uid uint64, doc interface{}) error

+ type ActivityDBData struct

+ Data *proto.ST_Activity_PB

+ IDx uint32

+ type ActivityDetailDBData struct

+ ContentID uint32

+ Detail *proto.ST_ActivityContent_PB

+ ID uint32

+ IDx uint32

+ type ActivityDetailDocument struct

+ ContentID uint32

+ Detail []byte

+ ID string

+ IDx uint32

+ type ActivityDetailObject struct

+ ActivityDetailMap map[string]*proto.ST_ActivityContent_PB

+ SendTopList bool

+ var ActicityDetailObj *ActivityDetailObject

+ func (o *ActivityDetailObject) GetTableName() string

+ func (o *ActivityDetailObject) Init(dbName, tableName string)

+ func (o *ActivityDetailObject) LoadActivityDetail(id uint32)

+ func (this *ActivityDetailObject) ClearAll()

+ func (this *ActivityDetailObject) GroupRange(onlyRead bool, id int, class int, cid int, ...)

+ func (this *ActivityDetailObject) NewGroup(d *proto.ST_ActivityContent_PB)

+ func (this *ActivityDetailObject) SaveTipslistDB()

+ type ActivityDocument struct

+ Activity []byte

+ ID uint32

+ type ActivityObject struct

+ ActivityDetailMap map[uint32]*proto.ST_Activity_PB

+ func (o *ActivityObject) GetTableName() string

+ func (o *ActivityObject) Init(dbName, tableName string)

+ func (o *ActivityObject) RemoveActivityByID(id uint32) error

+ func (this *ActivityObject) Find(onlyRead bool, ServerID, id uint32, ...)

+ func (this *ActivityObject) FindIgnoreServerid(onlyRead bool, id uint32, callback func(data *proto.ST_Activity_PB) bool)

+ func (this *ActivityObject) ForEach1(callback func(document *ActivityDocument))

+ func (this *ActivityObject) LoadAllActivities() error

+ func (this *ActivityObject) New(ServerID, id uint32, StagetEndTime uint64, time string) *proto.ST_Activity_PB

+ func (this *ActivityObject) Range(onlyRead bool, callback func(data *proto.ST_Activity_PB) bool)

+ func (this *ActivityObject) Save()

+ type NormalScoreDBData struct

+ ContentID uint32

+ IDx uint32

+ ScoreData *proto.ST_ActivityScore_PB

+ SerialID uint32

+ UserID uint64

+ type NormalScoreDocument struct

+ ActivityIdx uint32

+ ContentID uint32

+ ID string

+ ScoreData []byte

+ SerialID uint32

+ UserID uint64

+ type ScoreNormalObject struct

+ var ScoreNormalObj *ScoreNormalObject

+ func (o *ScoreNormalObject) DeleteDatasNotSerial(idx, serial uint32)

+ func (o *ScoreNormalObject) GetTableName() string

+ func (o *ScoreNormalObject) Init(dbName, tableName string)

+ func (o *ScoreNormalObject) RemoveActivityScoreById(id uint32) error