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.CustomCode.Shape; using MMDAL.DTO.Shape; using MMDAL.Query.Shape; using Newtonsoft.Json; namespace MMDAL.CustomCode.Shape { public class ShapeDAL : IShapeDAL { private readonly IQueryExecutor _QueryExecutor; private readonly IValidation _Validation; public ShapeDAL(IQueryExecutor IQueryExecutor, IValidation Validation) { _QueryExecutor = IQueryExecutor; _Validation = Validation; } public async Task GetShape(int ShapeId, LoginDTO LoginDTO) { string Json = ""; try { string sql = ShapeQB.GET_SHAPE; var parameters = new { shapeid = ShapeId }; ShapeDTO ShapeDTOs = await _QueryExecutor.QuerySingleAsync(LoginDTO, sql, parameters); Json = JsonConvert.SerializeObject(ShapeDTOs); return Json; } catch (Exception) { throw; } finally { Json = null; } } public async Task GetSelectListShape(int FirstNumber, int MaxResult, CriteriaDTO CriteriaDTO, LoginDTO LoginDTO, bool IsCount = false) { try { string Json = ""; if (IsCount == false) { string SQL = ShapeQB.GET_SELECTLIST_SHAPE; 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 SaveShape(ShapeDTO ShapeDTO, LoginDTO LoginDTO) { try { const string Sql = ShapeQB.SAVE_SHAPE; return await _QueryExecutor.ExecuteAsync(LoginDTO, Sql, ShapeDTO); } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.SaveErrorMessage}"); throw new Exception(Error); } } public async Task UpdateShape(ShapeDTO ShapeDTO, LoginDTO LoginDTO) { try { const string sql = ShapeQB.UPDATE_SHAPE; return await _QueryExecutor.ExecuteAsync(LoginDTO, sql, ShapeDTO); } catch (Exception ex) { string Error = await _Validation.HandleException(ex, $"{ErrorResponse.UpdateErrorMessage}"); throw new Exception(Error); } } public async Task DeleteShape(int ShapeId, LoginDTO LoginDTO) { try { string sql = ShapeQB.DELETE_SHAPE; var parameter = new { shapeid = ShapeId }; 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); } } } }