refactor: 어드민 유저 리팩토링

src/main/java/in/koreatech/koin/admin/owner/controller/AdminOwnerApi.java

@@ -0,0 +1,112 @@
+package in.koreatech.koin.admin.owner.controller;
+
+import static in.koreatech.koin.domain.user.model.UserType.ADMIN;
+
+import org.springdoc.core.annotations.ParameterObject;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import in.koreatech.koin.admin.owner.dto.AdminNewOwnersResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerUpdateRequest;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerUpdateResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnersResponse;
+import in.koreatech.koin.admin.owner.dto.OwnersCondition;
+import in.koreatech.koin.global.auth.Auth;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
+import io.swagger.v3.oas.annotations.security.SecurityRequirement;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+
+@Tag(name = "(Admin) Owner: 사장님", description = "관리자 권한으로 사장님 정보를 관리한다")
+public interface AdminOwnerApi {
+
+    @ApiResponses(
+        value = {
+            @ApiResponse(responseCode = "200"),
+            @ApiResponse(responseCode = "401", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "403", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "404", content = @Content(schema = @Schema(hidden = true))),
+        }
+    )
+    @Operation(summary = "사장님 권한 요청 허용")
+    @SecurityRequirement(name = "Jwt Authentication")
+    @PutMapping("/admin/owner/{id}/authed")
+    ResponseEntity<Void> allowOwnerPermission(
+        @PathVariable Integer id,
+        @Auth(permit = {ADMIN}) Integer adminId
+    );
+
+    @ApiResponses(
+        value = {
+            @ApiResponse(responseCode = "200"),
+            @ApiResponse(responseCode = "401", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "403", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "404", content = @Content(schema = @Schema(hidden = true))),
+        }
+    )
+    @Operation(summary = "특정 사장님 조회")
+    @SecurityRequirement(name = "Jwt Authentication")
+    @GetMapping("/admin/users/owner/{id}")
+    ResponseEntity<AdminOwnerResponse> getOwner(
+        @PathVariable Integer id,
+        @Auth(permit = {ADMIN}) Integer adminId
+    );
+
+    @ApiResponses(
+        value = {
+            @ApiResponse(responseCode = "200"),
+            @ApiResponse(responseCode = "401", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "403", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "404", content = @Content(schema = @Schema(hidden = true))),
+        }
+    )
+    @Operation(summary = "특정 사장님 수정")
+    @SecurityRequirement(name = "Jwt Authentication")
+    @PutMapping("/admin/users/owner/{id}")
+    ResponseEntity<AdminOwnerUpdateResponse> updateOwner(
+        @PathVariable Integer id,
+        @RequestBody @Valid AdminOwnerUpdateRequest request,
+        @Auth(permit = {ADMIN}) Integer adminId
+    );
+
+    @ApiResponses(
+        value = {
+            @ApiResponse(responseCode = "200"),
+            @ApiResponse(responseCode = "401", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "403", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "404", content = @Content(schema = @Schema(hidden = true)))
+        }
+    )
+    @Operation(summary = "가입 신청한 사장님 리스트 조회 (페이지네이션)")
+    @SecurityRequirement(name = "Jwt Authentication")
+    @GetMapping("/admin/users/new-owners")
+    ResponseEntity<AdminNewOwnersResponse> getNewOwners(
+        @ParameterObject @ModelAttribute OwnersCondition ownersCondition,
+        @Auth(permit = {ADMIN}) Integer adminId
+    );
+
+    @ApiResponses(
+        value = {
+            @ApiResponse(responseCode = "200"),
+            @ApiResponse(responseCode = "401", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "403", content = @Content(schema = @Schema(hidden = true))),
+            @ApiResponse(responseCode = "404", content = @Content(schema = @Schema(hidden = true)))
+        }
+    )
+    @Operation(summary = "사장 리스트 조회 (페이지네이션)")
+    @SecurityRequirement(name = "Jwt Authentication")
+    @GetMapping("/admin/users/owners")
+    ResponseEntity<AdminOwnersResponse> getOwners(
+        @ParameterObject @ModelAttribute OwnersCondition ownersCondition,
+        @Auth(permit = {ADMIN}) Integer adminId
+    );
+}

