VodDictServiceImpl.java

package com.meishu.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.meishu.common.configure.VODConfig;
import com.meishu.common.exception.HttpException;
import com.meishu.dto.voddict.*;
import com.meishu.mapper.*;
import com.meishu.model.*;
import com.meishu.service.VodDictService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.meishu.util.ConstantUtils;
import com.meishu.util.Signature;
import com.meishu.vo.voddict.*;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.profile.HttpProfile;
import com.tencentcloudapi.vod.v20180717.VodClient;
import com.tencentcloudapi.vod.v20180717.models.*;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;

/**
 * <p>
 * 视频字典表 服务实现类
 * </p>
 *
 * @author Tuyp
 * @since 2021-04-27
 */
@Service
public class VodDictServiceImpl extends ServiceImpl<VodDictMapper, VodDictDO> implements VodDictService {

    @Autowired
    private VODConfig vodConfig;

    @Autowired
    private VodPlayHistoryMapper vodPlayHistoryMapper;

    @Autowired
    private VodSubjectTreeMappingMapper vodSubjectTreeMappingMapper;

    @Autowired
    private KnowledgeSubjectDictMapper knowledgeSubjectDictMapper;

    @Autowired
    private VodDictMapper vodDictMapper;

    @Autowired
    private AdministerMapper administerMapper;


    public SignatureVO signature() throws Exception {
//
        SignatureVO signatureVO = new SignatureVO();

        Signature signature = new Signature();
        signature.setSecretId(vodConfig.getSecretId());
        signature.setSecretKey(vodConfig.getSecretKey());
        signature.setCurrentTime(System.currentTimeMillis());
        signature.setRandom(new Random().nextInt(Integer.MAX_VALUE));
        signature.setSignValidDuration(3600 * 24 * 2);

        String sign = "";
        try {
            sign = signature.getUploadSignature();
            signatureVO.setSign(sign);
        } catch (Exception ex) {
            ex.printStackTrace();
//            throw new MyException(ResultEnum.UNKNOWN_ERROR);
        }
        return signatureVO;
    }

    public IPage<GetTreeVodsVO> getTreeVods(GetTreeVodsDTO getTreeVodsDTO) {

        Page pager = new Page(getTreeVodsDTO.getPageNum(), getTreeVodsDTO.getPageSize());

        KnowledgeSubjectDictDO subjectDictDO = knowledgeSubjectDictMapper.selectById(getTreeVodsDTO.getSubjectId());

        //查看该老师的科目信息
        List<KnowledgeSubjectDictDO> subjectDictDOS = administerMapper.getTeacherSubjects(getTreeVodsDTO.getUserId());

        if ("1".equals(getTreeVodsDTO.getShareStatus())) {
            getTreeVodsDTO.setUserId(null);         //查看所有公共库的视频
        }

        List<String> strings = new ArrayList<>();
        for (KnowledgeSubjectDictDO subjectDictDO1 : subjectDictDOS) {
            strings.add(subjectDictDO1.getSubjectEn());
        }

        IPage<GetTreeVodsVO> getTreeVodsVOIPage = this.baseMapper.getTreeVods(pager, getTreeVodsDTO.getTreeId(), subjectDictDO.getSubjectEn(), getTreeVodsDTO.getVodName(), getTreeVodsDTO.getVodType(), getTreeVodsDTO.getShareStatus(), getTreeVodsDTO.getUserId(), strings, getTreeVodsDTO.getCheckStatus());

        List<GetTreeVodsVO> getTreeVodsVOS = getTreeVodsVOIPage.getRecords();
        for (GetTreeVodsVO getTreeVodsVO : getTreeVodsVOS) {
            //获取视频播放量
            Integer count = vodPlayHistoryMapper.queryPlayCounts( getTreeVodsVO.getId());
            getTreeVodsVO.setPlayCounts(count);

            //视频知识点
            List<SubjectTreeDO> vodTreeMappingDOS = this.baseMapper.getTrees(getTreeVodsVO.getId());
            getTreeVodsVO.setTrees(vodTreeMappingDOS);
        }
        getTreeVodsVOIPage.setRecords(getTreeVodsVOS);

        return getTreeVodsVOIPage;
    }

