package com.panzhihua.service_community.api;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.community.*;
|
import com.panzhihua.service_community.model.dos.ComActActPrizeDO;
|
import com.panzhihua.service_community.model.dos.ComActDynDO;
|
import com.panzhihua.service_community.model.dos.ComActMicroWishDO;
|
import com.panzhihua.service_community.service.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.data.domain.Page;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @program: springcloud_k8s_panzhihuazhihuishequ
|
* @description: 社区活动
|
* @author: huang.hongfa weixin hhf9596 qq 959656820
|
* @create: 2020-12-07 16:02
|
**/
|
@Slf4j
|
@RestController
|
@RequestMapping("/")
|
public class CommunityApi {
|
@Resource
|
private ComActActivityService comActActivityService;
|
@Resource
|
private ComActActPrizeService comActActPrizeService;
|
@Resource
|
private ComActDynService comActDynService;
|
@Resource
|
private ComActMicroWishService comActMicroWishService;
|
@Resource
|
private ComActEasyPhotoService comActEasyPhotoService;
|
|
/**
|
* 新增社区活动
|
*
|
* @param comActActivityVO 新增信息
|
* @return 新增结果
|
*/
|
@PostMapping("addactivity")
|
@Transactional(rollbackFor = Exception.class)
|
public R addActivity(@RequestBody ComActActivityVO comActActivityVO) {
|
R r = comActActivityService.addActivity(comActActivityVO);
|
boolean ok = r.isOk();
|
if (ok) {
|
Long activityId = (Long) r.getData();
|
Integer hasPrize = comActActivityVO.getHasPrize();
|
if (hasPrize.intValue() > 0) {
|
List<ComActActPrizeVO> comActActPrizeVOList = comActActivityVO.getComActActPrizeVOList();
|
if (!ObjectUtils.isEmpty(comActActPrizeVOList)) {
|
List<ComActActPrizeDO> comActActPrizeDOS = new ArrayList<>();
|
comActActPrizeVOList.forEach(comActActPrizeVO -> {
|
ComActActPrizeDO comActActPrizeDO = new ComActActPrizeDO();
|
BeanUtils.copyProperties(comActActPrizeVO, comActActPrizeDO);
|
comActActPrizeDO.setActivityId(activityId);
|
comActActPrizeDOS.add(comActActPrizeDO);
|
});
|
boolean saveBatch = comActActPrizeService.saveBatch(comActActPrizeDOS);
|
if (!saveBatch) {
|
return R.fail("保存奖品失败");
|
}
|
}
|
|
}
|
}
|
return R.fail();
|
}
|
|
/**
|
* 编辑社区活动
|
*
|
* @param comActActivityVO 编辑内容
|
* @return 编辑结果
|
*/
|
@PostMapping("putactivity")
|
@Transactional(rollbackFor = Exception.class)
|
public R putActivity(@RequestBody ComActActivityVO comActActivityVO) {
|
R r = comActActivityService.putActivity(comActActivityVO);
|
List<ComActActPrizeVO> comActActPrizeVOList = comActActivityVO.getComActActPrizeVOList();
|
boolean ok = r.isOk();
|
if (ok) {
|
if (!ObjectUtils.isEmpty(comActActPrizeVOList)) {
|
Long actActivityVOId = comActActivityVO.getId();
|
comActActPrizeService.remove(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, actActivityVOId));
|
if (!ObjectUtils.isEmpty(comActActPrizeVOList)) {
|
List<ComActActPrizeDO> comActActPrizeDOS = new ArrayList<>();
|
comActActPrizeVOList.forEach(comActActPrizeVO -> {
|
ComActActPrizeDO comActActPrizeDO = new ComActActPrizeDO();
|
BeanUtils.copyProperties(comActActPrizeVO, comActActPrizeDO);
|
comActActPrizeDO.setActivityId(actActivityVOId);
|
comActActPrizeDOS.add(comActActPrizeDO);
|
});
|
boolean saveBatch = comActActPrizeService.saveBatch(comActActPrizeDOS);
|
if (!saveBatch) {
|
return R.fail("保存奖品失败");
|
}
|
}
|
}
|
}
|
return r;
|
}
|
|
/**
|
* 删除社区活动
|
*
|
* @param comActActivityVO 活动主键
|
* @return 删除结果
|
*/
|
@PostMapping("deleteactivity")
|
public R deleteActivity(@RequestBody ComActActivityVO comActActivityVO) {
|
boolean remove = comActActivityService.removeById(comActActivityVO.getId());
|
if (remove) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 分页查询社区活动
|
*
|
* @param comActActivityVO 查询参数
|
* @return 分页集合
|
*/
|
@PostMapping("pageActivity")
|
public R pageActivity(@RequestBody ComActActivityVO comActActivityVO) {
|
R r = comActActivityService.pageActivity(comActActivityVO);
|
if (r.isOk()) {
|
Page<ComActActivityVO> page = (Page<ComActActivityVO>)r.getData();
|
List<ComActActivityVO> content = page.getContent();
|
if (!ObjectUtils.isEmpty(content)) {
|
List<ComActActPrizeVO> comActActPrizeVOList=new ArrayList<>();
|
content.forEach(comActActivityVO1 -> {
|
Long id = comActActivityVO1.getId();
|
List<ComActActPrizeDO> list = comActActPrizeService.list(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, id));
|
if (!ObjectUtils.isEmpty(list)) {
|
list.forEach(comActActPrizeDO -> {
|
ComActActPrizeVO comActActPrizeVO=new ComActActPrizeVO();
|
BeanUtils.copyProperties(comActActPrizeDO,comActActPrizeVO);
|
comActActPrizeVOList.add(comActActPrizeVO);
|
});
|
}
|
comActActivityVO1.setComActActPrizeVOList(comActActPrizeVOList);
|
comActActPrizeVOList.clear();
|
});
|
}
|
|
}
|
return r;
|
}
|
|
/**
|
* 发布活动
|
* @param comActActivityVO 主键id 发布时间
|
* @return 发布结果
|
*/
|
@PostMapping("releaseactivity")
|
public R releaseActivity(@RequestBody ComActActivityVO comActActivityVO){
|
return comActActivityService.releaseActivity(comActActivityVO);
|
}
|
|
/**
|
* 取消活动
|
* @param comActActivityVO 取消原因
|
* @return 取消结果
|
*/
|
@PostMapping("cancelactivity")
|
public R cancelActivity(@RequestBody ComActActivityVO comActActivityVO){
|
return comActActivityService.cancelActivity(comActActivityVO);
|
}
|
|
/**
|
* 活动详情
|
* @param id 活动id
|
* @return 详情
|
*/
|
@PostMapping("detailactivity")
|
public R detailActivity(@RequestParam("id") Long id,@RequestParam("userId")Long userId){
|
ComActActivityVO comActActivityVO = comActActivityService.inforActivity(id,userId);
|
if (ObjectUtils.isEmpty(comActActivityVO)) {
|
return R.fail("活动不存在");
|
}
|
List<ComActActPrizeDO> comActActPrizeDOS = comActActPrizeService.list(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, id));
|
if (!ObjectUtils.isEmpty(comActActPrizeDOS)) {
|
List<ComActActPrizeVO> comActActPrizeVOS=new ArrayList<>();
|
comActActPrizeDOS.forEach(comActActPrizeDO -> {
|
ComActActPrizeVO comActActPrizeVO=new ComActActPrizeVO();
|
BeanUtils.copyProperties(comActActPrizeDO,comActActPrizeVO);
|
comActActPrizeVOS.add(comActActPrizeVO);
|
});
|
comActActivityVO.setComActActPrizeVOList(comActActPrizeVOS);
|
}
|
ActivitySignVO activitySignVO=new ActivitySignVO();
|
activitySignVO.setActivityId(id);
|
R r = comActActivityService.listActivitySign(activitySignVO);
|
if (r.isOk()) {
|
List<ActivitySignVO> activitySignVOS=(List<ActivitySignVO>)r.getData();
|
comActActivityVO.setActivitySignVOList(activitySignVOS);
|
}
|
return R.ok(comActActivityVO);
|
}
|
|
/**
|
* 活动报名名单
|
* @param activitySignVO 查询参数
|
* @return 报名人员集合
|
*/
|
@PostMapping("listactivitysign")
|
public R listActivitySign(@RequestBody ActivitySignVO activitySignVO){
|
return comActActivityService.listActivitySign(activitySignVO);
|
}
|
|
/**
|
* 新增社区动态
|
* @param comActDynVO 新增信息
|
* @return 新增结果
|
*/
|
@PostMapping("adddynamic")
|
public R addDynamic(@RequestBody ComActDynVO comActDynVO){
|
ComActDynDO comActDynDO=new ComActDynDO();
|
BeanUtils.copyProperties(comActDynVO,comActDynDO);
|
boolean save = comActDynService.save(comActDynDO);
|
if (save) {
|
// 最多只能设置三条置顶状态，后边设置会取消先前设置的置顶
|
Integer isTopping = comActDynVO.getIsTopping();
|
boolean b = isTopping.intValue() == 1;
|
if (b) {
|
List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda().eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId,comActDynVO.getCommunityId()));
|
if (!ObjectUtils.isEmpty(list)) {
|
int size = list.size();
|
if (size==4) {
|
List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)).collect(Collectors.toList());
|
ComActDynDO comActDynDO1 = collect.get(0);
|
comActDynDO1.setIsTopping(0);
|
boolean update = comActDynService.updateById(comActDynDO1);
|
if (!update) {
|
return R.fail("修改置顶状态失败");
|
}
|
}
|
}
|
}
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 编辑社区动态
|
* @param comActDynVO 编辑内容
|
* @return 编辑结果
|
*/
|
@PostMapping("putdynamic")
|
public R putDynamic(@RequestBody ComActDynVO comActDynVO){
|
ComActDynDO comActDynDO=new ComActDynDO();
|
BeanUtils.copyProperties(comActDynVO,comActDynDO);
|
boolean update = comActDynService.updateById(comActDynDO);
|
if (update) {
|
// 最多只能设置三条置顶状态，后边设置会取消先前设置的置顶
|
Integer isTopping = comActDynVO.getIsTopping();
|
boolean b = isTopping.intValue() == 1;
|
if (b) {
|
List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda().eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId,comActDynVO.getCommunityId()));
|
if (!ObjectUtils.isEmpty(list)) {
|
int size = list.size();
|
if (size==4) {
|
List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)).collect(Collectors.toList());
|
ComActDynDO comActDynDO1 = collect.get(0);
|
comActDynDO1.setIsTopping(0);
|
boolean updateById = comActDynService.updateById(comActDynDO1);
|
if (!updateById) {
|
return R.fail("修改置顶状态失败");
|
}
|
}
|
}
|
}
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 删除社区动态
|
* @param comActDynVO 动态id
|
* @return 删除结果
|
*/
|
@PostMapping("deletedynamic")
|
public R deleteDynamic(@RequestBody ComActDynVO comActDynVO){
|
boolean b = comActDynService.removeById(comActDynVO.getId());
|
if (b) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 分页查询社区动态
|
* @param comActDynVO 查询参数
|
* @return 动态集合
|
*/
|
@PostMapping("pagedynamic")
|
public R pageDynamic(@RequestBody ComActDynVO comActDynVO){
|
return comActDynService.pageDynamic(comActDynVO);
|
}
|
|
/**
|
* 社区动态详情
|
* @param id 动态id
|
* @return 详情
|
*/
|
@PostMapping("detaildynamic")
|
public R detailDynamic(@RequestParam("id") Long id){
|
return comActDynService.detailDynamic(id);
|
}
|
|
|
/**
|
* 分页查询随手拍
|
* @param comActEasyPhotoVO 查询参数
|
* @return 心愿列表
|
*/
|
@PostMapping("pageeasyphoto")
|
public R pageEasyPhoto(@RequestBody ComActEasyPhotoVO comActEasyPhotoVO){
|
return comActEasyPhotoService.pageEasyPhoto(comActEasyPhotoVO);
|
}
|
|
/**
|
* 随手拍详情
|
* @param id 随手拍主键
|
* @param userId 登录用户
|
* @return 详情内容
|
*/
|
@PostMapping("detaileasyphoto")
|
public R detailEasyPhoto(@RequestParam("id")Long id,@RequestParam("userId")Long userId){
|
return comActEasyPhotoService.detailEasyPhoto(id,userId);
|
}
|
|
/**
|
* 分页查询微心愿
|
* @param comActMicroWishVO 查询参数
|
* @return 分页集合
|
*/
|
@PostMapping("pagemicrowish")
|
public R pageMicroWish(@RequestBody ComActMicroWishVO comActMicroWishVO){
|
return comActMicroWishService.pageMicroWish(comActMicroWishVO);
|
}
|
|
/**
|
* 心愿详情
|
* @param id 查询主键
|
* @param userId 登录用户id
|
* @return 心愿内容
|
*/
|
@PostMapping("detailmicrowish")
|
public R detailMicroWish(@RequestParam("id")Long id,@RequestParam("userId")Long userId){
|
return comActMicroWishService.detailMicroWish(id,userId);
|
}
|
|
/**
|
* 审核、分配、反馈心愿
|
* @param comActMicroWishVO 具体操作
|
* @return 操作结果
|
*/
|
@PostMapping("putlmicrowish")
|
public R putlMicroWish(@RequestBody ComActMicroWishVO comActMicroWishVO){
|
return comActMicroWishService.putlMicroWish(comActMicroWishVO);
|
}
|
|
/**
|
* 分页展示我的所有活动 时间倒序排列
|
* @param comActActivityVO 分页参数
|
* @return 分页集合
|
*/
|
@PostMapping("pagemyactivity")
|
public R pageMyActivity(@RequestBody ComActActivityVO comActActivityVO){
|
return comActActivityService.pageMyActivity(comActActivityVO);
|
}
|
|
/**
|
* 报名/取消报名社区活动
|
* @param signactivityVO 报名参数
|
* @return 报名 取消报名 结果
|
*/
|
@PostMapping("signactivity")
|
public R signActivity(@RequestBody SignactivityVO signactivityVO){
|
return comActActivityService.signActivity(signactivityVO);
|
}
|
|
/**
|
* 上传随手拍
|
* @param comActEasyPhotoVO 上传数据
|
* @return 上传结果
|
*/
|
@PostMapping("addeasyphoto")
|
public R addEasyPhoto(@RequestBody ComActEasyPhotoVO comActEasyPhotoVO){
|
return comActEasyPhotoService.addEasyPhoto(comActEasyPhotoVO);
|
}
|
|
/**
|
* 发布微心愿
|
* @param comActMicroWishVO 发布内容
|
* @return 发布结果
|
*/
|
@PostMapping("addmicrowish")
|
public R addMicroWish(@RequestBody ComActMicroWishVO comActMicroWishVO){
|
ComActMicroWishDO comActMicroWishDO=new ComActMicroWishDO();
|
BeanUtils.copyProperties(comActMicroWishVO,comActMicroWishDO);
|
boolean save = comActMicroWishService.save(comActMicroWishDO);
|
if (save) {
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 点赞/取消点赞随手拍
|
* @param comActEasyPhotoVO 操作参数
|
* @return 操作结果
|
*/
|
@PostMapping("puteasyphoto")
|
public R putEasyPhoto(@RequestBody ComActEasyPhotoVO comActEasyPhotoVO){
|
return comActEasyPhotoService.putEasyPhoto(comActEasyPhotoVO);
|
}
|
|
/**
|
* 点赞/取消点赞微心愿
|
* @param comActMicroWishVO 操作参数
|
* @return 操作结果
|
*/
|
@PostMapping("putmicrowish")
|
R putMicroWish(@RequestBody ComActMicroWishVO comActMicroWishVO){
|
return comActMicroWishService.comActMicroWishVO(comActMicroWishVO);
|
}
|
|
}
|
