я засыпаю.. утром продолжу

Confectionery/ConfectioneryBusinessLogic/AbstractMailWorker.cs

@@ -0,0 +1,84 @@
+using ConfectioneryContracts.BusinessLogicsContracts;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryBusinessLogic
+{
+	public class AbstractMailWorker
+	{
+		protected string _mailLogin = string.Empty;
+		protected string _mailPassword = string.Empty;
+		protected string _smtpClientHost = string.Empty;
+		protected int _smtpClientPort;
+		protected string _popHost = string.Empty;
+		protected int _popPort;
+		private readonly IMessageInfoLogic _messageInfoLogic;
+		private readonly ILogger _logger;
+
+		public AbstractMailWorker(ILogger<AbstractMailWorker> logger, IMessageInfoLogic messageInfoLogic)
+		{
+			_logger = logger;
+			_messageInfoLogic = messageInfoLogic;
+		}
+		public void MailConfig(MailConfigBindingModel config)
+		{
+			_mailLogin = config.MailLogin;
+			_mailPassword = config.MailPassword;
+			_smtpClientHost = config.SmtpClientHost;
+			_smtpClientPort = config.SmtpClientPort;
+			_popHost = config.PopHost;
+			_popPort = config.PopPort;
+			_logger.LogDebug("Config: {login}, {password}, {clientHost}, {clientPOrt}, {popHost}, {popPort}", _mailLogin, _mailPassword.Length, _smtpClientHost, _smtpClientPort, _popHost, _popPort);
+		}
+		public async void MailSendAsync(MailSendInfoBindingModel info)
+		{
+			if (string.IsNullOrEmpty(_mailLogin) || string.IsNullOrEmpty(_mailPassword))
+			{
+				return;
+			}
+
+			if (string.IsNullOrEmpty(_smtpClientHost) || _smtpClientPort == 0)
+			{
+				return;
+			}
+
+			if (string.IsNullOrEmpty(info.MailAddress) || string.IsNullOrEmpty(info.Subject) || string.IsNullOrEmpty(info.Text))
+			{
+				return;
+			}
+
+			_logger.LogDebug("Send Mail: {To}, {Subject}", info.MailAddress, info.Subject);
+			await SendMailAsync(info);
+		}
+		public async void MailCheck()
+		{
+			if (string.IsNullOrEmpty(_mailLogin) || string.IsNullOrEmpty(_mailPassword))
+			{
+				return;
+			}
+
+			if (string.IsNullOrEmpty(_popHost) || _popPort == 0)
+			{
+				return;
+			}
+
+			if (_messageInfoLogic == null)
+			{
+				return;
+			}
+
+			var list = await ReceiveMailAsync();
+			_logger.LogDebug("Check Mail: {Count} new mails", list.Count);
+			foreach (var mail in list)
+			{
+				_messageInfoLogic.Create(mail);
+			}
+		}
+		protected abstract Task SendMailAsync(MailSendInfoBindingModel info);
+		protected abstract Task<List<MessageInfoBindingModel>> ReceiveMailAsync();
+	}
+}

Confectionery/ConfectioneryBusinessLogic/ConfectioneryBusinessLogic.csproj

@@ -8,6 +8,7 @@
 
   <ItemGroup>
     <PackageReference Include="DocumentFormat.OpenXml" Version="3.0.2" />
+    <PackageReference Include="MailKit" Version="4.6.0" />
     <PackageReference Include="Microsoft.Extensions.Logging" Version="8.0.0" />
     <PackageReference Include="MigraDocCore.DocumentObjectModel" Version="1.3.63" />
     <PackageReference Include="MigraDocCore.Rendering" Version="1.3.63" />

Confectionery/ConfectioneryBusinessLogic/MailKitWorker.cs

