[신윤섭] 5차 과제 제출

backend/.gitignore

@@ -5,6 +5,12 @@ build/
 !**/src/main/**/build/
 !**/src/test/**/build/
 
+### Properties Files ###
+src/main/resources/application.properties
+src/main/resources/application-*.properties
+*.properties
+!gradle.properties
+
 ### STS ###
 .apt_generated
 .classpath

backend/build.gradle

@@ -26,6 +26,7 @@ repositories {
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-actuator'
     compileOnly 'org.projectlombok:lombok'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
     runtimeOnly 'com.mysql:mysql-connector-j'

backend/src/main/java/cotato/backend/BackendApplication.java

@@ -2,7 +2,9 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
 
+@EnableCaching
 @SpringBootApplication
 public class BackendApplication {
 

backend/src/main/java/cotato/backend/common/config/CacheConfig.java

@@ -0,0 +1,22 @@
+package cotato.backend.common.config;
+
+import java.util.List;
+
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.concurrent.ConcurrentMapCache;
+import org.springframework.cache.support.SimpleCacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class CacheConfig {
+	@Bean
+	public CacheManager cacheManager() {
+		SimpleCacheManager cacheManager = new SimpleCacheManager();
+		cacheManager.setCaches(List.of(
+			new ConcurrentMapCache("posts")
+		));
+		return cacheManager;
+	}
+}
+

backend/src/main/java/cotato/backend/common/dto/PageResponse.java

@@ -0,0 +1,37 @@
+package cotato.backend.common.dto;
+
+import java.util.List;
+
+import org.springframework.data.domain.Page;
+import org.springframework.http.HttpStatus;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+
+import lombok.Getter;
+
+@Getter
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class PageResponse<T> extends BaseResponse {
+	private final List<T> items;
+	private final int currentPage;
+	private final int totalPages;
+	private final long totalItems;
+
+	private PageResponse(HttpStatus status, List<T> content, int number, int totalPages, long totalElements) {
+		super(status);
+		this.items = content;
+		this.currentPage = number;
+		this.totalPages = totalPages;
+		this.totalItems = totalElements;
+	}
+
+	public static <T> PageResponse<T> from(Page<T> page) {
+		return new PageResponse<>(
+			HttpStatus.OK,
+			page.getContent(),
+			page.getNumber(),
+			page.getTotalPages(),
+			page.getTotalElements()
+		);
+	}
+}

backend/src/main/java/cotato/backend/common/exception/ErrorCode.java

@@ -13,9 +13,14 @@ public enum ErrorCode {
 	BAD_REQUEST(HttpStatus.BAD_REQUEST, "잘못된 요청입니다.", "COMMON-001"),
 	INVALID_PARAMETER(HttpStatus.BAD_REQUEST, "요청 파라미터가 잘 못 되었습니다.", "COMMON-002"),
 
+	//POST-400
+	POST_NOT_FOUND(HttpStatus.NOT_FOUND,"게시물을 찾지 못했습니다." , "COMMON-003" ),
+	POST_DELETE_FAILED(HttpStatus.BAD_REQUEST,"게시물 삭제가 실패하였습니다." , "COMMON-004" ),
+	POST_SAVE_FAILED(HttpStatus.BAD_REQUEST,"게시물 저장을 실패하였습니다." , "COMMON-005" ),
+
 	//500
 	INTERNAL_SERVER_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, "서버 내부에서 에러가 발생하였습니다.", "COMMON-002"),
-	;
+	CONCURRENCY_PROBLEM(HttpStatus.INTERNAL_SERVER_ERROR, "동시성 에러가 발생하였습니다." , "COMMON-003");
 
 	private final HttpStatus httpStatus;
 	private final String message;

backend/src/main/java/cotato/backend/domains/post/controller/PostController.java

@@ -0,0 +1,58 @@
+package cotato.backend.domains.post.controller;
+
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.web.PageableDefault;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
+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 cotato.backend.common.dto.DataResponse;
+import cotato.backend.common.dto.PageResponse;
+import cotato.backend.domains.post.dto.response.PostResponse;
+import cotato.backend.domains.post.dto.request.SavePostsByExcelRequest;
+import cotato.backend.domains.post.dto.request.SaveSinglePostRequest;
+import cotato.backend.domains.post.service.PostServiceImpl;
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequestMapping("/api/posts")
+@RequiredArgsConstructor
+public class PostController {
+
+	private final PostServiceImpl postService;
+
+	@PostMapping("/excel")
+	public ResponseEntity<DataResponse<Void>> savePostsByExcel(@RequestBody SavePostsByExcelRequest request) {
+		postService.saveEstatesByExcel(request);
+		return ResponseEntity.ok(DataResponse.ok());
+	}
+
+	@PostMapping
+	public ResponseEntity<DataResponse<Void>> savePost(@RequestBody SaveSinglePostRequest request) {
+		postService.saveSinglePost(request);
+		return ResponseEntity.ok(DataResponse.ok());
+	}
+
+	@GetMapping("/{id}")
+	public ResponseEntity<DataResponse<PostResponse>> getPost(@PathVariable Long id) {
+		return ResponseEntity.ok(DataResponse.from(postService.findPostById(id)));
+	}
+
+	@GetMapping
+	public ResponseEntity<PageResponse<PostResponse>> getPopularPosts(
+		@PageableDefault(sort = "likes", direction = Sort.Direction.DESC) Pageable pageable) {
+		return ResponseEntity.ok(PageResponse.from(postService.findPostsSortedByLikes(pageable)));
+	}
+
+	@DeleteMapping("/{id}")
+	public ResponseEntity<DataResponse<Void>> deletePost(@PathVariable Long id) {
+		postService.deletePostById(id);
+		return ResponseEntity.ok(DataResponse.ok());
+	}
+}

backend/src/main/java/cotato/backend/domains/post/dto/request/SavePostsByExcelRequest.java

@@ -1,12 +1,4 @@
 package cotato.backend.domains.post.dto.request;
 
-import lombok.AccessLevel;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@NoArgsConstructor(access = AccessLevel.PRIVATE)
-public class SavePostsByExcelRequest {
-
-	private String path;
+public record SavePostsByExcelRequest(String path) {
 }

backend/src/main/java/cotato/backend/domains/post/dto/request/SaveSinglePostRequest.java

@@ -0,0 +1,17 @@
+package cotato.backend.domains.post.dto.request;
+
+import cotato.backend.domains.post.entity.Post;
+import jakarta.validation.constraints.NotBlank;
+
+public record SaveSinglePostRequest(@NotBlank(message = "Title은 공백일 수 없습니다.") String title,
+									@NotBlank(message = "Content는 공백일 수 없습니다.") String content,
+									@NotBlank(message = "Name은 공백일 수 없습니다.") String name) {
+
+	public Post toEntity() {
+		return Post.builder().
+			title(title).
+			content(content).
+			name(name).
+			build();
+	}
+}

backend/src/main/java/cotato/backend/domains/post/dto/response/PostResponse.java

@@ -0,0 +1,13 @@
+package cotato.backend.domains.post.dto.response;
+
+import cotato.backend.domains.post.entity.Post;
+import lombok.Builder;
+import lombok.NonNull;
+
+@Builder
+public record PostResponse(@NonNull String title, @NonNull String content, @NonNull String name, int views, int likes) {
+
+	public static PostResponse from(Post post) {
+		return new PostResponse(post.getTitle(), post.getContent(), post.getName(), post.getViews(), post.getLikes());
+	}
+}

backend/src/main/java/cotato/backend/domains/post/entity/Post.java

@@ -0,0 +1,63 @@
+package cotato.backend.domains.post.entity;
+
+import org.hibernate.annotations.ColumnDefault;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Index;
+import jakarta.persistence.Table;
+import jakarta.persistence.Version;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.NonNull;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Table(name = "post",
+	indexes = {
+		@Index(name = "idx_post_views", columnList = "views")
+	}
+)
+public class Post {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long id;
+
+	@NonNull
+	private String title;
+
+	@NonNull
+	private String content;
+
+	@NonNull
+	private String name;
+
+	@ColumnDefault("0")
+	private int views;
+
+	@ColumnDefault("0")
+	private int likes;
+
+	@Version
+	@Column(name = "version", columnDefinition = "bigint default 0")
+	private Long version = 0L;
+
+	@Builder
+	public Post(String title, String content, String name, int views, int likes) {
+		this.title = title;
+		this.content = content;
+		this.name = name;
+		this.views = views;
+		this.likes = likes;
+	}
+
+	public void increaseViews() {
+		this.views++;
+	}
+}

backend/src/main/java/cotato/backend/domains/post/repository/LockRepository.java

@@ -0,0 +1,16 @@
+package cotato.backend.domains.post.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+import cotato.backend.domains.post.entity.Post;
+
+@Repository
+public interface LockRepository extends JpaRepository<Post, Long> {
+	@Query(value = "select get_lock(:key, 3000)", nativeQuery = true)
+	void getLock(String key);
+
+	@Query(value = "select release_lock(:key)", nativeQuery = true)
+	void releaseLock(String key);
+}