Skip to content

H
hilo-group
Commit 5f47802c authored by chenweijian's avatar chenweijian
Browse files
Options

group support

parent 07123285
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 4 deletions
cron/gift_cron/send_gift_redis.go
View file @ 5f47802c
...@@ -101,7 +101,9 @@ func groupSupportAddConsume(model *domain.Model, sendGiftEvent *gift_ev.SendGift ...@@ -101,7 +101,9 @@ func groupSupportAddConsume(model *domain.Model, sendGiftEvent *gift_ev.SendGift
//if time.Now().Unix() <= 1692964800 { // cwj---- //if time.Now().Unix() <= 1692964800 { // cwj----
// return nil // return nil
//} //}
model.Log.Infof("groupSupportAddConsume UserId:%d, sendGiftEvent:%+v", sendGiftEvent.SendUserId, sendGiftEvent)
if sendGiftEvent.SceneType != gift_e.GroupSceneType || sendGiftEvent.SceneUid == "" { if sendGiftEvent.SceneType != gift_e.GroupSceneType || sendGiftEvent.SceneUid == "" {
model.Log.Infof("groupSupportAddConsume UserId:%d, sendGiftEvent:%+v", sendGiftEvent.SendUserId, sendGiftEvent)
return return
} }
_, _, period := group_m.GetSupportLevelTime(time.Now()) _, _, period := group_m.GetSupportLevelTime(time.Now())
...@@ -110,23 +112,23 @@ func groupSupportAddConsume(model *domain.Model, sendGiftEvent *gift_ev.SendGift ...@@ -110,23 +112,23 @@ func groupSupportAddConsume(model *domain.Model, sendGiftEvent *gift_ev.SendGift
keyDiamond := rediskey.GetGroupSupportConsumeSummary(period) keyDiamond := rediskey.GetGroupSupportConsumeSummary(period)
_, err := model.RedisCluster.ZIncrBy(context.Background(), keyDiamond, float64(diamond), sendGiftEvent.SceneUid).Result() _, err := model.RedisCluster.ZIncrBy(context.Background(), keyDiamond, float64(diamond), sendGiftEvent.SceneUid).Result()
if err != nil { if err != nil {
model.Log.Errorf("AddSendGiftEventAsync groupSupport key:%s, val:%d, member:%s, err:%v", model.Log.Errorf("groupSupportAddConsume key:%s, val:%d, member:%s, err:%v",
keyDiamond, diamond, sendGiftEvent.SceneUid, err) keyDiamond, diamond, sendGiftEvent.SceneUid, err)
} }
err = redisCli.SetExpire(model.RedisCluster, keyDiamond, time.Hour*24*14) // 保留两周 err = redisCli.SetExpire(model.RedisCluster, keyDiamond, time.Hour*24*14) // 保留两周
if err != nil { if err != nil {
model.Log.Errorf("AddSendGiftEventAsync groupSupport key:%s, val:%d, member:%s, err:%v", model.Log.Errorf("groupSupportAddConsume key:%s, val:%d, member:%s, err:%v",
keyDiamond, diamond, sendGiftEvent.SceneUid, err) keyDiamond, diamond, sendGiftEvent.SceneUid, err)
} }
// 支持者数量 // 支持者数量
keySupportNum := rediskey.GetGroupSupportCountSupporter(period, sendGiftEvent.SceneUid) keySupportNum := rediskey.GetGroupSupportCountSupporter(period, sendGiftEvent.SceneUid)
err = model.RedisCluster.SAdd(context.Background(), keySupportNum, sendGiftEvent.SendUserId).Err() err = model.RedisCluster.SAdd(context.Background(), keySupportNum, sendGiftEvent.SendUserId).Err()
if err != nil { if err != nil {
model.Log.Errorf("AddSendGiftEventAsync groupSupport key:%s, UserId:%d, err:%v", keySupportNum, sendGiftEvent.SendUserId, err) model.Log.Errorf("groupSupportAddConsume key:%s, UserId:%d, err:%v", keySupportNum, sendGiftEvent.SendUserId, err)
} }
err = redisCli.SetExpire(model.RedisCluster, keySupportNum, time.Hour*24*14) // 保留两周 err = redisCli.SetExpire(model.RedisCluster, keySupportNum, time.Hour*24*14) // 保留两周
if err != nil { if err != nil {
model.Log.Errorf("AddSendGiftEventAsync groupSupport key:%s, UserId:%d, err:%v", keySupportNum, sendGiftEvent.SendUserId, err) model.Log.Errorf("groupSupportAddConsume key:%s, UserId:%d, err:%v", keySupportNum, sendGiftEvent.SendUserId, err)
} }
return return
} }
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