package com.qxueyou.scc.school.service.impl;
|
|
import java.math.BigInteger;
|
import java.util.Date;
|
import java.util.List;
|
|
import org.apache.commons.lang3.StringUtils;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.qxueyou.scc.base.model.FileMeta;
|
import com.qxueyou.scc.base.model.Pager;
|
import com.qxueyou.scc.base.model.Result;
|
//import com.qxueyou.scc.base.service.ICacheService;
|
import com.qxueyou.scc.base.service.impl.CommonAppService;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.operation.comment.mode.Comment;
|
import com.qxueyou.scc.operation.comment.mode.CommentPraise;
|
//import com.qxueyou.scc.comment.service.ICommentService;
|
import com.qxueyou.scc.school.model.SchClassCircle;
|
import com.qxueyou.scc.school.model.SchClassCircleMsg;
|
import com.qxueyou.scc.school.model.SchFile;
|
import com.qxueyou.scc.school.model.SchImg;
|
import com.qxueyou.scc.school.service.IClassCircleService;
|
import com.qxueyou.scc.user.model.User;
|
|
/**
|
* 课程、视频、讲义记录传播轨迹service
|
*
|
* @author lihanqi
|
*
|
*/
|
@Service
|
public class ClassCircleService extends CommonAppService implements IClassCircleService {
|
|
// //共用评论模块
|
// @Autowired
|
// ICommentService commentService;
|
//
|
// //缓存
|
// @Autowired
|
// ICacheService cache;
|
|
// 缓存
|
@SuppressWarnings("unused")
|
private static final String CACHE_MSG_IMGS = "CACHE_MSG_IMGS_";
|
@SuppressWarnings("unused")
|
private static final String CACHE_MSG_FILES = "CACHE_MSG_FILES_";
|
@SuppressWarnings("unused")
|
private static final String CACHE_MSG_COMMENTS = "CACHE_MSG_COMMENTS_";
|
|
@SuppressWarnings("unused")
|
private static final int ONE_DAY = 60 * 60 * 24;
|
|
/**
|
* 获取朋友圈
|
*
|
* @param pager
|
* @return
|
*/
|
public Result doGetMsgList(Pager pager) {
|
String userId = ClientUtils.getUserId();
|
SchClassCircle objSchClassCircle = this.getSchClassCircle(userId);
|
if (objSchClassCircle == null) {
|
this.addSchClassCircle(userId);
|
}
|
|
List<SchClassCircleMsg> lstSchClassCircleMsg = this.findList(
|
"from SchClassCircleMsg where deleteFlag is false and classId = ? order by createTime desc", pager,
|
CollectionUtils.newList(ClientUtils.getClassId()), SchClassCircleMsg.class);
|
|
if (lstSchClassCircleMsg != null && !lstSchClassCircleMsg.isEmpty()) {
|
// 缓存中获取评论
|
for (SchClassCircleMsg objSchClassCircleMsg : lstSchClassCircleMsg) {
|
objSchClassCircleMsg = this.packageMsg(objSchClassCircleMsg);
|
User user = this.read(User.class, objSchClassCircleMsg.getUserId());
|
objSchClassCircleMsg.setName(user.getName());
|
objSchClassCircleMsg.setImgPath(user.getImgPath());
|
objSchClassCircleMsg
|
.setMyLike(this.findCount("from CommentPraise where commentId = ? and commentterId = ?",
|
CollectionUtils.newList(objSchClassCircleMsg.getMsgId(), userId)) > 0 ? true : false);
|
}
|
}
|
|
return new Result(true, "", lstSchClassCircleMsg);
|
}
|
|
/**
|
* 获取消息的评论图片和文件
|
*
|
* @param objSchClassCircleMsg
|
* @return
|
*/
|
@SuppressWarnings("unused")
|
public SchClassCircleMsg packageMsg(SchClassCircleMsg objSchClassCircleMsg) {
|
String msgId = objSchClassCircleMsg.getMsgId();
|
// List<SchImg> imgs = cache.get(CACHE_MSG_IMGS + msgId, List.class);
|
//
|
// List<SchFile> files = cache.get(CACHE_MSG_FILES + msgId, List.class);
|
|
List<Comment> comments = this.updateComment(msgId, false);
|
|
// if(imgs == null || imgs.isEmpty()){
|
// imgs = this.find("from SchImg where deleteFlag is false and objectId = ?
|
// order by orderNo asc, createTime asc", CollectionUtils.newList(msgId),
|
// SchImg.class);
|
//
|
// cache.set(CACHE_MSG_IMGS + msgId, ONE_DAY, imgs);
|
// }
|
//
|
// if(files == null || files.isEmpty()){
|
// files = this.find("from SchFile where deleteFlag is false and objectId = ?
|
// order by orderNo asc, createTime asc", CollectionUtils.newList(msgId),
|
// SchFile.class);
|
//
|
// cache.set(CACHE_MSG_FILES + msgId, ONE_DAY, files);
|
// }
|
//
|
// objSchClassCircleMsg.setImgs(imgs);
|
// objSchClassCircleMsg.setFiles(files);
|
// objSchClassCircleMsg.setComments(comments);
|
|
return objSchClassCircleMsg;
|
}
|
|
/**
|
* 获取评论
|
*
|
* @param msgId
|
* @return
|
*/
|
private List<Comment> updateComment(String msgId, boolean isUpdate) {
|
// List<Comment> comments = cache.get(CACHE_MSG_COMMENTS + msgId, List.class);
|
List<Comment> comments = null;
|
|
if (comments == null || comments.isEmpty() || isUpdate) {
|
comments = this.find(
|
"from Comment where deleteFlag is false and commentObjectId = ? order by createTime asc",
|
CollectionUtils.newList(msgId), Comment.class);
|
|
// cache.set(CACHE_MSG_COMMENTS + msgId, ONE_DAY, comments);
|
}
|
|
return comments;
|
}
|
|
/**
|
* 获取朋友圈
|
*
|
* @return
|
*/
|
private SchClassCircle getSchClassCircle(String userId) {
|
return this.findUnique("from SchClassCircle where deleteFlag is false and userId = ?",
|
CollectionUtils.newList(userId), SchClassCircle.class);
|
}
|
|
/**
|
* 初始化朋友圈
|
*
|
* @param userId
|
* @return
|
*/
|
public String addSchClassCircle(String userId) {
|
SchClassCircle objSchClassCircle = new SchClassCircle();
|
objSchClassCircle.setUserId(userId);
|
objSchClassCircle.setEnable(true);
|
|
TraceUtils.setCreateTrace(objSchClassCircle);
|
|
this.save(objSchClassCircle);
|
|
return objSchClassCircle.getClassCircleId();
|
}
|
|
/**
|
* 发朋友圈
|
*
|
* @param userId
|
* @return
|
*/
|
public Result addMsg(SchClassCircleMsg classCircleMsg) {
|
|
classCircleMsg.setUserId(ClientUtils.getUserId());
|
classCircleMsg.setClassId(ClientUtils.getClassId());
|
classCircleMsg.setOrgId(ClientUtils.getOrgId());
|
classCircleMsg.setCommentCount(0);
|
classCircleMsg.setLikeCount(0);
|
classCircleMsg.setMyLike(false);
|
classCircleMsg.setDeleteFlag(false);
|
|
TraceUtils.setCreateTrace(classCircleMsg);
|
|
this.save(classCircleMsg);
|
|
// 添加图片
|
if (StringUtils.isNoneBlank(classCircleMsg.getImgsJson())) {
|
this.addFile(classCircleMsg.getImgsJson(), classCircleMsg.getMsgId(), "class_circle_img");
|
}
|
|
// 添加文件
|
if (StringUtils.isNoneBlank(classCircleMsg.getFilesJson())) {
|
this.addFile(classCircleMsg.getFilesJson(), classCircleMsg.getMsgId(), "class_circle_file");
|
}
|
|
return new Result(true, "", classCircleMsg);
|
}
|
|
/**
|
* 点赞
|
*
|
* @param msgId
|
* @return
|
*/
|
public Result doLike(String msgId) {
|
|
CommentPraise praiseObj = new CommentPraise();
|
praiseObj.setCommentId(msgId);
|
praiseObj.setPraise(true);
|
praiseObj.setCommentterId(ClientUtils.getUserId());
|
praiseObj.setCommentter(ClientUtils.getUserName());
|
praiseObj.setPraiseTime(new Date(System.currentTimeMillis()));
|
praiseObj.setDeleteFlag(false);
|
|
TraceUtils.setCreateTrace(praiseObj);
|
|
this.save(praiseObj);
|
|
this.bulkUpdate("update SchClassCircleMsg set likeCount = likeCount +1 where msgId = ?",
|
new Object[] { msgId });
|
|
Integer likeCount = this.findUnique("select likeCount from SchClassCircleMsg where msgId = ?",
|
CollectionUtils.newList(msgId), Integer.class);
|
return new Result(true, "", likeCount);
|
}
|
|
/**
|
* 评论
|
*
|
* @param msgId
|
* @param content
|
* @param parentCommentId
|
* @return
|
*/
|
public Result addComment(String msgId, String content, String parentCommentId) {
|
|
// 评论表
|
Comment comment = new Comment();
|
comment.setCommentterId(ClientUtils.getUserId());
|
comment.setCommentter(ClientUtils.getUserName());
|
comment.setCommentterHeadimg(ClientUtils.getUserImg());
|
comment.setContent(content);
|
comment.setCommentCount(BigInteger.ZERO);
|
comment.setCommentPraiseCount(BigInteger.ZERO);
|
comment.setCommentObjectId(msgId);
|
comment.setCommentTime(new Date(System.currentTimeMillis()));
|
comment.setCommentParentId(parentCommentId);
|
comment.setClassId(ClientUtils.getClassId());
|
TraceUtils.setCreateTrace(comment);
|
|
if (StringUtils.isNotEmpty(parentCommentId)) {
|
Comment parentComment = this.read(Comment.class, parentCommentId);
|
|
comment.setCommentedName(parentComment.getCommentter());
|
comment.setCommentedId(parentComment.getCommentterId());
|
}
|
|
this.save(comment);
|
|
this.bulkUpdate("update SchClassCircleMsg set commentCount = commentCount +1 where msgId = ?",
|
new Object[] { msgId });
|
|
this.updateComment(msgId, true);
|
|
return new Result(true, "", comment);
|
}
|
|
/**
|
* 删除评论
|
*
|
* @param msgId
|
* @param commentId
|
* @return
|
*/
|
public Result deleteComment(String msgId, String commentId) {
|
|
this.bulkUpdate("update Comment set deleteFlag = 1 where commentId = ? ", new Object[] { commentId });
|
this.bulkUpdate("update SchClassCircleMsg set commentCount = commentCount - 1 where msgId = ?",
|
new Object[] { msgId });
|
|
this.updateComment(msgId, true);
|
|
return new Result(true);
|
}
|
|
/**
|
* 点赞
|
*
|
* @param msgId
|
* @return
|
*/
|
public Result deleteLike(String msgId) {
|
|
this.bulkUpdate("update CommentPraise set deleteFlag = 1 where commentId = ? and commentterId = ?",
|
new Object[] { msgId, ClientUtils.getUserId() });
|
this.bulkUpdate("update SchClassCircleMsg set likeCount = likeCount - 1 where msgId = ?",
|
new Object[] { msgId });
|
|
return new Result(true);
|
}
|
|
/**
|
* 删除文件
|
*
|
* @param filesJson
|
* @param fileType
|
* @return
|
*/
|
public Result deleteFile(String fileId, String fileType) {
|
if ("class_circle_img".equals(fileType)) {
|
this.bulkUpdate("update SchImg set deleteFlag = true where imgId = ?", new Object[] { fileId });
|
} else {
|
this.bulkUpdate("update SchFile set deleteFlag = true where fileId = ?", new Object[] { fileId });
|
}
|
|
return new Result(true);
|
}
|
|
/**
|
* 新增文件
|
*
|
* @param filesJson
|
* @param fileType
|
* @return
|
*/
|
public Result addFile(String filesJson, String msgId, String fileType) {
|
|
List<FileMeta> files = JSONArray.parseArray(filesJson, FileMeta.class);
|
|
SchImg img = null;
|
SchFile file = null;
|
int i = 0;
|
for (FileMeta fileMeta : files) {
|
if ("class_circle_file".equals(fileType)) {
|
file = new SchFile();
|
file.setDeleteFlag(false);
|
file.setObjectId(msgId);
|
file.setFileType(fileMeta.getFileType());
|
file.setObjectType("SCH_CLASS_CIRCLE");
|
file.setSize(fileMeta.getFileSize());
|
file.setFileName(fileMeta.getFileName());
|
file.setOrderNo(i);
|
TraceUtils.setCreateTrace(file);
|
|
i++;
|
this.save(file);
|
} else {
|
img = new SchImg();
|
img.setDeleteFlag(false);
|
img.setObjectId(msgId);
|
img.setImgType(fileMeta.getFileType());
|
img.setObjectType("SCH_CLASS_CIRCLE");
|
img.setSize(fileMeta.getFileSize());
|
img.setOrderNo(i);
|
TraceUtils.setCreateTrace(img);
|
|
i++;
|
this.save(img);
|
}
|
}
|
return new Result(true);
|
}
|
}
|
