135 lines
3.6 KiB
Go
135 lines
3.6 KiB
Go
package model
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/codinl/go-logger"
|
|
"time"
|
|
)
|
|
|
|
//go:generate goqueryset -in analyse.go
|
|
// gen:qs
|
|
type Statistic struct {
|
|
Model
|
|
|
|
Count uint32 `json:"count" gorm:"default:0"` // 计数
|
|
EventType uint32 `json:"event_type" gorm:"index"` // 类型:1-运费包曝光次数
|
|
}
|
|
|
|
const (
|
|
UserRenewalLogActionPop = 1 // 弹窗
|
|
UserRenewalLogActionEnterActivity = 2 // 进入活动
|
|
UserRenewalLogActionPickGold = 3 // 领取黄金会员
|
|
UserRenewalLogActionPickPlatinum = 4 // 领取白金会员
|
|
UserRenewalLogActionPickBlackGold = 5 // 领取黑金会员
|
|
UserRenewalLogActionUseGold = 6 // 使用黄金会员
|
|
UserRenewalLogActionUsePlatinum = 7 // 使用白金会员
|
|
UserRenewalLogActionUseBlackGold = 8 // 使用黑金会员
|
|
)
|
|
|
|
// gen:qs
|
|
type UserRenewalLog struct {
|
|
Model
|
|
|
|
Uid uint32 `json:"uid"`
|
|
Action uint32 `json:"action"`
|
|
MemberExpire time.Time `json:"member_expire"`
|
|
Type uint32 `json:"type"` // 类型:1-续费 2-升级
|
|
RenewalNum uint32 `json:"renewal_num"`
|
|
Serial uint32 `json:"serial"`
|
|
// user_renewal_log
|
|
}
|
|
|
|
func (l *UserRenewalLog) Add() error {
|
|
err := DB.Create(l).Error
|
|
if err != nil {
|
|
logger.Error("user log add err:", err)
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func GetActionUserRenewalLog(uid, action uint32) (UserRenewalLog, error) {
|
|
var userRenewalLog UserRenewalLog
|
|
err := NewUserRenewalLogQuerySet(DB).UidEq(uid).ActionEq(action).OrderDescByID().
|
|
Limit(1).One(&userRenewalLog)
|
|
if err != nil && err != RecordNotFound {
|
|
logger.Error("user renewal log err:", err)
|
|
return userRenewalLog, err
|
|
}
|
|
return userRenewalLog, nil
|
|
}
|
|
|
|
// gen:qs
|
|
type UserMemberRecord struct {
|
|
Model
|
|
Uid uint32 `json:"uid" gorm:"index"`
|
|
BeforeMemberLevel uint32 `json:"before_member_level"`
|
|
AfterMemberLevel uint32 `json:"after_member_level"`
|
|
BeforeMemberExpire time.Time `json:"before_member_expire"`
|
|
AfterMemberExpire time.Time `json:"after_member_expire"`
|
|
InviteUid uint32 `json:"invite_uid" gorm:"index"`
|
|
DeductionDays uint32 `json:"deduction_days"` // 抵扣天数
|
|
DeductionFee uint32 `json:"deduction_fee"` // 抵扣金额
|
|
CouponId uint32 `json:"coupon_id"` // 优惠券id
|
|
Serial uint32 `json:"serial" gorm:"index"` // 日志
|
|
Type uint32 `json:"type" gorm:"index"` // 1-开通黄金 2-开通白金 3-开通黑金 4-续费黄金 5-续费白金 6-续费黑金 7-升级白金 8-升级黑金
|
|
OpenMemberLevel uint32 `json:"open_member_level"`
|
|
OpenMemberTime time.Time `json:"open_member_time"`
|
|
|
|
// user_member_record
|
|
}
|
|
|
|
func GetUserMemberRecordType(level uint32, memberType uint32) uint32 {
|
|
if memberType == 1 {
|
|
switch level {
|
|
case 2:
|
|
return 1
|
|
case 4:
|
|
return 2
|
|
case 5:
|
|
return 3
|
|
}
|
|
} else if memberType == 2 {
|
|
switch level {
|
|
case 2:
|
|
return 4
|
|
case 4:
|
|
return 5
|
|
case 5:
|
|
return 6
|
|
}
|
|
} else if memberType == 3 {
|
|
switch level {
|
|
case 4:
|
|
return 7
|
|
case 5:
|
|
return 8
|
|
}
|
|
}
|
|
|
|
return 0
|
|
}
|
|
|
|
func (m *UserMemberRecord) Add() {
|
|
go func() {
|
|
err := DB.Create(m).Error
|
|
if err != nil {
|
|
logger.Error("create user member record err:", err)
|
|
}
|
|
}()
|
|
}
|
|
|
|
// gen:qs
|
|
type UserActionLog struct {
|
|
Model
|
|
|
|
Uid uint32 `json:"uid" gorm:"index"`
|
|
ActionType uint32 `json:"action_type"` // 1-运费包_领券送时长专题页 2-运费包_购买运费包
|
|
First uint32 `json:"first"` // 1-首次
|
|
// user_action_log
|
|
}
|
|
|
|
func IsFirstUserAction(uid, actionType uint32) (bool, error) {
|
|
return QueryRecordExist(fmt.Sprintf("SELECT * FROM user_action_log WHERE uid=%d AND action_type=%d", uid, actionType))
|
|
}
|