From 1c7a417a7e6a09585c3d6ff0d036a052c785f12d Mon Sep 17 00:00:00 2001 From: flxxyz Date: Thu, 15 Jul 2021 12:08:07 +0800 Subject: [PATCH] =?UTF-8?q?(optimize):=20=E4=BB=A3=E7=A0=81=E7=B2=BE?= =?UTF-8?q?=E7=AE=80,=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lib/index.js | 2 +- package.json | 5 +- src/index.js | 162 +++++++++++++++++++++++++++++++-------------------- 3 files changed, 103 insertions(+), 66 deletions(-) diff --git a/lib/index.js b/lib/index.js index 5fdd54b..0021db2 100644 --- a/lib/index.js +++ b/lib/index.js @@ -1 +1 @@ -"use strict";Object.defineProperty(exports,"__esModule",{value:!0});var crypto=require("crypto"),fetch=require("node-fetch");function _interopDefaultLegacy(e){return e&&"object"==typeof e&&"default"in e?e:{default:e}}var fetch__default=_interopDefaultLegacy(fetch);class TTPay{API_URL="https://developer.toutiao.com/api/apps/ecpay/v1";constructor(e){if(!e.appId)throw Error("config.appId is required");if(!e.appSecret)throw Error("config.appSecret is required");if(!e.SALT)throw Error("config.SALT is required");e.notifyURL,this.config=Object.assign({TOKEN:""},e)}_genSign(e){const t=["app_id","thirdparty_id","sign"],r=[];for(var i in e)-1==t.indexOf(i)&&r.push(e[i]);return r.push(this.config.SALT),crypto.createHash("md5").update(r.sort().join("&")).digest("hex")}async _request(e,t={}){if(!e)throw Error("method is not found");t={method:"POST",body:JSON.stringify(t),headers:{"Content-Type":"application/json","User-Agent":"flxxyz/bytedance-mini-pay"}};return fetch__default.default(`${this.API_URL}${e}`,t).then(e=>e.json())}async createOrder(e,t,r,i,n={}){n.valid_time||(n.valid_time=1800);const o={app_id:this.config.appId,out_order_no:e,total_amount:t,subject:r,body:i,...n};this.config.notifyURL||(o.notify_url=this.config.notifyURL);n={...o,sign:this._genSign({...o})};return this._request("/create_order",n)}async queryOrder(e,t={}){t={app_id:this.config.appId,out_order_no:e,...t},t={...t,sign:this._genSign({...t})};return this._request("/query_order",t)}async createRefund(e,t,r,i,n={}){const o={app_id:this.config.appId,out_order_no:e,out_refund_no:t,refund_amount:r,reason:i,...n};this.config.notifyURL&&(o.notify_url=this.config.notifyURL);n={...o,sign:this._genSign({...o})};return this._request("/create_refund",n)}async queryRefund(e,t={}){t={app_id:this.config.appId,out_refund_no:e,...t},t={...t,sign:this._genSign({...t})};return this._request("/query_refund",t)}checkNotifySign(e={}){const{msg_signature:t,timestamp:r,msg:i="",nonce:n}=e;e=[this.config.TOKEN,r,n,i].sort().join();return t===crypto.createHash("sha1").update(e).digest("hex")}ackNotify=(e=()=>{})=>e('{"err_no":0,"err_tips":"success"}')}exports.TTPay=TTPay; +"use strict";Object.defineProperty(exports,"__esModule",{value:!0});var crypto=require("crypto"),fetch=require("node-fetch");function _interopDefaultLegacy(e){return e&&"object"==typeof e&&"default"in e?e:{default:e}}var fetch__default=_interopDefaultLegacy(fetch);class TTPay{API_URL="https://developer.toutiao.com/api/apps/ecpay/v1";skipArr=["app_id","thirdparty_id","sign"];config={appId:"",appSecret:"",mchId:"",SALT:"",TOKEN:"",notifyURL:""};constructor(e){if(!e.appId)throw Error("config.appId is required");if(!e.appSecret)throw Error("config.appSecret is required");if(!e.SALT)throw Error("config.SALT is required");this.config={TOKEN:"",...e}}_genSign(e){const r=[];for(var t in e)-1==this.skipArr.indexOf(t)&&r.push(e[t]);return r.push(this.config.SALT),crypto.createHash("md5").update(r.sort().join("&")).digest("hex")}async _request(e,r={}){if(!e)throw Error("uri is not found");return fetch__default.default(`${this.API_URL}${e}`,{method:"POST",body:JSON.stringify(r),headers:{"Content-Type":"application/json","User-Agent":"flxxyz/bytedance-mini-pay"}}).then(e=>e.json())}_genParams(e,r={}){const t={app_id:this.config.appId,...r};return"create"===e&&(r.notifyURL||this.config.notifyURL)&&(t.notify_url=this.config.notifyURL),{...t,sign:this._genSign({...t})}}createOrder(e,r,t,i,n={}){n.valid_time||(n.valid_time=1800);n=this._genParams("create",{out_order_no:e,total_amount:r,subject:t,body:i,...n});return this._request("/create_order",n)}queryOrder(e,r={}){r=this._genParams("query",{out_order_no:e,...r});return this._request("/query_order",r)}createRefund(e,r,t,i,n={}){n=this._genParams("create",{out_order_no:e,out_refund_no:r,refund_amount:t,reason:i,...n});return this._request("/create_refund",n)}queryRefund(e,r={}){r=this._genParams("create",{out_refund_no:e,...r});return this._request("/query_refund",r)}checkNotifySign(e={}){const{msg_signature:r,timestamp:t,msg:i="",nonce:n}=e;e=[this.config.TOKEN,t,n,i].sort().join("");return r===crypto.createHash("sha1").update(e).digest("hex")}ackNotify=(e=()=>{})=>e('{"err_no":0,"err_tips":"success"}')}exports.default=TTPay; diff --git a/package.json b/package.json index ef1d374..d788f7f 100644 --- a/package.json +++ b/package.json @@ -1,10 +1,11 @@ { "name": "bytedance-mini-pay", - "version": "0.0.1", + "version": "0.0.2", "description": "字节跳动小程序支付SDK", "main": "lib/index.js", "scripts": { - "build": "rollup -c ./rollup.config.js" + "build": "rollup -c ./rollup.config.js", + "build:min": "NODE_ENV=production npm run build" }, "repository": { "type": "git", diff --git a/src/index.js b/src/index.js index 4c7f3fd..2530ee1 100644 --- a/src/index.js +++ b/src/index.js @@ -1,19 +1,44 @@ import { createHash } from 'crypto'; import fetch from 'node-fetch'; -export class TTPay { +/** + * TTPay + * @constructor + * @class + * @public + */ +class TTPay { API_URL = 'https://developer.toutiao.com/api/apps/ecpay/v1'; + skipArr = ['app_id', 'thirdparty_id', 'sign']; + + /** + * @property {object} config + * @property {string} config.appId 字节小程序AppId + * @property {string} config.appSecret 字节小程序秘钥 + * @property {string} config.[mchId] 商户号 + * @property {string} config.TOKEN 担保交易的令牌 + * @property {string} config.SALT 担保交易的SALT + * @property {string} config.[notifyURL] 支付回调URL + */ + config = { + appId: '', + appSecret: '', + mchId: '', + SALT: '', + TOKEN: '', + notifyURL: '', + }; + constructor(config) { if (!config.appId) { throw Error('config.appId is required'); } if (!config.appSecret) { throw Error('config.appSecret is required'); } if (!config.SALT) { throw Error('config.SALT is required'); } - if (!config.notifyURL) { } - - this.config = Object.assign({ + this.config = { TOKEN: '', - }, config); + ...config, + }; } /** @@ -23,10 +48,9 @@ export class TTPay { * @returns {string} 签名 */ _genSign(params) { - const skipArr = ['app_id', 'thirdparty_id', 'sign']; const unsignArr = []; for (let key in params) { - if (skipArr.indexOf(key) != -1) { + if (this.skipArr.indexOf(key) != -1) { continue; } unsignArr.push(params[key]); @@ -37,26 +61,68 @@ export class TTPay { .digest('hex'); } - /** * @summary 发送请求 * @method _request * @param {string} uri 请求链接 * @param {object} body 请求体 - * @returns {Promise} 响应结果 + * @returns {Promise} 响应结果 */ async _request(uri, body = {}) { - if (!uri) { throw Error('method is not found'); } + if (!uri) { throw Error('uri is not found'); } - const opts = { + return await fetch(`${this.API_URL}${uri}`, { method: 'POST', body: JSON.stringify(body), headers: { 'Content-Type': 'application/json', 'User-Agent': 'flxxyz/bytedance-mini-pay', }, + }).then(r => r.json()); + } + + /** + * @summary 通用 create 函数 + * @method _genParams + * @param {string} action 操作 create, query + * @param {object} options 额外请求参数 + * @param {string} options.out_order_no 商户内部订单号 + * @param {number} options.amount 下单金额(单位: 分) + * @param {string} options.subject 商品描述 + * @param {string} options.body 商品详细 + * @param {number} options.valid_time 过期时间 默认1800s(单位: 秒); 最小 15 分钟，最大两天 + * @param {string} options.cp_extra 开发者自定义字段，回调原样回传 + * @param {string} options.notify_url 商户自定义回调地址 + * @param {string} options.thirdparty_id 服务商模式接入必传，第三方平台服务商 id，非服务商模式留空 + * @param {string} options.disable_msg 是否屏蔽担保支付的推送消息，1-屏蔽 0-非屏蔽，接入 POI 必传 + * @param {string} options.msg_page 担保支付消息跳转页 + * @param {string} options.store_uid 多门店模式下必传，多门店模式下，门店 uid + * @param {string} options.all_settle 是否为分账后退款，1-分账后退款；0-分账前退款。分账后退款会扣减可提现金额，请保证余额充足 + * @param {string} options.out_refund_no 商户分配的退款号 + * @param {number} options.amount 退款金额(单位: 分) + * @param {string} options.reason 退款理由，长度上限 100 + * @returns {object} 包含签名的所有参数 + */ + _genParams(action, options = {}) { + const basicParams = { + app_id: this.config.appId, + ...options, + }; + + if (action === 'create') { + if (options.notifyURL) { + basicParams.notify_url = this.config.notifyURL; + } else { + if (this.config.notifyURL) { + basicParams.notify_url = this.config.notifyURL; + } + } + } + + return { + ...basicParams, + sign: this._genSign({ ...basicParams }), }; - return await fetch(`${this.API_URL}${uri}`, opts).then(r => r.json()); } /** @@ -74,30 +140,20 @@ export class TTPay { * @param {string} options.disable_msg 是否屏蔽担保支付的推送消息，1-屏蔽 0-非屏蔽，接入 POI 必传 * @param {string} options.msg_page 担保支付消息跳转页 * @param {string} options.store_uid 多门店模式下必传，多门店模式下，门店 uid - * @returns {Promise} - + * @returns {Promise} 响应结果 */ - async createOrder(out_order_no, amount, subject, body, options = {}) { + createOrder(out_order_no, amount, subject, body, options = {}) { if (!options.valid_time) { options.valid_time = 1800; } - const basicParams = { - app_id: this.config.appId, + const params = this._genParams('create', { out_order_no, total_amount: amount, subject, body, ...options, - }; - - if (!this.config.notifyURL) { - basicParams.notify_url = this.config.notifyURL; - } - - const params = { - ...basicParams, - sign: this._genSign({ ...basicParams }), - }; + }); return this._request('/create_order', params); } @@ -108,19 +164,13 @@ export class TTPay { * @param {string} out_order_no 商户内部订单号 * @param {object} options 额外请求参数 * @param {string} options.thirdparty_id 服务商模式接入必传，第三方平台服务商 id，非服务商模式留空 - * @returns {Promise} - + * @returns {Promise} 响应结果 */ - async queryOrder(out_order_no, options = {}) { - const basicParams = { - app_id: this.config.appId, + queryOrder(out_order_no, options = {}) { + const params = this._genParams('query', { out_order_no, ...options, - }; - - const params = { - ...basicParams, - sign: this._genSign({ ...basicParams }), - }; + }); return this._request('/query_order', params); } @@ -139,26 +189,16 @@ export class TTPay { * @param {string} options.disable_msg 是否屏蔽担保支付的推送消息，1-屏蔽 * @param {string} options.msg_page 担保支付消息跳转页 * @param {string} options.all_settle 是否为分账后退款，1-分账后退款；0-分账前退款。分账后退款会扣减可提现金额，请保证余额充足 - * @returns {Promise} - + * @returns {Promise} 响应结果 */ - async createRefund(out_order_no, out_refund_no, amount, reason, options = {}) { - const basicParams = { - app_id: this.config.appId, + createRefund(out_order_no, out_refund_no, amount, reason, options = {}) { + const params = this._genParams('create', { out_order_no, out_refund_no, refund_amount: amount, reason, ...options, - }; - - if (this.config.notifyURL) { - basicParams.notify_url = this.config.notifyURL; - } - - const params = { - ...basicParams, - sign: this._genSign({ ...basicParams }), - }; + }); return this._request('/create_refund', params); } @@ -169,19 +209,13 @@ export class TTPay { * @param {string} out_refund_no 商户分配的退款号 * @param {object} options 额外请求参数 * @param {string} options.thirdparty_id 服务商模式接入必传，第三方平台服务商 id，非服务商模式留空 - * @returns {Promise} - + * @returns {Promise} 响应结果 */ - async queryRefund(out_refund_no, options = {}) { - const basicParams = { - app_id: this.config.appId, + queryRefund(out_refund_no, options = {}) { + const params = this._genParams('create', { out_refund_no, ...options, - }; - - const params = { - ...basicParams, - sign: this._genSign({ ...basicParams }), - }; + }); return this._request('/query_refund', params); } @@ -190,11 +224,11 @@ export class TTPay { * @summary 检查请求签名 * @method checkNotifySign * @param {object} body 请求体 - * @returns {boolean} - + * @returns {boolean} 验证请求来源正确 */ checkNotifySign(body = {}) { const { msg_signature, timestamp, msg = '', nonce } = body; - const str = [this.config.TOKEN, timestamp, nonce, msg].sort().join(); + const str = [this.config.TOKEN, timestamp, nonce, msg].sort().join(''); const _signature = createHash('sha1').update(str).digest('hex'); return msg_signature === _signature; } @@ -203,7 +237,9 @@ export class TTPay { * @summary 回调响应结果 * @method ackNotify * @param {Function} fn 回调处理函数 - * @returns - + * @returns 收到回调且处理成功 */ ackNotify = (fn = () => { }) => fn('{"err_no":0,"err_tips":"success"}'); } + +export default TTPay;