liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

log

Browse Source
This commit is contained in:
richboo111
2022-07-26 13:32:46 +08:00
parent f4527f4078
commit f007eceba6
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/financial/bill.go
View File

@@ -7,6 +7,7 @@ import (
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/model/dao" "git.rosy.net.cn/jx-callback/business/model/dao"
"git.rosy.net.cn/jx-callback/globals"
"github.com/astaxie/beego/client/orm" "github.com/astaxie/beego/client/orm"
"time" "time"
) )
@@ -169,6 +170,7 @@ func SettleUnionOrders(ctx *jxcontext.Context, vendorIDs []int) (err error) {
//微信 老会员续费 //微信 老会员续费
func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string) (errCode string, err error) { func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string) (errCode string, err error) {
globals.SugarLogger.Debugf("=====================微信充值会员开始：%v", err)
var db = dao.GetDB() var db = dao.GetDB()
//获取用户 当前会员信息 //获取用户 当前会员信息
userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal) userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal)
@@ -177,6 +179,7 @@ func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string) (errCod
} }
//当前状态是否是会员 续费/开通 //当前状态是否是会员 续费/开通
if len(userMembers) > 0 { if len(userMembers) > 0 {
globals.SugarLogger.Debugf("=====================进入微信充值会员：%v", err)
userMember := userMembers[0] userMember := userMembers[0]
if memberID == model.OrderTypeMember { if memberID == model.OrderTypeMember {
userMember.EndAt = userMember.EndAt.AddDate(0, 1, 0) userMember.EndAt = userMember.EndAt.AddDate(0, 1, 0)
@@ -192,6 +195,7 @@ func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string) (errCod
MemberType: model.MemberTypeNormal, MemberType: model.MemberTypeNormal,
MemberTypeID: memberID, MemberTypeID: memberID,
} }
globals.SugarLogger.Debugf("=====================进入微信新会员：%v", err)
if memberID == model.OrderTypeMember { if memberID == model.OrderTypeMember {
userMember2.EndAt = time.Now().AddDate(0, 1, 0) userMember2.EndAt = time.Now().AddDate(0, 1, 0)
} else { } else {
@@ -202,11 +206,13 @@ func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string) (errCod
return "开通会员失败", err return "开通会员失败", err
} }
} }
globals.SugarLogger.Debugf("=====================微信老会员结束：%v", err)
return errCode, err return errCode, err
} }
//微信 新充值会员 //微信 新充值会员
func WXInvestMemberNew(ctx *jxcontext.Context, memberID int, userID string) (errCode string, err error) { func WXInvestMemberNew(ctx *jxcontext.Context, memberID int, userID string) (errCode string, err error) {
globals.SugarLogger.Debugf("=====================创建新会员开始：%v", err)
var db = dao.GetDB() var db = dao.GetDB()
userMember2 := &model.UserMember{ userMember2 := &model.UserMember{
UserID: userID, UserID: userID,
@@ -220,7 +226,9 @@ func WXInvestMemberNew(ctx *jxcontext.Context, memberID int, userID string) (err
} }
dao.WrapAddIDCULDEntity(userMember2, ctx.GetUserName()) dao.WrapAddIDCULDEntity(userMember2, ctx.GetUserName())
if err = dao.CreateEntity(db, userMember2); err != nil { if err = dao.CreateEntity(db, userMember2); err != nil {
globals.SugarLogger.Debugf("=====================创建新用户失败：%v", err)
return "开通会员失败", err return "开通会员失败", err
} }
globals.SugarLogger.Debugf("=====================创建新会员结束：%v", err)
return errCode, err return errCode, err
} }