Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • src/main/java/com/wediscussmovies/project/service/impl/DiscussionServiceImpl.java

    rc02189f re0ef1b1  
    55import com.wediscussmovies.project.model.exception.PersonNotExistException;
    66import com.wediscussmovies.project.model.exception.UserNotExistException;
    7 import com.wediscussmovies.project.model.primarykeys.DiscussionLikesPK;
    8 import com.wediscussmovies.project.model.relation.DiscussionLikes;
    9 import com.wediscussmovies.project.repository.*;
     7import com.wediscussmovies.project.repository.DiscussionRepository;
    108import com.wediscussmovies.project.model.Discussion;
    119import com.wediscussmovies.project.model.Movie;
    1210import com.wediscussmovies.project.model.Person;
    1311import com.wediscussmovies.project.model.User;
     12import com.wediscussmovies.project.repository.MovieRepository;
     13import com.wediscussmovies.project.repository.PersonRepository;
     14import com.wediscussmovies.project.repository.UserRepository;
    1415import com.wediscussmovies.project.service.DiscussionService;
     16import com.wediscussmovies.project.service.MovieService;
     17import com.wediscussmovies.project.service.PersonService;
     18import com.wediscussmovies.project.service.UserService;
    1519import org.springframework.stereotype.Service;
    1620
    1721import java.sql.Date;
    1822import java.time.LocalDate;
    19 import java.util.ArrayList;
    2023import java.util.List;
    2124
     
    2427
    2528    private final DiscussionRepository discussionRepository;
    26     private final DiscussionLikesRepository discussionLikesRepository;
    2729    private final UserRepository userRepository;
    2830
     
    3032    private final PersonRepository personRepository;
    3133
    32     public DiscussionServiceImpl(DiscussionRepository discussionRepository, DiscussionLikesRepository discussionLikesRepository, UserRepository userRepository,
     34    public DiscussionServiceImpl(DiscussionRepository discussionRepository, UserRepository userRepository,
    3335                                 MovieRepository movieRepository, PersonRepository personRepository) {
    3436        this.discussionRepository = discussionRepository;
    35         this.discussionLikesRepository = discussionLikesRepository;
    3637        this.userRepository = userRepository;
    3738        this.movieRepository = movieRepository;
     
    9394    @Override
    9495    public void likeDiscussion(Integer discussionId, Integer userId) {
    95         Discussion discussion = discussionRepository.findById(discussionId).orElseThrow(() -> new DiscussionNotExistException(discussionId));
    96         User user = userRepository.findById(userId).orElseThrow(() -> new UserNotExistException(userId.toString()));
    97         this.discussionLikesRepository.save(new DiscussionLikes(discussion, user));
    98     }
    99 
    100     @Override
    101     public List<Discussion> findLikedDiscussionsByUser(User user) {
    102         List<DiscussionLikes> likes = discussionLikesRepository.findAllByUser(user);
    103         List<Discussion> discussions = new ArrayList<>();
    104         for(DiscussionLikes dl: likes){
    105             discussions.add(dl.getDiscussion());
    106         }
    107         return discussions;
     96        //ova fali od dijagram
    10897    }
    10998
    11099    @Override
    111100    public void unlikeDiscussion(Integer discussionId, Integer userId) {
    112         DiscussionLikesPK pk = new DiscussionLikesPK(discussionId, userId);
    113         this.discussionLikesRepository.deleteById(pk);
     101        // ova fali od dijagram
    114102    }
    115 
    116     @Override
    117     public com.wediscussmovies.project.querymodels.DiscussionLikes findLikesForDiscussionWithId(int discussionId) {
    118         return discussionRepository.findAllWithLikes().stream().filter(d ->  d.getDiscussionId().equals(discussionId)).findFirst().get();
    119     }
    120 
    121103
    122104    @Override
Note: See TracChangeset for help on using the changeset viewer.