谷粒随享
学习目标:
功能入口:运行小程序-->我的-->创作中心-->声音-->点击 + 添加声音
业务需求:当创作者新增专辑后,创作者将自己录制的音视频文件保存到声音。
需求:点击添加声音的时候会触发一个查询所有专辑列表,主要目的是为了让专辑与声音进行挂钩!
主要是根据userId,查询专辑Id 与专辑标题,然后按照专辑Id 进行降序排列。
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/27
AlbumInfoApiController控制器
/**
* TODO 该接口必须登录才能访问
* 查询当前登录用户所有专辑列表
*
* @return
*/
@Operation(summary = "查询当前登录用户所有专辑列表")
@GetMapping("/albumInfo/findUserAllAlbumList")
public Result<List<AlbumInfo>> getUserAllAlbumList() {
//1.获取用户ID
Long userId = AuthContextHolder.getUserId();
//2.调用业务层查询专辑列表
List<AlbumInfo> list = albumInfoService.getUserAllAlbumList(userId);
return Result.ok(list);
}
AlbumInfoService接口
/**
* 查询当前登录用户所有专辑列表
* @param userId
* @return
*/
List<AlbumInfo> getUserAllAlbumList(Long userId);
AlbumInfoServiceImpl实现类
/**
* 查询当前登录用户所有专辑列表
*
* @param userId
* @return
*/
@Override
public List<AlbumInfo> getUserAllAlbumList(Long userId) {
//1.构建查询条件
LambdaQueryWrapper<AlbumInfo> queryWrapper = new LambdaQueryWrapper<>();
//1.1 根据用户ID查询
queryWrapper.eq(AlbumInfo::getUserId, userId)
.select(AlbumInfo::getId, AlbumInfo::getAlbumTitle) //1.2 TODO 指定专辑ID, 专辑标题 列查询
.orderByDesc(AlbumInfo::getCreateTime) //1.3 根据创建时间倒序 sql limit 0,200
.last("limit 200"); //1.4 查询200条记录
//2.执行查询
return albumInfoMapper.selectList(queryWrapper);
}
腾讯云点播服务面向音视频、图片等媒体,提供制作上传、存储、转码、媒体处理、媒体 AI、加速分发播放、版权保护等一体化高品质媒体服务。使用腾讯云服务可以为音视频文件的存储、传输、处理和分发提供可靠、高效和安全的解决方案。这可以节省你自己构建和维护存储基础设施的成本和精力,并为用户提供更好的音视频体验。
快速接入流程:云点播 快速入门-文档中心-腾讯云 (tencent.com)
微信扫码登录
关注公众号
搜索云点播
微信认证
实名认证
立即开通服务
右边:点击访问管理
需求:主播录制的音频文件需要上传到腾讯云-云点播云服务器,在声音表
中存储音频文件腾讯云地址。
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/29
准备工作:
在nacos配置中心service-album-dev.yaml
中定义点播服务相关配置信息
vod:
appId: 1255727855 #需要修改为自己的
secretId: AKIDTOFybJvQqCWnDdyDNRQJ54xkT8hBbxCK #需要修改为自己的
secretKey: DKLH87saCmKZowS09IPRLE4pVCqQuKeu #需要修改为自己的
region: ap-beijing #需要修改为自己的
procedure: SimpleAesEncryptPreset #任务流
#tempPath: /root/tingshu/tempPath
tempPath: D:\code\workspace2023\tingshu\temp
playKey: wrTwwu8U3DRSRDgC8l7q #播放加密key
通过配置类读取(已提供)
package com.atguigu.tingshu.album.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@Configuration
@ConfigurationProperties(prefix="vod") //读取节点
@Data
public class VodConstantProperties {
private Integer appId;
private String secretId;
private String secretKey;
//https://cloud.tencent.com/document/api/266/31756#.E5.9C.B0.E5.9F.9F.E5.88.97.E8.A1.A8
private String region;
private String procedure;
private String tempPath;
private String playKey;
}
TrackInfoApiController控制器:
package com.atguigu.tingshu.album.api;
import com.atguigu.tingshu.album.service.TrackInfoService;
import com.atguigu.tingshu.common.result.Result;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import java.util.Map;
@Tag(name = "声音管理")
@RestController
@RequestMapping("api/album")
@SuppressWarnings({"all"})
public class TrackInfoApiController {
@Autowired
private TrackInfoService trackInfoService;
/**
* 上传音视频文件到腾讯云点播服务
*
* @param file
* @return
*/
@Operation(summary = "上传音视频文件到腾讯云点播服务")
@PostMapping("/trackInfo/uploadTrack")
public Result<Map<String, String>> uploadTrack(MultipartFile file) {
Map<String, String> mapResult = trackInfoService.uploadTrack(file);
return Result.ok(mapResult);
}
}
VodService接口
package com.atguigu.tingshu.album.service;
import com.atguigu.tingshu.model.album.TrackInfo;
import com.baomidou.mybatisplus.extension.service.IService;
import org.springframework.web.multipart.MultipartFile;
import java.util.Map;
public interface TrackInfoService extends IService<TrackInfo> {
/**
* 上传音视频文件到腾讯云点播服务
*
* @param file
* @return
*/
Map<String, String> uploadTrack(MultipartFile file);
}
VodServiceImpl实现类 云点播 Java SDK-开发指南-文档中心-腾讯云 (tencent.com) Java 语言实现声音上传功能API
package com.atguigu.tingshu.album.service.impl;
import com.atguigu.tingshu.album.config.VodConstantProperties;
import com.atguigu.tingshu.album.mapper.TrackInfoMapper;
import com.atguigu.tingshu.album.service.TrackInfoService;
import com.atguigu.tingshu.common.util.UploadFileUtil;
import com.atguigu.tingshu.model.album.TrackInfo;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.qcloud.vod.VodUploadClient;
import com.qcloud.vod.model.VodUploadRequest;
import com.qcloud.vod.model.VodUploadResponse;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import java.util.HashMap;
import java.util.Map;
@Slf4j
@Service
@SuppressWarnings({"all"})
public class TrackInfoServiceImpl extends ServiceImpl<TrackInfoMapper, TrackInfo> implements TrackInfoService {
@Autowired
private TrackInfoMapper trackInfoMapper;
@Autowired
private VodConstantProperties props;
/**
* 上传音视频文件到腾讯云点播服务
*
* @param file
* @return
*/
@Override
public Map<String, String> uploadTrack(MultipartFile file) {
try {
//0.将用户提交文件保存到临时目录下
String tempFilePath = UploadFileUtil.uploadTempPath(props.getTempPath(), file);
//1.初始化一个上传客户端对象
VodUploadClient client = new VodUploadClient(props.getSecretId(), props.getSecretKey());
//2.构造上传请求对象
VodUploadRequest request = new VodUploadRequest();
request.setMediaFilePath(tempFilePath);
VodUploadResponse response = client.upload(props.getRegion(), request);
if (response != null) {
//获取到文件地址、文件唯一标识
String mediaUrl = response.getMediaUrl();
String fileId = response.getFileId();
Map<String, String> mapResult = new HashMap<>();
mapResult.put("mediaFileId", fileId);
mapResult.put("mediaUrl", mediaUrl);
return mapResult;
}
return null;
} catch (Exception e) {
log.error("[云点播上传文件失败:]{}", e);
throw new RuntimeException(e);
}
}
}
上传之后可以在:音视频管理 - 媒资管理 - 云点播 - 控制台 (tencent.com)-应用管理-点击主应用-媒资管理-音视频管理看是否有音频
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/31
前端传递Json 字符串,此时我们可以使用封装好的TrackInfoVo实体类进行接收,方便处理数据
涉及到的表:
track_info 声音信息表
track_stat 声音统计表
album_info 专辑表
TrackInfoApiController控制器
/**
* TODO 该接口必须登录后才能访问
* @param trackInfoVo
* @return
*/
@Operation(summary = "新增声音")
@PostMapping("/trackInfo/saveTrackInfo")
public Result saveTrackInfo(@RequestBody @Validated TrackInfoVo trackInfoVo){
//1.获取用户ID
Long userId = AuthContextHolder.getUserId();
//2.调用业务层保存声音
trackInfoService.saveTrackInfo(userId, trackInfoVo);
return Result.ok();
}
TrackInfoService接口
/**
* 新增声音
* @param userId 用户ID
* @param trackInfoVo 声音相关信息
*/
void saveTrackInfo(Long userId, TrackInfoVo trackInfoVo);
/**
* 保存声音统计信息
* @param id
* @param statType
*/
void saveTrackStat(Long id, String statType);
TrackInfoServiceImpl实现类
package com.atguigu.tingshu.album.service.impl;
import cn.hutool.core.bean.BeanUtil;
import com.atguigu.tingshu.album.config.VodConstantProperties;
import com.atguigu.tingshu.album.mapper.AlbumInfoMapper;
import com.atguigu.tingshu.album.mapper.TrackInfoMapper;
import com.atguigu.tingshu.album.mapper.TrackStatMapper;
import com.atguigu.tingshu.album.service.TrackInfoService;
import com.atguigu.tingshu.album.service.VodService;
import com.atguigu.tingshu.common.constant.SystemConstant;
import com.atguigu.tingshu.common.util.UploadFileUtil;
import com.atguigu.tingshu.model.album.AlbumInfo;
import com.atguigu.tingshu.model.album.TrackInfo;
import com.atguigu.tingshu.model.album.TrackStat;
import com.atguigu.tingshu.vo.album.TrackInfoVo;
import com.atguigu.tingshu.vo.album.TrackMediaInfoVo;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.qcloud.vod.VodUploadClient;
import com.qcloud.vod.model.VodUploadRequest;
import com.qcloud.vod.model.VodUploadResponse;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;
@Slf4j
@Service
@SuppressWarnings({"all"})
public class TrackInfoServiceImpl extends ServiceImpl<TrackInfoMapper, TrackInfo> implements TrackInfoService {
@Autowired
private TrackInfoMapper trackInfoMapper;
@Autowired
private VodConstantProperties props;
@Autowired
private AlbumInfoMapper albumInfoMapper;
@Autowired
private VodService vodService;
@Autowired
private TrackStatMapper trackStatMapper;
/**
* 新增声音
* 1.新增声音记录
* 2.更新专辑(专辑包含声音数量)
* 3.初始化声音统计记录
*
* @param userId 用户ID
* @param trackInfoVo 声音相关信息
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void saveTrackInfo(Long userId, TrackInfoVo trackInfoVo) {
//1.新增声音记录
//1.1 将声音VO对象拷贝到声音PO对象
TrackInfo trackInfo = BeanUtil.copyProperties(trackInfoVo, TrackInfo.class);
//1.2 设置用户ID
trackInfo.setUserId(userId);
//1.3 设置状态 默认:通过 实际上应该有审核:机审或者人工审核
trackInfo.setStatus(SystemConstant.TRACK_STATUS_PASS);
//1.4 设置声音来源
trackInfo.setSource(SystemConstant.TRACK_SOURCE_USER);
//1.5 设置声音序号 根据专辑ID查询专辑得到该专辑下已有声音数量
AlbumInfo albumInfo = albumInfoMapper.selectById(trackInfo.getAlbumId());
trackInfo.setOrderNum(albumInfo.getIncludeTrackCount() + 1);
//1.6 设置音频文件相关信息(文件大小,时长,文件类型)-调用腾讯云点播平台接口获取
TrackMediaInfoVo mediaInfoVo = vodService.getTrackMediaInfo(trackInfo.getMediaFileId());
if (mediaInfoVo != null) {
trackInfo.setMediaDuration(BigDecimal.valueOf(mediaInfoVo.getDuration()));
trackInfo.setMediaSize(mediaInfoVo.getSize());
trackInfo.setMediaType(mediaInfoVo.getType());
}
//1.7 保存声音
trackInfoMapper.insert(trackInfo);
//2.更新专辑(专辑包含声音数量)
albumInfo.setIncludeTrackCount(albumInfo.getIncludeTrackCount() + 1);
albumInfoMapper.updateById(albumInfo);
//3.初始化声音统计记录
this.saveTrackStat(trackInfo.getId(), SystemConstant.TRACK_STAT_PLAY);
this.saveTrackStat(trackInfo.getId(), SystemConstant.TRACK_STAT_COLLECT);
this.saveTrackStat(trackInfo.getId(), SystemConstant.TRACK_STAT_PRAISE);
this.saveTrackStat(trackInfo.getId(), SystemConstant.TRACK_STAT_COMMENT);
}
}
初始化统计数据
/**
* 保存声音统计信息
*
* @param id
* @param statType
*/
@Override
public void saveTrackStat(Long id, String statType) {
TrackStat trackStat = new TrackStat();
trackStat.setTrackId(id);
trackStat.setStatType(statType);
trackStat.setStatNum(0);
trackStatMapper.insert(trackStat);
}
获取流媒体数据方法实现 参考地址API Explorer - 云 API - 控制台 (tencent.com)
package com.atguigu.tingshu.album.service.impl;
import com.atguigu.tingshu.album.config.VodConstantProperties;
import com.atguigu.tingshu.album.service.VodService;
import com.atguigu.tingshu.vo.album.TrackMediaInfoVo;
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 lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Slf4j
@Service
public class VodServiceImpl implements VodService {
@Autowired
private VodConstantProperties prop;
/**
* 根据云点播平台文件唯一标识获取媒体文件详情信息
*
* @param mediaFileId
* @return
*/
@Override
public TrackMediaInfoVo getTrackMediaInfo(String mediaFileId) {
try {
// 实例化一个认证对象,入参需要传入腾讯云账户 SecretId 和 SecretKey,此处还需注意密钥对的保密
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露,并威胁账号下所有资源的安全性。以下代码示例仅供参考,建议采用更安全的方式来使用密钥,请参见:https://cloud.tencent.com/document/product/1278/85305
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
Credential cred = new Credential(prop.getSecretId(), prop.getSecretKey());
// 实例化一个http选项,可选的,没有特殊需求可以跳过
VodClient client = new VodClient(cred, "");
// 实例化一个请求对象,每个接口都会对应一个request对象
DescribeMediaInfosRequest req = new DescribeMediaInfosRequest();
String[] fileIds1 = {mediaFileId};
req.setFileIds(fileIds1);
// 返回的resp是一个DescribeMediaInfosResponse的实例,与请求对象对应
DescribeMediaInfosResponse resp = client.DescribeMediaInfos(req);
// 输出json格式的字符串回包
if (resp != null && resp.getMediaInfoSet().length > 0) {
//获取第一个媒体文件信息
MediaInfo mediaInfo = resp.getMediaInfoSet()[0];
MediaBasicInfo basicInfo = mediaInfo.getBasicInfo();
MediaMetaData metaData = mediaInfo.getMetaData();
TrackMediaInfoVo vo = new TrackMediaInfoVo();
vo.setSize(metaData.getSize());
vo.setDuration(metaData.getDuration());
vo.setType(basicInfo.getType());
return vo;
}
} catch (Exception e) {
log.error("获取云点播平台资源信息异常:{}", e);
}
return null;
}
}
功能入口:运行小程序-->我的-->创作中心-->声音-->查询当前用户的声音列表,如下图所示:
查询分析:需要根据用户Id,状态或标题查询当前声音列表!这三个条件被封装到一个实体类中 TrackInfoQuery,返回结果对象封装到 TrackListVo 实体类中
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/33
TrackInfoApiController 控制器
/**
* TODO 必须登录才可以访问
* 获取当前登录声音分页列表
*
* @param page 页码
* @param limit 页大小
* @param trackInfoQuery 查询条件
* @return
*/
@Operation(summary = "获取当前登录声音分页列表")
@PostMapping("/trackInfo/findUserTrackPage/{page}/{limit}")
public Result<Page<TrackListVo>> getUserTrackByPage(@PathVariable int page, @PathVariable int limit, @RequestBody TrackInfoQuery trackInfoQuery) {
//1.获取用户ID
Long userId = AuthContextHolder.getUserId();
//2.封装分页查询对象
trackInfoQuery.setUserId(userId);
//3.调用业务层进行分页
Page<TrackListVo> PageInfo = new Page<>(page, limit);
PageInfo = trackInfoService.getUserTrackByPage(PageInfo, trackInfoQuery);
return Result.ok(PageInfo);
}
TrackInfoService接口
/**
* 获取当前登录声音分页列表
* @param pageInfo MP分页对象
* @param trackInfoQuery 查询声音条件对象
* @return
*/
Page<TrackListVo> getUserTrackByPage(Page<TrackListVo> pageInfo, TrackInfoQuery trackInfoQuery);
TrackInfoServiceImpl实现类
/**
* 获取当前登录声音分页列表
* @param pageInfo MP分页对象
* @param trackInfoQuery 查询声音条件对象
* @return
*/
@Override
public Page<TrackListVo> getUserTrackByPage(Page<TrackListVo> pageInfo, TrackInfoQuery trackInfoQuery) {
return trackInfoMapper.getUserTrackByPage(pageInfo, trackInfoQuery);
}
TrackInfoMapper接口
package com.atguigu.tingshu.album.mapper;
import com.atguigu.tingshu.model.album.TrackInfo;
import com.atguigu.tingshu.query.album.TrackInfoQuery;
import com.atguigu.tingshu.vo.album.TrackListVo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@Mapper
public interface TrackInfoMapper extends BaseMapper<TrackInfo> {
/**
* MP框架发现参数中包含分页对象,自动完成分页查询(自动查询总记录数,总页数,当前页数据自动封装到Page对象中)
* @param pageInfo
* @param trackInfoQuery
* @return
*/
Page<TrackListVo> getUserTrackByPage(Page<TrackListVo> pageInfo, @Param("vo") TrackInfoQuery trackInfoQuery);
}
SQL实现:
select
info.trackId,
info.track_title,
info.cover_url,
info.media_duration,
info.album_id,
info.status,
info.create_time,
max(if(info.stat_type='0701',info.stat_num,0)) playStatNum,
max(if(info.stat_type='0702',info.stat_num,0)) collectStatNum,
max(if(info.stat_type='0703',info.stat_num,0)) praiseStatNum,
max(if(info.stat_type='0704',info.stat_num,0)) albumCommentStatNum
from (select ti.id trackId,
ti.track_title,
ti.cover_url,
ti.media_duration,
ti.album_id,
ti.status,
ti.create_time,
ts.stat_type,
ts.stat_num
from track_info ti
left join track_stat ts on ts.track_id = ti.id
where ti.user_id = ?
and ti.status = '0501'
and ti.track_title like concat('%', '遮', '%')
and ti.is_deleted = 0
) info
group by info.trackId
order by info.create_time desc;
TrackInfoMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.atguigu.tingshu.album.mapper.TrackInfoMapper">
<select id="getUserTrackByPage" resultType="com.atguigu.tingshu.vo.album.TrackListVo">
select
info.trackId,
info.track_title,
info.cover_url,
info.media_duration,
info.album_id,
info.status,
info.create_time,
max(if(info.stat_type='0701',info.stat_num,0)) playStatNum,
max(if(info.stat_type='0702',info.stat_num,0)) collectStatNum,
max(if(info.stat_type='0703',info.stat_num,0)) praiseStatNum,
max(if(info.stat_type='0704',info.stat_num,0)) albumCommentStatNum
from (select ti.id trackId,
ti.track_title,
ti.cover_url,
ti.media_duration,
ti.album_id,
ti.status,
ti.create_time,
ts.stat_type,
ts.stat_num
from track_info ti
left join track_stat ts on ts.track_id = ti.id
<where>
<if test="vo.userId!=null">
and ti.user_id = #{vo.userId}
</if>
<if test="vo.status!=null and vo.status!=''">
and ti.status = #{vo.status}
</if>
<if test="vo.trackTitle!=null and vo.trackTitle!=''">
and ti.track_title like concat('%',#{vo.trackTitle},'%')
</if>
and ti.is_deleted = 0
</where>
) info
group by info.trackId
order by info.create_time desc
</select>
</mapper>
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/35
TrackInfoApiController控制器
/**
* 根据声音ID查询声音信息
*
* @param id
* @return
*/
@Operation(summary = "根据声音ID查询声音信息")
@GetMapping("/trackInfo/getTrackInfo/{id}")
public Result<TrackInfo> getTrackInfo(@PathVariable Long id) {
TrackInfo trackInfo = trackInfoService.getById(id);
return Result.ok(trackInfo);
}
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/37
TrackInfoApiController控制器
传递声音Id ,封装好的TrackInfoVo 实体类。
/**
* 修改声音信息
* @param id
* @param trackInfoVo
* @return
*/
@Operation(summary = "修改声音信息")
@PutMapping("/trackInfo/updateTrackInfo/{id}")
public Result updateTrackInfo(@PathVariable Long id, @RequestBody @Validated TrackInfoVo trackInfoVo){
trackInfoService.updateTrackInfo(id, trackInfoVo);
return Result.ok();
}
TrackInfoService接口
/**
* 修改声音信息
* @param id 声音ID
* @param trackInfoVo 变更后声音信息vo
*/
void updateTrackInfo(Long id, TrackInfoVo trackInfoVo);
TrackInfoServiceImpl实现类
/**
* 修改声音信息
*
* @param id 声音ID
* @param trackInfoVo 变更后声音信息vo
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void updateTrackInfo(Long id, TrackInfoVo trackInfoVo) {
//1.先获取声音信息-得到更新前声音文件唯一标识
TrackInfo trackInfo = trackInfoMapper.selectById(id);
String mediaFileId = trackInfo.getMediaFileId();
BeanUtil.copyProperties(trackInfoVo, trackInfo);
//2.调用腾讯云点播获取声音媒体信息(时长,类型,文件大小) 更新媒体信息
if (!mediaFileId.equals(trackInfo.getMediaFileId())) {
TrackMediaInfoVo trackMediaInfo = vodService.getTrackMediaInfo(trackInfo.getMediaFileId());
trackInfo.setMediaType(trackMediaInfo.getType());
trackInfo.setMediaSize(trackMediaInfo.getSize());
trackInfo.setMediaDuration(BigDecimal.valueOf(trackMediaInfo.getDuration()));
}
//3.更新声音信息表
trackInfoMapper.updateById(trackInfo);
}
涉及的表: track_info,album_info,track_stat,media
YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/39
TrackInfoApiController控制器
/**
* 根据声音ID删除声音
* @param id
* @return
*/
@Operation(summary = "根据声音ID删除声音")
@DeleteMapping("/trackInfo/removeTrackInfo/{id}")
public Result removeTrackInfo(@PathVariable Long id){
trackInfoService.removeTrackInfo(id);
return Result.ok();
}
TrackInfoService接口:
/**
* 根据声音ID删除声音
* @param id
* @return
*/
void removeTrackInfo(Long id);
TrackInfoServiceImpl实现类
/**
* 根据声音ID删除声音
* 0.更新当前专辑中声音序号
* 1.删除声音表记录
* 2.删除声音统计记录
* 3.更新专辑表中包含声音数量
* 4.将云点播平台的声音删除
* <p>
* id name orderNum
* 1 a 1
* 2 b 2 (删除该声音)
* 3 c 3
* 4 d 4
*
* @param id
* @return
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void removeTrackInfo(Long id) {
//1.更新声音表中序号(更新当前声音以后声音需要即可)
//1.1 根据ID查询当前删除声音信息
TrackInfo trackInfo = trackInfoMapper.selectById(id);
Integer orderNum = trackInfo.getOrderNum();
//1.2 更新该专辑下当前声音以后序号-1: update track_info set order_num = order_num-1 where album_id =? and order_num>?
trackInfoMapper.updateTrackNum(trackInfo.getAlbumId(), orderNum);
//2.删除声音表记录
trackInfoMapper.deleteById(id);
//3.删除声音统计记录
LambdaUpdateWrapper<TrackStat> trackStatLambdaUpdateWrapper = new LambdaUpdateWrapper<>();
trackStatLambdaUpdateWrapper.eq(TrackStat::getTrackId, id);
trackStatMapper.delete(trackStatLambdaUpdateWrapper);
//4.更新专辑表中包含声音数量
AlbumInfo albumInfo = albumInfoMapper.selectById(trackInfo.getAlbumId());
albumInfo.setIncludeTrackCount(albumInfo.getIncludeTrackCount() - 1);
albumInfoMapper.updateById(albumInfo);
//5.将云点播平台的声音删除
vodService.deleteTrackMedia(trackInfo.getMediaFileId());
}
VodService接口与实现类
/**
* 删除云点播平台文件
* @param mediaFileId
*/
void deleteTrackMedia(String mediaFileId);
TrackInfoMapper
/**
* 批量修改声音序号
* @param albumId
* @param orderNum
*/
@Update("update track_info set order_num = order_num-1 where album_id = #{albumId} and order_num > #{orderNum} and is_deleted = 0")
void updateTrackNum(@Param("albumId") Long albumId, @Param("orderNum") Integer orderNum);
API Explorer - 云 API - 控制台 (tencent.com)
/**
* 删除云点播平台文件
*
* @param mediaFileId
*/
@Override
public void deleteTrackMedia(String mediaFileId) {
try {
// 实例化一个认证对象,入参需要传入腾讯云账户 SecretId 和 SecretKey,此处还需注意密钥对的保密
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露,并威胁账号下所有资源的安全性。以下代码示例仅供参考,建议采用更安全的方式来使用密钥,请参见:https://cloud.tencent.com/document/product/1278/85305
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
Credential cred = new Credential(prop.getSecretId(), prop.getSecretKey());
// 实例化一个http选项,可选的,没有特殊需求可以跳过
HttpProfile httpProfile = new HttpProfile();
httpProfile.setEndpoint("vod.tencentcloudapi.com");
// 实例化一个client选项,可选的,没有特殊需求可以跳过
ClientProfile clientProfile = new ClientProfile();
clientProfile.setHttpProfile(httpProfile);
// 实例化要请求产品的client对象,clientProfile是可选的
VodClient client = new VodClient(cred, "", clientProfile);
// 实例化一个请求对象,每个接口都会对应一个request对象
DeleteMediaRequest req = new DeleteMediaRequest();
req.setFileId(mediaFileId);
// 返回的resp是一个DeleteMediaResponse的实例,与请求对象对应
DeleteMediaResponse resp = client.DeleteMedia(req);
// 输出json格式的字符串回包
log.info(DeleteMediaResponse.toJsonString(resp));
} catch (Exception e) {
log.error("【专辑服务】删除元点播媒体文件异常:{}", e);
}
}