GithubStar/SteamTools
1
0
Fork 0
mirror of https://github.com/BeyondDimension/SteamTools.git synced 2026-10-22 09:36:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

NotificationService

Browse Source
This commit is contained in:
RMBGAME
2022-07-20 18:03:04 +08:00
parent 9119b68b6d
commit dc487ca09e
1 changed files with 10 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ST.Client/Services/Mvvm/NotificationService.cs
+10 -15
View File
@@ -104,7 +104,6 @@ namespace System.Application.Services
{
var client = ICloudServiceClient.Instance.Notice;
var typeid = selectGroup == DefaultType ? null : selectGroup?.Id;
var isAll = typeid is null;
var result = await client.Table(typeid, 1, 30);
if (result.IsSuccess && result.Content != null)
{
@@ -114,31 +113,25 @@ namespace System.Application.Services
// item.PictureStream = httpService.GetImageAsync(item.Picture, ImageChannelType.NoticePicture);
//}
NoticesSource.Clear();
NoticesSource.AddOrUpdate(result.Content.DataSource);
if (isAll)
{
await LoadHasReadRecord();
}
var data = await LoadHasReadRecord(result.Content.DataSource);
NoticesSource.AddOrUpdate(data);
}
}
public async Task LoadHasReadRecord()
public async Task<List<NoticeDTO>> LoadHasReadRecord(List<NoticeDTO> notices)
{
var data = await notificationRepository.GetAllAsync(w => w.ExpirationTime > DateTimeOffset.Now);
if (data.Any_Nullable())
{
//var oldData = data.Where(w => w.ExpirationTime > DateTimeOffset.Now);
//if (oldData.Any())
// await notificationRepository.DeleteRangeAsync(oldData);
UnreadNotificationsCount = data.Count(x => !x.HasRead);
foreach (var d in data)
foreach (var notice in notices)
{
var notice = NoticesSource.Lookup(d.Id);
if (notice.HasValue)
notice.Value.HasRead = d.HasRead;
var n = data.FirstOrDefault(f => f.Id == notice.Id);
notice.HasRead = n.HasRead;
}
}
return notices;
}
public async Task InsertNotificationRecord(IEnumerable<NoticeDTO> notices)
@@ -162,8 +155,10 @@ namespace System.Application.Services
public async Task MarkNotificationHasRead(params Entities.Notification[] notice)
{
await notificationRepository.UpdateRangeAsync(notice);
UnreadNotificationsCount -= notice.Length;
UnreadNotificationsCount = UnreadNotificationsCount < 0 ? 0 : UnreadNotificationsCount;
}
public async void DeleteExpiredRecordAsync()
{
var data = await notificationRepository.GetAllAsync(w => w.ExpirationTime < DateTimeOffset.Now);