package com.panzhihua.service_community.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import javax.annotation.Resource;
|
|
import com.panzhihua.common.utlis.DateUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.util.StringUtils;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
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;
|
import com.panzhihua.service_community.service.ComActDiscussService;
|
|
/**
|
* @program: springcloud_k8s_panzhihuazhihuishequ
|
* @description: 议事投票
|
* @author: huang.hongfa weixin hhf9596 qq 959656820
|
* @create: 2021-01-22 14:51
|
**/
|
@Service
|
public class ComActDiscussServiceImpl implements ComActDiscussService {
|
@Resource
|
private ComActDiscussCommentDAO comActDiscussCommentDAO;
|
@Resource
|
private ComActDiscussDAO comActDiscussDAO;
|
@Resource
|
private ComActDiscussOptionUserDAO comActDiscussOptionUserDAO;
|
@Resource
|
private ComActDiscussUserDAO comActDiscussUserDAO;
|
@Resource
|
private ComActDiscussOptionDAO comActDiscussOptionDAO;
|
@Resource
|
private ComActDiscussCommentUserDAO comActDiscussCommentUserDAO;
|
@Resource
|
private ComActDiscussOptionService comActDiscussOptionService;
|
|
/**
|
* 议事投票-新增
|
*
|
* @param comActDiscussDTO
|
* 新增参数
|
* @return 新增结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R addDiscuss(ComActDiscussDTO comActDiscussDTO) {
|
ComActDiscussDO comActDiscussDO = new ComActDiscussDO();
|
BeanUtils.copyProperties(comActDiscussDTO, comActDiscussDO);
|
Integer type = comActDiscussDTO.getType();
|
Date nowDate = new Date();
|
if(type.equals(ComActDiscussDO.type.tp)){//判断是投票，需要转义时间
|
Date startTime = DateUtils.stringToDate(comActDiscussDTO.getStartTime(),DateUtils.ymdhms_format);
|
Date endTime = DateUtils.stringToDate(comActDiscussDTO.getEndTime(),DateUtils.ymdhms_format);
|
comActDiscussDO.setStartTime(startTime);
|
comActDiscussDO.setEndTime(endTime);
|
comActDiscussDO.setStatus(ComActDiscussDO.status.wks);
|
//根据时间判断状态是否开始
|
if (startTime != null && startTime.getTime() <= nowDate.getTime()) {
|
comActDiscussDO.setStatus(ComActDiscussDO.status.jxz);
|
comActDiscussDO.setReleaseAt(nowDate);
|
}
|
}else{
|
comActDiscussDO.setStatus(ComActDiscussDO.status.yfb);
|
}
|
//查询社区地址
|
ComActVO comActVO = comActDiscussDAO.selectCommunity(comActDiscussDTO.getCommunityId());
|
String address = comActDiscussDO.getAddress();
|
if (ObjectUtils.isEmpty(address)) {
|
comActDiscussDO.setAddress(comActVO.getAddress());
|
}
|
int insert = comActDiscussDAO.insert(comActDiscussDO);
|
if (insert > 0) {
|
//如果是投票，需要把投票的选项存储
|
if (type.equals(2)) {
|
Long comActDiscussDO1Id = comActDiscussDO.getId();
|
List<ComActDiscussOptionDTO> discussOptions = comActDiscussDTO.getDiscussOptions();
|
List<ComActDiscussOptionDO> comActDiscussOptionDOS = new ArrayList<>();
|
discussOptions.forEach(s -> {
|
ComActDiscussOptionDO comActDiscussOptionDO = new ComActDiscussOptionDO();
|
comActDiscussOptionDO.setDiscussId(comActDiscussDO1Id);
|
comActDiscussOptionDO.setOptionContent(s.getOptionContent());
|
comActDiscussOptionDO.setOptionUrl(s.getOptionUrl());
|
comActDiscussOptionDOS.add(comActDiscussOptionDO);
|
});
|
comActDiscussOptionService.saveBatch(comActDiscussOptionDOS);
|
}
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-编辑
|
* @param comActDiscussDTO 请求参数
|
* @return 编辑结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R editDiscuss(ComActDiscussDTO comActDiscussDTO) {
|
Long comActDiscussDO1Id = comActDiscussDTO.getId();
|
ComActDiscussDO comActDiscussDO = comActDiscussDAO.selectById(comActDiscussDO1Id);
|
if (ObjectUtils.isEmpty(comActDiscussDO)) {
|
return R.fail("议事投票不存在");
|
}
|
if(!comActDiscussDO.getStatus().equals(ComActDiscussDO.status.wks) && !comActDiscussDO.getStatus().equals(ComActDiscussDO.status.yfb)){
|
return R.fail("该状态不可修改");
|
}
|
Integer type = comActDiscussDO.getType();
|
Integer isRepeat = comActDiscussDO.getIsRepeat();
|
BeanUtils.copyProperties(comActDiscussDTO, comActDiscussDO);
|
comActDiscussDO.setType(type);
|
comActDiscussDO.setIsRepeat(isRepeat);
|
Date nowDate = new Date();
|
if(type.equals(ComActDiscussDO.type.tp)){//判断是投票，需要转义时间
|
Date startTime = DateUtils.stringToDate(comActDiscussDTO.getStartTime(),DateUtils.ymdhms_format);
|
Date endTime = DateUtils.stringToDate(comActDiscussDTO.getEndTime(),DateUtils.ymdhms_format);
|
comActDiscussDO.setStartTime(startTime);
|
comActDiscussDO.setEndTime(endTime);
|
comActDiscussDO.setStatus(ComActDiscussDO.status.wks);
|
//根据时间判断状态是否开始
|
if (startTime != null && startTime.getTime() <= nowDate.getTime()) {
|
comActDiscussDO.setStatus(ComActDiscussDO.status.jxz);
|
comActDiscussDO.setReleaseAt(nowDate);
|
}
|
}else{
|
comActDiscussDO.setStatus(ComActDiscussDO.status.yfb);
|
}
|
comActDiscussDO.setUpdateAt(new Date());
|
int insert = comActDiscussDAO.updateById(comActDiscussDO);
|
if (insert > 0) {
|
//如果是投票，需要把投票的选项存储
|
if (type.equals(2)) {
|
comActDiscussOptionService.remove(new QueryWrapper<ComActDiscussOptionDO>().lambda()
|
.eq(ComActDiscussOptionDO::getDiscussId,comActDiscussDO1Id));
|
List<ComActDiscussOptionDO> comActDiscussOptionDOS = new ArrayList<>();
|
comActDiscussDTO.getDiscussOptions().forEach(s -> {
|
ComActDiscussOptionDO comActDiscussOptionDO = new ComActDiscussOptionDO();
|
comActDiscussOptionDO.setDiscussId(comActDiscussDO1Id);
|
comActDiscussOptionDO.setOptionContent(s.getOptionContent());
|
comActDiscussOptionDO.setOptionUrl(s.getOptionUrl());
|
comActDiscussOptionDOS.add(comActDiscussOptionDO);
|
});
|
comActDiscussOptionService.saveBatch(comActDiscussOptionDOS);
|
}
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-详情
|
*
|
* @param id
|
* 主键
|
* @return ComActDiscussVO
|
*/
|
@Override
|
public R detailDiscuss(Long id) {
|
ComActDiscussDO comActDiscussDO = comActDiscussDAO.selectById(id);
|
if (ObjectUtils.isEmpty(comActDiscussDO)) {
|
return R.fail("议事投票不存在");
|
}
|
ComActDiscussVO comActDiscussVO = new ComActDiscussVO();
|
BeanUtils.copyProperties(comActDiscussDO, comActDiscussVO);
|
comActDiscussVO.setSignNum(comActDiscussDO.getFabulousNum());
|
Integer type = comActDiscussVO.getType();
|
if (type.equals(2)) {
|
//查询选项列表
|
List<ComActDiscussOptionVO> comActDiscussOptionVOS = comActDiscussOptionDAO.getDiscussOptionList(id);
|
comActDiscussVO.setComActDiscussOptionVOS(comActDiscussOptionVOS);
|
}
|
Long userId = comActDiscussDO.getUserId();
|
LoginUserInfoVO loginUserInfoVO = comActDiscussDAO.selectUserByUserId(userId);
|
comActDiscussVO.setUserName(loginUserInfoVO.getName());
|
return R.ok(comActDiscussVO);
|
}
|
|
/**
|
* 议事投票-删除
|
*
|
* @param id
|
* 主键
|
* @return 删除结果
|
*/
|
@Override
|
public R deleteDiscuss(Long id) {
|
ComActDiscussDO comActDiscussDO = new ComActDiscussDO();
|
comActDiscussDO.setId(id);
|
comActDiscussDO.setIsDel(ComActDiscussDO.isOk.yes);
|
if (comActDiscussDAO.updateById(comActDiscussDO) > 0) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-回复
|
*
|
* @param comActDiscussCommentDTO
|
* 评论内容
|
* @return 回复结果
|
*/
|
@Override
|
public R addDiscussComment(ComActDiscussCommentDTO comActDiscussCommentDTO) {
|
Long discussId = comActDiscussCommentDTO.getDiscussId();
|
ComActDiscussDO comActDiscussDO = comActDiscussDAO.selectById(discussId);
|
if (ObjectUtils.isEmpty(comActDiscussDO)) {
|
return R.fail("议事投票不存在");
|
}
|
ComActDiscussCommentDO comActDiscussCommentDO = new ComActDiscussCommentDO();
|
BeanUtils.copyProperties(comActDiscussCommentDTO, comActDiscussCommentDO);
|
Long userId = comActDiscussCommentDTO.getUserId();
|
Long userId1 = comActDiscussDO.getUserId();
|
if (userId.equals(userId1)) {
|
comActDiscussCommentDO.setIsAuthor(1);
|
}
|
int insert = comActDiscussCommentDAO.insert(comActDiscussCommentDO);
|
if (insert > 0) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-分页查询
|
*
|
* @param pageComActDiscussDTO
|
* 查询参数
|
* @return ComActDiscussVO
|
*/
|
@Override
|
public R pageDiscuss(PageComActDiscussDTO pageComActDiscussDTO) {
|
Page page = new Page<>();
|
Long pageNum = pageComActDiscussDTO.getPageNum();
|
Long pageSize = pageComActDiscussDTO.getPageSize();
|
if (null == pageNum || 0 == pageNum) {
|
pageNum = 1l;
|
}
|
if (null == pageSize || 0 == pageSize) {
|
pageSize = 10l;
|
}
|
page.setSize(pageSize);
|
page.setCurrent(pageNum);
|
IPage<ComActDiscussVO> iPage = comActDiscussDAO.pageDiscuss(page, pageComActDiscussDTO);
|
return R.ok(iPage);
|
|
}
|
|
/**
|
* 议事投票-后台分页查询
|
* @param pageComActDiscussDTO 请求参数
|
* @return 议事投票列表
|
*/
|
@Override
|
public R pageDiscussAdmin(PageComActDiscussDTO pageComActDiscussDTO) {
|
return R.ok(comActDiscussDAO.pageDiscussAdmin(new Page<>(pageComActDiscussDTO.getPageNum(),pageComActDiscussDTO.getPageSize()), pageComActDiscussDTO));
|
}
|
|
/**
|
* 议事投票-评论-查看
|
*
|
* @param id
|
* 主键
|
* @return 详情 ComActDiscussCommentVO
|
*/
|
@Override
|
public R detailDiscusscomment(Long id) {
|
ComActDiscussCommentDO comActDiscussCommentDO = comActDiscussCommentDAO.selectById(id);
|
if (ObjectUtils.isEmpty(comActDiscussCommentDO)) {
|
return R.fail("评论不存在");
|
}
|
ComActDiscussCommentVO comActDiscussCommentVO = new ComActDiscussCommentVO();
|
Long parentId = comActDiscussCommentDO.getParentId();
|
if (parentId.intValue() == 0) {
|
// 一级评论
|
BeanUtils.copyProperties(comActDiscussCommentDO, comActDiscussCommentVO);
|
} else {
|
ComActDiscussCommentDO comActDiscussCommentDO1 = comActDiscussCommentDAO.selectById(parentId);
|
BeanUtils.copyProperties(comActDiscussCommentDO1, comActDiscussCommentVO);
|
comActDiscussCommentVO.setCommentBack(comActDiscussCommentDO.getComment());
|
comActDiscussCommentVO.setTimeBack(comActDiscussCommentDO.getCreateAt());
|
comActDiscussCommentVO.setParentId(parentId);
|
}
|
Integer count = comActDiscussCommentUserDAO.selectCount(new QueryWrapper<ComActDiscussCommentUserDO>().lambda()
|
.eq(ComActDiscussCommentUserDO::getDisscussCommentId, id));
|
comActDiscussCommentVO.setNum(count);
|
LoginUserInfoVO loginUserInfoVO = comActDiscussDAO.selectUserByUserId(comActDiscussCommentDO.getUserId());
|
comActDiscussCommentVO.setUserName(loginUserInfoVO.getName());
|
comActDiscussCommentVO.setPhone(loginUserInfoVO.getPhone());
|
return R.ok(comActDiscussCommentVO);
|
}
|
|
/**
|
* 议事投票-评论-置顶
|
*
|
* @param id
|
* 主键
|
* @return 置顶结果
|
*/
|
@Override
|
public R putDiscussCommentTop(Long id) {
|
ComActDiscussCommentDO comActDiscussCommentDO = comActDiscussCommentDAO.selectById(id);
|
if (ObjectUtils.isEmpty(comActDiscussCommentDO)) {
|
return R.fail("评论不存在");
|
}
|
Long parentId = comActDiscussCommentDO.getParentId();
|
if (parentId.intValue() != 0) {
|
return R.fail("二级评论不能置顶");
|
}
|
Long discussId = comActDiscussCommentDO.getDiscussId();
|
ComActDiscussCommentDO comActDiscussCommentDO1 = new ComActDiscussCommentDO();
|
comActDiscussCommentDO1.setIsTopping(0);
|
comActDiscussCommentDAO.update(comActDiscussCommentDO1,
|
new UpdateWrapper<ComActDiscussCommentDO>().lambda().eq(ComActDiscussCommentDO::getDiscussId, discussId));
|
comActDiscussCommentDO1.setIsTopping(1);
|
comActDiscussCommentDO1.setId(id);
|
int update = comActDiscussCommentDAO.updateById(comActDiscussCommentDO1);
|
if (update > 0) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-评论-回复
|
*
|
* @param comActDiscussCommentDTO
|
* 回复内容
|
* @return 回复结果
|
*/
|
@Override
|
public R addDiscussCommentBack(ComActDiscussCommentDTO comActDiscussCommentDTO) {
|
Long id = comActDiscussCommentDTO.getId();
|
ComActDiscussCommentDO comActDiscussCommentDO = comActDiscussCommentDAO.selectById(id);
|
if (ObjectUtils.isEmpty(comActDiscussCommentDO)) {
|
return R.fail("评论不存在");
|
}
|
Long discussId = comActDiscussCommentDO.getDiscussId();
|
ComActDiscussDO comActDiscussDO = comActDiscussDAO.selectById(discussId);
|
if (ObjectUtils.isEmpty(comActDiscussDO)) {
|
return R.fail("议事投票不存在");
|
}
|
Long userId = comActDiscussDO.getUserId();
|
Long userId1 = comActDiscussCommentDTO.getUserId();
|
ComActDiscussCommentDO comActDiscussCommentDO1 = new ComActDiscussCommentDO();
|
comActDiscussCommentDO1.setDiscussId(discussId);
|
comActDiscussCommentDO1.setComment(comActDiscussCommentDTO.getComment());
|
comActDiscussCommentDO1.setUserId(comActDiscussCommentDTO.getUserId());
|
comActDiscussCommentDO1.setParentId(id);
|
if (userId.equals(userId1)) {
|
comActDiscussCommentDO1.setIsAuthor(1);
|
}
|
int insert = comActDiscussCommentDAO.insert(comActDiscussCommentDO1);
|
if (insert > 0) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-评论-分页查询
|
*
|
* @param pageComActDiscussCommentDTO
|
* 分页查询参数
|
* @return ComActDiscussCommentVO
|
*/
|
@Override
|
public R pageDiscussComment(PageComActDiscussCommentDTO pageComActDiscussCommentDTO) {
|
Page page = new Page<>();
|
Long pageNum = pageComActDiscussCommentDTO.getPageNum();
|
Long pageSize = pageComActDiscussCommentDTO.getPageSize();
|
if (null == pageNum || 0 == pageNum) {
|
pageNum = 1l;
|
}
|
if (null == pageSize || 0 == pageSize) {
|
pageSize = 10l;
|
}
|
page.setSize(pageSize);
|
page.setCurrent(pageNum);
|
IPage<ComActDiscussCommentVO> iPage = comActDiscussDAO.pageDiscussComment(page, pageComActDiscussCommentDTO);
|
return R.ok(iPage);
|
}
|
|
/**
|
* 议事投票-分页查询 小程序
|
*
|
* @param pageComActDiscussDTO
|
* 查询参数
|
* @return ComActDiscussVO 分页
|
*/
|
@Override
|
public R pageDiscussApplets(PageComActDiscussDTO pageComActDiscussDTO) {
|
Page page = new Page<>();
|
Long pageNum = pageComActDiscussDTO.getPageNum();
|
Long pageSize = pageComActDiscussDTO.getPageSize();
|
Long loginUserId = pageComActDiscussDTO.getLoginUserId();
|
if (null == pageNum || 0 == pageNum) {
|
pageNum = 1l;
|
}
|
if (null == pageSize || 0 == pageSize) {
|
pageSize = 10l;
|
}
|
page.setSize(pageSize);
|
page.setCurrent(pageNum);
|
IPage<ComActDiscussVO> iPage = comActDiscussDAO.pageDiscussApplets(page, pageComActDiscussDTO);
|
List<ComActDiscussVO> records = iPage.getRecords();
|
if (!ObjectUtils.isEmpty(records)) {
|
records.forEach(comActDiscussVO -> {
|
Integer type = comActDiscussVO.getType();
|
Long id = comActDiscussVO.getId();
|
if (type.equals(2)) {
|
List<ComActDiscussOptionDO> comActDiscussOptionDOS = comActDiscussOptionDAO.selectList(
|
new QueryWrapper<ComActDiscussOptionDO>().lambda().eq(ComActDiscussOptionDO::getDiscussId, id));
|
List<ComActDiscussOptionVO> comActDiscussOptionVOS = new ArrayList<>();
|
comActDiscussOptionDOS.forEach(comActDiscussOptionDO -> {
|
Long discussOptionDOId = comActDiscussOptionDO.getId();
|
Integer selectCount =
|
comActDiscussOptionUserDAO.selectCount(new QueryWrapper<ComActDiscussOptionUserDO>()
|
.lambda().eq(ComActDiscussOptionUserDO::getDiscussOptionId, discussOptionDOId));
|
ComActDiscussOptionVO comActDiscussOptionVO = new ComActDiscussOptionVO();
|
BeanUtils.copyProperties(comActDiscussOptionDO, comActDiscussOptionVO);
|
comActDiscussOptionVO.setNum(selectCount);
|
|
if (loginUserId != null) {
|
// 判断选项是否已投票
|
int haveVote =
|
comActDiscussOptionUserDAO.selectHaveVotes(comActDiscussOptionDO.getId(), loginUserId);
|
comActDiscussOptionVO.setHaveVote(haveVote > 0 ? 1 : 0);
|
}
|
comActDiscussOptionVOS.add(comActDiscussOptionVO);
|
});
|
comActDiscussOptionVOS.sort(Comparator.comparing(ComActDiscussOptionVO::getNum).reversed());
|
comActDiscussVO.setComActDiscussOptionVOS(comActDiscussOptionVOS);
|
}
|
|
if (loginUserId != null) {
|
Integer integer = comActDiscussUserDAO.selectCount(new QueryWrapper<ComActDiscussUserDO>().lambda()
|
.eq(ComActDiscussUserDO::getDiscussId, comActDiscussVO.getId())
|
.eq(ComActDiscussUserDO::getUserId, loginUserId));
|
if (integer > 0) {
|
comActDiscussVO.setHaveSign(1);
|
} else {
|
comActDiscussVO.setHaveSign(0);
|
}
|
// 判断是否已经投票
|
int haveVote = comActDiscussOptionUserDAO.selectHaveVote(id, loginUserId);
|
comActDiscussVO.setHaveVote(haveVote > 0 ? 1 : 0);
|
}
|
});
|
}
|
return R.ok(iPage);
|
}
|
|
/**
|
* 议事投票-点赞、取消点赞
|
*
|
* @param comActDiscussUserDTO
|
* 操作类型
|
* @return 操作结果
|
*/
|
@Override
|
public R putDiscussUser(ComActDiscussUserDTO comActDiscussUserDTO) {
|
Integer type = comActDiscussUserDTO.getType();
|
int num = 0;
|
ComActDiscussUserDO comActDiscussUserDO = new ComActDiscussUserDO();
|
BeanUtils.copyProperties(comActDiscussUserDTO, comActDiscussUserDO);
|
if (type.intValue() == 1) {
|
num = comActDiscussUserDAO.insert(comActDiscussUserDO);
|
} else {
|
num = comActDiscussUserDAO.delete(new QueryWrapper<ComActDiscussUserDO>().lambda()
|
.eq(ComActDiscussUserDO::getUserId, comActDiscussUserDTO.getUserId())
|
.eq(ComActDiscussUserDO::getDiscussId, comActDiscussUserDTO.getDiscussId()));
|
}
|
if (num > 0) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-评论-分页查询 小程序
|
*
|
* @param pageComActDiscussCommentDTO
|
* 分页参数
|
* @return ComActDiscussCommentVO
|
*/
|
@Override
|
public R pageDiscussCommentApplets(PageComActDiscussCommentDTO pageComActDiscussCommentDTO) {
|
Page page = new Page<>();
|
Long pageNum = pageComActDiscussCommentDTO.getPageNum();
|
Long pageSize = pageComActDiscussCommentDTO.getPageSize();
|
if (null == pageNum || 0 == pageNum) {
|
pageNum = 1l;
|
}
|
if (null == pageSize || 0 == pageSize) {
|
pageSize = 10l;
|
}
|
page.setSize(pageSize);
|
page.setCurrent(pageNum);
|
IPage<ComActDiscussCommentVO> iPage =
|
comActDiscussDAO.pageDiscussCommentApplets(page, pageComActDiscussCommentDTO);
|
List<ComActDiscussCommentVO> records = iPage.getRecords();
|
if (!ObjectUtils.isEmpty(records)) {
|
records.forEach(comActDiscussCommentVO -> {
|
List<ComActDiscussCommentVO> comActDiscussCommentVOList = new ArrayList<>();
|
Long id = comActDiscussCommentVO.getId();
|
comActDiscussCommentVOList = comActDiscussCommentDAO.selectChilds(id);
|
if (!ObjectUtils.isEmpty(comActDiscussCommentVOList)) {
|
List<ComActDiscussCommentVO> comActDiscussCommentVOS = comActDiscussCommentVOList;
|
comActDiscussCommentVOList.forEach(comActDiscussCommentVO1 -> {
|
Long parentId = comActDiscussCommentVO1.getParentId();
|
List<ComActDiscussCommentVO> collect = comActDiscussCommentVOS.stream()
|
.filter(comActDiscussCommentVO2 -> comActDiscussCommentVO2.getId().equals(parentId))
|
.collect(Collectors.toList());
|
if (!ObjectUtils.isEmpty(collect)) {
|
String userName = collect.get(0).getUserName();
|
String userNickName = collect.get(0).getUserNickName();
|
comActDiscussCommentVO1.setUserNameBack(userName);
|
comActDiscussCommentVO1.setUserNickNameBack(userNickName);
|
}
|
List<ComActDiscussCommentVO> collect1 = records.stream()
|
.filter(comActDiscussCommentVO2 -> comActDiscussCommentVO2.getId().equals(parentId))
|
.collect(Collectors.toList());
|
if (!ObjectUtils.isEmpty(collect1)) {
|
ComActDiscussCommentVO comActDiscussCommentVOFirst = collect1.get(0);
|
String userName = comActDiscussCommentVOFirst.getUserName();
|
String userNickName = comActDiscussCommentVOFirst.getUserNickName();
|
comActDiscussCommentVO1.setUserNameBack(userName);
|
comActDiscussCommentVO1.setUserNickNameBack(userNickName);
|
}
|
if (pageComActDiscussCommentDTO.getLoginUserId() != null
|
&& !pageComActDiscussCommentDTO.getLoginUserId().equals(0L)) {
|
Integer integer = comActDiscussCommentUserDAO
|
.selectCount(new QueryWrapper<ComActDiscussCommentUserDO>().lambda()
|
.eq(ComActDiscussCommentUserDO::getDisscussCommentId,
|
comActDiscussCommentVO1.getId())
|
.eq(ComActDiscussCommentUserDO::getUserId,
|
pageComActDiscussCommentDTO.getLoginUserId()));
|
if (integer > 0) {
|
comActDiscussCommentVO1.setHaveSign(1);
|
} else {
|
comActDiscussCommentVO1.setHaveSign(0);
|
}
|
}
|
// if(StringUtils.isEmpty(comActDiscussCommentVO1.getUserNickNameBack())){
|
// comActDiscussCommentVO1.setUserNickNameBack("社区管理员");
|
// }
|
});
|
comActDiscussCommentVO.setComActDiscussCommentVOList(comActDiscussCommentVOList);
|
}
|
if (pageComActDiscussCommentDTO.getLoginUserId() != null
|
&& !pageComActDiscussCommentDTO.getLoginUserId().equals(0L)) {
|
Integer integer =
|
comActDiscussCommentUserDAO.selectCount(new QueryWrapper<ComActDiscussCommentUserDO>().lambda()
|
.eq(ComActDiscussCommentUserDO::getDisscussCommentId, comActDiscussCommentVO.getId())
|
.eq(ComActDiscussCommentUserDO::getUserId, pageComActDiscussCommentDTO.getLoginUserId()));
|
if (integer > 0) {
|
comActDiscussCommentVO.setHaveSign(1);
|
} else {
|
comActDiscussCommentVO.setHaveSign(0);
|
}
|
}
|
|
// 判断当前评论是否是社区管理员评论
|
if (!comActDiscussCommentVO.getUserType().equals(1)) {
|
comActDiscussCommentVO.setUserNickName("社区管理员");
|
}
|
});
|
}
|
return R.ok(iPage);
|
}
|
|
/**
|
* 议事投票-详情 小程序
|
*
|
* @param id
|
* 主键
|
* @param loginUserId
|
* 登录用户主键
|
* @return ComActDiscussVO
|
*/
|
@Override
|
public R detailDiscussApplets(Long id, Long loginUserId) {
|
ComActDiscussDO comActDiscussDO = comActDiscussDAO.selectById(id);
|
if (ObjectUtils.isEmpty(comActDiscussDO)) {
|
return R.fail("议事投票不存在");
|
}
|
ComActDiscussVO comActDiscussVO = new ComActDiscussVO();
|
BeanUtils.copyProperties(comActDiscussDO, comActDiscussVO);
|
Integer integer = comActDiscussCommentDAO.selectCount(
|
new QueryWrapper<ComActDiscussCommentDO>().lambda().eq(ComActDiscussCommentDO::getDiscussId, id));
|
comActDiscussVO.setCommentNum(integer);
|
Integer integer1 = comActDiscussUserDAO
|
.selectCount(new QueryWrapper<ComActDiscussUserDO>().lambda().eq(ComActDiscussUserDO::getDiscussId, id));
|
comActDiscussVO.setSignNum(integer1);
|
Integer type = comActDiscussVO.getType();
|
if (type.equals(2)) {
|
List<ComActDiscussOptionDO> comActDiscussOptionDOS = comActDiscussOptionDAO.selectList(
|
new QueryWrapper<ComActDiscussOptionDO>().lambda().eq(ComActDiscussOptionDO::getDiscussId, id));
|
List<ComActDiscussOptionVO> comActDiscussOptionVOS = new ArrayList<>();
|
comActDiscussOptionDOS.forEach(comActDiscussOptionDO -> {
|
Long discussOptionDOId = comActDiscussOptionDO.getId();
|
Integer selectCount =
|
comActDiscussOptionUserDAO.selectCount(new QueryWrapper<ComActDiscussOptionUserDO>().lambda()
|
.eq(ComActDiscussOptionUserDO::getDiscussOptionId, discussOptionDOId));
|
ComActDiscussOptionVO comActDiscussOptionVO = new ComActDiscussOptionVO();
|
BeanUtils.copyProperties(comActDiscussOptionDO, comActDiscussOptionVO);
|
comActDiscussOptionVO.setNum(selectCount);
|
if (loginUserId != null && !loginUserId.equals(0L)) {
|
// 判断选项是否已投票
|
int haveVote =
|
comActDiscussOptionUserDAO.selectHaveVotes(comActDiscussOptionDO.getId(), loginUserId);
|
comActDiscussOptionVO.setHaveVote(haveVote > 0 ? 1 : 0);
|
}
|
comActDiscussOptionVOS.add(comActDiscussOptionVO);
|
});
|
comActDiscussOptionVOS.sort(Comparator.comparing(ComActDiscussOptionVO::getNum).reversed());
|
comActDiscussVO.setComActDiscussOptionVOS(comActDiscussOptionVOS);
|
}
|
Long userId = comActDiscussDO.getUserId();
|
LoginUserInfoVO loginUserInfoVO = comActDiscussDAO.selectUserByUserId(userId);
|
if (loginUserInfoVO != null) {
|
comActDiscussVO.setUserName(loginUserInfoVO.getName());
|
if (StringUtils.isEmpty(loginUserInfoVO.getNickName())) {
|
comActDiscussVO.setUserNickName(loginUserInfoVO.getName());
|
} else {
|
comActDiscussVO.setUserNickName(loginUserInfoVO.getNickName());
|
}
|
comActDiscussVO.setImageUrl(loginUserInfoVO.getImageUrl());
|
comActDiscussVO.setUserType(loginUserInfoVO.getType());
|
}
|
Long communityId = comActDiscussDO.getCommunityId();
|
Integer type1 = loginUserInfoVO.getType();
|
if (type1.intValue() > 1) {
|
ComActVO comActVO = comActDiscussDAO.selectCommunity(communityId);
|
comActDiscussVO.setUserName(comActVO.getName());
|
comActDiscussVO.setUserNickName(comActVO.getName());
|
}
|
if (loginUserId != null && !loginUserId.equals(0L)) {
|
ComActDiscussVO comActDiscussVO1 = comActDiscussDAO.selectHaveSignAndHaveVote(id, loginUserId);
|
comActDiscussVO.setHaveSign(comActDiscussVO1.getHaveSign());
|
comActDiscussVO.setHaveVote(comActDiscussVO1.getHaveVote());
|
}
|
|
return R.ok(comActDiscussVO);
|
}
|
|
/**
|
* 议事投票-投票
|
*
|
* @param comActDiscussOptionUserDTO
|
* 投票信息
|
* @return 投票结果
|
*/
|
@Override
|
public R addDiscussOptionUser(ComActDiscussOptionUserDTO comActDiscussOptionUserDTO) {
|
Long discussOptionId = comActDiscussOptionUserDTO.getDiscussOptionId();
|
Long userId = comActDiscussOptionUserDTO.getUserId();
|
ComActDiscussOptionDO comActDiscussOptionDO = comActDiscussOptionDAO.selectById(discussOptionId);
|
if (ObjectUtils.isEmpty(comActDiscussOptionDO)) {
|
return R.fail("选项不存在");
|
}
|
// Long discussId = comActDiscussOptionDO.getDiscussId();
|
// List<ComActDiscussOptionDO> comActDiscussOptionDOS = comActDiscussOptionDAO.selectList(new
|
// QueryWrapper<ComActDiscussOptionDO>().lambda().eq(ComActDiscussOptionDO::getDiscussId, discussId));
|
// List<Long> longList=comActDiscussOptionDOS.stream().map(comActDiscussOptionDO1 ->
|
// comActDiscussOptionDO1.getId()).collect(Collectors.toList());
|
Integer integer = comActDiscussOptionUserDAO.selectCount(
|
new QueryWrapper<ComActDiscussOptionUserDO>().lambda().eq(ComActDiscussOptionUserDO::getUserId, userId)
|
.eq(ComActDiscussOptionUserDO::getDiscussOptionId, discussOptionId));
|
if (integer > 0) {
|
return R.fail("不要重复投票");
|
}
|
ComActDiscussOptionUserDO comActDiscussOptionUserDO = new ComActDiscussOptionUserDO();
|
comActDiscussOptionUserDO.setUserId(userId);
|
comActDiscussOptionUserDO.setDiscussOptionId(discussOptionId);
|
int insert = comActDiscussOptionUserDAO.insert(comActDiscussOptionUserDO);
|
if (insert > 0) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 议事投票-评论-点赞、取消点赞
|
*
|
* @param comActDiscussCommentUserDTO
|
* 评论点赞
|
* @return 点赞结果
|
*/
|
@Override
|
public R putDiscussCommentUser(ComActDiscussCommentUserDTO comActDiscussCommentUserDTO) {
|
ComActDiscussCommentDO comActDiscussCommentDO =
|
comActDiscussCommentDAO.selectById(comActDiscussCommentUserDTO.getId());
|
if (ObjectUtils.isEmpty(comActDiscussCommentDO)) {
|
return R.fail("评论不存在");
|
}
|
Integer type = comActDiscussCommentUserDTO.getType();
|
int num = 0;
|
if (type.intValue() == 1) {
|
ComActDiscussCommentUserDO comActDiscussCommentUserDO = new ComActDiscussCommentUserDO();
|
comActDiscussCommentUserDO.setUserId(comActDiscussCommentUserDTO.getUserId());
|
comActDiscussCommentUserDO.setDisscussCommentId(comActDiscussCommentUserDTO.getId());
|
num = comActDiscussCommentUserDAO.insert(comActDiscussCommentUserDO);
|
} else {
|
num = comActDiscussCommentUserDAO.delete(new QueryWrapper<ComActDiscussCommentUserDO>().lambda()
|
.eq(ComActDiscussCommentUserDO::getUserId, comActDiscussCommentUserDTO.getUserId())
|
.eq(ComActDiscussCommentUserDO::getDisscussCommentId, comActDiscussCommentUserDTO.getId()));
|
}
|
if (num > 0) {
|
return R.ok();
|
}
|
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);
|
}
|
}
|
