文件目录如下

APBackUpFiles

app.config

OracleHelper

LocalFileMethods

LogFile

packages.config

ReadFile

如何发布

在工作的时候，遇到了需要定时对服务器的文件进行备份的需求，原因是 AP（服务器）上的空间不够了，导致一直在报警空间不足，本文就工作中使用到的程序进行简单的记录，本功能包含如下几个部分：

路径配置
数据库连接
文件移动
文件删除
文件压缩
记录 log

文件目录如下

下面来一个一个介绍。

APBackUpFiles

此方法的主要功能为：

文件移动
文件删除
文件压缩
记录 log

代码如下：

using Oracle.DataAccess.Client;
using System;
using System.Configuration;
using System.Data;
using System.IO;
using System.IO.Compression;namespace APBackUpFilesToDisk
{class APBackUpFiles{static void Main(){/** 注意将数据库连接改成正式环境* 注意上线的时候开启文件删除功能* 注意注释控制台输出的语句*/Console.WriteLine("\t现在开始");Console.WriteLine("正在执行.");Console.WriteLine("正在执行..");Console.WriteLine("正在执行...");Console.WriteLine("执行期间，请勿对文件夹内部文件 移动 / 复制 / 删除 / 插入！");string sDtaes = DateTime.Now.ToString("yyyy-MM-dd_HH-mm-ss");string sourceFolder = ConfigurationManager.AppSettings["SourcePath"]; // 源文件夹路径string backupFolder = ConfigurationManager.AppSettings["BackUpPath"]; // 备份文件夹路径string searchPattern = ConfigurationManager.AppSettings["FilenameSuffix"]; // 文件名匹配模式// log 文件存储路径，分时间存储string filename = ConfigurationManager.AppSettings["LogPath"] + "\\BackUpFiles_" + sDtaes + ".log";int iCounts = 0;// 已操作的文件个数// 文件操作方法 StreamWriter 数据流写入StreamWriter sws = new StreamWriter(filename, true);sws.AutoFlush = true;// 强制每行都写入，而不是等待close时候才写入// 程序开始标志sws.WriteLine("[Put File start : " + sDtaes + " ===============]");try{// 检查源文件夹是否存在if (!Directory.Exists(sourceFolder)){// 追加写入sws.WriteLine("源文件夹不存在。");sDtaes = DateTime.Now.ToString("yyyy-MM-dd_HH-mm-ss");sws.WriteLine("[Put File end : " + sDtaes + " ===============]");sws.WriteLine("===========================================================");sws.Close();return; // 退出程序}// 检查备份文件夹是否存在，不存在则创建if (!Directory.Exists(backupFolder)){Directory.CreateDirectory(backupFolder);}// 查找匹配的文件并备份string[] filesToBackup = Directory.GetFiles(sourceFolder, searchPattern);// 默认按照文件名称排序foreach (string file in filesToBackup){string sControl = file.Substring(file.LastIndexOf("\\") + 1, 10);// 取文件名称，即 control lot 信息iCounts++;// 只要对文件进行了判断，则计数加一if (bCheckStatus(sControl)){// 构造备份文件路径string backupFilePath = Path.Combine(backupFolder, Path.GetFileName(file));// 备份文件File.Copy(file, backupFilePath, true); // 如果目标文件已存在则覆盖Console.WriteLine("备份文件 {0} 至 {1}", file, backupFilePath);sws.WriteLine("BackUp File Success :【" + file + "】To【" + backupFilePath + "】");// 删除已备份的文件File.Delete(file);Console.WriteLine("删除文件 {0}", file);sws.WriteLine("[Delete File Success : " + file + "]");if (iCounts == 20000) break;}else{Console.WriteLine("不备份文件 {0} ", sControl);sws.WriteLine("不备份文件" + sControl + "");}}Console.WriteLine("开始压缩文件...");sws.WriteLine("开始压缩文件...");// 压缩本地文件string startPath = ConfigurationManager.AppSettings["StartPath"];// 需要被压缩的文件夹string zipPath = ConfigurationManager.AppSettings["ZipPath"] + "\\" + sDtaes + ".zip";// 压缩包存储的路径，并为压缩包命名ZipFile.CreateFromDirectory(startPath, zipPath);Console.WriteLine("压缩文件成功！");sws.WriteLine("压缩文件成功！");Console.WriteLine("开始删除文件...");sws.WriteLine("开始删除文件...");// 删除本地文件，节省空间LocalFileMethods dlf = new LocalFileMethods();dlf.DeleteLocalTXT(startPath, searchPattern);Console.WriteLine("删除文件成功！");sws.WriteLine("删除文件成功！");sDtaes = DateTime.Now.ToString("yyyy-MM-dd_HH-mm-ss");sws.WriteLine("[Put File end : " + sDtaes + " ===============]");sws.WriteLine("===========================================================");sws.WriteLine();sws.Close();Console.WriteLine("共执行：" + iCounts + "个文件");}catch (Exception ex){Console.WriteLine("[发生异常 : " + ex.Message + "]");sws.WriteLine("[发生异常 : " + ex.Message + "]");}}/// <summary>/// 传入文件名称，查询是否满足删除条件          /// </summary>/// <param name="sControl"></param>/// <returns></returns>public static bool bCheckStatus(string sControl){string sSql;DataTable dt = new DataTable();// sql 语句sSql = " select a.XXX from XXX a " +"where a.XXX like '" + sControl + "%' and a.XXX <> '" + sControl + "'";// sql 赋值 无参数传入 sqlOracleParameter[] paramATIO = new OracleParameter[] { };// 执行sqldt = OracleHelper.ExecuteDataTable(sSql, paramATIO);// 若有数据，判断所有状态if (dt.Rows.Count > 0){for (int i = 0; i < dt.Rows.Count; i++){if (dt.Rows[i][0].ToString() != "Terminated" && dt.Rows[i][0].ToString() != "Finished"){return false;}}// sql 语句sSql = " select a.XXX from XXX a " +"where a.XXX like '" + sControl + "%' and a.XXX <> '" + sControl + "'";// sql 赋值 无参数传入 sqlparamATIO = new OracleParameter[] { };// 执行sqldt = OracleHelper.ExecuteDataTable(sSql, paramATIO);if (dt.Rows.Count > 0)// 有数据{return true;}}else // 若 ASSY 无数据，需要去 FT 查{return false;}return false;}}
}

app.config

这个文件的作用是配置各种参数，包括了各种路径，可以实现在不改变代码的情况下直接修改操作的文件夹，简单的做到了降低耦合，提高代码复用性的作用，需要修改的时候直接改此配置文件即可。

<?xml version="1.0" encoding="utf-8"?>
<!--设定版本号及字符集--><configuration><appSettings><add key="Block" value="1"/><!--源文件夹路径，即需要被备份的文件所在的路径--><add key="SourcePath" value="C:\Test"/><!--备份文件夹路径，即需要将源文件备份到哪个文件夹--><add key="BackUpPath" value="D:\BackUpFiles"/><!--需要被压缩的文件夹，即你要把哪个文件夹压缩，一般同备份文件夹路径--><add key="StartPath" value="D:\BackUpFiles"/><!--压缩包存储的路径，并为压缩包命名，即压缩之后的文件放在哪个文件夹--><add key="ZipPath" value="D:\Zips"/><!--log 文件存储路径，分时间存储，即 log 文件的储存路径--><add key="LogPath" value="D:\APBackUpFilesToDisk\Logs"/><!--文件名匹配模式，即你要从源文件夹中筛选哪些后缀的文件--><add key="FilenameSuffix" value="*.LOT"/><add key="ClientSettingsProvider.ServiceUri" value=""/></appSettings><!--默认配置，不用管--><system.web><membership defaultProvider="ClientAuthenticationMembershipProvider"><providers><add name="ClientAuthenticationMembershipProvider" type="System.Web.ClientServices.Providers.ClientFormsAuthenticationMembershipProvider, System.Web.Extensions, Version=4.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35" serviceUri=""/></providers></membership><roleManager defaultProvider="ClientRoleProvider" enabled="true"><providers><add name="ClientRoleProvider" type="System.Web.ClientServices.Providers.ClientRoleProvider, System.Web.Extensions, Version=4.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35" serviceUri="" cacheTimeout="86400"/></providers></roleManager></system.web><startup><supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5"/></startup>
</configuration>

OracleHelper

此类的作用是连接数据库，在里面配置数据库连接，后面直接调用此方法即可实现简单的数据库操作（CRUD）。

using Oracle.DataAccess.Client;
using System.Data;namespace APBackUpFilesToDisk
{class OracleHelper{private static string connStr = "User Id=XXX;Password=XXX;" +"Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=XX.XX.XX.XX)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=XXXX)))";#region 执行SQL语句,返回受影响行数public static int ExecuteNonQuery(string sql, params OracleParameter[] parameters){using (OracleConnection conn = new OracleConnection(connStr)){conn.Open();using (OracleCommand cmd = conn.CreateCommand()){cmd.CommandText = sql;cmd.Parameters.AddRange(parameters);int i = cmd.ExecuteNonQuery();conn.Close();return i;}}}#endregion#region 执行SQL语句,返回DataTable;只用来执行查询结果比较少的情况public static DataTable ExecuteDataTable(string sql, params OracleParameter[] parameters){using (OracleConnection conn = new OracleConnection(connStr)){conn.Open();using (OracleCommand cmd = conn.CreateCommand()){cmd.CommandText = sql;cmd.Parameters.AddRange(parameters);OracleDataAdapter adapter = new OracleDataAdapter(cmd);DataTable datatable = new DataTable();adapter.Fill(datatable);conn.Close();return datatable;}}}#endregion}
}

LocalFileMethods

本地文件操作的方法。

using System;
using System.IO;namespace APBackUpFilesToDisk
{class LocalFileMethods{public void DeleteLocalTXT(string startPath,string searchPattern){try{string[] txtList = Directory.GetFiles(startPath, searchPattern);// 删除源文件foreach (string f in txtList){File.Delete(f);}}catch (DirectoryNotFoundException dirNotFound){Console.WriteLine(dirNotFound.Message);}}}
}

LogFile

记录 log 的方法。

using System;
using System.IO;namespace APBackUpFilesToDisk
{class LogFile{private string ToFileNmae;//日志存储路径public void Logfile(string path){this.ToFileNmae = path;}/// <summary>        /// 创建日志       /// </summary>       /// <param name="message">日志信息</param>       /// <param name="title">日志标题</param>     public void Log(string message){string path = this.ToFileNmae;string filename = path + "\\Log.txt";string cont = "";FileInfo fileInf = new FileInfo(filename);if (File.Exists(filename))//如何文件存在 则在文件后面累加    {FileStream myFss = new FileStream(filename, FileMode.Open, FileAccess.ReadWrite, FileShare.ReadWrite);StreamReader r = new StreamReader(myFss);cont = r.ReadToEnd();r.Close();myFss.Close();}#region 生成文件日志FileStream myFs = new FileStream(filename, FileMode.Create, FileAccess.ReadWrite, FileShare.ReadWrite);StreamWriter n = new StreamWriter(myFs);n.WriteLine(cont);n.WriteLine(DateTime.Now.ToString() + ":" + message);n.Close(); myFs.Close();if (fileInf.Length >= 1024 * 1024 * 200){string NewName = path + "Log" + time() + ".txt";File.Move(filename, NewName);}#endregion}/// <summary>       /// 系统时间       /// </summary>    /// <returns></returns>     /// public string time(){string dNow = DateTime.Now.ToString().Trim().Replace("/", "").Replace(":", "");string fileName = dNow.ToString();return fileName;}}
}

packages.config

默认配置，不管他。

<?xml version="1.0" encoding="utf-8"?>
<packages><package id="Oracle.DataAccess.x86.4" version="4.112.3" targetFramework="net45" />
</packages>

ReadFile

读取文件的操作，与写 log 等相互配合。

using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Text.RegularExpressions;namespace APBackUpFilesToDisk
{class ReadFile{public static void Movefile(string filename, string type){try{string sDir = ConfigurationManager.AppSettings[type];string sCommonPath = ConfigurationManager.AppSettings["Common"];string sDirSource = System.IO.Path.GetDirectoryName(filename);string[] sDirDetail = Regex.Split(sDirSource, sCommonPath);string sDirCus = sDirDetail[1];sDir = sDir + @"\" + sDirCus;string sFilename = System.IO.Path.GetFileName(filename);if (!Directory.Exists(sDir)){Directory.CreateDirectory(sDir);}if (File.Exists(Path.Combine(sDir, sFilename))){File.Move(Path.Combine(sDir, sFilename), Path.Combine(sDir, sFilename + DateTime.Now.ToString().Trim().Replace("/", "").Replace(":", "")));}File.Move(filename, Path.Combine(sDir, sFilename));}catch (Exception ex){WriteLog("ReaderMappingfile: " + ex.Message.ToString());}}public static void Backupfile(string filename){try{string sDir = System.IO.Path.GetDirectoryName(filename);string sFilename = System.IO.Path.GetFileName(filename);if (!Directory.Exists(Path.Combine(sDir, "backup"))){Directory.CreateDirectory(Path.Combine(sDir, "backup"));}if (File.Exists(Path.Combine(sDir, "backup\\" + sFilename))){File.Move(Path.Combine(sDir, "backup\\" + sFilename), Path.Combine(sDir, "backup\\" + sFilename + DateTime.Now.ToString().Trim().Replace("/", "").Replace(":", "")));}File.Move(filename, Path.Combine(sDir, "backup\\" + sFilename));}catch (Exception ex){WriteLog("ReaderMappingfile: " + ex.Message.ToString());}}public Dictionary<string, string> NewOld2D(string filename){Dictionary<string, string> DicMapping = new Dictionary<string, string>();try{string sBindetail = File.ReadAllText(filename);string[] s2DAll_list = Regex.Split(sBindetail.TrimEnd(), "");for (int i = 0; i < s2DAll_list.Length; i++){DicMapping.Add(s2DAll_list[i].Split(',')[0].ToString(), s2DAll_list[i].Split(',')[1].TrimEnd().ToString());}}catch (Exception ex){WriteLog("NewOld2D: " + ex.Message.ToString());}return DicMapping;}public static void WriteLog(string smessage){try{LogFile log1 = new LogFile();string sLogPath = System.AppDomain.CurrentDomain.BaseDirectory.ToString() + "\\LOG";if (!Directory.Exists(sLogPath)){Directory.CreateDirectory(sLogPath);}log1.Logfile(sLogPath);log1.Log(smessage);}catch (Exception ex){}}}
}