Perf: [BADA-368] 추천 고도화

src/main/java/com/TwoSeaU/BaData/domain/trade/controller/MockController.java

@@ -0,0 +1,21 @@
+package com.TwoSeaU.BaData.domain.trade.controller;
+
+import com.TwoSeaU.BaData.domain.trade.service.PostService;
+import com.TwoSeaU.BaData.global.response.ApiResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/v1/trades")
+public class MockController {
+    private final PostService postService;
+
+    @PostMapping("/mock/posts")
+    public ResponseEntity<ApiResponse<String>> createMockPost() {
+        return ResponseEntity.ok().body(ApiResponse.success(postService.generateGifticons()));
+    }
+}

src/main/java/com/TwoSeaU/BaData/domain/trade/controller/PostController.java

@@ -37,6 +37,15 @@ public ResponseEntity<ApiResponse<CursorPageResponse<PostResponse>>> getPosts(
         return ResponseEntity.ok().body(ApiResponse.success(postSearchService.searchPosts(query, user == null ? null : user.getUsername(), cursor, size)));
     }
 
+    @GetMapping("/posts/rdb")
+    public ResponseEntity<ApiResponse<CursorPageResponse<PostResponse>>> getPostsByRDB(
+            @RequestParam(required = false) Long cursor,
+            @RequestParam(defaultValue = "10") int size,
+            @RequestParam(required = false) String query,
+            @AuthenticationPrincipal User user) {
+        return ResponseEntity.ok().body(ApiResponse.success(postSearchService.searchPostsByRDB(query, user == null ? null : user.getUsername(), cursor, size)));
+    }
+
     @GetMapping("/posts/{userId}/{isSold}")
     public ResponseEntity<ApiResponse<CursorPageResponse<PostResponse>>> getPostsByUserId(
             @RequestParam(required = false) Long cursor,

src/main/java/com/TwoSeaU/BaData/domain/trade/controller/RecommendController.java

@@ -3,7 +3,10 @@
 import com.TwoSeaU.BaData.domain.trade.dto.response.PostsResponse;
 import com.TwoSeaU.BaData.domain.trade.dto.response.SaveRecommendLikesResponse;
 import com.TwoSeaU.BaData.domain.trade.service.LikeService;
-import com.TwoSeaU.BaData.domain.trade.service.RecommendService;
+import com.TwoSeaU.BaData.domain.trade.service.recommend.GlobalRecommendService;
+import com.TwoSeaU.BaData.domain.trade.service.recommend.doubleVector.RecommendServiceDouble;
+import com.TwoSeaU.BaData.domain.trade.service.recommend.floatVector.RecommendServiceFloat;
+import com.TwoSeaU.BaData.domain.trade.service.recommend.pgVector.RecommendServicePg;
 import com.TwoSeaU.BaData.global.response.ApiResponse;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.ResponseEntity;
@@ -15,16 +18,40 @@
 @RequiredArgsConstructor
 @RequestMapping("/api/v1/trades/posts/recommend")
 public class RecommendController {
-    private final RecommendService recommendService;
+    private final RecommendServiceDouble doubleRecommendServiceDouble;
+    private final RecommendServiceFloat floatRecommendServiceFloat;
+    private final RecommendServicePg pgvectorRecommendServicePg;
+    private final GlobalRecommendService globalRecommendService;
     private final LikeService likeService;
 
+    @GetMapping("/double")
+    public ResponseEntity<ApiResponse<PostsResponse>> recommendPostsByDouble(@AuthenticationPrincipal User user, @RequestParam(defaultValue = "true") boolean isStart) {
+        return ResponseEntity.ok().body(ApiResponse.success(doubleRecommendServiceDouble.recommendPosts(user == null ? null : user.getUsername(), isStart)));
+    }
+
+    @GetMapping("/float")
+    public ResponseEntity<ApiResponse<PostsResponse>> recommendPostsByFloat(@AuthenticationPrincipal User user, @RequestParam(defaultValue = "true") boolean isStart) {
+        return ResponseEntity.ok().body(ApiResponse.success(floatRecommendServiceFloat.recommendPostsByFloat(user == null ? null : user.getUsername(), isStart)));
+    }
+
+    //@GetMapping("/pgvector")
     @GetMapping
-    public ResponseEntity<ApiResponse<PostsResponse>> recommendPosts(@AuthenticationPrincipal User user, @RequestParam(defaultValue = "true") boolean isStart) {
-        return ResponseEntity.ok().body(ApiResponse.success(recommendService.recommendPosts(user == null ? null : user.getUsername(), isStart)));
+    public ResponseEntity<ApiResponse<PostsResponse>> recommendPostsByPgvector(@AuthenticationPrincipal User user, @RequestParam(defaultValue = "true") boolean isStart) {
+        return ResponseEntity.ok().body(ApiResponse.success(pgvectorRecommendServicePg.recommendPostsBypgVector(user == null ? null : user.getUsername(), isStart)));
     }
 
     @PostMapping("/likes/{postId}")
     public ResponseEntity<ApiResponse<SaveRecommendLikesResponse>> likeRecommendation(@AuthenticationPrincipal User user, @PathVariable Long postId) {
         return ResponseEntity.ok().body(ApiResponse.success(likeService.likesAtRecommendation(user == null ? null : user.getUsername(), postId)));
     }
+
+    @PatchMapping("/vector/update/all/double")
+    public ResponseEntity<ApiResponse<String>> updateAllPostForDouble() {
+        return ResponseEntity.ok().body(ApiResponse.success(globalRecommendService.updateAllDoubleVector()));
+    }
+
+    @PatchMapping("/vector/update/all/float")
+    public ResponseEntity<ApiResponse<String>> updateAllPostVectorForPgvector() {
+        return ResponseEntity.ok().body(ApiResponse.success(globalRecommendService.updateAllFloatAndPgVector()));
+    }
 }

src/main/java/com/TwoSeaU/BaData/domain/trade/entity/Gifticon.java

@@ -23,7 +23,9 @@ public class Gifticon extends Post{
     @Column(nullable = false)
     private String partner;
 
-    private double[] vector;
+    private double[] doubleVector;
+
+    private float[] floatVector;
 
     @ManyToOne(fetch = FetchType.EAGER)
     @JoinColumn(name = "category_id", nullable = false)
@@ -34,16 +36,21 @@ public class Gifticon extends Post{
     public Gifticon(final User user, final String title, final String comment, final BigDecimal price,
                     final LocalDate deadLine, final String postImage, final Boolean isSold,
                     final String couponNumber, final String partner, final GifticonCategory category,
-                    final double[] vector) {
+                    final double[] doubleVector, final float[] floatVector) {
         super(user, title, comment, price, deadLine, postImage, isSold);
         this.couponNumber = couponNumber;
         this.partner = partner;
         this.category = category;
-        this.vector = vector;
+        this.doubleVector = doubleVector;
+        this.floatVector = floatVector;
+    }
+
+    public void updateDoubleVector(final double[] doubleVector) {
+        this.doubleVector = doubleVector;
     }
 
-    public void updateVector(final double[] vector) {
-        this.vector = vector;
+    public void updateFloatVector(final float[] floatVector) {
+        this.floatVector = floatVector;
     }
 
     public void updateBarcodeViewTime(final LocalDateTime barcodeViewTime) {

src/main/java/com/TwoSeaU/BaData/domain/trade/entity/PostVector.java

@@ -0,0 +1,25 @@
+package com.TwoSeaU.BaData.domain.trade.entity;
+
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+@Table(name = "post_vector")
+public class PostVector {
+    @Id
+    private Long id;
+
+    @Column(name = "vector_pg", columnDefinition = "vector(57)")
+    private float[] vectorPg;
+
+    @OneToOne(fetch = FetchType.LAZY)
+    @MapsId
+    @JoinColumn(name = "id")
+    private Post post;
+}

src/main/java/com/TwoSeaU/BaData/domain/trade/repository/JdbcRepository.java

@@ -0,0 +1,92 @@
+package com.TwoSeaU.BaData.domain.trade.repository;
+
+import com.TwoSeaU.BaData.domain.trade.entity.Gifticon;
+import com.TwoSeaU.BaData.domain.trade.exception.TradeException;
+import com.TwoSeaU.BaData.domain.trade.service.recommend.floatVector.RecommendServiceFloat;
+import com.TwoSeaU.BaData.global.response.GeneralException;
+import lombok.RequiredArgsConstructor;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class JdbcRepository {
+    private final GifticonRepository gifticonRepository;
+    private final DataSource dataSource;
+    private final JdbcTemplate jdbcTemplate;
+    private final int LIMIT = 10;
+
+    public List<RecommendServiceFloat.RecommendationResult> findSimilarPosts(final float[] userVector, final int alreadyViewCount) {
+        final String sql = """
+                        SELECT id, vector_pg <=> ?::vector AS similarity 
+                        FROM post_vector
+                        ORDER BY vector_pg <=> ?::vector
+                        limit ?
+                                            ;
+                    """;
+
+        try (Connection conn = dataSource.getConnection()) {
+            return jdbcTemplate.query(
+                    sql,
+                    ps -> {
+                        ps.setObject(1, toPgvectorString(userVector));
+                        ps.setObject(2, toPgvectorString(userVector));
+                        ps.setInt(3, LIMIT + alreadyViewCount);
+                    },
+                    (rs, rowNum) -> {
+                        Long postId = rs.getLong("id");
+                        System.out.println("Post ID: " + postId);
+                        Gifticon gifticon = gifticonRepository.findById(postId)
+                                .orElseThrow(() -> new GeneralException(TradeException.POST_NOT_FOUND));
+
+                        return new RecommendServiceFloat.RecommendationResult(
+                                gifticon,
+                                rs.getDouble("similarity"),
+                                rs.getDouble("similarity")
+                        );
+                    }
+            );
+
+        } catch (SQLException e) {
+            throw new RuntimeException("추천 게시글 검색 실패", e);
+        }
+    }
+
+    public void insertPostVector(final Long postId, final float[] vector) {
+        final String sql = "INSERT INTO post_vector (id, vector_pg) VALUES (?, ?::vector)";
+
+        try (Connection conn = dataSource.getConnection()) {
+            jdbcTemplate.update(sql, postId, toPgvectorString(vector));
+        } catch (SQLException e) {
+            throw new RuntimeException("Post vector insert failed", e);
+        }
+    }
+
+    public void updatePostVector(final Long postId, final float[] vector) {
+        final String sql = "UPDATE post_vector SET vector_pg = ?::vector WHERE id = ?";
+
+        try (Connection conn = dataSource.getConnection()) {
+            jdbcTemplate.update(sql, toPgvectorString(vector), postId);
+        } catch (SQLException e) {
+            throw new RuntimeException("Post vector update failed", e);
+        }
+    }
+
+
+    private String toPgvectorString(float[] vector) {
+        StringBuilder sb = new StringBuilder();
+        sb.append("[");
+        for (int i = 0; i < vector.length; i++) {
+            sb.append(vector[i]);
+            if (i < vector.length - 1) sb.append(", ");
+        }
+        sb.append("]");
+
+        return sb.toString();
+    }
+}

src/main/java/com/TwoSeaU/BaData/domain/trade/service/PostSearchService.java

@@ -56,6 +56,16 @@ public CursorPageResponse<PostResponse> searchPosts(final String query, final St
         return searchByTitleAndComment(query, username, cursor, size);
     }
 
+    public CursorPageResponse<PostResponse> searchPostsByRDB(final String query, final String username, final Long cursor, final int size) {
+
+        if (query != null && !query.isEmpty()) {
+            log.info("event-keyword-search, {}", query);
+            saveSearchHistoryIfUserExists(username, query);
+        }
+
+        return postRepository.searchPostsByKeyword(query, username, cursor, size);
+    }
+
     private void saveSearchHistoryIfUserExists(final String username, final String query) {
         if (username == null) {
             return;