Changeset e0ef1b1 in Git for src/main/java/com/wediscussmovies/project/service/impl/ReplyServiceImpl.java

Timestamp:

02/04/22 23:22:13 (2 years ago)

Author:

Test <matonikolov77@…>

Branches:

main

Children:

5b447b0

Parents:

3ded84d

Message:

Added CRUD for movies,persons,discussion,replies,genres
Added ajaxcalls

File:

• src/main/java/com/wediscussmovies/project/service/impl/ReplyServiceImpl.java (modified) (1 diff)

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

@@ -1 +1 @@
 package com.wediscussmovies.project.service.impl;
 
-import com.wediscussmovies.project.model.*;
+import com.wediscussmovies.project.model.Discussion;
+import com.wediscussmovies.project.model.exception.DiscussionNotExistException;
+import com.wediscussmovies.project.model.exception.ReplyNotExistException;
+import com.wediscussmovies.project.model.primarykeys.ReplyPK;
+import com.wediscussmovies.project.repository.DiscussionRepository;
 import com.wediscussmovies.project.repository.ReplyRepository;
+import com.wediscussmovies.project.model.Reply;
+import com.wediscussmovies.project.model.User;
+import com.wediscussmovies.project.repository.UserRepository;
 import com.wediscussmovies.project.service.ReplyService;
 import org.springframework.stereotype.Service;
 
-import java.util.Optional;
+import java.sql.Date;
+import java.time.LocalDate;
+import java.util.List;
 
 @Service
 public class ReplyServiceImpl implements ReplyService {
+
     private final ReplyRepository replyRepository;
+    private final DiscussionRepository discussionRepository;
 
-    public ReplyServiceImpl(ReplyRepository replyRepository) {
+    public ReplyServiceImpl(ReplyRepository replyRepository,
+                            DiscussionRepository discussionRepository) {
         this.replyRepository = replyRepository;
+        this.discussionRepository = discussionRepository;
+    }
+
+
+
+    @Override
+    public void save(Integer discussionId, String text,User user) {
+
+        Discussion discussion = this.discussionRepository.findById(discussionId).orElseThrow(() -> new DiscussionNotExistException(discussionId));
+
+        Date date = Date.valueOf(LocalDate.now());
+        this.replyRepository.insertInto(text,date,user.getUserId(),discussionId);
+
     }
 
     @Override
-    public Optional<Reply> findById(Long id) {
-        return replyRepository.findById(1);
+    public void likeReply(Integer replyId, Integer userId) {
+        //da se implementira, promena vo baza
     }
 
     @Override
-    public void delete(Reply r) {
-        replyRepository.delete(r);
+    public void unlikeReply(Integer replyId, Integer userId) {
+        // da se implementira, promena vo baza
     }
 
     @Override
-    public Reply save(Reply r) {
-        return replyRepository.save(r);
+    public List<Reply> findAllByDiscussion(Discussion discussion) {
+        return this.replyRepository.findAllByDiscussion(discussion);
+    }
+
+
+    @Override
+    public Reply edit(Integer replyId,Integer discussionId,String text) {
+        ReplyPK replyPK = new ReplyPK(discussionId,replyId);
+        Reply reply = this.replyRepository.findById(replyPK).orElseThrow();
+        reply.setText(text);
+        return  this.replyRepository.save(reply);
+    }
+
+    @Override
+    public void delete(Integer discussionId, Integer replyId) {
+        this.replyRepository.deleteById(new ReplyPK(discussionId,replyId));
+    }
+
+    @Override
+    public Reply findById(Integer discussionId, Integer replyId) {
+        ReplyPK replyPK  = new ReplyPK(discussionId,replyId);
+        return this.replyRepository.findById(replyPK).orElseThrow(() -> new ReplyNotExistException(replyPK));
+
     }
 }