using ConfectioneryContracts.BindingModels; using ConfectioneryContracts.BussinessLogicsContracts; using Microsoft.Extensions.Logging; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace ConfectioneryBusinessLogic.MailWorker { public abstract 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 IClientLogic _clientLogic; private readonly ILogger _logger; public AbstractMailWorker(ILogger logger, IMessageInfoLogic messageInfoLogic, IClientLogic clientLogic) { _logger = logger; _messageInfoLogic = messageInfoLogic; _clientLogic = clientLogic; } 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, _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) { mail.ClientId = _clientLogic.ReadElement(new() { Email = mail.SenderName })?.Id; _messageInfoLogic.Create(mail); } } protected abstract Task SendMailAsync(MailSendInfoBindingModel info); protected abstract Task> ReceiveMailAsync(); } }