/* * (non-Javadoc) * * @see * com.doudou.database.service.post.IRepostService#queryWarnPostComments * (int, int, java.lang.String) */ public Pager queryWarnPostComments(int pageNo, int pageSize, String accountId) throws BusinessException { try { Pager pager = new Pager(pageNo, pageSize); int thisPage = (pageNo - 1) * pageSize;
// 获取该人所有的帖子 List<Post> postList = postRepository.getAccountPost(accountId); if (postList.size() == 0) { throw new BusinessException("还未发表帖子!"); } HashMap<Integer, Post> postHashMap = new HashMap<Integer, Post>(); List<Integer> postIdList = new ArrayList<Integer>();
// 将所有帖子id放入PostIdList中，并将帖子信息缓存到hashmap中 for (Post post : postList) { postIdList.add(post.getPostId()); postHashMap.put(post.getPostId(), post); }
// 查询帖子的所有评论贴,并按评论贴的发帖时间进行降序排序 StringBuilder listSql = new StringBuilder( "select * from Repost repost where repost.postId in (:list)" + " order by repost.repostTime DESC");
Query queryList = manager .createNativeQuery(listSql.toString(), Repost.class) .setFirstResult(thisPage).setMaxResults(pageSize); queryList.setParameter("list", postIdList); @SuppressWarnings("unchecked") List<Repost> repostList = queryList.getResultList(); if (repostList.size() == 0) { throw new BusinessException("还没有人评论你的帖子");
}
// 将评论贴与原帖进行相关联 for (Repost repost : repostList) { repost.setPost(postHashMap.get(repost.getPostId())); } // 获取所有的总数 StringBuilder countSql = new StringBuilder( "select count(repost.postId) from Repost repost ,Post post where post.postId=repost.repostId and post.accountId=:accountId"); Query query = manager.createNativeQuery(countSql.toString()); query.setParameter("accountId", accountId); pager.setTotalCount(((BigInteger) query.getSingleResult()) .intValue()); pager.setItems(repostList); return pager; } catch (BusinessException e) { throw e;
} catch (Exception e) { logger.error("query database error", e); throw new BusinessException("query database error");
}
}
转载于:https://www.cnblogs.com/programerlrc/p/4153878.html
相关资源：微信小程序源码-合集4.rar