xuecheng-plus-project148.zip

package com.xuecheng.media.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.j256.simplemagic.ContentInfo; import com.j256.simplemagic.ContentInfoUtil; import com.xuecheng.base.exception.XueChengPlusException; import com.xuecheng.base.model.PageParams; import com.xuecheng.base.model.PageResult; import com.xuecheng.base.model.RestResponse; import com.xuecheng.media.mapper.MediaFilesMapper; import com.xuecheng.media.mapper.MediaProcessMapper; import com.xuecheng.media.model.dto.QueryMediaParamsDto; import com.xuecheng.media.model.dto.UploadFileParamsDto; import com.xuecheng.media.model.dto.UploadFileResultDto; import com.xuecheng.media.model.po.MediaFiles; import com.xuecheng.media.model.po.MediaProcess; import com.xuecheng.media.service.MediaFileService; import io.minio.*; import lombok.extern.slf4j.Slf4j; import org.apache.commons.codec.digest.DigestUtils; import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.MediaType; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.io.*; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.util.Collections; import java.util.Comparator; import java.util.Date; import java.util.List; /** * @author Mr.M * @version 1.0 * @description TODO * @date 2022/9/10 8:58 */ @Slf4j @Service public class MediaFileServiceImpl implements MediaFileService { @Autowired MediaFilesMapper mediaFilesMapper; @Autowired MediaProcessMapper mediaProcessMapper; @Autowired MinioClient minioClient; //普通文件存储的桶 @Value("${minio.bucket.files}") private String bucket_files; //视频文件存储的桶 @Value("${minio.bucket.videofiles}") private String bucket_videofiles; @Autowired MediaFileService currentProxy; @Override public PageResult<MediaFiles> queryMediaFiels(Long companyId, PageParams pageParams, QueryMediaParamsDto queryMediaParamsDto) { //构建查询条件对象 LambdaQueryWrapper<MediaFiles> queryWrapper = new LambdaQueryWrapper<>(); //分页对象 Page<MediaFiles> page = new Page<>(pageParams.getPageNo(), pageParams.getPageSize()); // 查询数据内容获得结果 Page<MediaFiles> pageResult = mediaFilesMapper.selectPage(page, queryWrapper); // 获取数据列表 List<MediaFiles> list = pageResult.getRecords(); // 获取数据总数 long total = pageResult.getTotal(); // 构建结果集 PageResult<MediaFiles> mediaListResult = new PageResult<>(list, total, pageParams.getPageNo(), pageParams.getPageSize()); return mediaListResult; } @Override public UploadFileResultDto uploadFile(Long companyId, UploadFileParamsDto uploadFileParamsDto, byte[] bytes, String folder, String objectName) { //得到文件的md5值 String fileMd5 = DigestUtils.md5Hex(bytes); if (StringUtils.isEmpty(folder)) { //自动生成目录的路径 按年月日生成， folder = getFileFolder(new Date(), true, true, true); } else if (folder.indexOf("/") < 0) { folder = folder + "/"; } //文件名称 String filename = uploadFileParamsDto.getFilename(); if (StringUtils.isEmpty(objectName)) { //如果objectName为空，使用文件的md5值为objectName objectName = fileMd5 + filename.substring(filename.lastIndexOf(".")); } objectName = folder + objectName; try { addMediaFilesToMinIO(bytes, bucket_files, objectName); MediaFiles mediaFiles = currentProxy.addMediaFilesToDb(companyId, fileMd5, uploadFileParamsDto, bucket_files, objectName); //准备返回数据 UploadFileResultDto uploadFileResultDto = new UploadFileResultDto(); BeanUtils.copyProperties(mediaFiles, uploadFileResultDto); return uploadFileResultDto; } catch (Exception e) { log.debug("上传文件失败：{}", e.getMessage()); throw new RuntimeException(e.getMessage()); } // return null; } // @Override // public UploadFileResultDto uploadFile(Long companyId, UploadFileParamsDto uploadFileParamsDto, byte[] bytes, String folder, String objectName) { // // // //得到文件的md5值 // String fileMd5 = DigestUtils.md5Hex(bytes); // // if(StringUtils.isEmpty(folder)){ // //自动生成目录的路径 按年月日生成， // folder = getFileFolder(new Date(), true, true, true); // }else if(folder.indexOf("/")<0){ // folder = folder+"/"; // } // //文件名称 // String filename = uploadFileParamsDto.getFilename(); // // if(StringUtils.isEmpty(objectName)){ // //如果objectName为空，使用文件的md5值为objectName // objectName = fileMd5 + filename.substring(filename.lastIndexOf(".")); // } // // objectName = folder + objectName; // // try { // ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes); // String contentType = uploadFileParamsDto.getContentType(); // // PutObjectArgs putObjectArgs = PutObjectArgs.builder() // .bucket(bucket_files) // .object(objectName) // //InputStream stream, long objectSize 对象大小, long partSize 分片大小(-1表示5M,最大不要超过5T，最多10000) // .stream(byteArrayInputStream, byteArrayInputStream.available(), -1) // .contentType(contentType) // .build(); // //上传到minio // minioClient.putObject(putObjectArgs); // // //保存到数据库 // MediaFiles mediaFiles = mediaFilesMapper.selectById(fileMd5); // if(mediaFiles == null){ // mediaFiles = new MediaFiles(); // // //封装数据 // BeanUtils.copyProperties(uploadFileParamsDto,mediaFiles); // mediaFiles.setId(fileMd5); // mediaFiles.setFileId(fileMd5); // mediaFiles.setCompanyId(companyId); // mediaFiles.setFilename(filename); // mediaFiles.setBucket(bucket_files); // mediaFiles.setFilePath(objectName); // mediaFiles.setUrl("/"+bucket_files+"/"+objectName); // mediaFiles.setCreateDate(LocalDateTime.now()); // mediaFiles.setStatus("1"); // mediaFiles.setAuditStatus("002003"); // // //插入文件表 // mediaFilesMapper.insert(mediaFiles); // // } // // //准备返回数据 // UploadFileResultDto uploadFileResultDto = new UploadFileResultDto(); // BeanUtils.copyProperties(mediaFiles,uploadFileResultDto); // return uploadFileResultDto; // // // } catch (Exception e) { // log.debug("上传文件失败：{}",e.getMessage()); // } // // return null; // } /** * @param companyId * @param fileId * @param uploadFileParamsDto * @param bucket * @param objectName * @return com.xuecheng.media.model.po.MediaFiles * @description 将文件信息入库 * @author Mr.M * @date 2022/