From e5133e7006ae4eccb3d9a86855bff5785d905990 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Mon, 11 Jan 2021 18:06:50 +0800 Subject: [PATCH] aa --- business/model/dao/dao_order.go | 72 ++++++++++++++++--- business/partner/purchase/jx/localjx/order.go | 35 ++++++++- controllers/jx_order2.go | 14 ++++ 3 files changed, 111 insertions(+), 10 deletions(-) diff --git a/business/model/dao/dao_order.go b/business/model/dao/dao_order.go index 516cf270b..1dcf71c12 100644 --- a/business/model/dao/dao_order.go +++ b/business/model/dao/dao_order.go @@ -1482,31 +1482,57 @@ func GetPriceDefendOrder(db *DaoDB, vendorOrderID string, storeIDs, skuIDs, issu return priceDefendOrders, err } -func GetCoupons(db *DaoDB, couponType int, couponStatuss, storeIDs []int, keyword string) (coupons []*model.Coupons, err error) { +func GetCoupons(db *DaoDB, couponType int, couponStatuss, storeIDs []int, userID, mobile, keyword string) (coupons []*model.Coupons, err error) { sqlParams := []interface{}{} sql := ` - SELECT * - FROM coupons - WHERE 1 = 1 AND is_all = ? + SELECT DISTINCT a.* + FROM coupons a + ` + if userID != "" || mobile != "" { + sql += " JOIN user_coupons b ON a.id = b.coupon_id" + if userID != "" { + sql += " AND b.user_id = ?" + sqlParams = append(sqlParams, userID) + } + if mobile != "" { + sql += " AND b.mobile = ?" + sqlParams = append(sqlParams, mobile) + } + } + sql += ` + WHERE a.is_all = ? ` sqlParams = append(sqlParams, model.YES) if couponType != 0 { - sql += " AND coupon_type = ?" + sql += " AND a.coupon_type = ?" sqlParams = append(sqlParams, couponType) } if keyword != "" { - sql += " AND (name LIKE ? OR desc LIKE ?)" + sql += " AND (a.name LIKE ? OR a.desc LIKE ?)" sqlParams = append(sqlParams, "%"+keyword+"%", "%"+keyword+"%") } if len(couponStatuss) > 0 { - sql += " AND coupon_status IN (" + GenQuestionMarks(len(couponStatuss)) + ")" + sql += " AND a.coupon_status IN (" + GenQuestionMarks(len(couponStatuss)) + ")" sqlParams = append(sqlParams, couponStatuss) } - sql += - `UNION + sql += ` + UNION SELECT DISTINCT a.* FROM coupons a LEFT JOIN store_coupons b ON a.id = b.coupon_id AND b.deleted_at = ? + ` + if userID != "" || mobile != "" { + sql += " JOIN user_coupons c ON a.id = c.coupon_id" + if userID != "" { + sql += " AND c.user_id = ?" + sqlParams = append(sqlParams, userID) + } + if mobile != "" { + sql += " AND c.mobile = ?" + sqlParams = append(sqlParams, mobile) + } + } + sql += ` WHERE 1 = 1 ` sqlParams = append(sqlParams, utils.DefaultTimeValue) @@ -1545,5 +1571,33 @@ func GetStoreCoupons(db *DaoDB, couponIDs, storeIDs []int) (storeCoupons []*mode sql += " AND store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")" sqlParams = append(sqlParams, storeIDs) } + err = GetRows(db, &storeCoupons, sql, sqlParams) return storeCoupons, err } + +func GetUserCoupons(db *DaoDB, couponIDs []int, userIDs, mobiles []string, userStatus int) (userCoupons []*model.UserCoupons, err error) { + sql := ` + SELECT * + FROM user_coupons + WHERE 1 = 1 + ` + sqlParams := []interface{}{} + if len(couponIDs) > 0 { + sql += " AND coupon_id IN (" + GenQuestionMarks(len(couponIDs)) + ")" + sqlParams = append(sqlParams, couponIDs) + } + if len(userIDs) > 0 { + sql += " AND user_id IN (" + GenQuestionMarks(len(userIDs)) + ")" + sqlParams = append(sqlParams, userIDs) + } + if len(mobiles) > 0 { + sql += " AND mobile IN (" + GenQuestionMarks(len(mobiles)) + ")" + sqlParams = append(sqlParams, mobiles) + } + if userStatus != 0 { + sql += " AND user_coupon_status = ?" + sqlParams = append(sqlParams, userStatus) + } + err = GetRows(db, &userCoupons, sql, sqlParams) + return userCoupons, err +} diff --git a/business/partner/purchase/jx/localjx/order.go b/business/partner/purchase/jx/localjx/order.go index 4c6171296..e42abd562 100644 --- a/business/partner/purchase/jx/localjx/order.go +++ b/business/partner/purchase/jx/localjx/order.go @@ -2153,7 +2153,7 @@ func GetCoupons(ctx *jxcontext.Context, couponType int, couponStatuss, storeIDs var ( db = dao.GetDB() ) - coupons, err = dao.GetCoupons(db, couponType, couponStatuss, storeIDs, keyword) + coupons, err = dao.GetCoupons(db, couponType, couponStatuss, storeIDs, "", "", keyword) return coupons, err } @@ -2265,3 +2265,36 @@ func UpdateCoupons(ctx *jxcontext.Context, payload map[string]interface{}, store } return err } + +func ReceiveCoupons(ctx *jxcontext.Context, couponID int) (err error) { + var ( + db = dao.GetDB() + userID = ctx.GetUserID() + coupons = &model.Coupons{} + ) + coupons.ID = int64(couponID) + dao.GetEntity(db, coupons) + if coupons == nil { + return fmt.Errorf("领取优惠券失败！") + } + if coupons.CouponStatus != model.CouponStatusNormal { + return fmt.Errorf("优惠券状态有误，领取失败！") + } + if time.Now().Sub(coupons.EndAt) > 0 { + return fmt.Errorf("优惠券已过期，领取失败！") + } + if time.Now().Sub(coupons.BeginAt) < 0 { + return fmt.Errorf("优惠券未生效，领取失败！") + } + userCoupons, _ := dao.GetUserCoupons(db, []int{couponID}, []string{userID}, nil, model.CouponStatusNormal) + if len(userCoupons) > 0 { + return fmt.Errorf("您已经领取过该优惠券了，请使用后再领取！") + } + userCoupon := &model.UserCoupons{ + CouponID: couponID, + UserID: userID, + } + dao.WrapAddIDCULEntity(userCoupon, ctx.GetUserName()) + err = dao.CreateEntity(db, userCoupon) + return err +} diff --git a/controllers/jx_order2.go b/controllers/jx_order2.go index acaf89d98..ecbc7e904 100644 --- a/controllers/jx_order2.go +++ b/controllers/jx_order2.go @@ -349,3 +349,17 @@ func (c *JxOrderController) UpdateCoupons() { return retVal, "", err }) } + +// @Title 领取优惠券 +// @Description 领取优惠券 +// @Param token header string true "认证token" +// @Param couponID formData int true "券ID" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /ReceiveCoupons [post] +func (c *JxOrderController) ReceiveCoupons() { + c.callReceiveCoupons(func(params *tJxorderReceiveCouponsParams) (retVal interface{}, errCode string, err error) { + err = localjx.ReceiveCoupons(params.Ctx, params.CouponID) + return retVal, "", err + }) +}