test/ant-design-blazor
1
0
Fork 0
mirror of https://gitee.com/ant-design-blazor/ant-design-blazor.git synced 2024-12-02 03:57:38 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

fix(module: statistic): countdown pause while the navigate to other page (#3329)

Browse Source
This commit is contained in:
James Yeung 2023-07-01 16:51:17 +08:00 committed by GitHub
parent e0621d400d
commit e50750619e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 43 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

73
components/statistic/CountDown.razor.cs
View File

@ -1,6 +1,6 @@
using System;
using System.Text.RegularExpressions;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Components;
namespace AntDesign
@ -32,54 +32,67 @@ namespace AntDesign
[Parameter]
public int RefreshInterval { get; set; } = REFRESH_INTERVAL;
private Timer _timer;
private const int REFRESH_INTERVAL = 1000 / 10;
private TimeSpan _countDown = TimeSpan.Zero;
private CancellationTokenSource _cts = new();
private bool _firstAfterRender;
protected override void OnInitialized()
{
base.OnInitialized();
SetTimer();
}
private void SetTimer()
protected override async Task OnInitializedAsync()
{
_countDown = Value - DateTime.Now;
_timer = new Timer(StartCountDownForTimeSpan);
_timer.Change(0, RefreshInterval);
await base.OnInitializedAsync();
}
private void StartCountDownForTimeSpan(object o)
protected override void OnAfterRender(bool firstRender)
{
_countDown = _countDown.Add(TimeSpan.FromMilliseconds(-RefreshInterval));
if (_countDown.Ticks <= 0)
if (firstRender)
{
_countDown = TimeSpan.Zero;
_timer.Dispose();
if (OnFinish.HasDelegate)
{
InvokeAsync(() => OnFinish.InvokeAsync(o));
}
_firstAfterRender = true;
_ = StartCountDownForTimeSpan();
}
base.OnAfterRender(firstRender);
}
private async Task StartCountDownForTimeSpan()
{
if (!_firstAfterRender)
{
return;
}
if (_cts.Token.IsCancellationRequested)
{
_cts = new();
}
while (!_cts.Token.IsCancellationRequested)
{
_countDown = Value - DateTime.Now;
if (_countDown.Ticks <= 0)
{
_countDown = TimeSpan.Zero;
if (OnFinish.HasDelegate)
{
await OnFinish.InvokeAsync(this);
}
_cts.Cancel();
break;
}
InvokeStateHasChanged();
await Task.Delay(RefreshInterval, _cts.Token);
}
InvokeStateHasChanged();
}
public void Reset()
{
//避免初始化时调用Reset
if (_timer != null)
{
_timer.Dispose();
SetTimer();
}
_ = StartCountDownForTimeSpan();
}
protected override void Dispose(bool disposing)
{
_timer?.Dispose();
_cts?.Cancel();
base.Dispose(disposing);
}
}
}
}