OrderLogic edited: added sending msgs

JewelryStoreBusinessLogic/BusinessLogics/OrderLogic.cs

@@ -1,4 +1,5 @@
-using JewelryStoreContracts.BindingModels;
+using JewelryStoreBusinessLogic.MailWorker;
+using JewelryStoreContracts.BindingModels;
 using JewelryStoreContracts.BusinessLogicsContracts;
 using JewelryStoreContracts.SearchModels;
 using JewelryStoreContracts.StoragesContracts;
@@ -17,11 +18,15 @@ namespace JewelryStoreBusinessLogic.BusinessLogics
     {
         private readonly ILogger _logger;
         private readonly IOrderStorage _orderStorage;
+		private readonly AbstractMailWorker _mailWorker;
+		private readonly IClientLogic _clientLogic;
 
-        public OrderLogic(ILogger<OrderLogic> logger, IOrderStorage orderStorage)
+		public OrderLogic(ILogger<OrderLogic> logger, IOrderStorage orderStorage, AbstractMailWorker mailWorker, IClientLogic clientLogic)
         {
             _logger = logger;
             _orderStorage = orderStorage;
+			_mailWorker = mailWorker;
+			_clientLogic = clientLogic;
 		}
 
         public bool CreateOrder(OrderBindingModel model)
@@ -35,14 +40,15 @@ namespace JewelryStoreBusinessLogic.BusinessLogics
             }
 
             model.Status = OrderStatus.Принят;
+			var result = _orderStorage.Update(model);
 
-            if (_orderStorage.Insert(model) == null)
+			if (result == null)
 			{
                 model.Status = OrderStatus.Неизвестен;
                 _logger.LogWarning("Insert operation failed");
                 return false;
             }
-
+			SendOrderMessage(result.ClientId, $"Установка ПО, Заказ №{result.Id}", $"Заказ №{result.Id} от {result.DateCreate} на сумму {result.Sum:0.00} принят");
 			return true;
         }
 
@@ -75,13 +81,33 @@ namespace JewelryStoreBusinessLogic.BusinessLogics
             model.JewelId = vmodel.JewelId;
             model.Sum = vmodel.Sum;
             model.Count = vmodel.Count;
+			var result = _orderStorage.Update(model);
 
-            if (_orderStorage.Update(model) == null)
+			if (result == null)
             {
                 _logger.LogWarning("Update operation failed");
 
                 return false;
             }
+			SendOrderMessage(result.ClientId, $"Установка ПО, Заказ №{result.Id}", $"Заказ №{model.Id} изменен статус на {result.Status}");
+			return true;
+        }
+
+		private bool SendOrderMessage(int clientId, string subject, string text)
+		{
+			var client = _clientLogic.ReadElement(new() { Id = clientId });
+
+			if (client == null)
+			{
+				return false;
+			}
+
+			_mailWorker.MailSendAsync(new()
+			{
+				MailAddress = client.Email,
+				Subject = subject,
+				Text = text
+			});
 
 			return true;
 		}