message/handler/activity/jyActivityOther.go

package activity

import (
	dataUtil "app.yhyue.com/moapp/jybase/date"
	"app.yhyue.com/moapp/jybase/redis"
	"app.yhyue.com/moapp/message/handler/award"
	"fmt"
	"github.com/gogf/gf/v2/os/gcfg"
	"github.com/gogf/gf/v2/os/gctx"
	"time"
)

// ShareFinish 分享完成
func (BP *JyActivity) ShareFinish(userId string) error {
	if _, inActivity, _ := BP.InActivity(); !inActivity {
		return fmt.Errorf("不在活动时间内")
	}
	if redis.Put(BidderPlanRedis, fmt.Sprintf(BidderPlanShare, userId), 1, BP.cacheLong()) != true {
		return fmt.Errorf("存储异常")
	}
	return nil
}

// GetDailyBoonDetail 查询领取情况及剩余
// has 是否已经领取
// todayBalance 今日余额
// err 异常
func (BP *JyActivity) GetDailyBoonDetail(userId string) (has bool, todayBalance int, err error) {
	if preHeatTime, _, _ := BP.InActivity(); !preHeatTime {
		err = fmt.Errorf("不在预热活动时间内")
		return
	}
	//查询是否领取
	hasKey := fmt.Sprintf(BidderPlanHasDailyBoonKey, userId)
	has = redis.GetInt(BidderPlanRedis, hasKey) >= 1
	//查询剩余
	todaySumKey := fmt.Sprintf(BidderPlanDailyBoonKey, time.Now().Format(dataUtil.Date_yyyyMMdd))
	todayBalance = gcfg.Instance().MustGet(gctx.New(), "jyactivity.dailyBoon.reward.limit", 500).Int() - redis.GetInt(BidderPlanRedis, todaySumKey)
	if todayBalance < 0 {
		todayBalance = 0
	}
	return
}

// GetDailyBoonSVip 每日限量超级订阅领取
func (BP *JyActivity) GetDailyBoonSVip(userId string) (err error) {
	var has bool = false
	var todayBalance int = -1

	var startTime time.Time
	now := time.Now()
	startTime, err = time.ParseInLocation(dataUtil.Date_Full_Layout, fmt.Sprintf("%s %s", now.Format(dataUtil.Date_Short_Layout), BP.DailyClock), time.Local)
	if err != nil {
		err = fmt.Errorf("时间格式异常")
		return
	}
	if !now.After(startTime) {
		err = fmt.Errorf("活动没有开始")
		return
	}

	has, todayBalance, err = BP.GetDailyBoonDetail(userId)
	if err != nil {
		return
	}
	if has {
		err = fmt.Errorf("已领取")
		return
	} else if todayBalance == 0 {
		err = fmt.Errorf("剩余0")
		return
	}
	//剩余数量校验
	err = func() error {
		hasKey := fmt.Sprintf(BidderPlanHasDailyBoonKey, userId)
		if redis.Incr(BidderPlanRedis, hasKey) == 1 {
			todaySumKey := fmt.Sprintf(BidderPlanDailyBoonKey, time.Now().Format(dataUtil.Date_yyyyMMdd))
			balance := redis.Incr(BidderPlanRedis, todaySumKey)
			if balance > gcfg.Instance().MustGet(gctx.New(), "jyactivity.dailyBoon.reward.limit", 500).Int64() {
				return fmt.Errorf("剩余为零")
			}
			if err := award.GivenSubVip(userId, award.SubVip{
				Num:          gcfg.Instance().MustGet(gctx.New(), "jyactivity.dailyBoon.reward.svip", nil).Int64(),
				ActivityCode: BP.ActivityCode,
				Date:         time.Now().Unix(),
				Desc:         "预热福利",
			}); err != nil {
				redis.Del(BidderPlanRedis, hasKey)
				return fmt.Errorf("稍后重试")
			}
			if balance == 1 {
				_ = redis.SetExpire(BidderPlanRedis, todaySumKey, BP.cacheLong())
			}
			_ = redis.SetExpire(BidderPlanRedis, hasKey, BP.cacheLong())
		}
		return nil
	}()
	return err
}