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"
	"log"
	"time"
)

//当日中奖信息
func (BP *JyActivity) WinnerInfo() map[string]interface{} {
	return award.GetWinnerInfo()
}

// 问卷提交
func (BP *JyActivity) Questionnaire(userId, phone, answers string) error {
	if _, inActivity, _ := BP.InActivity(); !inActivity {
		return fmt.Errorf("不在活动时间内")
	}
	//保存问卷
	if award.SaveQuestionnaire(userId, phone, answers) {
		//问卷保存后--赠送7天超级订阅
		err := BP.GetDailyBoonSVip(userId)
		log.Println("err  开通超级订阅   --:", err)
		if err != nil {
			return err
		}
		if redis.Put(BidderPlanRedis, fmt.Sprintf(QuestionnaireSubmit, userId), 1, BP.cacheLong()) != true {
			return fmt.Errorf("redis de22q 存储异常")
		}
	} else {
		return fmt.Errorf("mongodb de22q 存储异常")
	}
	return nil
}

// 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, registerBool, questionsBool bool, 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
	}
	//默认问卷已提交  注册时间也在活动允许范围内
	questionsBool, registerBool = true, true
	//是否有权限领取
	powerSwitch := gcfg.Instance().MustGet(gctx.New(), "jyactivity.power.switch", false).Bool()
	//权限判断及问卷调查开关
	if powerSwitch {
		registerTime := gcfg.Instance().MustGet(gctx.New(), "jyactivity.power.time", 1609430400).Int64()
		//注册时间是否在允许范围内
		registerBool = registerTime < award.GetUserRegisterTime(userId)
		//问卷是否提交
		rsKey := fmt.Sprintf(QuestionnaireSubmit, userId)
		questionsBool = redis.GetInt(BidderPlanRedis, rsKey) > 0
	}
	return
}

// GetDailyBoonSVip 每日限量超级订阅领取
func (BP *JyActivity) GetDailyBoonSVip(userId string) (err error) {
	var has, questionsBool bool = false, 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, _, questionsBool, err = BP.GetDailyBoonDetail(userId)
	if err != nil {
		return
	}
	//问卷是否提交
	if !questionsBool {
		err = fmt.Errorf("问卷未提交")
		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())
			//领取7天超级订阅后清空权限缓存
			cacheKey := fmt.Sprintf(PowerCacheKey, userId)
			baseInfoCacheKey := fmt.Sprintf(IsGetUserBaseInfoRedisKey, userId)
			redis.Del(PowerCacheDb, cacheKey)
			redis.Del(PowerCacheDb, baseInfoCacheKey)
		}
		return nil
	}()
	return err
}