Merge remote-tracking branch 'origin/dev' into dev

nightFragrance-massage/src/main/java/com/ylx/massage/service/TbFileService.java

@@ -6,6 +6,8 @@ import com.ylx.common.core.domain.AjaxResult;
 import com.ylx.massage.domain.TbFile;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.util.List;
+
 /**
  * (TbFile)表服务接口
  *
@@ -14,7 +16,7 @@ import org.springframework.web.multipart.MultipartFile;
  */
 public interface TbFileService extends IService<TbFile> {
 
-    TbFile getByMd5(String md5);
+    List<TbFile> getByMd5(String md5);
 
     /**
      * 上传文件（普通的图片文件）

nightFragrance-massage/src/main/java/com/ylx/massage/service/impl/TbFileServiceImpl.java

@@ -4,8 +4,10 @@ import cn.hutool.crypto.digest.DigestUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ylx.common.constant.Constants;
 import com.ylx.common.config.RuoYiConfig;
 import com.ylx.common.core.domain.AjaxResult;
+import com.ylx.common.utils.StringUtils;
 import com.ylx.common.utils.file.FileUploadUtils;
 import com.ylx.common.utils.file.FileUtils;
 import com.ylx.framework.config.ServerConfig;
@@ -27,8 +29,10 @@ import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.ArrayList;
+import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
@@ -85,10 +89,10 @@ public class TbFileServiceImpl extends ServiceImpl<TbFileMapper, TbFile> impleme
      * @return 如果找到匹配的文件记录则返回该记录，否则返回 null
      */
     @Override
-    public TbFile getByMd5(String md5) {
+    public List<TbFile> getByMd5(String md5) {
         LambdaQueryWrapper<TbFile> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(TbFile::getMd5, md5);
-        return this.getOne(queryWrapper);
+        queryWrapper.eq(TbFile::getMd5, md5).orderByDesc(TbFile::getCreateTime);
+        return this.list(queryWrapper);
     }
 
     /**
@@ -114,14 +118,14 @@ public class TbFileServiceImpl extends ServiceImpl<TbFileMapper, TbFile> impleme
             // 计算文件 MD5 值
             String md5 = calculateMD5(file);
             // 检查是否已存在相同文件（通过MD5去重）
-            TbFile dbFile = this.getByMd5(md5);
-            if (null != dbFile) {
+            List<TbFile> dbFiles = this.getByMd5(md5);
+            if (null != dbFiles && !dbFiles.isEmpty()) {
                 // 文件已存在，直接返回已有文件的访问信息（秒传）
-                ajax.put("url", dbFile.getFileUrl());
-                ajax.put("newFileName", FileUtils.getName(dbFile.getFileUrl()));
-                ajax.put("originalFilename", dbFile.getFileName());
+                ajax.put("url", dbFiles.get(0).getFileUrl());
+                ajax.put("newFileName", FileUtils.getName(dbFiles.get(0).getFileUrl()));
+                ajax.put("originalFilename", dbFiles.get(0).getFileName());
                 // 封面图URL路径(针对视频文件)
-                ajax.put("coverUrl", dbFile.getCoverUrl());
+                ajax.put("coverUrl", dbFiles.get(0).getCoverUrl());
                 return ajax;
             }
 
@@ -191,14 +195,9 @@ public class TbFileServiceImpl extends ServiceImpl<TbFileMapper, TbFile> impleme
             // 计算文件 MD5 值
             String md5 = calculateMD5(file);
             // 检查是否已存在相同文件（通过 MD5 去重）
-            TbFile dbFile = this.getByMd5(md5);
-            if (null != dbFile) {
-                // 文件已存在，直接返回已有文件的访问信息（秒传）
-                ajax.put("url", dbFile.getFileUrl());
-                ajax.put("fileName", dbFile.getFileUrl());
-                ajax.put("newFileName", FileUtils.getName(dbFile.getFileUrl()));
-                ajax.put("originalFilename", dbFile.getFileName());
-                return ajax;
+            List<TbFile> dbFiles = this.getByMd5(md5);
+            if (null != dbFiles && !dbFiles.isEmpty()) {
+                deleteExistingSameFiles(dbFiles);
             }
 
             // 文件不存在，上传新文件
@@ -226,11 +225,66 @@ public class TbFileServiceImpl extends ServiceImpl<TbFileMapper, TbFile> impleme
             this.save(tbFile);
             return ajax;
         } catch (Exception e) {
+            e.printStackTrace();
             // 上传失败，返回错误信息
             return AjaxResult.error(e.getMessage());
         }
     }
 
+    private void deleteExistingSameFiles(List<TbFile> dbFiles) {
+        if (dbFiles == null || dbFiles.isEmpty()) {
+            return;
+        }
+
+        Set<String> fileUrls = new LinkedHashSet<>();
+        List<String> ids = new ArrayList<>();
+        String md5 = null;
+        for (TbFile dbFile : dbFiles) {
+            if (dbFile == null) {
+                continue;
+            }
+            if (StringUtils.isNotEmpty(dbFile.getFileUrl())) {
+                fileUrls.add(dbFile.getFileUrl());
+            }
+            if (StringUtils.isNotEmpty(dbFile.getId())) {
+                ids.add(dbFile.getId());
+            }
+            if (StringUtils.isEmpty(md5) && StringUtils.isNotEmpty(dbFile.getMd5())) {
+                md5 = dbFile.getMd5();
+            }
+        }
+
+        for (String fileUrl : fileUrls) {
+            deleteLocalProfileFile(fileUrl);
+        }
+
+        if (StringUtils.isNotEmpty(md5)) {
+            LambdaQueryWrapper<TbFile> queryWrapper = new LambdaQueryWrapper<>();
+            queryWrapper.eq(TbFile::getMd5, md5);
+            this.remove(queryWrapper);
+            return;
+        }
+
+        if (!ids.isEmpty()) {
+            this.removeByIds(ids);
+        }
+    }
+
+    private void deleteLocalProfileFile(String fileUrl) {
+        if (StringUtils.isEmpty(fileUrl) || !fileUrl.startsWith(Constants.RESOURCE_PREFIX)) {
+            return;
+        }
+        String profile = RuoYiConfig.getProfile();
+        if (StringUtils.isEmpty(profile)) {
+            log.warn("文件根路径未配置，跳过删除旧文件，fileUrl={}", fileUrl);
+            return;
+        }
+        String localPath = profile + StringUtils.substringAfter(fileUrl, Constants.RESOURCE_PREFIX);
+        if (!FileUtils.deleteFile(localPath)) {
+            log.warn("旧文件不存在或删除失败，localPath={}", localPath);
+        }
+    }
+
     /**
      * 生成封面图片文件到指定路径
      * <p>