    public IPage<GetTreeVodsVO> getCheckTreeVods(GetTreeVodsDTO getTreeVodsDTO) {

        Page pager = new Page(getTreeVodsDTO.getPageNum(), getTreeVodsDTO.getPageSize());

        KnowledgeSubjectDictDO subjectDictDO = knowledgeSubjectDictMapper.selectById(getTreeVodsDTO.getSubjectId());

        //查看该老师的科目信息
        List<KnowledgeSubjectDictDO> subjectDictDOS = administerMapper.getTeacherSubjects(getTreeVodsDTO.getUserId());

        List<String> strings = new ArrayList<>();
        for (KnowledgeSubjectDictDO subjectDictDO1 : subjectDictDOS) {
            strings.add(subjectDictDO1.getSubjectEn());
        }

        IPage<GetTreeVodsVO> getTreeVodsVOIPage = this.baseMapper.getTreeVods(pager, getTreeVodsDTO.getTreeId(), subjectDictDO.getSubjectEn(), getTreeVodsDTO.getVodName(), getTreeVodsDTO.getVodType(), getTreeVodsDTO.getShareStatus(), null, strings, getTreeVodsDTO.getCheckStatus());

        List<GetTreeVodsVO> getTreeVodsVOS = getTreeVodsVOIPage.getRecords();

        for (GetTreeVodsVO getTreeVodsVO : getTreeVodsVOS) {
            //获取视频播放量
            Integer count = vodPlayHistoryMapper.queryPlayCounts(getTreeVodsVO.getId());
            getTreeVodsVO.setPlayCounts(count);

            //视频知识点
            List<SubjectTreeDO> vodTreeMappingDOS = this.baseMapper.getTrees(getTreeVodsVO.getId());
            getTreeVodsVO.setTrees(vodTreeMappingDOS);
        }
        getTreeVodsVOIPage.setRecords(getTreeVodsVOS);

        return getTreeVodsVOIPage;
    }

    @Transactional(rollbackFor = Exception.class)
    public String deleteVod(VodDictDO vodDictDO) {

        VodDictDO vodDictDO1 = this.baseMapper.selectById(vodDictDO.getId());

        this.baseMapper.deleteById(vodDictDO.getId());

        vodSubjectTreeMappingMapper.delete(new QueryWrapper<VodSubjectTreeMappingDO>()
                .lambda()
                .eq(VodSubjectTreeMappingDO::getVodId, vodDictDO.getId()));

        try{

            //上传后直接转码
            Credential cred = new Credential(vodConfig.getSecretId(), vodConfig.getSecretKey());

            HttpProfile httpProfile = new HttpProfile();
            httpProfile.setEndpoint("vod.tencentcloudapi.com");

            ClientProfile clientProfile = new ClientProfile();
            clientProfile.setHttpProfile(httpProfile);

            VodClient client = new VodClient(cred, "", clientProfile);

            // 实例化一个请求对象,每个接口都会对应一个request对象
            DeleteMediaRequest req = new DeleteMediaRequest();
            req.setFileId(vodDictDO1.getVodCode());
            // 返回的resp是一个DeleteMediaResponse的实例，与请求对象对应
            client.DeleteMedia(req);
        } catch (TencentCloudSDKException e) {
            System.out.println(e.toString());
        }

        return ConstantUtils.DELETE_SUCCESS;
    }

