1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162 |
- package like
- import (
- "context"
- "time"
- "go-common/app/job/main/activity/conf"
- "go-common/library/cache/memcache"
- "go-common/library/cache/redis"
- "go-common/library/database/elastic"
- "go-common/library/database/sql"
- "go-common/library/net/http/blademaster"
- )
- const _activity = "activity"
- // Dao dao
- type Dao struct {
- db *sql.DB
- subjectStmt *sql.Stmt
- inOnlineLog *sql.Stmt
- mcLike *memcache.Pool
- mcLikeExpire int32
- redis *redis.Pool
- redisExpire int32
- httpClient *blademaster.Client
- es *elastic.Elastic
- setObjStatURL string
- setViewRankURL string
- setLikeContentURL string
- addLotteryTimesURL string
- }
- // New init
- func New(c *conf.Config) (d *Dao) {
- d = &Dao{
- db: sql.NewMySQL(c.MySQL.Like),
- mcLike: memcache.NewPool(c.Memcache.Like),
- mcLikeExpire: int32(time.Duration(c.Memcache.LikeExpire) / time.Second),
- redis: redis.NewPool(c.Redis.Config),
- redisExpire: int32(time.Duration(c.Redis.Expire) / time.Second),
- httpClient: blademaster.NewClient(c.HTTPClient),
- es: elastic.NewElastic(c.Elastic),
- setObjStatURL: c.Host.APICo + _setObjStatURI,
- setViewRankURL: c.Host.APICo + _setViewRankURI,
- setLikeContentURL: c.Host.APICo + _setLikeContentURI,
- addLotteryTimesURL: c.Host.Activity + _addLotteryTimesURI,
- }
- d.subjectStmt = d.db.Prepared(_selSubjectSQL)
- d.inOnlineLog = d.db.Prepared(_inOnlineLogSQL)
- return
- }
- // Close close
- func (d *Dao) Close() {
- d.db.Close()
- }
- // Ping ping
- func (d *Dao) Ping(c context.Context) error {
- return d.db.Ping(c)
- }
|