Promotion / CouponPromotion / Coupon

mã đang hoạt độngactive coupons

50K

mã đang hoạt độngactive coupons

lượt checkout lúc flash salecheckouts during a flash sale

~3,000/s

lượt checkout lúc flash salecheckouts during a flash sale

để kiểm tra và giữ một mãto validate and reserve a code

< 50 ms

để kiểm tra và giữ một mãto validate and reserve a code

lượt dùng vượt giới hạnuses beyond the limit

0

lượt dùng vượt giới hạnuses beyond the limit

Checkout gọi Coupon Service để kiểm tra điều kiện, tính mức giảm và giữ lượt trong cùng một transaction trên PostgreSQL. Khi đơn bị huỷ, sự kiện order.cancelled đi qua hàng đợi để worker trả lượt. Chọn “Hai người tranh lượt cuối” để xem câu UPDATE có điều kiện chặn người thứ hai.Checkout calls the Coupon Service to check eligibility, compute the discount and reserve a use in one PostgreSQL transaction. When an order is cancelled, an order.cancelled event goes through the queue and a worker releases the use. Choose “Two buyers race for the last use” to see the conditional UPDATE reject the second one.

1. 1

   Vượt giới hạn tổng do đọc rồi ghiExceeding the global limit with read-then-write

   SELECT used rồi so sánh trong code tạo khoảng hở giữa hai bước. Gộp kiểm tra và tăng vào một câu: UPDATE coupon SET used = used + 1 WHERE id = ? AND used < max_uses, xem số dòng bị ảnh hưởng. Với lưu lượng rất cao, dùng Redis DECR trên bộ đếm còn lại, kết quả âm thì INCR trả lại và từ chối.SELECT used and comparing in code leaves a gap between the two steps. Fold the check and the increment into one statement: UPDATE coupon SET used = used + 1 WHERE id = ? AND used < max_uses, then read the affected row count. At very high volume use Redis DECR on a remaining counter; a negative result is given back with INCR and rejected.

   Unit of Work
2. 2

   Một khách dùng mã nhiều lầnOne customer reusing a code

   Mỗi lần dùng là một dòng coupon_redemption có unique(coupon_id, user_id, order_id), nên bấm hai lần hoặc retry cùng một đơn không tạo lượt thứ hai. Giới hạn mỗi khách N lượt: đếm các dòng RESERVED/USED trong cùng transaction, hoặc với N = 1 dùng partial unique index (coupon_id, user_id) WHERE status <> 'RELEASED'.Each use is a coupon_redemption row with unique(coupon_id, user_id, order_id), so a double click or a retry of the same order never creates a second use. For a limit of N per customer, count RESERVED/USED rows in the same transaction, or for N = 1 use a partial unique index on (coupon_id, user_id) WHERE status <> 'RELEASED'.

   Unit of Work
3. 3

   Điều kiện áp mã ngày càng nhiềuEligibility rules keep growing

   Mỗi điều kiện là một Specification nhỏ: MinOrderValue, InCategory, FirstOrder, DateWindow, InSegment. Mã khuyến mãi lưu cấu hình, service ghép chúng bằng and/or/not. Thêm điều kiện mới là thêm một class, không sửa if-else trong checkout.Each condition is a small Specification: MinOrderValue, InCategory, FirstOrder, DateWindow, InSegment. The coupon stores its configuration and the service composes them with and/or/not. A new condition is a new class, not another if-else in checkout.

   Specification
4. 4

   Nhiều cách tính mức giảmMany ways to compute a discount

   Strategy cho từng kiểu: PercentWithCap, FixedAmount, FreeShipping, BuyXGetY. Tính trên số nguyên đơn vị nhỏ nhất của tiền tệ, không dùng double, và không cho tổng giảm vượt giá trị đơn.One Strategy per kind: PercentWithCap, FixedAmount, FreeShipping, BuyXGetY. Compute in integer minor units, never double, and never let the total discount exceed the order value.

   Strategy
5. 5

   Cộng dồn nhiều mãStacking several codes

   Chain of Responsibility theo priority: mã sản phẩm trước, mã đơn hàng sau, miễn phí vận chuyển cuối cùng. Mỗi mắt xích quyết định áp hay bỏ qua dựa trên cờ exclusive và nhóm cộng dồn, rồi chuyển phần đơn còn lại cho mắt xích kế tiếp.A Chain of Responsibility ordered by priority: item coupons first, order coupons next, free shipping last. Each link decides to apply or skip based on its exclusive flag and stacking group, then hands the remaining amount to the next link.

   Chain of Responsibility
