package cc.mrbird.febs.video.service.impl;

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.video.conversion.VideoConversion;
import cc.mrbird.febs.video.conversion.VideoMemberConversion;
import cc.mrbird.febs.video.dto.ApiVideoCollectionDto;
import cc.mrbird.febs.video.dto.ApiVideoHistoryDto;
import cc.mrbird.febs.video.dto.ApiVideoLikeDto;
import cc.mrbird.febs.video.dto.VideoListDto;
import cc.mrbird.febs.video.entity.*;
import cc.mrbird.febs.video.mapper.*;
import cc.mrbird.febs.video.service.IVideoMasterDataService;
import cc.mrbird.febs.video.service.IVideoMasterInfoService;
import cc.mrbird.febs.video.vo.VideoInfoItemVo;
import cc.mrbird.febs.video.vo.VideoInfoVo;
import cc.mrbird.febs.video.vo.VideoListVo;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.core.*;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;

/**
 * @author wzy
 * @date 2021-12-15
 **/
@Slf4j
@Service
@RequiredArgsConstructor
public class VideoMasterInfoServiceImpl extends ServiceImpl<VideoMasterInfoMapper, VideoMasterInfoEntity> implements IVideoMasterInfoService {

    private final VideoMasterItemsMapper videoMasterItemsMapper;
    private final VideoMasterSourceMapper videoMasterSourceMapper;
    private final VideoMasterDataMapper videoMasterDataMapper;
    private final VideoCollectionMapper videoCollectionMapper;
    private final VideoCommentInfoMapper videoCommentInfoMapper;
    private final VideoCommentLikeMapper videoCommentLikeMapper;
    private final VideoHistoryMapper videoHistoryMapper;
    private final VideoMemberMapper videoMemberMapper;
    private final IVideoMasterDataService videoMasterDataService;

