using EnablementDAL.CustomCode.ShowSchedule; using EnablementDAL.DTO; using EnablementDAL.DTO.Show; using EnablementDAL.Query.Show; using GB5Shared.DTO.Framework.Criteria; using GB5Shared.DTO.Framework.Login; using GB5Shared.QueryExecutor; using Newtonsoft.Json; namespace EnablementDAL.Implementations; public class ShowScheduleDAL : IShowScheduleDAL { private readonly IQueryExecutor _qe; public ShowScheduleDAL(IQueryExecutor qe) => _qe = qe; public async Task GetShowScheduleAsync(int showId, LoginDTO login, CancellationToken ct) => await _qe.QuerySingleAsync( login, ShowScheduleQB.GET_SHOW_SCHEDULE, new { ShowId = showId, TenantId = login.ClientId }, cancellationToken: ct).ConfigureAwait(false); public async Task InsertShowScheduleAsync(ShowScheduleDTO dto, LoginDTO login, CancellationToken ct) => await _qe.ExecuteAsync( login, ShowScheduleQB.INSERT_SHOW_SCHEDULE, dto, cancellationToken: ct).ConfigureAwait(false); public async Task UpdateShowScheduleAsync(ShowScheduleDTO dto, LoginDTO login, CancellationToken ct) => await _qe.ExecuteAsync( login, ShowScheduleQB.UPDATE_SHOW_SCHEDULE, dto, cancellationToken: ct).ConfigureAwait(false); public async Task DeleteShowScheduleAsync(int showScheduleId, LoginDTO login, CancellationToken ct) => await _qe.ExecuteAsync( login, ShowScheduleQB.DELETE_SHOW_SCHEDULE, new { ShowScheduleId = showScheduleId, TenantId = login.ClientId, ModifiedById = login.UserId }, cancellationToken: ct).ConfigureAwait(false); public async Task GetSelectListShowSchedule( int FirstNumber, int MaxResult, CriteriaDTO CriteriaDTO, LoginDTO LoginDTO, bool IsCount = false) { try { string Json = ""; if (!IsCount) { string Sql = ShowScheduleQB.GET_SELECTLIST_SHOW_SCHEDULE; var Parameters = new { firstnumber = FirstNumber, maxresult = MaxResult }; IEnumerable ShowScheduleDTO = await _qe.QueryAsync( LoginDTO, Sql, Parameters); Json = JsonConvert.SerializeObject(ShowScheduleDTO); } else { int Count = 0; Json = Count.ToString(); } return Json; } catch (Exception) { throw; } } public async Task GetShowScheduleList( CriteriaDTO criteriaDTO, LoginDTO LoginDTO) { try { string sql = ShowScheduleQB.GET_SHOW_SCHEDULE_LIST; var result = await _qe.QueryAsync( LoginDTO, sql, null!); return JsonConvert.SerializeObject(result); } catch (Exception) { throw; } } }