Method save_file

core/storage.py:1079–1117

保存文件（自动创建目录，流式上传）

(self, file: UploadFile, save_path: str)

            current_path = current_path.parent

    async def save_file(self, file: UploadFile, save_path: str):
        """保存文件（自动创建目录，流式上传）"""
        path_obj = Path(save_path)
        directory_path = str(path_obj.parent)
        # 提取原始文件名并进行清理
        filename = await sanitize_filename(path_obj.name)
        # 构建安全的保存路径
        safe_save_path = str(Path(directory_path) / filename)

        try:
            # 先创建目录结构
            await self._mkdir_p(directory_path)
            # 上传文件（流式）
            url = self._build_url(safe_save_path)

            async def file_sender():
                """流式读取文件内容"""
                chunk_size = 256 * 1024  # 256KB chunks
                while True:
                    chunk = await asyncio.to_thread(file.file.read, chunk_size)
                    if not chunk:
                        break
                    yield chunk

            async with aiohttp.ClientSession(auth=self.auth) as session:
                async with session.put(
                        url,
                        data=file_sender(),
                        headers={"Content-Type": file.content_type or "application/octet-stream"}
                ) as resp:
                    if resp.status not in (200, 201, 204):
                        content = await resp.text()
                        raise HTTPException(
                            status_code=resp.status,
                            detail=f"文件上传失败: {content[:200]}",
                        )
        except aiohttp.ClientError as e:
            raise HTTPException(
                status_code=503, detail=f"WebDAV连接异常: {str(e)}")

    async def delete_file(self, file_code: FileCodes):
        """删除WebDAV文件及空目录"""