package com.panzhihua.service_community.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.community.ComActActivityVO;
|
import com.panzhihua.common.model.vos.community.ComActDynVO;
|
import com.panzhihua.service_community.dao.ComActDAO;
|
import com.panzhihua.service_community.dao.ComActDynDAO;
|
import com.panzhihua.service_community.dao.ComActDynUserDAO;
|
import com.panzhihua.service_community.model.dos.ComActDO;
|
import com.panzhihua.service_community.model.dos.ComActDynDO;
|
import com.panzhihua.service_community.model.dos.ComActDynUserDO;
|
import com.panzhihua.service_community.service.ComActDynService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.ObjectUtils;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
|
/**
|
* @program: springcloud_k8s_panzhihuazhihuishequ
|
* @description: 社区动态
|
* @author: huang.hongfa weixin hhf9596 qq 959656820
|
* @create: 2020-12-07 14:29
|
**/
|
@Slf4j
|
@Service
|
public class ComActDynServiceImpl extends ServiceImpl<ComActDynDAO, ComActDynDO> implements ComActDynService {
|
@Resource
|
private ComActDynDAO comActDynDAO;
|
@Resource
|
private ComActDynUserDAO comActDynUserDAO;
|
@Resource
|
private ComActDAO comActDAO;
|
|
|
/**
|
* 分页查询社区动态
|
*
|
* @param comActDynVO 查询参数
|
* @return 动态集合
|
*/
|
@Override
|
public R pageDynamic(ComActDynVO comActDynVO) {
|
Page page = new Page<>();
|
Long pageNum = comActDynVO.getPageNum();
|
Long pageSize = comActDynVO.getPageSize();
|
if (null==pageNum||0==pageNum) {
|
pageNum = 1l;
|
}
|
if (null==pageSize||0==pageSize) {
|
pageSize = 10l;
|
}
|
page.setSize(pageSize);
|
page.setCurrent(pageNum);
|
IPage<ComActDynVO> iPage = comActDynDAO.pageDynamic(page, comActDynVO);
|
return R.ok(iPage);
|
}
|
|
/**
|
* 社区动态详情
|
*
|
* @param id 动态id
|
* @return 详情
|
*/
|
@Override
|
public R detailDynamic(Long id) {
|
ComActDynDO comActDynDO = this.getById(id);
|
if (ObjectUtils.isEmpty(comActDynDO)) {
|
return R.fail("社区动态不存在");
|
}
|
ComActDO comActDO = comActDAO.selectById(comActDynDO.getCommunityId());
|
Integer count = comActDynUserDAO.selectCount(new QueryWrapper<ComActDynUserDO>().lambda().eq(ComActDynUserDO::getDynId, id));
|
ComActDynVO comActDynVO=new ComActDynVO();
|
BeanUtils.copyProperties(comActDynDO,comActDynVO);
|
comActDynVO.setReadNum(count);
|
comActDynVO.setCommunityName(comActDO.getName());
|
return R.ok(comActDynVO);
|
}
|
|
/**
|
* 新增社区动态浏览记录
|
*
|
* @param id 动态主键
|
* @param userId 登录用户id
|
* @return 新增结果
|
*/
|
@Override
|
public R addDynamicUser(Long id, Long userId) {
|
ComActDynUserDO comActDynUserDO = comActDynUserDAO.selectOne(new QueryWrapper<ComActDynUserDO>().lambda().eq(ComActDynUserDO::getDynId, id).eq(ComActDynUserDO::getUserId, userId));
|
if (ObjectUtils.isEmpty(comActDynUserDO)) {
|
comActDynUserDO=new ComActDynUserDO();
|
comActDynUserDO.setCreateAt(new Date());
|
comActDynUserDO.setDynId(id);
|
comActDynUserDO.setUserId(userId);
|
int insert = comActDynUserDAO.insert(comActDynUserDO);
|
if (insert>0) {
|
return R.ok();
|
}
|
return R.fail();
|
}else{
|
return R.ok();
|
}
|
|
}
|
|
/**
|
* 定时任务刷新社区动态置顶状态
|
*
|
* @return 刷新结果
|
*/
|
@Override
|
public R timedTaskDynIstopping() {
|
int num=comActDynUserDAO.timedTaskDynIstopping();
|
if (num>0) {
|
log.info("一共维护社区动态数量【{}】",num);
|
}
|
return R.ok();
|
}
|
}
|
