using EasyBL.WebApi.Message;
using Entity.Sugar;
using HtmlAgilityPack;
using SqlSugar;
using SqlSugar.Base;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Net.Mail;
using System.Text;
using System.Text.RegularExpressions;
using System.Web;
using System.Web.Services.Protocols;
namespace EasyBL
{
public class MailService : ServiceBase
{
#region Declare Region
private string _sErrorMessages = string.Empty;
#endregion Declare Region
#region Property Region
/// <summary>
/// 組織ID
/// </summary>
public string OrgID { get; set; } = string.Empty;
/// <summary>
/// 組織ID
/// </summary>
public bool IsConfig { get; set; } = false;
/// <summary>
/// 錯誤信息
/// </summary>
public string ErrorMessages
{
set { _sErrorMessages += value + ";"; }
get { return _sErrorMessages; }
}
#endregion Property Region
public readonly EasyNet.Common.Map mailSetting = new EasyNet.Common.Map();
public MailService(string orgid, bool isconfig = false)
{
OrgID = orgid;
IsConfig = isconfig;
var array = new string[] { @"MailEncoding", "FromName", "FromEmail", "FromUserId", "FromPassword", "Server", "ServerPort", "Timeout", "SSL" };
mailSetting = Common.GetSystemSettings(OrgID, array);
}
#region 郵件寄送
/// <summary>
/// 郵件寄送
/// </summary>
/// <param name="i_crm">todo: describe i_crm parameter on SendMail</param>
/// <returns></returns>
public ResponseMessage SendMail(RequestMessage i_crm)
{
ResponseMessage rm = null;
string sMsg = null;
try
{
do
{
//string sParams = _fetchString(i_crm, "Params");
var bSend = SendMail(i_crm.DATA["Params"], out sMsg);
if (sMsg != null)
{
break;
}
} while (false);
rm = new SuccessResponseMessage(null, i_crm);
}
catch (Exception ex)
{
sMsg = Util.GetLastExceptionMsg(ex);
LogAndSendEmail(sMsg + "Param：" + JsonToString(i_crm), ex, i_crm.ORIGID, i_crm.USERID, nameof(MailService), nameof(MailService), "SendMail（郵件寄送）", "", "", "");
}
finally
{
if (null != sMsg)
{
rm = new ErrorResponseMessage(sMsg, i_crm);
}
}
return rm;
}
#endregion 郵件寄送
public bool SendMail(Object Params, out string o_sError)
{
var bSend = false;
string sError = null;
try
{
do
{
var db = SugarBase.GetIntance();
var mail = new Emails();
var dic = Params as Dictionary<string, object>;
if (!dic.ContainsKey(BLWording.EMAILTO))
{
sError = "缺少必要的參數：‘" + BLWording.EMAILTO + "’"; break;
}
if (!dic.ContainsKey(BLWording.MAILTEMPID) && !dic.ContainsKey(BLWording.EMAILBODY))
{
sError = "缺少必要的參數：‘" + BLWording.MAILTEMPID + "’ 或 ‘" + BLWording.EMAILBODY + "’"; break;
}
if (dic.ContainsKey(BLWording.EMAILBODY) && !dic.ContainsKey(BLWording.TITLE))
{
sError = "如果不是配置郵件模板，‘" + BLWording.TITLE + "’是必要的參數."; break;
}
if (dic.ContainsKey(BLWording.FROMUSERID) && !dic.ContainsKey(BLWording.FROMEMAIL))
{
//抓取當前使用者資料
var sFromUserId = dic[BLWording.FROMUSERID].ToString();
var saUserFrom = db.UnionAll(
db.Queryable<OTB_SYS_Members>().Where(it => it.Effective == "Y").Select(x => new AllUsers
{
OrgID = x.OrgID,
MemberID = x.MemberID,
MemberName = x.MemberName,
Email = x.Email
}),
db.Queryable<OTB_CRM_Customers>().Where(it => it.Effective == "Y").Select(x => new AllUsers
{
OrgID = x.OrgID,
MemberID = x.guid,
MemberName = SqlFunc.IIF(SqlFunc.HasValue(x.CustomerCName), x.CustomerCName, x.CustomerEName),
Email = x.Email
}))
.Where(it => it.MemberID == sFromUserId && it.OrgID == OrgID).ToList()
.ToList();
if (saUserFrom.Count == 0)
{
sError = "發件人信息有誤";
break;
}
var oUserFrom = saUserFrom.First();
mail.FromUserID = oUserFrom.MemberID;
mail.FromUserName = oUserFrom.MemberName;
mail.FromEmail = oUserFrom.Email;
}
if (dic.ContainsKey(BLWording.FROMUSERNAME) && string.IsNullOrWhiteSpace(mail.FromUserName))
{
mail.FromUserName = dic[BLWording.FROMUSERNAME].ToString();
}
if (dic.ContainsKey(BLWording.FROMEMAIL) && string.IsNullOrWhiteSpace(mail.FromEmail))
{
mail.FromEmail = dic[BLWording.FROMEMAIL].ToString();
}
var Tos = new List<EmailTo>();
var listTo = dic[BLWording.EMAILTO] as Object[];
var sToUserName = "";
var builder = new StringBuilder();
builder.Append(sToUserName);
foreach (Object mailto in listTo)
{
var dicto = mailto as Dictionary<string, object>;
var to = new EmailTo();
if (dicto.Keys.Contains("ToEmail"))
{
to.ToUserName = dicto["ToUserName"].ToString();
to.ToEmail = dicto["ToEmail"].ToString();
}
else
{
//抓取當前使用者資料
var sToUserId = dic[BLWording.TOUSERID].ToString();
var saUserTo = db.UnionAll(
db.Queryable<OTB_SYS_Members>().Where(it => it.Effective == "Y").Select(x => new AllUsers
{
OrgID = x.OrgID,
MemberID = x.MemberID,
MemberName = x.MemberName,
Email = x.Email
}),
db.Queryable<OTB_CRM_Customers>().Where(it => it.Effective == "Y").Select(x => new AllUsers
{
OrgID = x.OrgID,
MemberID = x.guid,
MemberName = SqlFunc.IIF(SqlFunc.HasValue(x.CustomerCName), x.CustomerCName, x.CustomerEName),
Email = x.Email
}))
.Where(it => it.MemberID == sToUserId && it.OrgID == OrgID).ToList()
.ToList();
if (saUserTo.Count == 0)
{
break;
}
var oUserTo = saUserTo.First();
to.ToUserID = oUserTo.MemberID;
to.ToUserName = oUserTo.MemberName;
to.ToEmail = oUserTo.Email;
}
to.Type = (dicto["Type"] != null && dicto["Type"].ToString() != "") ? dicto["Type"].ToString() : nameof(to);
builder.Append(to.ToUserName + ",");
Tos.Add(to);
}
sToUserName = builder.ToString();
sToUserName = (sToUserName + ",").Replace(",,", "");
if (Tos.Count == 0) { sError = "收件人信息有誤"; break; }
mail.EmailTo = Tos;
if (dic.ContainsKey(BLWording.EMAILBODY))
{
mail.EmailBody = dic[BLWording.EMAILBODY].ToString();
}
else
{
//獲取Email郵件格式
var sEmailTemplId = dic[BLWording.MAILTEMPID].ToString();
var oEmailTempl = new OTB_SYS_Email();
var saEmailTempl = db.Queryable<OTB_SYS_Email>()
.Where(it => it.EmailID == sEmailTemplId && it.OrgID == OrgID).ToList();
if (saEmailTempl.Count == 0)
{
sError = "找不到對應的模板";
break;
}
oEmailTempl = saEmailTempl.First();
mail.EmailBody = oEmailTempl.BodyHtml;
mail.Title = oEmailTempl.EmailSubject;
}
if (dic.ContainsKey(BLWording.TITLE))
{
mail.Title = dic[BLWording.TITLE].ToString();
}
if (dic.ContainsKey(BLWording.ATTACHMENTS))
{
mail.Attachments = dic[BLWording.ATTACHMENTS] as Object[];
}
var sBaseUrl = HttpContext.Current.Request.Url.ToString().Replace(HttpContext.Current.Request.RawUrl, "");
mail.EmailBody = mail.EmailBody.Replace("{{:Url}}", sBaseUrl).Replace("{{:FromUserName}}", mail.FromUserName);
if (dic.ContainsKey(BLWording.MAILDATA))
{
var dicData = dic[BLWording.MAILDATA] as Dictionary<string, object>;
foreach (var key in dicData.Keys)
{
mail.EmailBody = mail.EmailBody.Replace("{{:" + key + "}}", dicData[key].ToString());
}
mail.EmailBody = mail.EmailBody.Replace("{{:ToUserName}}", sToUserName);
}
//處理需要隱藏的tr標籤
var doc = new HtmlDocument();
doc.LoadHtml(mail.EmailBody);
foreach (HtmlNode NodeTb in doc.DocumentNode.SelectNodes("//tr"))
{
if (NodeTb.Attributes["style"] != null && NodeTb.Attributes["style"].Value.IndexOf("display:none") > -1)
{
NodeTb.Remove();
}
}
mail.EmailBody = doc.DocumentNode.OuterHtml; //總模版
bSend = MailFactory(mail, out sError);
} while (false);
return bSend;
}
catch (Exception ex)
{
sError = ex.Message;
Logger.Error("MailService.SendMail Error:" + sError + " Params：" + JsonToString(Params), ex);
return bSend;
}
finally
{
o_sError = sError;
}
}
public bool MailFactory(Emails i_oEmail, out string o_sError)
{
var bSend = false;
string sError = null;
try
{
do
{
var objEmail = new MailMessage();
//**寄件者信箱**
var sFromName = mailSetting["FromName"] != null ? mailSetting["FromName"].ToString() : Common.GetAppSettings("FromName").Trim(); //顯示發件人的名字代替Mail地址
var sMailFrom = mailSetting["FromEmail"] != null ? mailSetting["FromEmail"].ToString() : Common.GetAppSettings("FromEmail").Trim(); //發件人地址
sMailFrom = i_oEmail.FromEmail ?? sMailFrom; //發件人地址
sFromName = i_oEmail.FromUserName ?? sFromName; //系統郵件[請勿回覆]
var o_MailFrom = new MailAddress(sMailFrom, sFromName, Encoding.Default);
objEmail.From = o_MailFrom;
//**收件者信箱**//
objEmail.To.Clear();
objEmail.CC.Clear();
objEmail.Bcc.Clear();
MailAddress o_MailTo;
foreach (EmailTo _EmailTo in i_oEmail.EmailTo)
{
if (_EmailTo.ToEmail != "")
{
o_MailTo = new MailAddress(_EmailTo.ToEmail, _EmailTo.ToUserName);
switch (_EmailTo.Type)
{
case "to":
objEmail.To.Add(o_MailTo);
break;
case "cc":
objEmail.CC.Add(o_MailTo);
break;
case "bcc":
objEmail.Bcc.Add(o_MailTo);
break;
default:
break;
}
}
}
if (i_oEmail.Attachments != null && i_oEmail.Attachments.Length > 0)
{
foreach (string Attachment in i_oEmail.Attachments)
{
var sPath = Regex.Replace(Attachment, @"//|/", @"\");
var attachment = new Attachment(sPath);//<-這是附件部分~先用附件的物件把路徑指定進去~
objEmail.Attachments.Add(attachment); //<-郵件訊息中加入附件
}
}
//**信件標題**//
objEmail.Subject = i_oEmail.Title;
//**信件主旨**//
objEmail.Body = i_oEmail.EmailBody;
objEmail.Body = HttpContext.Current.Server.HtmlDecode(objEmail.Body);
objEmail.IsBodyHtml = true;
//'**设置正文的编码形式.这里的设置为取系统默认编码
//objEmail.BodyEncoding = System.Text.Encoding.Default;
objEmail.BodyEncoding = Encoding.UTF8;
//'**设置主题的编码形式.这里的设置为取系统默认编码
//objEmail.SubjectEncoding = System.Text.Encoding.Default;
objEmail.SubjectEncoding = Encoding.UTF8;
objEmail.DeliveryNotificationOptions = DeliveryNotificationOptions.OnFailure;
//**信件送出**
if (i_oEmail.IsCCSelf && i_oEmail.FromEmail != null && i_oEmail.FromEmail != "")
{
bSend = this.SendMailNET(objEmail);
}
else
{
bSend = this.SendMailNET_NoSelf(objEmail);
}
} while (false);
return bSend;
}
catch (Exception ex)
{
sError = ex.Message;
Logger.Error("MailService.MailFactory Error:" + sError + " Params：" + JsonToString(i_oEmail), ex);
return bSend;
}
finally
{
o_sError = sError;
}
}
#region Definition Public Methods
#region SendMail
/// <summary>
/// 同步發送電子郵件
/// </summary>
/// <param name="o_myMessage">電子郵件</param>
[SoapRpcMethod(OneWay = true)]
public void SendMail(MailMessage o_myMessage)
{
#region "重構在 GetEmailConfig()"
var o_myMailServer = GetEmailConfig(); //new SmtpClient(sServer);//寄件服務器地址,端口
#endregion "重構在 GetEmailConfig()"
try
{
object userState = o_myMailServer;
//o_myMailServer.SendCompleted += new SendCompletedEventHandler(SendCompletedCallback);
o_myMailServer.SendAsync(o_myMessage, userState);
}
catch (SmtpException ex)
{
ErrorMessages = ex.Message;
Logger.Error(ex);
}
}
/// <summary>
/// 同步發送電子郵件組
/// </summary>
/// <param name="o_myMessage">電子郵件組</param>
[SoapRpcMethod(OneWay = true)]
public void SendMail(MailMessage[] o_myMessage)
{
try
{
for (int i = 0; i <= o_myMessage.Length - 1; i++)
{
//Add by Alina 20131216 170 146 信件通知超連結 Star
o_myMessage[i].Body = o_myMessage[i].Body;
//Add by Alina 20131216 170 146 信件通知超連結 End
SendMail(o_myMessage[i]);//發送
}
}
catch (SmtpException ex)
{
ErrorMessages = ex.Message;
Logger.Error(ex);
}
}
#endregion SendMail
#region SendMailNET
/// <summary>
/// 同步發送電子郵件
/// </summary>
/// <param name="o_myMessage">電子郵件</param>
/// <returns></returns>
public bool SendMailNET_NoSelf(MailMessage o_myMessage)
{
try
{
Logger.Debug("發送郵件開始");
var o_myMailServer = GetEmailConfig(); //new SmtpClient(sServer);//寄件服務器地址,端口
//發送Mail
o_myMailServer.Send(o_myMessage);
Logger.Debug("FormName:" + o_myMessage.From.DisplayName + ";FormMail:" + o_myMessage.From.Address);
Logger.Debug("發送郵件結束");
return true;
}
catch (SmtpException ex)
{
ErrorMessages = ex.Message;
Logger.Error(ex);
return false;
}
}
/// <summary>
/// 同步發送電子郵件
/// </summary>
/// <param name="o_myMessage">電子郵件</param>
/// <returns></returns>
public bool SendMailNET(MailMessage o_myMessage)
{
try
{
Logger.Debug("發送郵件開始");
var o_myMailServer = GetEmailConfig(); //new SmtpClient(sServer);//寄件服務器地址,端口
//Add by Alina 需要把發件者的信息添加到抄送人中
var reg = new Regex(@"(\w*)(\()*");
var strFromName = o_myMessage.From.DisplayName;//人員名稱
var strFromMail = o_myMessage.From.Address;//人員Mail
var m = reg.Match(strFromName);
strFromName = m.Groups[1].Value;
var o_MailTo = new MailAddress(strFromMail, strFromName);
o_myMessage.From = o_MailTo;//發件者的信息
o_myMessage.CC.Add(o_myMessage.From);//把發件者的信息添加到抄送人中
//發送Mail
Logger.Debug("FormName:" + o_myMessage.From.DisplayName + ";FormMail:" + o_myMessage.From.Address);
o_myMailServer.Send(o_myMessage);
return true;
}
catch (SmtpException ex)
{
ErrorMessages = ex.Message;
Logger.Error(ex);
return false;
}
}
/// <summary>
/// 同步發送電子郵件組
/// </summary>
/// <param name="o_myMessage">電子郵件組</param>
/// <returns></returns>
public bool SendMailNET(MailMessage[] o_myMessage)
{
var blOK = true;
try
{
for (int i = 0; i <= o_myMessage.Length - 1; i++)
{
var blThisOK = SendMailNET(o_myMessage[i]);//發送
if (blThisOK == false)
{
//只記錄發送失敗的
blOK = false;
}
}
}
catch (SmtpException ex)
{
ErrorMessages = ex.Message;
Logger.Error(ex);
}
return blOK;
}
#endregion SendMailNET
#endregion Definition Public Methods
#region Definition Private Methods
#region "GetEmailConfig"
/// <summary>
/// 提供本類中其它公有郵件功能,取得基本smtp設定.
/// </summary>
/// <returns></returns>
private SmtpClient GetEmailConfig()
{
var sMailEncoding = IsConfig || mailSetting["MailEncoding"] == null ? ConfigurationManager.AppSettings["MailEncoding"].ToString().Trim() : mailSetting["MailEncoding"].ToString().Trim(); //設置字集防止亂碼
var sFromUserid = IsConfig || mailSetting["FromUserId"] == null ? ConfigurationManager.AppSettings["FromUserId"].ToString().Trim() : mailSetting["FromUserId"].ToString().Trim(); //發件人的帳號
var sFromPassword = IsConfig || mailSetting["FromPassword"] == null ? ConfigurationManager.AppSettings["FromPassword"].Trim() : mailSetting["FromPassword"].ToString(); //發件人的密碼
var sServer = IsConfig || mailSetting["Server"] == null ? ConfigurationManager.AppSettings["Server"].ToString().Trim() : mailSetting["Server"].ToString().Trim(); //發送郵件服務器的IP地址
int i32ServerPort;
int.TryParse(IsConfig || mailSetting["ServerPort"] == null ? ConfigurationManager.AppSettings["ServerPort"].ToString().Trim() : mailSetting["ServerPort"].ToString().Trim(), out i32ServerPort); //發送郵件服務器的端口
int iTimeout;
int.TryParse(IsConfig || mailSetting["Timeout"] == null ? ConfigurationManager.AppSettings["Timeout"].ToString().Trim() : mailSetting["Timeout"].ToString(), out iTimeout); //發送郵件超時時間
var blSSLYES = (IsConfig || mailSetting["SSL"] == null ? ConfigurationManager.AppSettings["SSL"].ToString().Trim() : mailSetting["SSL"].ToString().Trim()).Equals("true") ? true : false;//是否開啟SSL驗證
var o_myMailServer = new SmtpClient(sServer)
{
Host = sServer
};//寄件服務器地址,端口
if (i32ServerPort != 0)
{
o_myMailServer.Port = i32ServerPort;
}
o_myMailServer.EnableSsl = blSSLYES;//是否開啟SSL驗證
//o_myMailServer.DeliveryMethod = SmtpDeliveryMethod.Network;
if (iTimeout != 0)
{
o_myMailServer.Timeout = iTimeout * 1000; //若郵件過大,請手動加長時間, 1000約等於1秒
}
if (!sFromPassword.Equals(""))
{
o_myMailServer.UseDefaultCredentials = false;
o_myMailServer.Credentials = new System.Net.NetworkCredential(sFromUserid, sFromPassword);//登錄會員名和密碼
}
return o_myMailServer;
}
#endregion "GetEmailConfig"
#endregion Definition Private Methods
#region Page Control Event
//#region SendMail
//private void test()
//{
// System.Net.Mail.MailMessage objEmail = new System.Net.Mail.MailMessage();
// //**寄件者信箱** string strMailFrom = ""; string FromName = ""; if (strMailFrom.Equals("") ==
// false) { System.Net.Mail.MailAddress o_MailFrom = new
// System.Net.Mail.MailAddress(strMailFrom, FromName, Encoding.Default); objEmail.From =
// o_MailFrom; }
// //**收件者信箱** string strMailTo = ""; if (strMailTo.Equals("") == false) {
// System.Net.Mail.MailAddress o_MailTo = new System.Net.Mail.MailAddress(strMailTo);
// objEmail.To.Add(o_MailTo); }
// //**副本收件者信箱** string strMailCC = ""; if (strMailCC.Equals("") == false) { //隱藏副本收件者信箱不為空
// objEmail.CC.Add(strMailCC); }
// //**隱藏副本收件者信箱** string strMailbcc = ""; if (strMailbcc.Equals("") == false) {
// //隱藏副本收件者信箱不為空 objEmail.Bcc.Add(strMailbcc); }
// //**信件主旨** objEmail.Subject = "信件主旨";
// //**信件主體(HTML模式)** //objEmail.HTMLbody = ""
// //**信件主體(文字模式)** objEmail.Body = "信件主體";
// //'**设置正文的编码形式.这里的设置为取系统默认编码 objEmail.BodyEncoding = System.Text.Encoding.Default;
// //'**设置主题的编码形式.这里的设置为取系统默认编码 objEmail.SubjectEncoding = System.Text.Encoding.Default;
// //'**描述Mail傳遞告知選項 // Delay：通知传送是否延迟。 // Never：从不通知。 // None：没有通知。 // OnFailure：通知传送是否失败。
// // OnSuccess：通知传送是否成功。 objEmail.DeliveryNotificationOptions = System.Net.Mail.DeliveryNotificationOptions.OnFailure;
// //**信件送出** SendMailNET(objEmail); SendMailAsync(objEmail);
//}
//#endregion
#endregion Page Control Event
}
public class Emails
{
public string FromOrgID { get; set; }
public string FromUserID { get; set; }
public string FromUserName { get; set; }
public string FromEmail { get; set; }
public string Title { get; set; }
public string EmailBody { get; set; }
public bool IsCCSelf { get; set; }
public List<EmailTo> EmailTo { get; set; }
public object[] Attachments { get; set; }
}
public class EmailTo
{
public string ToUserID { get; set; }
public string ToUserName { get; set; }
public string ToEmail { get; set; }
public string Type { get; set; }
}
public class AllUsers
{
public string OrgID { get; set; }
public string MemberID { get; set; }
public string MemberName { get; set; }
public string Email { get; set; }
}
public class OutlookDotComMail
{
//string mailUser = "dd24166@outlook.com";
//string mailUserPwd = "654321zzz";
//var sender = new OutlookDotComMail(mailUser, mailUserPwd);
//sender.SendMail("john.yuan@origtek.com.cn", "Test Mail", "Hello!");
//string mailUser = "info@eurotran.com";
//string mailUserPwd = "@in27856000!";
//var sender = new OutlookDotComMail(mailUser, mailUserPwd);
//sender.SendMail("john.yuan@origtek.com.cn", "Test Mail!", "Hello!!!!");
private string _sender = "";
private string _password = "";
public OutlookDotComMail(string sender, string password)
{
_sender = sender;
_password = password;
}
public void SendMail(string recipient, string subject, string message)
{
//SmtpClient client = new SmtpClient("smtp-mail.outlook.com");
using (var client = new SmtpClient("smtp.office365.com")
{
Port = 587,
DeliveryMethod = SmtpDeliveryMethod.Network,
UseDefaultCredentials = false
})
{
var credentials = new System.Net.NetworkCredential(_sender, _password);
client.EnableSsl = true;
client.Credentials = credentials;
try
{
var mail = new MailMessage(_sender.Trim(), recipient.Trim())
{
Subject = subject,
Body = message
};
client.Send(mail);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
throw;
}
}
}
}
}