插件案例 —— 后台发邮件、云之家消息、机器人消息原创
MiLai
19人赞赏了该文章
3544次浏览
编辑于2020年08月04日 12:57:41
业务背景
有的时候针对业务监控，我们还需要对特殊的业务进行发邮件给上级部门或者主管，以便能做到更及时，无失误。
而对于每个公司，每个业务员信息维护方式一样，基于个人信息的邮箱地址，我们可以自行在发预警的时候也发送邮件。
下面我介绍一下如果自己扩展二开发送邮件功能。（以采购价格失效为例）当然了，你也放在执行计划中。
开发案例
其实扩展开发业务预警代码，在执行完业务后，同时进行邮件发送。
由于系统发送邮件需要指定发送人，所以我们可以在管理系统参数中默认预置发送人、发送服务器等信息。
最终调用MailUtils.SendEmail服务
发邮件
using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Net.Mail; using System.Text; using Kingdee.BOS; using Kingdee.BOS.App.Data; using Kingdee.BOS.Contracts; using Kingdee.BOS.Contracts.Messages; using Kingdee.BOS.Core; using Kingdee.BOS.Core.Metadata; using Kingdee.BOS.Core.SqlBuilder; using Kingdee.BOS.Log; using Kingdee.BOS.Msg; using Kingdee.BOS.Orm.DataEntity; using Kingdee.BOS.Util;
//继承 AbstractWarnServicePlugIn，方法
//发送邮件，获取默认发送人 //可以使用系统中默认的”邮件服务设置“，配值默认的发件人
ISystemParameterService sysService = Kingdee.BOS.Contracts.ServiceFactory.GetSystemParameterService(this.Context);
DynamicObjectinquirySysParam = sysService.Load(this.Context, 0, 0, "管理系统参数");
string mailFid = "";
if (inquirySysParam != null && inquirySysParam.DynamicObjectType.Properties.ContainsKey("SendMail"))
mailFid = Convert.ToString(inquirySysParam["SendMail_Id"]);
else
return;
//根据配值ID，获取对应的配值服务信息 //发件人账号、密码、发件地址、SSL等
string strSql = string.Format(@"SELECTFEMAILADDRESS,FUSERNAME,FPASSWORD,TSER.FMAILSERVER,FMESSAGETYPE,FSMTPPORT,FSSLFROM T_BAS_MAILVIRTUALACCOUNT TMAIL
INNER JOIN T_BAS_MAILSERVERTSER ON TMAIL.FMAILSERVER = TSER.FID WHERE TMAIL.FID = {0}", mailFid);
DynamicObjectCollectionmailInfos = DBUtils.ExecuteDynamicObject(this.Context, strSql, null, null, System.Data.CommandType.Text, null);
if (mailInfos == null || mailInfos.Count <= 0)
return;
DynamicObject mailInfo = mailInfos.FirstOrDefault();
string senderMailAddress = Convert.ToString(mailInfo["FEMAILADDRESS"]);
string title = e.WarnMessage.MobileTitle;
string SMTPHost = Convert.ToString(mailInfo["FMAILSERVER"]);
int port = Convert.ToInt32(mailInfo["FSMTPPORT"]);
bool isSSL = Convert.ToInt32(mailInfo["FSSL"]) == 1;
string userName = Convert.ToString(mailInfo["FUSERNAME"]);
string pwd = DoProclaimText(Convert.ToString(mailInfo["FPASSWORD"]));
//系统对发送消息的用户包装UserWarnMessageCollection，可以获取到对应的用户ID
var lst = e.WarnMessage.UserWarnMessageCollection;
if (lst == null || lst.Count <= 0)
return;
//根据用户ID，找到用户的Email
string emailSql = string.Format(@"SELECT FUSERID,FEMAIL FROM T_SEC_USER
WHEREFUSERID IN ({0})", string.Join(",", lst.Select(x => x.Key).ToArray()));
DynamicObjectCollectionmailLst = DBUtils.ExecuteDynamicObject(this.Context, emailSql, null, null, System.Data.CommandType.Text, null);
foreach (var item in lst)
{
try
{
List listTo = new List();
long userId = item.Key;
var info = mailLst.Where(x => Convert.ToInt64(x["FUSERID"]) == userId);
string userEmail = string.Empty;
if (info != null && info.Count() > 0)
userEmail = Convert.ToString(info.FirstOrDefault()["FEMAIL"]);
if (string.IsNullOrEmpty(userEmail))
continue;
listTo.Add(userEmail); //根据用户，对预警信息进行整理。
Kingdee.BOS.Core.Warn.Message.UserWarnMessage msg = item.Value;
string message = string.Join("\n", msg.GetMessageItems().ToList().Select(x => x.MessageEntity asMessageEntity).Select(x => x.Content).ToArray()); //发送邮件
MailUtils.Sendmail(senderMailAddress, null, listTo, title, message, SMTPHost, port, isSSL, null, userName, pwd);
}
catch (Exceptionex)
{
ILogService logService = Kingdee.BOS.Contracts.ServiceFactory.GetLogService(this.Context);
Kingdee.BOS.Core.Log.LogObject log = newKingdee.BOS.Core.Log.LogObject();
log.Description = ex.Message;
logService.WriteLog(this.Context, log);
}
}private string DoProclaimText(string CipherText)
{
string result;
if (StringUtils.IsEmpty(CipherText))
{
result = CipherText;
}
else
{
byte[] bytes = Encoding.BigEndianUnicode.GetBytes(CipherText);
int num = bytes.Length;
byte[] array = new byte[num / 2];
for (int i = 0; i < num; i += 4)
{
byte b = bytes[i + 1];
byte b2 = bytes[i + 3];
int num2 = (int)(b & 15) << 4;
int num3 = (int)(b & 240);
int num4 = (int)(b2 & 15);
int num5 = (b2 & 240) >> 4;
array[i / 2] = Convert.ToByte(num2 | num5);
array[i / 2 + 1] = Convert.ToByte(num3 | num4);
}
result = Encoding.BigEndianUnicode.GetString(array, 0, array.Length);
}
return result;
}发云之家消息
private void SendYZJMessage(Context ctx, DynamicObject inquirySysParam, string msg)
{
if (inquirySysParam != null && inquirySysParam.DynamicObjectType.Properties.ContainsKey("YT_YZJSendId"))
{
DynamicObjectCollection dynamicObjectCollection = inquirySysParam["YT_YZJSendId"] as DynamicObjectCollection;
if (this.publicAccountService == null)
{
this.publicAccountService = ServiceFactory.GetPublicAccountService(ctx);
}
this.yzjPublickAccount = this.publicAccountService.GetPublicAccountByID(ctx, 10038L);
if (this.yzjPublickAccount != null)
{
if (dynamicObjectCollection != null && dynamicObjectCollection.Count > 0)
{
if (this.xunTongService == null)
{
this.xunTongService = ServiceFactory.GetXunTongService(ctx);
}
if (this.userXunTongService == null)
{
this.userXunTongService = ServiceFactory.GetService<IUserXunTongService>(ctx);
}
List<string> xunTongOpenIds = this.userXunTongService.GetXunTongOpenIds(ctx, (from x in dynamicObjectCollection
select Convert.ToString(x["YT_YZJSendId_Id"])).ToList<string>());
if (xunTongOpenIds.Count > 0)
{
XTSingleTextMessage xtsingleTextMessage = new XTSingleTextMessage();
xtsingleTextMessage.Title = "付款成功";
xtsingleTextMessage.Date = DateTime.Now.ToString();
xtsingleTextMessage.Text = msg;
xtsingleTextMessage.IsOpenUser = true;
xtsingleTextMessage.Users = xunTongOpenIds;
xtsingleTextMessage.PubAcctCode = Convert.ToString(this.yzjPublickAccount["ACCOUNTID"]);
xtsingleTextMessage.PubAcctKey = Convert.ToString(this.yzjPublickAccount["ACCOUNTKEY"]);
try
{
XTSendResult xtsendResult = this.xunTongService.SendSingleMessage(ctx, xtsingleTextMessage);
}
catch (Exception ex)
{
Logger.Error("YT", "云之家消息发送失败", ex);
}
}
}
}
}
}发消息机器人
利用webhook 发送http请求，传输指定JSON即可。
推荐阅读