管理数据库实体删除时本地文件同步清除的策略

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.beans.factory.annotation.Autowired;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.io.IOException;
import javax.persistence.EntityNotFoundException;

@Service
public class ChannelService {

    @Autowired
    private ChannelRepository channelRepository; // 假设这是你的JPA Repository

    @Autowired
    private FileStorageService fileStorageService; // 自定义的文件存储服务

    /**
     * 删除频道及其关联的头像文件。
     * 整个操作在一个事务中进行，确保原子性。
     *
     * @param channelId 待删除频道的ID
     * @throws EntityNotFoundException 如果频道不存在
     * @throws RuntimeException 如果文件删除失败
     */
    @Transactional
    public void deleteChannelAndAvatar(Long channelId) {
        // 1. 查找频道实体以获取头像路径
        Channel channel = channelRepository.findById(channelId)
                                          .orElseThrow(() -> new EntityNotFoundException("Channel with ID " + channelId + " not found."));

        String avatarPath = channel.getAvatarPath();

        // 2. 删除数据库中的频道实体
        channelRepository.deleteById(channelId);

        // 3. 删除本地文件系统中的头像文件
        if (avatarPath != null && !avatarPath.isEmpty()) {
            try {
                fileStorageService.deleteFile(avatarPath);
            } catch (IOException e) {
                // 如果文件删除失败，抛出运行时异常，事务将回滚
                // 数据库实体删除也将被撤销，确保数据一致性
                throw new RuntimeException("Failed to delete avatar file for channel ID " + channelId + ": " + avatarPath, e);
            }
        }
    }
}

// 假设有一个文件存储服务接口或类
@Service
class FileStorageService {
    public void deleteFile(String filePath) throws IOException {
        Path path = Paths.get(filePath);
        // Files.deleteIfExists() 会在文件不存在时返回 false 而不抛异常
        if (!Files.deleteIfExists(path)) {
            // 如果文件存在但无法删除，或者路径无效，Files.deleteIfExists() 可能会抛出 IOException
            // 否则，如果文件不存在，它只是返回 false。这里我们假设如果返回 false 且文件确实存在，则删除失败。
            // 更严谨的检查可能需要 Files.exists(path) 配合。
            // 为了简化，这里直接捕获可能由 deleteIfExists 抛出的 IOException。
            System.err.println("Warning: File not found or could not be deleted: " + filePath);
        }
    }
}

// 假设的Channel实体类
// public class Channel {
//     private Long id;
//     private String name;
//     private String avatarPath; // 存储头像的本地路径
//     // getters and setters
// }