Commit 8378e971 authored by vicotor's avatar vicotor

fix bug

parent 12edaaac
...@@ -142,7 +142,7 @@ func (c *CacheData) checkQueryForFreeTimes(uid int64, userLevel *model.UserLevel ...@@ -142,7 +142,7 @@ func (c *CacheData) checkQueryForFreeTimes(uid int64, userLevel *model.UserLevel
taskUserMonthCmd := pip.Get(c.ctx, taskUserMonth) taskUserMonthCmd := pip.Get(c.ctx, taskUserMonth)
_, err := pip.Exec(c.ctx) _, err := pip.Exec(c.ctx)
if err != nil { if err != nil && err != goredislib.Nil {
return false, err return false, err
} }
...@@ -196,13 +196,14 @@ func (c *CacheData) checkQueryForFreeTimes(uid int64, userLevel *model.UserLevel ...@@ -196,13 +196,14 @@ func (c *CacheData) checkQueryForFreeTimes(uid int64, userLevel *model.UserLevel
} }
func (c *CacheData) checkQueryForCost(uid int64, user *UserInfo, userLevel *model.UserLevel, task *model.TaskType) (bool, error) { func (c *CacheData) checkQueryForCost(uid int64, user *UserInfo, userLevel *model.UserLevel, task *model.TaskType) (bool, error) {
chargeKey := fmt.Sprintf("charge-%d:", uid) chargeKey := fmt.Sprintf("%s%d", USER_INFO_CHARGE_KEY, uid)
balKey := fmt.Sprintf("bal-%d:", uid) balKey := fmt.Sprintf("%s%d", USER_INFO_BALANCE_KEY, uid)
pip := c.rdb.Pipeline() pip := c.rdb.Pipeline()
chargeCmd := pip.Get(c.ctx, chargeKey) chargeCmd := pip.Get(c.ctx, chargeKey)
balCmd := pip.Get(c.ctx, balKey) balCmd := pip.Get(c.ctx, balKey)
_, err := pip.Exec(c.ctx) _, err := pip.Exec(c.ctx)
if err != nil {
if err != nil && err != goredislib.Nil {
return false, err return false, err
} }
var ( var (
...@@ -271,15 +272,15 @@ func (c *CacheData) costFreeTime(uid int64, user *UserInfo, userLevel *model.Use ...@@ -271,15 +272,15 @@ func (c *CacheData) costFreeTime(uid int64, user *UserInfo, userLevel *model.Use
func (c *CacheData) costCharge(uid int64, fee int64) error { func (c *CacheData) costCharge(uid int64, fee int64) error {
// todo: just incr charge. // todo: just incr charge.
chargeKey := fmt.Sprintf("charge-%d:", uid) chargeKey := fmt.Sprintf("%s%d", USER_INFO_CHARGE_KEY, uid)
_, err := c.rdb.IncrBy(c.ctx, chargeKey, fee).Result() _, err := c.rdb.IncrBy(c.ctx, chargeKey, fee).Result()
return err return err
} }
func (c *CacheData) costForFee(uid int64, fee int64) error { func (c *CacheData) costForFee(uid int64, fee int64) error {
// todo: decr charge and balance. // todo: decr charge and balance.
chargeKey := fmt.Sprintf("charge-%d:", uid) chargeKey := fmt.Sprintf("%s%d", USER_INFO_CHARGE_KEY, uid)
balKey := fmt.Sprintf("bal-%d:", uid) balKey := fmt.Sprintf("%s%d", USER_INFO_BALANCE_KEY, uid)
if fee > 0 { if fee > 0 {
txp := c.rdb.TxPipeline() txp := c.rdb.TxPipeline()
txp.DecrBy(c.ctx, chargeKey, fee) txp.DecrBy(c.ctx, chargeKey, fee)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment