/**
|
* Copyright(c) Alibaba Group Holding Limited.
|
*
|
* @file: sms-sdk
|
* @authors: qiankun <chuck.ql@alibaba-inc.com> (https://work.alibaba-inc.com/work/u/85053)
|
* @date 18/1/31
|
*/
|
|
'use strict';
|
|
var _regenerator = require('babel-runtime/regenerator');
|
|
var _regenerator2 = _interopRequireDefault(_regenerator);
|
|
var _asyncToGenerator2 = require('babel-runtime/helpers/asyncToGenerator');
|
|
var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2);
|
|
var _extends2 = require('babel-runtime/helpers/extends');
|
|
var _extends3 = _interopRequireDefault(_extends2);
|
|
var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');
|
|
var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);
|
|
var _createClass2 = require('babel-runtime/helpers/createClass');
|
|
var _createClass3 = _interopRequireDefault(_createClass2);
|
|
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
|
var DysmsapiClient = require('@alicloud/dysmsapi-2017-05-25');
|
var DybaseapiClient = require('@alicloud/dybaseapi');
|
var MNSClient = require('@alicloud/mns');
|
// 短信回执报告：SmsReport，短信上行：SmsUp
|
var msgTypeList = ["SmsReport", "SmsUp"];
|
var DYSMSAPI_ENDPOINT = 'http://dysmsapi.aliyuncs.com';
|
var DYBASEAPI_ENDPOINT = 'http://dybaseapi.aliyuncs.com';
|
var DEFAULT_REGION = 'cn-hangzhou';
|
|
function hasOwnProperty(obj, key) {
|
return Object.prototype.hasOwnProperty.call(obj, key);
|
}
|
|
var SMSClient = function () {
|
function SMSClient(options) {
|
(0, _classCallCheck3.default)(this, SMSClient);
|
var accessKeyId = options.accessKeyId,
|
secretAccessKey = options.secretAccessKey,
|
smsApiEndpoint = options.smsApiEndpoint,
|
baseApiEndpoint = options.baseApiEndpoint,
|
regionId = options.regionId,
|
mnsVpc = options.mnsVpc;
|
|
if (!accessKeyId) {
|
throw new TypeError('parameter "accessKeyId" is required');
|
}
|
if (!secretAccessKey) {
|
throw new TypeError('parameter "secretAccessKey" is required');
|
}
|
this.dysmsapiClient = new DysmsapiClient({
|
accessKeyId: accessKeyId,
|
secretAccessKey: secretAccessKey,
|
regionId: regionId || DEFAULT_REGION,
|
endpoint: smsApiEndpoint || DYSMSAPI_ENDPOINT
|
});
|
this.dybaseClient = new DybaseapiClient({
|
accessKeyId: accessKeyId,
|
secretAccessKey: secretAccessKey,
|
regionId: regionId || DEFAULT_REGION,
|
endpoint: baseApiEndpoint || DYBASEAPI_ENDPOINT
|
});
|
this.mnsVpc = mnsVpc || {
|
secure: false, // use https or http
|
internal: false, // use internal endpoint
|
vpc: false
|
};
|
this.expire = [];
|
this.mnsClient = [];
|
}
|
|
//群发短信
|
|
|
(0, _createClass3.default)(SMSClient, [{
|
key: 'sendBatchSMS',
|
value: function sendBatchSMS(params) {
|
var options = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
|
|
return this.dysmsapiClient.sendBatchSms(params, (0, _extends3.default)({ formatParams: false }, options));
|
}
|
|
//发送短信
|
|
}, {
|
key: 'sendSMS',
|
value: function sendSMS(params) {
|
var options = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
|
|
return this.dysmsapiClient.sendSms(params, options);
|
}
|
|
//查询详情
|
|
}, {
|
key: 'queryDetail',
|
value: function queryDetail(params) {
|
var options = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
|
|
return this.dysmsapiClient.querySendDetails(params, options);
|
}
|
|
//失效时间与当前系统时间比较，提前2分钟刷新token
|
|
}, {
|
key: '_refresh',
|
value: function _refresh(type) {
|
return this.expire[type] - new Date().getTime() > 2 * 60 * 1000;
|
}
|
|
//获取token
|
|
}, {
|
key: '_getToken',
|
value: function _getToken(type) {
|
var msgType = msgTypeList[type];
|
return this.dybaseClient.queryTokenForMnsQueue({ MessageType: msgType });
|
}
|
|
//根据类型获取mnsclient实例
|
|
}, {
|
key: '_getMNSClient',
|
value: function () {
|
var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(type) {
|
var _ref2, _ref2$MessageTokenDTO, SecurityToken, AccessKeyId, AccessKeySecret, mnsClient;
|
|
return _regenerator2.default.wrap(function _callee$(_context) {
|
while (1) {
|
switch (_context.prev = _context.next) {
|
case 0:
|
if (!(this.mnsClient && this.mnsClient[type] instanceof MNSClient && this._refresh(type))) {
|
_context.next = 2;
|
break;
|
}
|
|
return _context.abrupt('return', this.mnsClient[type]);
|
|
case 2:
|
_context.next = 4;
|
return this._getToken(type);
|
|
case 4:
|
_ref2 = _context.sent;
|
_ref2$MessageTokenDTO = _ref2.MessageTokenDTO;
|
SecurityToken = _ref2$MessageTokenDTO.SecurityToken;
|
AccessKeyId = _ref2$MessageTokenDTO.AccessKeyId;
|
AccessKeySecret = _ref2$MessageTokenDTO.AccessKeySecret;
|
|
if (AccessKeyId && AccessKeySecret && SecurityToken) {
|
_context.next = 11;
|
break;
|
}
|
|
throw new TypeError('get token fail');
|
|
case 11:
|
mnsClient = new MNSClient('1943695596114318', (0, _extends3.default)({
|
securityToken: SecurityToken,
|
region: DEFAULT_REGION,
|
accessKeyId: AccessKeyId,
|
accessKeySecret: AccessKeySecret,
|
// optional & default
|
secure: false, // use https or http
|
internal: false, // use internal endpoint
|
vpc: false }, this.mnsVpc));
|
|
this.mnsClient[type] = mnsClient;
|
this.expire[type] = new Date().getTime() + 10 * 60 * 1000;
|
return _context.abrupt('return', mnsClient);
|
|
case 15:
|
case 'end':
|
return _context.stop();
|
}
|
}
|
}, _callee, this);
|
}));
|
|
function _getMNSClient(_x4) {
|
return _ref.apply(this, arguments);
|
}
|
|
return _getMNSClient;
|
}()
|
|
//typeIndex :0 为回执,1为上行
|
|
}, {
|
key: 'receiveMsg',
|
value: function () {
|
var _ref3 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2() {
|
var typeIndex = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 0;
|
var preQueueName = arguments[1];
|
var waitSeconds = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : 10;
|
var isDel = arguments.length > 3 && arguments[3] !== undefined ? arguments[3] : false;
|
var queueName, mnsClient, res, code, ReceiptHandle;
|
return _regenerator2.default.wrap(function _callee2$(_context2) {
|
while (1) {
|
switch (_context2.prev = _context2.next) {
|
case 0:
|
queueName = preQueueName + msgTypeList[typeIndex];
|
_context2.next = 3;
|
return this._getMNSClient(typeIndex);
|
|
case 3:
|
mnsClient = _context2.sent;
|
_context2.next = 6;
|
return mnsClient.receiveMessage(queueName, waitSeconds);
|
|
case 6:
|
res = _context2.sent;
|
code = res.code, ReceiptHandle = res.body.ReceiptHandle;
|
|
if (!(isDel && code === 200 && ReceiptHandle)) {
|
_context2.next = 11;
|
break;
|
}
|
|
_context2.next = 11;
|
return mnsClient.deleteMessage(queueName, ReceiptHandle);
|
|
case 11:
|
return _context2.abrupt('return', res);
|
|
case 12:
|
case 'end':
|
return _context2.stop();
|
}
|
}
|
}, _callee2, this);
|
}));
|
|
function receiveMsg() {
|
return _ref3.apply(this, arguments);
|
}
|
|
return receiveMsg;
|
}()
|
}]);
|
return SMSClient;
|
}();
|
|
module.exports = SMSClient;
|
