npm/wo-base-messenger
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

u

Browse Source
This commit is contained in:
陆柯 2022-08-06 11:53:40 +08:00
parent 2854f1dc32
commit e2f9feed1f
1 changed files with 67 additions and 66 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

123
messenger.js
View File

@ -2,7 +2,8 @@ const util = require('util')
const http = require('http') const http = require('http')
const NodeMailer = require('nodemailer') const NodeMailer = require('nodemailer')
const my = {} // 注意，unicloud 不支持，本文件里只好不用 ?. 操作符
const my = { envar: typeof wo !== 'undefined' ? wo.envar : globalThis.envar || {} }
const sender = {} const sender = {}
module.exports = { module.exports = {
@ -11,30 +12,30 @@ module.exports = {
}, },
// 或者如果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) {
sender.smtpTransporter = sender.smtpTransporter || NodeMailer.createTransport(wo.envar.SMTP) // messageObject: { from, to, cc, bcc, subject, text, html, sender, replyTo, inReplyTo }
sender.smtpTransporter = sender.smtpTransporter || NodeMailer.createTransport(my.envar.SMTP)
return await util.promisify(sender.smtpTransporter.sendMail).call(sender.smtpTransporter, messageObject) return await util.promisify(sender.smtpTransporter.sendMail).call(sender.smtpTransporter, messageObject)
}, },
async sendSms ({ async sendSms ({
phone, phone,
vendor, // = my.envar?.SMS.VENDOR || wo?.envar?.SMS.VENDOR || 'UNICLOUD' vendor = my.envar.SMS.vendor,
msg, // for vendor==='DXTON' msg, // for vendor==='DXTON'
msgParam, msgTemplate, // for ['ALIYUN','UNICLOUD'].includes(vendor) msgParam,
msgTemplate, // for ['ALIYUN','UNICLOUD'].includes(vendor)
signName, // for vendor==='ALIYUN', 'TENCENT' signName, // for vendor==='ALIYUN', 'TENCENT'
appid, // for vendor==='UNICLOUD', 'TENCENT' appid, // for vendor==='UNICLOUD', 'TENCENT'
} = {}) { } = {}) {
const envar = my.envar || wo.envar
vendor = vendor || envar.SMS.vendor
if (/^\+\d+-\d+$/.test(phone)) { if (/^\+\d+-\d+$/.test(phone)) {
if (vendor === 'DXTON' && msg) { if (vendor === 'DXTON' && msg) {
return await this.sendSmsDxton(phone, msg) return await this.sendSmsDxton(phone, msg)
} else if (vendor === 'ALIYUN' && msgParam && msgTemplate) { } else if (vendor === 'ALIYUN' && msgParam && msgTemplate) {
return await this.sendSmsAliyun(phone, msgParam, msgTemplate, signName) return await this.sendSmsAliyun(phone, msgParam, msgTemplate, signName)
} else if (vendor === 'UNICLOUD' && msgParam && msgTemplate) { } else if (vendor === 'UNICLOUD' && msgParam && msgTemplate) {
return await this.sendSmsUnicloud({phone, msgParam, msgTemplate, appid}) return await this.sendSmsUnicloud({ phone, msgParam, msgTemplate, appid })
} else if (vendor === 'TENCENT' && msgParam && msgTemplate) { } else if (vendor === 'TENCENT' && msgParam && msgTemplate) {
return await this.sendSmsTencent({phone, msgParam, msgTemplate, appid, signName}) return await this.sendSmsTencent({ phone, msgParam, msgTemplate, appid, signName })
} else { } else {
return { _state: 'SMS_UNKNOWN_VENDOR', error: {} } return { _state: 'SMS_UNKNOWN_VENDOR', error: {} }
} }
@ -53,36 +54,37 @@ module.exports = {
var matches = phone.match(/\d+/g) var matches = phone.match(/\d+/g)
var smsNumber, smsUrl var smsNumber, smsUrl
if (matches[0] === '86') { if (matches[0] === '86') {
smsUrl = wo.envar.SMS.DXTON.urlChina smsUrl = my.envar.SMS.DXTON.urlChina
smsNumber = matches[1] smsNumber = matches[1]
} else { } else {
smsUrl = wo.envar.SMS.DXTON.urlWorld // 国际短信不需要签名、模板，可发送任意内容。 smsUrl = my.envar.SMS.DXTON.urlWorld // 国际短信不需要签名、模板，可发送任意内容。
smsNumber = matches[0] + matches[1] smsNumber = matches[0] + matches[1]
} }
// let returnCode = await RequestPromise.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg)) // let returnCode = await RequestPromise.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg))
// let returnCode = await axios.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg)) // let returnCode = await axios.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg))
return await new Promise((resolve, reject)=>{ return await new Promise((resolve, reject) => {
http.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg), (resp)=>{ http
let returnCode = '' .get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg), (resp) => {
resp.on('returnCode', (chunk) => { returnCode += chunk }) let returnCode = ''
resp.on('end', () => { resp.on('returnCode', (chunk) => {
if (parseInt(returnCode)===100){ returnCode += chunk
resolve({ _state: 'SMS_SENT_SUCCESS' }) // 100: 发送成功 （表示已和我们接口连通） })
}else{ resp.on('end', () => {
resolve({ _state: 'SMS_SEND_FAIL', error: { returnCode }}) // 短信接口错误代码：http://www.dxton.com/help_detail/2.html if (parseInt(returnCode) === 100) {
} resolve({ _state: 'SMS_SENT_SUCCESS' }) // 100: 发送成功 （表示已和我们接口连通）
} else {
resolve({ _state: 'SMS_SEND_FAIL', error: { returnCode } }) // 短信接口错误代码：http://www.dxton.com/help_detail/2.html
}
})
})
.on('error', (error) => {
reject({ _state: 'SMS_SEND_ERROR', error })
}) })
}).on("error",(error)=>{
reject({ _state: 'SMS_SEND_ERROR', error })
})
}) })
}, },
async sendSmsAliyun (phone, msgParam, msgTemplate, signName) { async sendSmsAliyun (phone, msgParam, msgTemplate, signName = my.envar.SMS.ALIYUN.signName) {
const envar = my.envar || wo.envar sender.smsClientAliyun = sender.smsClientAliyun || new (require('@alicloud/sms-sdk'))(my.envar.SMS.ALIYUN) // https://www.npmjs.com/package/@alicloud/sms-sdk
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}`
@ -90,7 +92,7 @@ module.exports = {
return await sender.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, //必填:短信签名-可在短信控制台中找到
TemplateCode: msgTemplate, //必填:短信模板-可在短信控制台中找到，发送国际/港澳台消息时，请使用国际/港澳台短信模版 TemplateCode: msgTemplate, //必填:短信模板-可在短信控制台中找到，发送国际/港澳台消息时，请使用国际/港澳台短信模版
TemplateParam: JSON.stringify(msgParam), //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时。 TemplateParam: JSON.stringify(msgParam), //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时。
}) })
@ -109,16 +111,15 @@ module.exports = {
) )
}, },
async sendSmsUnicloud({ phone, msgTemplate, msgParam, appid }) { async sendSmsUnicloud ({ phone, msgTemplate, msgParam, appid = my.envar.SMS.UNICLOUD.appid } = {}) {
try { try {
const envar = my.envar || wo.envar // 不能在下面调用 my.envar.*** 因为 my.envar 可能并未初始化，而 unicloud 又不支持 ?. 操作符.
const result = await uniCloud.sendSms({ const result = await uniCloud.sendSms({
appid: appid || envar.SMS.UNICLOUD.appid, appid: appid,
smsKey: envar.SMS.UNICLOUD.smsKey, smsKey: my.envar.SMS.UNICLOUD.smsKey,
smsSecret: envar.SMS.UNICLOUD.smsSecret, smsSecret: my.envar.SMS.UNICLOUD.smsSecret,
phone: phone.match(/\d+/g)[1], phone: phone.match(/\d+/g)[1],
templateId: msgTemplate || 'uni_sms_test', templateId: msgTemplate || 'uni_sms_test',
data: msgParam // 模版中的变量的值，例如 { passcode: '234345', purpose: '注册' } data: msgParam, // 模版中的变量的值，例如 { passcode: '234345', purpose: '注册' }
}) })
return { _state: 'SMS_SENT_SUCCESS', result } // 调用成功，请注意这时不代表发送成功。// { code:0, errCode:0, success:true } 错误码参见 https://uniapp.dcloud.net.cn/uniCloud/send-sms.html return { _state: 'SMS_SENT_SUCCESS', result } // 调用成功，请注意这时不代表发送成功。// { code:0, errCode:0, success:true } 错误码参见 https://uniapp.dcloud.net.cn/uniCloud/send-sms.html
@ -126,35 +127,35 @@ module.exports = {
// 调用失败 例如 {"code":undefined,"msg":"短信发送失败：账户余额不足"} // 调用失败 例如 {"code":undefined,"msg":"短信发送失败：账户余额不足"}
return { return {
_state: 'SMS_SEND_FAIL', _state: 'SMS_SEND_FAIL',
error // { errCode, errMsg } error, // { errCode, errMsg }
} }
} }
}, },
async sendSmsTencent ({ phone, msgTemplate, msgParam, signName, appid }) { async sendSmsTencent ({ phone, msgTemplate, msgParam, signName = my.envar.SMS.TENCENT.signName, appid = my.envar.SMS.TENCENT.appid } = {}) {
const envar = my.envar || wo.envar sender.smsClientTencent = sender.smsClientTencent || new (require('tencentcloud-sdk-nodejs').sms.v20210111.Client)(my.envar.SMS.TENCENT) // https://cloud.tencent.com/document/product/382/43197
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 sender.smsClientTencent
.SendSms({
return await sender.smsClientTencent.SendSms({ // API: https://cloud.tencent.com/document/product/382/55981 // API: https://cloud.tencent.com/document/product/382/55981
PhoneNumberSet: [phone.replace('-', '')], PhoneNumberSet: [phone.replace('-', '')],
SmsSdkAppId: appid || envar.SMS.TENCENT.appid, SmsSdkAppId: appid,
SignName: signName || envar.SMS.TENCENT.signName, SignName: signName,
TemplateId: msgTemplate, TemplateId: msgTemplate,
TemplateParamSet: Object.values(msgParam), TemplateParamSet: Object.values(msgParam),
}).then( })
function ({SendStatusSet, RequestId} = {}) { .then(
let { SerialNo, PhoneNumber, Fee, Code, Message, IsoCode } = SendStatusSet[0] function ({ SendStatusSet, RequestId } = {}) {
if (Code === 'Ok') { let { SerialNo, PhoneNumber, Fee, Code, Message, IsoCode } = SendStatusSet[0]
return { _state: 'SMS_SENT_SUCCESS' } if (Code === 'Ok') {
} else { return { _state: 'SMS_SENT_SUCCESS' }
return { _state: 'SMS_SEND_FAIL', error: {SendStatusSet, RequestId} } } else {
return { _state: 'SMS_SEND_FAIL', error: { SendStatusSet, RequestId } }
}
},
function (error) {
return { _state: 'SMS_SEND_ERROR', error }
} }
}, )
function (error) { },
return { _state: 'SMS_SEND_ERROR', error }
}
)
}
} }