This commit is contained in:
苏尹岚
2020-10-19 15:15:52 +08:00
parent 10d66dda21
commit a41052cd9c
2 changed files with 51 additions and 42 deletions

View File

@@ -587,47 +587,47 @@ func RefreshUserMemberStatus(ctx *jxcontext.Context) (err error) {
} }
func InvestMember(ctx *jxcontext.Context, memberID int) (err error) { func InvestMember(ctx *jxcontext.Context, memberID int) (err error) {
var ( // var (
db = dao.GetDB() // db = dao.GetDB()
memberCards []*model.MemberCard // memberCards []*model.MemberCard
memberCard *model.MemberCard // memberCard *model.MemberCard
) // )
userMembers, err := dao.GetUserMember(db, ctx.GetUserID(), model.MemberTypeNormal) // userMembers, err := dao.GetUserMember(db, ctx.GetUserID(), model.MemberTypeNormal)
configList, err := dao.QueryConfigs(db, model.ConfigTypeName[model.ConfigTypeMemberCard], model.ConfigTypeMemberCard, "") // configList, err := dao.QueryConfigs(db, model.ConfigTypeName[model.ConfigTypeMemberCard], model.ConfigTypeMemberCard, "")
if len(configList) <= 0 { // if len(configList) <= 0 {
return fmt.Errorf("未找到会员卡配置!") // return fmt.Errorf("未找到会员卡配置!")
} // }
config := configList[0] // config := configList[0]
err = jxutils.Strings2Objs(config.Value, &memberCards) // err = jxutils.Strings2Objs(config.Value, &memberCards)
if err != nil { // if err != nil {
return err // return err
} // }
for _, v := range memberCards { // for _, v := range memberCards {
if v.ID == memberID { // if v.ID == memberID {
memberCard = v // memberCard = v
} // }
} // }
dao.Begin(db) // dao.Begin(db)
defer func() { // defer func() {
if r := recover(); r != nil { // if r := recover(); r != nil {
dao.Rollback(db) // dao.Rollback(db)
panic(r) // panic(r)
} // }
}() // }()
//证明已经开了会员了,相当于续费 // //证明已经开了会员了,相当于续费
if len(userMembers) > 0 { // if len(userMembers) > 0 {
userMember := userMembers[0] // userMember := userMembers[0]
if memberID == model.MemberCardTypeMonth { // if memberID == model.MemberCardTypeMonth {
userMember.EndAt = userMember.EndAt.AddDate(0, 1, 0) // userMember.EndAt = userMember.EndAt.AddDate(0, 1, 0)
} else { // } else {
userMember.EndAt = userMember.EndAt.AddDate(1, 0, 0) // userMember.EndAt = userMember.EndAt.AddDate(1, 0, 0)
} // }
} else { // } else {
userMember2 := &model.UserMember{} // userMember2 := &model.UserMember{}
dao.WrapAddIDCULDEntity(userMember2, ctx.GetUserName()) // dao.WrapAddIDCULDEntity(userMember2, ctx.GetUserName())
} // }
//账户余额支出 // //账户余额支出
//支出明细、 // //支出明细、
dao.Commit(db) // dao.Commit(db)
return err return err
} }

View File

@@ -349,6 +349,15 @@ func init() {
Filters: nil, Filters: nil,
Params: nil}) Params: nil})
beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:User2Controller"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:User2Controller"],
beego.ControllerComments{
Method: "InvestMember",
Router: `/InvestMember`,
AllowHTTPMethods: []string{"post"},
MethodParams: param.Make(),
Filters: nil,
Params: nil})
beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:User2Controller"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:User2Controller"], beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:User2Controller"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:User2Controller"],
beego.ControllerComments{ beego.ControllerComments{
Method: "LoadMyCart", Method: "LoadMyCart",