improve:Dlass笔记上传服务
This commit is contained in:
@@ -161,7 +161,17 @@ namespace Ink_Canvas.Helpers
|
|||||||
{
|
{
|
||||||
LogHelper.WriteLogToFile($"已恢复上传队列:{restoredCount}个文件,跳过{skippedCount}个无效文件", LogHelper.LogType.Event);
|
LogHelper.WriteLogToFile($"已恢复上传队列:{restoredCount}个文件,跳过{skippedCount}个无效文件", LogHelper.LogType.Event);
|
||||||
// 如果恢复了队列,触发处理
|
// 如果恢复了队列,触发处理
|
||||||
_ = ProcessUploadQueueAsync();
|
_ = Task.Run(async () =>
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await ProcessUploadQueueAsync().ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogToFile($"恢复上传队列后处理时出错: {ex}", LogHelper.LogType.Error);
|
||||||
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
else if (skippedCount > 0)
|
else if (skippedCount > 0)
|
||||||
{
|
{
|
||||||
@@ -357,8 +367,15 @@ namespace Ink_Canvas.Helpers
|
|||||||
{
|
{
|
||||||
_ = Task.Run(async () =>
|
_ = Task.Run(async () =>
|
||||||
{
|
{
|
||||||
await Task.Delay(TimeSpan.FromMinutes(delayMinutes));
|
try
|
||||||
EnqueueFile(filePath);
|
{
|
||||||
|
await Task.Delay(TimeSpan.FromMinutes(delayMinutes)).ConfigureAwait(false);
|
||||||
|
EnqueueFile(filePath);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogToFile($"延迟加入上传队列时出错: {ex}", LogHelper.LogType.Error);
|
||||||
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@@ -387,7 +404,17 @@ namespace Ink_Canvas.Helpers
|
|||||||
});
|
});
|
||||||
|
|
||||||
// 异步保存队列到文件
|
// 异步保存队列到文件
|
||||||
_ = Task.Run(async () => await SaveQueueToFileAsync());
|
_ = Task.Run(async () =>
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await SaveQueueToFileAsync().ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogToFile($"保存上传队列时出错(后台任务): {ex}", LogHelper.LogType.Error);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
// 如果队列达到批量大小,触发批量上传
|
// 如果队列达到批量大小,触发批量上传
|
||||||
if (_uploadQueue.Count >= BATCH_SIZE)
|
if (_uploadQueue.Count >= BATCH_SIZE)
|
||||||
@@ -566,7 +593,17 @@ namespace Ink_Canvas.Helpers
|
|||||||
// 如果队列达到批量大小,继续处理
|
// 如果队列达到批量大小,继续处理
|
||||||
if (_uploadQueue.Count >= BATCH_SIZE)
|
if (_uploadQueue.Count >= BATCH_SIZE)
|
||||||
{
|
{
|
||||||
_ = ProcessUploadQueueAsync();
|
_ = Task.Run(async () =>
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await ProcessUploadQueueAsync().ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
LogHelper.WriteLogToFile($"继续批量处理上传队列时出错: {ex}", LogHelper.LogType.Error);
|
||||||
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
|
|||||||
Reference in New Issue
Block a user