From e2f9feed1f85bee05fa384e289a21ca0788dcafd Mon Sep 17 00:00:00 2001 From: Luk Lu Date: Sat, 6 Aug 2022 11:53:40 +0800 Subject: [PATCH] u --- messenger.js | 133 ++++++++++++++++++++++++++------------------------- 1 file changed, 67 insertions(+), 66 deletions(-) diff --git a/messenger.js b/messenger.js index a2995ed..fad002a 100644 --- a/messenger.js +++ b/messenger.js @@ -2,7 +2,8 @@ const util = require('util') const http = require('http') const NodeMailer = require('nodemailer') -const my = {} +// 注意，unicloud 不支持，本文件里只好不用 ?. 操作符 +const my = { envar: typeof wo !== 'undefined' ? wo.envar : globalThis.envar || {} } const sender = {} module.exports = { @@ -11,30 +12,30 @@ module.exports = { }, // 或者如果smtp参数已经确定，就可以直接定义 sendMail: Bluebird.promisify(Smtp.sendMail).bind(Smtp) - async sendMail (messageObject) { // messageObject: { from, to, cc, bcc, subject, text, html, sender, replyTo, inReplyTo } - sender.smtpTransporter = sender.smtpTransporter || NodeMailer.createTransport(wo.envar.SMTP) + async sendMail (messageObject) { + // 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) }, - - async sendSms ({ - phone, - vendor, // = my.envar?.SMS.VENDOR || wo?.envar?.SMS.VENDOR || 'UNICLOUD' + + async sendSms ({ + phone, + vendor = my.envar.SMS.vendor, msg, // for vendor==='DXTON' - msgParam, msgTemplate, // for ['ALIYUN','UNICLOUD'].includes(vendor) + msgParam, + msgTemplate, // for ['ALIYUN','UNICLOUD'].includes(vendor) signName, // for vendor==='ALIYUN', 'TENCENT' appid, // for vendor==='UNICLOUD', 'TENCENT' } = {}) { - const envar = my.envar || wo.envar - vendor = vendor || envar.SMS.vendor if (/^\+\d+-\d+$/.test(phone)) { if (vendor === 'DXTON' && msg) { return await this.sendSmsDxton(phone, msg) } else if (vendor === 'ALIYUN' && msgParam && msgTemplate) { return await this.sendSmsAliyun(phone, msgParam, msgTemplate, signName) } 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) { - return await this.sendSmsTencent({phone, msgParam, msgTemplate, appid, signName}) + return await this.sendSmsTencent({ phone, msgParam, msgTemplate, appid, signName }) } else { return { _state: 'SMS_UNKNOWN_VENDOR', error: {} } } @@ -42,7 +43,7 @@ module.exports = { return { _state: 'SMS_INVALID_PHONE', error: {} } } }, - + /* 使用 dxton.com 的短信接口 http://www.dxton.com/help_detail/38.html - 测试接口： - 国内： http://sms.106jiekou.com/utf8/sms.aspx?account=9999&password=接口密码&mobile=13900008888&content=您的订单编码：888888。如需帮助请联系客服。 @@ -53,36 +54,37 @@ module.exports = { var matches = phone.match(/\d+/g) var smsNumber, smsUrl if (matches[0] === '86') { - smsUrl = wo.envar.SMS.DXTON.urlChina + smsUrl = my.envar.SMS.DXTON.urlChina smsNumber = matches[1] } else { - smsUrl = wo.envar.SMS.DXTON.urlWorld // 国际短信不需要签名、模板，可发送任意内容。 + smsUrl = my.envar.SMS.DXTON.urlWorld // 国际短信不需要签名、模板，可发送任意内容。 smsNumber = matches[0] + matches[1] } // let returnCode = await RequestPromise.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg)) // let returnCode = await axios.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg)) - return await new Promise((resolve, reject)=>{ - http.get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg), (resp)=>{ - let returnCode = '' - resp.on('returnCode', (chunk) => { returnCode += chunk }) - resp.on('end', () => { - 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 - } + return await new Promise((resolve, reject) => { + http + .get(smsUrl + '&mobile=' + smsNumber + '&content=' + encodeURIComponent(msg), (resp) => { + let returnCode = '' + resp.on('returnCode', (chunk) => { + returnCode += chunk + }) + resp.on('end', () => { + 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) { - const envar = my.envar || wo.envar - - sender.smsClientAliyun = sender.smsClientAliyun || new (require('@alicloud/sms-sdk'))(envar.SMS.ALIYUN) // https://www.npmjs.com/package/@alicloud/sms-sdk + async sendSmsAliyun (phone, msgParam, msgTemplate, signName = my.envar.SMS.ALIYUN.signName) { + sender.smsClientAliyun = sender.smsClientAliyun || new (require('@alicloud/sms-sdk'))(my.envar.SMS.ALIYUN) // https://www.npmjs.com/package/@alicloud/sms-sdk const [countryCode, callNumber] = phone.match(/\d+/g) const smsNumber = countryCode === '86' ? callNumber : `00${countryCode}${callNumber}` @@ -90,7 +92,7 @@ module.exports = { return await sender.smsClientAliyun .sendSMS({ PhoneNumbers: smsNumber, //必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式；发送国际/港澳台消息时，接收号码格式为00+国际区号+号码，如“0085200000000” - SignName: signName || envar.SMS.ALIYUN.signName, //必填:短信签名-可在短信控制台中找到 + SignName: signName, //必填:短信签名-可在短信控制台中找到 TemplateCode: msgTemplate, //必填:短信模板-可在短信控制台中找到，发送国际/港澳台消息时，请使用国际/港澳台短信模版 TemplateParam: JSON.stringify(msgParam), //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时。 }) @@ -109,52 +111,51 @@ module.exports = { ) }, - async sendSmsUnicloud({ phone, msgTemplate, msgParam, appid }) { + async sendSmsUnicloud ({ phone, msgTemplate, msgParam, appid = my.envar.SMS.UNICLOUD.appid } = {}) { try { - const envar = my.envar || wo.envar // 不能在下面调用 my.envar.*** 因为 my.envar 可能并未初始化，而 unicloud 又不支持 ?. 操作符. const result = await uniCloud.sendSms({ - appid: appid || envar.SMS.UNICLOUD.appid, - smsKey: envar.SMS.UNICLOUD.smsKey, - smsSecret: envar.SMS.UNICLOUD.smsSecret, + appid: appid, + smsKey: my.envar.SMS.UNICLOUD.smsKey, + smsSecret: my.envar.SMS.UNICLOUD.smsSecret, phone: phone.match(/\d+/g)[1], 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 } catch (error) { // 调用失败 例如 {"code":undefined,"msg":"短信发送失败：账户余额不足"} return { _state: 'SMS_SEND_FAIL', - error // { errCode, errMsg } + error, // { errCode, errMsg } } } }, - async sendSmsTencent ({ phone, msgTemplate, msgParam, signName, appid }) { - const envar = my.envar || wo.envar + async sendSmsTencent ({ phone, msgTemplate, msgParam, signName = my.envar.SMS.TENCENT.signName, appid = my.envar.SMS.TENCENT.appid } = {}) { + 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({ // API: https://cloud.tencent.com/document/product/382/55981 - PhoneNumberSet: [phone.replace('-', '')], - SmsSdkAppId: appid || envar.SMS.TENCENT.appid, - SignName: signName || envar.SMS.TENCENT.signName, - TemplateId: msgTemplate, - TemplateParamSet: Object.values(msgParam), - }).then( - function ({SendStatusSet, RequestId} = {}) { - let { SerialNo, PhoneNumber, Fee, Code, Message, IsoCode } = SendStatusSet[0] - if (Code === 'Ok') { - return { _state: 'SMS_SENT_SUCCESS' } - } else { - return { _state: 'SMS_SEND_FAIL', error: {SendStatusSet, RequestId} } + return await sender.smsClientTencent + .SendSms({ + // API: https://cloud.tencent.com/document/product/382/55981 + PhoneNumberSet: [phone.replace('-', '')], + SmsSdkAppId: appid, + SignName: signName, + TemplateId: msgTemplate, + TemplateParamSet: Object.values(msgParam), + }) + .then( + function ({ SendStatusSet, RequestId } = {}) { + let { SerialNo, PhoneNumber, Fee, Code, Message, IsoCode } = SendStatusSet[0] + if (Code === 'Ok') { + return { _state: 'SMS_SENT_SUCCESS' } + } 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 } - } - ) - } - + ) + }, }