EDM开发之三：其他功能

EDM开发过程中遇到的其他问题

1、session：

session记录到数据库中，sql数据库自带程序C:WindowsMicrosoft.NETFrameworkv4.0.30319aspnet_regsql.exe，可以在命令行执行

“C:WindowsMicrosoft.NETFrameworkv4.0.30319aspnet_regsql.exe -S . -E -ssadd -sstype c -d TestSessionStore”会在数据库中生成一个名为TestSessionStore的数据库，这就是为session而生的，然后在web.config中的sessionState改为

<sessionState mode="SQLServer" allowCustomSqlDatabase="true"
                  sqlConnectionString="server=数据库; database=数据库名;uid=帐号;pwd=密码;"
                  cookieless="false"
                  timeout="60">
</sessionState>

这样，再用sessin就会记录在数据库中了。不过如果直接运行.exe程序手动生成数据库，会报错，提示无会话状态。

2、task：

用多线程方法可以减少发送大量邮件花费时间长的问题（SMTP限制之后再说），task是对ThreadPool线程池的封装，相对于线程池具有很多优势，比如：（1）ThreadPool不支持线程的取消、完成、失败通知等交互性操作；(2)ThreadPool不支持线程执行的先后次序；通过对ThreadPool进行封装，于是.net Framework4.0有了TPL和Task。也就是说，相对于线程池，task使我能对线程的可控性大大提高了。

（1）普通用法：

Task t = new Task(() => 
{ 
   Console.WriteLine("任务开始"); 
}); 
t.Start(); 
t.ContinueWith((task) => 
{ 
  Console.WriteLine("任务完成"); 
}); 

（2）任物工厂：

Task[] tasks = new Task[] 
{ 
    taskFactory.StartNew(() => Add(cts.Token)), 
    taskFactory.StartNew(() => Add(cts.Token)), 
    taskFactory.StartNew(() => Add(cts.Token)) 
}; 
//CancellationToken.None指示TasksEnded不能被取消 
taskFactory.ContinueWhenAll(tasks, TasksEnded, CancellationToken.None); 

CancellationTokenSource是通知 CancellationToken，告知其应被取消。当其被实例化后，执行.Canale()方法，即可取消线程。

task可以等待某个线程执行完成后再执行：

t1.Wait(); //等待任务t1完成
Task.WaitAll(t2, t3);  //等待任务t2和t3完成
t4.ContinueWith(TaskEndedByCatch); //t4执行完成后继续执行TaskEndedByCatch方法
taskFactory.ContinueWhenAll(tasks, TasksEnded, CancellationToken.None); //工厂内所有线程执行完毕后，执行TasksEnded方法，CancellationToken.None指示此方法不能被取消。

3、解压：

对于传入的文件，可能是文本文件，也可能是压缩文件，这就要求将传入的压缩文件解压并对文件路径进行记录，而且由于压缩文件格式不确定，所以调用WinRAR软件进行解压。

/// <summary>
/// 利用 WinRAR 进行解压缩
/// </summary>
/// <param name="path">文件解压路径（绝对路径）</param>
/// <param name="rarPath">将要解压缩文件的存放目录（绝对路径）</param>
/// <param name="rarName">将要解压缩文件名（包括后缀）</param>
/// <returns>true 或 false。解压缩成功返回 true，反之，false。</returns>
public bool UnRarOrZip(string path, string rarPath, string rarName)
{
    bool flag = false;
    try
    {
        RegistryKey regkey = Registry.ClassesRoot.OpenSubKey(@"WinRAR.ZIPshellopencommand");//根据注册表，获取WinRAR的运行路径
        if (regkey != null)
        {
            Object regvalue = regkey.GetValue("");
            string rarexe = regvalue.ToString();
            regkey.Close();
            rarexe = rarexe.Substring(1, rarexe.Length - 7);

            Directory.CreateDirectory(path);
            //解压缩命令，相当于在要压缩文件(rarName)上点右键->WinRAR->解压到当前文件夹
            string cmd = string.Format("x {0} {1} -y",
                rarName,
                path);
            var startinfo = new ProcessStartInfo
            {
                FileName = rarexe,
                Arguments = cmd,
                WindowStyle = ProcessWindowStyle.Hidden,
                WorkingDirectory = rarPath
            };

            var process = new Process {StartInfo = startinfo};
            process.Start();
            process.WaitForExit();
            if (process.HasExited)
            {
                flag = true;
            }
            process.Close();
        }
    }
    catch (Exception e)
    {
        throw e;
    }
    return flag;
}

public void Dispose()
{
    throw new NotImplementedException();
}
}

4、文件操作：

系统中需要对文件和文件夹进行读写操作。

创建文件或文件夹：

//创建文件夹
public void CreateDirectory(string pathName)
{
    if (!Directory.Exists(pathName))
    {
        Directory.CreateDirectory(pathName);
    }
}

//创建文件
public void CreateFile(string pathName)
{
    if (!File.Exists(pathName))
    {
        File.Create(pathName);
    }
}

获取文件名或文件夹名：

//获取目录下所有文件名
public List<string> GetAllFiles(string path)
{
    var dir = new DirectoryInfo(path);
    var fiList = new List<FileInfo>();
    if (dir.Exists)
    {
        fiList.AddRange(dir.GetFiles());
    }
    var fileName = new List<string>();
    if (fiList.Count != 0)
    {
        fileName.AddRange(fiList.Select(dl => dl.Name));
    }
    return fileName;
}

