add
This commit is contained in:
@@ -169,7 +169,10 @@ func SettleUnionOrders(ctx *jxcontext.Context, vendorIDs []int) (err error) {
|
|||||||
|
|
||||||
func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string, isFree bool) (errCode string, err error) {
|
func WXInvestMember(ctx *jxcontext.Context, memberID int, userID string, isFree bool) (errCode string, err error) {
|
||||||
var db = dao.GetDB()
|
var db = dao.GetDB()
|
||||||
|
//获取用户当前用户信息
|
||||||
userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal)
|
userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal)
|
||||||
|
//获取用户微信下单信息
|
||||||
|
//userBill, err := dao.GetUserBill(db, userID, "")
|
||||||
txDB, _ := dao.Begin(db)
|
txDB, _ := dao.Begin(db)
|
||||||
defer func() {
|
defer func() {
|
||||||
if r := recover(); r != nil {
|
if r := recover(); r != nil {
|
||||||
|
|||||||
@@ -122,7 +122,7 @@ func OnWXPayFinished(order *model.Order) (err error) {
|
|||||||
switch order.Type {
|
switch order.Type {
|
||||||
case model.OrderTpyeMember:
|
case model.OrderTpyeMember:
|
||||||
//微信支付充值会员
|
//微信支付充值会员
|
||||||
if _, err = WXInvestMember(ctx, userMember[0].MemberType, order.UserID, true); err != nil {
|
if _, err = WXInvestMember(ctx, userMember[0].MemberTypeID, order.UserID, true); err != nil {
|
||||||
dao.Rollback(db, txDB)
|
dao.Rollback(db, txDB)
|
||||||
}
|
}
|
||||||
default:
|
default:
|
||||||
|
|||||||
Reference in New Issue
Block a user