1、文件存储接口
using System.IO;using System.Threading.Tasks;namespace CJavaPy.Storage{ public interface IStorage { string SaveFile(Stream stream, string fileName); Task SaveFileAsync(Stream stream, string fileName); string SaveFile(Stream stream, string directory, string fileName); Task SaveFileAsync(Stream stream, string directory, string fileName); void AppendFile(Stream stream, string filePath); Task AppendFileAsync(Stream stream, string filePath); void Delete(string filePath); void DeleteDirectory(string path); }}
2、本地存储实现接口方法
using System;using System.Collections.Generic;using System.IO;using System.Text;using System.Threading.Tasks;namespace CJavaPy.Storage{ public class LocalStorage : IStorage { public string ToFilePath(string path) { return Path.Combine(path.Split(new char[] { '/', '\\' }, StringSplitOptions.RemoveEmptyEntries)); } //虚拟路径转成物理路径 protected virtual string MapPath(string path) { return Path.Combine(Directory.GetCurrentDirectory(), ToFilePath(path.TrimStart('~'))); } //生成文件目录 protected virtual string GenerateDictionary(string fileName) { return Path.Combine("Files", fileName); } //追加文件内容 public virtual void AppendFile(Stream stream, string filePath) { using (FileStream fileStream = new FileStream(MapPath(filePath), FileMode.Append)) { stream.CopyTo(fileStream); } } //异步追加文件内容 public virtual async Task AppendFileAsync(Stream stream, string filePath) { using (FileStream fileStream = new FileStream(MapPath(filePath), FileMode.Append)) { await stream.CopyToAsync(fileStream); } } //删除文件 public virtual void Delete(string filePath) { File.Delete(MapPath(filePath)); } //指定文件名同步保存文件 public virtual string SaveFile(Stream stream, string fileName) { return SaveFile(stream, GenerateDictionary(fileName), fileName); } //指定文件名异步保存文件 public virtual Task SaveFileAsync(Stream stream, string fileName) { return SaveFileAsync(stream, GenerateDictionary(fileName), fileName); } // 指定目录和文件名同步保存文件 public virtual string SaveFile(Stream stream, string directory, string fileName) { string filePath = Path.Combine(MapPath(directory), fileName); using (FileStream fileStream = new FileStream(filePath, FileMode.Create)) { stream.CopyTo(fileStream); } return filePath; } //指定目录和文件名异步保存文件 public virtual async Task SaveFileAsync(Stream stream, string directory, string fileName) { string filePath = Path.Combine(MapPath(directory), fileName); using (FileStream fileStream = new FileStream(filePath, FileMode.Create)) { await stream.CopyToAsync(fileStream); } return filePath; } public virtual void DeleteDirectory(string path) { Directory.Delete(MapPath(path), true); } }}
3、Web目录(wwwroot)存储实现接口方法
using System;using System.Collections.Generic;using System.IO;using System.Text;using System.Threading.Tasks;namespace CJavaPy.Storage{ public class WebStorage : IStorage { const string WebRoot = "wwwroot"; const string UploadFolder = "UpLoad"; const string ImageFolder = "Images"; const string FileFolder = "Files"; //判断图片 public bool IsImage(string extension) { extension = extension.ToLower(); if (extension == ".gif" || extension == ".jpg" || extension == ".png" || extension == ".jpeg" || extension == ".bmp") { return true; } else return false; } //路径转换 public string ToFilePath(string path) { return Path.Combine(path.Split(new char[] { '/', '\\' }, StringSplitOptions.RemoveEmptyEntries)); } //虚拟路径转成物理路径 protected virtual string MapPath(string path) { return Path.Combine(Directory.GetCurrentDirectory(), WebRoot, ToFilePath(path.TrimStart('~'))); } //生成上传目录路径 protected virtual string GenerateDictionary(string fileName) { string folder = IsImage(Path.GetExtension(fileName)) ? ImageFolder : FileFolder; return Path.Combine(new string[] { UploadFolder, folder, DateTime.Now.ToString("yyyyMM") }); } //追加文件内容 public virtual void AppendFile(Stream stream, string filePath) { using (FileStream fileStream = new FileStream(MapPath(filePath), FileMode.Append)) { stream.CopyTo(fileStream); } } //异步追加文件内容 public virtual async Task AppendFileAsync(Stream stream, string filePath) { using (FileStream fileStream = new FileStream(MapPath(filePath), FileMode.Append)) { await stream.CopyToAsync(fileStream); } } //删除文件 public virtual void Delete(string filePath) { FileInfo file = new FileInfo(MapPath(filePath)); if (file.Exists) { file.Delete(); } } //指定文件名保存文件 public virtual string SaveFile(Stream stream, string fileName) { return SaveFile(stream, GenerateDictionary(fileName), fileName); } //异步保存文件 public virtual Task SaveFileAsync(Stream stream, string fileName) { return SaveFileAsync(stream, GenerateDictionary(fileName), fileName); } //指定目录和文件名保存文件 public virtual string SaveFile(Stream stream, string directory, string fileName) { string filePath = Path.Combine(MapPath(directory), fileName); DirectoryInfo dir = new DirectoryInfo(Path.GetDirectoryName(filePath)); if (!dir.Exists) { dir.Create(); } using (FileStream fileStream = new FileStream(filePath, FileMode.Create)) { stream.CopyTo(fileStream); } string webPath = string.Join("/", directory.Split(new char[] { Path.DirectorySeparatorChar, Path.AltDirectorySeparatorChar }, StringSplitOptions.RemoveEmptyEntries)); return $"~/{webPath}/{fileName}"; } //指定目录和文件名异步保存文件 public virtual async Task SaveFileAsync(Stream stream, string directory, string fileName) { string filePath = Path.Combine(MapPath(directory), fileName); DirectoryInfo dir = new DirectoryInfo(Path.GetDirectoryName(filePath)); if (!dir.Exists) { dir.Create(); } using (FileStream fileStream = new FileStream(filePath, FileMode.Create)) { await stream.CopyToAsync(fileStream); } string webPath = string.Join("/", directory.Split(new char[] { Path.DirectorySeparatorChar, Path.AltDirectorySeparatorChar }, StringSplitOptions.RemoveEmptyEntries)); return $"~/{webPath}/{fileName}"; } public virtual void DeleteDirectory(string path) { Directory.Delete(MapPath(path), true); } }}