//获取目录下所有文件夹名
public List<string> GetAllDirectorys(string path)
{
    var dir = new DirectoryInfo(path);
    var diList = new List<DirectoryInfo>();
    if (dir.Exists)
    {
        diList.AddRange(dir.GetDirectories());
    }
    var fileName = new List<string>();
    if (diList.Count != 0)
    {
        fileName.AddRange(diList.Select(dl => dl.Name));
    }
    return fileName;
}

删除文件：

//删除文件
public void DeleteFile(string path)
{
    //判断文件是不是存在
    if (!File.Exists(path)) return;
    //文件删除
    File.Delete(path);
}

清空文件夹：

 //清空文件夹
        public void DeleteDirectory(string path)
        {
            //判断文件是不是存在
            if (!Directory.Exists(path)) return;
            //文件夹清空
            DeleteFolder(path);
        }
        public static void DeleteFolder(string dir)
        {
            foreach (string d in Directory.GetFileSystemEntries(dir))
            {
                if (File.Exists(d))
                {
                    FileInfo fi = new FileInfo(d);
                    if (fi.Attributes.ToString().IndexOf("ReadOnly", System.StringComparison.Ordinal) != -1)
                        fi.Attributes = FileAttributes.Normal;
                    File.Delete(d);//直接删除其中的文件  
                }
                else
                {
                    var d1 = new DirectoryInfo(d);
                    if (d1.GetFiles().Length != 0)
                    {
                        DeleteFolder(d1.FullName);////递归删除子文件夹
                    }
                    Directory.Delete(d);
                }
            }
        }

获取目录下第一次出现文件的路径：

public string GetNewUrl(string pathUrl, string pathName)
{
    var files = GetAllFiles(pathUrl);
    if (files.Count == 0)
    {
        var directions = GetAllDirectorys(pathUrl);
        if (directions.Count > 0)
        {
            pathName += "/" + directions.FirstOrDefault();
            GetNewUrl(pathUrl + "\" + directions.FirstOrDefault(), pathName);
        }
    }
    return pathName;
}

5、对于excel文件的导入导出操作：

系统数据导入可能是txt文件，也可能是excel文件。对于导入的Excel文件，使用NPOI进行操作。

excel文件操作类：

private HSSFWorkbook _hssfworkbook;

public void InitializeWorkbook(string path)
{
    using (var file = new FileStream(path, FileMode.Open, FileAccess.Read))
    {
        _hssfworkbook = new HSSFWorkbook(file);
    }
}

public void InitializeWorkbook(FileUpload uploadfile)
{
    uploadfile.SaveAs(HttpContext.Current.Server.MapPath("~/Content/excel.xls"));
    string path = HttpContext.Current.Server.MapPath("~/Content/excel.xls");
    using (var file = new FileStream(path, FileMode.Open, FileAccess.Read))
    {
        _hssfworkbook = new HSSFWorkbook(file);
    }
}

/// <summary>
/// 数据导出
/// </summary>
/// <param name="sheetName">Excel Sheet名称</param>
/// <param name="cellNames">列名</param>
/// <param name="setCellValue">设置列值的委托方法</param>
/// <returns></returns>
public MemoryStream ExportEdm(string sheetName, string[] cellNames, Action<ISheet> setCellValue)
{
    using (var output = new MemoryStream())
    {
        IWorkbook workBook = new HSSFWorkbook();
        var sheet = workBook.CreateSheet(sheetName);
        var headRow = sheet.CreateRow(0);
        for (int i = 0; i < cellNames.Length; i++)
            headRow.CreateCell(i).SetCellValue(cellNames[i]);
        setCellValue(sheet);
        for (int i = 0; i < cellNames.Length; i++)
            sheet.AutoSizeColumn(i);
        workBook.Write(output);
        return output;
    }
}

excel导入导出实例：

/// <summary>
/// Excel数据导入
/// </summary>
public void GetExcel(string path)
{
    var uplodeExcel = new ExcelHelper();
    uplodeExcel.InitializeWorkbook(path);
    var list = uplodeExcel.SetCurrentSheet();
}

/// <summary>
/// Excel导出EDM
/// </summary>
public ActionResult ReportExcel()
{
    var list = (from entity in models
                let model = _sendService.GetCountList(entity.SendTableName)
                select new SendTypeStatis
                {}).ToList();
    string[] cellNames =
    {
        "EDM名称", "真实路径"
    };
    var output = new ReportExcel().ExportEdm("EDM导出", cellNames, r =>
    {
        if (!list.Any()) return;
        var rowNumber = 1;
        foreach (var ml in list)
        {
            var number = 0;
            var row = r.CreateRow(rowNumber++);
            row.CreateCell(number++).SetCellValue(ml.EdmName);
            row.CreateCell(number).SetCellValue(ml.EdmNewUrl);
        }
    });
    string saveAs = string.Format("数据导出-{0:d}.xls", DateTime.Now.Ticks);
    Response.ContentType = "application/vnd.ms-excel";
    Response.AddHeader("Content-Disposition", string.Format("attachment;filename={0}", saveAs));
    Response.BinaryWrite(output.GetBuffer());
    Response.End();

    return Json("success");
}