package com.newvideo.service.imp;
|
|
import java.io.Serializable;
|
import java.math.BigInteger;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.Session;
|
import org.springframework.cache.annotation.Cacheable;
|
import org.springframework.orm.hibernate4.HibernateCallback;
|
import org.springframework.stereotype.Service;
|
|
import com.newvideo.dao.CommentDao;
|
import com.newvideo.dao.CommentReplyDao;
|
import com.newvideo.domain.Comment2;
|
import com.newvideo.domain.CommentReply;
|
import com.newvideo.domain.LoginUser;
|
import com.newvideo.util.Constant;
|
import com.newvideo.util.StringUtil;
|
|
@Service
|
public class CommentService {
|
@Resource
|
private CommentDao commentDao;
|
@Resource
|
private CommentReplyDao commentReplyDao;
|
|
public void addComment2(Comment2 c) {
|
|
commentDao.create(c);
|
}
|
|
@SuppressWarnings("unchecked")
|
@Cacheable(value = "homeCache",key="'getComment2List'+'-'+#videoId+'-'+#thirdType+'-'+#page")
|
public List<Comment2> getComment2List(final String videoId, final String thirdType, final int page) {
|
|
return (List<Comment2>) commentDao.excute(new HibernateCallback<List<Comment2>>() {
|
public List<Comment2> doInHibernate(Session session) throws HibernateException {
|
List<Comment2> list = new ArrayList<Comment2>();
|
try {
|
list = session
|
.createQuery(
|
"from Comment2 c where c.thirdType=? and c.video.id=? and c.show=1 order by c.createtime desc")
|
.setParameter(0, thirdType).setParameter(1, videoId)
|
.setFirstResult((page - 1) * Constant.pageCount).setMaxResults(Constant.pageCount).list();
|
for (Comment2 c : list) {
|
List<CommentReply> li = session.createQuery("from CommentReply cr where cr.comment.id=?")
|
.setParameter(0, c.getId()).list();
|
c.setReplyList(li);
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
@Cacheable(value = "homeCache",key="'getComment2ListCount'+'-'+#videoId+'-'+#thirdType")
|
public long getComment2ListCount(String videoId, String thirdType) {
|
|
return commentDao.getCount(
|
"from Comment2 c where c.thirdType=? and c.video.id=? and c.show=1 order by c.createtime desc",
|
new String[] { thirdType, videoId });
|
}
|
|
public Comment2 getComment2ById(String id) {
|
return commentDao.find(Comment2.class, id);
|
}
|
|
public boolean isHaveNewMessage(String uid) {
|
long count = commentDao.getCount(
|
"select count(*) from CommentReply cr where cr.parent!=null and cr.parent.user.id=? and cr.read=0",
|
new String[] { uid });
|
if (count > 0)
|
return true;
|
else
|
return false;
|
}
|
|
@SuppressWarnings("unchecked")
|
public List<CommentReply> getCommentReplyList(final String uid, final int pageIndex) {
|
return (List<CommentReply>) commentDao.excute(new HibernateCallback<List<CommentReply>>() {
|
public List<CommentReply> doInHibernate(Session session) throws HibernateException {
|
List<CommentReply> crlist = new ArrayList<CommentReply>();
|
try {
|
List<BigInteger> list = session
|
.createSQLQuery(
|
"SELECT cr.id FROM wk_video_comment_reply cr LEFT JOIN wk_video_comment2 c ON cr.`commentid`=c.`id` LEFT JOIN wk_video_comment_reply ccr ON ccr.`id`=cr.`parentid` WHERE (cr.`parentid` IS NULL AND c.`loginuid`=?) OR (cr.`parentid` IS NOT NULL AND ccr.`uid`=?) order by cr.createtime desc")
|
.setParameter(0, uid).setParameter(1, uid)
|
.setFirstResult((pageIndex - 1) * Constant.pageCount).setMaxResults(Constant.pageCount)
|
.list();
|
for (BigInteger c : list) {
|
crlist.add((CommentReply) session.get(CommentReply.class, c + ""));
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return crlist;
|
}
|
});
|
}
|
|
public void updateCommentReply(CommentReply cr) {
|
commentReplyDao.update(cr);
|
}
|
|
public CommentReply getCommentReplay(String id) {
|
return commentReplyDao.find(CommentReply.class, id);
|
}
|
|
public long getCommentReplyListCount(String uid) {
|
|
return commentReplyDao.getCountSQL(
|
"SELECT count(cr.id) FROM wk_video_comment_reply cr LEFT JOIN wk_video_comment2 c ON cr.`commentid`=c.`id` LEFT JOIN wk_video_comment_reply ccr ON ccr.`id`=cr.`parentid` WHERE (cr.`parentid` IS NULL AND c.`loginuid`="
|
+ uid + ") OR (cr.`parentid` IS NOT NULL AND ccr.`uid`=" + uid + ")");
|
}
|
|
@SuppressWarnings("unchecked")
|
public void setCommentReplyRead(final String uid) {
|
commentDao.excute(new HibernateCallback() {
|
public Object doInHibernate(Session session) throws HibernateException {
|
try {
|
List<CommentReply> list = session
|
.createQuery(
|
"from CommentReply cr where (cr.parent!=null and cr.parent.user.id=?) or (cr.parent = null and cr.comment.user.id=?)")
|
.setParameter(0, uid).setParameter(1, uid).list();
|
session.getTransaction().begin();
|
for (CommentReply cr : list) {
|
cr.setRead(true);
|
session.update(cr);
|
}
|
session.flush();
|
session.getTransaction().commit();
|
} catch (Exception e) {
|
e.printStackTrace();
|
session.getTransaction().rollback();
|
}
|
return null;
|
}
|
});
|
}
|
|
public Serializable replyComment(String commentid, String commentReplyId, String uid, String content) {
|
CommentReply cr = new CommentReply();
|
cr.setComment(new Comment2(commentid));
|
cr.setContent(content);
|
cr.setCreatetime(System.currentTimeMillis() + "");
|
if (!StringUtil.isNullOrEmpty(commentReplyId))
|
cr.setParent(new CommentReply(commentReplyId));
|
cr.setRead(false);
|
cr.setUser(new LoginUser(uid));
|
Serializable result = commentReplyDao.save(cr);
|
return result;
|
}
|
|
}
|
