第2章 声音管理.md 32 KB

谷粒随享

第2章 声音管理

学习目标:

  • 声音相关业务流程
  • 新增声音(音视频文件上传到腾讯云点播服务)
  • 修改声音
  • 删除声音

1、新增声音

功能入口:运行小程序-->我的-->创作中心-->声音-->点击 + 添加声音

业务需求:当创作者新增专辑后,创作者将自己录制的音视频文件保存到声音。

  • 选择声音所属专辑
  • 设置声音封面
  • 选择本地录制好音频文件上传
  • 用户填写其他信息(声音标题、声音简介、是否公开)
  • 提交表单完成声音新增

1.1 获取用户专辑列表

需求:点击添加声音的时候会触发一个查询所有专辑列表,主要目的是为了让专辑与声音进行挂钩!

主要是根据userId,查询专辑Id 与专辑标题,然后按照专辑Id 进行降序排列。

image-20231010091237839

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);
}

1.2 上传声音到点播服务

腾讯云点播服务面向音视频、图片等媒体,提供制作上传、存储、转码、媒体处理、媒体 AI、加速分发播放、版权保护等一体化高品质媒体服务。使用腾讯云服务可以为音视频文件的存储、传输、处理和分发提供可靠、高效和安全的解决方案。这可以节省你自己构建和维护存储基础设施的成本和精力,并为用户提供更好的音视频体验。

  1. 可靠性和可用性: 腾讯云提供高可靠性的存储服务,确保音视频文件的安全和持久保存。腾讯云具有跨多个地理区域和数据中心的数据冗余备份,以确保数据的高可用性和容灾能力。
  2. 扩展性和弹性: 腾讯云提供高度可扩展的存储解决方案,可以根据需要轻松扩展存储容量,适应不断增长的音视频数据需求。你可以根据实际情况动态调整存储空间,并随时新增或删除文件。
  3. 快速传输和低延迟: 腾讯云拥有全球范围的网络基础设施,可以提供快速的音视频文件上传和下载速度,同时降低传输延迟,使用户能够更快速地访问和共享文件。
  4. 安全性和权限控制: 腾讯云提供多层次的安全机制来保护用户的音视频文件。你可以使用腾讯云提供的身份验证和权限控制功能确保只有授权用户才能访问和管理文件。此外,腾讯云也提供数据加密和防止盗链等功能,以增强音视频文件的安全性。
  5. 多媒体处理和分发: 腾讯云提供了丰富的多媒体处理和分发服务,可以对上传的音视频文件进行转码、截图、剪辑等处理,并提供内容分发网络(CDN)加速服务,使用户能够高效地将音视频内容传送到全球各地的用户。

快速接入流程:云点播 快速入门-文档中心-腾讯云 (tencent.com)

  • 微信扫码登录

  • 关注公众号

  • 搜索云点播

  • 微信认证

  • 实名认证

  • 立即开通服务

  • 右边:点击访问管理

需求:主播录制的音频文件需要上传到腾讯云-云点播云服务器,在声音表中存储音频文件腾讯云地址。

YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/29

准备工作:

  1. 应用管理导航菜单获取APPID

image-20231010095600292

  1. 访问管理新建用户,分配点播服务权限

    image-20231010095827697

image-20231010100059988

image-20231010100134657

  1. 进入用户详情,获取秘钥

image-20231010100320526

  1. 在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
    
  2. 通过配置类读取(已提供)

    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)-应用管理-点击主应用-媒资管理-音视频管理看是否有音频

1.3 保存声音

YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/31

前端传递Json 字符串,此时我们可以使用封装好的TrackInfoVo实体类进行接收,方便处理数据

涉及到的表:

  • track_info 声音信息表

    • user_id、order_num、media_duration、media_size、media_type、source status 需要手动设置数据
    • user_id : 直接从工具类中获取(TODO暂时用固定用户ID
    • order_num : 声音在专辑中的排序值,从1开始依次递增,值越小排序越前,根据专辑Id上一条声音的排序值 并且按照声音Id 进行降序排列 并且获取第一条数.
    • media_duration media_size:根据流媒体Id获取到数据并赋值!
    • source status : 自己设置
  • 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;
    }
}

2、查询声音列表

功能入口:运行小程序-->我的-->创作中心-->声音-->查询当前用户的声音列表,如下图所示:

image-20231010150001125

查询分析:需要根据用户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>

3、修改声音

3.1 回显声音列表

YAPI接口地址:http://192.168.200.6:3000/project/11/interface/api/35

  1. 根据Id获取数据并回显
  2. 保存修改之后的数据

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);
}

3.2 修改声音

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);
}

4、删除声音

涉及的表: 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);
    }
}