|
|
using NPOI.SS.UserModel;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Data;
|
|
|
using System.IO;
|
|
|
using System.Linq;
|
|
|
using System.Net;
|
|
|
using System.Text;
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
|
namespace VOL.Core.FtpHelper
|
|
|
{
|
|
|
public class FTPHelper
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// FTP请求对象
|
|
|
/// </summary>
|
|
|
FtpWebRequest request = null;
|
|
|
/// <summary>
|
|
|
/// FTP响应对象
|
|
|
/// </summary>
|
|
|
FtpWebResponse response = null;
|
|
|
/// <summary>
|
|
|
/// FTP服务器地址
|
|
|
/// </summary>
|
|
|
public string ftpURI { get; private set; }
|
|
|
/// <summary>
|
|
|
/// FTP服务器IP
|
|
|
/// </summary>
|
|
|
public string ftpServerIP { get; private set; }
|
|
|
/// <summary>
|
|
|
/// FTP服务器默认目录
|
|
|
/// </summary>
|
|
|
public string ftpRemotePath { get; private set; }
|
|
|
/// <summary>
|
|
|
/// FTP服务器登录用户名
|
|
|
/// </summary>
|
|
|
public string ftpUserID { get; private set; }
|
|
|
/// <summary>
|
|
|
/// FTP服务器登录密码
|
|
|
/// </summary>
|
|
|
public string ftpPassword { get; private set; }
|
|
|
|
|
|
/// <summary>
|
|
|
/// 初始化
|
|
|
/// </summary>
|
|
|
/// <param name="FtpServerIP">FTP连接地址</param>
|
|
|
/// <param name="FtpRemotePath">指定FTP连接成功后的当前目录, 如果不指定即默认为根目录</param>
|
|
|
/// <param name="FtpUserID">用户名</param>
|
|
|
/// <param name="FtpPassword">密码</param>
|
|
|
public FTPHelper(string ftpServerIP, string ftpRemotePath, string ftpUserID, string ftpPassword)
|
|
|
{
|
|
|
this.ftpServerIP = ftpServerIP;
|
|
|
this.ftpRemotePath = ftpRemotePath;
|
|
|
this.ftpUserID = ftpUserID;
|
|
|
this.ftpPassword = ftpPassword;
|
|
|
this.ftpURI = "ftp://" + ftpServerIP + "/" + ftpRemotePath + "/";
|
|
|
}
|
|
|
~FTPHelper()
|
|
|
{
|
|
|
if (response != null)
|
|
|
{
|
|
|
response.Close();
|
|
|
response = null;
|
|
|
}
|
|
|
if (request != null)
|
|
|
{
|
|
|
request.Abort();
|
|
|
request = null;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 建立FTP链接,返回响应对象
|
|
|
/// </summary>
|
|
|
/// <param name="uri">FTP地址</param>
|
|
|
/// <param name="ftpMethod">操作命令</param>
|
|
|
/// <returns></returns>
|
|
|
private FtpWebResponse Open(Uri uri, string ftpMethod)
|
|
|
{
|
|
|
request = (FtpWebRequest)FtpWebRequest.Create(uri);
|
|
|
request.Method = ftpMethod;
|
|
|
|
|
|
request.KeepAlive = false;
|
|
|
request.UseBinary = true;
|
|
|
//request.UsePassive = false;
|
|
|
|
|
|
request.Credentials = new NetworkCredential(this.ftpUserID, this.ftpPassword);
|
|
|
return (FtpWebResponse)request.GetResponse();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 建立FTP链接,返回请求对象
|
|
|
/// </summary>
|
|
|
/// <param name="uri">FTP地址</param>
|
|
|
/// <param name="ftpMethod">操作命令</param>
|
|
|
private FtpWebRequest OpenRequest(Uri uri, string ftpMethod)
|
|
|
{
|
|
|
request = (FtpWebRequest)WebRequest.Create(uri);
|
|
|
request.Method = ftpMethod;
|
|
|
request.UseBinary = true;
|
|
|
request.KeepAlive = false;
|
|
|
request.Credentials = new NetworkCredential(this.ftpUserID, this.ftpPassword);
|
|
|
return request;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 创建目录
|
|
|
/// </summary>
|
|
|
/// <param name="remoteDirectoryName">目录名</param>
|
|
|
public void CreateDirectory(string remoteDirectoryName)
|
|
|
{
|
|
|
response = Open(new Uri(ftpURI + remoteDirectoryName), WebRequestMethods.Ftp.MakeDirectory);
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 更改目录或文件名
|
|
|
/// </summary>
|
|
|
/// <param name="currentName">当前名称</param>
|
|
|
/// <param name="newName">修改后新名称</param>
|
|
|
public void ReName(string currentName, string newName)
|
|
|
{
|
|
|
request = OpenRequest(new Uri(ftpURI + currentName), WebRequestMethods.Ftp.Rename);
|
|
|
request.RenameTo = newName;
|
|
|
response = (FtpWebResponse)request.GetResponse();
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 切换当前目录
|
|
|
/// </summary>
|
|
|
/// <param name="IsRoot">true:绝对路径 false:相对路径</param>
|
|
|
public void GotoDirectory(string DirectoryName, bool IsRoot)
|
|
|
{
|
|
|
if (IsRoot)
|
|
|
ftpRemotePath = DirectoryName;
|
|
|
else
|
|
|
ftpRemotePath += "/" + DirectoryName;
|
|
|
|
|
|
ftpURI = "ftp://" + ftpServerIP + "/" + ftpRemotePath + "/";
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 删除目录(包括下面所有子目录和子文件)
|
|
|
/// </summary>
|
|
|
/// <param name="remoteDirectoryName">要删除的带路径目录名:如web/test</param>
|
|
|
/*
|
|
|
* 例:删除test目录
|
|
|
FTPHelper helper = new FTPHelper("x.x.x.x", "web", "user", "password");
|
|
|
helper.RemoveDirectory("web/test");
|
|
|
*/
|
|
|
public void RemoveDirectory(string remoteDirectoryName)
|
|
|
{
|
|
|
GotoDirectory(remoteDirectoryName, true);
|
|
|
var listAll = ListFilesAndDirectories();
|
|
|
foreach (var m in listAll)
|
|
|
{
|
|
|
if (m.IsDirectory)
|
|
|
RemoveDirectory(m.Path);
|
|
|
else
|
|
|
DeleteFile(m.Name);
|
|
|
}
|
|
|
GotoDirectory(remoteDirectoryName, true);
|
|
|
response = Open(new Uri(ftpURI), WebRequestMethods.Ftp.RemoveDirectory);
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 文件上传
|
|
|
/// </summary>
|
|
|
/// <param name="localFilePath">本地文件路径</param>
|
|
|
public void Upload(string localFilePath)
|
|
|
{
|
|
|
FileInfo fileInf = new FileInfo(localFilePath);
|
|
|
request = OpenRequest(new Uri(ftpURI + fileInf.Name), WebRequestMethods.Ftp.UploadFile);
|
|
|
request.ContentLength = fileInf.Length;
|
|
|
int buffLength = 2048;
|
|
|
byte[] buff = new byte[buffLength];
|
|
|
int contentLen;
|
|
|
using (var fs = fileInf.OpenRead())
|
|
|
{
|
|
|
using (var strm = request.GetRequestStream())
|
|
|
{
|
|
|
contentLen = fs.Read(buff, 0, buffLength);
|
|
|
while (contentLen != 0)
|
|
|
{
|
|
|
strm.Write(buff, 0, contentLen);
|
|
|
contentLen = fs.Read(buff, 0, buffLength);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 删除文件
|
|
|
/// </summary>
|
|
|
/// <param name="remoteFileName">要删除的文件名</param>
|
|
|
public void DeleteFile(string remoteFileName)
|
|
|
{
|
|
|
response = Open(new Uri(ftpURI + remoteFileName), WebRequestMethods.Ftp.DeleteFile);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取当前目录的文件和一级子目录信息
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public List<FileStruct> ListFilesAndDirectories()
|
|
|
{
|
|
|
var fileList = new List<FileStruct>();
|
|
|
response = Open(new Uri(ftpURI), WebRequestMethods.Ftp.ListDirectoryDetails);
|
|
|
using (var stream = response.GetResponseStream())
|
|
|
{
|
|
|
using (var sr = new StreamReader(stream))
|
|
|
{
|
|
|
string line = null;
|
|
|
while ((line = sr.ReadLine()) != null)
|
|
|
{
|
|
|
//line的格式如下:
|
|
|
//08-18-13 11:05PM <DIR> aspnet_client
|
|
|
//09-22-13 11:39PM 2946 Default.aspx
|
|
|
//DateTime dtDate = DateTime.ParseExact(line.Substring(0, 8), "MM-dd-yy", null);
|
|
|
//DateTime dtDateTime = DateTime.Parse(dtDate.ToString("yyyy-MM-dd") + line.Substring(8, 9));
|
|
|
string[] arrs = line.Split(' ');
|
|
|
var model = new FileStruct()
|
|
|
{
|
|
|
IsDirectory = line.IndexOf("<DIR>") > 0 ? true : false,
|
|
|
CreateTime = DateTime.Now,
|
|
|
Name = arrs[arrs.Length - 1],
|
|
|
Path = ftpRemotePath + "/" + arrs[arrs.Length - 1]
|
|
|
};
|
|
|
fileList.Add(model);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
return fileList;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 列出当前目录的所有文件
|
|
|
/// </summary>
|
|
|
public List<FileStruct> ListFiles()
|
|
|
{
|
|
|
var listAll = ListFilesAndDirectories();
|
|
|
var listFile = listAll.Where(m => m.IsDirectory == false).ToList();
|
|
|
return listFile;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 列出当前目录的所有一级子目录
|
|
|
/// </summary>
|
|
|
public List<FileStruct> ListDirectories()
|
|
|
{
|
|
|
var listAll = ListFilesAndDirectories();
|
|
|
var listFile = listAll.Where(m => m.IsDirectory == true).ToList();
|
|
|
return listFile;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 判断当前目录下指定的子目录或文件是否存在
|
|
|
/// </summary>
|
|
|
/// <param name="remoteName">指定的目录或文件名</param>
|
|
|
public bool IsExist(string remoteName)
|
|
|
{
|
|
|
var list = ListFilesAndDirectories();
|
|
|
if (list.Count(m => m.Name == remoteName) > 0)
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 判断当前目录下指定的一级子目录是否存在
|
|
|
/// </summary>
|
|
|
/// <param name="RemoteDirectoryName">指定的目录名</param>
|
|
|
public bool IsDirectoryExist(string remoteDirectoryName)
|
|
|
{
|
|
|
var listDir = ListDirectories();
|
|
|
if (listDir.Count(m => m.Name == remoteDirectoryName) > 0)
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 判断当前目录下指定的子文件是否存在
|
|
|
/// </summary>
|
|
|
/// <param name="RemoteFileName">远程文件名</param>
|
|
|
public bool IsFileExist(string remoteFileName)
|
|
|
{
|
|
|
var listFile = ListFiles();
|
|
|
if (listFile.Count(m => m.Name == remoteFileName) > 0)
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 下载
|
|
|
/// </summary>
|
|
|
/// <param name="saveFilePath">下载后的保存路径</param>
|
|
|
/// <param name="downloadFileName">要下载的文件名</param>
|
|
|
public string Download(string saveFilePath, string downloadFileName)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
using (FileStream outputStream = File.Open(saveFilePath, FileMode.OpenOrCreate, FileAccess.Write))
|
|
|
{
|
|
|
response = Open(new Uri(ftpURI + downloadFileName), WebRequestMethods.Ftp.DownloadFile);
|
|
|
using (Stream ftpStream = response.GetResponseStream())
|
|
|
{
|
|
|
int bufferSize = 2048;
|
|
|
int readCount;
|
|
|
byte[] buffer = new byte[bufferSize];
|
|
|
readCount = ftpStream.Read(buffer, 0, bufferSize);
|
|
|
while (readCount > 0)
|
|
|
{
|
|
|
outputStream.Write(buffer, 0, readCount);
|
|
|
readCount = ftpStream.Read(buffer, 0, bufferSize);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
return saveFilePath;
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
public class FileStruct
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 是否为目录
|
|
|
/// </summary>
|
|
|
public bool IsDirectory { get; set; }
|
|
|
/// <summary>
|
|
|
/// 创建时间
|
|
|
/// </summary>
|
|
|
public DateTime CreateTime { get; set; }
|
|
|
/// <summary>
|
|
|
/// 文件或目录名称
|
|
|
/// </summary>
|
|
|
public string Name { get; set; }
|
|
|
/// <summary>
|
|
|
/// 路径
|
|
|
/// </summary>
|
|
|
public string Path { get; set; }
|
|
|
}
|
|
|
}
|