github/cool-admin-midway-packages
1
0
Fork 0
mirror of https://github.com/cool-team-official/cool-admin-midway-packages.git synced 2025-12-11 13:52:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

短信支持亚马逊云

Browse Source
This commit is contained in:
cool 2023-12-05 19:54:37 +08:00
parent 12e6b9c50f
commit d15ae19f33
12 changed files with 395 additions and 270 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/package.json
View File

@ -1,6 +1,6 @@
{
"name": "@cool-midway/core",
"version": "7.0.2",
"version": "7.0.3",
"description": "",
"main": "dist/index.js",
"typings": "index.d.ts",

31
core/src/interface.ts
View File

@ -344,11 +344,34 @@ export interface CoolSmsConfig {
/**
* 腾讯云短信配置
*/
tx: CoolTxConfig;
tx: CoolSmsTxConfig;
/**
* 云片短信配置
*/
yp: CoolYpConfig;
yp: CoolSmsYpConfig;
/**
* aws短信配置
*/
aws: CoolSmsAwsConfig;
}
export interface CoolSmsAwsConfig {
/**
* 区域
*/
region: string;
/**
* accessKeyId
*/
accessKeyId: string;
/**
* secretAccessKey
*/
secretAccessKey: string;
/**
* 扩展配置
*/
extend?: any;
}
/**
@ -376,7 +399,7 @@ export interface CoolSmsAliConfig {
/**
* 腾讯云配置
*/
export interface CoolTxConfig {
export interface CoolSmsTxConfig {
/**
* 应用ID
*/
@ -402,7 +425,7 @@ export interface CoolTxConfig {
/**
* 云片短信配置
*/
export interface CoolYpConfig {
export interface CoolSmsYpConfig {
/**
* 云片apikey
*/

2
core/src/package.json
View File

@ -1,6 +1,6 @@
{
"name": "@cool-midway/core",
"version": "7.0.2",
"version": "7.0.3",
"description": "",
"main": "index.js",
"typings": "index.d.ts",

5
sms/package.json
View File

@ -1,6 +1,6 @@
{
"name": "@cool-midway/sms",
"version": "7.0.0",
"version": "7.0.1",
"description": "cool-js.com 短信",
"main": "dist/index.js",
"typings": "index.d.ts",
@ -35,15 +35,16 @@
"@midwayjs/mock": "^3.9.0",
"@types/jest": "^29.2.5",
"@types/node": "^18.11.18",
"axios": "^1.5.0",
"cross-env": "^7.0.3",
"jest": "^29.3.1",
"mwts": "^1.3.0",
"ts-jest": "^29.0.3",
"axios": "^1.5.0",
"typescript": "^4.9.4"
},
"dependencies": {
"@alicloud/pop-core": "^1.7.13",
"@aws-sdk/client-sns": "^3.465.0",
"tencentcloud-sdk-nodejs": "^4.0.607"
}
}

108
sms/src/ali.ts
View File

@ -1,5 +1,5 @@
import * as Core from '@alicloud/pop-core';
import { Config, Provide } from "@midwayjs/core";
import { Config, Provide } from '@midwayjs/core';
import { CoolSmsAliConfig } from './interface';
import { CoolCommException } from '@cool-midway/core';
@ -8,57 +8,61 @@ import { CoolCommException } from '@cool-midway/core';
*/
@Provide()
export class SmsAli {
@Config('cool.sms.ali')
config: CoolSmsAliConfig;
@Config('cool.sms.ali')
config: CoolSmsAliConfig;
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsAliConfig) {
this.config = config;
}
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsAliConfig) {
this.config = config;
}
/**
* 发送短信
* @param phone 手机号
* @param params 参数
* @param config signName 签名 template 模板
* @returns
*/
async send(phone, params: {
[key: string]: string;
}, config?: {
signName: string;
template: string;
}) {
const { accessKeyId, accessKeySecret } = this.config;
if (!accessKeyId || !accessKeyId) {
throw new CoolCommException('请配置阿里云短信');
}
if (!config) {
config = {
signName: this.config.signName,
template: this.config.template,
};
}
const client = new Core({
accessKeyId,
accessKeySecret,
endpoint: 'https://dysmsapi.aliyuncs.com',
// endpoint: 'https://cs.cn-hangzhou.aliyuncs.com',
apiVersion: '2017-05-25',
// apiVersion: '2018-04-18',
});
const data = {
RegionId: 'cn-shanghai',
PhoneNumbers: phone,
signName: config.signName,
templateCode: config.template,
TemplateParam: JSON.stringify(params),
};
return await client.request('SendSms', data, {
method: 'POST',
});
/**
* 发送短信
* @param phone 手机号
* @param params 参数
* @param config signName 签名 template 模板
* @returns
*/
async send(
phone,
params: {
[key: string]: string;
},
config?: {
signName: string;
template: string;
}
}
) {
const { accessKeyId, accessKeySecret } = this.config;
if (!accessKeyId || !accessKeyId) {
throw new CoolCommException('请配置阿里云短信');
}
if (!config) {
config = {
signName: this.config.signName,
template: this.config.template,
};
}
const client = new Core({
accessKeyId,
accessKeySecret,
endpoint: 'https://dysmsapi.aliyuncs.com',
// endpoint: 'https://cs.cn-hangzhou.aliyuncs.com',
apiVersion: '2017-05-25',
// apiVersion: '2018-04-18',
});
const data = {
RegionId: 'cn-shanghai',
PhoneNumbers: phone,
signName: config.signName,
templateCode: config.template,
TemplateParam: JSON.stringify(params),
};
return await client.request('SendSms', data, {
method: 'POST',
});
}
}

50
sms/src/aws.ts Normal file
View File

@ -0,0 +1,50 @@
import { Config, Provide } from '@midwayjs/core';
import { CoolSmsAwsConfig } from './interface';
import { CoolCommException } from '@cool-midway/core';
import { SNSClient, PublishCommand } from '@aws-sdk/client-sns';
/**
* 亚马逊云短信
*/
@Provide()
export class SmsAws {
@Config('cool.sms.aws')
config: CoolSmsAwsConfig;
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsAwsConfig) {
this.config = config;
}
/**
* 发送短信
* @param phone 手机号
* @param params 参数
* @returns
*/
async send(phone: string, content: string) {
const { region, accessKeyId, secretAccessKey, extend = {} } = this.config;
if (!region || !accessKeyId || !secretAccessKey) {
throw new CoolCommException('请配置AWS短信');
}
// 配置 AWS
const client = new SNSClient({
region, // 例如 'us-east-1'
credentials: {
accessKeyId,
secretAccessKey,
},
...extend,
});
const data = {
Message: content,
PhoneNumber: phone,
};
const result = await client.send(new PublishCommand(data));
return result;
}
}

1
sms/src/index.ts
View File

@ -5,5 +5,6 @@ export * from './interface';
export * from './ali';
export * from './yp';
export * from './tx';
export * from './aws';
export * from './sms';

31
sms/src/interface.ts
View File

@ -6,11 +6,34 @@ export interface CoolSmsConfig {
/**
* 腾讯云短信配置
*/
tx: CoolTxConfig;
tx: CoolSmsTxConfig;
/**
* 云片短信配置
*/
yp: CoolYpConfig;
yp: CoolSmsYpConfig;
/**
* aws短信配置
*/
aws: CoolSmsAwsConfig;
}
export interface CoolSmsAwsConfig {
/**
* 区域
*/
region: string;
/**
* accessKeyId
*/
accessKeyId: string;
/**
* secretAccessKey
*/
secretAccessKey: string;
/**
* 扩展配置
*/
extend?: any;
}
/**
@ -38,7 +61,7 @@ export interface CoolSmsAliConfig {
/**
* 腾讯云配置
*/
export interface CoolTxConfig {
export interface CoolSmsTxConfig {
/**
* 应用ID
*/
@ -64,7 +87,7 @@ export interface CoolTxConfig {
/**
* 云片短信配置
*/
export interface CoolYpConfig {
export interface CoolSmsYpConfig {
/**
* 云片apikey
*/

3
sms/src/package.json
View File

@ -1,6 +1,6 @@
{
"name": "@cool-midway/sms",
"version": "7.0.0",
"version": "7.0.1",
"description": "cool-js.com 短信",
"main": "index.js",
"typings": "index.d.ts",
@ -44,6 +44,7 @@
},
"dependencies": {
"@alicloud/pop-core": "^1.7.13",
"@aws-sdk/client-sns": "^3.465.0",
"tencentcloud-sdk-nodejs": "^4.0.607"
}
}

156
sms/src/sms.ts
View File

@ -1,83 +1,97 @@
import { Config, Inject, Provide } from "@midwayjs/core";
import { SmsYp } from "./yp";
import { SmsAli } from "./ali";
import { SmsTx } from "./tx";
import { CoolSmsConfig } from "./interface";
import { Config, Inject, Provide } from '@midwayjs/core';
import { SmsYp } from './yp';
import { SmsAli } from './ali';
import { SmsTx } from './tx';
import { CoolSmsConfig } from './interface';
import { SmsAws } from './aws';
@Provide()
export class CoolSms {
@Inject()
smsYp: SmsYp
@Inject()
smsYp: SmsYp;
@Inject()
smsAli: SmsAli
@Inject()
smsAli: SmsAli;
@Inject()
smsTx: SmsTx
@Inject()
smsTx: SmsTx;
@Config('cool.sms')
config: CoolSmsConfig;
@Inject()
smsAws: SmsAws;
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsConfig) {
this.smsYp.setConfig(config.yp);
this.smsAli.setConfig(config.ali);
this.smsTx.setConfig(config.tx);
this.config = config;
@Config('cool.sms')
config: CoolSmsConfig;
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsConfig) {
this.smsYp.setConfig(config.yp);
this.smsAli.setConfig(config.ali);
this.smsTx.setConfig(config.tx);
this.config = config;
}
/**
* 发送验证码 模板字段名为：code
* @param phone
* @param config
*/
async sendCode(
phone,
config?: {
signName: string;
template: string;
}
) {
const code = this.generateNumber();
let params = {
code,
};
await this.send(phone, this.config.tx ? [code] : params, config);
return code;
}
/**
* 发送验证码 模板字段名为：code
* @param phone
* @param config
*/
async sendCode(phone, config?: {
signName: string;
template: string;
}) {
const code = this.generateNumber();
let params = {
code
}
await this.send(phone, this.config.tx ? [code] : params, config)
return code;
/**
* 发送短信
* @param phone
* @param params
* @param config
* @returns
*/
async send(
phone: string,
params: any,
config?: {
signName: string;
template: string;
}
) {
if (this.config.ali) {
return await this.smsAli.send(phone, params, config);
}
if (this.config.tx) {
return await this.smsTx.send(phone, params, config);
}
if (this.config.yp) {
return await this.smsYp.send(phone, params, config);
}
if (this.config.aws) {
return await this.smsAws.send(phone, params);
}
return true;
}
/**
* 发送短信
* @param phone
* @param params
* @param config
* @returns
*/
async send(phone: string, params: any, config?: {
signName: string;
template: string;
}) {
if (this.config.ali) {
return await this.smsAli.send(phone, params, config);
}
if (this.config.tx) {
return await this.smsTx.send(phone, params, config);
}
if (this.config.yp) {
return await this.smsYp.send(phone, params, config);
}
return true;
/**
* 生成验证码
*/
generateNumber(digits = 4) {
if (digits <= 0) {
return 0;
}
/**
* 生成验证码
*/
generateNumber(digits = 4) {
if (digits <= 0) {
return 0;
}
const min = Math.pow(10, digits - 1);
const max = Math.pow(10, digits) - 1;
return Math.floor(Math.random() * (max - min + 1)) + min;
}
}
const min = Math.pow(10, digits - 1);
const max = Math.pow(10, digits) - 1;
return Math.floor(Math.random() * (max - min + 1)) + min;
}
}

126
sms/src/tx.ts
View File

@ -1,70 +1,74 @@
import { Config, Provide } from "@midwayjs/core";
import { CoolTxConfig } from './interface';
import * as tencentcloud from "tencentcloud-sdk-nodejs";
import { CoolCommException } from "@cool-midway/core";
import { Config, Provide } from '@midwayjs/core';
import { CoolSmsTxConfig } from './interface';
import * as tencentcloud from 'tencentcloud-sdk-nodejs';
import { CoolCommException } from '@cool-midway/core';
/**
* 腾讯云短信
*/
@Provide()
export class SmsTx {
@Config('cool.sms.tx')
config: CoolTxConfig;
@Config('cool.sms.tx')
config: CoolSmsTxConfig;
/**
* 配置
* @param config
*/
setConfig(config: CoolTxConfig) {
this.config = config;
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsTxConfig) {
this.config = config;
}
/**
* 发送短信
* @param phone 手机号
* @param params 参数
* @param config signName 签名 template 模板
* @returns
*/
async send(
phone: string,
params: string[],
config?: {
signName: string;
template: string;
}
/**
* 发送短信
* @param phone 手机号
* @param params 参数
* @param config signName 签名 template 模板
* @returns
*/
async send(phone: string, params: string[], config?: {
signName: string;
template: string;
}) {
const { appId, secretId, secretKey } = this.config;
if(!config) {
config = {
signName: this.config.signName,
template: this.config.template,
};
}
if(!appId || !secretId || !secretKey) {
throw new CoolCommException('请配置腾讯云短信');
}
const smsClient = tencentcloud.sms.v20210111.Client;
const client = new smsClient({
credential: {
secretId,
secretKey,
},
region: 'ap-guangzhou',
profile: {
signMethod: 'HmacSHA256',
httpProfile: {
reqMethod: 'POST',
reqTimeout: 30,
endpoint: 'sms.tencentcloudapi.com',
},
},
});
const data = {
SmsSdkAppId: appId,
SignName: config.signName,
TemplateId: config.template,
TemplateParamSet: params,
PhoneNumberSet: [`+86${phone}`],
};
return client.SendSms(data);
) {
const { appId, secretId, secretKey } = this.config;
if (!config) {
config = {
signName: this.config.signName,
template: this.config.template,
};
}
}
if (!appId || !secretId || !secretKey) {
throw new CoolCommException('请配置腾讯云短信');
}
const smsClient = tencentcloud.sms.v20210111.Client;
const client = new smsClient({
credential: {
secretId,
secretKey,
},
region: 'ap-guangzhou',
profile: {
signMethod: 'HmacSHA256',
httpProfile: {
reqMethod: 'POST',
reqTimeout: 30,
endpoint: 'sms.tencentcloudapi.com',
},
},
});
const data = {
SmsSdkAppId: appId,
SignName: config.signName,
TemplateId: config.template,
TemplateParamSet: params,
PhoneNumberSet: [`+86${phone}`],
};
return client.SendSms(data);
}
}

150
sms/src/yp.ts
View File

@ -1,6 +1,6 @@
import { Config, Provide } from "@midwayjs/core";
import { CoolYpConfig } from "./interface";
import { CoolCommException } from "@cool-midway/core";
import { Config, Provide } from '@midwayjs/core';
import { CoolSmsYpConfig } from './interface';
import { CoolCommException } from '@cool-midway/core';
import axios from 'axios';
/**
@ -8,79 +8,83 @@ import axios from 'axios';
*/
@Provide()
export class SmsYp {
@Config('cool.sms.yp')
config: CoolYpConfig;
@Config('cool.sms.yp')
config: CoolSmsYpConfig;
/**
* 配置
* @param config
*/
setConfig(config: CoolYpConfig) {
this.config = config;
/**
* 配置
* @param config
*/
setConfig(config: CoolSmsYpConfig) {
this.config = config;
}
/**
* 发送短信
* @param phones 手机号 数组，需要加国家码如 ["+8612345678901"]
* @param params 参数
* @param config signName 签名 template 模板
* @returns
*/
async send(
phones: string,
params: {
[key: string]: string;
},
config?: {
signName: string;
template: string;
}
) {
const { apikey } = this.config;
if (!config) {
config = {
signName: this.config.signName,
template: this.config.template,
};
}
if (!apikey) {
throw new CoolCommException('请配置云片短信');
}
/**
* 发送短信
* @param phones 手机号 数组，需要加国家码如 ["+8612345678901"]
* @param params 参数
* @param config signName 签名 template 模板
* @returns
*/
async send(phones: string, params: {
[key: string]: string;
}, config?: {
signName: string;
template: string;
}) {
const { apikey } = this.config;
if (!config) {
config = {
signName: this.config.signName,
template: this.config.template,
};
}
if (!apikey) {
throw new CoolCommException('请配置云片短信');
}
const headers = {
Accept: 'application/json;charset=utf-8',
'Content-Type': 'application/x-www-form-urlencoded;charset=utf-8',
};
const data = {
apikey: apikey,
mobile: phones,
tpl_id: config.template,
tpl_value: this.smsTplValue(params),
};
const result = await axios.post(
'https://sms.yunpian.com/v2/sms/tpl_single_send.json',
data,
{ headers }
);
if (result.data.code === 0) {
return true;
}
return false;
}
const headers = {
Accept: 'application/json;charset=utf-8',
'Content-Type': 'application/x-www-form-urlencoded;charset=utf-8',
};
const data = {
apikey: apikey,
mobile: phones,
tpl_id: config.template,
tpl_value: this.smsTplValue(params),
};
const result = await axios.post(
'https://sms.yunpian.com/v2/sms/tpl_single_send.json',
data,
{ headers }
);
if (result.data.code === 0) {
return true;
}
return false;
/**
* 获得短信模板值
* @param obj
* @returns
*/
protected smsTplValue(obj) {
const urlParams = [];
for (let key in obj) {
// eslint-disable-next-line no-prototype-builtins
if (obj.hasOwnProperty(key)) {
const encodedKey = encodeURIComponent(`#${key}#`);
const encodedValue = encodeURIComponent(obj[key]);
urlParams.push(`${encodedKey}=${encodedValue}`);
}
}
/**
* 获得短信模板值
* @param obj
* @returns
*/
protected smsTplValue(obj) {
const urlParams = [];
for (let key in obj) {
// eslint-disable-next-line no-prototype-builtins
if (obj.hasOwnProperty(key)) {
const encodedKey = encodeURIComponent(`#${key}#`);
const encodedValue = encodeURIComponent(obj[key]);
urlParams.push(`${encodedKey}=${encodedValue}`);
}
}
return urlParams.join('&');
}
}
return urlParams.join('&');
}
}