deploy 1.14.1

배포 1.14.1

Author: rvbear

src/main/java/com/day_walk/backend/domain/course_like/bean/KafkaCourseLikeConsumer.java

@@ -15,20 +15,19 @@
 public class KafkaCourseLikeConsumer {
     private final CourseLikeRepository courseLikeRepository;
     private final CourseLikeRedisRepository courseLikeRedisRepository;
-    private final GetCourseLikeEntityBean getCourseLikeEntityBean;
 
     @KafkaListener(topics = "save-course-like", groupId = "save-course-like", containerFactory = "courseLikeKafkaListenerContainerFactory")
     public void redisSaveConsume(CourseLikeEvent courseLikeEvent) {
-        courseLikeRedisRepository.saveCourseLike(courseLikeEvent.getUserId(), courseLikeEvent.getCourseId(), courseLikeEvent.isLiked());
+        courseLikeRedisRepository.saveCourseLike(courseLikeEvent.getUserId(), courseLikeEvent.getCourseId(), courseLikeEvent.getLiked());
     }
 
     @KafkaListener(topics = "bulk-course-like", groupId = "bulk-course-like", containerFactory = "courseLikeKafkaListenerContainerFactory")
     public void mysqlConsume(CourseLikeEvent courseLikeEvent) {
-        if (courseLikeEvent.isLiked()) {
+        if (Boolean.TRUE.equals(courseLikeEvent.getLiked())) {
             CourseLikeEntity courseLike = new CourseLikeEntity(UUID.randomUUID(), courseLikeEvent.getUserId(), courseLikeEvent.getCourseId());
             courseLikeRepository.save(courseLike);
         } else {
-            CourseLikeEntity courseLike = getCourseLikeEntityBean.exec(courseLikeEvent);
+            CourseLikeEntity courseLike = courseLikeRepository.findByUserIdAndCourseId(courseLikeEvent.getUserId(), courseLikeEvent.getCourseId());
 
             if (courseLike != null) {
                 courseLikeRepository.delete(courseLike);

src/main/java/com/day_walk/backend/domain/course_like/data/out/CourseLikeEvent.java

@@ -12,5 +12,5 @@
 public class CourseLikeEvent {
     private UUID userId;
     private UUID courseId;
-    private boolean liked;
+    private Boolean liked;
 }

src/main/java/com/day_walk/backend/domain/place_like/bean/KafkaPlaceLikeConsumer.java

@@ -15,20 +15,19 @@
 public class KafkaPlaceLikeConsumer {
     private final PlaceLikeRepository placeLikeRepository;
     private final PlaceLikeRedisRepository placeLikeRedisRepository;
-    private final GetPlaceLikeEntityBean getPlaceLikeEntityBean;
 
     @KafkaListener(topics = "save-place-like", groupId = "save-place-like", containerFactory = "placeLikeKafkaListenerContainerFactory")
     public void redisSaveConsume(PlaceLikeEvent placeLikeEvent) {
-        placeLikeRedisRepository.savePlaceLike(placeLikeEvent.getUserId(), placeLikeEvent.getPlaceId(), placeLikeEvent.isLiked());
+        placeLikeRedisRepository.savePlaceLike(placeLikeEvent.getUserId(), placeLikeEvent.getPlaceId(), placeLikeEvent.getLiked());
     }
 
     @KafkaListener(topics = "bulk-place-like", groupId = "bulk-place-like", containerFactory = "placeLikeKafkaListenerContainerFactory")
     public void mysqlConsume(PlaceLikeEvent placeLikeEvent) {
-        if (placeLikeEvent.isLiked()) {
+        if (Boolean.TRUE.equals(placeLikeEvent.getLiked())) {
             PlaceLikeEntity placeLike = new PlaceLikeEntity(UUID.randomUUID(), placeLikeEvent.getUserId(), placeLikeEvent.getPlaceId());
             placeLikeRepository.save(placeLike);
         } else {
-            PlaceLikeEntity placeLike = getPlaceLikeEntityBean.exec(placeLikeEvent.getUserId(), placeLikeEvent.getPlaceId());
+            PlaceLikeEntity placeLike = placeLikeRepository.findByUserIdAndPlaceId(placeLikeEvent.getUserId(), placeLikeEvent.getPlaceId());
 
             if (placeLike != null) {
                 placeLikeRepository.delete(placeLike);

src/main/java/com/day_walk/backend/domain/place_like/data/out/PlaceLikeEvent.java

@@ -12,5 +12,5 @@
 public class PlaceLikeEvent {
     private UUID userId;
     private UUID placeId;
-    private boolean liked;
+    private Boolean liked;
 }