src/main/java/in/koreatech/koin/admin/owner/controller/AdminOwnerController.java

@@ -0,0 +1,73 @@
+package in.koreatech.koin.admin.owner.controller;
+
+import static in.koreatech.koin.domain.user.model.UserType.ADMIN;
+
+import org.springdoc.core.annotations.ParameterObject;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import in.koreatech.koin.admin.owner.service.AdminOwnerService;
+import in.koreatech.koin.admin.owner.dto.AdminNewOwnersResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerUpdateRequest;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerUpdateResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnersResponse;
+import in.koreatech.koin.admin.owner.dto.OwnersCondition;
+import in.koreatech.koin.global.auth.Auth;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequiredArgsConstructor
+public class AdminOwnerController implements AdminOwnerApi{
+
+    private final AdminOwnerService adminOwnerService;
+
+    @PutMapping("/admin/owner/{id}/authed")
+    public ResponseEntity<Void> allowOwnerPermission(
+        @PathVariable Integer id,
+        @Auth(permit = {ADMIN}) Integer adminId) {
+        adminOwnerService.allowOwnerPermission(id);
+        return ResponseEntity.ok().build();
+    }
+
+    @GetMapping("/admin/users/owner/{id}")
+    public ResponseEntity<AdminOwnerResponse> getOwner(
+        @PathVariable Integer id,
+        @Auth(permit = {ADMIN}) Integer adminId
+    ) {
+        AdminOwnerResponse response = adminOwnerService.getOwner(id);
+        return ResponseEntity.ok().body(response);
+    }
+
+    @PutMapping("/admin/users/owner/{id}")
+    public ResponseEntity<AdminOwnerUpdateResponse> updateOwner(
+        @PathVariable Integer id,
+        @RequestBody @Valid AdminOwnerUpdateRequest request,
+        @Auth(permit = {ADMIN}) Integer adminId
+    ) {
+        AdminOwnerUpdateResponse response = adminOwnerService.updateOwner(id, request);
+        return ResponseEntity.ok().body(response);
+    }
+
+    @GetMapping("/admin/users/new-owners")
+    public ResponseEntity<AdminNewOwnersResponse> getNewOwners(
+        @ParameterObject @ModelAttribute OwnersCondition ownersCondition,
+        @Auth(permit = {ADMIN}) Integer adminId
+    ) {
+        return ResponseEntity.ok().body(adminOwnerService.getNewOwners(ownersCondition));
+    }
+
+    @GetMapping("/admin/users/owners")
+    public ResponseEntity<AdminOwnersResponse> getOwners(
+        @ParameterObject @ModelAttribute OwnersCondition ownersCondition,
+        @Auth(permit = {ADMIN}) Integer adminId
+    ) {
+        return ResponseEntity.ok().body(adminOwnerService.getOwners(ownersCondition));
+    }
+}

src/main/java/in/koreatech/koin/admin/user/dto/AdminNewOwnersResponse.java → src/main/java/in/koreatech/koin/admin/owner/dto/AdminNewOwnersResponse.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.dto;
+package in.koreatech.koin.admin.owner.dto;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.REQUIRED;

src/main/java/in/koreatech/koin/admin/user/dto/AdminOwnerResponse.java → src/main/java/in/koreatech/koin/admin/owner/dto/AdminOwnerResponse.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.dto;
+package in.koreatech.koin.admin.owner.dto;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.REQUIRED;
@@ -7,16 +7,12 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
-import org.springframework.data.domain.Page;
-
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.databind.PropertyNamingStrategies.SnakeCaseStrategy;
 import com.fasterxml.jackson.databind.annotation.JsonNaming;
 
 import in.koreatech.koin.domain.owner.model.Owner;
 import in.koreatech.koin.domain.owner.model.OwnerAttachment;
-import in.koreatech.koin.domain.owner.model.OwnerIncludingShop;
-import in.koreatech.koin.global.model.Criteria;
 import io.swagger.v3.oas.annotations.media.Schema;
 
 @JsonNaming(value = SnakeCaseStrategy.class)

