fix: 个人库删除文件夹及模型时删除oss对应文件释放空间

src/main/java/com/lqkj/link/module/zone/repository/ModelInfoRepository.java

@@ -40,4 +40,5 @@ public interface ModelInfoRepository extends JpaRepository<ModelInfo, Integer> {
     )
     void deleteAllByTemplateIds(@Param("templateIds") List<Integer> templateIds);
 
+    List<ModelInfo> findByCategoryIdIn(List<Integer> categoryId);
 }

src/main/java/com/lqkj/link/module/zone/service/ResourceService.java

@@ -122,16 +122,28 @@ public class ResourceService {
     }
 
     public void deleteModel(Integer modelId) {
+        ModelInfo modelInfo = infoRepository.findById(modelId).get();
         infoRepository.deleteById(modelId);
+        aliOSSUtils.deleteModel(modelInfo.getOriginalPath());
     }
 
     @Transactional
     public void deleteCategory(List<Integer> categoryId) {
+        deleteOssFiles(categoryId);
         categoryRepository.deleteAllByIdInBatch(categoryId);
         // 更新用户资源刷新状态
         userInfoRepository.updateRefreshStatus();
     }
 
+    /**
+     * 删除oss文件
+     *
+     * @param categoryId
+     */
+    private void deleteOssFiles(List<Integer> categoryId) {
+        infoRepository.findByCategoryIdIn(categoryId).forEach(modelInfo -> aliOSSUtils.deleteModel(modelInfo.getOriginalPath()));
+    }
+
     public List<Map<String, Object>> resourceCategory(String userCode) {
         return categoryRepository.queryWithUserCode(userCode);
     }

src/main/java/com/lqkj/link/util/AliOSSUtils.java

@@ -123,5 +123,10 @@ public class AliOSSUtils {
         return size;
     }
 
+    public void deleteModel(String path) {
+        OSS ossClient = new OSSClientBuilder().build(aliProperties.getEndpoint(), aliProperties.getAccessKeyId(), aliProperties.getAccessKeySecret());
+        String prefix = aliProperties.getOsspath().split("//")[0] + "//" + aliProperties.getBucketName() + "." + aliProperties.getOsspath().split("//")[1] + "/";
+        ossClient.deleteObject(aliProperties.getBucketName(), path.replace(prefix, ""));
+    }
 
 }