群组优化

cron/gift_cron/send_gift_redis.go

@@ -105,7 +105,7 @@ func groupSupportAddConsume(model *domain.Model, sendGiftEvent *gift_ev.SendGift
 	}
 	_, _, period := group_m.GetSupportLevelTime(time.Now())
 	// 钻石数
-	diamond := sendGiftEvent.GiftN * sendGiftEvent.ResGift.DiamondNum
+	diamond := sendGiftEvent.GiftN * sendGiftEvent.ResGift.DiamondNum * mysql.Num(len(sendGiftEvent.ReceiveUserIds))
 	keyDiamond := rediskey.GetGroupSupportConsumeSummary(period)
 	_, err := model.RedisCluster.ZIncrBy(context.Background(), keyDiamond, float64(diamond), sendGiftEvent.SceneUid).Result()
 	if err != nil {