feature : owner 웨이팅 조회 API 구현

src/main/java/com/prgrms/catchtable/common/exception/ErrorCode.java

@@ -31,6 +31,7 @@ public enum ErrorCode {
     INTERNAL_SERVER_ERROR("내부 서버 오류입니다."),
 
     ALREADY_EXIST_OWNER("이미 존재하는 점주입니다"),
+    NOT_EXIST_OWNER("해당 아이디의 점주가 존재하지 않습니다."),
     BAD_REQUEST_EMAIL_OR_PASSWORD("이메일 혹은 비밀번호를 확인해주세요"),
     BAD_REQUEST_INPUT_GENDER_TYPE("성별 타입을 양식대로 입력해주세요");
 

src/main/java/com/prgrms/catchtable/waiting/controller/MemberWaitingController.java

@@ -1,7 +1,7 @@
 package com.prgrms.catchtable.waiting.controller;
 
-import com.prgrms.catchtable.waiting.dto.CreateWaitingRequest;
-import com.prgrms.catchtable.waiting.dto.WaitingResponse;
+import com.prgrms.catchtable.waiting.dto.request.CreateWaitingRequest;
+import com.prgrms.catchtable.waiting.dto.response.MemberWaitingResponse;
 import com.prgrms.catchtable.waiting.service.MemberWaitingService;
 import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
@@ -23,29 +23,32 @@ public class MemberWaitingController {
     private final MemberWaitingService memberWaitingService;
 
     @PostMapping("/{shopId}/{memberId}")
-    public ResponseEntity<WaitingResponse> createWaiting(@PathVariable("shopId") Long shopId,
+    public ResponseEntity<MemberWaitingResponse> createWaiting(@PathVariable("shopId") Long shopId,
         @PathVariable("memberId") Long memberId,
         @Valid @RequestBody CreateWaitingRequest request) {
-        WaitingResponse response = memberWaitingService.createWaiting(shopId, memberId, request);
+        MemberWaitingResponse response = memberWaitingService.createWaiting(shopId, memberId,
+            request);
         return ResponseEntity.ok(response);
     }
 
     @PatchMapping("/{memberId}")
-    public ResponseEntity<WaitingResponse> postponeWaiting(
+    public ResponseEntity<MemberWaitingResponse> postponeWaiting(
         @PathVariable("memberId") Long memberId) {
-        WaitingResponse response = memberWaitingService.postponeWaiting(memberId);
+        MemberWaitingResponse response = memberWaitingService.postponeWaiting(memberId);
         return ResponseEntity.ok(response);
     }
 
     @DeleteMapping("/{memberId}")
-    public ResponseEntity<WaitingResponse> cancelWaiting(@PathVariable("memberId") Long memberId) {
-        WaitingResponse response = memberWaitingService.cancelWaiting(memberId);
+    public ResponseEntity<MemberWaitingResponse> cancelWaiting(
+        @PathVariable("memberId") Long memberId) {
+        MemberWaitingResponse response = memberWaitingService.cancelWaiting(memberId);
         return ResponseEntity.ok(response);
     }
 
     @GetMapping("/{memberId}")
-    public ResponseEntity<WaitingResponse> getWaiting(@PathVariable("memberId") Long memberId) {
-        WaitingResponse response = memberWaitingService.getWaiting(memberId);
+    public ResponseEntity<MemberWaitingResponse> getWaiting(
+        @PathVariable("memberId") Long memberId) {
+        MemberWaitingResponse response = memberWaitingService.getWaiting(memberId);
         return ResponseEntity.ok(response);
     }
 }

src/main/java/com/prgrms/catchtable/waiting/controller/OwnerWaitingController.java

@@ -0,0 +1,25 @@
+package com.prgrms.catchtable.waiting.controller;
+
+import com.prgrms.catchtable.waiting.dto.response.OwnerWaitingListResponse;
+import com.prgrms.catchtable.waiting.service.OwnerWaitingService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RequiredArgsConstructor
+@RequestMapping("owner/waitings")
+@RestController
+public class OwnerWaitingController {
+
+    private final OwnerWaitingService ownerWaitingService;
+
+    @GetMapping("/{ownerId}")
+    public ResponseEntity<OwnerWaitingListResponse> getOwnerAllWaiting(
+        @PathVariable("ownerId") Long ownerId) {
+        OwnerWaitingListResponse response = ownerWaitingService.getOwnerAllWaiting(ownerId);
+        return ResponseEntity.ok(response);
+    }
+}

src/main/java/com/prgrms/catchtable/waiting/dto/WaitingMapper.java

@@ -5,6 +5,12 @@
 import com.prgrms.catchtable.member.domain.Member;
 import com.prgrms.catchtable.shop.domain.Shop;
 import com.prgrms.catchtable.waiting.domain.Waiting;
+import com.prgrms.catchtable.waiting.dto.request.CreateWaitingRequest;
+import com.prgrms.catchtable.waiting.dto.response.MemberWaitingResponse;
+import com.prgrms.catchtable.waiting.dto.response.OwnerWaitingListResponse;
+import com.prgrms.catchtable.waiting.dto.response.OwnerWaitingResponse;
+import java.util.ArrayList;
+import java.util.List;
 import lombok.NoArgsConstructor;
 
 @NoArgsConstructor(access = PRIVATE)
@@ -21,8 +27,8 @@ public static Waiting toWaiting(CreateWaitingRequest request, int waitingNumber,
     }
 
     // entity -> dto
-    public static WaitingResponse toWaitingResponse(Waiting waiting, Long rank) {
-        return WaitingResponse.builder()
+    public static MemberWaitingResponse toWaitingResponse(Waiting waiting, Long rank) {
+        return MemberWaitingResponse.builder()
             .waitingId(waiting.getId())
             .shopId(waiting.getShop().getId())
             .shopName(waiting.getShop().getName())
@@ -33,4 +39,22 @@ public static WaitingResponse toWaitingResponse(Waiting waiting, Long rank) {
             .status(waiting.getStatus().getDescription())
             .build();
     }
+
+    public static OwnerWaitingResponse toOwnerWaitingResponse(Waiting waiting, Long rank) {
+        return OwnerWaitingResponse.builder()
+            .waitingId(waiting.getId())
+            .waitingNumber(waiting.getWaitingNumber())
+            .rank(rank)
+            .peopleCount(waiting.getPeopleCount())
+            .build();
+    }
+
+    public static OwnerWaitingListResponse toOwnerWaitingListResponse(List<Waiting> waitings) {
+        long rank = 1L;
+        List<OwnerWaitingResponse> list = new ArrayList<>();
+        for (Waiting waiting : waitings) {
+            list.add(toOwnerWaitingResponse(waiting, rank++));
+        }
+        return new OwnerWaitingListResponse(list);
+    }
 }

src/main/java/com/prgrms/catchtable/waiting/dto/CreateWaitingRequest.java → src/main/java/com/prgrms/catchtable/waiting/dto/request/CreateWaitingRequest.java

@@ -1,4 +1,4 @@
-package com.prgrms.catchtable.waiting.dto;
+package com.prgrms.catchtable.waiting.dto.request;
 
 import jakarta.validation.constraints.Positive;
 import lombok.Builder;

src/main/java/com/prgrms/catchtable/waiting/dto/WaitingResponse.java → src/main/java/com/prgrms/catchtable/waiting/dto/response/MemberWaitingResponse.java

@@ -1,9 +1,9 @@
-package com.prgrms.catchtable.waiting.dto;
+package com.prgrms.catchtable.waiting.dto.response;
 
 import lombok.Builder;
 
 @Builder
-public record WaitingResponse(
+public record MemberWaitingResponse(
     Long waitingId,
     Long shopId,
     String shopName,

src/main/java/com/prgrms/catchtable/waiting/dto/response/OwnerWaitingListResponse.java

@@ -0,0 +1,11 @@
+package com.prgrms.catchtable.waiting.dto.response;
+
+import java.util.List;
+import lombok.Builder;
+
+@Builder
+public record OwnerWaitingListResponse(
+    List<OwnerWaitingResponse> shopWaitings
+) {
+
+}

src/main/java/com/prgrms/catchtable/waiting/dto/response/OwnerWaitingResponse.java

@@ -0,0 +1,13 @@
+package com.prgrms.catchtable.waiting.dto.response;
+
+import lombok.Builder;
+
+@Builder
+public record OwnerWaitingResponse(
+    Long waitingId,
+    int waitingNumber,
+    Long rank,
+    int peopleCount
+) {
+
+}

src/main/java/com/prgrms/catchtable/waiting/repository/WaitingRepository.java

@@ -5,6 +5,7 @@
 import com.prgrms.catchtable.waiting.domain.Waiting;
 import com.prgrms.catchtable.waiting.domain.WaitingStatus;
 import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
@@ -20,4 +21,10 @@ public interface WaitingRepository extends JpaRepository<Waiting, Long> {
         + "where w.member = :member and w.status = :status")
     Optional<Waiting> findByMemberAndStatusWithShop(@Param("member") Member member,
         @Param("status") WaitingStatus status);
+
+    @Query("select w from Waiting w where w.id in :ids")
+    List<Waiting> findByIds(@Param("ids") List<Long> ids);
+
+    @Query("select w from Waiting w join fetch w.member where w.id = :id")
+    Optional<Waiting> findWaitingWithMember(@Param("id") Long id);
 }

src/main/java/com/prgrms/catchtable/waiting/repository/waitingline/BasicWaitingLineRepository.java

@@ -7,6 +7,7 @@
 import com.prgrms.catchtable.common.exception.custom.BadRequestCustomException;
 import com.prgrms.catchtable.common.exception.custom.NotFoundCustomException;
 import java.util.LinkedList;
+import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Queue;
@@ -33,6 +34,11 @@ public void entry(Long shopId, Long waitingId) {
         waitingLine.remove();
     }
 
+    public List<Long> getShopWaitingIdsInOrder(Long shopId) {
+        Queue<Long> waitingLine = waitingLines.get(shopId);
+        return waitingLine.stream().toList();
+    }
+
     public void cancel(Long shopId, Long waitingId) {
         Queue<Long> waitingLine = waitingLines.get(shopId);
         validateIfWaitingExists(waitingLine, waitingId);

src/main/java/com/prgrms/catchtable/waiting/repository/waitingline/RedisWaitingLineRepository.java

@@ -5,6 +5,8 @@
 
 import com.prgrms.catchtable.common.exception.custom.BadRequestCustomException;
 import com.prgrms.catchtable.common.exception.custom.NotFoundCustomException;
+import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
 import lombok.RequiredArgsConstructor;
@@ -41,6 +43,18 @@ public <K, V> Object execute(RedisOperations<K, V> operations)
         });
     }
 
+    public List<Long> getShopWaitingIdsInOrder(Long shopId) {
+        List<String> stringList = redisTemplate.opsForList().range("s" + shopId, 0, -1);
+        if (stringList == null) {
+            throw new BadRequestCustomException(WAITING_DOES_NOT_EXIST);
+        }
+        List<Long> longList = new ArrayList<>(stringList.stream()
+            .map(Long::parseLong)
+            .toList());
+        Collections.reverse(longList);
+        return longList;
+    }
+
     public void entry(Long shopId, Long waitingId) {
         validateIfWaitingExists(shopId, waitingId);
         redisTemplate.execute(new SessionCallback<>() {

src/main/java/com/prgrms/catchtable/waiting/repository/waitingline/WaitingLineRepository.java

@@ -1,5 +1,7 @@
 package com.prgrms.catchtable.waiting.repository.waitingline;
 
+import java.util.List;
+
 public interface WaitingLineRepository {
 
     void save(Long shopId, Long waitingId);
@@ -14,5 +16,7 @@ public interface WaitingLineRepository {
 
     Long getWaitingLineSize(Long shopId);
 
+    List<Long> getShopWaitingIdsInOrder(Long shopId);
+
     void printWaitingLine(Long shopId);
 }

src/main/java/com/prgrms/catchtable/waiting/service/MemberWaitingService.java

@@ -15,8 +15,8 @@
 import com.prgrms.catchtable.shop.domain.Shop;
 import com.prgrms.catchtable.shop.repository.ShopRepository;
 import com.prgrms.catchtable.waiting.domain.Waiting;
-import com.prgrms.catchtable.waiting.dto.CreateWaitingRequest;
-import com.prgrms.catchtable.waiting.dto.WaitingResponse;
+import com.prgrms.catchtable.waiting.dto.request.CreateWaitingRequest;
+import com.prgrms.catchtable.waiting.dto.response.MemberWaitingResponse;
 import com.prgrms.catchtable.waiting.repository.WaitingRepository;
 import com.prgrms.catchtable.waiting.repository.waitingline.WaitingLineRepository;
 import java.time.LocalDate;
@@ -39,7 +39,7 @@ public class MemberWaitingService {
     private final ShopRepository shopRepository;
     private final WaitingLineRepository waitingLineRepository;
 
-    public WaitingResponse createWaiting(Long shopId, Long memberId,
+    public MemberWaitingResponse createWaiting(Long shopId, Long memberId,
         CreateWaitingRequest request) {
         // 연관 엔티티 조회
         Member member = getMemberEntity(memberId);
@@ -63,7 +63,7 @@ public WaitingResponse createWaiting(Long shopId, Long memberId,
     }
 
     @Transactional
-    public WaitingResponse postponeWaiting(Long memberId) {
+    public MemberWaitingResponse postponeWaiting(Long memberId) {
         Member member = getMemberEntity(memberId);
         Waiting waiting = getWaitingEntityInProgress(member);
 
@@ -77,7 +77,7 @@ public WaitingResponse postponeWaiting(Long memberId) {
     }
 
     @Transactional
-    public WaitingResponse cancelWaiting(Long memberId) {
+    public MemberWaitingResponse cancelWaiting(Long memberId) {
         Member member = getMemberEntity(memberId);
         Waiting waiting = getWaitingEntityInProgress(member);
 
@@ -89,7 +89,7 @@ public WaitingResponse cancelWaiting(Long memberId) {
     }
 
     @Transactional(readOnly = true)
-    public WaitingResponse getWaiting(Long memberId) {
+    public MemberWaitingResponse getWaiting(Long memberId) {
         Member member = getMemberEntity(memberId);
         Waiting waiting = getWaitingEntityInProgress(member);
 

src/main/java/com/prgrms/catchtable/waiting/service/OwnerWaitingService.java

@@ -0,0 +1,35 @@
+package com.prgrms.catchtable.waiting.service;
+
+import static com.prgrms.catchtable.common.exception.ErrorCode.NOT_EXIST_OWNER;
+import static com.prgrms.catchtable.waiting.dto.WaitingMapper.toOwnerWaitingListResponse;
+
+import com.prgrms.catchtable.common.exception.custom.BadRequestCustomException;
+import com.prgrms.catchtable.owner.domain.Owner;
+import com.prgrms.catchtable.owner.repository.OwnerRepository;
+import com.prgrms.catchtable.waiting.domain.Waiting;
+import com.prgrms.catchtable.waiting.dto.response.OwnerWaitingListResponse;
+import com.prgrms.catchtable.waiting.repository.WaitingRepository;
+import com.prgrms.catchtable.waiting.repository.waitingline.WaitingLineRepository;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@RequiredArgsConstructor
+@Service
+public class OwnerWaitingService {
+
+    private final WaitingRepository waitingRepository;
+    private final WaitingLineRepository waitingLineRepository;
+    private final OwnerRepository ownerRepository;
+
+    @Transactional(readOnly = true)
+    public OwnerWaitingListResponse getOwnerAllWaiting(Long ownerId) {
+        Owner owner = ownerRepository.findById(ownerId)
+            .orElseThrow(() -> new BadRequestCustomException(NOT_EXIST_OWNER));
+        List<Long> waitingIds = waitingLineRepository.getShopWaitingIdsInOrder(
+            owner.getShop().getId());
+        List<Waiting> waitings = waitingRepository.findByIds(waitingIds);
+        return toOwnerWaitingListResponse(waitings);
+    }
+}

src/test/java/com/prgrms/catchtable/owner/fixture/OwnerFixture.java

@@ -1,16 +1,15 @@
 package com.prgrms.catchtable.owner.fixture;
 
+import static com.prgrms.catchtable.member.domain.Gender.MALE;
+
 import com.prgrms.catchtable.common.data.shop.ShopData;
-import com.prgrms.catchtable.member.domain.Gender;
 import com.prgrms.catchtable.owner.domain.Owner;
 import com.prgrms.catchtable.owner.dto.request.JoinOwnerRequest;
 import com.prgrms.catchtable.owner.dto.request.LoginOwnerRequest;
 import com.prgrms.catchtable.shop.domain.Shop;
 import java.time.LocalDate;
 import org.springframework.test.util.ReflectionTestUtils;
 
-import static com.prgrms.catchtable.member.domain.Gender.MALE;
-
 
 public class OwnerFixture {
 
@@ -29,7 +28,21 @@ public static Owner getOwner(String email, String password) {
         return owner;
     }
 
-    public static JoinOwnerRequest getJoinOwnerRequest(String email, String password){
+    public static Owner getOwner(Shop shop) {
+        Owner owner = Owner.builder()
+            .name("ownerA")
+            .email("email")
+            .password("password")
+            .phoneNumber("010-3462-2480")
+            .gender(MALE)
+            .dateBirth(LocalDate.of(2000, 9, 13))
+            .build();
+        ReflectionTestUtils.setField(shop, "id", 1L);
+        owner.insertShop(shop);
+        return owner;
+    }
+
+    public static JoinOwnerRequest getJoinOwnerRequest(String email, String password) {
         return JoinOwnerRequest.builder()
             .name("ownerA")
             .email(email)
@@ -40,7 +53,7 @@ public static JoinOwnerRequest getJoinOwnerRequest(String email, String password
             .build();
     }
 
-    public static LoginOwnerRequest getLoginOwnerRequest(String email, String password){
+    public static LoginOwnerRequest getLoginOwnerRequest(String email, String password) {
         return LoginOwnerRequest.builder()
             .email(email)
             .password(password)