using System; using System.ComponentModel.DataAnnotations; using System.Threading; using System.Threading.Tasks; using FrameworkDAL.CustomCode.DashboardPage; using FrameworkDAL.DTO.Dashboard; using GB5Shared.DaprCache; using GB5Shared.DTO.Framework.AutoNumber; using GB5Shared.DTO.Framework.Login; using GB5Shared.GenerateAutoNumber; using GB5Shared.Resource.Response; using GB5Shared.Validation; namespace FrameworkBLL.DashboardPage { public class DashboardPageBLL : IDashboardPageBLL { private readonly IDashboardPageDAL _DashboardPageDAL; private readonly AutoNumber _AutoNumber; private readonly IValidation _Validation; private readonly KeyInvalidate _KeyInvalidate; public DashboardPageBLL(IDashboardPageDAL DashboardPageDAL, AutoNumber AutoNumber, IValidation Validation, KeyInvalidate KeyInvalidate) { _DashboardPageDAL = DashboardPageDAL; _AutoNumber = AutoNumber; _Validation = Validation; _KeyInvalidate = KeyInvalidate; } public async Task GetDashboardPage(int DashboardId, LoginDTO LoginDTO, CancellationToken ct = default) { try { return await _DashboardPageDAL.GetDashboardPage(DashboardId, LoginDTO, ct); } catch (Exception) { throw; } } public async Task SaveDashboardPage(DashboardPageDTO DashboardPageDTO, LoginDTO LoginDTO, CancellationToken ct = default) { if (DashboardPageDTO == null) throw new ArgumentNullException(nameof(DashboardPageDTO)); AutoNumberDTO? autoNumberDTO = null; try { if (DashboardPageDTO.DashboardId == 0) throw new ArgumentException("DashboardId is required."); if (DashboardPageDTO.PageId == 0) throw new ArgumentException("PageId is required."); string result; if (DashboardPageDTO.DashboardPageId == 0) { autoNumberDTO = await _AutoNumber.GetAutoNumber(1, "DASHBOARDPAGE", LoginDTO); DashboardPageDTO.DashboardPageId = autoNumberDTO.StartNumber; await _DashboardPageDAL.SaveDashboardPage(DashboardPageDTO, LoginDTO, ct); result = $"{SuccessResponse.SaveSuccessMessage} {DashboardPageDTO.DashboardPageId}"; } else { await _DashboardPageDAL.UpdateDashboardPage(DashboardPageDTO, LoginDTO, ct); result = $"{SuccessResponse.UpdateSuccessMessage} {DashboardPageDTO.DashboardPageId}"; } // GetDashboardListForUser embeds each Dashboard's Pages[] and is cached at // USER_LEVEL — see DashboardBLL's matching note for why a full flush // (rather than a precisely-targeted key) is used for this class of write. await _KeyInvalidate.AllInvalidateCache("-1").ConfigureAwait(false); return result; } catch (ValidationException vex) { throw new Exception(vex.Message); } catch (Exception) { if (autoNumberDTO != null && DashboardPageDTO.DashboardPageId > 0) await _AutoNumber.RollbackAutoNumber("DASHBOARDPAGE", DashboardPageDTO.DashboardPageId, LoginDTO); throw; } } public async Task DeleteDashboardPage(int DashboardPageId, LoginDTO LoginDTO, CancellationToken ct = default) { try { var result = await _DashboardPageDAL.DeleteDashboardPage(DashboardPageId, LoginDTO, ct); await _KeyInvalidate.AllInvalidateCache("-1").ConfigureAwait(false); return result; } catch (Exception) { throw; } } public async Task DeleteDashboardPageWithDashboardAndPage(int DashboardId, int PageId, LoginDTO LoginDTO, CancellationToken ct = default) { try { var result = await _DashboardPageDAL.DeleteDashboardPageWithDashboardAndPage(DashboardId, PageId, LoginDTO, ct); await _KeyInvalidate.AllInvalidateCache("-1").ConfigureAwait(false); return result; } catch (Exception) { throw; } } } }