package com.panzhihua.service_community.service.impl;

import java.util.Date;
import java.util.List;

import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.community.easyPhoto.AddEasyPhotoActivityDTO;
import com.panzhihua.common.model.dtos.community.easyPhoto.EditEasyPhotoActivityDTO;
import com.panzhihua.common.model.dtos.community.easyPhoto.PageEasyPhotoActivityDTO;
import com.panzhihua.common.model.dtos.community.easyPhoto.PageEasyPhotoActivityUserDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActEasyPhotoActivityVO;
import com.panzhihua.common.utlis.DateUtils;
import com.panzhihua.service_community.dao.ComActEasyPhotoActivityMapper;
import com.panzhihua.service_community.model.dos.ComActEasyPhotoActivityDO;
import com.panzhihua.service_community.service.ComActEasyPhotoActivityService;

import lombok.extern.slf4j.Slf4j;

/**
 * @auther lyq
 * @create 2021-06-25 10:34:16
 * @describe 随手拍活动表服务实现类
 */
@Slf4j
@Service
public class ComActEasyPhotoActivityServiceImpl extends
    ServiceImpl<ComActEasyPhotoActivityMapper, ComActEasyPhotoActivityDO> implements ComActEasyPhotoActivityService {

    /**
     * 查询随手拍是否有活动
     * 
     * @return 活动详情
     */
    @Override
    public R getEasyPhotoActivity(Long communityId) {
        ComActEasyPhotoActivityVO photoActivityVO = new ComActEasyPhotoActivityVO();
        Date nowDate = DateUtils.getCurrentDate(DateUtils.ymdhms_format);
        List<ComActEasyPhotoActivityDO> photoActivityDOS =
            this.baseMapper.selectList(new QueryWrapper<ComActEasyPhotoActivityDO>().lambda()
                .eq(ComActEasyPhotoActivityDO::getCommunityId, communityId)
                .eq(ComActEasyPhotoActivityDO::getStatus, ComActEasyPhotoActivityDO.status.jxz)
                .le(ComActEasyPhotoActivityDO::getActivityStartAt, nowDate)
                .ge(ComActEasyPhotoActivityDO::getActivityEndAt, nowDate));
        if (!photoActivityDOS.isEmpty()) {
            ComActEasyPhotoActivityDO photoActivityDO = photoActivityDOS.get(0);
            BeanUtils.copyProperties(photoActivityDO, photoActivityVO);
            return R.ok(photoActivityVO);
        }
        return R.ok();
    }

    /**
     * 社区后台-分页查询随手拍活动列表
     * 
     * @param pageEasyPhotoActivityDTO
     *            请求参数
     * @return 随手拍活动列表
     */
    @Override
    public R pageActivity(PageEasyPhotoActivityDTO pageEasyPhotoActivityDTO) {
        return R.ok(this.baseMapper.pageActivity(
            new Page(pageEasyPhotoActivityDTO.getPageNum(), pageEasyPhotoActivityDTO.getPageSize()),
            pageEasyPhotoActivityDTO));
    }

    /**
     * 社区后台-添加随手拍活动
     * 
     * @param addEasyPhotoActivityDTO
     *            请求参数
     * @return 添加结果
     */
    @Override
    public R addActivity(AddEasyPhotoActivityDTO addEasyPhotoActivityDTO) {

        // 判断当前活动时间是否与其他时间有冲突
        Integer count = this.baseMapper.getEasyPhotoActivityTimeConflict(addEasyPhotoActivityDTO.getActivityStartAt(),
            addEasyPhotoActivityDTO.getActivityEndAt(), null, addEasyPhotoActivityDTO.getCommunityId());
        if (count > 0) {
            return R.fail("在此期间已有活动，请勿重复添加");
        }

        Date nowDate = new Date();
        ComActEasyPhotoActivityDO photoActivityDO = new ComActEasyPhotoActivityDO();
        BeanUtils.copyProperties(addEasyPhotoActivityDTO, photoActivityDO);
        photoActivityDO.setActivityStartAt(
            DateUtils.stringToDate(addEasyPhotoActivityDTO.getActivityStartAt(), DateUtils.ymdhm_format));
        photoActivityDO.setActivityEndAt(
            DateUtils.stringToDate(addEasyPhotoActivityDTO.getActivityEndAt(), DateUtils.ymdhm_format));
        photoActivityDO.setCreateAt(new Date());
        photoActivityDO.setReleaseAt(new Date());
        if (photoActivityDO.getActivityEndAt().getTime() <= nowDate.getTime()) {
            return R.fail("活动结束时间不可小于当前时间");
        }

        if (nowDate.getTime() >= photoActivityDO.getActivityStartAt().getTime()) {
            photoActivityDO.setStatus(ComActEasyPhotoActivityDO.status.jxz);
        } else {
            photoActivityDO.setStatus(ComActEasyPhotoActivityDO.status.dks);
        }

        photoActivityDO.setCount(0);
        if (this.baseMapper.insert(photoActivityDO) > 0) {
            return R.ok();
        }
        return R.fail("添加失败");
    }

    /**
     * 社区后台-编辑随手拍活动
     * 
     * @param editEasyPhotoActivityDTO
     *            请求参数
     * @return 编辑结果
     */
    @Override
    public R editActivity(EditEasyPhotoActivityDTO editEasyPhotoActivityDTO) {

        ComActEasyPhotoActivityDO photoActivityDO = this.baseMapper.selectById(editEasyPhotoActivityDTO.getId());
        if (photoActivityDO == null) {
            return R.fail("未查询到活动记录");
        }

        Integer count = this.baseMapper.getEasyPhotoActivityTimeConflict(editEasyPhotoActivityDTO.getActivityStartAt(),
            editEasyPhotoActivityDTO.getActivityEndAt(), editEasyPhotoActivityDTO.getId(),
            photoActivityDO.getCommunityId());
        if (count > 0) {
            return R.fail("在此期间已有活动，请勿重复添加");
        }

        BeanUtils.copyProperties(editEasyPhotoActivityDTO, photoActivityDO);
        photoActivityDO.setActivityStartAt(
            DateUtils.stringToDate(editEasyPhotoActivityDTO.getActivityStartAt(), DateUtils.ymdhm_format));
        photoActivityDO.setActivityEndAt(
            DateUtils.stringToDate(editEasyPhotoActivityDTO.getActivityEndAt(), DateUtils.ymdhm_format));
        if (new Date().getTime() > photoActivityDO.getActivityStartAt().getTime()) {
            photoActivityDO.setStatus(ComActEasyPhotoActivityDO.status.jxz);
        } else {
            photoActivityDO.setStatus(ComActEasyPhotoActivityDO.status.dks);
        }

        if (new Date().getTime() > photoActivityDO.getActivityEndAt().getTime()) {
            photoActivityDO.setStatus(ComActEasyPhotoActivityDO.status.yjs);
        }
        if (this.baseMapper.updateById(photoActivityDO) > 0) {
            return R.ok();
        }
        return R.fail("编辑失败");
    }

    /**
     * 社区后台-取消随手拍活动
     * 
     * @param id
     *            随手拍活动id
     * @return 取消结果
     */
    @Override
    public R cancelActivity(Long id) {
        ComActEasyPhotoActivityDO photoActivityDO = this.baseMapper.selectById(id);
        if (photoActivityDO == null) {
            return R.fail("未查询到活动记录");
        }
        photoActivityDO.setStatus(ComActEasyPhotoActivityDO.status.yqx);
        if (this.baseMapper.updateById(photoActivityDO) > 0) {
            return R.ok();
        }
        return R.fail("取消失败");
    }

    /**
     * 分页查询随手拍活动下居民参与记录
     * 
     * @param activityUserDTO
     *            请求参数
     * @return 居民参与记录
     */
    @Override
    public R pageActivityUser(PageEasyPhotoActivityUserDTO activityUserDTO) {
        return R.ok(this.baseMapper
            .pageActivityUser(new Page(activityUserDTO.getPageNum(), activityUserDTO.getPageSize()), activityUserDTO));
    }

    /**
     * 随手拍活动定时任务
     * 
     * @return 执行结果
     */
    @Override
    public R timeTaskEasyPhotoActivity() {
        // 定时任务扫描未开始活动，如果开始时间大于当前时间则更新活动状态
        log.info("定时任务检测未开始的随手拍活动，判断是否开始");
        List<ComActEasyPhotoActivityDO> photoActivityDOS =
            this.baseMapper.selectList(new QueryWrapper<ComActEasyPhotoActivityDO>().lambda()
                .eq(ComActEasyPhotoActivityDO::getStatus, ComActEasyPhotoActivityDO.status.dks));
        if (!photoActivityDOS.isEmpty()) {
            Date nowDate = new Date();
            photoActivityDOS.forEach(photoActivity -> {
                if (photoActivity.getActivityStartAt().getTime() <= nowDate.getTime()) {
                    photoActivity.setStatus(ComActEasyPhotoActivityDO.status.jxz);
                    this.baseMapper.updateById(photoActivity);
                }
            });
        }
        // 定时任务扫描已开始活动，如果结束时间大于当前时间则更新活动状态
        log.info("定时任务检测已开始的随手拍活动，判断活动是否已结束");
        List<ComActEasyPhotoActivityDO> oldPhotoActivityDOS =
            this.baseMapper.selectList(new QueryWrapper<ComActEasyPhotoActivityDO>().lambda()
                .eq(ComActEasyPhotoActivityDO::getStatus, ComActEasyPhotoActivityDO.status.jxz));
        if (!oldPhotoActivityDOS.isEmpty()) {
            Date nowDate = new Date();
            oldPhotoActivityDOS.forEach(photoActivity -> {
                if (photoActivity.getActivityEndAt().getTime() <= nowDate.getTime()) {
                    photoActivity.setStatus(ComActEasyPhotoActivityDO.status.yjs);
                    this.baseMapper.updateById(photoActivity);
                }
            });
        }
        return R.ok();
    }
}