@@ -0,0 +1,82 @@
+using MailKit.Net.Pop3;
+using MailKit.Security;
+using Microsoft.Extensions.Logging;
+using ConfectioneryContracts.BindingModels;
+using ConfectioneryContracts.BusinessLogicsContracts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Mail;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryBusinessLogic
+{
+	public class MailKitWorker : AbstractMailWorker
+	{
+		public MailKitWorker(ILogger<MailKitWorker> logger, IMessageInfoLogic messageInfoLogic) : base(logger, messageInfoLogic) { }
+
+		protected override async Task SendMailAsync(MailSendInfoBindingModel info)
+		{
+			using var objMailMessage = new MailMessage();
+			using var objSmtpClient = new SmtpClient(_smtpClientHost, _smtpClientPort);
+			try
+			{
+				objMailMessage.From = new MailAddress(_mailLogin);
+				objMailMessage.To.Add(new MailAddress(info.MailAddress));
+				objMailMessage.Subject = info.Subject;
+				objMailMessage.Body = info.Text;
+				objMailMessage.SubjectEncoding = Encoding.UTF8;
+				objMailMessage.BodyEncoding = Encoding.UTF8;
+
+				objSmtpClient.UseDefaultCredentials = false;
+				objSmtpClient.EnableSsl = true;
+				objSmtpClient.DeliveryMethod = SmtpDeliveryMethod.Network;
+				objSmtpClient.Credentials = new NetworkCredential(_mailLogin, _mailPassword);
+
+				await Task.Run(() => objSmtpClient.Send(objMailMessage));
+			}
+			catch (Exception)
+			{
+				throw;
+			}
+		}
+
+		protected override async Task<List<MessageInfoBindingModel>> ReceiveMailAsync()
+		{
+			var list = new List<MessageInfoBindingModel>();
+			using var client = new Pop3Client();
+			await Task.Run(() =>
+			{
+				try
+				{
+					client.Connect(_popHost, _popPort, SecureSocketOptions.SslOnConnect);
+					client.Authenticate(_mailLogin, _mailPassword);
+					for (int i = 0; i < client.Count; i++)
+					{
+						var message = client.GetMessage(i);
+						foreach (var mail in message.From.Mailboxes)
+						{
+							list.Add(new MessageInfoBindingModel
+							{
+								DateDelivery = message.Date.DateTime,
+								MessageId = message.MessageId,
+								SenderName = mail.Address,
+								Subject = message.Subject,
+								Body = message.TextBody
+							});
+						}
+					}
+				}
+				catch (MailKit.Security.AuthenticationException)
+				{ }
+				finally
+				{
+					client.Disconnect(true);
+				}
+			});
+			return list;
+		}
+	}
+}

Confectionery/ConfectioneryBusinessLogic/MessageInfoLogic.cs

@@ -0,0 +1,90 @@
+using Microsoft.Extensions.Logging;
+using ConfectioneryContracts.BindingModels;
+using ConfectioneryContracts.BusinessLogicsContracts;
+using ConfectioneryContracts.SearchModels;
+using ConfectioneryContracts.StoragesContracts;
+using ConfectioneryContracts.ViewModels;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryBusinessLogic
+{
+	public class MessageInfoLogic : IMessageInfoLogic
+	{
+		private readonly ILogger _logger;
+		private readonly IMessageInfoStorage _messageInfoStorage;
+		private readonly IClientStorage _clientStorage;
+		public MessageInfoLogic(ILogger<MessageInfoLogic> logger, IMessageInfoStorage messageInfoStorage, IClientStorage clientStorage)
+		{
+			_logger = logger;
+			_messageInfoStorage = messageInfoStorage;
+			_clientStorage = clientStorage;
+		}
+		public List<MessageInfoViewModel>? ReadList(MessageInfoSearchModel? model)
+		{
+			_logger.LogInformation("ReadList. MessageId:{MessageId}.ClientId:{ClientId}", model?.MessageId, model?.ClientId);
+			var list = model == null ? _messageInfoStorage.GetFullList() : _messageInfoStorage.GetFilteredList(model);
+			if (list == null)
+			{
+				_logger.LogWarning("ReadList return null list");
+				return null;
+			}
+			_logger.LogInformation("ReadList. Count:{Count}", list.Count);
+			return list;
+		}
+		public bool Create(MessageInfoBindingModel model)
+		{
+			CheckModel(model);
+			if (_messageInfoStorage.Insert(model) == null)
+			{
+				_logger.LogWarning("Insert operation failed");
+				return false;
+			}
+			return true;
+		}
+		private void CheckModel(MessageInfoBindingModel model, bool withParams = true)
+		{
+			if (model == null)
+			{
+				throw new ArgumentNullException(nameof(model));
+			}
+			if (!withParams)
+			{
+				return;
+			}
+			if (string.IsNullOrEmpty(model.MessageId))
+			{
+				throw new ArgumentNullException("Не указан id сообщения", nameof(model.MessageId));
+			}
+			if (string.IsNullOrEmpty(model.SenderName))
+			{
+				throw new ArgumentNullException("Не указао почта", nameof(model.SenderName));
+			}
+			if (string.IsNullOrEmpty(model.Subject))
+			{
+				throw new ArgumentNullException("Не указана тема", nameof(model.Subject));
+			}
+			if (string.IsNullOrEmpty(model.Body))
+			{
+				throw new ArgumentNullException("Не указан текст сообщения", nameof(model.Subject));
+			}
+
+			_logger.LogInformation("MessageInfo. MessageId:{MessageId}.SenderName:{SenderName}.Subject:{Subject}.Body:{Body}", model.MessageId, model.SenderName, model.Subject, model.Body);
+			var element = _clientStorage.GetElement(new ClientSearchModel
+			{
+				Email = model.SenderName
+			});
+			if (element == null)
+			{
+				_logger.LogWarning("Не удалоссь найти клиента, отправившего письмо с адреса Email:{Email}", model.SenderName);
+			}
+			else
+			{
+				model.ClientId = element.Id;
+			}
+		}
+	}
+}

