Changeset 8f1b7e9 in Git for src/main/java

Timestamp:

02/10/22 13:28:00 (3 years ago)

Author:

Test <matonikolov77@…>

Branches:

main

Children:

980eeda

Parents:

6f91f99

Message:

Changed DiscussionRepository and DiscussionServiceImpl for fetching likes

Location:

src/main/java/com/wediscussmovies/project

Files:

• model/Discussion.java (modified) (4 diffs)
• model/Movie.java (modified) (1 diff)
• model/Person.java (modified) (1 diff)
• model/User.java (modified) (1 diff)
• querymodels/DiscussionLikesQM.java (modified) (1 diff)
• repository/DiscussionRepository.java (modified) (1 diff)
• service/DiscussionService.java (modified) (1 diff)
• service/impl/DiscussionServiceImpl.java (modified) (4 diffs)
• web/controller/DiscussionController.java (modified) (3 diffs)

src/main/java/com/wediscussmovies/project/model/Discussion.java

@@ -1 +1 @@
 package com.wediscussmovies.project.model;
 
-import com.wediscussmovies.project.model.relation.DiscussionLikes;
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
 
 import javax.persistence.*;
-import java.sql.Date;
-import java.util.List;
+import java.time.LocalDate;
 import java.util.Objects;
 
@@ -28 +28 @@
     @Basic
     @Column(name = "date")
-    private Date date;
+    private LocalDate date;
 
 
@@ -47 +47 @@
 
     @Transient
-    private Long likes;
+    private long likes;
 
