微心愿详情bug

huanghongfa

2021-01-15 ada9d2e3f734582a0d9ae8c00a936d8c8ed669d7

 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java

New file
@@ -0,0 +1,407 @@
package com.panzhihua.service_dangjian.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.panzhihua.common.model.dtos.partybuilding.ActivitySignUpDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActActivityVO;
import com.panzhihua.common.model.vos.partybuilding.PageActivityMembersVO;
import com.panzhihua.common.model.vos.partybuilding.PartyBuildingActivityVO;
import com.panzhihua.common.model.vos.partybuilding.PartyBuildingMemberVO;
import com.panzhihua.service_dangjian.dao.ComBpActivityDAO;
import com.panzhihua.service_dangjian.dao.ComPbActivityMemberDAO;
import com.panzhihua.service_dangjian.dao.ComPbMemberDAO;
import com.panzhihua.service_dangjian.model.dos.ComPbActivityDO;
import com.panzhihua.service_dangjian.model.dos.ComPbActivityMemberDO;
import com.panzhihua.service_dangjian.model.dos.ComPbMemberDO;
import com.panzhihua.service_dangjian.service.ComBpActivityService;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.client.utils.DateUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import javax.annotation.Resource;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
 * @description: 党员活动
 * @author: huang.hongfa weixin hhf9596 qq 959656820
 * @create: 2020-12-01 09:16
 **/
@Slf4j
@Service
public class ComBpActivityServiceImpl implements ComBpActivityService {
    @Resource
    private ComBpActivityDAO comBpActivityDAO;
    @Resource
    private ComPbActivityMemberDAO comPbActivityMemberDAO;
    @Resource
    private ComPbMemberDAO comPbMemberDAO;

    /**
     * 查询某个党员加入的所有党员活动
     *
     * @param partyBuildingActivityVO 查询参数
     * @return 活动集合
     */
    @Override
    public R listPartyMemberActivities(PartyBuildingActivityVO partyBuildingActivityVO) {
        List<PartyBuildingActivityVO> partyBuildingActivityVOS = comBpActivityDAO.listPartyMemberActivities(partyBuildingActivityVO);
        return R.ok(partyBuildingActivityVOS);
    }

    /**
     * 活动报名名单分页查询
     *
     * @param pageActivityMembersVO 查询参数 手机号 名字
     * @return 分页数据
     */
    @Override
    public R pageActivityMembers(PageActivityMembersVO pageActivityMembersVO) {
        Page page = new Page<>();
        Long pageNum = pageActivityMembersVO.getPageNum();
        Long pageSize = pageActivityMembersVO.getPageSize();
        Long activityId = pageActivityMembersVO.getActivityId();
        if (null == pageNum) {
            pageNum = 1l;
        }
        if (null == pageSize) {
            pageSize = 10l;
        }
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        IPage<PageActivityMembersVO> iPage = comPbActivityMemberDAO.pageActivityMembers(page, pageActivityMembersVO);
        Map<String,Object> map=new HashMap<>(3);
        ComPbActivityDO comPbActivityDO = comBpActivityDAO.selectById(activityId);
        map.put("page",iPage);
        map.put("name",comPbActivityDO.getName());
        map.put("createAt",DateUtils.formatDate(comPbActivityDO.getCreateAt(),"yyyy-MM-dd HH:mm:ss"));
        return R.ok(map);
    }