    @Override
    public IPage<VideoMasterInfoEntity> findInPage(VideoMasterInfoEntity info, QueryRequest request) {
        Page<VideoMasterInfoEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
        return this.baseMapper.selectInPage(info, page);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addVideo(VideoMasterInfoEntity info) {

        this.baseMapper.insert(info);
        List<VideoMasterItemsEntity> items = info.getItems();
        if (CollUtil.isEmpty(items)) {
            throw new FebsException("章节异常");
        }

        int i = 1;
        for (VideoMasterItemsEntity item : items) {
            if (StrUtil.isBlank(item.getName())){
                throw new FebsException("章节标题未填写");
            }
            VideoMasterSourceEntity source = this.videoMasterSourceMapper.selectById(item.getSourceId());
            item.setMasterId(info.getId());
            item.setSeq(i);
            item.setVideoUrl(source.getUrl());

            this.videoMasterItemsMapper.insert(item);
            i++;
        }

        VideoMasterDataEntity data = new VideoMasterDataEntity();
        data.setMasterId(info.getId());
        data.setCollectCnt(0);
        data.setPlayCnt(0);
        data.setStarCnt(0);
        this.videoMasterDataMapper.insert(data);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateVideo(VideoMasterInfoEntity info) {
        this.baseMapper.updateById(info);

//        List<VideoMasterItemsEntity> beforeItems = this.videoMasterItemsMapper.selectItemsByMasterId(info.getId());
        List<VideoMasterItemsEntity> newItems = info.getItems();
        if (CollUtil.isEmpty(newItems)) {
            throw new FebsException("章节异常");
        }

        List<Long> existID = new ArrayList<>();
        List<VideoMasterItemsEntity> newInsert = new ArrayList<>();
        int i = 1;
        for (VideoMasterItemsEntity newItem : newItems) {
            if (StrUtil.isBlank(newItem.getName())) {
                throw new FebsException("章节标题未填写");
            }

            if (newItem.getId() != null) {
                newItem.setSeq(i);
                this.videoMasterItemsMapper.updateById(newItem);
                existID.add(newItem.getId());
                i++;
            } else {
                newInsert.add(newItem);
            }
        }

        if (CollUtil.isNotEmpty(existID)) {
            this.videoMasterItemsMapper.deleteNotInIds(existID, info.getId());
        }

        if (CollUtil.isNotEmpty(newInsert)) {
            for (VideoMasterItemsEntity item : newInsert) {
                VideoMasterSourceEntity source = this.videoMasterSourceMapper.selectById(item.getSourceId());
                item.setMasterId(info.getId());
                item.setVideoUrl(source.getUrl());
                item.setSeq(i);
                this.videoMasterItemsMapper.insert(item);

                i++;
            }
        }
    }

    @Override
    public VideoMasterInfoEntity findById(Long id) {
        return this.baseMapper.selectEntityById(id);
    }

    @Override
    public void changeIsUp(Long id) {
        VideoMasterInfoEntity masterInfo = this.baseMapper.selectById(id);
        if (masterInfo == null) {
            throw new FebsException("视频不存在");
        }
        if (AppContants.FLAG_INT_Y.equals(masterInfo.getIsUp())) {
            masterInfo.setIsUp(AppContants.FLAG_INT_N);
        } else {
            masterInfo.setIsUp(AppContants.FLAG_INT_Y);
        }

        this.baseMapper.updateById(masterInfo);
    }

    @Override
    public List<VideoListVo> findVideoList(VideoListDto videoListDto) {
        Page<VideoListVo> page = new Page<>(videoListDto.getPageNum(), videoListDto.getPageSize());

        videoListDto.setIsUp(AppContants.FLAG_INT_Y);
        IPage<VideoListVo> data = this.baseMapper.selectVideoListInPage(videoListDto, page);
        return data.getRecords();
    }

    @Override
    public VideoInfoVo findVideoInfo(Long videoId, Long itemId) {
        VideoMasterInfoEntity videoInfoEntity = this.baseMapper.selectEntityById(videoId);
        if (videoInfoEntity == null) {
            throw new FebsException("视频不存在");
        }

        VideoMemberEntity loginUser = LoginUserUtil.getLoginUser();
        VideoInfoVo videoInfoVo = VideoConversion.INSTANCE.videoInfoEntityToInfoVo(videoInfoEntity);
        List<VideoInfoItemVo> items = VideoConversion.INSTANCE.videoItemEntitiesToItemVoes(videoInfoEntity.getItems());
        videoInfoVo.setItems(items);

        VideoMasterDataEntity data = this.videoMasterDataMapper.selectDataByMasterId(videoInfoEntity.getId());
        videoInfoVo.setPlayCnt(data.getPlayCnt());
        videoInfoVo.setCollectCnt(data.getCollectCnt());
        videoInfoVo.setStarCnt(data.getStarCnt());

        if (loginUser != null) {
            // 是否点赞
            VideoCommentLikeEntity commentLike = this.videoCommentLikeMapper.selectCommentLikeByMemberIdAndRelateId(loginUser.getId(), videoInfoEntity.getId());
            if (commentLike != null) {
                videoInfoVo.setIsLike(1);
            } else {
                videoInfoVo.setIsLike(2);
            }

            // 是否收藏
            VideoCollectionEntity collection = this.videoCollectionMapper.selectVideoCollectionByVideoIdAndMemberId(videoInfoEntity.getId(), loginUser.getId());
            if (collection != null) {
                videoInfoVo.setIsCollect(1);
            } else {
                videoInfoVo.setIsCollect(2);
            }
        }

        // 视频是否需要vip
        if (AppContants.FLAG_INT_N.equals(videoInfoEntity.getIsFree())) {
            // 判断用户是否登录
            if (loginUser == null) {
                videoInfoVo.setNotLogin(AppContants.FLAG_INT_N);
                return videoInfoVo;
            }

            // 判断用户是否为vip
            VideoMemberEntity member = this.videoMemberMapper.selectById(loginUser.getId());
            if (AppContants.FLAG_INT_N.equals(member.getIsVip())) {
                videoInfoVo.setNotVip(AppContants.FLAG_INT_N);
                return videoInfoVo;
            }
        }


        VideoMasterItemsEntity currentItem = this.videoMasterItemsMapper.selectItemByVideoIdAndItemId(videoId, itemId);
        if (currentItem == null) {
            throw new FebsException("视频不存在");
        }

        videoInfoVo.setNotLogin(AppContants.FLAG_INT_Y);
        videoInfoVo.setNotVip(AppContants.FLAG_INT_Y);
        videoInfoVo.setSubTitle(currentItem.getName());
        videoInfoVo.setVideoUrl(currentItem.getVideoUrl());
        videoInfoVo.setThumb(currentItem.getThumb());
        videoInfoVo.setItemId(currentItem.getId());
        videoInfoVo.setTimeLength(currentItem.getTimeLength());

        // 增加播放量
        this.videoMasterDataService.modifyVideoData(videoInfoEntity.getId(), 1, 1);

        // 历史记录
        if (loginUser != null) {
            VideoHistoryEntity history = this.videoHistoryMapper.selectByMemberIdAndVideoId(loginUser.getId(), videoInfoEntity.getId());
            if (history == null) {
                history = new VideoHistoryEntity();
                history.setVideoId(videoInfoEntity.getId());
                history.setMemberId(loginUser.getId());
                history.setVideoItemId(currentItem.getId());
                this.videoHistoryMapper.insert(history);
            } else {
                history.setVideoItemId(currentItem.getId());
                this.videoHistoryMapper.updateById(history);
            }
        }

        return videoInfoVo;
    }

    @Override
    public FebsResponse videoCollection(ApiVideoCollectionDto apiVideoCollectionDto) {
        Long id = LoginUserUtil.getLoginUser().getId();
        Long videoId = apiVideoCollectionDto.getVideoId();
        VideoMasterInfoEntity videoMasterInfoEntity = this.baseMapper.selectById(videoId);
        if(videoMasterInfoEntity == null){
            throw new FebsException("视频不存在");
        }
        VideoCollectionEntity videoCollection = videoCollectionMapper.selectVideoCollectionByVideoIdAndMemberId(videoId, id);
        if(videoCollection != null){
            videoCollectionMapper.deleteById(videoCollection.getId());

            //收藏数-1
            this.videoMasterDataService.modifyVideoData(videoMasterInfoEntity.getId(), -1, 2);
//            VideoMasterDataEntity videoMasterDataEntity = videoMasterDataMapper.selectDataByMasterId(videoId);
//            int collectCnt = videoMasterDataEntity.getCollectCnt();
//            videoMasterDataEntity.setCollectCnt((collectCnt - 1) <= 0 ? 0:(collectCnt - 1));
//            videoMasterDataMapper.updateById(videoMasterDataEntity);
            return new FebsResponse().success().message("已取消收藏");
        }else{
            VideoCollectionEntity videoCollectionEntity = new VideoCollectionEntity();
            videoCollectionEntity.setMemberId(id);
            videoCollectionEntity.setVideoId(videoId);
            videoCollectionMapper.insert(videoCollectionEntity);
            //收藏数+1

            this.videoMasterDataService.modifyVideoData(videoMasterInfoEntity.getId(), 1, 2);
//            VideoMasterDataEntity videoMasterDataEntity = videoMasterDataMapper.selectDataByMasterId(videoId);
//            int collectCnt = videoMasterDataEntity.getCollectCnt();
//            videoMasterDataEntity.setCollectCnt((collectCnt + 1) <= 0 ? 0:(collectCnt + 1));
//            videoMasterDataMapper.updateById(videoMasterDataEntity);
            return new FebsResponse().success().message("已收藏");
        }
    }

    @Override
    public FebsResponse videoLike(ApiVideoLikeDto apiVideoLikeDto) {
        Long id = LoginUserUtil.getLoginUser().getId();
        Integer type = apiVideoLikeDto.getType();
        Long relateId = apiVideoLikeDto.getRelateId();
        VideoCommentLikeEntity videoCommentLikeEntity = videoCommentLikeMapper.selectCommentLikeByMemberIdAndRelateId(id,relateId);

        VideoMasterInfoEntity videoMasterInfoEntity = this.baseMapper.selectById(relateId);
        if(videoCommentLikeEntity != null){
            if(1 == type){
                //视频
                if(videoMasterInfoEntity == null){
                    throw new FebsException("视频不存在");
                }
                videoCommentLikeMapper.deleteById(videoCommentLikeEntity.getId());
                //点赞数-1
                this.videoMasterDataService.modifyVideoData(videoMasterInfoEntity.getId(), -1, 3);
//                VideoMasterDataEntity videoMasterDataEntity = videoMasterDataMapper.selectDataByMasterId(relateId);
//                int starCnt = videoMasterDataEntity.getStarCnt();
//                videoMasterDataEntity.setStarCnt((starCnt - 1) <= 0 ? 0:(starCnt - 1));
//                videoMasterDataMapper.updateById(videoMasterDataEntity);
                return new FebsResponse().success().message("已取消点赞");
            }else if(2 == type){
                //评论
                VideoCommentInfoEntity videoCommentInfoEntity = videoCommentInfoMapper.selectById(relateId);
                if(videoCommentInfoEntity == null){
                    throw new FebsException("评论不存在");
                }
                videoCommentLikeMapper.deleteById(videoCommentLikeEntity.getId());
                return new FebsResponse().success().message("已取消点赞");
            }else{
                throw new FebsException("网络繁忙");
            }
        }else{
            VideoCommentLikeEntity videoCommentLike = new VideoCommentLikeEntity();
            videoCommentLike.setType(type);
            videoCommentLike.setRelateId(relateId);
            videoCommentLike.setMemberId(id);
            videoCommentLikeMapper.insert(videoCommentLike);
            //点赞数+1

            this.videoMasterDataService.modifyVideoData(videoMasterInfoEntity.getId(), 1, 3);
//            VideoMasterDataEntity videoMasterDataEntity = videoMasterDataMapper.selectDataByMasterId(relateId);
//            int starCnt = videoMasterDataEntity.getStarCnt();
//            videoMasterDataEntity.setStarCnt((starCnt + 1) <= 0 ? 0:(starCnt + 1));
//            videoMasterDataMapper.updateById(videoMasterDataEntity);
            return new FebsResponse().success().message("已点赞");
        }

    }

    @Override
    public FebsResponse delVideoHistory(ApiVideoHistoryDto apiVideoHistoryDto) {
        Long id = LoginUserUtil.getLoginUser().getId();
        String ids = apiVideoHistoryDto.getIds();
        List<String> idList = StrUtil.split(ids, ',');
        videoHistoryMapper.delVideoHistoryByIdsAndMemberId(idList,id);
        return new FebsResponse().success().message("成功");
    }
}