#18 menu crud 및 메뉴 이미지 업로드 구현

build.gradle

@@ -51,6 +51,14 @@ dependencies {
     // Validation
     implementation 'org.springframework.boot:spring-boot-starter-validation'
 
+    // S3
+    implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
+    // Resilience4j
+    implementation 'io.github.resilience4j:resilience4j-spring-boot2:1.7.1'
+    implementation 'io.github.resilience4j:resilience4j-bulkhead:1.7.1'
+    // 비동기 실행
+    implementation 'org.springframework.boot:spring-boot-starter-aop'
+
     testImplementation 'org.springframework.security:spring-security-test'
     testImplementation 'org.awaitility:awaitility:4.3.0'
     testImplementation 'com.h2database:h2'

src/main/java/com/example/gtable/global/config/AsyncConfig.java

@@ -0,0 +1,21 @@
+package com.example.gtable.global.config;
+
+import java.util.concurrent.Executor;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+public class AsyncConfig {
+	@Bean(name = "s3UploadExecutor")
+	public Executor s3UploadExecutor() {
+		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+		executor.setCorePoolSize(5);
+		executor.setMaxPoolSize(10);
+		executor.setQueueCapacity(100);
+		executor.setThreadNamePrefix("S3Upload-");
+		executor.initialize();
+		return executor;
+	}
+}

src/main/java/com/example/gtable/global/config/AwsS3Config.java

@@ -0,0 +1,33 @@
+package com.example.gtable.global.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.services.s3.AmazonS3Client;
+import com.amazonaws.services.s3.AmazonS3ClientBuilder;
+
+@Configuration
+public class AwsS3Config {
+
+	@Value("${cloud.aws.credentials.access-key}")
+	private String accessKey;
+
+	@Value("${cloud.aws.credentials.secret-key}")
+	private String secretKey;
+
+	@Value("${cloud.aws.region.static}")
+	private String region;
+
+	@Bean
+	public AmazonS3Client amazonS3Client() {
+		BasicAWSCredentials awsCredentials = new BasicAWSCredentials(accessKey, secretKey);
+		return (AmazonS3Client)AmazonS3ClientBuilder.standard()
+			.withRegion(region)
+			.withCredentials(new AWSStaticCredentialsProvider(awsCredentials))
+			.build();
+	}
+
+}

src/main/java/com/example/gtable/global/config/SecurityConfig.java

@@ -51,7 +51,9 @@ public SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
 				.requestMatchers(
 					"/oauth2/authorization/kakao", // 카카오 로그인 요청
 					"/login/oauth2/code/**", // 카카오 인증 콜백
-					"/api/refresh-token")  // refresh token (토큰 갱신)
+					"/api/refresh-token", // refresh token (토큰 갱신)
+					"/stores/**",
+					"/menus/**")
 				.permitAll()
 				.anyRequest().authenticated() // 그외 요청은 허가된 사람만 인가
 			)

src/main/java/com/example/gtable/global/s3/S3Service.java

@@ -0,0 +1,57 @@
+package com.example.gtable.global.s3;
+
+import java.io.InputStream;
+import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import com.amazonaws.services.s3.AmazonS3Client;
+import com.amazonaws.services.s3.model.ObjectMetadata;
+
+import io.github.resilience4j.bulkhead.annotation.Bulkhead;
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class S3Service {
+	private final AmazonS3Client amazonS3Client;
+
+	@Value("${cloud.aws.s3.bucket}")
+	private String bucket;
+
+	public record S3UploadResult(String key, String url) {
+	}
+
+	@Bulkhead(name = "s3UploadBulkhead", type = Bulkhead.Type.THREADPOOL)
+	@Async("s3UploadExecutor")
+	public CompletableFuture<S3UploadResult> upload(String type, Long refId, MultipartFile file) {
+		try (InputStream inputStream = file.getInputStream()) {
+			String key = createFileKey(type, refId, file.getOriginalFilename());
+			ObjectMetadata metadata = new ObjectMetadata();
+			metadata.setContentLength(file.getSize());
+
+			amazonS3Client.putObject(bucket, key, inputStream, metadata);
+			String url = amazonS3Client.getUrl(bucket, key).toString();
+
+			return CompletableFuture.completedFuture(new S3UploadResult(key, url));
+		} catch (Exception e) {
+			throw new RuntimeException("S3 업로드 실패", e);
+		}
+	}
+
+	public void delete(String filename) {
+		try {
+			amazonS3Client.deleteObject(bucket, filename);
+		} catch (Exception e) {
+			throw new RuntimeException("S3 파일 삭제 실패", e);
+		}
+	}
+
+	private String createFileKey(String type, Long refId, String filename) {
+		return type + "/" + refId + "/" + UUID.randomUUID() + "-" + filename;
+	}
+}

src/main/java/com/example/gtable/menu/controller/MenuController.java