    @Transactional(rollbackFor = Exception.class)
    public VodDictDO uploadVods(UploadVodsDTO uploadVodsDTO) {

        KnowledgeSubjectDictDO subjectDictDO = knowledgeSubjectDictMapper.selectById(uploadVodsDTO.getSubjectId());

        VodDictDO vodDictDO = new VodDictDO();
        BeanUtils.copyProperties(uploadVodsDTO, vodDictDO);
        vodDictDO.setStatus("0");
        vodDictDO.setShareStatus("0");  //刚上传的视频属于个人库
        vodDictDO.setCheckStatus("0");  //刚上传的视频，没有审核状态
        vodDictDO.setSubjectId(subjectDictDO.getSubjectEn());
        vodDictDO.setCreateDate(LocalDateTime.now());
        vodDictDO.setUpdateDate(LocalDateTime.now());
        this.baseMapper.insert(vodDictDO);

        List<Long> longs = uploadVodsDTO.getTreeIds();
        for (Long lg : longs) {
            VodSubjectTreeMappingDO vodTreeMappingDO = new VodSubjectTreeMappingDO();
            vodTreeMappingDO.setTreeId(lg);
            vodTreeMappingDO.setVodId(vodDictDO.getId());
            vodTreeMappingDO.setStatus("1");
            vodSubjectTreeMappingMapper.insert(vodTreeMappingDO);

//            //包含知识点的课程，也会传上该视频
//            //找到包含 该知识点的courseTree
//            List<CourseTreeDO> courseTreeDOS = courseTreeMapper.selectList(new QueryWrapper<CourseTreeDO>()
//                    .lambda()
//                    .eq(CourseTreeDO::getTreeId, lg));
//
//            for (CourseTreeDO courseTreeDO : courseTreeDOS) {
//                //新增记录
//                VodCourseTreeMappingDO vodCourseTreeMappingDO = new VodCourseTreeMappingDO();
//                vodCourseTreeMappingDO.setVodId(vodDictDO.getId());
//                vodCourseTreeMappingDO.setTreeId(courseTreeDO.getId());
//                vodCourseTreeMappingDO.setStatus("0");
//                vodCourseTreeMappingMapper.insert(vodCourseTreeMappingDO);
//            }
        }

        //上传后直接转码
        Credential cred = new Credential(vodConfig.getSecretId(), vodConfig.getSecretKey());

        HttpProfile httpProfile = new HttpProfile();
        httpProfile.setEndpoint("vod.tencentcloudapi.com");

        ClientProfile clientProfile = new ClientProfile();
        clientProfile.setHttpProfile(httpProfile);

        VodClient client = new VodClient(cred, "", clientProfile);

        ProcessMediaRequest processMediaRequest = new ProcessMediaRequest();
        MediaProcessTaskInput mediaProcessTaskInput1 = new MediaProcessTaskInput();
        TranscodeTaskInput[] transcodeTaskInputs1 = new TranscodeTaskInput[1];
        TranscodeTaskInput transcodeTaskInput1 = new TranscodeTaskInput();
        transcodeTaskInput1.setDefinition(ConstantUtils.TEMPLATE_VOD);
        transcodeTaskInputs1[0] = transcodeTaskInput1;
        mediaProcessTaskInput1.setTranscodeTaskSet(transcodeTaskInputs1);
        processMediaRequest.setMediaProcessTask(mediaProcessTaskInput1);
        processMediaRequest.setFileId(uploadVodsDTO.getVodCode());

        ProcessMediaResponse processMediaResponse = null;
        try {
            processMediaResponse = client.ProcessMedia(processMediaRequest);
            System.out.println(processMediaResponse);
        } catch (Exception ex) {
            throw new HttpException(50001);
        }

        return vodDictDO;
    }

    public String updateVod(UploadVodsDTO uploadVodsDTO) {

        VodDictDO vodDictDO = new VodDictDO();
        BeanUtils.copyProperties(uploadVodsDTO, vodDictDO);
        this.baseMapper.updateById(vodDictDO);

        vodSubjectTreeMappingMapper.delete(new QueryWrapper<VodSubjectTreeMappingDO>()
                .lambda()
                .in(VodSubjectTreeMappingDO::getVodId, uploadVodsDTO.getId()));

//        //从新传了新视频，需要转码
//        if (!uploadVodsDTO.getVodUrl().contains("100030")){
//            //上传后直接转码
//            Credential cred = new Credential(vodConfig.getSecretId(), vodConfig.getSecretKey());
//
//            HttpProfile httpProfile = new HttpProfile();
//            httpProfile.setEndpoint("vod.tencentcloudapi.com");
//
//            ClientProfile clientProfile = new ClientProfile();
//            clientProfile.setHttpProfile(httpProfile);
//
//            VodClient client = new VodClient(cred, "", clientProfile);
//
//            ProcessMediaRequest processMediaRequest = new ProcessMediaRequest();
//            MediaProcessTaskInput mediaProcessTaskInput1 = new MediaProcessTaskInput();
//            TranscodeTaskInput[] transcodeTaskInputs1 = new TranscodeTaskInput[1];
//            TranscodeTaskInput transcodeTaskInput1 = new TranscodeTaskInput();
//            transcodeTaskInput1.setDefinition(ConstantUtils.TEMPLATE_VOD);
//            transcodeTaskInputs1[0] = transcodeTaskInput1;
//            mediaProcessTaskInput1.setTranscodeTaskSet(transcodeTaskInputs1);
//            processMediaRequest.setMediaProcessTask(mediaProcessTaskInput1);
//            processMediaRequest.setFileId(uploadVodsDTO.getVodCode());
//
//            ProcessMediaResponse processMediaResponse = null;
//            try {
//                processMediaResponse = client.ProcessMedia(processMediaRequest);
//                System.out.println(processMediaResponse);
//
//                //删除原视频  TODO
//            } catch (Exception ex) {
//                throw new HttpException(50001);
//            }
//        }

        List<Long> longs = uploadVodsDTO.getTreeIds();
        for (Long lg : longs) {
            VodSubjectTreeMappingDO vodTreeMappingDO = new VodSubjectTreeMappingDO();
            vodTreeMappingDO.setTreeId(lg);
            vodTreeMappingDO.setVodId(vodDictDO.getId());
            vodSubjectTreeMappingMapper.insert(vodTreeMappingDO);
        }
        return ConstantUtils.SUCCESS_UPDATE;
    }

