Review DB 연동 및 테스트 완료

review/build.gradle

@@ -22,7 +22,7 @@ repositories {
 }
 
 ext {
-	set('springCloudVersion', "2022.0.0")
+	set('springCloudVersion', "2022.0.3")
 }
 
 dependencies {
@@ -32,6 +32,11 @@ dependencies {
 	developmentOnly 'org.springframework.boot:spring-boot-devtools'
 	annotationProcessor 'org.projectlombok:lombok'
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
+	runtimeOnly("com.mysql:mysql-connector-j")
+	implementation 'org.springframework.boot:spring-boot-starter-data-jdbc'
+
+
+	implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:3.0.2'	//spring boot 3.0 ver =>  mybatis 3 버전 써야됨
 }
 
 dependencyManagement {

review/src/main/java/com/msaclub/review/ReviewApplication.java

@@ -3,15 +3,14 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.context.annotation.ComponentScan;
 
 @SpringBootApplication
 @EnableDiscoveryClient
 public class ReviewApplication {
 
 	public static void main(String[] args) {
 		SpringApplication.run(ReviewApplication.class, args);
-		System.out.println("bye");
-
 	}
 
 }

review/src/main/java/com/msaclub/review/controller/ReviewController.java

@@ -0,0 +1,172 @@
+package com.msaclub.review.controller;
+
+
+import com.msaclub.review.model.ReviewDto;
+import com.msaclub.review.service.ReviewService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.sql.Timestamp;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+
+@RestController
+@RequestMapping("/review")
+@Slf4j
+public class ReviewController {
+
+    @Autowired
+    ReviewService reviewService;
+
+
+    @GetMapping("/DBConnectionTest")
+    public String testConnection() {
+        try {
+            int number = reviewService.getNumberOfPurchaseList("ssafy");
+            return "조회 성공";
+        } catch(Exception e) {
+            System.out.println(e);
+            return "DB Connection Error : 로그 메시지 참고해주세요";
+        }
+    }
+    @GetMapping("/testGetNumberOfPurchaseList")
+    public String testGetNumberOfPurchaseList() {
+
+        int number = reviewService.getNumberOfPurchaseList("ssafy");
+        log.info(number + "개 구매하였습니다");
+
+        return "testGetNumberOfPurchaseList";
+    }
+
+
+
+    @GetMapping("/testGetPurchaseListByDate")
+    public String testGetPurchaseListByDate() {
+        String startString = "2020-01-01 12:34:56";
+        String endString = "2023-12-25 12:34:56";
+
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+        LocalDateTime startTime = LocalDateTime.parse(startString, formatter);
+        LocalDateTime endTime = LocalDateTime.parse(endString, formatter);
+
+
+        List<String> result = reviewService.getPurchaseListByDate("ssafy", Timestamp.valueOf(startTime), Timestamp.valueOf(endTime));
+        log.info(result.toString());
+
+        return "testGetPurchaseListByDate";
+    }
+
+    @GetMapping("/testGetPurchaseList")
+    public String testGetPurchaseList() {
+        List<String> result = reviewService.getPurchaseList("ssafy");
+
+        log.info(result.toString());
+        return "testGetPurchaseList";
+    }
+
+    @GetMapping("/testIsBuyer")
+    public String testIsBuyer() {
+        boolean isBuyer = reviewService.isBuyer("ssafy", "galaxys23");
+
+        if(isBuyer)
+            log.info("true");
+        else
+            log.info("false");
+
+        return "testIsBuyer";
+    }
+
+    /*check*/
+    @GetMapping("/testReview")
+    public String testReview() {
+        boolean result = reviewService.review(1, "내용을 수정하겠습니다");
+        if(result) {
+            log.info("수정 성공!!");
+        } else {
+            log.info("수정 실패!!");
+        }
+        return "testReview";
+    }
+
+    /*check*/
+    @GetMapping("/testDeleteReview")
+    public String testDeleteReview() {
+        boolean result = reviewService.deleteReview(1);
+        if(result) {
+            log.info("성공적으로 삭제하였습니다");
+        } else {
+            log.info("삭제에 실패했습니다");
+        }
+        return "testDeleteReview";
+    }
+
+    @GetMapping("/testGetReviewByReviewId")
+    public String testGetReviewByReviewId() {
+        ReviewDto result = reviewService.getReviewByReviewId(1);
+        if(result != null) {
+            log.info(result.toString());
+        } else {
+            log.info("조회에 실패했습니다");
+        }
+        return "testGetReviewByReviewId";
+    }
+////
+    @GetMapping("/testGetReviewCount")
+    public String testGetReviewCount() {
+        int number = reviewService.getReviewCount("ssafy");
+        log.info(number + "개의 리뷰를 작성했습니다");
+        return "testGetReviewCount";
+    }
+
+    @GetMapping("/testGetReviewByUserId")
+    public String testGetReviewByUserId() {
+        List<ReviewDto> result = reviewService.getReviewByUserId("ssafy");
+        if(result != null) {
+            log.info(result.toString());
+        } else {
+            log.info("조회에 실패했습니다");
+        }
+        return "testGetReviewByUserId";
+    }
+
+    @GetMapping("/testGetReviewByUserIdWithParam")
+    public String testGetReviewByUserIdWithParam() {
+        int pageNo = 2;
+        int reviewPerPage = 3;
+        List<ReviewDto> result = reviewService.getReviewByUserIdWithParam("ssafy", pageNo, reviewPerPage);
+        if(result != null) {
+            log.info(result.toString());
+        } else {
+            log.info("조회에 실패했습니다");
+        }
+        return "testGetReviewByUserIdWithParam";
+    }
+
+    //
+    @GetMapping("/testGetReviewByRating")
+    public String testGetReviewByRating() {
+        List<ReviewDto> result = reviewService.getReviewByRating("galaxy", true);
+        if(result != null) {
+            log.info(result.toString());
+        } else {
+            log.info("조회에 실패했습니다");
+        }
+        return "testGetReviewByRating";
+    }
+
+
+//
+    @GetMapping("/testGetReviewAvg")
+    public String testGetReviewAvg() {
+
+        double avgRating = reviewService.getReviewAvg("galaxy");
+        log.info(String.valueOf(avgRating));
+
+        return "testGetReviewAvg";
+    }
+}

review/src/main/java/com/msaclub/review/model/ReviewDto.java

@@ -0,0 +1,34 @@
+package com.msaclub.review.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+@Setter
+@Getter
+public class ReviewDto {
+
+    private String reviewId;
+    private String userId;
+    private String productId;
+    private int rating;
+    private String comment;
+    private LocalDateTime createdAt;
+    private LocalDateTime modifiedAt;
+    private boolean deleted;
+
+    @Override
+    public String toString() {
+        return "ReviewDto{" +
+                "reviewId='" + reviewId + '\'' +
+                ", userId='" + userId + '\'' +
+                ", productId='" + productId + '\'' +
+                ", rating=" + rating +
+                ", comment='" + comment + '\'' +
+                ", createdAt=" + createdAt +
+                ", modifiedAt=" + modifiedAt +
+                ", deleted=" + deleted +
+                "}\n";
+    }
+}

review/src/main/java/com/msaclub/review/model/mapper/ReviewMapper.java

@@ -0,0 +1,44 @@
+package com.msaclub.review.model.mapper;
+
+import com.msaclub.review.model.ReviewDto;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.sql.Timestamp;
+import java.util.List;
+
+@Mapper
+@Repository
+public interface ReviewMapper {
+
+    int getNumberOfPurchaseList(String userId);
+
+
+    List<String> getPurchaseListByDate(@Param("userId") String userId, @Param("start") Timestamp start, @Param("end") Timestamp end);
+
+    List<String> getPurchaseList(String userId);
+
+    boolean isBuyer(String userId, String productId);
+
+    boolean review(int reviewId, String content);
+
+    boolean deleteReview(int reviewId);
+
+    ReviewDto getReviewByReviewId(int reviewId);
+
+    int getReviewCount(String userId);
+
+    List<ReviewDto> getReviewByUserId(String userId);
+
+    List<ReviewDto> getReviewByUserIdWithParam(String userId, int pageNo, int reviewPerPage);
+
+    List<ReviewDto> getReviewByRating(String productId, boolean isAscending);
+
+
+    double getReviewAvg(String productId);
+
+
+
+
+}

review/src/main/java/com/msaclub/review/service/ReviewService.java

@@ -0,0 +1,51 @@
+package com.msaclub.review.service;
+
+import com.msaclub.review.model.ReviewDto;
+
+import java.sql.Timestamp;
+import java.util.List;
+
+public interface ReviewService {
+
+
+    // 현재 구매자의 구매 목록 갯수 가져오기
+    int getNumberOfPurchaseList(String userId);
+
+    // 현재 구매자의 날짜별 구매 목록 가져오기
+    List<String> getPurchaseListByDate(String userId, Timestamp start, Timestamp end);
+
+
+    // 현재 구매자의 구매 리스트 가져오기
+    List<String> getPurchaseList(String userId);
+
+    // 현재 댓글 쓰기 기능을 요청한 사용자가 구매자가 맞나 판별
+    boolean isBuyer(String userId, String productId);
+
+    // 리뷰 수정
+    boolean review(int reviewId, String content);
+
+    // 리뷰 삭제
+    boolean deleteReview(int reviewId);
+
+    // 리뷰 조회 (by reviewId)
+    ReviewDto getReviewByReviewId(int reviewId);
+
+    // 어떤 유저가 작성한 리뷰 갯수 반환하기
+    int getReviewCount(String userId);
+
+    // 리뷰 조회 (by userId)
+    List<ReviewDto> getReviewByUserId(String userId);
+
+    // 리뷰 조회
+    List<ReviewDto> getReviewByUserIdWithParam(String userId, int pageNo, int reviewPerPage);
+
+    // 리뷰 점수 순으로 조회하기
+    List<ReviewDto> getReviewByRating(String productId, boolean isAsending);
+
+    // 리뷰 평점 계산하기
+    double getReviewAvg(String productId);
+
+
+
+
+}