package com.panzhihua.service_dangjian.service.impl;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

import javax.annotation.Resource;

import org.apache.http.client.utils.DateUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;

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.exceptions.PartyBuildingMemberException;
import com.panzhihua.common.model.dtos.partybuilding.ActivitySignUpDTO;
import com.panzhihua.common.model.dtos.partybuilding.ComPbActivityDTO;
import com.panzhihua.common.model.vos.LoginUserInfoVO;
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.common.utlis.SensitiveUtil;
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 static java.util.Objects.nonNull;

/**
 * @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;

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

    /**
     * 查询某个党员加入的所有党员活动
     *
     * @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);
        iPage.getRecords().forEach(record -> {
            record.setPhone(SensitiveUtil.desensitizedPhoneNumber(record.getPhone()));
        });
        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("活动不存在");
        }
        LoginUserInfoVO loginUserInfoVO = comBpActivityDAO.selectUserInfoByUserId(comPbActivityDO.getCreateBy());
        Integer type = loginUserInfoVO.getType();
        int isPerson = 0;
        if (type.intValue() == 1) {
            isPerson = 1;
        }
        PartyBuildingActivityVO partyBuildingActivityVO = new PartyBuildingActivityVO();
        BeanUtils.copyProperties(comPbActivityDO, partyBuildingActivityVO);

        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)) {
            int size = comPbActivityMemberDOS.size();
            if (size >= 6) {
                comPbActivityMemberDOS = comPbActivityMemberDOS.subList(0, 6);
            }
            comPbActivityMemberDOS.forEach(member -> {
                PartyBuildingMemberVO partyBuildingMemberVO = new PartyBuildingMemberVO();
                BeanUtils.copyProperties(member, partyBuildingMemberVO);
                partyBuildingMemberVO.setCreateAt(member.getCreateAt());
                partyBuildingMemberVOS.add(partyBuildingMemberVO);
            });
            partyBuildingActivityVO.setParticipationActualNum(comPbActivityMemberDOS.size());
        } else {
            partyBuildingActivityVO.setParticipationActualNum(0);
        }
        // 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);
        partyBuildingActivityVO.setIsPerson(isPerson);
        partyBuildingActivityVO.setCreateByName(loginUserInfoVO.getName());

        // 查询社区名称
        if (partyBuildingActivityVO.getCommunityId() != null) {
            partyBuildingActivityVO.setCommunityName(
                comBpActivityDAO.selectCommunityNameByCommunityId(partyBuildingActivityVO.getCommunityId()));
        }

        partyBuildingActivityVO.setCodeType(2);
        return R.ok(partyBuildingActivityVO);
    }

    /**
     * 新增党员活动
     *
     * @param partyBuildingActivityVO
     *            参数
     * @return 新增结果
     */
    @Override
    public R addactivity(PartyBuildingActivityVO partyBuildingActivityVO) {
        ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
        BeanUtils.copyProperties(partyBuildingActivityVO, comPbActivityDO);
        Date now = new Date();
        comPbActivityDO.setEnrollTimeBegin(now);
        comPbActivityDO.setCreateAt(now);

        Integer status = partyBuildingActivityVO.getStatus();
        if (status != null && status.intValue() == 2) {// 点击'保存并发布' 按钮
            // 默认设置为“进行中”
            comPbActivityDO.setStatus(4);
        }

        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();
                Integer status = partyBuildingActivityVO1.getStatus();
                String createByName = partyBuildingActivityVO1.getCreateByName();
                if (!ObjectUtils.isEmpty(activityTimeBegin)) {
                    partyBuildingActivityVO1.setActivityTimeBeginFormat(formatTo.format(activityTimeBegin));
                }
                if (status.intValue() == 3) {
                    partyBuildingActivityVO1.setStatus(4);
                }
                if (!ObjectUtils.isEmpty(createByName) && createByName.equals("管理员")) {
                    partyBuildingActivityVO1.setIsPerson(0);
                } else {
                    partyBuildingActivityVO1.setIsPerson(1);
                }
            });
        }
        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
     * @param communityId
     *            社区id
     * @param status
     * @return 党建活动列表
     */
    @Override
    public R listActivity(Long userId, Long communityId, Integer status) {
        List<ComActActivityVO> comActActivityVOS = new ArrayList<>();
        /*Long memberId=comPbActivityMemberDAO.selectMemberIdByUserId(userId,communityId);
        if (ObjectUtils.isEmpty(memberId)) {
            return R.fail();
        }*/
        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(
            new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getUserId, 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);
        if (nonNull(status)) {
            comPbActivityDOS = comPbActivityDOS.stream()
                    .filter(activityDO -> activityDO.getStatus().equals(status)).collect(Collectors.toList());
        }
        if (!comPbActivityDOS.isEmpty()) {
            comPbActivityDOS.forEach(comPbActivityDO -> {
                ComActActivityVO comActActivityVO = new ComActActivityVO();
                Long createBy = comPbActivityDO.getCreateBy();
                LoginUserInfoVO loginUserInfoVO = comPbActivityMemberDAO.selectUserInfo(createBy);
                Integer type = loginUserInfoVO.getType();
                if (type == 1) {
                    comActActivityVO.setIsPerson(1);
                } else {
                    comActActivityVO.setIsPerson(0);
                }
                Integer activityStatus = comPbActivityDO.getStatus();
                if (activityStatus.intValue() == 3) {
                    activityStatus = 4;
                }
                comActActivityVO.setType(3);
                comActActivityVO.setId(comPbActivityDO.getId());
                comActActivityVO.setStatus(activityStatus);
                comActActivityVO.setActivityName(comPbActivityDO.getName());
                comActActivityVO.setCover(comPbActivityDO.getCover());
                comActActivityVO.setBeginAt(comPbActivityDO.getActivityTimeBegin());
                comActActivityVO.setSingDate(comPbActivityMemberDOS.stream()
                        .filter(comPbActivityMemberDO -> comPbActivityMemberDO.getActivityId().equals(comActActivityVO.getId()))
                        .collect(Collectors.toList()).get(0).getCreateAt());
                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)) {
            comPbActivityMemberDOS.forEach(member -> {
                PartyBuildingMemberVO partyBuildingMemberVO = new PartyBuildingMemberVO();
                BeanUtils.copyProperties(member, partyBuildingMemberVO);
                partyBuildingMemberVO.setCreateAt(member.getCreateAt());
                partyBuildingMemberVOS.add(partyBuildingMemberVO);
            });
        }
        /*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);
                ComPbActivityMemberDO comPbActivityMemberDO1 = comPbActivityMemberDOS.stream().filter(comPbActivityMemberDO -> comPbActivityMemberDO.getMemberId().equals(comPbMemberDO.getId())).collect(Collectors.toList()).get(0);
                partyBuildingMemberVO.setCreateAt(comPbActivityMemberDO1.getCreateAt());
                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.setUserId(userId);
                // 添加参加活动的党员快照信息，防止党员信息删除后无法显示
                comPbActivityMemberDO1.setName(comPbMemberDO.getName());
                comPbActivityMemberDO1.setPhotoPath(comPbMemberDO.getPhotoPath());
                comPbActivityMemberDO1.setCreateAt(new Date());
                mum = comPbActivityMemberDAO.insert(comPbActivityMemberDO1);
            } else {
                return R.ok(null, "已经加入了");
            }
        } else {
            if (empty) {
                return R.ok(null, "已经取消");
            } else {
                Long createBy = comPbActivityDO.getCreateBy();
                if (createBy.equals(userId)) {
                    return R.fail("发起者不能取消报名");
                }
                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);
        // 查询已结束的活动id,便于计算用户积分
        List<Long> pbActivityEndIds = comBpActivityDAO.getTaskPbActivityEndIds();
        // 修改进行状态为进行中 或者已结束
        int num2 = comBpActivityDAO.updateStatusToActiveOrEnd();
        log.info("定时任务修改党建活动--修改进行状态为进行中 或者已结束数量【{}】", num2);
        return R.ok(pbActivityEndIds);
    }

    /**
     * 创建党员活动 小程序创建党员活动
     *
     * @param comPbActivityDTO
     *            创建内容
     * @return 创建结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public R addActivityApplets(ComPbActivityDTO comPbActivityDTO) {
        ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
        Long createBy = comPbActivityDTO.getCreateBy();
        BeanUtils.copyProperties(comPbActivityDTO, comPbActivityDO);
        int insert = comBpActivityDAO.insert(comPbActivityDO);
        if (insert > 0) {
            ComPbActivityDO comPbActivityDO1 = comBpActivityDAO.selectOne(new QueryWrapper<ComPbActivityDO>().lambda()
                .eq(ComPbActivityDO::getName, comPbActivityDTO.getName())
                .eq(ComPbActivityDO::getCover, comPbActivityDTO.getCover()).last(" order by create_at desc limit 1 "));
            Long comPbActivityDO1Id = comPbActivityDO1.getId();
            ComPbMemberDO comPbMemberDO = comPbMemberDAO.selectByUserId(createBy);
            if (ObjectUtils.isEmpty(comPbMemberDO)) {
                log.error("【{}】不是党员", createBy);
                throw new PartyBuildingMemberException("用户不是党员");
            }
            Long comPbMemberDOId = comPbMemberDO.getId();
            ComPbActivityMemberDO comPbActivityMemberDO = new ComPbActivityMemberDO();
            comPbActivityMemberDO.setMemberId(comPbMemberDOId);
            comPbActivityMemberDO.setActivityId(comPbActivityDO1Id);
            comPbActivityMemberDO.setCreateAt(new Date());
            comPbActivityMemberDO.setUserId(comPbActivityDTO.getCreateBy());
            comPbActivityMemberDO.setName(comPbMemberDO.getName());
            comPbActivityMemberDO.setPhotoPath(comPbMemberDO.getPhotoPath());
            comPbActivityMemberDAO.insert(comPbActivityMemberDO);
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 根据党员活动id查询活动下报名人员
     *
     * @param activityId
     *            党员活动id
     * @return 活动下报名人员
     */
    @Override
    public R getTaskPbActivityPeopleList(Long activityId) {
        return R.ok(this.comBpActivityDAO.getTaskPbActivityPeopleList(activityId));
    }

}