BlogPostServiceImpl.java

@Service
public class BlogPostServiceImpl implements BlogPostService {

    @Autowired
    private UserService userService;

    @Autowired
    private BlogPostRepository blogPostRepository;

    @Autowired
    BlogMapper blogMapper;

    @Override
    public BlogPost create(BlogPost blogPost) {

	return blogPostRepository.save(blogPost);

    }

    @Override
    public BlogPost findById(Integer blogId) throws Exception {

	Optional<BlogPost> blogPost =  blogPostRepository.findById(blogId);
	
	return blogPost.orElseThrow(() -> new Exception("blog Post not found"));

    }
    
    @Override
    public boolean exists(Integer blogPostId) {
	
	return blogPostRepository.existsById(blogPostId);
	
    }

    @Override
    public void archiveBlogPost() {

	blogPostRepository.archiveBlogPost(BlogStatus.ARCHIVED, new Date());

    }

    @Override
    public String createImage(String name, MultipartFile file, String path) throws Exception {
	try {
	    File image = new File(path + name);
	    BufferedOutputStream stream = new BufferedOutputStream(new FileOutputStream(image));
	    stream.write(file.getBytes());
	    stream.close();

	    return name;
	} catch (Exception e) {
	    throw e;
	}
    }

    @Override
    public BlogDto createBlogPost(BlogDto blogDto, String imagePath) throws Exception {

	Boolean exist = exists(blogDto.getId());
	BlogPost blogPost = new BlogPost();

	if (exist) {
	    blogPost = findById(blogDto.getId());
	}

	blogPost.setTitle(blogDto.getTitle());
	blogPost.setContent(blogDto.getContent());

	if (!imagePath.isEmpty()) {
	    blogPost.setImage(imagePath);
	}

	if (blogDto.isPreview() || blogDto.isSave()) {

	    blogPost.setStatus(BlogStatus.DRAFT);

	} else {

	    blogPost.setStatus(BlogStatus.READY);

	}

	Authentication auth = SecurityContextHolder.getContext().getAuthentication();
	User user = userService.findUserByEmail(auth.getName());
	blogPost.setEditor(user);

	if (exist) {
	    blogPost.setModifyBy(auth.getName());
	    blogPost.setModifyTime(new Date());
	} else {
	    blogPost.setCreateBy(auth.getName());
	    blogPost.setCreateTime(new Date());
	    blogPost.setModifyBy(auth.getName());
	    blogPost.setModifyTime(new Date());
	}

	create(blogPost);

	return blogMapper.createDtoFromBlogPost(blogPost);

    }

    @Override
    public void changeStatus(Integer blogPostId, Boolean approve, String date) throws ParseException {

	SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yyyy");
	BlogStatus status;

	if (approve) {
	    status = BlogStatus.PUBLISHED;
	} else {
	    status = BlogStatus.REJECT;
	}

	if (date.isEmpty()) {
	    blogPostRepository.updateBlogPostSetStatusById(status, blogPostId);
	} else {
	    blogPostRepository.updateBlogPostSetStatusDateById(status, blogPostId, formatter.parse(date));

	}

    }

    @Override
    public List<BlogDto> getAll() {

	Authentication auth = SecurityContextHolder.getContext().getAuthentication();
	User user = userService.findUserByEmail(auth.getName());

	List<BlogDto> blogPostList;

	if (user.getRole().getName().equals("EDITOR")) {

	    blogPostList = user.getPosts()
		    .stream()
		    .sorted((o1, o2) -> o2.getId() - o1.getId())
		    .map(blogMapper::createDtoFromBlogPost)
		    .collect(Collectors.toList());

	} else {

	    blogPostList = blogPostRepository.findByOrderByIdDesc()
		    .stream()
		    .map(blogMapper::createDtoFromBlogPost)
		    .collect(Collectors.toList());

	}

	return blogPostList;

    }

    @Override
    public BlogDto findByIdtoShow(Integer blogId) throws Exception {
	BlogPost blogPost = findById(blogId);
	return blogMapper.createDtoFromBlogPost(blogPost);
    }
    
    

}