src/main/java/in/koreatech/koin/admin/user/dto/AdminOwnerUpdateRequest.java → src/main/java/in/koreatech/koin/admin/owner/dto/AdminOwnerUpdateRequest.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.dto;
+package in.koreatech.koin.admin.owner.dto;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 

src/main/java/in/koreatech/koin/admin/user/dto/AdminOwnerUpdateResponse.java → src/main/java/in/koreatech/koin/admin/owner/dto/AdminOwnerUpdateResponse.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.dto;
+package in.koreatech.koin.admin.owner.dto;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 

src/main/java/in/koreatech/koin/admin/user/dto/AdminOwnersResponse.java → src/main/java/in/koreatech/koin/admin/owner/dto/AdminOwnersResponse.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.dto;
+package in.koreatech.koin.admin.owner.dto;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.REQUIRED;

src/main/java/in/koreatech/koin/admin/user/dto/OwnersCondition.java → src/main/java/in/koreatech/koin/admin/owner/dto/OwnersCondition.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.dto;
+package in.koreatech.koin.admin.owner.dto;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 

src/main/java/in/koreatech/koin/admin/user/repository/AdminOwnerRepository.java → src/main/java/in/koreatech/koin/admin/owner/repository/AdminOwnerRepository.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.repository;
+package in.koreatech.koin.admin.owner.repository;
 
 import java.util.Optional;
 

src/main/java/in/koreatech/koin/admin/user/repository/AdminOwnerShopRedisRepository.java → src/main/java/in/koreatech/koin/admin/owner/repository/AdminOwnerShopRedisRepository.java

@@ -1,4 +1,4 @@
-package in.koreatech.koin.admin.user.repository;
+package in.koreatech.koin.admin.owner.repository;
 
 import java.util.Optional;
 

src/main/java/in/koreatech/koin/admin/owner/service/AdminOwnerService.java