Confectionery/ConfectioneryContracts/BindingModels/MailConfigBindingModel.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryContracts.BindingModels
+{
+	public class MailConfigBindingModel
+	{
+		public string MailLogin { get; set; } = string.Empty;
+		public string MailPassword { get; set; } = string.Empty;
+		public string SmtpClientHost { get; set; } = string.Empty;
+		public int SmtpClientPort { get; set; }
+		public string PopHost { get; set; } = string.Empty;
+		public int PopPort { get; set; }
+	}
+}

Confectionery/ConfectioneryContracts/BindingModels/MailSendInfoBindingModel.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryContracts.BindingModels
+{
+	public class MailSendInfoBindingModel
+	{
+		public string MailAddress { get; set; } = string.Empty;
+		public string Subject { get; set; } = string.Empty;
+		public string Text { get; set; } = string.Empty;
+	}
+}

Confectionery/ConfectioneryContracts/BindingModels/MessageInfoBindingModel.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryContracts.BindingModels
+{
+	public class MessageInfoBindingModel
+	{
+		public string MessageId { get; set; } = string.Empty;
+		public int? ClientId { get; set; }
+		public string SenderName { get; set; } = string.Empty;
+		public string Subject { get; set; } = string.Empty;
+		public string Body { get; set; } = string.Empty;
+		public DateTime DateDelivery { get; set; }
+	}
+}

Confectionery/ConfectioneryContracts/BusinessLogicsContracts/IMessageInfoLogic.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using ConfectioneryContracts.BindingModels;
+using ConfectioneryContracts.SearchModels;
+using ConfectioneryContracts.ViewModels;
+
+
+namespace ConfectioneryContracts.BusinessLogicsContracts
+{
+	public interface IMessageInfoLogic
+	{
+		List<MessageInfoViewModel>? ReadList(MessageInfoSearchModel? model);
+		bool Create(MessageInfoBindingModel model);
+	}
+}

Confectionery/ConfectioneryContracts/SearchModels/MessageInfoSearchModel.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryContracts.SearchModels
+{
+	public class MessageInfoSearchModel
+	{
+		public int? ClientId { get; set; }
+		public string? MessageId { get; set; }
+	}
+}

Confectionery/ConfectioneryContracts/StoragesContracts/IMessageInfoStorage.cs

@@ -0,0 +1,19 @@
+using ConfectioneryContracts.BindingModels;
+using ConfectioneryContracts.SearchModels;
+using ConfectioneryContracts.ViewModels;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryContracts.StoragesContracts
+{
+	public interface IMessageInfoStorage
+	{
+		List<MessageInfoViewModel> GetFullList();
+		List<MessageInfoViewModel> GetFilteredList(MessageInfoSearchModel model);
+		MessageInfoViewModel? GetElement(MessageInfoSearchModel model);
+		MessageInfoViewModel? Insert(MessageInfoBindingModel model);
+	}
+}

Confectionery/ConfectioneryContracts/ViewModels/MessageInfoViewModel.cs

