| | |
| | | package com.panzhihua.service_community.api; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | 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.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.*; |
| | |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R addActivity(@RequestBody ComActActivityVO comActActivityVO) { |
| | | R r = comActActivityService.addActivity(comActActivityVO); |
| | | boolean ok = r.isOk(); |
| | | boolean ok = R.isOk(r); |
| | | if (ok) { |
| | | Long activityId = (Long) r.getData(); |
| | | Integer hasPrize = comActActivityVO.getHasPrize(); |
| | |
| | | } |
| | | |
| | | } |
| | | }else { |
| | | return R.fail(); |
| | | } |
| | | return R.fail(); |
| | | return R.ok(); |
| | | } |
| | | |
| | | /** |
| | |
| | | public R putActivity(@RequestBody ComActActivityVO comActActivityVO) { |
| | | R r = comActActivityService.putActivity(comActActivityVO); |
| | | List<ComActActPrizeVO> comActActPrizeVOList = comActActivityVO.getComActActPrizeVOList(); |
| | | boolean ok = r.isOk(); |
| | | boolean ok = R.isOk(r); |
| | | if (ok) { |
| | | if (!ObjectUtils.isEmpty(comActActPrizeVOList)) { |
| | | Integer hasPrize = comActActivityVO.getHasPrize(); |
| | | if (!ObjectUtils.isEmpty(comActActPrizeVOList)&&hasPrize.intValue()==1) { |
| | | Long actActivityVOId = comActActivityVO.getId(); |
| | | comActActPrizeService.remove(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, actActivityVOId)); |
| | | if (!ObjectUtils.isEmpty(comActActPrizeVOList)) { |
| | |
| | | public R deleteActivity(@RequestBody ComActActivityVO comActActivityVO) { |
| | | boolean remove = comActActivityService.removeById(comActActivityVO.getId()); |
| | | if (remove) { |
| | | comActActPrizeService.remove(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId,comActActivityVO.getId())); |
| | | return R.ok(); |
| | | } |
| | | return R.fail(); |
| | |
| | | * @param comActActivityVO 查询参数 |
| | | * @return 分页集合 |
| | | */ |
| | | @PostMapping("pageActivity") |
| | | @PostMapping("pageactivity") |
| | | public R pageActivity(@RequestBody ComActActivityVO comActActivityVO) { |
| | | R r = comActActivityService.pageActivity(comActActivityVO); |
| | | if (r.isOk()) { |
| | | if (R.isOk(r)) { |
| | | Page<ComActActivityVO> page = (Page<ComActActivityVO>)r.getData(); |
| | | List<ComActActivityVO> content = page.getContent(); |
| | | List<ComActActivityVO> content = page.getRecords(); |
| | | if (!ObjectUtils.isEmpty(content)) { |
| | | List<ComActActPrizeVO> comActActPrizeVOList=new ArrayList<>(); |
| | | content.forEach(comActActivityVO1 -> { |
| | |
| | | ActivitySignVO activitySignVO=new ActivitySignVO(); |
| | | activitySignVO.setActivityId(id); |
| | | R r = comActActivityService.listActivitySign(activitySignVO); |
| | | if (r.isOk()) { |
| | | if (R.isOk(r)) { |
| | | List<ActivitySignVO> activitySignVOS=(List<ActivitySignVO>)r.getData(); |
| | | comActActivityVO.setActivitySignVOList(activitySignVOS); |
| | | } |
| | |
| | | if (!ObjectUtils.isEmpty(list)) { |
| | | int size = list.size(); |
| | | if (size==4) { |
| | | List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)).collect(Collectors.toList()); |
| | | List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getUpdateAt)).collect(Collectors.toList()); |
| | | ComActDynDO comActDynDO1 = collect.get(0); |
| | | comActDynDO1.setIsTopping(0); |
| | | boolean updateById = comActDynService.updateById(comActDynDO1); |