package cn.huge.module.meet.service;

import cn.huge.base.common.constant.FileConsts;
import cn.huge.base.common.exception.ServiceException;
import cn.huge.base.common.utils.DateUtils;
import cn.huge.base.common.utils.IdUtils;
import cn.huge.base.common.utils.SpringContextUtil;
import cn.huge.base.common.utils.ThreadPoolUtils;
import cn.huge.module.client.api.impl.UtilsClientImpl;
import cn.huge.module.constant.BaseConsts;
import cn.huge.module.mediate.constant.MeetBaseConstsEnum;
import cn.huge.module.meet.dao.mapper.MeetVideoMapper;
import cn.huge.module.meet.domain.po.MeetCloud;
import cn.huge.module.meet.domain.po.MeetVideo;
import cn.huge.module.xylink.constant.XylinkConsts;
import cn.huge.module.xylink.domain.dto.XylinkVedioDTO;
import cn.huge.module.xylink.domain.po.XylinkVideo;
import cn.huge.module.xylink.service.XylinkVideoService;
import cn.huge.module.xylink.utils.XylinkUtils;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import net.sf.json.JSONObject;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.transaction.annotation.Transactional;

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * @author liyj
 * @version 1.0.0
 * @title: 云会议录制视频表业务逻辑处理
 * @Description JPA的单表数据查询以由BaseService完成
 * @company hugeinfo
 * @Time 2022-05-09 16:18:58
 */
@Slf4j
@Service
@Transactional(rollbackFor = Exception.class)
public class MeetVideoService extends ServiceImpl<MeetVideoMapper, MeetVideo> {

    @Autowired
    private MeetVideoMapper mapper;

    @Autowired
    private MeetCloudService meetCloudService;
    @Autowired
    private XylinkVideoService xylinkVideoService;

    @Autowired
    private UtilsClientImpl utilsClient;

    /**
     * 更新对象
     *
     * @param entity 对象
     */
    public void updateMeetVideo(MeetVideo entity) {
        try {
            mapper.updateMeetVideo(entity);
        } catch (Exception e) {
            log.error("service方法[MeetVideoService.updateMeetVideo]调用异常：" + e, e);
            throw new ServiceException("MeetVideoService.updateMeetVideo", e);
        }
    }

    /**
     * 条件更新对象
     *
     * @param entity 对象
     * @param terms  条件
     */
    public void updateMeetVideoTerms(MeetVideo entity, Map<String, Object> terms) {
        try {
            mapper.updateMeetVideoTerms(entity, terms);
        } catch (Exception e) {
            log.error("service方法[MeetVideoService.updateMeetVideoTerms]调用异常：" + e, e);
            throw new ServiceException("MeetVideoService.updateMeetVideoTerms", e);
        }
    }

    /**
     * 根据编号物理删除
     *
     * @param id 查询条件集合
     */
    public void deleteMeetVideo(String id) {
        try {
            mapper.deleteMeetVideo(id);
        } catch (Exception e) {
            log.error("service方法[MeetVideoService.deleteMeetVideo]调用异常：" + e, e);
            throw new ServiceException("MeetVideoService.deleteMeetVideo", e);
        }
    }

    /**
     * 按条件查询
     *
     * @param terms 条件
     * @return List
     */
    public List<MeetVideo> listTerms(Map<String, Object> terms) {
        return mapper.listTerms(terms);
    }

    /**
     * 按条件统计
     *
     * @param terms 条件
     * @return long
     */
    public long countTerms(Map<String, Object> terms) {
        return mapper.countTerms(terms);
    }

    /**
     * 按条件分页查询
     *
     * @param page  分页对象
     * @param terms 条件
     * @return Page
     */
    public Page<MeetVideo> pageQuery(PageRequest page, Map<String, Object> terms) {
        long total = mapper.countTerms(terms);
        List<MeetVideo> content = mapper.pageTerms(page, terms);
        return new PageImpl<MeetVideo>(content, page, total);
    }

    /**
     * 新增或更新对象
     *
     * @param meetVideo 实体对象
     */
    public void saveMeetVideo(MeetVideo meetVideo) {
        try {
            Date nowDate = DateUtils.getNowDate();
            // 判断是否新增
            if (IdUtils.checkNewId(meetVideo.getId())) {
                meetVideo.setId(utilsClient.getNewTimeId());
                meetVideo.setCreateTime(nowDate);
            }
            meetVideo.setUpdateTime(nowDate);
            this.saveOrUpdate(meetVideo);
        } catch (Exception e) {
            log.error("service方法[MeetVideoService.saveMeetVideo]调用异常：" + e, e);
            throw new ServiceException("MeetVideoService.saveMeetVideo", e);
        }
    }