@@ -0,0 +1,29 @@
+using ConfectioneryDataModels.Models;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryContracts.ViewModels
+{
+	public class MessageInfoViewModel : IMessageInfoModel
+	{
+		public string MessageId { get; set; } = string.Empty;
+
+		public int? ClientId { get; set; }
+
+		[DisplayName("Отправитель")]
+		public string SenderName { get; set; } = string.Empty;
+
+		[DisplayName("Дата письма")]
+		public DateTime DateDelivery { get; set; }
+
+		[DisplayName("Заголовок")]
+		public string Subject { get; set; } = string.Empty;
+
+		[DisplayName("Текст")]
+		public string Body { get; set; } = string.Empty;
+	}
+}

Confectionery/ConfectioneryDataModels/IMessageInfoModel.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryDataModels.Models
+{
+	public interface IMessageInfoModel
+	{
+		string MessageId { get; }
+		int? ClientId { get; }
+		string SenderName { get; }
+		DateTime DateDelivery { get; }
+		string Subject { get; }
+		string Body { get; }
+	}
+}

Confectionery/ConfectioneryDatabaseImplement/MessageInfo.cs

@@ -0,0 +1,64 @@
+using ConfectioneryContracts.BindingModels;
+using ConfectioneryContracts.ViewModels;
+using ConfectioneryDataModels.Models;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryDatabaseImplement
+{
+	public class MessageInfo : IMessageInfoModel
+	{
+		[Key]
+		[DatabaseGenerated(DatabaseGeneratedOption.None)]
+		public string MessageId { get; set; } = string.Empty;
+
+		public int? ClientId { get; set; }
+
+		public virtual Client? Client { get; set; }
+
+		[Required]
+		public string SenderName { get; set; } = string.Empty;
+
+		[Required]
+		public DateTime DateDelivery { get; set; }
+
+		[Required]
+		public string Subject { get; set; } = string.Empty;
+
+		[Required]
+		public string Body { get; set; } = string.Empty;
+
+		public static MessageInfo? Create(MessageInfoBindingModel? model)
+		{
+			if (model == null)
+			{
+				return null;
+			}
+			return new()
+			{
+				MessageId = model.MessageId,
+				ClientId = model.ClientId,
+				SenderName = model.SenderName,
+				DateDelivery = model.DateDelivery,
+				Subject = model.Subject,
+				Body = model.Body,
+
+			};
+		}
+
+		public MessageInfoViewModel GetViewModel => new()
+		{
+			MessageId = MessageId,
+			ClientId = ClientId,
+			SenderName = SenderName,
+			DateDelivery = DateDelivery,
+			Subject = Subject,
+			Body = Body
+		};
+	}
+}

Confectionery/ConfectioneryDatabaseImplement/MessageInfoStorage.cs

@@ -0,0 +1,50 @@
+using ConfectioneryContracts.BindingModels;
+using ConfectioneryContracts.SearchModels;
+using ConfectioneryContracts.ViewModels;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ConfectioneryDatabaseImplement.Implements
+{
+	public class MessageInfoStorage
+	{
+		public List<MessageInfoViewModel> GetFullList()
+		{
+			using var context = new ConfectioneryDatabase();
+			return context.MessageInfos.Select(x => x.GetViewModel).ToList();
+		}
+		public List<MessageInfoViewModel> GetFilteredList(MessageInfoSearchModel model)
+		{
+			if (!model.ClientId.HasValue)
+			{
+				return new();
+			}
+			using var context = new ConfectioneryDatabase();
+			return context.MessageInfos.Where(x => x.ClientId.HasValue && x.ClientId == model.ClientId).Select(x => x.GetViewModel).ToList();
+		}
+		public MessageInfoViewModel? GetElement(MessageInfoSearchModel model)
+		{
+			if (string.IsNullOrEmpty(model.MessageId))
+			{
+				return new();
+			}
+			using var context = new ConfectioneryDatabase();
+			return context.MessageInfos.FirstOrDefault(x => x.MessageId == model.MessageId)?.GetViewModel;
+		}
+		public MessageInfoViewModel? Insert(MessageInfoBindingModel model)
+		{
+			var newMessage = MessageInfo.Create(model);
+			if (newMessage == null)
+			{
+				return null;
+			}
+			using var context = new ConfectioneryDatabase();
+			context.MessageInfos.Add(newMessage);
+			context.SaveChanges();
+			return newMessage.GetViewModel;
+		}
+	}
+}