    /**
     * 党员活动详情
     *
     * @param id 活动id
     * @return 活动详情内容
     */
    @Override
    public R activityinfo(Long id,Long userId) {
        ComPbActivityDO comPbActivityDO = comBpActivityDAO.selectById(id);
        if (ObjectUtils.isEmpty(comPbActivityDO)) {
            return R.fail("活动不存在");
        }
        PartyBuildingActivityVO partyBuildingActivityVO = new PartyBuildingActivityVO();
        BeanUtils.copyProperties(comPbActivityDO, partyBuildingActivityVO);
        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getActivityId, id).orderByDesc(ComPbActivityMemberDO::getCreateAt));
        List<PartyBuildingMemberVO> partyBuildingMemberVOS = new ArrayList<>();
        if (!ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
            List<Long> collect = comPbActivityMemberDOS.stream().map(ComPbActivityMemberDO::getMemberId).collect(Collectors.toList());
            int size = collect.size();
            if (size>=6) {
                collect=collect.subList(0,6);
            }
            List<ComPbMemberDO> comPbMemberDOS = comPbMemberDAO.selectList(new QueryWrapper<ComPbMemberDO>().lambda().in(ComPbMemberDO::getId, collect));
            comPbMemberDOS.forEach(comPbMemberDO -> {
                PartyBuildingMemberVO partyBuildingMemberVO = new PartyBuildingMemberVO();
                BeanUtils.copyProperties(comPbMemberDO, partyBuildingMemberVO);
                partyBuildingMemberVOS.add(partyBuildingMemberVO);
            });
            partyBuildingActivityVO.setParticipationActualNum(size);
        } else {
            partyBuildingActivityVO.setParticipationActualNum(0);
        }
        ComPbActivityMemberDO comPbActivityMemberDO=comPbActivityMemberDAO.selectByUserIdActivityId(id,userId);
        if (ObjectUtils.isEmpty(comPbActivityMemberDO)) {
            partyBuildingActivityVO.setIsSign(0);
        } else {
            partyBuildingActivityVO.setIsSign(1);
        }
        partyBuildingActivityVO.setPartyBuildingMemberVOS(partyBuildingMemberVOS);
        return R.ok(partyBuildingActivityVO);
    }

    /**
     * 新增党员活动
     *
     * @param partyBuildingActivityVO 参数
     * @return 新增结果
     */
    @Override
    public R addactivity(PartyBuildingActivityVO partyBuildingActivityVO) {
        ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
        BeanUtils.copyProperties(partyBuildingActivityVO, comPbActivityDO);
        comPbActivityDO.setCreateAt(new Date());
        int insert = comBpActivityDAO.insert(comPbActivityDO);
        if (insert > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 编辑党员活动
     *
     * @param partyBuildingActivityVO 编辑内容
     * @return 编辑结果
     */
    @Override
    public R updateActivity(PartyBuildingActivityVO partyBuildingActivityVO) {
        ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
        BeanUtils.copyProperties(partyBuildingActivityVO, comPbActivityDO);
        int update = comBpActivityDAO.updateById(comPbActivityDO);
        if (update > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 发布党员活动
     *
     * @param id 主键id
     * @return 发布结果
     */
    @Override
    public R releaseActivity(Long id) {
        ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
        comPbActivityDO.setId(id);
        comPbActivityDO.setStatus(2);
        comPbActivityDO.setReleaseTime(new Date());
        int update = comBpActivityDAO.updateById(comPbActivityDO);
        if (update > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 删除党员活动
     *
     * @param id 主键id
     * @return 删除结果
     */
    @Override
    public R deleteActivity(Long id) {
        int delete = comBpActivityDAO.deleteById(id);
        if (delete > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 分页查询党员活动
     *
     * @param partyBuildingActivityVO 查询条件
     * @return 查询结果
     */
    @Override
    public R pageActivity(PartyBuildingActivityVO partyBuildingActivityVO) {
        Page page = new Page<>();
        Long pageNum = partyBuildingActivityVO.getPageNum();
        Long pageSize = partyBuildingActivityVO.getPageSize();
        if (null == pageNum) {
            pageNum = 1l;
        }
        if (null == pageSize) {
            pageSize = 10l;
        }
        page.setSize(pageSize);
        page.setCurrent(pageNum);
        IPage<PartyBuildingActivityVO> iPage = comBpActivityDAO.pageActivity(page, partyBuildingActivityVO);
        List<PartyBuildingActivityVO> records = iPage.getRecords();
        if (!ObjectUtils.isEmpty(records)) {
            DateFormat formatTo = new SimpleDateFormat("M月d ahh:mm");
            records.forEach(partyBuildingActivityVO1 -> {
                Date activityTimeBegin = partyBuildingActivityVO1.getActivityTimeBegin();
                if (!ObjectUtils.isEmpty(activityTimeBegin)) {
                    partyBuildingActivityVO1.setActivityTimeBeginFormat(formatTo.format(activityTimeBegin));
                }
            });
        }
        return R.ok(iPage);
    }

    /**
     * 取消活动
     *
     * @param partyBuildingActivityVO 取消原因
     * @return 操作结果
     */
    @Override
    public R cancelActivity(PartyBuildingActivityVO partyBuildingActivityVO) {
        ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
        comPbActivityDO.setId(partyBuildingActivityVO.getId());
        comPbActivityDO.setCancelReason(partyBuildingActivityVO.getCancelReason());
        comPbActivityDO.setStatus(6);
        int update = comBpActivityDAO.updateById(comPbActivityDO);
        if (update > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 用户的所有党建活动
     *
     * @param userId 用户id
     * @return 党建活动列表
     */
    @Override
    public R listActivity(Long userId) {
        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getMemberId, userId));
        if (ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
            return R.fail();
        }
        List<Long> collect = comPbActivityMemberDOS.stream().map(comPbActivityMemberDO -> comPbActivityMemberDO.getActivityId()).collect(Collectors.toList());
        List<ComPbActivityDO> comPbActivityDOS = comBpActivityDAO.selectBatchIds(collect);
        List<ComActActivityVO> comActActivityVOS = new ArrayList<>();
        comPbActivityDOS.forEach(comPbActivityDO -> {
            ComActActivityVO comActActivityVO = new ComActActivityVO();
            comActActivityVO.setType(3);
            comActActivityVO.setId(comPbActivityDO.getId());
            comActActivityVO.setStatus(comPbActivityDO.getStatus());
            comActActivityVO.setActivityName(comPbActivityDO.getName());
            comActActivityVO.setCover(comPbActivityDO.getCover());
            comActActivityVO.setBeginAt(comPbActivityDO.getActivityTimeBegin());
            comActActivityVOS.add(comActActivityVO);
        });
        return R.ok(comActActivityVOS);
    }

    /**
     * 党员活动人员参入列表
     *
     * @param id 活动id
     * @return 党员集合
     */
    @Override
    public R listPartyBuildingMember(Long id) {
        List<PartyBuildingMemberVO> partyBuildingMemberVOS = new ArrayList<>();
        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getActivityId, id).orderByDesc(ComPbActivityMemberDO::getCreateAt));
        if (!ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
            List<Long> collect = comPbActivityMemberDOS.stream().map(ComPbActivityMemberDO::getMemberId).collect(Collectors.toList());
            List<ComPbMemberDO> comPbMemberDOS = comPbMemberDAO.selectList(new QueryWrapper<ComPbMemberDO>().lambda().in(ComPbMemberDO::getId, collect));
            comPbMemberDOS.forEach(comPbMemberDO -> {
                PartyBuildingMemberVO partyBuildingMemberVO = new PartyBuildingMemberVO();
                BeanUtils.copyProperties(comPbMemberDO, partyBuildingMemberVO);
                partyBuildingMemberVOS.add(partyBuildingMemberVO);
            });
        }
        return R.ok(partyBuildingMemberVOS);
    }

    /**
     * 报名、取消报名党员活动
     *
     * @param activitySignUpDTO 操作参数
     * @return 操作结果
     */
    @Override
    public R putActivitySignUp(ActivitySignUpDTO activitySignUpDTO) {
        Long id=activitySignUpDTO.getId();
        Long userId=activitySignUpDTO.getUserId();
        ComPbActivityDO comPbActivityDO = comBpActivityDAO.selectById(id);
        if (ObjectUtils.isEmpty(comPbActivityDO)) {
            return R.fail("活动不存在");
        }
        ComPbMemberDO comPbMemberDO=comPbMemberDAO.selectByUserId(userId);
        if (ObjectUtils.isEmpty(comPbMemberDO)) {
            return R.fail("您不是党员");
        }
        Integer type=activitySignUpDTO.getType();
        ComPbActivityMemberDO comPbActivityMemberDO = comPbActivityMemberDAO.selectOne(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getMemberId, comPbMemberDO.getId()).eq(ComPbActivityMemberDO::getActivityId, id));
        boolean empty = ObjectUtils.isEmpty(comPbActivityMemberDO);
        int mum=0;
        if (type.intValue()==1) {
            if (empty) {
                ComPbActivityMemberDO comPbActivityMemberDO1=new ComPbActivityMemberDO();
                comPbActivityMemberDO1.setActivityId(id);
                comPbActivityMemberDO1.setMemberId(comPbMemberDO.getId());
                comPbActivityMemberDO1.setCreateAt(new Date());
                mum=comPbActivityMemberDAO.insert(comPbActivityMemberDO1);
            } else {
                return R.ok(null,"已经加入了");
            }
        }else{
            if (empty) {
                return R.ok(null,"已经取消");
            }else{
                mum=comPbActivityMemberDAO.deleteById(comPbActivityMemberDO.getId());
            }
        }
        if (mum>0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 获取党建活动所有参入人员的id集合
     *
     * @param id 党建活动id
     * @return 人员id集合
     */
    @Override
    public R selectAllPartyBuildingActivityMembers(Long id) {
        List<Long> longs=comPbActivityMemberDAO.selectAllPartyBuildingActivityMembers(id);
        return R.ok(longs);
    }

    /**
     * 定时任务取消党建活动
     *
     * @return 取消党建活动数量
     */
    @Override
    public R timedTaskPartyBuildingActivity() {
        List<Long> ids=comBpActivityDAO.selectTimedTaskPartyBuildingActivity();
        List<PartyBuildingActivityVO> partyBuildingActivityVOS = new ArrayList<>();
        if (!ObjectUtils.isEmpty(ids)) {
            List<ComPbActivityDO> comPbActivityDOS = comBpActivityDAO.selectBatchIds(ids);
            comPbActivityDOS.forEach(comPbActivityDO -> {
                PartyBuildingActivityVO partyBuildingActivityVO = new PartyBuildingActivityVO();
                BeanUtils.copyProperties(comPbActivityDO,partyBuildingActivityVO);
                List<Long> userIdS=comBpActivityDAO.selectTimedTaskPartyBuildingActivityUserids(comPbActivityDO.getId());
                partyBuildingActivityVO.setUserIds(userIdS);
                partyBuildingActivityVOS.add(partyBuildingActivityVO);
            });
            int i = comBpActivityDAO.updateBatchIds(ids);
            log.info("定时任务取消党建活动数量【{}】",i);
        }
        return R.ok(partyBuildingActivityVOS);
    }

    /**
     * 定时任务刷新党建活动的各个状态 除取消外
     *
     * @return 修改结果
     */
    @Override
    public R timedTaskPartyBuildingActivityAll() {
//        修改发布状态为未开始
        int num=comBpActivityDAO.updateStatusToNotBegin();
        log.info("定时任务修改党建活动--修改发布状态为未开始数量【{}】",num);
//        修改报名状态为报名中
        int num1=comBpActivityDAO.updateStatusToSign();
        log.info("定时任务修改党建活动--修改报名状态为报名中始数量【{}】",num1);
//        修改进行状态为进行中 或者已结束
        int num2=comBpActivityDAO.updateStatusToActiveOrEnd();
        log.info("定时任务修改党建活动--修改进行状态为进行中 或者已结束数量【{}】",num2);
        return R.ok();
    }

    public static void main(String[] args) {
        DateFormat formatTo = new SimpleDateFormat("M月d ahh:mm");
        String format = formatTo.format(new Date());
        System.out.println(format);
    }

}