-    public Discussion(Character type, String text, String title, Date date, User user) {
+    public Discussion(Character type, String text, String title, LocalDate date, User user) {
         this.type = type;
         this.text = text;
@@ -56 +56 @@
         this.user = user;
     }
+
+
 
     public Discussion() {

src/main/java/com/wediscussmovies/project/model/Movie.java

@@ -9 +9 @@
 
 import javax.persistence.*;
+import java.io.Serializable;
 import java.sql.Date;
 import java.util.Collection;

src/main/java/com/wediscussmovies/project/model/Person.java

@@ -7 +7 @@
 import javax.persistence.*;
 import javax.swing.text.DateFormatter;
+import java.io.Serializable;
 import java.sql.Date;
 import java.time.LocalDate;

src/main/java/com/wediscussmovies/project/model/User.java

@@ -10 +10 @@
 
 import javax.persistence.*;
+import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.Collection;

src/main/java/com/wediscussmovies/project/querymodels/DiscussionLikesQM.java

@@ -1 +1 @@
 package com.wediscussmovies.project.querymodels;
 
+import com.wediscussmovies.project.model.Movie;
+import com.wediscussmovies.project.model.Person;
+import com.wediscussmovies.project.model.User;
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
+import java.time.LocalDate;
+import java.util.Date;
 import java.util.Objects;
 
 @Data
+@AllArgsConstructor
+@NoArgsConstructor
 public class DiscussionLikesQM {
+
     private Integer discussionId;
     private Long likes;
-
-    public DiscussionLikesQM(Integer discussionId, Long likes) {
-        this.discussionId = discussionId;
-        this.likes = likes;
-    }
-
-    public DiscussionLikesQM() {
-    }
 
     @Override

src/main/java/com/wediscussmovies/project/repository/DiscussionRepository.java

@@ -19 +19 @@
      List<Discussion> findAllByPerson (Person person);
 
-     @Query(value = "select new com.wediscussmovies.project.querymodels.DiscussionLikesQM(d.discussionId, count(dl.id.userId)) from Discussion d" +
+     @Query(value = "select new com.wediscussmovies.project.querymodels.DiscussionLikesQM(d.discussionId, count (dl.user) ) from Discussion d" +
              " left join DiscussionLikes dl on dl.id.discussionId = d.discussionId" +
-             " where :discussionId = d.discussionId" +
-             " group by d.discussionId"+
-             " order by count(dl.id.userId) desc")
+             " where :id = d.discussionId" +
+             " group by d.discussionId")
      @Transactional
-     DiscussionLikesQM findDiscussionWithLikes(@Param("discussionId") Integer discussionId);
+     DiscussionLikesQM findDiscussionWithLikes(@Param("id") Integer discussionId);
 
-     @Query(value = "select new com.wediscussmovies.project.querymodels.DiscussionLikesQM(d.discussionId, count(dl.id.userId)) from Discussion d" +
+     @Query(value = "select new com.wediscussmovies.project.querymodels.DiscussionLikesQM (d.discussionId, count(dl.user))  from Discussion d" +
              " left join DiscussionLikes dl on dl.id.discussionId = d.discussionId" +
              " group by d.discussionId"+
-             " order by count(dl.id.userId) desc")
+               " order by d.discussionId asc")
      @Transactional
-     List<DiscussionLikesQM> findAllDiscussionsWithLikes();
+     List<DiscussionLikesQM
+             > findAllDiscussionsWithLikes();
 }

src/main/java/com/wediscussmovies/project/service/DiscussionService.java

@@ -22 +22 @@
     DiscussionLikesQM findLikesForDiscussionWithId(Integer discussionId);
 
-    void findLikesForAllDiscussions(List<Discussion> discussions);
+    List<DiscussionLikesQM> findLikesForAllDiscussions();
 
 }

src/main/java/com/wediscussmovies/project/service/impl/DiscussionServiceImpl.java

@@ -16 +16 @@
 import org.springframework.stereotype.Service;
 
-import java.sql.Date;
 import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
 
 @Service
@@ -45 +45 @@
     @Override
     public List<Discussion> listAll() {
-        return this.discussionRepository.findAll();
+        List<Discussion> discussions = this.discussionRepository.findAll();
+        List<DiscussionLikesQM> discussionLikes  = this.discussionRepository.findAllDiscussionsWithLikes();
+        for (int i = 0; i < discussionLikes.size(); i++){
+            discussions.get(i).setLikes(discussionLikes.get(i).getLikes());
+        }
+        return discussions;
     }
 
     @Override
     public void save(Character type,Integer id,String title, String text,User user) {
-        Date date = Date.valueOf(LocalDate.now());
+        LocalDate date = LocalDate.now();
         Discussion discussion;
 
@@ -123 +128 @@
 
     @Override
-    public void findLikesForAllDiscussions(List<Discussion> discussions) {
-//        this.discussionRepository.findAllDiscussionsWithLikes()
-//                .forEach(el ->{
-//                        if (discussions.)
-//                });
+    public List<DiscussionLikesQM> findLikesForAllDiscussions() {
+           // return this.discussionRepository.findAllDiscussionsWithLikes();
+        return this.discussionRepository.findAllDiscussionsWithLikes();
     }
 
@@ -145 +148 @@
     @Override
     public Discussion findById(Integer id) {
-        return discussionRepository.findById(id).orElseThrow(() -> new DiscussionNotExistException(id));
+        Discussion disc =  discussionRepository.findById(id).orElseThrow(() -> new DiscussionNotExistException(id));
+        disc.setLikes(this.discussionRepository.findDiscussionWithLikes(id).getLikes());
+        return disc;
     }
 

src/main/java/com/wediscussmovies/project/web/controller/DiscussionController.java

@@ -45 +45 @@
 
          */
-        List<Discussion> discussions = discussionService.listAllByTitle(titleSearch);
+        //List<Discussion> discussions = discussionService.listAllByTitle(titleSearch);
+        List<Discussion> discussions = discussionService.listAll();
         model.addAttribute("discussions", discussions);
         model.addAttribute("contentTemplate", "discussionsList");
         model.addAttribute("user",LoggedUser.getLoggedUser());
         this.addModelPropertiesForUser(model);
-        this.addModelPropertiesLikes(model,null, discussions);
+       // this.addModelPropertiesLikes(model,null, discussions);
         return "template";
     }
@@ -63 +64 @@
         try {
             Discussion disc = discussionService.findById(id);
-            disc.setLikes(discussionService.findLikesForDiscussionWithId(disc.getDiscussionId()).getLikes());
             model.addAttribute("disc", disc);
             model.addAttribute("contentTemplate", "discussion");
@@ -185 +185 @@
         // ispagja kompliciran kod vaka, podobro da dodademe i svojstvo u diskusijata i koga ke se dodade lajk
         // soodvetno da se zgoleme i obratno
-        if(discussion==null){
-            List<DiscussionLikesQM> discussionLikes = new ArrayList<>();
-            for(Discussion d: discussions){
-                discussionLikes.add(discussionService.findLikesForDiscussionWithId(d.getDiscussionId()));
-            }
-            model.addAttribute("likes", discussionLikes);
-        }
-        else{
-            model.addAttribute("likes",discussionService.findLikesForDiscussionWithId(discussion.getDiscussionId()).getLikes());
-        }
+//        if(discussion==null){
+//            List<DiscussionLikesQM> discussionLikes = new ArrayList<>();
+//            for(Discussion d: discussions){
+//                discussionLikes.add(discussionService.findLikesForDiscussionWithId(d.getDiscussionId()));
+//            }
+//            model.addAttribute("likes", discussionLikes);
+//        }
+//        else{
+//            model.addAttribute("likes",discussionService.findLikesForDiscussionWithId(discussion.getDiscussionId()).getLikes());
+//        }
     }