dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// NormalCoinString 普通扭蛋字符串标识，数据库和redis
	NormalCoinString = "normal"

	// ColorfulCoinString 梦幻扭蛋字符串标识，数据库和redis
	ColorfulCoinString = "colorful"

	// WeekCoinString 周星扭蛋字符串标识，数据库和redis
	WeekCoinString = "week"

	// LplCoinString 周星扭蛋字符串标识，数据库和redis
	LplCoinString = "lpl"

	// BlessCoinString 祈福扭蛋字符串标识，数据库和redis
	BlessCoinString = "bless"
)
View Source 
const (

	// CapsulePrizeGift1Type 辣条
	CapsulePrizeGift1Type // 辣条
	// CapsulePrizeTitleType 头衔
	CapsulePrizeTitleType
	// CapsulePrizeStuff1Type 经验原石
	CapsulePrizeStuff1Type
	// CapsulePrizeStuff2Type 经验曜石
	CapsulePrizeStuff2Type
	// CapsulePrizeStuff3Type 贤者之石
	CapsulePrizeStuff3Type
	// CapsulePrizeSmallTvType 小电视
	CapsulePrizeSmallTvType
	// CapsulePrizeGuard3Type 舰长体验
	CapsulePrizeGuard3Type
	// CapsulePrizeGuard2Type 提督体验
	CapsulePrizeGuard2Type
	// CapsulePrizeGuard1Type 总督体验
	CapsulePrizeGuard1Type
)
View Source 
const (

	// CapsuleGiftTypeAll gift_type 为全部道具
	CapsuleGiftTypeAll
	// CapsuleGiftTypeGold gift_type 为金瓜子道具
	CapsuleGiftTypeGold
	// CapsuleGiftTypeSelected gift_type 为指定道具
	CapsuleGiftTypeSelected
)
View Source 
const BlessCoinId = 5

BlessCoinId 祈福抽奖券

View Source 
const CapsuleActionTrans = "trans"

CapsuleActionTrans 转换扭蛋币

View Source 
const ColorfulCoinId = 2

ColorfulCoinId 梦幻扭蛋id

View Source 
const IsBottomPool = 1

IsBottomPool 是否为保底奖池

View Source 
const LplCoinId = 4

LplCoinId 周星扭蛋id

View Source 
const NormalCoinId = 1

NormalCoinId 普通扭蛋id

View Source 
const WeekCoinId = 3

WeekCoinId 周星扭蛋id

Variables

View Source 
var (

	// ReprotConfig map
	ReprotConfig map[int64]string

	// CoinIdIntMap map
	CoinIdIntMap map[int64]string
	// PrizeNameMap map
	PrizeNameMap map[int64]string
)
View Source 
var (
	// UnLockGetWrong flag
	UnLockGetWrong = "UnLockGetWrong"
	// ErrUnLockGet error
	ErrUnLockGet = errors.New(UnLockGetWrong)
)
View Source 
var RcApi *rcApi.Client

RcApi liverpc reward-service api

Functions

func InitAPI 

func InitAPI()

InitAPI init all service APIs

Types

type CapsuleCoinConf 

type CapsuleCoinConf struct {
	Id          int64
	Title       string
	GiftType    int64
	ChangeNum   int64
	StartTime   int64
	EndTime     int64
	Status      int64
	GiftMap     map[int64]struct{}
	AreaMap     map[int64]struct{}
	PoolConf    *CapsulePoolConf
	AllPoolConf []*CapsulePoolConf
}

CapsuleCoinConf 扭蛋币配置

type CapsuleConf 

type CapsuleConf struct {
	CoinConfMap map[int64]*CapsuleCoinConf
	CacheTime   int64
	ChangeFlag  int64
	RwLock      sync.RWMutex
}

CapsuleConf 扭蛋全局配置

type CapsulePoolConf 

type CapsulePoolConf struct {
	Id                 int64
	CoinId             int64
	Title              string
	Rule               string
	StartTime, EndTime int64
	Status             int64
	IsBottom           int64
	PoolPrize          []*CapsulePoolPrize
}

CapsulePoolConf 奖池配置

type CapsulePoolPrize 

type CapsulePoolPrize struct {
	Id, PoolId, Type, Num, ObjectId, Expire           int64
	Name, WebImage, MobileImage, Description, JumpUrl string
	ProType                                           int64
	Chance                                            int64
	LoopNum, LimitNum, Weight                         int64
}

CapsulePoolPrize 奖池奖品

type Dao 

type Dao struct {
	// contains filtered or unexported fields
}

Dao dao

func New 

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) AddNotice 

func (d *Dao) AddNotice(ctx context.Context, uid, coinId, coinNum int64)

AddNotice 增加标记

func (*Dao) CheckLplFirstGift 

func (d *Dao) CheckLplFirstGift(ctx context.Context, uid, giftId int64) bool

CheckLplFirstGift 检测是否首次送礼

func (*Dao) Close 

func (d *Dao) Close()

Close close the resource.

func (*Dao) GetActiveColorPool 

func (d *Dao) GetActiveColorPool(ctx context.Context) (pool []*model.Pool, err error)

GetActiveColorPool 获取奖池

func (*Dao) GetCapsuleChangeFlag 

func (d *Dao) GetCapsuleChangeFlag(ctx context.Context) (randNum int64, err error)

GetCapsuleChangeFlag 获取扭蛋配置变化标记

func (*Dao) GetCapsuleChangeInfo 

func (d *Dao) GetCapsuleChangeInfo(ctx context.Context) (int64, int64)

