using System;
using System.IO;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace HttpDownload
{
public class DownloadTask
{
public string BelongingId { get; set; } // 任务id
//public int DownloadTaskId { get; set; }
public string FileUrl { get; }
public string FileDir { get; }
public long Offset { get; } // 开始下载的位置
public string ExpectedMD5 { get; }
private volatile DownloadStatus status;
public DownloadStatus Status { get { return status; } }
private string exceptionInfo;
public string ExceptionInfo { get { return exceptionInfo; } } // 保存发生异常时的Message
private double percentage = 0d;
private HttpDownloader httpDownloader = null;
///
///
///
///
///
///
/// 如果 offset == -1, 则把已写入文件的字节数当作offset
public DownloadTask(string fileUrl, string fileDir, string expectedMD5, long offset = 0L)
{
this.FileUrl = fileUrl;
this.FileDir = fileDir;
this.Offset = offset;
this.ExpectedMD5 = expectedMD5;
status = DownloadStatus.Created;
exceptionInfo = string.Empty;
httpDownloader = new HttpDownloader(fileUrl, fileDir, offset);
}
public DownloadTask(string taskId, string fileUrl, string fileDir, string expectedMD5, long offset = 0L)
{
this.BelongingId = taskId;
this.FileUrl = fileUrl;
this.FileDir = fileDir;
this.Offset = offset;
this.ExpectedMD5 = expectedMD5;
status = DownloadStatus.Created;
exceptionInfo = string.Empty;
httpDownloader = new HttpDownloader(fileUrl, fileDir, offset);
}
internal static void download(DownloadTask dTask)
{
try
{
if (dTask.status.Equals(DownloadStatus.Paused))
return;
dTask.status = DownloadStatus.Processing;
dTask.httpDownloader.DownloadFile();
if (dTask.httpDownloader.running)
dTask.status = DownloadStatus.Completed;
}
catch (Exception ex)
{
dTask.status = DownloadStatus.ExceptionStopped;
dTask.exceptionInfo = ex.Message;
}
}
public string calculateMD5()
{
if (Status.Equals(DownloadStatus.Completed))
{
string md5Digest = "";
return md5Digest;
}
return null;
}
public void pauseTask()
{
if (status == DownloadStatus.Completed)
return;
httpDownloader.running = false;
status = DownloadStatus.Paused;
}
public void resumeTask()
{
if (!httpDownloader.running)
{
httpDownloader.running = true;
status = DownloadStatus.WaitToRun;
}
}
public bool isFinished()
{
return httpDownloader.Finished;
}
public string getFileName()
{
return Path.GetFileName(FileDir);
}
public long totalFileSize
{
get
{
if (httpDownloader != null)
return httpDownloader.TotalRemoteFileSize;
return 0;
}
}
public long BytesWritten
{
get
{
if (httpDownloader != null)
return httpDownloader.BytesWritten;
return 0;
}
}
public string getSpeed(bool isFormatted)
{
if (httpDownloader != null && DownloadStatus.Processing.Equals(status))
return httpDownloader.getSpeed(isFormatted);
return "0 B/s";
}
public double getPercentage(int decimals)
{
if (httpDownloader != null)
return httpDownloader.getPercentage(decimals);
return 0d;
}
}
public enum DownloadStatus
{
Created, // 初始状态
WaitToRun, // 进入队列等待被执行
Paused, // 已暂停
Processing,// 正在执行
Completed, // 完成
ExceptionStopped // 出现异常已暂停
}
}