开会员

business/model/dao/dao_user.go

@@ -258,3 +258,21 @@ func GetUserOrderSMS(db *DaoDB, mobile, name string) (userOrderSms *model.UserOr
 	err = GetRow(db, &userOrderSms, sql, sqlParams)
 	return userOrderSms, err
 }
+
+func GetUserMember(db *DaoDB, userID, vendorOrderID string) (userMembers []*model.UserMember, err error) {
+	sql := `
+		SELECT * 
+		  FROM user_member
+		 WHERE deleted_at = ? 
+	`
+	sqlParams := []interface{}{utils.DefaultTimeValue}
+	if userID != "" {
+		sql += " AND user_id = ?"
+		sqlParams = append(sqlParams, userID)
+	}
+	if vendorOrderID != "" {
+		sql += " AND vendor_order_id = ?"
+		sqlParams = append(sqlParams, vendorOrderID)
+	}
+	return userMembers, err
+}

business/model/user.go

@@ -17,6 +17,8 @@ const (
 	UserTypeOperator    = 4
 	UserTypeBoss        = 8
 	UserTypeNonConsumer = ^1
+
+	MemberTypeDiscountCard = 1 //会员折扣卡
 )
 
 var (

business/partner/purchase/jx/localjx/order.go

@@ -372,10 +372,13 @@ func Pay4User(ctx *jxcontext.Context, thingID, payType int, vendorPayType string
 			userMember := &model.UserMember{
 				VendorOrderID: vendorOrderID,
 				UserID:        ctx.GetUserID(),
-				MemberType: ,
+				MemberType:    model.MemberTypeDiscountCard,
+				EndAt:         utils.Str2Time(time.Now().AddDate(0, 1, 0).AddDate(0, 0, -1).Format("2006-01-02") + "23:59:59"),
+				MemberTypeID:  thingID,
+				IsPay:         model.NO,
 			}
 			dao.WrapAddIDCULDEntity(userMember, ctx.GetUserName())
-
+			dao.CreateEntity(db, userMember)
 		}
 	default:
 		err = fmt.Errorf("支付方式:%d当前不支持", payType)
@@ -491,7 +494,12 @@ func OnPayFinished(orderPay *model.OrderPay) (err error) {
 	} else {
 		switch orderPay.PayType {
 		case model.PayTypeTL_DiscountCard:
-
+			userMembers, _ := dao.GetUserMember(dao.GetDB(), "", orderPay.VendorOrderID)
+			if len(userMembers) > 0 {
+				userMembers[0].IsPay = model.YES
+				dao.UpdateEntity(dao.GetDB(), userMembers[0], "IsPay")
+				err = nil
+			}
 		default:
 			priceDefendOrders, _ := dao.GetPriceDefendOrder(dao.GetDB(), orderPay.VendorOrderID, nil, nil, []int{jxutils.GetDefendPriceIssue()}, 0, -1, -1, 0, "", utils.ZeroTimeValue, utils.ZeroTimeValue, false)
 			if len(priceDefendOrders) > 0 {