    public VodDictDO getVodInfo(VodDictDO vodDictDO) {
        return this.baseMapper.selectById(vodDictDO.getId());
    }

    public String insertPlayHistory(VodPlayHistoryDO vodPlayHistoryDO) {
        vodPlayHistoryMapper.insert(vodPlayHistoryDO);
        return ConstantUtils.ADD_SUCCESS;
    }

    public GetToCheckCountsVO getToCheckVodCounts(GetToCheckVodCountsDTO getToCheckVodCountsDTO) {

        GetToCheckCountsVO getToCheckVodCountsVO = new GetToCheckCountsVO();

        KnowledgeSubjectDictDO subjectDictDO = knowledgeSubjectDictMapper.selectById(getToCheckVodCountsDTO.getSubjectId());


        Integer counts = this.baseMapper.selectCount(new QueryWrapper<VodDictDO>()
                .lambda()
                .eq(VodDictDO::getSubjectId, subjectDictDO.getSubjectEn())
                .eq(VodDictDO::getCheckStatus, "2"));

        getToCheckVodCountsVO.setToCheckCounts(counts);
        //已审核  包括已通过 未通过
        Integer counts1 = this.baseMapper.selectCount(new QueryWrapper<VodDictDO>()
                .lambda()
                .eq(VodDictDO::getSubjectId, subjectDictDO.getSubjectEn())
                .in(VodDictDO::getCheckStatus, new String[]{"1", "3"}));


        getToCheckVodCountsVO.setCheckCounts(counts1);

        return getToCheckVodCountsVO;
    }

    @Transactional(rollbackFor = Exception.class)
    public String compressVodByCode(VodDictDO vodDictDO) {

        VodDictDO vodDictDO1 = this.baseMapper.selectById(vodDictDO.getId());

        //转码
        Credential cred = new Credential(vodConfig.getSecretId(), vodConfig.getSecretKey());

        HttpProfile httpProfile = new HttpProfile();
        httpProfile.setEndpoint("vod.tencentcloudapi.com");

        ClientProfile clientProfile = new ClientProfile();
        clientProfile.setHttpProfile(httpProfile);

        VodClient client = new VodClient(cred, "", clientProfile);

        ProcessMediaRequest processMediaRequest = new ProcessMediaRequest();
        MediaProcessTaskInput mediaProcessTaskInput1 = new MediaProcessTaskInput();
        TranscodeTaskInput[] transcodeTaskInputs1 = new TranscodeTaskInput[1];
        TranscodeTaskInput transcodeTaskInput1 = new TranscodeTaskInput();
        transcodeTaskInput1.setDefinition(ConstantUtils.TEMPLATE_VOD);
        transcodeTaskInputs1[0] = transcodeTaskInput1;
        mediaProcessTaskInput1.setTranscodeTaskSet(transcodeTaskInputs1);
        processMediaRequest.setMediaProcessTask(mediaProcessTaskInput1);
        processMediaRequest.setFileId(vodDictDO1.getVodCode());

        ProcessMediaResponse processMediaResponse = null;
        try {
            processMediaResponse = client.ProcessMedia(processMediaRequest);
            System.out.println(processMediaResponse);
        } catch (Exception ex) {
            throw new HttpException(50001);
        }


        return ConstantUtils.COMPRESS_SUCCESS;
    }

    public String deleteOriginVod(DeleteOriginVodDTO deleteOriginVodDTO) {
        //转码
        Credential cred = new Credential(vodConfig.getSecretId(), vodConfig.getSecretKey());

        HttpProfile httpProfile = new HttpProfile();
        httpProfile.setEndpoint("vod.tencentcloudapi.com");

        ClientProfile clientProfile = new ClientProfile();
        clientProfile.setHttpProfile(httpProfile);

        VodClient client = new VodClient(cred, "", clientProfile);

        //删除原视频
        try {

            //替换原视频的地址
            List<MediaProcessResultSet> mediaProcessResultSets = deleteOriginVodDTO.getProcedureStateChangeEvent()
                    .getMediaProcessResultSet();

            VodDictDO vodDictDO = vodDictMapper.selectOne(new QueryWrapper<VodDictDO>()
                    .lambda()
                    .eq(VodDictDO::getVodCode, deleteOriginVodDTO.getProcedureStateChangeEvent().getFileId()));

            vodDictDO.setVodUrl(mediaProcessResultSets.get(0).getTranscodeTask().getOutput().getUrl());
            vodDictMapper.updateById(vodDictDO);

            DeleteMediaRequest req = new DeleteMediaRequest();
            req.setFileId(deleteOriginVodDTO.getProcedureStateChangeEvent().getFileId());

            MediaDeleteItem[] mediaDeleteItems1 = new MediaDeleteItem[1];
            MediaDeleteItem mediaDeleteItem1 = new MediaDeleteItem();
            mediaDeleteItem1.setType("OriginFiles");
            mediaDeleteItems1[0] = mediaDeleteItem1;

            req.setDeleteParts(mediaDeleteItems1);

            client.DeleteMedia(req);

        } catch (Exception e) {
            System.out.println(e.toString());
        }

        return ConstantUtils.DELETE_SUCCESS;
    }

