|
@@ -24,7 +24,7 @@ import ( |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
// SettlementGiveActivityCoin 结算观看激励广告得到蛋蛋积分 |
|
|
// SettlementGiveActivityCoin 结算观看激励广告得到蛋蛋积分 |
|
|
func SettlementGiveActivityCoin(engine *xorm.Engine, user model.User, ecpm string, ch *rabbit.Channel) (err error) { |
|
|
|
|
|
|
|
|
func SettlementGiveActivityCoin(engine *xorm.Engine, user model.User, ecpm string, ch *rabbit.Channel) (rewardValue float64, err error) { |
|
|
uid := user.Id |
|
|
uid := user.Id |
|
|
now := time.Now() |
|
|
now := time.Now() |
|
|
|
|
|
|
|
@@ -64,7 +64,7 @@ func SettlementGiveActivityCoin(engine *xorm.Engine, user model.User, ecpm strin |
|
|
|
|
|
|
|
|
go dealEcpm(user, ecpm, ch) //TODO::协程处理ecpm的变化 |
|
|
go dealEcpm(user, ecpm, ch) //TODO::协程处理ecpm的变化 |
|
|
|
|
|
|
|
|
var rewardValue float64 //TODO::奖励多少个活跃积分(根据ecpm, 新用户机制, 蛋蛋分机制) |
|
|
|
|
|
|
|
|
//TODO::奖励多少个活跃积分(根据ecpm, 新用户机制, 蛋蛋分机制) |
|
|
redisConn := cache.GetPool().Get() |
|
|
redisConn := cache.GetPool().Get() |
|
|
sysCfgDb := implement.NewSysCfgDb(engine, redisConn) |
|
|
sysCfgDb := implement.NewSysCfgDb(engine, redisConn) |
|
|
videoRewardUnitPrice := sysCfgDb.SysCfgGetWithDb(enum.VideoRewardUnitPrice) |
|
|
videoRewardUnitPrice := sysCfgDb.SysCfgGetWithDb(enum.VideoRewardUnitPrice) |
|
|