feat: 쿠폰 보관함 조회 기능 구현

src/docs/asciidoc/coupon.adoc

@@ -85,6 +85,15 @@ include::{snippets}/coupons/http-response.adoc[]
 
  사용자가 자신의 보관함에 있는 쿠폰들을 조회합니다.
 
+==== 요청
+
+include::{snippets}/my-coupons/couponId/http-request.adoc[]
+
+[discrete]
+==== 응답
+
+include::{snippets}/my-coupons/couponId/http-response.adoc[]
+
 ---
 
 === 쿠폰 사용 (진행 중)

src/main/java/com/moabam/api/application/bug/BugService.java

@@ -55,7 +55,7 @@ public PurchaseProductResponse purchaseBugProduct(Long memberId, Long productId,
 		Payment payment = PaymentMapper.toPayment(memberId, product);
 
 		if (!isNull(request.couponWalletId())) {
-			Coupon coupon = couponService.getByWallet(request.couponWalletId(), memberId);
+			Coupon coupon = couponService.getByWalletIdAndMemberId(request.couponWalletId(), memberId);
 			payment.applyCoupon(coupon, request.couponWalletId());
 		}
 		paymentRepository.save(payment);

src/main/java/com/moabam/api/application/coupon/CouponManageService.java

@@ -0,0 +1,91 @@
+package com.moabam.api.application.coupon;
+
+import java.time.LocalDate;
+import java.util.Optional;
+import java.util.Set;
+
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import com.moabam.api.domain.coupon.Coupon;
+import com.moabam.api.domain.coupon.CouponWallet;
+import com.moabam.api.domain.coupon.repository.CouponManageRepository;
+import com.moabam.api.domain.coupon.repository.CouponRepository;
+import com.moabam.api.domain.coupon.repository.CouponWalletRepository;
+import com.moabam.global.auth.model.AuthMember;
+import com.moabam.global.common.util.ClockHolder;
+import com.moabam.global.error.exception.BadRequestException;
+import com.moabam.global.error.model.ErrorMessage;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class CouponManageService {
+
+	private static final long ISSUE_SIZE = 10;
+
+	private final ClockHolder clockHolder;
+
+	private final CouponRepository couponRepository;
+	private final CouponManageRepository couponManageRepository;
+	private final CouponWalletRepository couponWalletRepository;
+
+	@Scheduled(fixedDelay = 1000)
+	public void issue() {
+		LocalDate now = LocalDate.from(clockHolder.times());
+		Optional<Coupon> isCoupon = couponRepository.findByStartAt(now);
+
+		if (!canIssue(isCoupon)) {
+			return;
+		}
+
+		Coupon coupon = isCoupon.get();
+		Set<Long> membersId = couponManageRepository.popMinQueue(coupon.getName(), ISSUE_SIZE);
+
+		membersId.forEach(memberId -> {
+			int nextStock = couponManageRepository.increaseIssuedStock(coupon.getName());
+
+			if (coupon.getStock() < nextStock) {
+				return;
+			}
+
+			CouponWallet couponWallet = CouponWallet.create(memberId, coupon);
+			couponWalletRepository.save(couponWallet);
+		});
+	}
+
+	public void register(AuthMember authMember, String couponName) {
+		double registerTime = System.currentTimeMillis();
+		validateRegister(couponName);
+		couponManageRepository.addIfAbsentQueue(couponName, authMember.id(), registerTime);
+	}
+
+	public void deleteCouponManage(String couponName) {
+		couponManageRepository.deleteQueue(couponName);
+		couponManageRepository.deleteIssuedStock(couponName);
+	}
+
+	private void validateRegister(String couponName) {
+		LocalDate now = LocalDate.from(clockHolder.times());
+		Optional<Coupon> coupon = couponRepository.findByStartAt(now);
+
+		if (coupon.isEmpty() || !coupon.get().getName().equals(couponName)) {
+			throw new BadRequestException(ErrorMessage.INVALID_COUPON_PERIOD);
+		}
+	}
+
+	private boolean canIssue(Optional<Coupon> coupon) {
+		if (coupon.isEmpty()) {
+			return false;
+		}
+
+		Coupon currentCoupon = coupon.get();
+		int currentStock = couponManageRepository.getIssuedStock(currentCoupon.getName());
+		int maxStock = currentCoupon.getStock();
+
+		return currentStock < maxStock;
+	}
+}

src/main/java/com/moabam/api/application/coupon/CouponMapper.java

@@ -2,8 +2,10 @@
 
 import com.moabam.api.domain.coupon.Coupon;
 import com.moabam.api.domain.coupon.CouponType;
+import com.moabam.api.domain.coupon.CouponWallet;
 import com.moabam.api.dto.coupon.CouponResponse;
 import com.moabam.api.dto.coupon.CreateCouponRequest;
+import com.moabam.api.dto.coupon.MyCouponResponse;
 
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
@@ -25,7 +27,7 @@ public static Coupon toEntity(Long adminId, CreateCouponRequest coupon) {
 	}
 
 	// TODO : Admin Table 생성 시, 관리자 명 추가할 예정
-	public static CouponResponse toDto(Coupon coupon) {
+	public static CouponResponse toResponse(Coupon coupon) {
 		return CouponResponse.builder()
 			.id(coupon.getId())
 			.adminName(coupon.getAdminId() + "admin")
@@ -38,4 +40,16 @@ public static CouponResponse toDto(Coupon coupon) {
 			.openAt(coupon.getOpenAt())
 			.build();
 	}
+
+	public static MyCouponResponse toMyResponse(CouponWallet couponWallet) {
+		Coupon coupon = couponWallet.getCoupon();
+
+		return MyCouponResponse.builder()
+			.id(coupon.getId())
+			.name(coupon.getName())
+			.description(coupon.getDescription())
+			.point(coupon.getPoint())
+			.type(coupon.getType())
+			.build();
+	}
 }

src/main/java/com/moabam/api/application/coupon/CouponService.java

@@ -7,13 +7,15 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import com.moabam.api.domain.coupon.Coupon;
+import com.moabam.api.domain.coupon.CouponWallet;
 import com.moabam.api.domain.coupon.repository.CouponRepository;
 import com.moabam.api.domain.coupon.repository.CouponSearchRepository;
 import com.moabam.api.domain.coupon.repository.CouponWalletSearchRepository;
 import com.moabam.api.domain.member.Role;
 import com.moabam.api.dto.coupon.CouponResponse;
 import com.moabam.api.dto.coupon.CouponStatusRequest;
 import com.moabam.api.dto.coupon.CreateCouponRequest;
+import com.moabam.api.dto.coupon.MyCouponResponse;
 import com.moabam.global.auth.model.AuthMember;
 import com.moabam.global.common.util.ClockHolder;
 import com.moabam.global.error.exception.BadRequestException;
@@ -28,15 +30,18 @@
 @Transactional(readOnly = true)
 public class CouponService {
 
+	private final ClockHolder clockHolder;
+	private final CouponManageService couponManageService;
+
 	private final CouponRepository couponRepository;
 	private final CouponSearchRepository couponSearchRepository;
 	private final CouponWalletSearchRepository couponWalletSearchRepository;
-	private final ClockHolder clockHolder;
 
 	@Transactional
 	public void create(AuthMember admin, CreateCouponRequest request) {
 		validateAdminRole(admin);
 		validateConflictName(request.name());
+		validateConflictStartAt(request.startAt());
 		validatePeriod(request.startAt(), request.openAt());
 
 		Coupon coupon = CouponMapper.toEntity(admin.id(), request);
@@ -49,40 +54,38 @@ public void delete(AuthMember admin, Long couponId) {
 		Coupon coupon = couponRepository.findById(couponId)
 			.orElseThrow(() -> new NotFoundException(ErrorMessage.NOT_FOUND_COUPON));
 		couponRepository.delete(coupon);
+		couponManageService.deleteCouponManage(coupon.getName());
 	}
 
 	public CouponResponse getById(Long couponId) {
 		Coupon coupon = couponRepository.findById(couponId)
 			.orElseThrow(() -> new NotFoundException(ErrorMessage.NOT_FOUND_COUPON));
 
-		return CouponMapper.toDto(coupon);
-	}
-
-	public Coupon getByWallet(Long couponWalletId, Long memberId) {
-		return couponWalletSearchRepository.findByIdAndMemberId(couponWalletId, memberId)
-			.orElseThrow(() -> new NotFoundException(ErrorMessage.NOT_FOUND_COUPON_WALLET))
-			.getCoupon();
+		return CouponMapper.toResponse(coupon);
 	}
 
 	public List<CouponResponse> getAllByStatus(CouponStatusRequest request) {
 		LocalDate now = LocalDate.from(clockHolder.times());
 		List<Coupon> coupons = couponSearchRepository.findAllByStatus(now, request);
 
 		return coupons.stream()
-			.map(CouponMapper::toDto)
+			.map(CouponMapper::toResponse)
 			.toList();
 	}
 
-	public Coupon validatePeriod(String couponName) {
-		LocalDate now = LocalDate.from(clockHolder.times());
-		Coupon coupon = couponRepository.findByName(couponName)
-			.orElseThrow(() -> new NotFoundException(ErrorMessage.NOT_FOUND_COUPON));
+	public List<MyCouponResponse> getWallet(Long couponId, AuthMember authMember) {
+		List<CouponWallet> couponWallets =
+			couponWalletSearchRepository.findAllByCouponIdAndMemberId(couponId, authMember.id());
 
-		if (!now.equals(coupon.getStartAt())) {
-			throw new BadRequestException(ErrorMessage.INVALID_COUPON_PERIOD);
-		}
+		return couponWallets.stream()
+			.map(CouponMapper::toMyResponse)
+			.toList();
+	}
 
-		return coupon;
+	public Coupon getByWalletIdAndMemberId(Long couponWalletId, Long memberId) {
+		return couponWalletSearchRepository.findByIdAndMemberId(couponWalletId, memberId)
+			.orElseThrow(() -> new NotFoundException(ErrorMessage.NOT_FOUND_COUPON_WALLET))
+			.getCoupon();
 	}
 
 	private void validatePeriod(LocalDate startAt, LocalDate openAt) {
@@ -108,4 +111,10 @@ private void validateConflictName(String couponName) {
 			throw new ConflictException(ErrorMessage.CONFLICT_COUPON_NAME);
 		}
 	}
+
+	private void validateConflictStartAt(LocalDate startAt) {
+		if (couponRepository.existsByStartAt(startAt)) {
+			throw new ConflictException(ErrorMessage.CONFLICT_COUPON_START_AT);
+		}
+	}
 }

src/main/java/com/moabam/api/application/notification/NotificationService.java

@@ -30,7 +30,6 @@ public class NotificationService {
 
 	private static final String KNOCK_BODY = "%s님이 콕 찔렀습니다.";
 	private static final String CERTIFY_TIME_BODY = "%s방 인증 시간입니다.";
-	private static final String KNOCK_KEY = "room_%s_member_%s_knocks_%s";
 
 	private final FcmService fcmService;
 	private final RoomService roomService;
@@ -41,13 +40,11 @@ public class NotificationService {
 	@Transactional
 	public void sendKnock(AuthMember member, Long targetId, Long roomId) {
 		roomService.validateRoomById(roomId);
-
-		String knockKey = generateKnockKey(member.id(), targetId, roomId);
-		validateConflictKnock(knockKey);
+		validateConflictKnock(member.id(), targetId, roomId);
 
 		String fcmToken = fcmService.findTokenByMemberId(targetId);
 		fcmService.sendAsync(fcmToken, String.format(KNOCK_BODY, member.nickname()));
-		notificationRepository.saveKnock(knockKey);
+		notificationRepository.saveKnock(member.id(), targetId, roomId);
 	}
 
 	@Scheduled(cron = "0 50 * * * *")
@@ -68,8 +65,8 @@ public List<Long> getMyKnockStatusInRoom(Long memberId, Long roomId, List<Partic
 			.filter(participant -> !participant.getMemberId().equals(memberId))
 			.toList();
 
-		Predicate<Long> knockPredicate = targetId
-			-> notificationRepository.existsKnockByKey(generateKnockKey(memberId, targetId, roomId));
+		Predicate<Long> knockPredicate = targetId ->
+			notificationRepository.existsKnockByKey(memberId, targetId, roomId);
 
 		Map<Boolean, List<Long>> knockStatus = filteredParticipants.stream()
 			.map(Participant::getMemberId)
@@ -78,13 +75,9 @@ public List<Long> getMyKnockStatusInRoom(Long memberId, Long roomId, List<Partic
 		return knockStatus.get(true);
 	}
 
-	private void validateConflictKnock(String knockKey) {
-		if (notificationRepository.existsKnockByKey(knockKey)) {
+	private void validateConflictKnock(Long memberId, Long targetId, Long roomId) {
+		if (notificationRepository.existsKnockByKey(memberId, targetId, roomId)) {
 			throw new ConflictException(ErrorMessage.CONFLICT_KNOCK);
 		}
 	}
-
-	private String generateKnockKey(Long memberId, Long targetId, Long roomId) {
-		return String.format(KNOCK_KEY, roomId, memberId, targetId);
-	}
 }

src/main/java/com/moabam/api/domain/coupon/Coupon.java

@@ -55,7 +55,7 @@ public class Coupon extends BaseTimeEntity {
 	@Column(name = "stock", nullable = false)
 	private int stock;
 
-	@Column(name = "start_at", nullable = false)
+	@Column(name = "start_at", unique = true, nullable = false)
 	private LocalDate startAt;
 
 	@Column(name = "open_at", nullable = false)

src/main/java/com/moabam/api/domain/coupon/CouponWallet.java

@@ -12,7 +12,6 @@
 import jakarta.persistence.ManyToOne;
 import jakarta.persistence.Table;
 import lombok.AccessLevel;
-import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
@@ -34,9 +33,12 @@ public class CouponWallet extends BaseTimeEntity {
 	@ManyToOne(fetch = FetchType.LAZY)
 	private Coupon coupon;
 
-	@Builder
 	private CouponWallet(Long memberId, Coupon coupon) {
 		this.memberId = memberId;
 		this.coupon = coupon;
 	}
+
+	public static CouponWallet create(Long memberId, Coupon coupon) {
+		return new CouponWallet(memberId, coupon);
+	}
 }