    /**
     * 保存云会议录制视频
     *
     * @param caseId   纠纷编号
     * @param meetType 会议类型
     * @return List<MeetVideo>
     */
    public void saveCloudVideo(String caseId, String meetType, boolean rightNow) {
        try {
            // 异步转存小鱼云会议录制视频到多元化平台
            if(rightNow){
                ThreadPoolUtils.executor(new AsynReSaveCloudVideo(caseId, meetType));
            }else {
                ThreadPoolUtils.executor(new AsynSaveCloudVideo(caseId, meetType));
            }

        } catch (Exception e) {
            log.error("service方法[MeetVideoService.saveCloudVideo]调用异常：" + e, e);
            throw new ServiceException("MeetVideoService.saveCloudVideo", e);
        }
    }

    /**
     * 保存云会议录制视频-异步实现
     */
    public class AsynSaveCloudVideo implements Runnable {
        private String caseId;
        private String meetType;

        public AsynSaveCloudVideo(String caseId, String meetType) {
            this.caseId = caseId;
            this.meetType = meetType;
        }


        @Override
        public void run() {
            try {
                log.info("开始保存视频...先等待5分钟...");
                Thread.sleep(60 * 5000);
                Date nowDate = DateUtils.getNowDate();
                SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
                // 保存云会议录制视频
                List<MeetCloud> meetCloudList = meetCloudService.listByCaseId(caseId, meetType);
                if (CollectionUtils.isNotEmpty(meetCloudList)) {
                    log.info("save saveVideo meetCloudList {}", JSON.toJSONString(meetCloudList));
                    MeetCloud meetCloud = meetCloudList.get(0);
                    List<XylinkVedioDTO> xylinkVedioDTOList = XylinkUtils.getMeetingVideos(meetCloud.getRoomNo());
                    log.info("save saveVideo xylinkVedioDTOList {}", JSON.toJSONString(xylinkVedioDTOList));
                    if (CollectionUtils.isNotEmpty(xylinkVedioDTOList)) {
                        for (XylinkVedioDTO xylinkVedioDTO : xylinkVedioDTOList) {
                            MeetVideo meetVideo = new MeetVideo();
                            meetVideo.setId(xylinkVedioDTO.getVodId());
                            meetVideo.setCaseId(caseId);
                            meetVideo.setMeetId(meetCloud.getMeetId());
                            meetVideo.setMeetType(meetCloud.getMeetType());
                            meetVideo.setMeetTypeName(meetCloud.getMeetTypeName());
                            meetVideo.setColudId(meetCloud.getId());
                            meetVideo.setRoomNo(xylinkVedioDTO.getMeetingRoomNumber());
                            meetVideo.setVodId(xylinkVedioDTO.getVodId());
                            meetVideo.setVideoName(meetCloud.getRoomName() + MeetBaseConstsEnum.getDes(meetType) + "录制视频_" + sdf.format(xylinkVedioDTO.getStartTime()));
                            meetVideo.setDisplayName(xylinkVedioDTO.getDisplayName());
                            meetVideo.setStartTime(xylinkVedioDTO.getStartTime());
                            meetVideo.setEndTime(xylinkVedioDTO.getEndTime());
                            meetVideo.setFileSize(xylinkVedioDTO.getFileSize());
                            meetVideo.setNemoNo(xylinkVedioDTO.getNemoNumber());
                            if (XylinkUtils.VOD_METADATA_TYPE_4.equals(xylinkVedioDTO.getVodMetadataType())) {
                                meetVideo.setRecordStatus(MeetBaseConstsEnum.RECORD_STATUS_1.getIndex());
                                meetVideo.setRecordStatusName(MeetBaseConstsEnum.RECORD_STATUS_1.getDes());
                            } else {
                                meetVideo.setRecordStatus(MeetBaseConstsEnum.RECORD_STATUS_2.getIndex());
                                meetVideo.setRecordStatusName(MeetBaseConstsEnum.RECORD_STATUS_2.getDes());
                            }
                            log.info("save saveVideo xylinkVedioDTO {}", xylinkVedioDTO.getDownloadUrl());
                            meetVideo.setDownUrl(xylinkVedioDTO.getDownloadUrl());
                            meetVideo.setCustId(meetCloud.getCustId());
                            meetVideo.setCreateTime(nowDate);
                            meetVideo.setUpdateTime(nowDate);
                            // 小鱼云会议录制视频转存到多元化平台
                            String playUrl = xylinkVideoService.saveVideoToDyh(meetVideo.getVodId(), meetVideo.getVideoName() + FileConsts._mp4);
                            if (StringUtils.isNotEmpty(playUrl)) {
                                // 转存成功
                                meetVideo.setPlayUrl(playUrl);
                                meetVideo.setIsDownload(1);
                            } else {
                                // 转存失败，保存小鱼云会议录制视频记录
                                XylinkVideo xylinkVideo = new XylinkVideo();
                                String vodId = xylinkVedioDTO.getVodId();
                                xylinkVideo.setId(vodId);
                                xylinkVideo.setVodId(vodId);
                                xylinkVideo.setDisplayName(xylinkVedioDTO.getDisplayName());
                                xylinkVideo.setStartTime(xylinkVedioDTO.getStartTime());
                                xylinkVideo.setEndTime(xylinkVedioDTO.getEndTime());
                                xylinkVideo.setFileSize(xylinkVedioDTO.getFileSize());
                                xylinkVideo.setMeetingRoomNumber(xylinkVedioDTO.getMeetingRoomNumber());
                                xylinkVideo.setNemoNumber(xylinkVedioDTO.getNemoNumber());
                                xylinkVideo.setVodMetadataType(xylinkVedioDTO.getVodMetadataType());
                                xylinkVideo.setTranscriptionId(xylinkVedioDTO.getTranscriptionId());
                                xylinkVideo.setTranscriptionTxtFileUrl(xylinkVedioDTO.getTranscriptionTxtFileUrl());
                                xylinkVideo.setPlayUrl(XylinkUtils.getDownloadUrl(vodId));
                                xylinkVideo.setDownloadUrl(XylinkUtils.getDownloadUrl(vodId));
                                xylinkVideo.setStorage(XylinkConsts.STORAGE_1);
                                xylinkVideo.setCreateTime(nowDate);
                                xylinkVideo.setUpdateTime(nowDate);
                                xylinkVideoService.saveOrUpdate(xylinkVideo);
                                // 设置小鱼访问路径
                                meetVideo.setPlayUrl(xylinkVedioDTO.getPlayUrl());
                                meetVideo.setIsDownload(0);
                            }
                            mapper.insert(meetVideo);
                        }
                    }
                }
                log.info("结束保存视频...");
            } catch (Exception e) {
                log.error("service方法[MeetVideoService.AsynSaveCloudVideo]调用异常：" + e, e);
                throw new ServiceException("MeetVideoService.AsynSaveCloudVideo", e);
            }
        }
    }

