using Microsoft.Extensions.Logging; using PlumbingRepairContracts.BindingModels; using PlumbingRepairContracts.BusinessLogicsContracts; using PlumbingRepairContracts.SearchModels; using PlumbingRepairContracts.StoragesContracts; using PlumbingRepairContracts.ViewModels; using PlumbingRepairDataModels.Models; using System; using System.Collections.Generic; using System.Linq; using System.Reflection; using System.Text; using System.Threading.Tasks; namespace PlumbingRepairBusinessLogic.BusinessLogics { public class ShopLogic :IShopLogic { private readonly ILogger _logger; private readonly IShopStorage _shopStorage; public ShopLogic(ILogger logger, IShopStorage shopStorage) { _logger = logger; _shopStorage = shopStorage; } public List? ReadList(ShopSearchModel? model) { _logger.LogInformation("ReadList. ShopName:{ShopName}. Id:{Id}", model?.ShopName, model?.Id); var list = model == null ? _shopStorage.GetFullList() : _shopStorage.GetFilteredList(model); if (list == null) { _logger.LogWarning("ReadList return null list"); return null; } _logger.LogInformation("ReadList. Count:{Count}", list.Count); return list; } public ShopViewModel? ReadElement(ShopSearchModel model) { if (model == null) { throw new ArgumentNullException(nameof(model)); } _logger.LogInformation("ReadElement. ShopName:{ShopName}. Id:{Id}", model.ShopName, model.Id); var element = _shopStorage.GetElement(model); if (element == null) { _logger.LogWarning("ReadElement element not found"); return null; } _logger.LogInformation("ReadElement find. Id:{Id}", element.Id); return element; } public bool Create(ShopBindingModel model) { CheckModel(model); if (_shopStorage.Insert(model) == null) { _logger.LogWarning("Insert operation failed"); return false; } return true; } public bool Update(ShopBindingModel model) { CheckModel(model); if (_shopStorage.Update(model) == null) { _logger.LogWarning("Update operation failed"); return false; } return true; } public bool Delete(ShopBindingModel model) { CheckModel(model, false); _logger.LogInformation("Delete. Id:{Id}", model.Id); if (_shopStorage.Delete(model) == null) { _logger.LogWarning("Delete operation failed"); return false; } return true; } public bool StoreReplenishment(ShopSearchModel shopModel, IWorkModel workModel, int count) { if (shopModel == null) { throw new ArgumentNullException(nameof(shopModel)); } if (workModel == null) { throw new ArgumentNullException(nameof(workModel)); } if (count <= 0) { throw new ArgumentNullException("Количество товаров должно быть больше 0", nameof(count)); } _logger.LogInformation("StoreReplenishment. ShopName:{ShopName}. Id:{Id}", shopModel.ShopName, shopModel.Id); var element = _shopStorage.GetElement(shopModel); if (element == null) { throw new InvalidOperationException("Ошибка. Элемент не найден"); } if(element.maxCountWorks - element.ShopWorks.Sum(x => x.Value.Item2) < count) { throw new InvalidOperationException("Ошибка. Нет места в магазине"); } if(element.ShopWorks.ContainsKey(workModel.Id)) { var oldWorks = element.ShopWorks[workModel.Id]; oldWorks.Item2 += count; element.ShopWorks[workModel.Id] = oldWorks; _logger.LogInformation("StoreReplenishment. Added {count} '{work}' to '{ShopName}' shop", count, workModel.WorkName,shopModel.ShopName); } else { element.ShopWorks.Add(workModel.Id,(workModel, count)); _logger.LogInformation("StoreReplenishment. Added {count} new '{work}' to '{ShopName}' shop", count, workModel.WorkName, shopModel.ShopName); } if(_shopStorage.Update(new ShopBindingModel() { Id = element.Id, ShopName = element.ShopName, Address = element.Address, DateOpening = element.DateOpening, maxCountWorks = element.maxCountWorks, ShopWorks= element.ShopWorks, }) == null) { _logger.LogInformation("StoreReplenishment. Update operation failed"); return false; } return true; } public bool CheckAndSupply(IWorkModel model, int count) { if (count<0) { _logger.LogWarning("Checksupply operation error. Works count < 0."); return false; } var shopList = _shopStorage.GetFullList(); int shopsCapacity = shopList.Sum(x => x.maxCountWorks); int currentWorks = shopList.Select(x => x.ShopWorks.Sum(x => x.Value.Item2)).Sum(); int freespace = shopsCapacity - currentWorks; if ( freespace < count) { _logger.LogWarning("Checksupply operation error. No space for a new work."); return false; } foreach (var shop in shopList) { int freePlaces = shop.maxCountWorks - shop.ShopWorks.Select(x => x.Value.Item2).Sum(); if (freePlaces == 0) { continue; } if( freePlaces - count >= 0) { if (StoreReplenishment(new() { Id = shop.Id }, model, count)) count = 0; else { _logger.LogWarning("Supply error"); return false; } } if (freePlaces - count < 0) { if (StoreReplenishment(new() { Id = shop.Id }, model, freePlaces)) count-= freePlaces; else { _logger.LogWarning("Supply error"); return false; } } if (count == 0) return true; } return false; } private void CheckModel(ShopBindingModel model, bool withParams = true) { if (model == null) { throw new ArgumentNullException(nameof(model)); } if (!withParams) { return; } if (string.IsNullOrEmpty(model.ShopName)) { throw new ArgumentNullException("Нет названия магазина", nameof(model.ShopName)); } if (string.IsNullOrEmpty(model.Address)) { throw new ArgumentNullException("Нет адреса магазина", nameof(model.ShopName)); } if (model.maxCountWorks < 0) { throw new InvalidOperationException("Максимальное количество работ магазина отрицательно"); } _logger.LogInformation("Shop. ShopName:{ShopName}. Address:{Address}. Id:{Id}", model.ShopName, model.Address, model.Id); var element = _shopStorage.GetElement(new ShopSearchModel { ShopName = model.ShopName }); if (element != null && element.Id != model.Id) { throw new InvalidOperationException("Компонент с таким названием уже есть"); } } public bool SellWork(IWorkModel model, int count) { return _shopStorage.SellWork(model, count); } } }