@@ -0,0 +1,50 @@
+package com.example.gtable.menu.controller;
+
+import org.springframework.http.HttpStatus;
+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.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.example.gtable.global.api.ApiUtils;
+import com.example.gtable.menu.dto.MenuCreateRequest;
+import com.example.gtable.menu.dto.MenuCreateResponse;
+import com.example.gtable.menu.service.MenuService;
+
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequestMapping("/menus")
+@RequiredArgsConstructor
+public class MenuController {
+
+	private final MenuService menuService;
+
+	@PostMapping("/create")
+	public ResponseEntity<?> createMenu(@Valid @RequestBody MenuCreateRequest request) {
+		MenuCreateResponse response = menuService.createMenu(request);
+
+		return ResponseEntity
+			.status(HttpStatus.CREATED)
+			.body(
+				ApiUtils.success(
+					response
+				)
+			);
+	}
+
+	@GetMapping("/{storeId}")
+	public ResponseEntity<?> getMenusByStoreId(@PathVariable Long storeId) {
+		return ResponseEntity
+			.status(HttpStatus.OK)
+			.body(
+				ApiUtils.success(
+					menuService.getMenusByStoreId(storeId)
+				)
+			);
+	}
+}

src/main/java/com/example/gtable/menu/dto/MenuCreateRequest.java

@@ -0,0 +1,33 @@
+package com.example.gtable.menu.dto;
+
+import com.example.gtable.menu.model.Menu;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+public class MenuCreateRequest {
+
+	@NotNull
+	private Long storeId;
+	@NotNull
+	private String name;
+	@NotNull
+	private String description;
+	@NotNull
+	private String price;
+
+	public Menu toEntity() {
+		return Menu.builder()
+			.storeId(storeId)
+			.name(name)
+			.description(description)
+			.price(price)
+			.build();
+	}
+}
+

src/main/java/com/example/gtable/menu/dto/MenuCreateResponse.java

@@ -0,0 +1,32 @@
+package com.example.gtable.menu.dto;
+
+import java.time.LocalDateTime;
+
+import com.example.gtable.menu.model.Menu;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+@Builder
+public class MenuCreateResponse {
+	private Long menuId;
+	private Long storeId;
+	private String name;
+	private String description;
+	private String price;
+	private LocalDateTime createdAt;
+
+	public static MenuCreateResponse fromEntity(Menu menu) {
+		return MenuCreateResponse.builder()
+			.createdAt(menu.getCreatedAt())
+			.menuId(menu.getId())
+			.storeId(menu.getStoreId())
+			.name(menu.getName())
+			.description(menu.getDescription())
+			.price(menu.getPrice())
+			.build();
+	}
+}

src/main/java/com/example/gtable/menu/dto/MenuReadDto.java

@@ -0,0 +1,33 @@
+package com.example.gtable.menu.dto;
+
+import java.util.List;
+
+import com.example.gtable.menu.model.Menu;
+import com.example.gtable.menuImage.dto.MenuImageUploadResponse;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+@Builder
+public class MenuReadDto {
+	private Long menuId;
+	private Long storeId;
+	private String name;
+	private String description;
+	private String price;
+	private List<MenuImageUploadResponse> images;
+
+	public static MenuReadDto fromEntity(Menu menu, List<MenuImageUploadResponse> images) {
+		return MenuReadDto.builder()
+			.menuId(menu.getId())
+			.storeId(menu.getStoreId())
+			.name(menu.getName())
+			.description(menu.getDescription())
+			.price(menu.getPrice())
+			.images(images)
+			.build();
+	}
+}

src/main/java/com/example/gtable/menu/dto/MenuReadResponse.java

@@ -0,0 +1,21 @@
+package com.example.gtable.menu.dto;
+
+import java.util.List;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+@Builder
+public class MenuReadResponse {
+
+	private List<MenuReadDto> menuReadDto;
+
+	public static MenuReadResponse of(List<MenuReadDto> menuReadDto) {
+		return MenuReadResponse.builder()
+			.menuReadDto(menuReadDto)
+			.build();
+	}
+}

src/main/java/com/example/gtable/menu/model/Menu.java

@@ -0,0 +1,42 @@
+package com.example.gtable.menu.model;
+
+import java.time.LocalDateTime;
+
+import com.example.gtable.global.entity.BaseTimeEntity;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@Entity
+@Table(name = "menus")
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+@SuperBuilder
+public class Menu extends BaseTimeEntity {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long Id;
+	private Long storeId;
+	private String name;
+	private String description;
+	private String price;
+
+	public Menu(LocalDateTime createdAt, Long id, Long storeId, String name, String description, String price) {
+		super(createdAt);
+		this.Id = id;
+		this.storeId = storeId;
+		this.name = name;
+		this.description = description;
+		this.price = price;
+	}
+}

src/main/java/com/example/gtable/menu/repository/MenuRepository.java

@@ -0,0 +1,13 @@
+package com.example.gtable.menu.repository;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import com.example.gtable.menu.model.Menu;
+
+@Repository
+public interface MenuRepository extends JpaRepository<Menu, Long> {
+	List<Menu> findAllByStoreId(Long storeId);
+}