    public class AsynReSaveCloudVideo implements Runnable {
        private String caseId;
        private String meetType;


        public AsynReSaveCloudVideo(String caseId, String meetType) {
            this.caseId = caseId;
            this.meetType = meetType;

        }


        @Override
        public void run() {
            try {
                Date nowDate = DateUtils.getNowDate();
                SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
                // 保存云会议录制视频
                List<MeetCloud> meetCloudList = meetCloudService.listByCaseId(caseId, meetType);
                if (CollectionUtils.isNotEmpty(meetCloudList)) {
                    log.info("save saveVideo meetCloudList {}", JSON.toJSONString(meetCloudList));
                    MeetCloud meetCloud = meetCloudList.get(0);
                    List<XylinkVedioDTO> xylinkVedioDTOList = XylinkUtils.getMeetingVideos(meetCloud.getRoomNo());
                    log.info("save saveVideo xylinkVedioDTOList {}", JSON.toJSONString(xylinkVedioDTOList));
                    if (CollectionUtils.isNotEmpty(xylinkVedioDTOList)) {
                        for (XylinkVedioDTO xylinkVedioDTO : xylinkVedioDTOList) {
                            MeetVideo meetVideo = mapper.selectById(xylinkVedioDTO.getVodId());
                            if (meetVideo != null) {
                                String playUrl = xylinkVideoService.saveVideoToDyh(meetVideo.getVodId(), meetVideo.getVideoName() + FileConsts._mp4);
                                if (StringUtils.isNotEmpty(playUrl)) {
                                    // 转存成功
                                    meetVideo.setPlayUrl(playUrl);
                                    meetVideo.setUpdateTime(new Date());
                                    meetVideo.setIsDownload(1);
                                    mapper.updateMeetVideo(meetVideo);
                                }
                            }

                        }
                    }
                }
                log.info("结束保存视频...");
            } catch (Exception e) {
                log.error("service方法[MeetVideoService.AsynSaveCloudVideo]调用异常：" + e, e);
                throw new ServiceException("MeetVideoService.AsynSaveCloudVideo", e);
            }
        }
    }

    /**
     * 查询云会议录制视频
     *
     * @param caseId   纠纷编号
     * @param meetType 会议类型
     * @return List<MeetVideo>
     */
    public List<MeetVideo> listByCase(String caseId, String meetType) {
        try {
            QueryWrapper<MeetVideo> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("case_id", caseId).eq("meet_type", meetType);
            List<MeetVideo> meetVideoList = this.list(queryWrapper);
            if (CollectionUtils.isEmpty(meetVideoList)) {
                QueryWrapper<MeetVideo> meetVideoQueryWrapper = new QueryWrapper<>();
                meetVideoQueryWrapper.eq("case_id", caseId).eq("meet_type", meetType);
                meetVideoList = mapper.selectList(meetVideoQueryWrapper);
            }
            return meetVideoList;
        } catch (Exception e) {
            log.error("service方法[MeetVideoService.listByCase]调用异常：" + e, e);
            throw new ServiceException("MeetVideoService.listByCase", e);
        }
    }

    public List<MeetVideo> getDownloadVideo() {
        return mapper.getDownloadVideo();
    }

}