using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using GB5Shared.DTO.Framework.Criteria; using GB5Shared.DTO.Framework.Login; using GB5Shared.QueryExecutor; using GB5Shared.Resource.Response; using GB5Shared.Validation; using MMDAL.DTO.MaterialGrade; using MMDAL.Query.MaterialGrade; using Newtonsoft.Json; namespace MMDAL.CustomCode.MaterialGrade { public class MaterialGradeDAL : IMaterialGradeDAL { private readonly IQueryExecutor _QueryExecutor; private readonly IValidation _Validation; public MaterialGradeDAL(IQueryExecutor QueryExecutor, IValidation Validation) { _QueryExecutor = QueryExecutor; _Validation = Validation; } public async Task GetMaterialGrade(int MaterialGradeId, LoginDTO LoginDTO) { try { string sql = MaterialGradeQB.GET_MATERIALGRADE; var parameters = new { materialgradeid = MaterialGradeId }; MaterialGradeDTO MaterialGradeDTOs = await _QueryExecutor.QuerySingleAsync(LoginDTO, sql, parameters); return MaterialGradeDTOs; } catch (Exception) { throw; } } public async Task GetSelectListMaterialGrade(int FirstNumber, int MaxResult, CriteriaDTO CriteriaDTO, LoginDTO LoginDTO, bool IsCount = false) { try { string Json = ""; if (IsCount == false) { string SQL = MaterialGradeQB.GET_SELECTLIST_MATERIALGRADE; var parameter = new { firstnumber = FirstNumber, maxresult = MaxResult }; var Result = await _QueryExecutor.QueryAsync(LoginDTO, SQL, parameter); Json = JsonConvert.SerializeObject(Result); } else { int Count = 0; Json = Count.ToString(); } return Json; } catch (Exception) { throw; } } public async Task SaveMaterialGrade(MaterialGradeDTO MaterialGradeDTO, LoginDTO LoginDTO) { try { const string Sql = MaterialGradeQB.SAVE_MATERIALGRADE; return await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, MaterialGradeDTO); } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.SaveErrorMessage}"); throw new Exception(Error); } } public async Task UpdateMaterialGrade(MaterialGradeDTO MaterialGradeDTO, LoginDTO LoginDTO) { try { const string Sql = MaterialGradeQB.UPDATE_MATERIALGRADE; return await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, MaterialGradeDTO); } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.UpdateErrorMessage}"); throw new Exception(Error); } } public async Task DeleteMaterialGrade(int MaterialGradeId, LoginDTO LoginDTO) { try { string Sql = MaterialGradeQB.DELETE_MATERIALGRADE; var parameter = new { materialgradeid = MaterialGradeId }; var result = await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, parameter); 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); } } } }