Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
1c473f88b9 |
@@ -11,7 +11,7 @@
|
|||||||
</dependentAssembly>
|
</dependentAssembly>
|
||||||
<dependentAssembly>
|
<dependentAssembly>
|
||||||
<assemblyIdentity name="System.Text.Json" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
|
<assemblyIdentity name="System.Text.Json" publicKeyToken="cc7b13ffcd2ddd51" culture="neutral" />
|
||||||
<bindingRedirect oldVersion="0.0.0.0-8.0.0.1" newVersion="8.0.0.1" />
|
<bindingRedirect oldVersion="0.0.0.0-9.0.0.6" newVersion="9.0.0.6" />
|
||||||
</dependentAssembly>
|
</dependentAssembly>
|
||||||
</assemblyBinding>
|
</assemblyBinding>
|
||||||
</runtime>
|
</runtime>
|
||||||
|
@@ -83,8 +83,8 @@
|
|||||||
<Reference Include="LanzouCloudSolve, Version=1.0.3.0, Culture=neutral, processorArchitecture=MSIL">
|
<Reference Include="LanzouCloudSolve, Version=1.0.3.0, Culture=neutral, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\LanzouCloudSolve.1.0.3\lib\netstandard2.0\LanzouCloudSolve.dll</HintPath>
|
<HintPath>packages\LanzouCloudSolve.1.0.3\lib\netstandard2.0\LanzouCloudSolve.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
<Reference Include="Microsoft.Bcl.AsyncInterfaces, Version=8.0.0.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
<Reference Include="Microsoft.Bcl.AsyncInterfaces, Version=9.0.0.6, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\Microsoft.Bcl.AsyncInterfaces.8.0.0\lib\net462\Microsoft.Bcl.AsyncInterfaces.dll</HintPath>
|
<HintPath>packages\Microsoft.Bcl.AsyncInterfaces.9.0.6\lib\net462\Microsoft.Bcl.AsyncInterfaces.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
<Reference Include="Newtonsoft.Json, Version=13.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
|
<Reference Include="Newtonsoft.Json, Version=13.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\Newtonsoft.Json.13.0.3\lib\net45\Newtonsoft.Json.dll</HintPath>
|
<HintPath>packages\Newtonsoft.Json.13.0.3\lib\net45\Newtonsoft.Json.dll</HintPath>
|
||||||
@@ -94,6 +94,9 @@
|
|||||||
<HintPath>packages\System.Buffers.4.5.1\lib\net461\System.Buffers.dll</HintPath>
|
<HintPath>packages\System.Buffers.4.5.1\lib\net461\System.Buffers.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
<Reference Include="System.Core" />
|
<Reference Include="System.Core" />
|
||||||
|
<Reference Include="System.IO.Pipelines, Version=9.0.0.6, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
||||||
|
<HintPath>packages\System.IO.Pipelines.9.0.6\lib\net462\System.IO.Pipelines.dll</HintPath>
|
||||||
|
</Reference>
|
||||||
<Reference Include="System.Memory, Version=4.0.1.2, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
<Reference Include="System.Memory, Version=4.0.1.2, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\System.Memory.4.5.5\lib\net461\System.Memory.dll</HintPath>
|
<HintPath>packages\System.Memory.4.5.5\lib\net461\System.Memory.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
@@ -104,11 +107,11 @@
|
|||||||
<Reference Include="System.Runtime.CompilerServices.Unsafe, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
|
<Reference Include="System.Runtime.CompilerServices.Unsafe, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\System.Runtime.CompilerServices.Unsafe.6.0.0\lib\net461\System.Runtime.CompilerServices.Unsafe.dll</HintPath>
|
<HintPath>packages\System.Runtime.CompilerServices.Unsafe.6.0.0\lib\net461\System.Runtime.CompilerServices.Unsafe.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
<Reference Include="System.Text.Encodings.Web, Version=8.0.0.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
<Reference Include="System.Text.Encodings.Web, Version=9.0.0.6, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\System.Text.Encodings.Web.8.0.0\lib\net462\System.Text.Encodings.Web.dll</HintPath>
|
<HintPath>packages\System.Text.Encodings.Web.9.0.6\lib\net462\System.Text.Encodings.Web.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
<Reference Include="System.Text.Json, Version=8.0.0.1, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
<Reference Include="System.Text.Json, Version=9.0.0.6, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\System.Text.Json.8.0.1\lib\net462\System.Text.Json.dll</HintPath>
|
<HintPath>packages\System.Text.Json.9.0.6\lib\net462\System.Text.Json.dll</HintPath>
|
||||||
</Reference>
|
</Reference>
|
||||||
<Reference Include="System.Threading.Tasks.Extensions, Version=4.2.0.1, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
<Reference Include="System.Threading.Tasks.Extensions, Version=4.2.0.1, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51, processorArchitecture=MSIL">
|
||||||
<HintPath>packages\System.Threading.Tasks.Extensions.4.5.4\lib\net461\System.Threading.Tasks.Extensions.dll</HintPath>
|
<HintPath>packages\System.Threading.Tasks.Extensions.4.5.4\lib\net461\System.Threading.Tasks.Extensions.dll</HintPath>
|
||||||
@@ -181,8 +184,8 @@
|
|||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
<Error Condition="!Exists('packages\Costura.Fody.6.0.0\build\Costura.Fody.props')" Text="$([System.String]::Format('$(ErrorText)', 'packages\Costura.Fody.6.0.0\build\Costura.Fody.props'))" />
|
<Error Condition="!Exists('packages\Costura.Fody.6.0.0\build\Costura.Fody.props')" Text="$([System.String]::Format('$(ErrorText)', 'packages\Costura.Fody.6.0.0\build\Costura.Fody.props'))" />
|
||||||
<Error Condition="!Exists('packages\Costura.Fody.6.0.0\build\Costura.Fody.targets')" Text="$([System.String]::Format('$(ErrorText)', 'packages\Costura.Fody.6.0.0\build\Costura.Fody.targets'))" />
|
<Error Condition="!Exists('packages\Costura.Fody.6.0.0\build\Costura.Fody.targets')" Text="$([System.String]::Format('$(ErrorText)', 'packages\Costura.Fody.6.0.0\build\Costura.Fody.targets'))" />
|
||||||
<Error Condition="!Exists('packages\Fody.6.8.2\build\Fody.targets')" Text="$([System.String]::Format('$(ErrorText)', 'packages\Fody.6.8.2\build\Fody.targets'))" />
|
<Error Condition="!Exists('packages\Fody.6.9.2\build\Fody.targets')" Text="$([System.String]::Format('$(ErrorText)', 'packages\Fody.6.9.2\build\Fody.targets'))" />
|
||||||
</Target>
|
</Target>
|
||||||
<Import Project="packages\Costura.Fody.6.0.0\build\Costura.Fody.targets" Condition="Exists('packages\Costura.Fody.6.0.0\build\Costura.Fody.targets')" />
|
<Import Project="packages\Costura.Fody.6.0.0\build\Costura.Fody.targets" Condition="Exists('packages\Costura.Fody.6.0.0\build\Costura.Fody.targets')" />
|
||||||
<Import Project="packages\Fody.6.8.2\build\Fody.targets" Condition="Exists('packages\Fody.6.8.2\build\Fody.targets')" />
|
<Import Project="packages\Fody.6.9.2\build\Fody.targets" Condition="Exists('packages\Fody.6.9.2\build\Fody.targets')" />
|
||||||
</Project>
|
</Project>
|
120
Form1.Designer.cs
generated
120
Form1.Designer.cs
generated
@@ -1,47 +1,39 @@
|
|||||||
namespace CheckDownload
|
namespace CheckDownload
|
||||||
{
|
{
|
||||||
partial class Update
|
partial class Update
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 必需的设计器变量。
|
/// 必需的设计器变量。
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private System.ComponentModel.IContainer components = null;
|
private System.ComponentModel.IContainer components = null;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 清理所有正在使用的资源。
|
/// 清理所有正在使用的资源。
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="disposing">如果应释放托管资源,为 true;否则为 false。</param>
|
/// <param name="disposing">如果应释放托管资源,为 true;否则为 false。</param>
|
||||||
protected override void Dispose(bool disposing)
|
protected override void Dispose(bool disposing)
|
||||||
{
|
{
|
||||||
if (disposing && (components != null))
|
if (disposing && (components != null))
|
||||||
{
|
{
|
||||||
components.Dispose();
|
components.Dispose();
|
||||||
}
|
}
|
||||||
base.Dispose(disposing);
|
base.Dispose(disposing);
|
||||||
}
|
}
|
||||||
|
|
||||||
#region Windows 窗体设计器生成的代码
|
#region Windows 窗体设计器生成的代码
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 设计器支持所需的方法 - 不要修改
|
/// 设计器支持所需的方法 - 不要修改
|
||||||
/// 使用代码编辑器修改此方法的内容。
|
/// 使用代码编辑器修改此方法的内容。
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private void InitializeComponent()
|
private void InitializeComponent()
|
||||||
{
|
{
|
||||||
this.Update_Text = new System.Windows.Forms.Label();
|
|
||||||
this.Update_Pro = new System.Windows.Forms.ProgressBar();
|
this.Update_Pro = new System.Windows.Forms.ProgressBar();
|
||||||
this.Status_Box = new System.Windows.Forms.Label();
|
this.Status_Box = new System.Windows.Forms.Label();
|
||||||
|
this.Count_Box = new System.Windows.Forms.Label();
|
||||||
|
this.Size_Box = new System.Windows.Forms.Label();
|
||||||
this.SuspendLayout();
|
this.SuspendLayout();
|
||||||
//
|
//
|
||||||
// Update_Text
|
|
||||||
//
|
|
||||||
this.Update_Text.AutoSize = true;
|
|
||||||
this.Update_Text.Location = new System.Drawing.Point(12, 12);
|
|
||||||
this.Update_Text.Name = "Update_Text";
|
|
||||||
this.Update_Text.Size = new System.Drawing.Size(59, 12);
|
|
||||||
this.Update_Text.TabIndex = 0;
|
|
||||||
this.Update_Text.Text = "更新状态:";
|
|
||||||
//
|
|
||||||
// Update_Pro
|
// Update_Pro
|
||||||
//
|
//
|
||||||
this.Update_Pro.Location = new System.Drawing.Point(12, 36);
|
this.Update_Pro.Location = new System.Drawing.Point(12, 36);
|
||||||
@@ -51,22 +43,41 @@
|
|||||||
//
|
//
|
||||||
// Status_Box
|
// Status_Box
|
||||||
//
|
//
|
||||||
this.Status_Box.AutoSize = true;
|
this.Status_Box.AutoEllipsis = true;
|
||||||
this.Status_Box.Location = new System.Drawing.Point(72, 12);
|
this.Status_Box.Location = new System.Drawing.Point(12, 12);
|
||||||
this.Status_Box.Name = "Status_Box";
|
this.Status_Box.Name = "Status_Box";
|
||||||
this.Status_Box.Size = new System.Drawing.Size(23, 12);
|
this.Status_Box.Size = new System.Drawing.Size(165, 12);
|
||||||
this.Status_Box.TabIndex = 2;
|
this.Status_Box.TabIndex = 2;
|
||||||
this.Status_Box.Text = "...";
|
this.Status_Box.Text = "...";
|
||||||
//
|
//
|
||||||
|
// Count_Box
|
||||||
|
//
|
||||||
|
this.Count_Box.Anchor = ((System.Windows.Forms.AnchorStyles)((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Right)));
|
||||||
|
this.Count_Box.Location = new System.Drawing.Point(306, 12);
|
||||||
|
this.Count_Box.Name = "Count_Box";
|
||||||
|
this.Count_Box.Size = new System.Drawing.Size(50, 12);
|
||||||
|
this.Count_Box.TabIndex = 3;
|
||||||
|
this.Count_Box.TextAlign = System.Drawing.ContentAlignment.TopRight;
|
||||||
|
//
|
||||||
|
// Size_Box
|
||||||
|
//
|
||||||
|
this.Size_Box.Anchor = ((System.Windows.Forms.AnchorStyles)((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Right)));
|
||||||
|
this.Size_Box.Location = new System.Drawing.Point(183, 12);
|
||||||
|
this.Size_Box.Name = "Size_Box";
|
||||||
|
this.Size_Box.Size = new System.Drawing.Size(117, 12);
|
||||||
|
this.Size_Box.TabIndex = 4;
|
||||||
|
this.Size_Box.TextAlign = System.Drawing.ContentAlignment.TopRight;
|
||||||
|
//
|
||||||
// Update
|
// Update
|
||||||
//
|
//
|
||||||
this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
|
this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
|
||||||
this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
|
this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
|
||||||
this.ClientSize = new System.Drawing.Size(363, 73);
|
this.ClientSize = new System.Drawing.Size(363, 73);
|
||||||
this.ControlBox = false;
|
this.ControlBox = false;
|
||||||
|
this.Controls.Add(this.Size_Box);
|
||||||
|
this.Controls.Add(this.Count_Box);
|
||||||
this.Controls.Add(this.Status_Box);
|
this.Controls.Add(this.Status_Box);
|
||||||
this.Controls.Add(this.Update_Pro);
|
this.Controls.Add(this.Update_Pro);
|
||||||
this.Controls.Add(this.Update_Text);
|
|
||||||
this.FormBorderStyle = System.Windows.Forms.FormBorderStyle.None;
|
this.FormBorderStyle = System.Windows.Forms.FormBorderStyle.None;
|
||||||
this.MaximizeBox = false;
|
this.MaximizeBox = false;
|
||||||
this.MinimizeBox = false;
|
this.MinimizeBox = false;
|
||||||
@@ -76,15 +87,14 @@
|
|||||||
this.TopMost = true;
|
this.TopMost = true;
|
||||||
this.Load += new System.EventHandler(this.Update_Load);
|
this.Load += new System.EventHandler(this.Update_Load);
|
||||||
this.ResumeLayout(false);
|
this.ResumeLayout(false);
|
||||||
this.PerformLayout();
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
private System.Windows.Forms.Label Update_Text;
|
|
||||||
private System.Windows.Forms.ProgressBar Update_Pro;
|
|
||||||
private System.Windows.Forms.Label Status_Box;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
private System.Windows.Forms.ProgressBar Update_Pro;
|
||||||
|
private System.Windows.Forms.Label Status_Box;
|
||||||
|
private System.Windows.Forms.Label Count_Box;
|
||||||
|
private System.Windows.Forms.Label Size_Box;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
293
Form1.cs
293
Form1.cs
@@ -39,22 +39,29 @@ namespace CheckDownload
|
|||||||
// 阿里云OSS访问密钥Secret
|
// 阿里云OSS访问密钥Secret
|
||||||
private const string OssAccessKeySecret = "7ClQns3wz6psmIp9T2OfuEn3tpzrCK";
|
private const string OssAccessKeySecret = "7ClQns3wz6psmIp9T2OfuEn3tpzrCK";
|
||||||
// 123盘鉴权密钥
|
// 123盘鉴权密钥
|
||||||
private const string OneDriveAuthKey = "ZhwG3LxOtGJwM3ym";
|
private const string OneDriveAuthKey = "6SwdpWdSJuJRSh";
|
||||||
// 123盘UID
|
// 123盘UID
|
||||||
private const string OneDriveUid = "1850250683";
|
private const string OneDriveUid = "1826795402";
|
||||||
// 123盘路径(不包含域名)- 修改此处即可同时生效于主备域名
|
// 123盘路径(不包含域名)- 修改此处即可同时生效于主备域名
|
||||||
private const string OneDrivePath = "/1850250683/SuWin";
|
private const string OneDrivePath = "/1826795402/KeyAuth";
|
||||||
// 123盘主域名
|
// 123盘主域名
|
||||||
private const string OneDriveMainDomain = "vip.123pan.cn";
|
private const string OneDriveMainDomain = "vip.123pan.cn";
|
||||||
// 123盘备用域名
|
// 123盘备用域名
|
||||||
private const string OneDriveBackupDomain = "vip.123yx.com";
|
private const string OneDriveBackupDomain = "vip.123yx.com";
|
||||||
// 123盘鉴权有效时间(秒)
|
// 123盘鉴权有效时间(秒)
|
||||||
private const int OneDriveAuthTimeout = 600;
|
private const int OneDriveAuthTimeout = 600;
|
||||||
|
// 下载流超时时间(毫秒)
|
||||||
|
private const int DownloadStreamTimeoutMs = 60000;
|
||||||
|
|
||||||
// 网络优化: 静态HttpClient实例,避免套接字耗尽
|
// 网络优化: 静态HttpClient实例,避免套接字耗尽
|
||||||
private static readonly HttpClient _httpClient = new HttpClient { Timeout = TimeSpan.FromSeconds(20) };
|
private static readonly HttpClient _httpClient = new HttpClient { Timeout = TimeSpan.FromSeconds(20) };
|
||||||
// OSS客户端:仅初始化一次,避免频繁创建导致内存占用过高
|
// OSS客户端:仅初始化一次,避免频繁创建导致内存占用过高
|
||||||
private static readonly OssClient _ossClient = new OssClient(OssEndpoint, OssAccessKeyId, OssAccessKeySecret);
|
private static readonly ClientConfiguration _ossClientConfig = new ClientConfiguration
|
||||||
|
{
|
||||||
|
ConnectionTimeout = 20000, // 20 seconds
|
||||||
|
MaxErrorRetry = 0
|
||||||
|
};
|
||||||
|
private static readonly OssClient _ossClient = new OssClient(OssEndpoint, OssAccessKeyId, OssAccessKeySecret, _ossClientConfig);
|
||||||
// 网络优化: 备用DNS服务列表,提高解析成功率
|
// 网络优化: 备用DNS服务列表,提高解析成功率
|
||||||
private static readonly List<string> _dnsServers = new List<string> { "223.5.5.5", "119.29.29.29" };
|
private static readonly List<string> _dnsServers = new List<string> { "223.5.5.5", "119.29.29.29" };
|
||||||
// 最大并发下载数量
|
// 最大并发下载数量
|
||||||
@@ -67,6 +74,52 @@ namespace CheckDownload
|
|||||||
private int _completedCount = 0;
|
private int _completedCount = 0;
|
||||||
// 总下载数量
|
// 总下载数量
|
||||||
private int _totalCount = 0;
|
private int _totalCount = 0;
|
||||||
|
// 已下载总字节数
|
||||||
|
private long _totalDownloadedBytes = 0;
|
||||||
|
// 下载总计时器
|
||||||
|
private Stopwatch _overallStopwatch;
|
||||||
|
// 已下载速度字节数
|
||||||
|
private long _speedDownloadedBytes = 0;
|
||||||
|
// 更新计数显示(线程安全)
|
||||||
|
private void UpdateCountBox(int completed, int total)
|
||||||
|
{
|
||||||
|
string text = total > 0 ? $"{completed}/{total}" : "";
|
||||||
|
if (this.InvokeRequired)
|
||||||
|
{
|
||||||
|
this.Invoke((MethodInvoker)delegate { Count_Box.Text = text; });
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Count_Box.Text = text;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// 更新文件大小和速度显示(线程安全)
|
||||||
|
private void UpdateSizeBox(string text)
|
||||||
|
{
|
||||||
|
if (this.InvokeRequired)
|
||||||
|
{
|
||||||
|
this.Invoke((MethodInvoker)delegate { Size_Box.Text = text; });
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Size_Box.Text = text;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// 累计已下载字节并更新Size_Box
|
||||||
|
private void AddDownloadedBytes(long bytes, bool countForSpeed)
|
||||||
|
{
|
||||||
|
long total = Interlocked.Add(ref _totalDownloadedBytes, bytes);
|
||||||
|
if (countForSpeed)
|
||||||
|
{
|
||||||
|
Interlocked.Add(ref _speedDownloadedBytes, bytes);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (_overallStopwatch == null) return;
|
||||||
|
|
||||||
|
double mbTotal = total / 1024.0 / 1024.0;
|
||||||
|
double mbSpeed = (_speedDownloadedBytes / 1024.0 / 1024.0) / Math.Max(0.1, _overallStopwatch.Elapsed.TotalSeconds);
|
||||||
|
UpdateSizeBox($"{mbTotal:F1}MB/{mbSpeed:F1}MB/s");
|
||||||
|
}
|
||||||
// 临时文件夹路径
|
// 临时文件夹路径
|
||||||
private string _tempDirectory;
|
private string _tempDirectory;
|
||||||
// 基准目录路径(用于文件更新的目标目录)
|
// 基准目录路径(用于文件更新的目标目录)
|
||||||
@@ -107,13 +160,11 @@ namespace CheckDownload
|
|||||||
this.Invoke((MethodInvoker)delegate
|
this.Invoke((MethodInvoker)delegate
|
||||||
{
|
{
|
||||||
Update_Pro.Value = Math.Min(Math.Max(percentage, Update_Pro.Minimum), Update_Pro.Maximum);
|
Update_Pro.Value = Math.Min(Math.Max(percentage, Update_Pro.Minimum), Update_Pro.Maximum);
|
||||||
Application.DoEvents();
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
Update_Pro.Value = Math.Min(Math.Max(percentage, Update_Pro.Minimum), Update_Pro.Maximum);
|
Update_Pro.Value = Math.Min(Math.Max(percentage, Update_Pro.Minimum), Update_Pro.Maximum);
|
||||||
Application.DoEvents();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -165,12 +216,12 @@ namespace CheckDownload
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
CleanupNewFiles();
|
CleanupNewFiles();
|
||||||
UpdateStatus("下载在线MD5文件并读取...");
|
UpdateStatus("下载MD5...");
|
||||||
string tempFilePath = Path.Combine(_tempDirectory, Md5File);
|
string tempFilePath = Path.Combine(_tempDirectory, Md5File);
|
||||||
// 使用新的带123盘的下载方法
|
// 使用新的带123盘的下载方法
|
||||||
if (!await DownloadMd5FileWithFallback(Md5File, tempFilePath))
|
if (!await DownloadMd5FileWithFallback(Md5File, tempFilePath))
|
||||||
{
|
{
|
||||||
UpdateStatus("下载在线MD5文件失败");
|
UpdateStatus("MD5下载失败");
|
||||||
await Task.Delay(3000);
|
await Task.Delay(3000);
|
||||||
this.Close();
|
this.Close();
|
||||||
return;
|
return;
|
||||||
@@ -178,7 +229,7 @@ namespace CheckDownload
|
|||||||
var onlineData = ReadOnlineMd5File(tempFilePath);
|
var onlineData = ReadOnlineMd5File(tempFilePath);
|
||||||
if (!ValidateOnlineData(onlineData.Version, onlineData.Md5, onlineData.Data))
|
if (!ValidateOnlineData(onlineData.Version, onlineData.Md5, onlineData.Data))
|
||||||
{
|
{
|
||||||
UpdateStatus("在线MD5文件无效");
|
UpdateStatus("MD5文件无效");
|
||||||
await Task.Delay(3000);
|
await Task.Delay(3000);
|
||||||
this.Close();
|
this.Close();
|
||||||
return;
|
return;
|
||||||
@@ -187,30 +238,34 @@ namespace CheckDownload
|
|||||||
// 基于md5.json内容智能检测基准目录
|
// 基于md5.json内容智能检测基准目录
|
||||||
InitializeBaseDirectoryFromMd5Data(onlineData.Data);
|
InitializeBaseDirectoryFromMd5Data(onlineData.Data);
|
||||||
|
|
||||||
UpdateStatus("比较本地和在线MD5文件...");
|
UpdateStatus("比较文件...");
|
||||||
var compareResult = CompareMd5Data(onlineData.Data);
|
var compareResult = CompareMd5Data(onlineData.Data);
|
||||||
if (compareResult.Count == 0)
|
if (compareResult.Count == 0)
|
||||||
{
|
{
|
||||||
UpdateStatus("所有文件都是最新的,无需更新");
|
|
||||||
UpdateProgressValue(100);
|
UpdateProgressValue(100);
|
||||||
|
UpdateCountBox(0, 0);
|
||||||
|
UpdateSizeBox("");
|
||||||
|
|
||||||
// 无需更新时清理临时文件夹
|
// 无需更新时清理临时文件夹
|
||||||
CleanupTempDirectory();
|
CleanupTempDirectory();
|
||||||
|
UpdateStatus("无需更新");
|
||||||
// 显示更新完成并等待2秒
|
|
||||||
UpdateStatus("更新完成");
|
|
||||||
await Task.Delay(2000);
|
await Task.Delay(2000);
|
||||||
this.Close();
|
this.Close();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus("下载并验证文件...");
|
UpdateStatus("下载文件...");
|
||||||
// 根据路径长度排序,优先下载小文件/浅层文件,可加其它排序规则
|
// 根据路径长度排序,优先下载小文件/浅层文件,可加其它排序规则
|
||||||
var orderedFileList = compareResult.OrderBy(k => k.Key.Length)
|
var orderedFileList = compareResult.OrderBy(k => k.Key.Length)
|
||||||
.ToDictionary(k => k.Key, v => v.Value);
|
.ToDictionary(k => k.Key, v => v.Value);
|
||||||
|
|
||||||
_totalCount = orderedFileList.Count;
|
_totalCount = orderedFileList.Count;
|
||||||
_completedCount = 0;
|
_completedCount = 0;
|
||||||
|
_totalDownloadedBytes = 0;
|
||||||
|
_speedDownloadedBytes = 0;
|
||||||
|
_overallStopwatch = Stopwatch.StartNew();
|
||||||
|
UpdateSizeBox("0MB/0MB/s");
|
||||||
|
UpdateCountBox(_completedCount, _totalCount);
|
||||||
_downloadedFiles.Clear();
|
_downloadedFiles.Clear();
|
||||||
var failedFiles = new ConcurrentDictionary<string, string>();
|
var failedFiles = new ConcurrentDictionary<string, string>();
|
||||||
|
|
||||||
@@ -218,17 +273,17 @@ namespace CheckDownload
|
|||||||
|
|
||||||
if (!failedFiles.IsEmpty)
|
if (!failedFiles.IsEmpty)
|
||||||
{
|
{
|
||||||
UpdateStatus($"有 {failedFiles.Count} 个文件下载失败,开始重试...");
|
UpdateStatus($"重试 {failedFiles.Count} 个失败文件...");
|
||||||
var stillFailing = await RetryFailedFilesAsync(new Dictionary<string, string>(failedFiles));
|
var stillFailing = await RetryFailedFilesAsync(new Dictionary<string, string>(failedFiles));
|
||||||
if (stillFailing.Any())
|
if (stillFailing.Any())
|
||||||
{
|
{
|
||||||
UpdateStatus($"重试后仍有 {stillFailing.Count} 个文件下载失败。");
|
UpdateStatus($"{stillFailing.Count} 个文件重试失败");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (_completedCount == 0 && orderedFileList.Count > 0)
|
if (_completedCount == 0 && orderedFileList.Count > 0)
|
||||||
{
|
{
|
||||||
throw new Exception("所有文件下载失败。");
|
throw new Exception("全部文件下载失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
await VerifyAndSaveAllFiles();
|
await VerifyAndSaveAllFiles();
|
||||||
@@ -238,13 +293,15 @@ namespace CheckDownload
|
|||||||
|
|
||||||
// 显示完成状态并退出
|
// 显示完成状态并退出
|
||||||
UpdateStatus("更新完成");
|
UpdateStatus("更新完成");
|
||||||
|
UpdateCountBox(0, 0);
|
||||||
|
UpdateSizeBox("");
|
||||||
await Task.Delay(3000);
|
await Task.Delay(3000);
|
||||||
this.Close();
|
this.Close();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
UpdateStatus($"更新失败: {ex.Message}");
|
UpdateStatus($"更新失败: {ex.Message.Split(new[] { '\r', '\n' }, StringSplitOptions.RemoveEmptyEntries).FirstOrDefault()}");
|
||||||
await Task.Delay(3000);
|
await Task.Delay(3000);
|
||||||
this.Close();
|
this.Close();
|
||||||
}
|
}
|
||||||
@@ -260,7 +317,7 @@ namespace CheckDownload
|
|||||||
var newFiles = Directory.GetFiles(_baseDirectory, "*.new", SearchOption.AllDirectories);
|
var newFiles = Directory.GetFiles(_baseDirectory, "*.new", SearchOption.AllDirectories);
|
||||||
if (newFiles.Length > 0)
|
if (newFiles.Length > 0)
|
||||||
{
|
{
|
||||||
UpdateStatus("正在清理旧的更新文件...");
|
UpdateStatus("清理旧文件...");
|
||||||
foreach (var file in newFiles)
|
foreach (var file in newFiles)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
@@ -297,9 +354,14 @@ namespace CheckDownload
|
|||||||
return (version, jsonMd5, data);
|
return (version, jsonMd5, data);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex) when (ex is OssException || ex is JsonException)
|
catch (OssException)
|
||||||
{
|
{
|
||||||
UpdateStatus($"读取在线MD5文件失败: {ex.Message}");
|
UpdateStatus("读取MD5失败");
|
||||||
|
return (null, null, null);
|
||||||
|
}
|
||||||
|
catch (JsonException)
|
||||||
|
{
|
||||||
|
UpdateStatus("读取MD5失败");
|
||||||
return (null, null, null);
|
return (null, null, null);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -315,7 +377,7 @@ namespace CheckDownload
|
|||||||
{
|
{
|
||||||
if (string.IsNullOrEmpty(version) || string.IsNullOrEmpty(md5) || data == null)
|
if (string.IsNullOrEmpty(version) || string.IsNullOrEmpty(md5) || data == null)
|
||||||
{
|
{
|
||||||
UpdateStatus("在线MD5文件无效");
|
UpdateStatus("MD5文件无效");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
@@ -384,6 +446,11 @@ namespace CheckDownload
|
|||||||
{
|
{
|
||||||
_totalCount = fileList.Count;
|
_totalCount = fileList.Count;
|
||||||
_completedCount = 0;
|
_completedCount = 0;
|
||||||
|
_totalDownloadedBytes = 0;
|
||||||
|
_speedDownloadedBytes = 0;
|
||||||
|
_overallStopwatch = Stopwatch.StartNew();
|
||||||
|
UpdateSizeBox("0MB/0MB/s");
|
||||||
|
UpdateCountBox(_completedCount, _totalCount);
|
||||||
_downloadedFiles.Clear();
|
_downloadedFiles.Clear();
|
||||||
var failedFiles = new ConcurrentDictionary<string, string>();
|
var failedFiles = new ConcurrentDictionary<string, string>();
|
||||||
|
|
||||||
@@ -391,11 +458,11 @@ namespace CheckDownload
|
|||||||
|
|
||||||
if (!failedFiles.IsEmpty)
|
if (!failedFiles.IsEmpty)
|
||||||
{
|
{
|
||||||
UpdateStatus($"有 {failedFiles.Count} 个文件下载失败,开始重试...");
|
UpdateStatus($"重试 {failedFiles.Count} 个失败文件...");
|
||||||
var stillFailing = await RetryFailedFilesAsync(new Dictionary<string, string>(failedFiles));
|
var stillFailing = await RetryFailedFilesAsync(new Dictionary<string, string>(failedFiles));
|
||||||
if (stillFailing.Any())
|
if (stillFailing.Any())
|
||||||
{
|
{
|
||||||
UpdateStatus($"重试后仍有 {stillFailing.Count} 个文件下载失败。");
|
UpdateStatus($"{stillFailing.Count} 个文件重试失败");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -432,7 +499,8 @@ namespace CheckDownload
|
|||||||
int progress = (int)((double)_completedCount / _totalCount * 95);
|
int progress = (int)((double)_completedCount / _totalCount * 95);
|
||||||
UpdateProgressValue(progress);
|
UpdateProgressValue(progress);
|
||||||
|
|
||||||
UpdateStatus($"{Path.GetFileName(file.Key)} {_completedCount}/{_totalCount}");
|
UpdateStatus($"下载: {Path.GetFileName(file.Key)}");
|
||||||
|
UpdateCountBox(_completedCount, _totalCount);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -457,21 +525,29 @@ namespace CheckDownload
|
|||||||
{
|
{
|
||||||
string tempFilePath = Path.Combine(_tempDirectory, filePath);
|
string tempFilePath = Path.Combine(_tempDirectory, filePath);
|
||||||
string fileName = Path.GetFileName(filePath);
|
string fileName = Path.GetFileName(filePath);
|
||||||
|
long downloadedBytes = 0;
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (await CheckExistingTempFile(tempFilePath, expectedMd5, fileName))
|
if (await CheckExistingTempFile(tempFilePath, expectedMd5, fileName))
|
||||||
{
|
{
|
||||||
|
// 已存在临时文件
|
||||||
|
downloadedBytes = new FileInfo(tempFilePath).Length;
|
||||||
|
AddDownloadedBytes(downloadedBytes, false);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus($"{fileName} {_completedCount + 1}/{_totalCount}");
|
UpdateStatus($"下载: {fileName}");
|
||||||
|
UpdateCountBox(_completedCount + 1, _totalCount);
|
||||||
if (await DownloadFileFromOneDrive(filePath, expectedMd5, tempFilePath))
|
if (await DownloadFileFromOneDrive(filePath, expectedMd5, tempFilePath))
|
||||||
{
|
{
|
||||||
|
downloadedBytes = new FileInfo(tempFilePath).Length;
|
||||||
|
AddDownloadedBytes(downloadedBytes, true);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus($"{fileName} {_completedCount + 1}/{_totalCount}");
|
UpdateStatus($"下载: {fileName}");
|
||||||
|
UpdateCountBox(_completedCount + 1, _totalCount);
|
||||||
string ossKey = $"File/{expectedMd5}";
|
string ossKey = $"File/{expectedMd5}";
|
||||||
|
|
||||||
var obj = _ossClient.GetObject(OssBucketName, ossKey);
|
var obj = _ossClient.GetObject(OssBucketName, ossKey);
|
||||||
@@ -484,19 +560,38 @@ namespace CheckDownload
|
|||||||
|
|
||||||
using (var fileStream = File.Create(tempFilePath))
|
using (var fileStream = File.Create(tempFilePath))
|
||||||
{
|
{
|
||||||
await obj.Content.CopyToAsync(fileStream);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await obj.Content.CopyToAsync(fileStream, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
downloadedBytes = new FileInfo(tempFilePath).Length;
|
||||||
|
AddDownloadedBytes(downloadedBytes, true);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
catch (Exception ex) when (ex is OssException || ex is WebException)
|
catch (Exception ex) when (ex is OssException || ex is WebException || ex is OperationCanceledException)
|
||||||
{
|
{
|
||||||
UpdateStatus($"{fileName} {_completedCount + 1}/{_totalCount}");
|
UpdateStatus($"下载: {fileName}");
|
||||||
|
UpdateCountBox(_completedCount + 1, _totalCount);
|
||||||
string ossKey = $"File/{expectedMd5}";
|
string ossKey = $"File/{expectedMd5}";
|
||||||
return await DownloadFileWithFallback(ossKey, tempFilePath);
|
bool ok = await DownloadFileWithFallback(ossKey, tempFilePath);
|
||||||
|
if (ok)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
downloadedBytes = new FileInfo(tempFilePath).Length;
|
||||||
|
AddDownloadedBytes(downloadedBytes, true);
|
||||||
|
}
|
||||||
|
catch
|
||||||
|
{
|
||||||
|
// File might not be accessible for a moment after download
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ok;
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"下载异常: {fileName} - {ex.Message}");
|
UpdateStatus($"下载异常: {fileName}");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -517,25 +612,25 @@ namespace CheckDownload
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus($"检查已存在的临时文件: {fileName}");
|
UpdateStatus($"检查: {fileName}");
|
||||||
|
|
||||||
string actualMd5 = await Task.Run(() => CalculateMD5FromFile(tempFilePath));
|
string actualMd5 = await Task.Run(() => CalculateMD5FromFile(tempFilePath));
|
||||||
|
|
||||||
if (actualMd5.Equals(expectedMd5, StringComparison.OrdinalIgnoreCase))
|
if (actualMd5.Equals(expectedMd5, StringComparison.OrdinalIgnoreCase))
|
||||||
{
|
{
|
||||||
UpdateStatus($"临时文件完整,跳过下载: {fileName}");
|
UpdateStatus($"跳过: {fileName}");
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
UpdateStatus($"临时文件不完整,重新下载: {fileName}");
|
UpdateStatus($"重下载: {fileName}");
|
||||||
File.Delete(tempFilePath);
|
File.Delete(tempFilePath);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
UpdateStatus($"检查临时文件时出错,将重新下载: {fileName} - {ex.Message}");
|
UpdateStatus($"检查出错: {fileName}");
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (File.Exists(tempFilePath))
|
if (File.Exists(tempFilePath))
|
||||||
@@ -561,11 +656,11 @@ namespace CheckDownload
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
UpdateStatus($"正在从123盘下载: {fileName}");
|
UpdateStatus($"123盘下载: {fileName}");
|
||||||
|
|
||||||
string authUrl = GenerateAuthUrl($"http://{OneDriveMainDomain}{OneDrivePath}", fileName);
|
string authUrl = GenerateAuthUrl($"http://{OneDriveMainDomain}{OneDrivePath}", fileName);
|
||||||
|
|
||||||
UpdateStatus($"使用主域名下载文件...");
|
UpdateStatus("123盘主域...");
|
||||||
|
|
||||||
var request = new HttpRequestMessage(HttpMethod.Get, authUrl) { Version = HttpVersion.Version11 };
|
var request = new HttpRequestMessage(HttpMethod.Get, authUrl) { Version = HttpVersion.Version11 };
|
||||||
request.Headers.Add("User-Agent", "CheckDownload/1.0");
|
request.Headers.Add("User-Agent", "CheckDownload/1.0");
|
||||||
@@ -582,25 +677,28 @@ namespace CheckDownload
|
|||||||
using (var remote = await response.Content.ReadAsStreamAsync())
|
using (var remote = await response.Content.ReadAsStreamAsync())
|
||||||
using (var localFile = File.Create(localPath))
|
using (var localFile = File.Create(localPath))
|
||||||
{
|
{
|
||||||
await remote.CopyToAsync(localFile);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await remote.CopyToAsync(localFile, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus($"123盘主域名下载成功: {fileName}");
|
UpdateStatus($"主域成功: {fileName}");
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"123盘主域名下载失败,尝试备用域名: {fileName}");
|
UpdateStatus("主域失败, 转备用...");
|
||||||
}
|
}
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
UpdateStatus($"正在从123盘备用域名下载: {fileName}");
|
UpdateStatus($"123盘备用下载: {fileName}");
|
||||||
|
|
||||||
string authUrl = GenerateAuthUrl($"http://{OneDriveBackupDomain}{OneDrivePath}", fileName);
|
string authUrl = GenerateAuthUrl($"http://{OneDriveBackupDomain}{OneDrivePath}", fileName);
|
||||||
|
|
||||||
UpdateStatus($"使用备用域名下载文件...");
|
UpdateStatus("123盘备用域...");
|
||||||
|
|
||||||
var request = new HttpRequestMessage(HttpMethod.Get, authUrl) { Version = HttpVersion.Version11 };
|
var request = new HttpRequestMessage(HttpMethod.Get, authUrl) { Version = HttpVersion.Version11 };
|
||||||
request.Headers.Add("User-Agent", "CheckDownload/1.0");
|
request.Headers.Add("User-Agent", "CheckDownload/1.0");
|
||||||
@@ -617,16 +715,19 @@ namespace CheckDownload
|
|||||||
using (var remote = await response.Content.ReadAsStreamAsync())
|
using (var remote = await response.Content.ReadAsStreamAsync())
|
||||||
using (var localFile = File.Create(localPath))
|
using (var localFile = File.Create(localPath))
|
||||||
{
|
{
|
||||||
await remote.CopyToAsync(localFile);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await remote.CopyToAsync(localFile, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus($"123盘备用域名下载成功: {fileName}");
|
UpdateStatus($"备用域成功: {fileName}");
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"123盘备用域名下载失败: {fileName} - {ex.Message}");
|
UpdateStatus($"备用域失败: {fileName}");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -661,7 +762,10 @@ namespace CheckDownload
|
|||||||
using (var remote = await response.Content.ReadAsStreamAsync())
|
using (var remote = await response.Content.ReadAsStreamAsync())
|
||||||
using (var localFile = File.Create(localPath))
|
using (var localFile = File.Create(localPath))
|
||||||
{
|
{
|
||||||
await remote.CopyToAsync(localFile);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await remote.CopyToAsync(localFile, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
@@ -690,13 +794,16 @@ namespace CheckDownload
|
|||||||
using (var remote = await response.Content.ReadAsStreamAsync())
|
using (var remote = await response.Content.ReadAsStreamAsync())
|
||||||
using (var localFile = File.Create(localPath))
|
using (var localFile = File.Create(localPath))
|
||||||
{
|
{
|
||||||
await remote.CopyToAsync(localFile);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await remote.CopyToAsync(localFile, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
@@ -713,7 +820,7 @@ namespace CheckDownload
|
|||||||
|
|
||||||
for (int i = 0; i < MaxDownloadRetries && filesToRetry.Any(); i++)
|
for (int i = 0; i < MaxDownloadRetries && filesToRetry.Any(); i++)
|
||||||
{
|
{
|
||||||
UpdateStatus($"第 {i + 1} 次重试,剩余 {filesToRetry.Count} 个文件...");
|
UpdateStatus($"重试 {i + 1}/{MaxDownloadRetries}, 剩{filesToRetry.Count}个");
|
||||||
var failedThisRound = new ConcurrentDictionary<string, string>();
|
var failedThisRound = new ConcurrentDictionary<string, string>();
|
||||||
|
|
||||||
await PerformDownloads(filesToRetry, failedThisRound);
|
await PerformDownloads(filesToRetry, failedThisRound);
|
||||||
@@ -722,7 +829,7 @@ namespace CheckDownload
|
|||||||
|
|
||||||
if (filesToRetry.Any() && i < MaxDownloadRetries - 1)
|
if (filesToRetry.Any() && i < MaxDownloadRetries - 1)
|
||||||
{
|
{
|
||||||
UpdateStatus($"等待 3 秒后进行下一次重试...");
|
UpdateStatus("等待3秒后重试");
|
||||||
await Task.Delay(3000);
|
await Task.Delay(3000);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -753,18 +860,18 @@ namespace CheckDownload
|
|||||||
var ips = JsonConvert.DeserializeObject<List<string>>(responseBody);
|
var ips = JsonConvert.DeserializeObject<List<string>>(responseBody);
|
||||||
if (ips != null && ips.Any())
|
if (ips != null && ips.Any())
|
||||||
{
|
{
|
||||||
UpdateStatus($"通过 {dnsServer} 成功解析域名 {domain}");
|
UpdateStatus($"DNS解析成功: {dnsServer}");
|
||||||
return ips;
|
return ips;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"通过 {dnsServer} 解析域名失败,尝试下一个...");
|
UpdateStatus($"DNS解析失败: {dnsServer}");
|
||||||
await Task.Delay(500);
|
await Task.Delay(500);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus($"所有DNS服务器均无法解析域名: {domain}");
|
UpdateStatus("所有DNS解析失败");
|
||||||
return new List<string>();
|
return new List<string>();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -773,7 +880,7 @@ namespace CheckDownload
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
private async Task VerifyAndSaveAllFiles()
|
private async Task VerifyAndSaveAllFiles()
|
||||||
{
|
{
|
||||||
UpdateStatus("正在校验文件...");
|
UpdateStatus("校验文件...");
|
||||||
var failedFiles = new ConcurrentBag<string>();
|
var failedFiles = new ConcurrentBag<string>();
|
||||||
var filesForScripting = new ConcurrentBag<(string original, string newFile)>();
|
var filesForScripting = new ConcurrentBag<(string original, string newFile)>();
|
||||||
|
|
||||||
@@ -839,7 +946,7 @@ namespace CheckDownload
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
UpdateStatus("所有文件校验和保存成功");
|
UpdateStatus("校验保存成功");
|
||||||
UpdateProgressValue(100);
|
UpdateProgressValue(100);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -859,25 +966,25 @@ namespace CheckDownload
|
|||||||
}
|
}
|
||||||
catch (IOException)
|
catch (IOException)
|
||||||
{
|
{
|
||||||
UpdateStatus($"文件被占用,尝试解锁...");
|
UpdateStatus("文件占用,解锁中...");
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
await Task.Delay(1000);
|
await Task.Delay(1000);
|
||||||
|
|
||||||
File.Move(sourcePath, targetPath);
|
File.Move(sourcePath, targetPath);
|
||||||
UpdateStatus($"文件解锁成功并已更新");
|
UpdateStatus("解锁并更新成功");
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
catch
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"文件仍被占用,无法移动");
|
UpdateStatus("文件仍被占用");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
UpdateStatus($"移动文件时发生错误: {ex.Message}");
|
UpdateStatus("移动文件出错");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -927,9 +1034,9 @@ namespace CheckDownload
|
|||||||
};
|
};
|
||||||
Process.Start(startInfo);
|
Process.Start(startInfo);
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"创建替换脚本时出错: {ex.Message}");
|
UpdateStatus("创建脚本出错");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -951,9 +1058,9 @@ namespace CheckDownload
|
|||||||
Directory.CreateDirectory(_tempDirectory);
|
Directory.CreateDirectory(_tempDirectory);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"初始化临时目录失败: {ex.Message}");
|
UpdateStatus("初始化Temp失败");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1004,13 +1111,28 @@ namespace CheckDownload
|
|||||||
}
|
}
|
||||||
using (var fileStream = File.Create(localPath))
|
using (var fileStream = File.Create(localPath))
|
||||||
{
|
{
|
||||||
obj.Content.CopyTo(fileStream);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await obj.Content.CopyToAsync(fileStream, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
catch (Exception ex) when (ex is OssException || ex is WebException || ex is IOException)
|
catch (OssException)
|
||||||
{
|
{
|
||||||
UpdateStatus($"主下载失败,尝试备用方案...");
|
UpdateStatus("主下载失败,转备用...");
|
||||||
|
}
|
||||||
|
catch (WebException)
|
||||||
|
{
|
||||||
|
UpdateStatus("主下载失败,转备用...");
|
||||||
|
}
|
||||||
|
catch (IOException)
|
||||||
|
{
|
||||||
|
UpdateStatus("主下载失败,转备用...");
|
||||||
|
}
|
||||||
|
catch (OperationCanceledException)
|
||||||
|
{
|
||||||
|
UpdateStatus("主下载失败,转备用...");
|
||||||
}
|
}
|
||||||
|
|
||||||
var domain = new Uri("https://" + OssEndpoint).Host;
|
var domain = new Uri("https://" + OssEndpoint).Host;
|
||||||
@@ -1048,14 +1170,21 @@ namespace CheckDownload
|
|||||||
using (var remote = await response.Content.ReadAsStreamAsync())
|
using (var remote = await response.Content.ReadAsStreamAsync())
|
||||||
using (var localFile = File.Create(localPath))
|
using (var localFile = File.Create(localPath))
|
||||||
{
|
{
|
||||||
await remote.CopyToAsync(localFile);
|
using (var cts = new CancellationTokenSource(DownloadStreamTimeoutMs))
|
||||||
|
{
|
||||||
|
await remote.CopyToAsync(localFile, 81920, cts.Token);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
catch (Exception)
|
catch (HttpRequestException)
|
||||||
{
|
{
|
||||||
UpdateStatus($"备用方案用IP {ip} 下载失败");
|
UpdateStatus($"IP下载失败: {ip}");
|
||||||
|
}
|
||||||
|
catch (OperationCanceledException)
|
||||||
|
{
|
||||||
|
UpdateStatus($"IP下载失败: {ip}");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
@@ -1130,9 +1259,9 @@ namespace CheckDownload
|
|||||||
|
|
||||||
return authUrl;
|
return authUrl;
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
UpdateStatus($"生成鉴权URL失败: {ex.Message}");
|
UpdateStatus("生成AuthUrl失败");
|
||||||
return $"{url}/{file}";
|
return $"{url}/{file}";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1184,18 +1313,18 @@ namespace CheckDownload
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
UpdateStatus("尝试从123盘下载MD5文件...");
|
UpdateStatus("123盘下载MD5...");
|
||||||
if (await DownloadFromOneDrive($"http://{OneDriveMainDomain}{OneDrivePath}", fileName, localPath))
|
if (await DownloadFromOneDrive($"http://{OneDriveMainDomain}{OneDrivePath}", fileName, localPath))
|
||||||
{
|
{
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
UpdateStatus("123盘下载失败,尝试阿里云OSS备用方案...");
|
UpdateStatus("123盘失败,转OSS...");
|
||||||
return await DownloadFileWithFallback(fileName, localPath);
|
return await DownloadFileWithFallback(fileName, localPath);
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
UpdateStatus($"所有下载方式都失败: {ex.Message}");
|
UpdateStatus("所有下载方式均失败");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1215,7 +1344,7 @@ namespace CheckDownload
|
|||||||
|
|
||||||
if (Directory.Exists(tempPath))
|
if (Directory.Exists(tempPath))
|
||||||
{
|
{
|
||||||
UpdateStatus("清理临时文件...");
|
UpdateStatus("清理Temp...");
|
||||||
Directory.Delete(tempPath, true);
|
Directory.Delete(tempPath, true);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1343,7 +1472,7 @@ namespace CheckDownload
|
|||||||
|
|
||||||
return currentDir;
|
return currentDir;
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch
|
||||||
{
|
{
|
||||||
return currentDir;
|
return currentDir;
|
||||||
}
|
}
|
||||||
|
@@ -3,16 +3,17 @@
|
|||||||
<package id="Aliyun.OSS.SDK" version="2.14.1" targetFramework="net472" />
|
<package id="Aliyun.OSS.SDK" version="2.14.1" targetFramework="net472" />
|
||||||
<package id="Costura.Fody" version="6.0.0" targetFramework="net472" developmentDependency="true" />
|
<package id="Costura.Fody" version="6.0.0" targetFramework="net472" developmentDependency="true" />
|
||||||
<package id="DnsClient" version="1.8.0" targetFramework="net472" />
|
<package id="DnsClient" version="1.8.0" targetFramework="net472" />
|
||||||
<package id="Fody" version="6.8.2" targetFramework="net472" developmentDependency="true" />
|
<package id="Fody" version="6.9.2" targetFramework="net472" developmentDependency="true" />
|
||||||
<package id="LanzouCloudSolve" version="1.0.3" targetFramework="net472" />
|
<package id="LanzouCloudSolve" version="1.0.3" targetFramework="net472" />
|
||||||
<package id="Microsoft.Bcl.AsyncInterfaces" version="8.0.0" targetFramework="net472" />
|
<package id="Microsoft.Bcl.AsyncInterfaces" version="9.0.6" targetFramework="net472" />
|
||||||
<package id="Newtonsoft.Json" version="13.0.3" targetFramework="net472" />
|
<package id="Newtonsoft.Json" version="13.0.3" targetFramework="net472" />
|
||||||
<package id="System.Buffers" version="4.5.1" targetFramework="net472" />
|
<package id="System.Buffers" version="4.5.1" targetFramework="net472" />
|
||||||
|
<package id="System.IO.Pipelines" version="9.0.6" targetFramework="net472" />
|
||||||
<package id="System.Memory" version="4.5.5" targetFramework="net472" />
|
<package id="System.Memory" version="4.5.5" targetFramework="net472" />
|
||||||
<package id="System.Numerics.Vectors" version="4.5.0" targetFramework="net472" />
|
<package id="System.Numerics.Vectors" version="4.5.0" targetFramework="net472" />
|
||||||
<package id="System.Runtime.CompilerServices.Unsafe" version="6.0.0" targetFramework="net472" />
|
<package id="System.Runtime.CompilerServices.Unsafe" version="6.0.0" targetFramework="net472" />
|
||||||
<package id="System.Text.Encodings.Web" version="8.0.0" targetFramework="net472" />
|
<package id="System.Text.Encodings.Web" version="9.0.6" targetFramework="net472" />
|
||||||
<package id="System.Text.Json" version="8.0.1" targetFramework="net472" />
|
<package id="System.Text.Json" version="9.0.6" targetFramework="net472" />
|
||||||
<package id="System.Threading.Tasks.Extensions" version="4.5.4" targetFramework="net472" />
|
<package id="System.Threading.Tasks.Extensions" version="4.5.4" targetFramework="net472" />
|
||||||
<package id="System.ValueTuple" version="4.5.0" targetFramework="net472" />
|
<package id="System.ValueTuple" version="4.5.0" targetFramework="net472" />
|
||||||
</packages>
|
</packages>
|
Reference in New Issue
Block a user