using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using PalGain.Core;
|
using PalGain.Core.Tasks;
|
using BatchService.Framework.Utility;
|
using sbcLabSystem.Data.Domain.Backstage;
|
using sbcLabSystem.Data.Domain.Account;
|
using sbcLabSystem.Service.Account;
|
using sbcLabSystem.Service.QC;
|
using sbcLabSystem.Service.Common;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
|
namespace sbcLabSystem.Service.Task
|
{
|
public class SendEmailTaskService : ITask
|
{
|
private delegate void SentMailProcess(EmileInfo mailInfo, EmailSmtpInfo smtpInfo);
|
private QCService _qcService;
|
private AccountService _accountService;
|
|
public SendEmailTaskService(QCService i_qcService,
|
AccountService i_accountService)
|
{
|
_qcService = i_qcService;
|
_accountService = i_accountService;
|
}
|
|
public void Execute()
|
{
|
try
|
{
|
LogHelper.Debug(LogHelper.LoggerType.ScheduleTask, "准备发送邮件");
|
EmailSmtpInfo smtpInfo = _accountService.GetDefaultSmtpInfo();
|
_accountService.GetUnSentEmails().ToList().ForEach(x =>
|
{
|
SentMailProcess process = new SentMailProcess(SentProcess);
|
process.BeginInvoke(x, smtpInfo, null, null);
|
Thread.Sleep(10 * 1000);
|
});
|
LogHelper.Debug(LogHelper.LoggerType.ScheduleTask,
|
string.Format("共计发送邮件:{0}", _accountService.GetUnSentEmails().Count()));
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex.ToString());
|
}
|
}
|
|
private void SentProcess(EmileInfo mailInfo, EmailSmtpInfo smtpInfo)
|
{
|
Email emailSender = new Email();
|
emailSender.isbodyHtml = true;
|
emailSender.host = smtpInfo.Host;
|
emailSender.IsEnableSSL = smtpInfo.IsEnableSSL;
|
emailSender.SSLPort = smtpInfo.SSLPort;
|
emailSender.mailBody = mailInfo.Boody;
|
emailSender.mailFrom = smtpInfo.UserEmail;
|
emailSender.mailPwd = smtpInfo.Password;
|
emailSender.mailToArray = new string[] { mailInfo.EmileName };
|
emailSender.mailSubject = mailInfo.Title;
|
|
LogHelper.Debug(LogHelper.LoggerType.ScheduleTask,
|
string.Format("发送邮件给:{0},发件人:{1},主题:{2},内容:{3},序列化为:{4}",
|
emailSender.mailToArray[0],
|
emailSender.mailFrom,
|
emailSender.mailSubject,
|
emailSender.mailBody,
|
JsonConvert.SerializeObject(emailSender)));
|
|
bool sendStatus = false;
|
try
|
{
|
sendStatus = emailSender.Send();
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex.ToString());
|
mailInfo.Column1 = ex.Message;
|
_accountService.SetErrorMessageToEmailSentBox(mailInfo);
|
|
}
|
|
LogHelper.Debug(LogHelper.LoggerType.ScheduleTask,
|
string.Format("发送状态:{0},收件人:{1}",
|
sendStatus.ToString(),
|
emailSender.mailToArray[0]));
|
if (sendStatus)
|
{
|
_accountService.SetSentStatusToEmailSentBox(mailInfo);
|
}
|
}
|
}
|
}
|