@@ -0,0 +1,139 @@
+package in.koreatech.koin.admin.owner.service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import in.koreatech.koin.admin.owner.repository.AdminOwnerRepository;
+import in.koreatech.koin.admin.owner.repository.AdminOwnerShopRedisRepository;
+import in.koreatech.koin.admin.shop.repository.shop.AdminShopRepository;
+import in.koreatech.koin.admin.owner.dto.AdminNewOwnersResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerUpdateRequest;
+import in.koreatech.koin.admin.owner.dto.AdminOwnerUpdateResponse;
+import in.koreatech.koin.admin.owner.dto.AdminOwnersResponse;
+import in.koreatech.koin.admin.owner.dto.OwnersCondition;
+import in.koreatech.koin.admin.user.repository.AdminUserRepository;
+import in.koreatech.koin.domain.owner.model.Owner;
+import in.koreatech.koin.domain.owner.model.OwnerIncludingShop;
+import in.koreatech.koin.domain.shop.model.shop.Shop;
+import in.koreatech.koin.domain.user.model.UserType;
+import in.koreatech.koin.global.model.Criteria;
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class AdminOwnerService {
+
+    private final AdminOwnerRepository adminOwnerRepository;
+    private final AdminOwnerShopRedisRepository adminOwnerShopRedisRepository;
+    private final AdminShopRepository adminShopRepository;
+    private final AdminUserRepository adminUserRepository;
+
+    @Transactional
+    public void allowOwnerPermission(Integer id) {
+        Owner owner = adminOwnerRepository.getById(id);
+        owner.getUser().auth();
+        adminOwnerShopRedisRepository.findById(id).ifPresent(ownerShop -> {
+            Integer shopId = ownerShop.getShopId();
+            if (shopId != null) {
+                Shop shop = adminShopRepository.getById(shopId);
+                shop.updateOwner(owner);
+                owner.setGrantShop(true);
+            }
+            adminOwnerShopRedisRepository.deleteById(id);
+        });
+    }
+
+    public AdminOwnerResponse getOwner(Integer ownerId) {
+        Owner owner = adminOwnerRepository.getById(ownerId);
+
+        List<Integer> shopsId = adminShopRepository.findAllByOwnerId(ownerId)
+            .stream()
+            .map(Shop::getId)
+            .toList();
+
+        return AdminOwnerResponse.of(owner, shopsId);
+    }
+
+    @Transactional
+    public AdminOwnerUpdateResponse updateOwner(Integer ownerId, AdminOwnerUpdateRequest request) {
+        Owner owner = adminOwnerRepository.getById(ownerId);
+        owner.update(request);
+        return AdminOwnerUpdateResponse.from(owner);
+    }
+
+    public AdminNewOwnersResponse getNewOwners(OwnersCondition ownersCondition) {
+        ownersCondition.checkDataConstraintViolation();
+
+        Integer totalOwners = adminUserRepository.findUsersCountByUserTypeAndIsAuthed(UserType.OWNER, false);
+        Criteria criteria = Criteria.of(ownersCondition.page(), ownersCondition.limit(), totalOwners);
+        Sort.Direction direction = ownersCondition.getDirection();
+
+        Page<Owner> result = getNewOwnersResultPage(ownersCondition, criteria, direction);
+
+        List<OwnerIncludingShop> ownerIncludingShops = new ArrayList<>();
+        for (Owner owner : result.getContent()) {
+            Shop shop = adminOwnerShopRedisRepository.findById(owner.getId())
+                .map(ownerShop -> adminShopRepository.findById(ownerShop.getShopId()).orElse(null))
+                .orElse(null);
+
+            OwnerIncludingShop ownerIncludingShop = OwnerIncludingShop.of(owner, shop);
+            ownerIncludingShops.add(ownerIncludingShop);
+        }
+
+        return AdminNewOwnersResponse.of(ownerIncludingShops, result, criteria);
+    }
+
+    public AdminOwnersResponse getOwners(OwnersCondition ownersCondition) {
+        ownersCondition.checkDataConstraintViolation();
+
+        Integer totalOwners = adminUserRepository.findUsersCountByUserTypeAndIsAuthed(UserType.OWNER, true);
+        Criteria criteria = Criteria.of(ownersCondition.page(), ownersCondition.limit(), totalOwners);
+        Sort.Direction direction = ownersCondition.getDirection();
+
+        Page<Owner> result = getOwnersResultPage(ownersCondition, criteria, direction);
+
+        return AdminOwnersResponse.of(result, criteria);
+    }
+
+    private Page<Owner> getNewOwnersResultPage(OwnersCondition ownersCondition, Criteria criteria,
+        Sort.Direction direction) {
+        PageRequest pageRequest = PageRequest.of(
+            criteria.getPage(),
+            criteria.getLimit(),
+            Sort.by(direction, "user.createdAt")
+        );
+
+        if (ownersCondition.searchType() == OwnersCondition.SearchType.EMAIL) {
+            return adminOwnerRepository.findPageUnauthenticatedOwnersByEmail(ownersCondition.query(), pageRequest);
+        }
+        if (ownersCondition.searchType() == OwnersCondition.SearchType.NAME) {
+            return adminOwnerRepository.findPageUnauthenticatedOwnersByName(ownersCondition.query(), pageRequest);
+        }
+        return adminOwnerRepository.findPageUnauthenticatedOwners(pageRequest);
+    }
+
+    private Page<Owner> getOwnersResultPage(OwnersCondition ownersCondition, Criteria criteria,
+        Sort.Direction direction) {
+        PageRequest pageRequest = PageRequest.of(
+            criteria.getPage(),
+            criteria.getLimit(),
+            Sort.by(direction, "user.createdAt")
+        );
+
+        if (ownersCondition.searchType() == OwnersCondition.SearchType.EMAIL) {
+            return adminOwnerRepository.findPageOwnersByEmail(ownersCondition.query(), pageRequest);
+        }
+        if (ownersCondition.searchType() == OwnersCondition.SearchType.NAME) {
+            return adminOwnerRepository.findPageOwnersByName(ownersCondition.query(), pageRequest);
+        }
+        return adminOwnerRepository.findPageOwners(pageRequest);
+    }
+}