Java REST API中无本地文件路径处理ZIP文件内容

import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;

@RestController
public class ZipFileUploadController {

    /**
     * 处理上传的ZIP文件，直接从输入流读取内容并进行处理，不写入本地文件系统。
     *
     * @param file 上传的ZIP文件
     * @return 处理结果的ResponseEntity
     */
    @PostMapping("/import/zip")
    public ResponseEntity<String> uploadZipFileAndProcess(@RequestParam("file") MultipartFile file) {
        if (file.isEmpty()) {
            return ResponseEntity.badRequest().body("上传文件为空。");
        }

        // 确保上传的是ZIP文件（可选，可以通过文件名或内容类型判断）
        if (!file.getOriginalFilename().toLowerCase().endsWith(".zip")) {
            return ResponseEntity.badRequest().body("请上传ZIP格式的文件。");
        }

        try (ZipInputStream zis = new ZipInputStream(file.getInputStream())) {
            ZipEntry zipEntry;
            // 遍历ZIP文件中的每一个条目
            while ((zipEntry = zis.getNextEntry()) != null) {
                // 跳过目录条目
                if (zipEntry.isDirectory()) {
                    System.out.println("跳过目录: " + zipEntry.getName());
                    continue;
                }

                // 处理文件条目
                System.out.println("正在处理文件: " + zipEntry.getName());

                // 示例：将文件内容作为文本读取并打印。
                // 对于二进制文件，您可以直接读取字节流。
                try (BufferedReader reader = new BufferedReader(new InputStreamReader(zis, StandardCharsets.UTF_8))) {
                    String line;
                    StringBuilder fileContent = new StringBuilder();
                    while ((line = reader.readLine()) != null) {
                        fileContent.append(line).append(System.lineSeparator());
                        // 在这里，您可以对每一行内容进行处理，例如解析CSV、JSON，然后保存到数据库。
                        // System.out.println("内容行: " + line); // 打印每一行
                    }
                    // 假设将整个文件内容保存到数据库
                    saveToDatabase(zipEntry.getName(), fileContent.toString());
                }
                // zis.closeEntry() 在 getNextEntry() 被调用时或 ZipInputStream 关闭时自动处理
            }
            return ResponseEntity.ok("ZIP文件已成功处理，未进行本地存储。");
        } catch (IOException e) {
            System.err.println("处理ZIP文件时发生错误: " + e.getMessage());
            e.printStackTrace();
            return ResponseEntity.internalServerError().body("处理ZIP文件时发生错误: " + e.getMessage());
        } catch (Exception e) {
            System.err.println("未知错误: " + e.getMessage());
            e.printStackTrace();
            return ResponseEntity.internalServerError().body("未知错误: " + e.getMessage());
        }
    }

    /**
     * 模拟将文件内容保存到数据库的方法。
     * 实际应用中，您会在这里集成您的数据访问层。
     *
     * @param fileName    ZIP文件中的文件名
     * @param fileContent 文件内容
     */
    private void saveToDatabase(String fileName, String fileContent) {
        // 实际的数据库持久化逻辑将在此处实现
        System.out.println("将文件 '" + fileName + "' 的内容保存到数据库...");
        // 例如: someService.saveFileEntry(fileName, fileContent);
        // 为了演示，这里只打印内容的前100个字符
        System.out.println("保存内容示例 (前100字符): " + (fileContent.length() > 100 ? fileContent.substring(0, 100) + "..." : fileContent));
    }
}