6. 6

   Dò mã và mã bị chia sẻ công khaiCode guessing and leaked codes

   Rate limit số lần thử mã theo user và IP bằng Redis, khoá tạm sau nhiều lần sai. Với mã giá trị cao, sinh mã dùng một lần, ngẫu nhiên đủ dài (10–12 ký tự), gắn với khách cụ thể thay vì một mã chung.Rate-limit coupon attempts per user and IP in Redis and lock out briefly after repeated failures. For high-value campaigns, generate long random single-use codes (10–12 characters) bound to a customer instead of one shared code.

   Rate Limiter
7. 7

   Giữ lượt rồi bỏ đơnReserved uses on abandoned orders

   Lượt được giữ ở trạng thái RESERVED khi checkout, chuyển USED khi thanh toán xong. Đơn huỷ hoặc hết hạn thanh toán thì worker chuyển RELEASED và giảm used; điều kiện WHERE status = 'RESERVED' giữ cho việc trả lượt idempotent.A use is RESERVED at checkout and becomes USED once payment succeeds. A cancelled or unpaid order is moved to RELEASED by a worker, which also decrements used; the WHERE status = 'RESERVED' guard keeps the release idempotent.

   Command

Giữ một lượt dùng: kiểm tra điều kiện, tăng used bằng UPDATE có điều kiện, ghi dòng redemption unique, tất cả trong một transaction.Reserving a use: check eligibility, increment used with a conditional UPDATE and insert a unique redemption row, all in one transaction.

@Service
@RequiredArgsConstructor
public class CouponRedemptionService {
    private final CouponRepository coupons;
    private final RedemptionRepository redemptions;
    private final EligibilityRules rules;

    @Transactional
    public Discount reserve(String code, Order order) {
        Coupon c = coupons.findByCode(code)
                .orElseThrow(() -> new CouponException("NOT_FOUND"));
        Specification<CouponContext> spec = rules.of(c); // a.and(b).and(c)1
        if (!spec.isSatisfiedBy(new CouponContext(c, order))) {
            throw new CouponException("NOT_ELIGIBLE");
        }
        if (coupons.incrementIfAvailable(c.getId()) == 0) {2
            throw new CouponException("EXHAUSTED");
        }
        try {
            redemptions.saveAndFlush(Redemption.reserved(c, order));3
        } catch (DataIntegrityViolationException e) {
            throw new CouponException("ALREADY_USED"); // rolls back the increment4
        }
        return c.strategy().apply(order);
    }
}

interface CouponRepository extends JpaRepository<Coupon, Long> {
    Optional<Coupon> findByCode(String code);

    @Modifying
    @Query("UPDATE Coupon c SET c.used = c.used + 1 "
         + "WHERE c.id = :id AND c.used < c.maxUses")
    int incrementIfAvailable(@Param("id") long id);
}

type CouponService struct {
	db    *pgxpool.Pool
	rules RuleBuilder // builds a Spec from coupon_rule rows
}

func (s *CouponService) Reserve(ctx context.Context, code string, o Order) (Discount, error) {
	tx, err := s.db.Begin(ctx)
	if err != nil {
		return Discount{}, err
	}
	defer tx.Rollback(ctx) // no-op after Commit1

	c, err := loadCoupon(ctx, tx, code)
	if err != nil {
		return Discount{}, err
	}
	if !s.rules.For(c).IsSatisfiedBy(CouponContext{Coupon: c, Order: o}) {
		return Discount{}, ErrNotEligible
	}

	tag, err := tx.Exec(ctx, `UPDATE coupon SET used = used + 12
		WHERE id = $1 AND used < max_uses`, c.ID)
	if err != nil {
		return Discount{}, err
	}
	if tag.RowsAffected() == 0 {
		return Discount{}, ErrExhausted
	}

	_, err = tx.Exec(ctx, `INSERT INTO coupon_redemption
		(coupon_id, user_id, order_id, status) VALUES ($1, $2, $3, 'RESERVED')`,
		c.ID, o.UserID, o.ID)
	var pgErr *pgconn.PgError
	if errors.As(err, &pgErr) && pgErr.Code == "23505" {3
		return Discount{}, ErrAlreadyUsed
	} else if err != nil {
		return Discount{}, err
	}

	if err := tx.Commit(ctx); err != nil {
		return Discount{}, err
	}
	return c.Strategy().Apply(o), nil4
}

Mỗi pattern mở bài học tương ứng trong menu Pattern.Each one opens its lesson in the Patterns menu.