315 lines
8.8 KiB
Go
315 lines
8.8 KiB
Go
package model
|
|
|
|
import (
|
|
"crypto/sha512"
|
|
"errors"
|
|
"fmt"
|
|
"github.com/codinl/go-logger"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
RedeemCodeStatusStock = "stocking" // 库存
|
|
RedeemCodeStatusHold = "user-hold" // 用户持有
|
|
RedeemCodeStatusUsed = "used" // 已使用
|
|
)
|
|
const (
|
|
CodeTypeMemberCard30 = "member-card-30" // 会员卡 30天
|
|
CodeTypeMemberGoldMember = "member-card-gold-member"
|
|
CodeTypeMemberPlatinumMember = "member-card-platinum-member"
|
|
CodeTypeMemberBlackGoldMember = "member-card-black-gold-member"
|
|
CodeTypeDeductionCoupon5 = "deduction-coupon-5"
|
|
)
|
|
|
|
const (
|
|
RedeemCodeSecretKey = "046033a527d1b723ed0a1012e6518d490"
|
|
)
|
|
|
|
const (
|
|
UserRedeemCodeStatusHold = "user-hold"
|
|
UserRedeemCodeStatusUsed = "used"
|
|
)
|
|
|
|
const (
|
|
RedeemCodeActivityTypeStore = 1 // 门店赠送
|
|
RedeemCodeActivityTypeUserInvite = 2 // 用户邀请
|
|
|
|
)
|
|
|
|
//go:generate goqueryset -in redeem_code.go
|
|
// gen:qs
|
|
type RedeemCode struct {
|
|
Model
|
|
|
|
SerialCode string `json:"serial_code" gorm:"index;comment:'兑换编码'"` // 兑换编码
|
|
CodeType string `json:"code_type"` // memberCard
|
|
Status string `json:"status" gorm:"index;comment:'兑换状态'"` // stocking user-hold used
|
|
StoreId uint32 `json:"store_id" gorm:"index"` // 门店id
|
|
CodeSecret string `json:"code_secret"` // 兑换密码
|
|
EffectiveTime time.Time `json:"effective_time"` // 生效时间
|
|
ExpirationTime time.Time `json:"expiration_time"` // 过期时间
|
|
CouponId uint32 `json:"coupon_id" gorm:"index"`
|
|
//Remark string `json:"remark"`
|
|
}
|
|
|
|
// gen:qs
|
|
type UserRedeemCode struct {
|
|
Model
|
|
Uid uint32 `json:"uid" gorm:"index;comment:'用户id'"`
|
|
Status string `json:"status" gorm:"index;comment:'兑换状态'"` // user-hold used
|
|
StoreId uint32 `json:"store_id" gorm:"index"` // 门店id
|
|
SerialCode string `json:"serial_code" gorm:"index;comment:'兑换编码'"` // 兑换编码
|
|
CodeType string `json:"code_type"` // memberCard
|
|
ConvertTime time.Time `json:"convert_time"` // 绑定时间
|
|
ActivityType uint32 `json:"activity_type"` // 1-门店赠送 2-用户邀请
|
|
}
|
|
|
|
//type BindingRedeemCodeRecord struct {
|
|
// Model
|
|
//}
|
|
|
|
// 会员兑换码
|
|
// 用户押金
|
|
// 支付押金
|
|
// 押金
|
|
// 开通会员
|
|
// 管理端 发 会员 Sign 校验
|
|
|
|
func RedeemSecretCode(redeem string) string {
|
|
semen := redeem[:13] + strings.ToUpper(RedeemCodeSecretKey)
|
|
shaer := sha512.New()
|
|
shaer.Write([]byte(semen))
|
|
r := shaer.Sum(nil)
|
|
hs := fmt.Sprintf("%x", r)
|
|
return hs[:7]
|
|
}
|
|
|
|
func UserRedeemCodeList(uid uint32) ([]UserRedeemCode, error) {
|
|
var userRedeems []UserRedeemCode
|
|
err := NewUserRedeemCodeQuerySet(DB).UidEq(uid).OrderDescByID().All(&userRedeems)
|
|
if err != nil && err != RecordNotFound {
|
|
logger.Error("user redeem code err:", err)
|
|
return userRedeems, err
|
|
}
|
|
if len(userRedeems) == 0 {
|
|
return userRedeems, nil
|
|
}
|
|
holdList := make([]UserRedeemCode, 0)
|
|
usedList := make([]UserRedeemCode, 0)
|
|
for i, _ := range userRedeems {
|
|
if userRedeems[i].Status == UserRedeemCodeStatusHold {
|
|
//holdList = append(holdList, userRedeems[i])
|
|
} else {
|
|
usedList = append(usedList, userRedeems[i])
|
|
}
|
|
}
|
|
|
|
return append(holdList, usedList...), nil
|
|
}
|
|
|
|
// 会员兑换码兑换
|
|
func UserRedeemCodeConvert(uid uint32, serialCode string) error {
|
|
var userRedeem UserRedeemCode
|
|
err := NewUserRedeemCodeQuerySet(DB).UidEq(uid).SerialCodeEq(serialCode).One(&userRedeem)
|
|
if err != nil {
|
|
logger.Error("user redeem code err:", err)
|
|
return err
|
|
}
|
|
if userRedeem.Status != UserRedeemCodeStatusHold {
|
|
return errors.New("user redeem code not exist")
|
|
}
|
|
|
|
begin := DB.Begin()
|
|
num, err := NewRedeemCodeQuerySet(begin).SerialCodeEq(serialCode).GetUpdater().SetStatus(RedeemCodeStatusUsed).UpdateNum()
|
|
if err != nil {
|
|
logger.Error("user redeem code err:", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
if num == 0 {
|
|
logger.Error("num is 0 err:")
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
//qsUserRedeem := NewUserRedeemCodeQuerySet(begin).UidEq(uid).SerialCodeEq(serialCode).GetUpdater()
|
|
//if userRedeem.CodeType == CodeTypeMemberGoldMember {
|
|
// //qsUserRedeem = qsUserRedeem.SetCodeType()
|
|
//}
|
|
updateNum, err := NewUserRedeemCodeQuerySet(begin).UidEq(uid).SerialCodeEq(serialCode).GetUpdater().
|
|
SetStatus(UserRedeemCodeStatusUsed).SetConvertTime(time.Now()).UpdateNum()
|
|
if err != nil {
|
|
logger.Error("user redeem code err:", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
if updateNum == 0 {
|
|
logger.Error("num is 0 err:")
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
user := GetUserByUid(uid)
|
|
qs := NewUserQuerySet(begin).UidEq(uid).GetUpdater()
|
|
if user.MemberLevel != 1 && user.MemberLevel != 3 &&
|
|
userRedeem.CodeType != CodeTypeMemberCard30 {
|
|
logger.Error("code type used by consumer:")
|
|
begin.Rollback()
|
|
return errors.New("code type used by consumer")
|
|
}
|
|
|
|
addDates := 0
|
|
memberLevel := uint32(0)
|
|
switch userRedeem.CodeType {
|
|
case CodeTypeMemberCard30:
|
|
addDates = 30
|
|
memberLevel = 3
|
|
case CodeTypeMemberGoldMember:
|
|
addDates = 365
|
|
memberLevel = 2
|
|
qs = qs.SetMemberLevel(MemberLevelGold).SetOpenMemberTime(time.Now()).SetOpenMemberChannel(OpenMemberChannelRedeemCode)
|
|
case CodeTypeMemberPlatinumMember:
|
|
addDates = 365
|
|
memberLevel = 4
|
|
qs = qs.SetMemberLevel(MemberLevelPlatinum).SetOpenMemberTime(time.Now()).SetOpenMemberChannel(OpenMemberChannelRedeemCode)
|
|
case CodeTypeMemberBlackGoldMember:
|
|
addDates = 365
|
|
memberLevel = 5
|
|
qs = qs.SetMemberLevel(MemberLevelBlackGold).SetOpenMemberTime(time.Now()).SetOpenMemberChannel(OpenMemberChannelRedeemCode)
|
|
default:
|
|
logger.Error(" code type err:", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
if user.MemberExpire.After(time.Now()) {
|
|
qs = qs.SetMemberExpire(user.MemberExpire.AddDate(0, 0, addDates))
|
|
} else {
|
|
qs = qs.SetMemberExpire(time.Now().AddDate(0, 0, addDates))
|
|
}
|
|
if user.MemberLevel == 1 || user.MemberLevel == 3 {
|
|
qs = qs.SetMemberLevel(memberLevel)
|
|
}
|
|
|
|
userNum, err := qs.UpdateNum()
|
|
if err != nil {
|
|
logger.Error("user redeem code err:", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
if userNum == 0 {
|
|
logger.Error("num is 0 err:")
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
err = begin.Commit().Error
|
|
if err != nil {
|
|
logger.Error("user redeem code err:", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func CodeSendToUser(uid uint32, codeType string, activityType uint32) error {
|
|
count, err := NewUserRedeemCodeQuerySet(DB).UidEq(uid).Count()
|
|
if err != nil {
|
|
logger.Error("err:", err)
|
|
return err
|
|
}
|
|
if count > 24 {
|
|
logger.Error("redeem code limit 24")
|
|
return errors.New("redeem code limit 24")
|
|
}
|
|
var redeemCode RedeemCode
|
|
err = NewRedeemCodeQuerySet(DB).StatusEq(RedeemCodeStatusStock).CodeTypeEq(codeType).Limit(1).One(&redeemCode)
|
|
if err != nil {
|
|
logger.Errorf("err:%#v", err)
|
|
return err
|
|
}
|
|
|
|
begin := DB.Begin()
|
|
|
|
sql := fmt.Sprintf("UPDATE redeem_code SET `status` ='%s' WHERE id =%d", RedeemCodeStatusHold, redeemCode.ID)
|
|
err = begin.Exec(sql).Error
|
|
if err != nil {
|
|
logger.Errorf("err:%#v", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
userRedeemCode := &UserRedeemCode{
|
|
Uid: uid,
|
|
Status: UserRedeemCodeStatusHold,
|
|
SerialCode: redeemCode.SerialCode,
|
|
CodeType: redeemCode.CodeType,
|
|
ActivityType: activityType,
|
|
//ActivityType: RedeemCodeActivityTypeUserInvite,
|
|
}
|
|
err = begin.Create(userRedeemCode).Error
|
|
if err != nil {
|
|
logger.Errorf("err:%#v", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
err = begin.Commit().Error
|
|
if err != nil {
|
|
logger.Errorf("err:%#v", err)
|
|
begin.Rollback()
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func SendUserVm(uid, memberLevel, inviteLevel uint32) error {
|
|
if memberLevel == 3 {
|
|
return nil
|
|
}
|
|
config, err := GetMemberVmConfig(memberLevel)
|
|
if err != nil {
|
|
logger.Error("err:", err)
|
|
return err
|
|
}
|
|
|
|
amount := 0
|
|
describe := ""
|
|
event := ""
|
|
if inviteLevel == 0 {
|
|
amount = int(config.MemberVm)
|
|
describe = "开通会员奖励"
|
|
event = VmEventOpenMember
|
|
} else if inviteLevel == 1 {
|
|
amount = int(config.Invite1Vm)
|
|
describe = "邀请会员奖励"
|
|
event = VmEventInvite1Member
|
|
} else if inviteLevel == 2 {
|
|
amount = int(config.Invite2Vm)
|
|
describe = "邀请会员奖励"
|
|
event = VmEventInvite2Member
|
|
} else if inviteLevel == 100 {
|
|
amount = int(config.AutomationMemberVm)
|
|
describe = "开通会员奖励"
|
|
event = VmEventOpenMember
|
|
}
|
|
|
|
err = UserVmUpdate(uid, amount, event, describe)
|
|
if err != nil {
|
|
logger.Error("err:", err)
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func GetUserRenewalCouponIds() ([]uint32, error) {
|
|
ids := make([]uint32, 0)
|
|
var coupons []Coupon
|
|
err := NewCouponQuerySet(DB).ActivityIdEq(1).All(&coupons)
|
|
if err != nil {
|
|
logger.Error("coupons err:", err)
|
|
return ids, err
|
|
}
|
|
for i, _ := range coupons {
|
|
ids = append(ids, coupons[i].ID)
|
|
}
|
|
|
|
return ids, nil
|
|
}
|