123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177 |
- package dao
- import (
- "context"
- "fmt"
- "strconv"
- "go-common/library/cache/memcache"
- "go-common/library/log"
- "go-common/library/stat/prom"
- )
- var _ _mc
- func (d *Dao) CacheUserCoin(c context.Context, id int64) (res float64, err error) {
- conn := d.mc.Get(c)
- defer conn.Close()
- key := countKey(id)
- reply, err := conn.Get(key)
- if err != nil {
- if err == memcache.ErrNotFound {
- err = nil
- return
- }
- prom.BusinessErrCount.Incr("mc:CacheUserCoin")
- log.Errorv(c, log.KV("CacheUserCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- var v string
- err = conn.Scan(reply, &v)
- if err != nil {
- prom.BusinessErrCount.Incr("mc:CacheUserCoin")
- log.Errorv(c, log.KV("CacheUserCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- r, err := strconv.ParseFloat(v, 64)
- if err != nil {
- prom.BusinessErrCount.Incr("mc:CacheUserCoin")
- log.Errorv(c, log.KV("CacheUserCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- res = float64(r)
- return
- }
- func (d *Dao) AddCacheUserCoin(c context.Context, id int64, val float64) (err error) {
- conn := d.mc.Get(c)
- defer conn.Close()
- key := countKey(id)
- bs := []byte(strconv.FormatFloat(val, 'E', -1, 64))
- item := &memcache.Item{Key: key, Value: bs, Expiration: d.mcExpire, Flags: memcache.FlagRAW}
- if err = conn.Set(item); err != nil {
- prom.BusinessErrCount.Incr("mc:AddCacheUserCoin")
- log.Errorv(c, log.KV("AddCacheUserCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- return
- }
- func (d *Dao) CacheItemCoin(c context.Context, id int64, tp int64) (res int64, err error) {
- conn := d.mc.Get(c)
- defer conn.Close()
- key := itemCoinKey(id, tp)
- reply, err := conn.Get(key)
- if err != nil {
- if err == memcache.ErrNotFound {
- err = nil
- return
- }
- prom.BusinessErrCount.Incr("mc:CacheItemCoin")
- log.Errorv(c, log.KV("CacheItemCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- var v string
- err = conn.Scan(reply, &v)
- if err != nil {
- prom.BusinessErrCount.Incr("mc:CacheItemCoin")
- log.Errorv(c, log.KV("CacheItemCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- r, err := strconv.ParseInt(v, 10, 64)
- if err != nil {
- prom.BusinessErrCount.Incr("mc:CacheItemCoin")
- log.Errorv(c, log.KV("CacheItemCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- res = int64(r)
- return
- }
- func (d *Dao) AddCacheItemCoin(c context.Context, id int64, val int64, tp int64) (err error) {
- conn := d.mc.Get(c)
- defer conn.Close()
- key := itemCoinKey(id, tp)
- bs := []byte(strconv.FormatInt(int64(val), 10))
- item := &memcache.Item{Key: key, Value: bs, Expiration: d.mcExpire, Flags: memcache.FlagRAW}
- if err = conn.Set(item); err != nil {
- prom.BusinessErrCount.Incr("mc:AddCacheItemCoin")
- log.Errorv(c, log.KV("AddCacheItemCoin", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- return
- }
- func (d *Dao) Exp(c context.Context, id int64) (res int64, err error) {
- conn := d.mc.Get(c)
- defer conn.Close()
- key := expKey(id)
- reply, err := conn.Get(key)
- if err != nil {
- if err == memcache.ErrNotFound {
- err = nil
- return
- }
- prom.BusinessErrCount.Incr("mc:Exp")
- log.Errorv(c, log.KV("Exp", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- var v string
- err = conn.Scan(reply, &v)
- if err != nil {
- prom.BusinessErrCount.Incr("mc:Exp")
- log.Errorv(c, log.KV("Exp", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- r, err := strconv.ParseInt(v, 10, 64)
- if err != nil {
- prom.BusinessErrCount.Incr("mc:Exp")
- log.Errorv(c, log.KV("Exp", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- res = int64(r)
- return
- }
- func (d *Dao) SetTodayExpCache(c context.Context, id int64, val int64) (err error) {
- conn := d.mc.Get(c)
- defer conn.Close()
- key := expKey(id)
- bs := []byte(strconv.FormatInt(int64(val), 10))
- item := &memcache.Item{Key: key, Value: bs, Expiration: d.expireExp, Flags: memcache.FlagRAW}
- if err = conn.Set(item); err != nil {
- prom.BusinessErrCount.Incr("mc:SetTodayExpCache")
- log.Errorv(c, log.KV("SetTodayExpCache", fmt.Sprintf("%+v", err)), log.KV("key", key))
- return
- }
- return
- }
|