    public String checkVod(CheckVodDTO checkVodDTO) {

        //审核通过
        if ("1".equals(checkVodDTO.getCheckStatus())) {
            VodDictDO vodDictDO1 = vodDictMapper.selectById(checkVodDTO.getId());

            vodDictDO1.setVodName(checkVodDTO.getVodName());
            vodDictDO1.setVodType(checkVodDTO.getVodType());
            vodDictDO1.setShareStatus("1"); //已共享
            vodDictDO1.setCheckStatus("1");// 已通过审核
            vodDictMapper.updateById(vodDictDO1);

            List<Long> ids = checkVodDTO.getTreeIds();

            //删除之前原视频的关联知识点
            vodSubjectTreeMappingMapper.delete(new QueryWrapper<VodSubjectTreeMappingDO>()
                    .lambda()
                    .eq(VodSubjectTreeMappingDO::getVodId, vodDictDO1.getId()));

            for (Long lg : ids) {
                //知识点关联
                VodSubjectTreeMappingDO vodSubjectTreeMappingDO = new VodSubjectTreeMappingDO();
                vodSubjectTreeMappingDO.setVodId(vodDictDO1.getId());
                vodSubjectTreeMappingDO.setTreeId(lg);
                vodSubjectTreeMappingDO.setStatus("0");     //不是关联视频
                vodSubjectTreeMappingMapper.insert(vodSubjectTreeMappingDO);
            }
        } else {
            //不通过
            VodDictDO vodDictDO = new VodDictDO();
            BeanUtils.copyProperties(checkVodDTO, vodDictDO);
            this.baseMapper.updateById(vodDictDO);
        }
        return ConstantUtils.CHECK_STATUS;
    }

    public IPage<VodDictDO> publicUpload(PublicCheckingDTO publicCheckingDTO) {

        Page pager = new Page(publicCheckingDTO.getPageNum(), publicCheckingDTO.getPageSize());
        return this.baseMapper.selectPage(pager, new QueryWrapper<VodDictDO>()
                .lambda()
                .eq(VodDictDO::getAdministerId, publicCheckingDTO.getUserId())
                .eq(VodDictDO::getCheckStatus, publicCheckingDTO.getCheckStatus())
                .orderByDesc(VodDictDO::getUpdateDate));
    }

    public String withdraw(VodDictDO vodDictDO) {
        vodDictDO.setCheckStatus("0");
        vodDictDO.setShareStatus("0");
        this.baseMapper.updateById(vodDictDO);
        return ConstantUtils.SET_SUCCESS;
    }

    public GetVodDetailVO getVodDetail(VodDictDO vodDictDO) {

        GetVodDetailVO getVodDetailVO = new GetVodDetailVO();

        VodDictDO vodDictDO1 = this.baseMapper.selectById(vodDictDO.getId());
        BeanUtils.copyProperties(vodDictDO1, getVodDetailVO);

        List<SubjectTreeDO> subjectTreeDOS = this.baseMapper.getTrees(vodDictDO.getId());

        getVodDetailVO.setSubjectTreeDOS(subjectTreeDOS);
        return getVodDetailVO;
    }

    public String setRelatedVod(VodSubjectTreeMappingDO vodSubjectTreeMappingDO){

        VodSubjectTreeMappingDO vodSubjectTreeMappingDO1 = new VodSubjectTreeMappingDO();
        vodSubjectTreeMappingDO1.setStatus(vodSubjectTreeMappingDO.getStatus());

        vodSubjectTreeMappingMapper.update(vodSubjectTreeMappingDO1,new QueryWrapper<VodSubjectTreeMappingDO>()
        .lambda()
        .eq(VodSubjectTreeMappingDO::getVodId,vodSubjectTreeMappingDO.getVodId()));

        return ConstantUtils.SUCCESS_UPDATE;
    }

}