using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using AdminDAL.DTO.Draft; using AdminDAL.Query.Draft; using GB5Shared.DTO.Framework.Criteria; using GB5Shared.DTO.Framework.Login; using GB5Shared.QueryExecutor; using GB5Shared.Resource.Response; using GB5Shared.Validation; using Newtonsoft.Json; namespace AdminDAL.CustomCode.Draft { public class DraftDAL : IDraftDAL { private readonly IQueryExecutor _QueryExecutor; private readonly IValidation _Validation; public DraftDAL(IQueryExecutor IQueryExecutor, IValidation IValidation) { _QueryExecutor = IQueryExecutor; _Validation = IValidation; } public async Task GetDraft(int DraftId, LoginDTO LoginDTO) { string Json = ""; try { string sql = DraftQB.GET_DRAFT; var parameters = new { draftid = DraftId }; DraftDTO DraftDTOs = await _QueryExecutor.QuerySingleAsync(LoginDTO, sql, parameters); Json = JsonConvert.SerializeObject(DraftDTOs); return Json; } catch (Exception) { throw; } finally { Json = null; } } public async Task GetSelectListDraft(int FirstNumber, int MaxResult, CriteriaDTO CriteriaDTO, LoginDTO LoginDTO, bool IsCount = false) { try { string Json = ""; if (IsCount == false) { string SQL = DraftQB.GET_SELECTLIST_DRAFT; var parameter = new { firstnumber = FirstNumber, maxresult = MaxResult }; List DraftDTO = (await _QueryExecutor.QueryAsync(LoginDTO, SQL, parameter)).ToList(); Json = JsonConvert.SerializeObject(DraftDTO); } else { int Count = 0; Json = Count.ToString(); } return Json; } catch (Exception) { throw; } } public async Task SaveDraft(DraftDTO DraftDTO, LoginDTO LoginDTO) { try { string Sql = DraftQB.SAVE_DRAFT; return await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, DraftDTO); } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.SaveErrorMessage}"); throw new Exception(Error); } } public async Task UpdateDraft(DraftDTO DraftDTO, LoginDTO LoginDTO) { try { string Sql = DraftQB.UPDATE_DRAFT; return await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, DraftDTO); } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.UpdateErrorMessage}"); throw new Exception(Error); } } public async Task DeleteDraft(int DraftId, LoginDTO LoginDTO) { try { string Sql = DraftQB.DELETE_DRAFT; var Parameters = new { draftid = DraftId }; int result = await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, Parameters); if (result > 0) { return $"{SuccessResponse.DeleteSuccessMessage}"; } else { return $"{ErrorResponse.DeleteNotFoundMessage}"; } } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.DeleteErrorMessage}"); throw new Exception(Error); } } } }