From c6512655e722d9ca80dd8c34b79f6d3923ecf86c Mon Sep 17 00:00:00 2001
From: 罗元桥 <2376770955@qq.com>
Date: 星期二, 22 六月 2021 16:07:50 +0800
Subject: [PATCH] Merge branch 'test' into 'test_screen'

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActDiscussServiceImpl.java |   42 ++++++++++++++++++++++++++++++++++++++----
 1 files changed, 38 insertions(+), 4 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActDiscussServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActDiscussServiceImpl.java
index 3fa0c13..8dfb337 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActDiscussServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActDiscussServiceImpl.java
@@ -5,12 +5,14 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.panzhihua.common.model.dtos.community.*;
+import com.panzhihua.common.model.dtos.community.bigscreen.work.ScreenDiscussListDTO;
 import com.panzhihua.common.model.vos.LoginUserInfoVO;
 import com.panzhihua.common.model.vos.R;
 import com.panzhihua.common.model.vos.community.ComActDiscussCommentVO;
 import com.panzhihua.common.model.vos.community.ComActDiscussOptionVO;
 import com.panzhihua.common.model.vos.community.ComActDiscussVO;
 import com.panzhihua.common.model.vos.community.ComActVO;
+import com.panzhihua.common.model.vos.community.screen.work.DiscussListVO;
 import com.panzhihua.service_community.dao.*;
 import com.panzhihua.service_community.model.dos.*;
 import com.panzhihua.service_community.service.ComActDiscussOptionService;
@@ -420,8 +422,11 @@
                         }
                         List<ComActDiscussCommentVO> collect1 = records.stream().filter(comActDiscussCommentVO2 -> comActDiscussCommentVO2.getId().equals(parentId)).collect(Collectors.toList());
                         if (!ObjectUtils.isEmpty(collect1)) {
-                            String userName = collect1.get(0).getUserName();
+                            ComActDiscussCommentVO comActDiscussCommentVOFirst = collect1.get(0);
+                            String userName = comActDiscussCommentVOFirst.getUserName();
+                            String userNickName = comActDiscussCommentVOFirst.getUserNickName();
                             comActDiscussCommentVO1.setUserNameBack(userName);
+                            comActDiscussCommentVO1.setUserNickNameBack(userNickName);
                         }
                         Integer integer = comActDiscussCommentUserDAO.selectCount(new QueryWrapper<ComActDiscussCommentUserDO>().lambda().eq(ComActDiscussCommentUserDO::getDisscussCommentId, comActDiscussCommentVO1.getId()).eq(ComActDiscussCommentUserDO::getUserId, pageComActDiscussCommentDTO.getLoginUserId()));
                         if (integer>0) {
@@ -479,9 +484,11 @@
         }
         Long userId = comActDiscussDO.getUserId();
         LoginUserInfoVO loginUserInfoVO=comActDiscussDAO.selectUserByUserId(userId);
-        comActDiscussVO.setUserName(loginUserInfoVO.getName());
-        comActDiscussVO.setImageUrl(loginUserInfoVO.getImageUrl());
-        comActDiscussVO.setUserNickName(loginUserInfoVO.getNickName());
+        if(loginUserInfoVO != null){
+            comActDiscussVO.setUserName(loginUserInfoVO.getName());
+            comActDiscussVO.setUserNickName(loginUserInfoVO.getNickName());
+            comActDiscussVO.setImageUrl(loginUserInfoVO.getImageUrl());
+        }
         Long communityId = comActDiscussDO.getCommunityId();
         Integer type1 = loginUserInfoVO.getType();
         if (type1.intValue()>1) {
@@ -552,4 +559,31 @@
         }
         return R.fail();
     }
+
+    /**
+     * 工作大屏-一起议列表
+     * @param discussListDTO    请求参数
+     * @return  一起议列表
+     */
+    @Override
+    public R getScreenDiscussList(ScreenDiscussListDTO discussListDTO){
+        IPage<DiscussListVO> discussListVOIPage = comActDiscussDAO.getScreenDiscussList(new Page(discussListDTO.getPageNum(),discussListDTO.getPageSize()),discussListDTO);
+        if(!discussListVOIPage.getRecords().isEmpty()){
+            discussListVOIPage.getRecords().forEach(discussListVO -> {
+                //查询评论数量和点赞数量
+                Integer integer = comActDiscussCommentDAO.selectCount(new QueryWrapper<ComActDiscussCommentDO>().lambda().eq(ComActDiscussCommentDO::getDiscussId, discussListVO.getId()));
+                discussListVO.setCommentCount(integer);
+                Integer integer1 = comActDiscussUserDAO.selectCount(new QueryWrapper<ComActDiscussUserDO>().lambda().eq(ComActDiscussUserDO::getDiscussId, discussListVO.getId()));
+                discussListVO.setFabulousCount(integer1);
+
+                if(discussListVO.getType().equals(ScreenDiscussListDTO.type.tp)){//投票
+                    List<ComActDiscussOptionVO> discussOptionList = comActDiscussDAO.getScreenDiscussOptionList(discussListVO.getId());
+                    if(!discussOptionList.isEmpty()){
+                        discussListVO.setDiscussOptionList(discussOptionList);
+                    }
+                }
+            });
+        }
+        return R.ok(discussListVOIPage);
+    }
 }

--
Gitblit v1.7.1