GetCapsuleChangeInfo 获取扭蛋配置信息

func (*Dao) GetCapsuleConf 

func (d *Dao) GetCapsuleConf(ctx context.Context) (conf map[int64]*CapsuleCoinConf, err error)

GetCapsuleConf 获取扭蛋币配置

func (*Dao) GetCoin 

func (d *Dao) GetCoin(score int64, coinConf *CapsuleCoinConf) (coinNum int64)

GetCoin 获取扭蛋数量

func (*Dao) GetCoinConfigMap 

func (d *Dao) GetCoinConfigMap(ctx context.Context, coinIds []int64) (configMap map[int64][]*model.CoinConfig, err error)

GetCoinConfigMap 批量获取扭蛋币

func (*Dao) GetCoinMap 

func (d *Dao) GetCoinMap(ctx context.Context) (coinMap map[int64]*model.Coin, err error)

GetCoinMap 批量获取扭蛋币

func (*Dao) GetCouponData 

func (d *Dao) GetCouponData(ctx context.Context) (extraData []*model.ExtraData, err error)

GetCouponData 添加数据

func (*Dao) GetExtraDataByIds 

func (d *Dao) GetExtraDataByIds(ctx context.Context, start, end int64) (extraData []*model.ExtraData, err error)

GetExtraDataByIds 获取数据

func (*Dao) GetExtraDataByTime 

func (d *Dao) GetExtraDataByTime(ctx context.Context, startTime, endTime string) (extraData []*model.ExtraData, err error)

GetExtraDataByTime 获取数据

func (*Dao) GetPoolMap 

func (d *Dao) GetPoolMap(ctx context.Context, coinIds []int64) (poolMap map[int64][]*model.Pool, err error)

GetPoolMap 批量奖池信息

func (*Dao) GetPoolPrizeMap 

func (d *Dao) GetPoolPrizeMap(ctx context.Context, poolIds []int64) (poolPrizeMap map[int64][]*model.PoolPrize, err error)

GetPoolPrizeMap 批量奖池奖品

func (*Dao) GetTransNum 

func (d *Dao) GetTransNum(ctx context.Context, coinId int64) (changeNum int64, err error)

GetTransNum 获取扭蛋币数量

func (*Dao) GetUserCapsuleInfo 

func (d *Dao) GetUserCapsuleInfo(c context.Context, uid int64) (coinMap map[int64]int64, err error)

GetUserCapsuleInfo 获取扭蛋币积分

func (*Dao) GetUserInfo 

func (d *Dao) GetUserInfo(c context.Context, uid, coinId int64) (coinMap map[int64]int64, err error)

GetUserInfo 获取扭蛋币详情

func (*Dao) GetUserInfoById 

func (d *Dao) GetUserInfoById(ctx context.Context, table string, start int64, end int64) (infos [][4]int64, err error)

GetUserInfoById 获取扭蛋币信息

func (*Dao) GetUserInfoByUids 

func (d *Dao) GetUserInfoByUids(ctx context.Context, table string, uids []int64) (infos map[int64][2]int64, err error)

GetUserInfoByUids 获取扭蛋币信息

func (*Dao) Lock 

func (d *Dao) Lock(ctx context.Context, realKey string, ttl int, retry int, retryDelay int) (gotLock bool, lockValue string, err error)

Lock .

func (*Dao) Ping 

func (d *Dao) Ping(ctx context.Context) error

Ping dao ping

func (*Dao) RelaodCapsuleConfig 

func (d *Dao) RelaodCapsuleConfig(ctx context.Context, changeFlag int64) (conf map[int64]*CapsuleCoinConf, err error)

RelaodCapsuleConfig 重新加载扭蛋配置

func (*Dao) ReportCapsuleChange 

func (d *Dao) ReportCapsuleChange(ctx context.Context, coinId, uid, score int64, action, platform string, pInfo map[int64]int64, coinConf *CapsuleCoinConf) bool

ReportCapsuleChange 通知扭蛋积分变换

func (*Dao) TransCapsule 

func (d *Dao) TransCapsule(ctx context.Context, table string, colorChangeNum int64, normalChangeNum int64) (err error)

TransCapsule 转换扭蛋币

func (*Dao) UnLock 

func (d *Dao) UnLock(ctx context.Context, realKey string, lockValue string) (err error)

UnLock .

func (*Dao) UpdateCapsule 

func (d *Dao) UpdateCapsule(ctx context.Context, uid, coinId, score int64, action, platform string, coinConf *CapsuleCoinConf) (affect int64, err error)

UpdateCapsule 更新扭蛋币积分

func (*Dao) UpdateExtraById 

func (d *Dao) UpdateExtraById(ctx context.Context, id int64, itemValue int64, itemExtra string) (status bool, err error)

UpdateExtraById 更新数据

func (*Dao) UpdateExtraMtimeById 

func (d *Dao) UpdateExtraMtimeById(ctx context.Context, id int64, mtime string) (status bool, err error)

UpdateExtraMtimeById 更新时间数据

func (*Dao) UpdateExtraValueById 

func (d *Dao) UpdateExtraValueById(ctx context.Context, id int64, itemValue int64) (status bool, err error)

UpdateExtraValueById 更新数据

func (*Dao) UpdateScore 

func (d *Dao) UpdateScore(ctx context.Context, uid, coinId, score int64, action, platform string, userInfo map[int64]int64, coinConf *CapsuleCoinConf) (affect int64, err error)

UpdateScore 更新扭蛋币积分

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.