基于SqlSugar的开发框架循序渐进介绍（7）-- 在文件上传模块中采用选项模式【Options】处理常规上传和FTP文件上传

    /// <summary>
    ///文件上传处理的选项信息/// </summary>
    public classUploadSettingOptions

    {/// <summary>
        ///可指定的存储物理地址，如C:\\Attachment，如果没有配置项AttachmentBasePath，则默认一个相对目录。/// </summary>
        public string AttachmentBasePath { get; set; }/// <summary>
        ///指定附件上传的方式，如ftp为FTP方式，为空则为普通方式/// </summary>
        public string AttachmentUploadType { get; set; }/// <summary>
        ///FTP服务地址/// </summary>
        public string FtpServer { get; set; }/// <summary>
        ///FTP用户名/// </summary>
        public string FtpUser { get; set; }/// <summary>
        ///FTP密码/// </summary>
        public string FtpPassword { get; set; }/// <summary>
        ///FTP的基础路径，如可以指定为IIS的路径：http://www.iqidi.com:8000 ,方便下载打开/// </summary>
        public string FtpBaseUrl { get; set; }

    }

    /// <summary>
    ///上传附件信息 应用层服务接口实现/// </summary>
    public class FileUploadService : MyCrudService<FileUploadInfo,string, FileUploadPagedDto>, IFileUploadService

    {//微软引入选项模式,它是用于配置框架服务使用的设置. 选项模式由Microsoft.Extensions.Options NuGet包实现//在你需要获得一个选项值时,将 IOptions<TOption> 服务注入到你的类中,使用它的 .Value 属性得到值.
        private readonlyUploadSettingOptions _options;/// <summary>
        ///参数化构造，注入上传处理设置信息/// </summary>
        /// <param name="options"></param>
        public FileUploadService(IOptions<UploadSettingOptions>options) 

        {

            _options=options.Value;

        }

        /// <summary>
        ///上传文件（根据配置文件选择合适的上传方式）/// </summary>
        /// <param name="info">文件信息（包含流数据）</param>
        /// <returns></returns>
        public async Task<CommonResult>Upload(FileUploadInfo info)

        {var uploadType = this._options.AttachmentUploadType;if (string.IsNullOrEmpty(uploadType))

            {return await this.UploadByNormal(info);

            }else if (uploadType.Equals("ftp", StringComparison.OrdinalIgnoreCase))

            {return await this.UploadByFTP(info);

            }else{throw new ArgumentException("AttachmentUploadType配置指定了无效的值， 请置空或者填写ftp。");

            }

        }

  <appSettings>
    <!--保存目录及FTP配置信息-->
    <!--可指定的存储物理地址，如C:\\Attachment，如果没有配置则默认相对目录。-->
    <addkey="AttachmentBasePath"value="" />
    <!--指定附件默认上传的方式， 如为FTP方式：ftp，为空则为普通方式-->
    <addkey="AttachmentUploadType"value="" />
    <!--非空的时候，读取下面的FTP信息-->
    <addkey="FtpServer"value="114.215.106.96" />
    <addkey="FtpUser"value="web2" />
    <addkey="FtpPassword"value="" />
    <!--可以指定为HTTP或者FTP的路径，供下载查看-->
    <addkey="FtpBaseUrl"value="http://www.iqidi.com/ftp" />
  </appSettings>

        /// <summary>
        ///应用程序的主入口点。/// </summary>
[STAThread]static voidMain()

        {//IServiceCollection负责注册
            IServiceCollection services = newServiceCollection();//添加IApiUserSession实现类
            services.AddSingleton<IApiUserSession, ApiUserPrincipal>(); //CurrentPrincipal实现方式//构造对应环境下的UploadSettingOptions信息
            services.Configure<UploadSettingOptions>(option =>{

                SetUploadOptions(option);

            });

        /// <summary>
        ///构造对应环境下的UploadSettingOptions信息/// </summary>
        /// <returns></returns>
        private staticUploadSettingOptions SetUploadOptions(UploadSettingOptions option)

        {var config = newAppConfig();

            option.AttachmentBasePath= config.AppConfigGet("AttachmentBasePath");

            option.AttachmentUploadType= config.AppConfigGet("AttachmentUploadType");

            option.FtpServer= config.AppConfigGet("FtpServer");

            option.FtpUser= config.AppConfigGet("FtpUser");

            option.FtpPassword= config.AppConfigGet("FtpPassword");

            option.FtpBaseUrl= config.AppConfigGet("FtpBaseUrl");returnoption;

        }

    "UploadSettingOptions": {"AttachmentBasePath": "", //可指定的存储物理地址，如C:\\Attachment，如果没有配置则默认相对目录。
      "AttachmentUploadType": "", //ftp或空，为空则为普通方式
      "FtpServer": "114.215.106.96", //FTP服务器地址
      "FtpUser": "web2", //FTP账号
      "FtpPassword": "", //FTP密码
      "FtpBaseUrl": "http://www.iqidi.com/ftp"//可以指定为HTTP或者FTP的路径，供下载查看
    }

builder.Services.Configure<UploadSettingOptions>(builder.Configuration.GetSection("UploadSettingOptions"));

    /// <summary>
    ///上传附件信息 应用层服务接口实现/// </summary>
    public class FileUploadService : MyCrudService<FileUploadInfo,string, FileUploadPagedDto>, IFileUploadService

    {//微软引入选项模式,它是用于配置框架服务使用的设置. 选项模式由Microsoft.Extensions.Options NuGet包实现//在你需要获得一个选项值时,将 IOptions<TOption> 服务注入到你的类中,使用它的 .Value 属性得到值.
        private readonlyUploadSettingOptions _options;/// <summary>
        ///参数化构造，注入上传处理设置信息/// </summary>
        /// <param name="options"></param>
        public FileUploadService(IOptions<UploadSettingOptions>options) 

        {

            _options=options.Value;

        }

//使用FluentFTP操作FTP文件
var client = new FtpClient(this._options.FtpServer, this._options.FtpUser, this._options.FtpPassword);//如果配置指定了端口，则使用特定端口
if (!string.IsNullOrEmpty(this._options.FtpServer) && this._options.FtpServer.Contains(":"))

{string port = this._options.FtpServer.Split(':')[1];if (!string.IsNullOrEmpty(port))

    {

        client.Port=port.ToInt32();

    }

}

    //确定日期时间目录（格式：yyyy-MM），不存在则创建
    string savePath = string.Format("/{0}-{1:D2}/{2}", DateTime.Now.Year, DateTime.Now.Month, category);bool isExistDir =client.DirectoryExists(savePath);if (!isExistDir)

    {

        client.CreateDirectory(savePath);

    }//使用FTP上传文件//避免文件重复，使用GUID命名
    var ext =FileUtil.GetExtension(info.FileName);var newFileName = string.Format("{0}{1}", Guid.NewGuid().ToString(), ext);//FileUtil.GetFileName(file);
savePath=savePath.UriCombine(newFileName);var uploaded = await client.UploadAsync(info.FileData, savePath, FtpRemoteExists.Overwrite, true);//成功后，写入数据库
    if (uploaded ==FtpStatus.Success)

    {