This commit is contained in:
陆柯 2022-05-03 13:50:09 +08:00
parent b9581b14d8
commit 0a3df0ef33

View File

@ -3,19 +3,17 @@ const http = require('http')
const NodeMailer = require('nodemailer') const NodeMailer = require('nodemailer')
const my = {} const my = {}
const sender = {}
module.exports = { module.exports = {
init (envar) { init (envar) {
my.envar = envar my.envar = envar
my.smtpTransporter = NodeMailer.createTransport(envar.SMTP)
my.smsClientAliyun = new (require('@alicloud/sms-sdk'))(envar.SMS.ALIYUN) // https://www.npmjs.com/package/@alicloud/sms-sdk
my.smsClientTencent = new (require('tencentcloud-sdk-nodejs').sms.v20210111.Client)(envar.SMS.TENCENT) // https://cloud.tencent.com/document/product/382/43197
}, },
// 或者如果smtp参数已经确定就可以直接定义 sendMail: Bluebird.promisify(Smtp.sendMail).bind(Smtp) // 或者如果smtp参数已经确定就可以直接定义 sendMail: Bluebird.promisify(Smtp.sendMail).bind(Smtp)
async sendMail (messageObject) { // messageObject: { from, to, cc, bcc, subject, text, html, sender, replyTo, inReplyTo } async sendMail (messageObject) { // messageObject: { from, to, cc, bcc, subject, text, html, sender, replyTo, inReplyTo }
my.smtpTransporter = my.smtpTransporter || NodeMailer.createTransport(wo.envar.SMTP) sender.smtpTransporter = sender.smtpTransporter || NodeMailer.createTransport(wo.envar.SMTP)
return await util.promisify(my.smtpTransporter.sendMail).call(my.smtpTransporter, messageObject) return await util.promisify(sender.smtpTransporter.sendMail).call(sender.smtpTransporter, messageObject)
}, },
async sendSms ({ async sendSms ({
@ -84,12 +82,12 @@ module.exports = {
async sendSmsAliyun (phone, msgParam, msgTemplate, signName) { async sendSmsAliyun (phone, msgParam, msgTemplate, signName) {
const envar = my.envar || wo.envar const envar = my.envar || wo.envar
my.smsClientAliyun = my.smsClientAliyun || new (require('@alicloud/sms-sdk'))(envar.SMS.ALIYUN) sender.smsClientAliyun = sender.smsClientAliyun || new (require('@alicloud/sms-sdk'))(envar.SMS.ALIYUN) // https://www.npmjs.com/package/@alicloud/sms-sdk
const [countryCode, callNumber] = phone.match(/\d+/g) const [countryCode, callNumber] = phone.match(/\d+/g)
const smsNumber = countryCode === '86' ? callNumber : `00${countryCode}${callNumber}` const smsNumber = countryCode === '86' ? callNumber : `00${countryCode}${callNumber}`
return await my.smsClientAliyun return await sender.smsClientAliyun
.sendSMS({ .sendSMS({
PhoneNumbers: smsNumber, //必填:待发送手机号。支持以逗号分隔的形式进行批量调用批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式;发送国际/港澳台消息时接收号码格式为00+国际区号+号码如“0085200000000” PhoneNumbers: smsNumber, //必填:待发送手机号。支持以逗号分隔的形式进行批量调用批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式;发送国际/港澳台消息时接收号码格式为00+国际区号+号码如“0085200000000”
SignName: signName || envar.SMS.ALIYUN.signName, //必填:短信签名-可在短信控制台中找到 SignName: signName || envar.SMS.ALIYUN.signName, //必填:短信签名-可在短信控制台中找到
@ -136,9 +134,9 @@ module.exports = {
async sendSmsTencent ({ phone, msgTemplate, msgParam, signName, appid }) { async sendSmsTencent ({ phone, msgTemplate, msgParam, signName, appid }) {
const envar = my.envar || wo.envar const envar = my.envar || wo.envar
my.smsClientTencent = my.smsClientTencent || new (require('tencentcloud-sdk-nodejs').sms.v20210111.Client)(envar.SMS.TENCENT) sender.smsClientTencent = sender.smsClientTencent || new (require('tencentcloud-sdk-nodejs').sms.v20210111.Client)(envar.SMS.TENCENT) // https://cloud.tencent.com/document/product/382/43197
return await my.smsClientTencent.SendSms({ // API: https://cloud.tencent.com/document/product/382/55981 return await sender.smsClientTencent.SendSms({ // API: https://cloud.tencent.com/document/product/382/55981
PhoneNumberSet: [phone.replace('-', '')], PhoneNumberSet: [phone.replace('-', '')],
SmsSdkAppId: appid || envar.SMS.TENCENT.appid, SmsSdkAppId: appid || envar.SMS.TENCENT.appid,
SignName: signName || envar.SMS.TENCENT.signName, SignName: signName || envar.SMS.TENCENT.signName,