阿里云批量删除视频和远程调用

冷不防 2021-07-25 01:47 407阅读 0赞

# 一 vod中实现批量删除文件的API #

## 1 web层 ##

VideoController.java

/**
    * 功能描述：根据 阿里云视频id列表 删除视频
    *
    * @param videoIdList 阿里云视频id列表
    * @return R 返回给前端的数据
    * @author cakin
    * @date 2020/12/13
    */
    @DeleteMapping("remove")
    public R removeVideoByIdList(@ApiParam(value = "阿里云视频id列表", required = true) @RequestBody List<String> videoIdList) {
        try {
            videoService.removeVideoByIdList(videoIdList);
            return R.ok().message("视频删除成功");
        } catch (Exception e) {
            log.error(ExceptionUtils.getMessage(e));
            throw new GuliException(ResultCodeEnum.VIDEO_DELETE_ALIYUN_ERROR);
        }
    }

## 2 Service层 ##

接口

/**
    * 功能描述：根据 阿里云视频id列表 删除视频
    *
    * @param videoIdList 阿里云视频id列表
    * @return R 返回给前端的数据
    * @author cakin
    * @date 2020/12/13
    */
    void removeVideoByIdList(List<String> videoIdList) throws ClientException;

实现

/**
    * 功能描述：根据 阿里云视频id列表 删除视频，批量删除，每次最多删除20个
    *
    * @param videoIdList 阿里云视频id列表
    * @return R 返回给前端的数据
    * @author cakin
    * @date 2020/12/13
    */
    @Override
    public void removeVideoByIdList(List<String> videoIdList) throws ClientException {
        DefaultAcsClient client = AliyunVodSDKUtils.initVodClient(
                vodProperties.getKeyid(),
                vodProperties.getKeysecret());
        DeleteVideoRequest request = new DeleteVideoRequest();
        int size = videoIdList.size(); // id列表的长度
        StringBuffer idListStr = new StringBuffer(); //组装好的字符串
        for (int i = 1; i <= size; i++) {
            idListStr.append(videoIdList.get(i - 1));
            if (i == size || i % 20 == 0) { // 当是最后一个或是20的倍数，就开始批量删除
                // 删除，支持传入多个视频ID，多个用逗号分隔。id不能超过20个
                log.info("idListStr = " + idListStr.toString());
                request.setVideoIds(idListStr.toString());
                client.getAcsResponse(request);
                // 重置idListStr
                idListStr = new StringBuffer();
            } else {
                idListStr.append(",");
            }
        }
    }

## 3 swagger测试 ##

## ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][] ##

# 二 edu项目中实现远程调用 #

## 1 创建feign接口 ##

/**
    * 功能描述：根据 vodId 删除视频
    *
    * @param videoIdList 视频id列表
    * @return R 返回给前端的数据
    * @author cakin
    * @date 2020/12/13
    */
    @DeleteMapping("/admin/vod/media/remove")
    R removeVideoByIdList(@RequestBody List<String> videoIdList);

## 2 创建容错类 ##

/**
    * 功能描述：批量删除容错保护
    *
    * @author cakin
    * @date 2020/12/13
    * @param videoIdList 视频id列表
    * @return R 返回给前端的数据
    */
    @Override
    public R removeVideoByIdList(List<String> videoIdList) {
        log.info("熔断保护");
        return R.error();
    }

# 三 删除video时删除视频（传递id列表方案） #

## 1 service中调用feign接口 ##

接口

/**
    * 功能描述：根据id删除视频
    *
    * @author cakin
    * @date 2020/12/13
    * @param id 视频id
    */
    void removeMediaVideoById(String id);

实现

@Autowired
    private VodMediaService vodMediaService;
    
    @Override
    public void removeMediaVideoById(String id) {
        Video video = baseMapper.selectById(id);
        String videoSourceId = video.getVideoSourceId();
        List<String> videoSourceIdList = new ArrayList<>();
        videoSourceIdList.add(videoSourceId);
        vodMediaService.removeVideoByIdList(videoSourceIdList);
    }

## 3 web层 ##

//删除视频
    videoService.removeMediaVideoById(id);

# 四 删除chapter时删除视频 #

## 1 service中调用feign接口 ##

接口

/**
    * 功能描述：根据章节id删除视频
    *
    * @author cakin
    * @date 2020/12/13
    * @param chapterId 章节id
    */
    void removeMediaVideoByChapterId(String chapterId);

实现

/**
    * 功能描述：根据章节id删除视频
    *
    * @param chapterId 章节id
    * @author cakin
    * @date 2020/12/13
    */
    @Override
    public void removeMediaVideoByChapterId(String chapterId) {
        QueryWrapper<Video> queryWrapper = new QueryWrapper<>();
        queryWrapper.select("video_source_id");
        queryWrapper.eq("chapter_id", chapterId);
    
    
        List<Map<String, Object>> maps = baseMapper.selectMaps(queryWrapper);
        List<String> videoSourceIdList = this.getVideoSourceIdList(maps);
        vodMediaService.removeVideoByIdList(videoSourceIdList);
    }
    
    /**
    * 组装视频id列表
    *
    * @param maps 视频id map
    * @return 视频id列表
    */
    private List<String> getVideoSourceIdList(List<Map<String, Object>> maps) {
        ArrayList<String> videoSourceIdList = new ArrayList<>();
        for (Map<String, Object> map : maps) {
            String videoSourceId = (String) map.get("video_source_id");
            videoSourceIdList.add(videoSourceId);
        }
        return videoSourceIdList;
    }

## 2 web层 ##

//删除视频：VOD
    videoService.removeMediaVideoByChapterId(id);

# 五 删除course时删除视频 #

## 1 service中调用feign接口 ##

接口

/**
    * 功能描述：根据课程id删除视频
    *
    * @author cakin
    * @date 2020/12/13
    * @param CourseId 课程id
    */
    void removeMediaVideoByCourseId(String CourseId);

实现

/**
    * 功能描述：根据课程id删除视频
    *
    * @param CourseId 课程id
    * @author cakin
    * @date 2020/12/13
    */
    @Override
    public void removeMediaVideoByCourseId(String CourseId) {
        QueryWrapper<Video> queryWrapper = new QueryWrapper<>();
        queryWrapper.select("video_source_id");
        queryWrapper.eq("course_id", CourseId);
    
    
        List<Map<String, Object>> maps = baseMapper.selectMaps(queryWrapper);
        List<String> videoSourceIdList = this.getVideoSourceIdList(maps);
        vodMediaService.removeVideoByIdList(videoSourceIdList);
    }

## 2 web层 ##

videoService.removeMediaVideoByCourseId(id);

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/fdbd5f2c38b14a959aeaf12b82cfe5c1.png