|
|
@@ -0,0 +1,1774 @@
|
|
|
+package com.ruoyi.generator.service.impl;
|
|
|
+
|
|
|
+import com.alibaba.fastjson2.JSONObject;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import com.ruoyi.common.constant.CacheConstants;
|
|
|
+import com.ruoyi.common.core.domain.entity.SysUser;
|
|
|
+import com.ruoyi.common.core.page.TableDataInfo;
|
|
|
+import com.ruoyi.common.core.redis.RedisCache;
|
|
|
+import com.ruoyi.common.utils.DateUtils;
|
|
|
+import com.ruoyi.common.utils.SecurityUtils;
|
|
|
+import com.ruoyi.common.utils.bean.BeanUtils;
|
|
|
+import com.ruoyi.common.utils.ip.AddressUtils;
|
|
|
+import com.ruoyi.generator.domain.Community.*;
|
|
|
+import com.ruoyi.generator.mapper.community.*;
|
|
|
+import com.ruoyi.generator.service.*;
|
|
|
+import com.ruoyi.generator.vo.*;
|
|
|
+import com.ruoyi.system.mapper.SysUserMapper;
|
|
|
+import org.apache.ibatis.annotations.Param;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.data.redis.core.RedisTemplate;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import java.net.HttpURLConnection;
|
|
|
+import java.net.URL;
|
|
|
+import java.text.ParseException;
|
|
|
+import java.time.LocalDate;
|
|
|
+import java.time.ZoneId;
|
|
|
+import java.time.temporal.ChronoUnit;
|
|
|
+import java.util.*;
|
|
|
+import java.util.concurrent.ExecutionException;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
+import java.util.regex.Pattern;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 业务 服务层实现
|
|
|
+ *
|
|
|
+ * @author ruoyi
|
|
|
+ */
|
|
|
+@Service
|
|
|
+public class CommunityArticleServiceImpl extends ServiceImpl<CommunityArticleMapper, CommunityArticle> implements ICommunityArticleService {
|
|
|
+ private static final Logger log = LoggerFactory.getLogger(CommunityArticleServiceImpl.class);
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleMapper communityArticleMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private SysUserMapper sysUserMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityLikeMapper communityLikeMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityCollectMapper communityCollectMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleCommentMapper communityArticleCommentMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityCommentLikeMapper communityCommentLikeMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleTagMapper articleTagMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleTagMapper communityArticleTagMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityTagMapper communityTagMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleImagesMapper communityArticleImagesMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityClassCircleMapper communityClassCircleMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityCircleMapper communityCircleMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityUserCircleMapper communityUserCircleMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityUserLikeMapper communityUserLikeMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityUserInfoMapper communityUserInfoMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ICommunityArticleClassService communityArticleClassService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityCollectionArticleMapper communityCollectionArticleMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ICommunityCollectionArticleService collectionArticleService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityTagBlockMapper communityTagBlockMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleRecommendMapper recommendMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ICommunityArticleService communityArticleService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ICommunityPrivacyService communityPrivacyService;
|
|
|
+ @Autowired
|
|
|
+ private CommunityCollectionMapper communityCollectionMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityUserBlockMapper communityUserBlockMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityUserPromptMapper communityUserPromptMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleCollectMapper communityArticleCollectMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityCommentRaffleMapper communityCommentRaffleMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private CommunityArticleCircleMapper communityArticleCircleMapper;
|
|
|
+ @Autowired
|
|
|
+ private RedisCache redisCache;
|
|
|
+ @Autowired
|
|
|
+ private RedisTemplate<Object, Object> redisTemplate;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ICommunityArticleAtService communityArticleAtService;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询文章列表
|
|
|
+ *
|
|
|
+ * @param communityArticle 文章信息
|
|
|
+ * @return 文章信息集合
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityArticleVo> selectCommunityArticleList(Long userId, TableDataInfo rspData, CommunityArticle communityArticle, int pageNum, int pageSize, int searchType) {
|
|
|
+
|
|
|
+ List<CommunityArticleVo> communityArticleVos = null;
|
|
|
+ //找出板块下的分类
|
|
|
+ List<Long> classIds = communityArticle.getClassIds();
|
|
|
+ System.out.println("classIds: " + classIds);
|
|
|
+ if (classIds != null && classIds.contains(19L)) { // Check for null and then use contains()
|
|
|
+ classIds = null;
|
|
|
+ searchType = 3;
|
|
|
+ }
|
|
|
+
|
|
|
+ Long id = communityArticle.getId();
|
|
|
+ List<Long> articleIds = communityArticle.getArticleIds();
|
|
|
+ Integer pageTagType = communityArticle.getPageTagType();
|
|
|
+ Integer noCollection = communityArticle.getNoCollection();
|
|
|
+ if (pageTagType != null && pageTagType == 1) {
|
|
|
+ List<CommunityUserLikeVo> communityUserLikeVos = selectCommunityUserLikeList(SecurityUtils.getUserId(), null, 1, 999999, 1);
|
|
|
+ if (communityUserLikeVos.isEmpty()) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ List<Long> likeUserIds = communityUserLikeVos.stream().map(CommunityUserLikeVo::getLikeUserId).collect(Collectors.toList());
|
|
|
+ communityArticle.setUserIds(likeUserIds);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(id)) {
|
|
|
+ //获取指定文章详细内容,文章浏览量+1
|
|
|
+ CommunityArticle article = communityArticleMapper.selectById(id);
|
|
|
+ article.setPageViews(article.getPageViews() + 1);
|
|
|
+ communityArticleMapper.updateById(article);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (articleIds != null && !articleIds.isEmpty()) {
|
|
|
+ for (Long articleId : articleIds) {
|
|
|
+ //获取指定文章详细内容,文章浏览量+1
|
|
|
+ CommunityArticle article = communityArticleMapper.selectById(articleId);
|
|
|
+ article.setPageViews(article.getPageViews() + 1);
|
|
|
+ communityArticleMapper.updateById(article);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ Boolean isDraft = communityArticle.getIsDraft();
|
|
|
+ //判断草稿箱是否为空 为空则为false
|
|
|
+ if (isDraft == null) {
|
|
|
+ communityArticle.setIsDraft(false);
|
|
|
+ }
|
|
|
+
|
|
|
+ //根据分类查找文章
|
|
|
+ int offset = (pageNum - 1) * pageSize;
|
|
|
+ communityArticleVos = communityArticleMapper.selectCommunityArticleList(communityArticle, classIds, offset, pageSize, searchType, userId);
|
|
|
+
|
|
|
+ List<CommunityArticleVo> articleVos_copy = new ArrayList<>(communityArticleVos);
|
|
|
+ if (noCollection != null) {
|
|
|
+ if (noCollection == 1) {
|
|
|
+ //剔除是否有合集文章
|
|
|
+ List<Long> ids = communityArticleVos.stream().map(CommunityArticleVo::getId).collect(Collectors.toList());
|
|
|
+ if (!ids.isEmpty()) {
|
|
|
+ List<CommunityCollectionArticle> collections = communityCollectionArticleMapper.selectList(new QueryWrapper<CommunityCollectionArticle>()
|
|
|
+ .in("article_id", ids)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ }));
|
|
|
+
|
|
|
+ for (CommunityArticleVo communityArticleVo : articleVos_copy) {
|
|
|
+ for (CommunityCollectionArticle collection : collections) {
|
|
|
+ if (collection.getArticleId().equals(communityArticleVo.getId())) {
|
|
|
+ communityArticleVos.remove(communityArticleVo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ rspData.setTotal(communityArticleVos.size());
|
|
|
+ List<CommunityArticleVo> communityArticleVos_copy = new ArrayList<>(communityArticleVos);
|
|
|
+ for (CommunityArticleVo articleVo : communityArticleVos_copy) {
|
|
|
+ //判断当前文章是否被用户拉黑
|
|
|
+ List<CommunityUserBlock> communityUserBlocks = communityUserBlockMapper.selectList(new QueryWrapper<CommunityUserBlock>()
|
|
|
+ .eq("user_id", userId)
|
|
|
+ .eq("peer_id", articleVo.getUserId()));
|
|
|
+
|
|
|
+ for (CommunityUserBlock userBlock : communityUserBlocks) {
|
|
|
+ if (userBlock.isBlock()) {
|
|
|
+ articleVo.setBlock(userBlock.isBlock());
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取文章是否被关注
|
|
|
+ List<CommunityUserLike> communityUserLikes = communityUserLikeMapper.selectList(new QueryWrapper<CommunityUserLike>()
|
|
|
+ .eq("user_id", userId)
|
|
|
+ .eq("like_user_id", articleVo.getUserId())
|
|
|
+ );
|
|
|
+
|
|
|
+ for (CommunityUserLike communityUserLike : communityUserLikes) {
|
|
|
+ articleVo.setCare(communityUserLike.getUserId() != null);
|
|
|
+ }
|
|
|
+
|
|
|
+ /* communityArticleMapper.selectList();
|
|
|
+ articleVo.setCare();*/
|
|
|
+
|
|
|
+ List<Map<String, Object>> imageList = articleVo.getImageList();
|
|
|
+
|
|
|
+ //设置文章的板块
|
|
|
+ List<CommunityArticleClass> articleId = communityArticleCircleMapper.selectList(
|
|
|
+ new QueryWrapper<CommunityArticleClass>()
|
|
|
+ .eq("article_id", articleVo.getId())
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ })
|
|
|
+ );
|
|
|
+ // 使用 Java Streams API 提取 classId，并转换成 List<Long>
|
|
|
+ List<Long> classIdss = articleId.stream()
|
|
|
+ .map(CommunityArticleClass::getClassId)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ articleVo.setClassIds(classIdss);
|
|
|
+
|
|
|
+
|
|
|
+ List<CommunityArticleImages> videoList = new ArrayList<>();
|
|
|
+ CommunityArticleImages videos = null;
|
|
|
+ List<Map<String, Object>> imageList_copy = new ArrayList<>(imageList);
|
|
|
+ for (Map<String, Object> image : imageList_copy) {
|
|
|
+ String imageUrl = image.get("imageUrl").toString();
|
|
|
+ //判断是否是视频
|
|
|
+ boolean isVideo = isVideoFile(imageUrl);
|
|
|
+ if (isVideo) {
|
|
|
+ imageList.remove(image);
|
|
|
+ videos = JSONObject.parseObject(JSONObject.toJSONString(image), CommunityArticleImages.class);
|
|
|
+ //BeanUtils.copyProperties(image, videos);
|
|
|
+ videoList.add(videos);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ articleVo.setVideoList(videoList);
|
|
|
+
|
|
|
+ //设置评论回复数量
|
|
|
+ articleVo.setCommentCount(communityArticleCommentMapper.queryCommentCount(articleVo.getId()));
|
|
|
+ //设置文章的点赞数量
|
|
|
+ articleVo.setLikeCount(communityLikeMapper.selectList(new QueryWrapper<CommunityLike>().eq("article_id", articleVo.getId())).size());
|
|
|
+ //设置文章的收藏数量
|
|
|
+ articleVo.setCollectCount(communityCollectMapper.selectList(new QueryWrapper<CommunityArticleCollect>().eq("article_id", articleVo.getId())).size());
|
|
|
+ //设置文章推荐数量
|
|
|
+ articleVo.setRecommendCount(recommendMapper.selectList(new QueryWrapper<CommunityArticleRecommend>()
|
|
|
+ .eq("article_id", articleVo.getId())
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ })).size());
|
|
|
+ //设置文章所属合集
|
|
|
+ articleVo.setCollectionVo(communityCollectionMapper.selectCollectById(userId, articleVo.getId()));
|
|
|
+
|
|
|
+
|
|
|
+ //设置中奖信息
|
|
|
+ CommunityCommentRaffleVo communityCommentRaffleVo = new CommunityCommentRaffleVo();
|
|
|
+ CommunityCommentRaffle communityCommentRaffle = communityCommentRaffleMapper.selectOne(
|
|
|
+ new QueryWrapper<CommunityCommentRaffle>()
|
|
|
+ .eq("article_id", articleVo.getId())
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ }));
|
|
|
+ if (communityCommentRaffle != null) {
|
|
|
+ BeanUtils.copyProperties(communityCommentRaffle, communityCommentRaffleVo);
|
|
|
+ CommunityUserInfoVo communityUserInfoVo = communityArticleService.selectCommunityUserInfoById(communityCommentRaffle.getUserId(), false);
|
|
|
+ communityCommentRaffleVo.setUserName(communityUserInfoVo.getNickName());
|
|
|
+ communityCommentRaffleVo.setUserAvatar(communityUserInfoVo.getAvatar());
|
|
|
+ articleVo.setCommentRaffleVo(communityCommentRaffleVo);
|
|
|
+ }
|
|
|
+ //文章下的评论
|
|
|
+// List<Map<String, Object>> comments = articleVo.getComments();
|
|
|
+// for (Map<String, Object> communityArticleCommentVo : comments) {
|
|
|
+// String commentUserId = communityArticleCommentVo.get("userId").toString();
|
|
|
+// if (Objects.isNull(commentUserId)) {
|
|
|
+// break;
|
|
|
+// }
|
|
|
+// //获取评论的用户信息
|
|
|
+// SysUser sysUser = sysUserMapper.selectUserById(Long.parseLong(commentUserId));
|
|
|
+// communityArticleCommentVo.put("username", sysUser.getUserName());
|
|
|
+// communityArticleCommentVo.put("avatar", sysUser.getAvatar());
|
|
|
+// //当前登录用户是否已点赞
|
|
|
+// List<CommunityCommentLike> commentLikes = communityCommentLikeMapper.selectList(new QueryWrapper<CommunityCommentLike>().eq("comment_id", communityArticleCommentVo.get("id")).eq("user_id", userId));
|
|
|
+// communityArticleCommentVo.put("commentLike", !commentLikes.isEmpty());
|
|
|
+//
|
|
|
+// //该评论的点赞数量
|
|
|
+// communityArticleCommentVo.put("commentLikeCount", communityCommentLikeMapper.selectList(new QueryWrapper<CommunityCommentLike>().eq("comment_id", communityArticleCommentVo.get("id"))).size());
|
|
|
+// }
|
|
|
+
|
|
|
+ //判断是否已收藏
|
|
|
+ CommunityArticleCollect collect = communityCollectMapper.selectOne(new QueryWrapper<CommunityArticleCollect>().eq("user_id", userId).eq("article_id", articleVo.getId()));
|
|
|
+ articleVo.setCollect(!Objects.isNull(collect));
|
|
|
+
|
|
|
+ //判断是否已点赞
|
|
|
+ CommunityLike like = communityLikeMapper.selectOne(new QueryWrapper<CommunityLike>().eq("user_id", userId).eq("article_id", articleVo.getId()));
|
|
|
+ articleVo.setLike(!Objects.isNull(like));
|
|
|
+
|
|
|
+ //判断是否已推荐
|
|
|
+ CommunityArticleRecommend recommend = recommendMapper.selectOne(new QueryWrapper<CommunityArticleRecommend>()
|
|
|
+ .eq("user_id", userId)
|
|
|
+ .eq("article_id", articleVo.getId()).and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ }));
|
|
|
+ articleVo.setRecommend(!Objects.isNull(recommend));
|
|
|
+
|
|
|
+ //获取文章标签
|
|
|
+ List<CommunityArticleTag> articleTags = communityArticleTagMapper.selectList(new QueryWrapper<CommunityArticleTag>()
|
|
|
+ .eq("article_id", articleVo.getId())
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ }));
|
|
|
+ List<Long> tagList = articleTags.stream().map(CommunityArticleTag::getTagId).collect(Collectors.toList());
|
|
|
+ List<Long> tagIds = new ArrayList<>();
|
|
|
+
|
|
|
+ if (!tagList.isEmpty()) {
|
|
|
+ //判断当前标签是否被当前登录用户拉黑
|
|
|
+ List<CommunityTagBlock> communityTagBlocks = communityTagBlockMapper.selectList(new QueryWrapper<CommunityTagBlock>()
|
|
|
+ .in("tag_id", tagList)
|
|
|
+ .eq("user_id", userId)
|
|
|
+ .eq("is_block", 1));
|
|
|
+
|
|
|
+ for (CommunityTagBlock tagBlock : communityTagBlocks) {
|
|
|
+ if (tagBlock.isBlock()) {
|
|
|
+ communityArticleVos.remove(articleVo);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ tagIds.add(tagBlock.getTagId());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (communityTagBlocks.isEmpty()) {
|
|
|
+ tagIds.addAll(tagList);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!tagIds.isEmpty()) {
|
|
|
+ List<CommunityTag> communityTags = communityTagMapper.selectBatchIds(tagIds);
|
|
|
+ articleVo.setTags(communityTags);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return communityArticleVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询文章列表
|
|
|
+ *
|
|
|
+ * @param communityArticle 文章信息
|
|
|
+ * @return 文章信息集合
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityArticleVo> selectCommunityArticleList1(Long userId, TableDataInfo rspData, CommunityArticle communityArticle, int pageNum, int pageSize, int searchType) {
|
|
|
+
|
|
|
+ List<CommunityArticleVo> communityArticleVos = null;
|
|
|
+ //找出板块下的分类
|
|
|
+ List<Long> classIds = communityArticle.getClassIds();
|
|
|
+ Long id = communityArticle.getId();
|
|
|
+ List<Long> articleIds = communityArticle.getArticleIds();
|
|
|
+ Integer pageTagType = communityArticle.getPageTagType();
|
|
|
+ Integer noCollection = communityArticle.getNoCollection();
|
|
|
+ if (pageTagType != null && pageTagType == 1) {
|
|
|
+ List<CommunityUserLikeVo> communityUserLikeVos = selectCommunityUserLikeList(SecurityUtils.getUserId(), null, 1, 999999, 1);
|
|
|
+ if (communityUserLikeVos.isEmpty()) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ List<Long> likeUserIds = communityUserLikeVos.stream().map(CommunityUserLikeVo::getLikeUserId).collect(Collectors.toList());
|
|
|
+ communityArticle.setUserIds(likeUserIds);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(id)) {
|
|
|
+ //获取指定文章详细内容,文章浏览量+1
|
|
|
+ CommunityArticle article = communityArticleMapper.selectById(id);
|
|
|
+ article.setPageViews(article.getPageViews() + 1);
|
|
|
+ communityArticleMapper.updateById(article);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (articleIds != null && !articleIds.isEmpty()) {
|
|
|
+ for (Long articleId : articleIds) {
|
|
|
+ //获取指定文章详细内容,文章浏览量+1
|
|
|
+ CommunityArticle article = communityArticleMapper.selectById(articleId);
|
|
|
+ article.setPageViews(article.getPageViews() + 1);
|
|
|
+ communityArticleMapper.updateById(article);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //根据分类查找文章
|
|
|
+ int offset = (pageNum - 1) * pageSize;
|
|
|
+ communityArticleVos = communityArticleMapper.selectCommunityArticleList(communityArticle, classIds, offset, pageSize, searchType, userId);
|
|
|
+
|
|
|
+ List<CommunityArticleVo> articleVos_copy = new ArrayList<>(communityArticleVos);
|
|
|
+ if (noCollection != null) {
|
|
|
+ if (noCollection == 1) {
|
|
|
+ //剔除是否有合集文章
|
|
|
+ List<Long> ids = communityArticleVos.stream().map(CommunityArticleVo::getId).collect(Collectors.toList());
|
|
|
+ if (!ids.isEmpty()) {
|
|
|
+ List<CommunityCollectionArticle> collections = communityCollectionArticleMapper.selectList(new QueryWrapper<CommunityCollectionArticle>()
|
|
|
+ .in("article_id", ids)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ }));
|
|
|
+
|
|
|
+ for (CommunityArticleVo communityArticleVo : articleVos_copy) {
|
|
|
+ for (CommunityCollectionArticle collection : collections) {
|
|
|
+ if (collection.getArticleId().equals(communityArticleVo.getId())) {
|
|
|
+ communityArticleVos.remove(communityArticleVo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //数据拉取区域
|
|
|
+ //判断当前文章是否被用户拉黑
|
|
|
+ //用户拉黑数据
|
|
|
+ List<CommunityUserBlock> communityUserBlocks = redisCache.getCacheList(CacheConstants.COMMUNITY_USER_BLOCK);
|
|
|
+ if (communityUserBlocks.isEmpty()) {
|
|
|
+ communityUserBlocks = communityUserBlockMapper.selectList(new QueryWrapper<CommunityUserBlock>());
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_USER_BLOCK, communityUserBlocks);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_USER_BLOCK, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //关注数据
|
|
|
+ List<CommunityUserLike> communityUserLikes = redisCache.getCacheList(CacheConstants.COMMUNITY_USER_LIKE);
|
|
|
+ if (communityUserLikes.isEmpty()) {
|
|
|
+ communityUserLikes = communityUserLikeMapper.selectList(new QueryWrapper<CommunityUserLike>());
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_USER_LIKE, communityUserLikes);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_USER_LIKE, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章板块数据
|
|
|
+ List<CommunityArticleClass> communityArticleClasses = redisCache.getCacheList(CacheConstants.COMMUNITY_ARTICLE_CLASS);
|
|
|
+ if (communityArticleClasses.isEmpty()) {
|
|
|
+ communityArticleClasses = communityArticleCircleMapper.selectList(new QueryWrapper<CommunityArticleClass>().eq("is_delete", false));
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_ARTICLE_CLASS, communityArticleClasses);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_ARTICLE_CLASS, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章点赞数据
|
|
|
+ List<CommunityLike> communityLikes = redisCache.getCacheList(CacheConstants.COMMUNITY_LIKE);
|
|
|
+ if (communityLikes.isEmpty()) {
|
|
|
+ communityLikes = communityLikeMapper.selectList(new QueryWrapper<CommunityLike>());
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_LIKE, communityLikes);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_LIKE, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章收藏数据
|
|
|
+ List<CommunityArticleCollect> communityArticleCollects = redisCache.getCacheList(CacheConstants.COMMUNITY_COLLECT);
|
|
|
+ if (communityArticleCollects.isEmpty()) {
|
|
|
+ communityArticleCollects = communityCollectMapper.selectList(new QueryWrapper<CommunityArticleCollect>());
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_COLLECT, communityArticleCollects);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_COLLECT, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章推荐数据
|
|
|
+ List<CommunityArticleRecommend> communityArticleRecommends = redisCache.getCacheList(CacheConstants.COMMUNITY_ARTICLE_RECOMMEND);
|
|
|
+ if (communityArticleRecommends.isEmpty()) {
|
|
|
+ communityArticleRecommends = recommendMapper.selectList(new QueryWrapper<CommunityArticleRecommend>().eq("is_delete", false));
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_ARTICLE_RECOMMEND, communityArticleRecommends);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_ARTICLE_RECOMMEND, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //中奖信息数据
|
|
|
+ List<CommunityCommentRaffle> communityCommentRaffles = redisCache.getCacheList(CacheConstants.COMMUNITY_COMMENT_RAFFLE);
|
|
|
+ if (communityCommentRaffles.isEmpty()) {
|
|
|
+ communityCommentRaffles = communityCommentRaffleMapper.selectList(new QueryWrapper<CommunityCommentRaffle>().eq("is_delete", false));
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_COMMENT_RAFFLE, communityCommentRaffles);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_COMMENT_RAFFLE, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章标签数据
|
|
|
+ List<CommunityArticleTag> communityArticleTags = redisCache.getCacheList(CacheConstants.COMMUNITY_ARTICLE_TAG);
|
|
|
+ if (communityArticleTags.isEmpty()) {
|
|
|
+ communityArticleTags = communityArticleTagMapper.selectList(new QueryWrapper<CommunityArticleTag>().eq("is_delete", false));
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_ARTICLE_TAG, communityArticleTags);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_ARTICLE_TAG, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章标签拉黑数据
|
|
|
+ List<CommunityTagBlock> communityTagBlocks = redisCache.getCacheList(CacheConstants.COMMUNITY_TAG_BLOCK);
|
|
|
+ if (communityTagBlocks.isEmpty()) {
|
|
|
+ communityTagBlocks = communityTagBlockMapper.selectList(new QueryWrapper<CommunityTagBlock>().eq("is_block", 1));
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_TAG_BLOCK, communityTagBlocks);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_TAG_BLOCK, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ //文章标签
|
|
|
+ List<CommunityTag> communityTags = redisCache.getCacheList(CacheConstants.COMMUNITY_TAG);
|
|
|
+ if (communityTags.isEmpty()) {
|
|
|
+ communityTags = communityTagMapper.selectList(new QueryWrapper<CommunityTag>().eq("is_delete", false));
|
|
|
+ redisCache.setCacheList(CacheConstants.COMMUNITY_TAG, communityTags);
|
|
|
+ redisCache.expire(CacheConstants.COMMUNITY_TAG, 24, TimeUnit.HOURS);
|
|
|
+ }
|
|
|
+
|
|
|
+ rspData.setTotal(communityArticleVos.size());
|
|
|
+ List<CommunityArticleVo> communityArticleVos_copy = new ArrayList<>(communityArticleVos);
|
|
|
+ List<CommunityArticleImages> videoList = new ArrayList<>();
|
|
|
+ for (CommunityArticleVo articleVo : communityArticleVos_copy) {
|
|
|
+ //判断当前文章是否被用户拉黑
|
|
|
+ communityUserBlocks
|
|
|
+ .stream()
|
|
|
+ .filter(item -> item.getUserId().equals(userId) && item.getPeerId().equals(articleVo.getUserId()))
|
|
|
+ .findFirst()
|
|
|
+ .ifPresent(communityUserBlock -> articleVo.setBlock(communityUserBlock.isBlock()));
|
|
|
+
|
|
|
+ //获取文章是否被关注
|
|
|
+ communityUserLikes
|
|
|
+ .stream()
|
|
|
+ .filter(item -> item.getUserId().equals(userId) && item.getLikeUserId().equals(articleVo.getUserId()))
|
|
|
+ .findFirst()
|
|
|
+ .ifPresent(communityUserLike -> articleVo.setCare(communityUserLike.getUserId() != null));
|
|
|
+
|
|
|
+ //设置文章的板块 提取 classId，并转换成 List<Long>
|
|
|
+ List<CommunityArticleClass> communityArticleClassList = communityArticleClasses
|
|
|
+ .stream()
|
|
|
+ .filter(item ->
|
|
|
+ item.getArticleId().equals(articleVo.getId()) && !item.getIsDelete()).collect(Collectors.toList());
|
|
|
+ classIds = communityArticleClassList
|
|
|
+ .stream()
|
|
|
+ .map(CommunityArticleClass::getClassId)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ articleVo.setClassIds(classIds);
|
|
|
+
|
|
|
+ List<Map<String, Object>> imageList = articleVo.getImageList();
|
|
|
+ List<Map<String, Object>> imageList_copy = new ArrayList<>(imageList);
|
|
|
+ CommunityArticleImages videos = null;
|
|
|
+ for (Map<String, Object> image : imageList_copy) {
|
|
|
+ String imageUrl = image.get("imageUrl").toString();
|
|
|
+ //判断是否是视频
|
|
|
+ boolean isVideo = isVideoFile(imageUrl);
|
|
|
+ if (isVideo) {
|
|
|
+ imageList.remove(image);
|
|
|
+ videos = JSONObject.parseObject(JSONObject.toJSONString(image), CommunityArticleImages.class);
|
|
|
+ //BeanUtils.copyProperties(image, videos);
|
|
|
+ videoList.add(videos);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ articleVo.setVideoList(videoList);
|
|
|
+
|
|
|
+ //设置评论回复数量
|
|
|
+ articleVo.setCommentCount(communityArticleCommentMapper.queryCommentCount(articleVo.getId()));
|
|
|
+ //设置文章的点赞数量
|
|
|
+ articleVo.setLikeCount((int) communityLikes.stream().filter(item -> item.getArticleId().equals(articleVo.getId())).count());
|
|
|
+ //设置文章的收藏数量
|
|
|
+ articleVo.setCollectCount((int) communityArticleCollects.stream().filter(item -> item.getArticleId().equals(articleVo.getId())).count());
|
|
|
+ //设置文章推荐数量
|
|
|
+ articleVo.setRecommendCount((int) communityArticleRecommends.stream().filter(item -> item.getArticleId().equals(articleVo.getId()) && !item.isDelete()).count());
|
|
|
+ //设置文章所属合集
|
|
|
+ articleVo.setCollectionVo(communityCollectionMapper.selectCollectById(userId, articleVo.getId()));
|
|
|
+
|
|
|
+ //设置中奖信息
|
|
|
+ CommunityCommentRaffleVo communityCommentRaffleVo = new CommunityCommentRaffleVo();
|
|
|
+ communityCommentRaffles
|
|
|
+ .stream()
|
|
|
+ .filter(item -> item.getArticleId().equals(articleVo.getId()) && !item.isDelete())
|
|
|
+ .findFirst()
|
|
|
+ .ifPresent(communityCommentRaffle -> {
|
|
|
+ BeanUtils.copyProperties(communityCommentRaffle, communityCommentRaffleVo);
|
|
|
+ CommunityUserInfoVo communityUserInfoVo = communityArticleService.selectCommunityUserInfoById(communityCommentRaffle.getUserId(), true);
|
|
|
+ communityCommentRaffleVo.setUserName(communityUserInfoVo.getNickName());
|
|
|
+ communityCommentRaffleVo.setUserAvatar(communityUserInfoVo.getAvatar());
|
|
|
+ articleVo.setCommentRaffleVo(communityCommentRaffleVo);
|
|
|
+ });
|
|
|
+
|
|
|
+ //判断是否已收藏
|
|
|
+ List<CommunityArticleCollect> collects = communityArticleCollects.stream().filter(item -> item.getUserId().equals(userId) && item.getArticleId().equals(articleVo.getId())).collect(Collectors.toList());
|
|
|
+ articleVo.setCollect(!collects.isEmpty());
|
|
|
+
|
|
|
+ //判断是否已点赞
|
|
|
+ List<CommunityLike> likes = communityLikes.stream().filter(item -> item.getUserId().equals(userId) && item.getArticleId().equals(articleVo.getId())).collect(Collectors.toList());
|
|
|
+ articleVo.setLike(!likes.isEmpty());
|
|
|
+
|
|
|
+ //判断是否已推荐
|
|
|
+ List<CommunityArticleRecommend> recommends = communityArticleRecommends.stream().filter(item -> item.getUserId().equals(userId) && item.getArticleId().equals(articleVo.getId()) && !item.isDelete()).collect(Collectors.toList());
|
|
|
+ articleVo.setRecommend(!recommends.isEmpty());
|
|
|
+
|
|
|
+ //获取文章标签
|
|
|
+ List<CommunityArticleTag> articleTags = communityArticleTags.stream().filter(item -> item.getArticleId().equals(articleVo.getId()) && !item.getIsDelete()).collect(Collectors.toList());
|
|
|
+ List<Long> tagList = articleTags.stream().map(CommunityArticleTag::getTagId).collect(Collectors.toList());
|
|
|
+ List<Long> tagIds = new ArrayList<>();
|
|
|
+
|
|
|
+ if (!tagList.isEmpty()) {
|
|
|
+ //判断当前标签是否被当前登录用户拉黑
|
|
|
+ List<CommunityTagBlock> communityTagBlockList = communityTagBlocks
|
|
|
+ .stream()
|
|
|
+ .filter(item -> tagList.contains(item.getTagId()) && item.getUserId().equals(userId))
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ for (CommunityTagBlock tagBlock : communityTagBlockList) {
|
|
|
+ if (tagBlock.isBlock()) {
|
|
|
+ communityArticleVos.remove(articleVo);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ tagIds.add(tagBlock.getTagId());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (communityTagBlockList.isEmpty()) {
|
|
|
+ tagIds.addAll(tagList);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!tagIds.isEmpty()) {
|
|
|
+ List<CommunityTag> communityTagList = communityTags
|
|
|
+ .stream()
|
|
|
+ .filter(item -> tagIds.contains(item.getId()))
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ articleVo.setTags(communityTagList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return communityArticleVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 发布文章
|
|
|
+ *
|
|
|
+ * @param communityArticle 文章信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void insertCommunityArticle(CommunityArticle communityArticle) {
|
|
|
+
|
|
|
+ //判断是否传ID 如果有ID贼删除原来的文章 重新插入一条新文章
|
|
|
+ if (communityArticle.getId() != null) {
|
|
|
+ //增加字段 文章编辑字段
|
|
|
+ communityArticle.setIsDelete(true);
|
|
|
+
|
|
|
+ UpdateWrapper<CommunityArticle> updateWrapper = new UpdateWrapper<>();
|
|
|
+ updateWrapper.eq("id", communityArticle.getId());
|
|
|
+
|
|
|
+ // 创建一个新的 CommunityArticle 对象，只设置 isDelete 字段
|
|
|
+ CommunityArticle updateArticle = new CommunityArticle();
|
|
|
+ updateArticle.setIsDelete(communityArticle.getIsDelete());
|
|
|
+
|
|
|
+ communityArticleService.update(updateArticle, updateWrapper);
|
|
|
+
|
|
|
+ communityArticle.setParentId(communityArticle.getId());
|
|
|
+ communityArticle.setId(null);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ Long userId = SecurityUtils.getLoginUser().getUserId();
|
|
|
+ //插入文章信息
|
|
|
+ communityArticle.setUserId(userId);
|
|
|
+ communityArticle.setCreateBy(userId);
|
|
|
+ communityArticle.setUpdateBy(userId);
|
|
|
+ communityArticle.setIsDelete(false);
|
|
|
+/* communityArticle.setComment(false);
|
|
|
+ communityArticle.setDownload(false);
|
|
|
+ communityArticle.setRaffle(false);*/
|
|
|
+ communityArticle.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticle.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+
|
|
|
+ String address = null;
|
|
|
+ try {
|
|
|
+ address = AddressUtils.getAddress(null);
|
|
|
+ } catch (ExecutionException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ communityArticle.setAddress(address);
|
|
|
+
|
|
|
+ communityArticleMapper.insert(communityArticle);
|
|
|
+ //插入标签日志
|
|
|
+ List<String> tags = communityArticle.getTags();
|
|
|
+ if (tags != null && !tags.isEmpty()) {
|
|
|
+ CommunityArticleTag tagLog = null;
|
|
|
+ for (String tag : tags) {
|
|
|
+ tagLog = new CommunityArticleTag();
|
|
|
+ tagLog.setArticleId(communityArticle.getId());
|
|
|
+ tagLog.setTagId(Long.parseLong(tag));
|
|
|
+ tagLog.setUpdateBy(userId);
|
|
|
+ tagLog.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ tagLog.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ tagLog.setCreateBy(userId);
|
|
|
+ articleTagMapper.insert(tagLog);
|
|
|
+
|
|
|
+ //标签热度自增
|
|
|
+ CommunityTag communityTag = communityTagMapper.selectById(Long.parseLong(tag));
|
|
|
+ communityTag.setTagHot(Objects.isNull(communityTag.getTagHot()) ? 1 : communityTag.getTagHot() + 1);
|
|
|
+ communityTag.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityTag.setUpdateBy(userId);
|
|
|
+ communityTagMapper.updateById(communityTag);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //插入图片日志
|
|
|
+ List<CommunityImagesVo> images = communityArticle.getImages();
|
|
|
+ if (images != null && !images.isEmpty()) {
|
|
|
+ CommunityArticleImages articleImages = null;
|
|
|
+ for (CommunityImagesVo image : images) {
|
|
|
+ articleImages = new CommunityArticleImages();
|
|
|
+ articleImages.setArticleId(communityArticle.getId());
|
|
|
+ articleImages.setImageUrl(image.getImages());
|
|
|
+ articleImages.setCompressUrl(image.getCompressedImages());
|
|
|
+ articleImages.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ articleImages.setCreateBy(userId);
|
|
|
+ communityArticleImagesMapper.insert(articleImages);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //插入板块
|
|
|
+ List<Long> classIds = communityArticle.getClassIds();
|
|
|
+ if (classIds != null && !classIds.isEmpty()) {
|
|
|
+ List<CommunityArticleClass> articleClasses = new ArrayList<>();
|
|
|
+ CommunityArticleClass articleClass = null;
|
|
|
+ for (Long classId : classIds) {
|
|
|
+ articleClass = new CommunityArticleClass();
|
|
|
+ articleClass.setClassId(classId);
|
|
|
+ articleClass.setArticleId(communityArticle.getId());
|
|
|
+ articleClass.setCreateBy(userId);
|
|
|
+ articleClass.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ articleClasses.add(articleClass);
|
|
|
+ }
|
|
|
+ communityArticleClassService.saveBatch(articleClasses);
|
|
|
+ }
|
|
|
+
|
|
|
+ //插入合集
|
|
|
+ List<String> collectionIds = communityArticle.getCollectionIds();
|
|
|
+ if (collectionIds != null && !collectionIds.isEmpty()) {
|
|
|
+ List<CommunityCollectionArticle> collectionArticles = new ArrayList<>();
|
|
|
+ CommunityCollectionArticle collectionArticle = null;
|
|
|
+ for (String collectionId : collectionIds) {
|
|
|
+ collectionArticle = new CommunityCollectionArticle();
|
|
|
+ collectionArticle.setCollectionId(Long.parseLong(collectionId));
|
|
|
+ collectionArticle.setArticleId(communityArticle.getId());
|
|
|
+ collectionArticle.setCreateBy(userId);
|
|
|
+ collectionArticle.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ collectionArticles.add(collectionArticle);
|
|
|
+ }
|
|
|
+ collectionArticleService.saveBatch(collectionArticles);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ // at 人插入at通知表 判断是不是草稿箱 草稿箱不需要通知
|
|
|
+ if (communityArticle.getIsDraft() != null && !communityArticle.getIsDraft()) {
|
|
|
+ //拿到需要At人的ID
|
|
|
+ List<Long> atUserIds = communityArticle.getAtUserIds();
|
|
|
+ if (atUserIds != null && !atUserIds.isEmpty()) {
|
|
|
+ List<CommunityArticleAt> communityArticleAts = new ArrayList<>();
|
|
|
+ CommunityArticleAt communityArticleAt = null;
|
|
|
+ for (Long atUserId : atUserIds) {
|
|
|
+ communityArticleAt = new CommunityArticleAt();
|
|
|
+ communityArticleAt.setType(0L);
|
|
|
+ communityArticleAt.setArticleId(communityArticle.getId());
|
|
|
+ communityArticleAt.setUserId(userId);
|
|
|
+ communityArticleAt.setPeerId(atUserId);
|
|
|
+ communityArticleAt.setCreateBy(userId);
|
|
|
+ communityArticleAt.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticleAts.add(communityArticleAt);
|
|
|
+ }
|
|
|
+ communityArticleAtService.saveBatch(communityArticleAts);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 编辑文章
|
|
|
+ *
|
|
|
+ * @param communityArticle 文章信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void editCommunityArticle(CommunityArticle communityArticle) {
|
|
|
+
|
|
|
+ Long userId = SecurityUtils.getLoginUser().getUserId();
|
|
|
+ //编辑文章信息
|
|
|
+ communityArticle.setUpdateBy(userId);
|
|
|
+ communityArticle.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+
|
|
|
+
|
|
|
+ CommunityArticle article = communityArticleMapper.selectOne((new QueryWrapper<CommunityArticle>()
|
|
|
+ .eq("id", communityArticle.getId())
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ })));
|
|
|
+
|
|
|
+ if (article != null) {
|
|
|
+ Integer pageViews = Math.toIntExact(article.getPageViews());
|
|
|
+ if (pageViews != null) {
|
|
|
+ communityArticle.setPageViews(pageViews);
|
|
|
+ } else {
|
|
|
+ // 处理 pageViews 为 null 的情况，比如设置为 0 或记录日志
|
|
|
+ communityArticle.setPageViews(0);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ String address = null;
|
|
|
+ try {
|
|
|
+ address = AddressUtils.getAddress(null);
|
|
|
+ } catch (ExecutionException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ communityArticle.setAddress(address);
|
|
|
+
|
|
|
+ communityArticleMapper.updateById(communityArticle);
|
|
|
+
|
|
|
+
|
|
|
+ //插入标签日志
|
|
|
+ List<String> tags = communityArticle.getTags();
|
|
|
+ if (tags != null && !tags.isEmpty()) {
|
|
|
+ //不在本次更新的标签都传失效
|
|
|
+ communityArticleTagMapper.update(
|
|
|
+ null,
|
|
|
+ new UpdateWrapper<CommunityArticleTag>()
|
|
|
+ .eq("article_id", communityArticle.getId())
|
|
|
+ .notIn("tag_id", tags)
|
|
|
+ .set("is_delete", true)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", 1).or().isNull("is_delete");
|
|
|
+ })
|
|
|
+ );
|
|
|
+
|
|
|
+ CommunityArticleTag tagLog = null;
|
|
|
+ for (String tag : tags) {
|
|
|
+
|
|
|
+ //查询该标签是否在数据库中存在
|
|
|
+ CommunityArticleTag communityArticleTag = communityArticleTagMapper.selectOne((new QueryWrapper<CommunityArticleTag>()
|
|
|
+ .eq("article_id", communityArticle.getId())
|
|
|
+ .eq("tag_id", tag)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ })));
|
|
|
+ //不为空就不操作
|
|
|
+ if (communityArticleTag == null) {
|
|
|
+ tagLog = new CommunityArticleTag();
|
|
|
+ tagLog.setArticleId(communityArticle.getId());
|
|
|
+ tagLog.setTagId(Long.parseLong(tag));
|
|
|
+ tagLog.setUpdateBy(userId);
|
|
|
+ tagLog.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ tagLog.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ tagLog.setCreateBy(userId);
|
|
|
+ articleTagMapper.insert(tagLog);
|
|
|
+
|
|
|
+ //标签热度自增
|
|
|
+ CommunityTag communityTag = communityTagMapper.selectById(Long.parseLong(tag));
|
|
|
+ communityTag.setTagHot(Objects.isNull(communityTag.getTagHot()) ? 1 : communityTag.getTagHot() + 1);
|
|
|
+ communityTag.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityTag.setUpdateBy(userId);
|
|
|
+ communityTagMapper.updateById(communityTag);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //插入图片日志
|
|
|
+ List<CommunityImagesVo> images = communityArticle.getImages();
|
|
|
+
|
|
|
+ //插入图片日志 都失效
|
|
|
+ communityArticleImagesMapper.update(
|
|
|
+ null,
|
|
|
+ new UpdateWrapper<CommunityArticleImages>()
|
|
|
+ .eq("article_id", communityArticle.getId())
|
|
|
+ .set("is_delete", true)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", 1).or().isNull("is_delete");
|
|
|
+ })
|
|
|
+ );
|
|
|
+
|
|
|
+ if (images != null && !images.isEmpty()) {
|
|
|
+ CommunityArticleImages articleImages = null;
|
|
|
+ for (CommunityImagesVo image : images) {
|
|
|
+ articleImages = new CommunityArticleImages();
|
|
|
+ articleImages.setArticleId(communityArticle.getId());
|
|
|
+ articleImages.setImageUrl(image.getImages());
|
|
|
+ articleImages.setCompressUrl(image.getCompressedImages());
|
|
|
+ articleImages.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ articleImages.setCreateBy(userId);
|
|
|
+ communityArticleImagesMapper.insert(articleImages);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //插入板块
|
|
|
+ List<Long> classIds = communityArticle.getClassIds();
|
|
|
+
|
|
|
+ //插入板块 都失效
|
|
|
+ communityArticleClassService.update(
|
|
|
+ null,
|
|
|
+ new UpdateWrapper<CommunityArticleClass>()
|
|
|
+ .eq("article_id", communityArticle.getId())
|
|
|
+ .set("is_delete", true)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", 1).or().isNull("is_delete");
|
|
|
+ })
|
|
|
+ );
|
|
|
+
|
|
|
+ if (classIds != null && !classIds.isEmpty()) {
|
|
|
+ List<CommunityArticleClass> articleClasses = new ArrayList<>();
|
|
|
+ CommunityArticleClass articleClass = null;
|
|
|
+ for (Long classId : classIds) {
|
|
|
+ articleClass = new CommunityArticleClass();
|
|
|
+ articleClass.setClassId(classId);
|
|
|
+ articleClass.setArticleId(communityArticle.getId());
|
|
|
+ articleClass.setCreateBy(userId);
|
|
|
+ articleClass.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ articleClasses.add(articleClass);
|
|
|
+ }
|
|
|
+ communityArticleClassService.saveBatch(articleClasses);
|
|
|
+ }
|
|
|
+
|
|
|
+ //插入合集
|
|
|
+ List<String> collectionIds = communityArticle.getCollectionIds();
|
|
|
+
|
|
|
+ if (collectionIds != null && !collectionIds.isEmpty()) {
|
|
|
+ //插入合集 都失效
|
|
|
+ collectionArticleService.update(
|
|
|
+ null,
|
|
|
+ new UpdateWrapper<CommunityCollectionArticle>()
|
|
|
+ .eq("article_id", communityArticle.getId())
|
|
|
+ .eq("create_by", userId)
|
|
|
+ .set("is_delete", true)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", 1).or().isNull("is_delete");
|
|
|
+ })
|
|
|
+ );
|
|
|
+
|
|
|
+ List<CommunityCollectionArticle> collectionArticles = new ArrayList<>();
|
|
|
+ CommunityCollectionArticle collectionArticle = null;
|
|
|
+ for (String collectionId : collectionIds) {
|
|
|
+ collectionArticle = new CommunityCollectionArticle();
|
|
|
+ collectionArticle.setCollectionId(Long.parseLong(collectionId));
|
|
|
+ collectionArticle.setArticleId(communityArticle.getId());
|
|
|
+ collectionArticle.setCreateBy(userId);
|
|
|
+ collectionArticle.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ collectionArticles.add(collectionArticle);
|
|
|
+ }
|
|
|
+ collectionArticleService.saveBatch(collectionArticles);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ // at 人插入at通知表 判断是不是草稿箱 草稿箱不需要通知
|
|
|
+ if (communityArticle.getIsDraft() != null && !communityArticle.getIsDraft()) {
|
|
|
+ //拿到需要At人的ID
|
|
|
+ List<Long> atUserIds = communityArticle.getAtUserIds();
|
|
|
+
|
|
|
+ if (atUserIds != null && !atUserIds.isEmpty()) {
|
|
|
+ List<CommunityArticleAt> communityArticleAts = new ArrayList<>();
|
|
|
+ CommunityArticleAt communityArticleAt = null;
|
|
|
+ for (Long atUserId : atUserIds) {
|
|
|
+ communityArticleAt = new CommunityArticleAt();
|
|
|
+ communityArticleAt.setType(0L);
|
|
|
+ communityArticleAt.setArticleId(communityArticle.getId());
|
|
|
+ communityArticleAt.setUserId(userId);
|
|
|
+ communityArticleAt.setPeerId(atUserId);
|
|
|
+ communityArticleAt.setCreateBy(userId);
|
|
|
+ communityArticleAt.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticleAts.add(communityArticleAt);
|
|
|
+ }
|
|
|
+ communityArticleAtService.saveBatch(communityArticleAts);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 发送评论
|
|
|
+ *
|
|
|
+ * @param communityArticleComment 评论信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void sendComment(CommunityArticleComment communityArticleComment) throws ParseException {
|
|
|
+ communityArticleComment.setId(null);
|
|
|
+ communityArticleComment.setCreateBy(SecurityUtils.getLoginUser().getUserId());
|
|
|
+ communityArticleComment.setUpdateBy(SecurityUtils.getLoginUser().getUserId());
|
|
|
+ communityArticleComment.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticleComment.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticleComment.setDelete(false);
|
|
|
+ String address = null;
|
|
|
+ try {
|
|
|
+ address = AddressUtils.getAddress(null);
|
|
|
+ } catch (ExecutionException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+
|
|
|
+ communityArticleComment.setAddress(address);
|
|
|
+ communityArticleCommentMapper.insert(communityArticleComment);
|
|
|
+
|
|
|
+ //拿到需要At人的ID
|
|
|
+ List<Long> atUserIds = communityArticleComment.getAtUserIds();
|
|
|
+ if (atUserIds != null && !atUserIds.isEmpty()) {
|
|
|
+ List<CommunityArticleAt> communityArticleAts = new ArrayList<>();
|
|
|
+ CommunityArticleAt communityArticleAt = null;
|
|
|
+ for (Long atUserId : atUserIds) {
|
|
|
+ communityArticleAt = new CommunityArticleAt();
|
|
|
+ communityArticleAt.setType(1L);
|
|
|
+ communityArticleAt.setArticleId(communityArticleComment.getArticleId());
|
|
|
+ communityArticleAt.setCommentId(communityArticleComment.getId());
|
|
|
+ communityArticleAt.setUserId(SecurityUtils.getLoginUser().getUserId());
|
|
|
+ communityArticleAt.setPeerId(atUserId);
|
|
|
+ communityArticleAt.setCreateBy(SecurityUtils.getLoginUser().getUserId());
|
|
|
+ communityArticleAt.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticleAts.add(communityArticleAt);
|
|
|
+ }
|
|
|
+ communityArticleAtService.saveBatch(communityArticleAts);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除评论
|
|
|
+ *
|
|
|
+ * @param communityArticleComment 评论信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public void deleteComment(CommunityArticleComment communityArticleComment) {
|
|
|
+ communityArticleComment.setDelete(true);
|
|
|
+ communityArticleComment.setUpdateBy(SecurityUtils.getUserId());
|
|
|
+ communityArticleComment.setUpdateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityArticleCommentMapper.updateById(communityArticleComment);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询该文章对应的用户是否已经点赞
|
|
|
+ *
|
|
|
+ * @param communityLike 点赞信息
|
|
|
+ * @return 点赞信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public CommunityLike selectCommunityLikeById(CommunityLike communityLike) {
|
|
|
+ QueryWrapper<CommunityLike> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.eq("article_id", communityLike.getArticleId()).eq("user_id", communityLike.getUserId());
|
|
|
+ return communityLikeMapper.selectOne(queryWrapper);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增点赞
|
|
|
+ *
|
|
|
+ * @param communityLike 点赞信息
|
|
|
+ * @return 点赞是否成功
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public boolean insertCommunityLikeById(CommunityLike communityLike) {
|
|
|
+ return communityLikeMapper.insert(communityLike) > 0;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除点赞
|
|
|
+ *
|
|
|
+ * @param communityLike 点赞信息
|
|
|
+ * @return 删除是否成功
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public boolean deleteCommunityLikeById(CommunityLike communityLike) {
|
|
|
+ return communityLikeMapper.deleteById(communityLike.getId()) > 0;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询该文章对应的用户是否已经收藏
|
|
|
+ *
|
|
|
+ * @param collect 收藏信息
|
|
|
+ * @return 收藏信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public CommunityArticleCollect selectCommunityCollectById(CommunityArticleCollect collect) {
|
|
|
+ return communityCollectMapper.selectOne(new QueryWrapper<CommunityArticleCollect>().eq("article_id", collect.getArticleId()).eq("user_id", SecurityUtils.getUserId()));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增收藏
|
|
|
+ *
|
|
|
+ * @param collect 收藏信息
|
|
|
+ * @return 收藏是否成功
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public boolean insertCommunityCollectById(CommunityArticleCollect collect) {
|
|
|
+ return communityCollectMapper.insert(collect) > 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除收藏
|
|
|
+ *
|
|
|
+ * @param collect 收藏信息
|
|
|
+ * @return 删除是否成功
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public boolean deleteCommunityCollectById(CommunityArticleCollect collect) {
|
|
|
+ return communityCollectMapper.deleteById(collect) > 0;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据板块获取圈子列表
|
|
|
+ *
|
|
|
+ * @param classId 板块id
|
|
|
+ * @return 圈子列表信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityCircleVo> selectCommunityCircleList(String classId) {
|
|
|
+ List<CommunityClassCircle> classes = communityClassCircleMapper.selectList(new QueryWrapper<CommunityClassCircle>().eq("class_id", classId));
|
|
|
+ List<Long> circleIds = new ArrayList<>();
|
|
|
+ for (CommunityClassCircle aClass : classes) {
|
|
|
+ circleIds.add(aClass.getCircleId());
|
|
|
+ }
|
|
|
+
|
|
|
+ List<CommunityCircleVo> communityCircleVos = null;
|
|
|
+ if (!circleIds.isEmpty()) {
|
|
|
+ List<CommunityCircle> communityCircles = communityCircleMapper.selectBatchIds(circleIds);
|
|
|
+ //复制到Vo对象中
|
|
|
+ communityCircleVos = new ArrayList<>();
|
|
|
+ CommunityCircleVo communityCircleVo = null;
|
|
|
+ for (CommunityCircle communityCircle : communityCircles) {
|
|
|
+ communityCircleVo = new CommunityCircleVo();
|
|
|
+ BeanUtils.copyProperties(communityCircle, communityCircleVo);
|
|
|
+
|
|
|
+ //获取当前用户是否有关注这些圈子
|
|
|
+ CommunityUserCircle communityUserCircles = communityUserCircleMapper.selectOne(new QueryWrapper<CommunityUserCircle>().eq("circle_id", communityCircle.getId()).eq("user_id", SecurityUtils.getLoginUser().getUserId()).eq("is_delete", 0));
|
|
|
+ if (Objects.isNull(communityUserCircles) || Objects.isNull(communityUserCircles.getId())) {
|
|
|
+ //没找到关注数据,则设为false,反之则true
|
|
|
+ communityCircleVo.setLike(false);
|
|
|
+ } else {
|
|
|
+ communityCircleVo.setLike(true);
|
|
|
+ }
|
|
|
+ communityCircleVos.add(communityCircleVo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return communityCircleVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 关注或取消关注用户粉丝/关注
|
|
|
+ *
|
|
|
+ * @param likeUserId 被关注人id
|
|
|
+ * @return 登录用户关注信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public CommunityUserLike addOrDeleteUserLike(Long likeUserId) {
|
|
|
+ Long userId = SecurityUtils.getLoginUser().getUserId(); // 当前登录用户id
|
|
|
+ //1.检查是否已被当前用户关注
|
|
|
+ CommunityUserLike communityUserLike = communityUserLikeMapper.selectOne(new QueryWrapper<CommunityUserLike>().eq("user_id", userId).eq("like_user_id", likeUserId));
|
|
|
+ //2.1 没有则进行关注,返回关注列表信息
|
|
|
+ if (Objects.isNull(communityUserLike) || Objects.isNull(communityUserLike.getId())) {
|
|
|
+ communityUserLike = new CommunityUserLike();
|
|
|
+ communityUserLike.setUserId(userId);
|
|
|
+ communityUserLike.setLikeUserId(likeUserId);
|
|
|
+ communityUserLike.setRead(false);
|
|
|
+ communityUserLike.setCreateBy(userId);
|
|
|
+ communityUserLike.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityUserLikeMapper.insert(communityUserLike);
|
|
|
+
|
|
|
+ communityUserLike = communityUserLikeMapper.selectOne(new QueryWrapper<CommunityUserLike>().eq("user_id", userId).eq("like_user_id", likeUserId));
|
|
|
+ return communityUserLike;
|
|
|
+ }
|
|
|
+
|
|
|
+ //2.2 已关注则取消关注
|
|
|
+ communityUserLikeMapper.deleteById(communityUserLike);
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取当前登录用户信息
|
|
|
+ *
|
|
|
+ * @param userId 用户id
|
|
|
+ * @return 用户信息
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public CommunityUserInfoVo selectCommunityUserInfoById(Long userId, boolean isToken) {
|
|
|
+ SysUser sysUser = sysUserMapper.selectUserById(userId);
|
|
|
+
|
|
|
+ System.out.println(sysUser);
|
|
|
+ CommunityUserInfo communityUserInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", userId));
|
|
|
+ CommunityUserInfoVo communityUserInfoVo = new CommunityUserInfoVo();
|
|
|
+ BeanUtils.copyProperties(communityUserInfo, communityUserInfoVo);
|
|
|
+ communityUserInfoVo.setAvatar(sysUser.getAvatar());
|
|
|
+ communityUserInfoVo.setNickName(sysUser.getNickName());
|
|
|
+ communityUserInfoVo.setSex(sysUser.getSex());
|
|
|
+ communityUserInfoVo.setUserId(userId);
|
|
|
+ communityUserInfoVo.setUserState(sysUser.getUserState());
|
|
|
+ communityUserInfoVo.setReportTime(sysUser.getReportTime());
|
|
|
+
|
|
|
+ //设置关注,粉丝,陪伴天数 文章数量
|
|
|
+ communityUserInfoVo.setLikeCount(communityUserLikeMapper.selectList(new QueryWrapper<CommunityUserLike>().eq("user_id", userId)).size());
|
|
|
+ communityUserInfoVo.setFansCount(communityUserLikeMapper.selectList(new QueryWrapper<CommunityUserLike>().eq("like_user_id", userId)).size());
|
|
|
+
|
|
|
+ Date createTime = sysUser.getCreateTime();
|
|
|
+ // 将 Date 对象转换为 LocalDate 对象
|
|
|
+ LocalDate localCreateTime = createTime.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
|
|
|
+ // 获取当前日期
|
|
|
+ LocalDate today = LocalDate.now();
|
|
|
+ // 计算两个日期之间的天数差
|
|
|
+ long daysDifference = ChronoUnit.DAYS.between(localCreateTime, today);
|
|
|
+ communityUserInfoVo.setCompanionCount((int) daysDifference);
|
|
|
+
|
|
|
+ communityUserInfoVo.setArticleCount(communityArticleMapper.selectList(new QueryWrapper<CommunityArticle>()
|
|
|
+ .eq("user_id", userId)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ })).size());
|
|
|
+
|
|
|
+
|
|
|
+ String address = null;
|
|
|
+ try {
|
|
|
+ address = AddressUtils.getAddress(sysUser.getLoginIp());
|
|
|
+ } catch (ExecutionException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ communityUserInfoVo.setAddress(address);
|
|
|
+ //设置是否被当前登录的用户关注
|
|
|
+ communityUserInfoVo.setLike(false);
|
|
|
+ if (isToken) {
|
|
|
+ Long loginUserId = SecurityUtils.getLoginUser().getUserId();
|
|
|
+ if (!Objects.equals(userId, loginUserId)) {
|
|
|
+ CommunityUserLike communityUserLike = communityUserLikeMapper.selectOne(new QueryWrapper<CommunityUserLike>().eq("user_id", loginUserId).eq("like_user_id", userId));
|
|
|
+ if (!Objects.isNull(communityUserLike) && !Objects.isNull(communityUserLike.getId())) {
|
|
|
+ communityUserInfoVo.setLike(true);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return communityUserInfoVo;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据条件搜索用户列表信息(无权限卡控)
|
|
|
+ *
|
|
|
+ * @param searchValue 搜索值
|
|
|
+ * @return 用户
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserInfoVo> selectUserBySearchValue(@Param("searchValue") String searchValue,
|
|
|
+ @Param("offset") int offset,
|
|
|
+ @Param("limit") int limit) {
|
|
|
+ return communityUserInfoMapper.selectUserBySearchValue(searchValue, offset, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserInfoVo> selectBlockUserBySearchValue(@Param("searchValue") String searchValue,
|
|
|
+ @Param("userId") Long userId,
|
|
|
+ @Param("offset") int offset,
|
|
|
+ @Param("limit") int limit) {
|
|
|
+ return communityUserInfoMapper.selectBlockUserBySearchValue(searchValue, userId, offset, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据条件搜索用户列表信息(有权限卡控)
|
|
|
+ *
|
|
|
+ * @param searchValue 搜索值
|
|
|
+ * @return 用户
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserInfoVo> selectUsersByAccountOrName(@Param("searchValue") String searchValue,
|
|
|
+ @Param("offset") int offset,
|
|
|
+ @Param("limit") int limit) {
|
|
|
+ List<CommunityUserInfoVo> communityUserInfoVos = communityUserInfoMapper.selectUsersByAccountOrName(searchValue, offset, limit);
|
|
|
+ communityUserInfoVos.forEach(item -> {
|
|
|
+ CommunityUserLike communityUserLike = communityUserLikeMapper.selectOne(new QueryWrapper<CommunityUserLike>()
|
|
|
+ .eq("user_id", SecurityUtils.getUserId())
|
|
|
+ .eq("like_user_id", item.getUserId()));
|
|
|
+
|
|
|
+ if (Objects.nonNull(communityUserLike)) {
|
|
|
+ item.setLike(true);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ return communityUserInfoVos;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取关注列表
|
|
|
+ *
|
|
|
+ * @param userId 登录用户id
|
|
|
+ * @return 当前用户关注列表
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserLikeVo> selectCommunityUserLikeList(Long userId, String userName, int pageNum, int pageSize, int searchType) {
|
|
|
+ int offset = (pageNum - 1) * pageSize;
|
|
|
+// Page<CommunityUserLike> page = new Page<>(pageNum, pageSize);
|
|
|
+// QueryWrapper<CommunityUserLike> queryWrapper = new QueryWrapper<CommunityUserLike>()
|
|
|
+// .eq("user_id", userId);
|
|
|
+// if (searchType == 1) {
|
|
|
+// queryWrapper.orderByDesc("create_time");
|
|
|
+// } else {
|
|
|
+// queryWrapper.orderByAsc("create_time");
|
|
|
+// }
|
|
|
+//
|
|
|
+// List<CommunityUserLike> communityUserLikes = communityUserLikeMapper.selectPage(page, queryWrapper).getRecords();
|
|
|
+
|
|
|
+ List<CommunityUserLike> communityUserLikes = communityUserLikeMapper.selectUserLikeList(userId, offset, pageSize, userName, searchType);
|
|
|
+
|
|
|
+ List<CommunityUserLikeVo> communityUserLikeVos = new ArrayList<>();
|
|
|
+ CommunityUserLikeVo communityUserLikeVo = null;
|
|
|
+ Boolean isCare = false;
|
|
|
+
|
|
|
+ for (CommunityUserLike communityUserLike : communityUserLikes) {
|
|
|
+ communityUserLikeVo = new CommunityUserLikeVo();
|
|
|
+ //用户信息
|
|
|
+ SysUser sysUserLike = sysUserMapper.selectUserById(communityUserLike.getLikeUserId());
|
|
|
+ SysUser sysUser = sysUserMapper.selectUserById(communityUserLike.getUserId());
|
|
|
+ //用户自我介绍
|
|
|
+ CommunityUserInfo userInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", communityUserLike.getUserId()));
|
|
|
+ CommunityUserInfo likeUserInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", communityUserLike.getLikeUserId()));
|
|
|
+ BeanUtils.copyProperties(communityUserLike, communityUserLikeVo);
|
|
|
+
|
|
|
+ //关注的用户是否已经关注当前用户
|
|
|
+ CommunityUserLike communityUserLikeFans = communityUserLikeMapper.selectOne(
|
|
|
+ new QueryWrapper<CommunityUserLike>()
|
|
|
+ .eq("like_user_id", userId)
|
|
|
+ .eq("user_id", communityUserLike.getLikeUserId()));
|
|
|
+
|
|
|
+ if (communityUserLikeFans != null) {
|
|
|
+ isCare = true;
|
|
|
+ }
|
|
|
+ communityUserLikeVo.setIsCare(isCare);
|
|
|
+
|
|
|
+ if (Objects.nonNull(userInfo)) {
|
|
|
+ communityUserLikeVo.setProfile(userInfo.getProfile());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(likeUserInfo)) {
|
|
|
+ communityUserLikeVo.setLikeProfile(likeUserInfo.getProfile());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(sysUser)) {
|
|
|
+ communityUserLikeVo.setAvatar(sysUser.getAvatar());
|
|
|
+ communityUserLikeVo.setUsername(sysUser.getNickName());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(sysUserLike)) {
|
|
|
+ communityUserLikeVo.setLikeUsername(sysUserLike.getNickName());
|
|
|
+ communityUserLikeVo.setLikeAvatar(sysUserLike.getAvatar());
|
|
|
+ }
|
|
|
+
|
|
|
+ //如果不需要搜索名字直接添加
|
|
|
+// if (userName != null && communityUserLikeVo.getLikeUsername().matches("(?i).*" + Pattern.quote(userName) + ".*")) {
|
|
|
+// communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+// } else if (userName == null) {
|
|
|
+// communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+// }
|
|
|
+ communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+ }
|
|
|
+ return communityUserLikeVos;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取粉丝列表
|
|
|
+ *
|
|
|
+ * @param userId 登录用户id
|
|
|
+ * @return 当前用户粉丝列表
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserLikeVo> selectUserFansList(Long userId, String userName, int pageNum, int pageSize, int searchType) {
|
|
|
+ //int offset = (pageNum - 1) * pageSize;
|
|
|
+ Page<CommunityUserLike> page = new Page<>(pageNum, pageSize);
|
|
|
+ QueryWrapper<CommunityUserLike> queryWrapper = new QueryWrapper<CommunityUserLike>()
|
|
|
+ .eq("like_user_id", userId);
|
|
|
+ if (searchType == 1) {
|
|
|
+ queryWrapper.orderByDesc("create_time");
|
|
|
+ } else {
|
|
|
+ queryWrapper.orderByAsc("create_time");
|
|
|
+ }
|
|
|
+
|
|
|
+ List<CommunityUserLike> communityUserLikes = communityUserLikeMapper.selectPage(page, queryWrapper).getRecords();
|
|
|
+
|
|
|
+ List<CommunityUserLikeVo> communityUserLikeVos = new ArrayList<>();
|
|
|
+ CommunityUserLikeVo communityUserLikeVo = null;
|
|
|
+
|
|
|
+ for (CommunityUserLike communityUserLike : communityUserLikes) {
|
|
|
+ Boolean isCare = false;
|
|
|
+ // System.out.println(communityUserLike.getUserId() + "---" + userId);
|
|
|
+ //用户信息
|
|
|
+ SysUser sysUserLike = sysUserMapper.selectUserById(communityUserLike.getLikeUserId());
|
|
|
+ //用户自我介绍
|
|
|
+ CommunityUserInfo userInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", communityUserLike.getUserId()));
|
|
|
+ CommunityUserInfo likeUserInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", communityUserLike.getLikeUserId()));
|
|
|
+
|
|
|
+
|
|
|
+ //用户是否关注当前用户
|
|
|
+ CommunityUserLike communityUserLikeFans = communityUserLikeMapper.selectOne(
|
|
|
+ new QueryWrapper<CommunityUserLike>()
|
|
|
+ .eq("like_user_id", communityUserLike.getUserId())
|
|
|
+ .eq("user_id", userId));
|
|
|
+
|
|
|
+ if (communityUserLikeFans != null) {
|
|
|
+ isCare = true;
|
|
|
+ }
|
|
|
+ communityUserLikeVo = new CommunityUserLikeVo();
|
|
|
+ BeanUtils.copyProperties(communityUserLike, communityUserLikeVo);
|
|
|
+ SysUser sysUser = sysUserMapper.selectUserById(communityUserLike.getUserId());
|
|
|
+
|
|
|
+ communityUserLikeVo.setIsCare(isCare);
|
|
|
+
|
|
|
+
|
|
|
+ if (Objects.nonNull(sysUser)) {
|
|
|
+ communityUserLikeVo.setAvatar(sysUser.getAvatar());
|
|
|
+ communityUserLikeVo.setUsername(sysUser.getNickName());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(userInfo)) {
|
|
|
+ communityUserLikeVo.setProfile(userInfo.getProfile());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(sysUserLike)) {
|
|
|
+ communityUserLikeVo.setLikeUsername(sysUserLike.getNickName());
|
|
|
+ communityUserLikeVo.setLikeAvatar(sysUserLike.getAvatar());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.nonNull(likeUserInfo)) {
|
|
|
+ communityUserLikeVo.setLikeProfile(likeUserInfo.getProfile());
|
|
|
+ }
|
|
|
+ //如果不需要搜索名字直接添加
|
|
|
+ if (userName != null && communityUserLikeVo.getUsername().matches("(?i).*" + Pattern.quote(userName) + ".*")) {
|
|
|
+ communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+ } else if (userName == null) {
|
|
|
+ communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ return communityUserLikeVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取互相关注列表
|
|
|
+ *
|
|
|
+ * @param userId 登录用户id
|
|
|
+ * @return 获取互相关注列表
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserLikeVo> selectMutualAttention(Long userId, String userName, int pageNum, int pageSize, int searchType) {
|
|
|
+
|
|
|
+ //先查询自己关注的人
|
|
|
+ List<CommunityUserLikeVo> communityUserLikeVos = selectCommunityUserLikeList(userId, null, 1, 10000000, 0);
|
|
|
+ //再查询被关注的人是否关注自己
|
|
|
+ List<Long> likeUserIds = new ArrayList<>();
|
|
|
+ for (CommunityUserLikeVo communityUserLikeVo : communityUserLikeVos) {
|
|
|
+ likeUserIds.add(communityUserLikeVo.getLikeUserId());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!likeUserIds.isEmpty()) {
|
|
|
+ QueryWrapper<CommunityUserLike> queryWrapper = new QueryWrapper<CommunityUserLike>()
|
|
|
+ .in("user_id", likeUserIds).eq("like_user_id", userId);
|
|
|
+ if (searchType == 1) {
|
|
|
+ queryWrapper.orderByDesc("create_time");
|
|
|
+ } else {
|
|
|
+ queryWrapper.orderByAsc("create_time");
|
|
|
+ }
|
|
|
+ //分页查询数据
|
|
|
+ //int offset = (pageNum - 1) * pageSize;
|
|
|
+ Page<CommunityUserLike> page = new Page<>(pageNum, pageSize);
|
|
|
+
|
|
|
+ List<CommunityUserLike> communityUserLikes = communityUserLikeMapper.selectPage(page, queryWrapper).getRecords();
|
|
|
+
|
|
|
+ System.out.println("communityUserLikes: " + communityUserLikes);
|
|
|
+ CommunityUserLikeVo communityUserLikeVo = null;
|
|
|
+ communityUserLikeVos = new ArrayList<>();
|
|
|
+ for (CommunityUserLike communityUserLike : communityUserLikes) {
|
|
|
+ //用户信息
|
|
|
+ SysUser sysUserLike = sysUserMapper.selectUserById(communityUserLike.getLikeUserId());
|
|
|
+ //用户自我介绍
|
|
|
+ CommunityUserInfo userInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", communityUserLike.getUserId()));
|
|
|
+ CommunityUserInfo likeUserInfo = communityUserInfoMapper.selectOne(new QueryWrapper<CommunityUserInfo>().eq("user_id", communityUserLike.getLikeUserId()));
|
|
|
+
|
|
|
+ communityUserLikeVo = new CommunityUserLikeVo();
|
|
|
+ BeanUtils.copyProperties(communityUserLike, communityUserLikeVo);
|
|
|
+ SysUser sysUser = sysUserMapper.selectUserById(communityUserLike.getUserId());
|
|
|
+ communityUserLikeVo.setProfile(userInfo.getProfile());
|
|
|
+ communityUserLikeVo.setAvatar(sysUser.getAvatar());
|
|
|
+ communityUserLikeVo.setUsername(sysUser.getNickName());
|
|
|
+ communityUserLikeVo.setLikeUsername(sysUserLike.getNickName());
|
|
|
+ communityUserLikeVo.setLikeAvatar(sysUserLike.getAvatar());
|
|
|
+ communityUserLikeVo.setLikeProfile(likeUserInfo.getProfile());
|
|
|
+ communityUserLikeVo.setIsCare(true);
|
|
|
+
|
|
|
+
|
|
|
+ //如果不需要搜索名字直接添加
|
|
|
+ if (userName != null && communityUserLikeVo.getUsername().matches("(?i).*" + Pattern.quote(userName) + ".*")) {
|
|
|
+ communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+ } else if (userName == null) {
|
|
|
+ communityUserLikeVos.add(communityUserLikeVo);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return communityUserLikeVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断评论的人 是否在文章作者的关注列表中
|
|
|
+ *
|
|
|
+ * @param userId 必填
|
|
|
+ * @param commentId 可选 评论的评论接口
|
|
|
+ * @param articleId 可选 文章评论接口
|
|
|
+ * @return true or false
|
|
|
+ * @throws ParseException
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Boolean checkCommentPermission(Long userId, Long commentId, Long articleId) throws ParseException {
|
|
|
+ /**
|
|
|
+ * 1.传commentId 说明是 评论的评论接口
|
|
|
+ * 2.传articleId 说明是文章评论接口
|
|
|
+ * 3.询隐私设置表 communityPrivacyService.selectUserPrivacy 权限有没有开启
|
|
|
+ * 4.没有开启 直接结束
|
|
|
+ * 5.开启 查询作者关注列表
|
|
|
+ * 6。是否是关注的人评论我 有则评论成功，没有则返回失败
|
|
|
+ */
|
|
|
+ //假设传的评论ID 根据 评论ID要找到文章ID
|
|
|
+ if (articleId == null) {
|
|
|
+ List<CommunityArticleComment> communityArticleComments
|
|
|
+ = communityArticleCommentMapper
|
|
|
+ .selectList(new QueryWrapper<CommunityArticleComment>().eq("id", commentId));
|
|
|
+ CommunityArticleComment communityArticleComment = communityArticleComments.get(0);
|
|
|
+ articleId = communityArticleComment.getArticleId();
|
|
|
+ }
|
|
|
+ ;
|
|
|
+
|
|
|
+ //获取文章信息 找到文章创建人
|
|
|
+ List<CommunityArticle> communityArticles
|
|
|
+ = communityArticleMapper
|
|
|
+ .selectList(new QueryWrapper<CommunityArticle>().eq("id", articleId));
|
|
|
+
|
|
|
+ // 提取用户ID
|
|
|
+ Long articleUserId = null; // 初始化用户ID
|
|
|
+
|
|
|
+ if (!communityArticles.isEmpty()) { // 检查列表是否为空
|
|
|
+ CommunityArticle article = communityArticles.get(0); // 获取第一个文章
|
|
|
+ articleUserId = article.getUserId(); // 假设CommunityArticle有getUserId()方法
|
|
|
+ } else {
|
|
|
+ // 处理未找到文章的情况
|
|
|
+ // 例如，可以抛出异常或记录日志
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 直接允许作者评论
|
|
|
+ if (articleUserId.equals(userId)) {
|
|
|
+ /* // 如果评论者是文章作者，直接进行评论
|
|
|
+ communityArticleService.sendComment(communityArticleComment);*/
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询隐私设置
|
|
|
+ List<CommunityUserPrivacyVo> communityUserPrivacyVos = communityPrivacyService.selectUserPrivacy(articleUserId);
|
|
|
+ // 检查隐私设置 只允许我关注的人评论我
|
|
|
+ boolean IsComment = false;
|
|
|
+ for (CommunityUserPrivacyVo privacyVo : communityUserPrivacyVos) {
|
|
|
+ if (privacyVo.getIsComment() != null && privacyVo.getIsComment()) {
|
|
|
+ IsComment = true; // 只允许特定用户评论
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 如果评论受限，则查询用户关注列表
|
|
|
+ if (IsComment) {
|
|
|
+ List<CommunityUserLikeVo> communityUserLikeVos = communityArticleService.selectCommunityUserLikeList(articleUserId, null, 1, 100000, 0);
|
|
|
+ // 3. 检查评论者是否在关注列表中
|
|
|
+ boolean isFollower = communityUserLikeVos.stream()
|
|
|
+ .anyMatch(like -> like.getLikeUserId().equals(userId));
|
|
|
+ System.out.println(userId);
|
|
|
+ // 如果不是关注者，返回失败
|
|
|
+ if (!isFollower) {
|
|
|
+ //return AjaxResult.error("您没有权限评论此文章，因为只允许关注的人评论您!");
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<TrendingTop> selectTrendingTopByContent(String content) {
|
|
|
+ return communityArticleMapper.selectTrendingTopByContent(content);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 个人中心简介信息
|
|
|
+ *
|
|
|
+ * @param userId
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<CommunityUserPromptVo> selectCommunityUserPrompt(Long userId) {
|
|
|
+ if (Objects.isNull(userId)) {
|
|
|
+ userId = SecurityUtils.getLoginUser().getUserId();
|
|
|
+ }
|
|
|
+ // 查询自己的通知列表
|
|
|
+ List<CommunityUserPrompt> communityUserPrompts
|
|
|
+ = communityUserPromptMapper
|
|
|
+ .selectList(new QueryWrapper<CommunityUserPrompt>().eq("user_id", userId));
|
|
|
+
|
|
|
+
|
|
|
+ // 创建一个用于存放VO的列表
|
|
|
+ List<CommunityUserPromptVo> communityUserPromptVos = new ArrayList<>();
|
|
|
+ // 遍历查询结果，复制属性到 VO 对象
|
|
|
+ for (CommunityUserPrompt communityUserPrompt : communityUserPrompts) {
|
|
|
+ CommunityUserPromptVo communityUserPromptVo = new CommunityUserPromptVo();
|
|
|
+ BeanUtils.copyProperties(communityUserPrompt, communityUserPromptVo);
|
|
|
+ communityUserPromptVos.add(communityUserPromptVo);
|
|
|
+ }
|
|
|
+ // 判断隐私权限是否为空
|
|
|
+ if (communityUserPromptVos.isEmpty()) {
|
|
|
+ // 如果没有隐私权限，插入一条关于 userId 的数据
|
|
|
+ CommunityUserPrompt newPrompt = new CommunityUserPrompt();
|
|
|
+ newPrompt.setUserId(userId);
|
|
|
+ newPrompt.setLikeUser(false);
|
|
|
+ newPrompt.setCommentCircle(false);
|
|
|
+ newPrompt.setLikeCollect(false);
|
|
|
+ // 设置其他必要的默认值，例如：
|
|
|
+ // 使用 MyBatis-Plus 执行插入操作
|
|
|
+ communityUserPromptMapper.insert(newPrompt);
|
|
|
+ // 将新插入的记录转换为 VO 并返回
|
|
|
+ CommunityUserPromptVo newPromptVo = new CommunityUserPromptVo();
|
|
|
+ BeanUtils.copyProperties(newPrompt, newPromptVo);
|
|
|
+ communityUserPromptVos.add(newPromptVo);
|
|
|
+ }
|
|
|
+ return communityUserPromptVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 修改service实现
|
|
|
+ @Override
|
|
|
+ public List<CommunityArticleVo> selectUserNoCo(Long userId, int pageNum, int pageSize, int searchType) {
|
|
|
+ //PageHelper.startPage(pageNum, pageSize);
|
|
|
+ return communityArticleMapper.selectUserNoCoArticles(userId);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<CommunityArticleVo> selectUserLike(Long userId, int pageNum, int pageSize, int searchType) {
|
|
|
+ // 查询的喜欢列表
|
|
|
+ List<CommunityLike> communityUserLike
|
|
|
+ = communityLikeMapper
|
|
|
+ .selectList(new QueryWrapper<CommunityLike>().eq("user_id", userId));
|
|
|
+ List<Long> articleIds = communityUserLike.stream().map(item -> item.getArticleId()).collect(Collectors.toList());
|
|
|
+ TableDataInfo rspData = null;
|
|
|
+ CommunityArticle communityArticle = null;
|
|
|
+ List<CommunityArticleVo> communityArticleVos = null;
|
|
|
+ if (!articleIds.isEmpty()) {
|
|
|
+ rspData = new TableDataInfo();
|
|
|
+ communityArticle = new CommunityArticle();
|
|
|
+ communityArticle.setArticleIds(articleIds);
|
|
|
+ communityArticleVos = communityArticleService.selectCommunityArticleList(userId, rspData, communityArticle, pageNum, pageSize, searchType);
|
|
|
+ }
|
|
|
+ return communityArticleVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<CommunityArticleVo> selectUserCollect(Long userId, int pageNum, int pageSize, int searchType) {
|
|
|
+ // 查询收藏的列表
|
|
|
+ List<CommunityArticleCollect> communityArticleCollects
|
|
|
+ = communityArticleCollectMapper
|
|
|
+ .selectList(new QueryWrapper<CommunityArticleCollect>().eq("user_id", userId));
|
|
|
+
|
|
|
+
|
|
|
+ List<Long> articleIds = communityArticleCollects.stream().map(item -> item.getArticleId()).collect(Collectors.toList());
|
|
|
+ TableDataInfo rspData = null;
|
|
|
+ CommunityArticle communityArticle = null;
|
|
|
+ List<CommunityArticleVo> communityArticleVos = null;
|
|
|
+ if (!articleIds.isEmpty()) {
|
|
|
+ rspData = new TableDataInfo();
|
|
|
+ communityArticle = new CommunityArticle();
|
|
|
+ communityArticle.setArticleIds(articleIds);
|
|
|
+ communityArticleVos = communityArticleService.selectCommunityArticleList(userId, rspData, communityArticle, pageNum, pageSize, searchType);
|
|
|
+ }
|
|
|
+ return communityArticleVos;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 开启抽奖
|
|
|
+ *
|
|
|
+ * @param articleId
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public CommunityCommentRaffleVo selectCommentRaffle(Long articleId) {
|
|
|
+ CommunityCommentRaffle communityCommentRaffle = communityCommentRaffleMapper.selectOne(
|
|
|
+ new QueryWrapper<CommunityCommentRaffle>()
|
|
|
+ .eq("article_id", articleId)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ }));
|
|
|
+
|
|
|
+ CommunityCommentRaffleVo communityCommentRaffleVo = new CommunityCommentRaffleVo();
|
|
|
+ CommunityUserInfoVo communityUserInfoVo = null;
|
|
|
+ //如果抽奖表为空则需要插入一条数据
|
|
|
+ if (communityCommentRaffle == null) {
|
|
|
+ List<CommunityArticleComment> communityArticleComments = communityArticleCommentMapper.selectList(new QueryWrapper<CommunityArticleComment>()
|
|
|
+ .eq("article_id", articleId)
|
|
|
+ .and((wrapper) -> {
|
|
|
+ wrapper.ne("is_delete", true).or().isNull("is_delete");
|
|
|
+ })
|
|
|
+ );
|
|
|
+ if (communityArticleComments.size() == 0) {
|
|
|
+ return communityCommentRaffleVo;
|
|
|
+ }
|
|
|
+ // 使用 Random 类生成一个随机索引
|
|
|
+ Random random = new Random();
|
|
|
+ int randomIndex = random.nextInt(communityArticleComments.size());
|
|
|
+ CommunityArticleComment communityArticleComment = communityArticleComments.get(randomIndex);
|
|
|
+ CommunityCommentRaffle commentRaffle = new CommunityCommentRaffle();
|
|
|
+ commentRaffle.setArticleId(communityArticleComment.getArticleId());
|
|
|
+ commentRaffle.setCommentId(communityArticleComment.getId());
|
|
|
+ commentRaffle.setUserId(communityArticleComment.getUserId());
|
|
|
+ commentRaffle.setCreateBy(SecurityUtils.getUserId());
|
|
|
+ commentRaffle.setCreateTime(DateUtils.parseDate(DateUtils.getTime()));
|
|
|
+ communityCommentRaffleMapper.insert(commentRaffle);
|
|
|
+ BeanUtils.copyProperties(commentRaffle, communityCommentRaffleVo);
|
|
|
+ communityUserInfoVo = communityArticleService.selectCommunityUserInfoById(commentRaffle.getUserId(), true);
|
|
|
+ communityCommentRaffleVo.setUserName(communityUserInfoVo.getNickName());
|
|
|
+ communityCommentRaffleVo.setUserAvatar(communityUserInfoVo.getAvatar());
|
|
|
+ return communityCommentRaffleVo;
|
|
|
+ }
|
|
|
+
|
|
|
+ BeanUtils.copyProperties(communityCommentRaffle, communityCommentRaffleVo);
|
|
|
+ communityUserInfoVo = communityArticleService.selectCommunityUserInfoById(communityCommentRaffle.getUserId(), true);
|
|
|
+ communityCommentRaffleVo.setUserName(communityUserInfoVo.getNickName());
|
|
|
+ communityCommentRaffleVo.setUserAvatar(communityUserInfoVo.getAvatar());
|
|
|
+ return communityCommentRaffleVo;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断是否是视频文件
|
|
|
+ *
|
|
|
+ * @param fileUrl 文件地址
|
|
|
+ * @return 结果
|
|
|
+ */
|
|
|
+ public static boolean isVideoFile(String fileUrl) {
|
|
|
+ try {
|
|
|
+ // 打开 HTTP 连接
|
|
|
+ URL url = new URL(fileUrl);
|
|
|
+ HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
|
|
+ connection.setRequestMethod("GET");
|
|
|
+
|
|
|
+ // 获取文件类型
|
|
|
+ String mimeType = connection.getContentType();
|
|
|
+
|
|
|
+ // 判断是否为视频类型
|
|
|
+ return mimeType != null && mimeType.startsWith("video");
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
