From a7d45c34737ce985c38502f235069ba8bbda3210 Mon Sep 17 00:00:00 2001 From: Luk Lu Date: Wed, 9 Mar 2022 15:54:33 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20init(envi)=20=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E6=9D=A5=E5=88=9D=E5=A7=8B=E5=8C=96=EF=BC=9B=E6=8A=8A?= =?UTF-8?q?phone=E5=8F=82=E6=95=B0=E5=90=88=E5=B9=B6=E5=88=B0=E7=AC=AC?= =?UTF-8?q?=E4=BA=8C=E4=B8=AA{...}=E5=8F=82=E6=95=B0=E9=87=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ConfigTemplate.js | 31 +++++++++++++++++++++++++++++++ messenger.js | 40 +++++++++++++++++----------------------- 2 files changed, 48 insertions(+), 23 deletions(-) diff --git a/ConfigTemplate.js b/ConfigTemplate.js index 80168ac..83caa04 100644 --- a/ConfigTemplate.js +++ b/ConfigTemplate.js @@ -17,6 +17,37 @@ module.exports = { aliyun:{ accessKeyId:'？？？？', secretAccessKey:'？？？？', + }, + tencent:{ // https://cloud.tencent.com/document/product/382/43197 + credential: { + /* 必填：腾讯云账户密钥对secretId，secretKey。 + * 这里采用的是从环境变量读取的方式，需要在环境变量中先设置这两个值。 + * 你也可以直接在代码中写死密钥对，但是小心不要将代码复制、上传或者分享给他人， + * 以免泄露密钥对危及你的财产安全。 + * SecretId、SecretKey 查询: https://console.cloud.tencent.com/cam/capi */ + secretId: process.env.secretId, + secretKey: process.env.secretKey, + }, + /* 必填：地域信息，可以直接填写字符串ap-guangzhou，支持的地域列表参考 https://cloud.tencent.com/document/api/382/52071#.E5.9C.B0.E5.9F.9F.E5.88.97.E8.A1.A8 */ + region: "ap-guangzhou", // ap-beijing, ap-nanjing + /* 非必填: + * 客户端配置对象，可以指定超时时间等配置 */ + profile: { + /* SDK默认用TC3-HMAC-SHA256进行签名，非必要请不要修改这个字段 */ + signMethod: "HmacSHA256", + httpProfile: { + /* SDK默认使用POST方法。 + * 如果你一定要使用GET方法，可以在这里设置。GET方法无法处理一些较大的请求 */ + reqMethod: "POST", + /* SDK有默认的超时时间，非必要请不要进行调整 + * 如有需要请在代码中查阅以获取最新的默认值 */ + reqTimeout: 30, + /** + * 指定接入地域域名，默认就近地域接入域名为 sms.tencentcloudapi.com ，也支持指定地域域名访问，例如广州地域的域名为 sms.ap-guangzhou.tencentcloudapi.com + */ + endpoint: "sms.tencentcloudapi.com" + }, + } } }, } \ No newline at end of file diff --git a/messenger.js b/messenger.js index d230137..cb9532c 100644 --- a/messenger.js +++ b/messenger.js @@ -1,27 +1,28 @@ const util = require('util') -//const RequestPromise = require('request-promise-native') // request-promise/-native。https://www.npmjs.com/package/request-promise. 还看到一个方法：Bluebird.promisifyAll(require("request")); const http = require('http') -const NodeMailer = require('nodemailer') // 或者 const smtpTransporter=require('nodemailer').createTransport({host:'', port:25, auth:{user:'',pass:''}}) +const NodeMailer = require('nodemailer') -let smtpTransporter = null - -let smsClient = null // 在调用时，才创建 smsClient，防止 wo.envi 还没有建立好。 +const my = {} module.exports = { + init (envi) { + my.envi = envi + my.smtpTransporter = NodeMailer.createTransport(envi.SMTP) + my.smsClient = new (require('@alicloud/sms-sdk'))(envi.SMS.aliyun) // https://www.npmjs.com/package/@alicloud/sms-sdk + }, - async sendMail (option) { - // 或者如果smtp参数已经确定，就可以直接定义 sendMail: Bluebird.promisify(Smtp.sendMail).bind(Smtp) - smtpTransporter = smtpTransporter || NodeMailer.createTransport(wo.envi.SMTP) - return await util.promisify(smtpTransporter.sendMail).call(smtpTransporter, option) + async sendMail (option) { // 或者如果smtp参数已经确定，就可以直接定义 sendMail: Bluebird.promisify(Smtp.sendMail).bind(Smtp) + my.smtpTransporter = my.smtpTransporter || NodeMailer.createTransport(wo.envi.SMTP) + return await util.promisify(my.smtpTransporter.sendMail).call(my.smtpTransporter, option) }, - async sendSms (phone, { vendor, msg, msgParam, templateCode, signName }={}) { + async sendSms ({ phone, vendor, msg, msgParam, msgTemplate, signName }={}) { // 通过option对象，对外提供统一的调用参数格式 if (/^\+\d+-\d+$/.test(phone)) { if (vendor === 'dxton' && msg) { return await this.sendSmsDxton(phone, msg) - } else if (vendor === 'aliyun' && msgParam && templateCode && signName) { - return await this.sendSmsAliyun(phone, msgParam, templateCode, signName) + } else if (vendor === 'aliyun' && msgParam && msgTemplate && signName) { + return await this.sendSmsAliyun(phone, msgParam, msgTemplate, signName) } } return null // 手机号格式错误，或者 option.vendor 错误。 @@ -63,15 +64,8 @@ module.exports = { }, - async sendSmsAliyun (phone, msgParam, templateCode, signName) { - // msgParam 是消息模板参数对象，例如 { code: "890353" } - smsClient = - smsClient || - new (require('@alicloud/sms-sdk'))({ - // 在调用时，才创建 smsClient，防止 wo.envi 还没有建立好。 - accessKeyId: wo.envi.SMS.aliyun.accessKeyId, - secretAccessKey: wo.envi.SMS.aliyun.secretAccessKey, - }) + async sendSmsAliyun (phone, msgParam, msgTemplate, signName) { + my.smsClient = my.smsClient || new (require('@alicloud/sms-sdk'))(wo.envi.SMS.aliyun) var matches = phone.match(/\d+/g) var smsNumber @@ -80,11 +74,11 @@ module.exports = { } else { smsNumber = '00' + matches[0] + matches[1] } - return await smsClient + return await my.smsClient .sendSMS({ PhoneNumbers: smsNumber, //必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式；发送国际/港澳台消息时，接收号码格式为00+国际区号+号码，如“0085200000000” SignName: signName, //必填:短信签名-可在短信控制台中找到 - TemplateCode: templateCode, //必填:短信模板-可在短信控制台中找到，发送国际/港澳台消息时，请使用国际/港澳台短信模版 + TemplateCode: msgTemplate, //必填:短信模板-可在短信控制台中找到，发送国际/港澳台消息时，请使用国际/港澳台短信模版 TemplateParam: JSON.stringify(msgParam), //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时。 }) .then(