mirror of
https://gitee.com/durcframework/SOP.git
synced 2025-08-11 21:57:56 +08:00
4.0.2
This commit is contained in:
tanghc
125
sop-sdk/sdk-nodejs/common/Class.js
Normal file
125
sop-sdk/sdk-nodejs/common/Class.js
Normal file
@@ -0,0 +1,125 @@
|
||||
/**
|
||||
* 面相对象辅助类，可实现类的创建，继承，方法重写
|
||||
*
|
||||
<pre>
|
||||
//-------------------------
|
||||
// JS类的创建,继承
|
||||
//-------------------------
|
||||
|
||||
// 例子1:-------------------------
|
||||
// 创建一个父类
|
||||
var Person = Class.create({
|
||||
// 构造函数
|
||||
init:function(option){
|
||||
this.name = option.name;
|
||||
}
|
||||
,getName:function() {
|
||||
return this.name;
|
||||
}
|
||||
});
|
||||
|
||||
// 声明类实例
|
||||
var Jim = new Person({name:'Jim'});
|
||||
console.log('Jim name:' + Jim.getName())
|
||||
|
||||
//例子2:-------------------------
|
||||
|
||||
// 创建一个类,继承Person类，并重写getName
|
||||
var Man = Class.create({
|
||||
init:function(option) {
|
||||
this._super(option);// 调用父类构造函数
|
||||
this.age = option.age;
|
||||
}
|
||||
// 重写父类方法
|
||||
,getName:function() {
|
||||
// 调用父类的getName()
|
||||
var name = this._super();
|
||||
return '我重写了getName方法：{'+name+'}';
|
||||
}
|
||||
},Person);
|
||||
|
||||
var man = new Man({name:'Tom',age:22});
|
||||
console.log('man name:' + man.getName())
|
||||
|
||||
console.log('Jim instanceof Person: ' + (Jim instanceof Person));
|
||||
console.log('man instanceof Person: ' + (man instanceof Person));
|
||||
</pre>
|
||||
*
|
||||
*/
|
||||
exports.Class = (function () {
|
||||
// ------Class Creation------
|
||||
var initializing = false,
|
||||
fnTest = /xyz/.test(function () {
|
||||
xyz;
|
||||
}) ? /\b_super\b/ : /.*/;
|
||||
|
||||
// The base Class implementation (does nothing)
|
||||
this.Class = function () {
|
||||
};
|
||||
|
||||
// Create a new Class that inherits from this class
|
||||
Class.extend = function (prop) {
|
||||
var _super = this.prototype;
|
||||
|
||||
// Instantiate a base class (but only create the instance,
|
||||
// don't run the init constructor)
|
||||
initializing = true;
|
||||
var prototype = new this();
|
||||
initializing = false;
|
||||
|
||||
// Copy the properties over onto the new prototype
|
||||
for (var name in prop) {
|
||||
// Check if we're overwriting an existing function
|
||||
prototype[name] = typeof prop[name] == "function" && typeof _super[name] == "function" && fnTest.test(prop[name]) ? (function (name, fn) {
|
||||
return function () {
|
||||
var tmp = this._super;
|
||||
|
||||
// Add a new ._super() method that is the same method
|
||||
// but on the super-class
|
||||
this._super = _super[name];
|
||||
|
||||
// The method only need to be bound temporarily, so we
|
||||
// remove it when we're done executing
|
||||
var ret = fn.apply(this, arguments);
|
||||
this._super = tmp;
|
||||
|
||||
return ret;
|
||||
};
|
||||
})(name, prop[name]) : prop[name];
|
||||
}
|
||||
|
||||
// The dummy class constructor
|
||||
function Class() {
|
||||
// All construction is actually done in the init method
|
||||
if (!initializing && this.init) this.init.apply(this, arguments);
|
||||
}
|
||||
|
||||
// Populate our constructed prototype object
|
||||
Class.prototype = prototype;
|
||||
|
||||
// Enforce the constructor to be what we expect
|
||||
Class.prototype.constructor = Class;
|
||||
|
||||
// And make this class extendable
|
||||
Class.extend = arguments.callee;
|
||||
|
||||
return Class;
|
||||
};// ------Class Creation end------
|
||||
|
||||
|
||||
|
||||
return {
|
||||
/**
|
||||
* 创建一个类
|
||||
* @param option 类方法,json数据
|
||||
* @param parentClass 父类
|
||||
*/
|
||||
create: function (option, parentClass) {
|
||||
if (!parentClass) {
|
||||
parentClass = Class;
|
||||
}
|
||||
return parentClass.extend(option);
|
||||
}
|
||||
};
|
||||
|
||||
})();
|
||||
151
sop-sdk/sdk-nodejs/common/OpenClient.js
Normal file
151
sop-sdk/sdk-nodejs/common/OpenClient.js
Normal file
@@ -0,0 +1,151 @@
|
||||
const needle = require('needle')
|
||||
const moment = require('moment')
|
||||
|
||||
const {Class} = require("./Class");
|
||||
const {RequestType} = require('./RequestType')
|
||||
const {SignUtil} = require('./SignUtil')
|
||||
const {BaseRequest} = require('../request/BaseRequest')
|
||||
|
||||
const HEADERS = {'Accept-Encoding': 'identity'}
|
||||
|
||||
const getHeaders = function (headers) {
|
||||
if (!headers) {
|
||||
return HEADERS
|
||||
}
|
||||
for (const key in HEADERS) {
|
||||
headers[key] = HEADERS[key];
|
||||
}
|
||||
return headers
|
||||
}
|
||||
|
||||
const OpenClient = Class.create({
|
||||
/**
|
||||
* 初始化客户端
|
||||
* @param appId 应用ID
|
||||
* @param privateKey 应用私钥，2048位，PKCS8
|
||||
* @param url 请求url
|
||||
*/
|
||||
init: function (appId, privateKey, url) {
|
||||
this.appId = appId;
|
||||
this.privateKey = privateKey;
|
||||
this.url = url;
|
||||
},
|
||||
/**
|
||||
* 发送请求
|
||||
* @param request 请求类
|
||||
* @param callback 回调函数，参数json
|
||||
*/
|
||||
execute: function (request, callback) {
|
||||
this.executeToken(request, null, callback)
|
||||
},
|
||||
/**
|
||||
* 发送请求
|
||||
* @param request 请求类
|
||||
* @param token token
|
||||
* @param callback 回调函数，参数json
|
||||
*/
|
||||
executeToken: function (request, token, callback) {
|
||||
if (!(request instanceof BaseRequest)) {
|
||||
throw 'request类未继承BaseRequest'
|
||||
}
|
||||
const requestType = request.getRequestType();
|
||||
if (request.files) {
|
||||
this._postFile(request, callback);
|
||||
} else {
|
||||
switch (requestType) {
|
||||
case RequestType.GET:
|
||||
this._get(request, callback);
|
||||
break
|
||||
case RequestType.POST_FORM:
|
||||
this._postForm(request, callback);
|
||||
break
|
||||
case RequestType.POST_JSON:
|
||||
this._postJson(request, callback);
|
||||
break
|
||||
case RequestType.POST_FILE:
|
||||
this._postFile(request, callback);
|
||||
break
|
||||
default :{
|
||||
throw 'request.getRequestType()类型不正确'
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
_get: function(request, callback) {
|
||||
const allParams = this._buildParams(request)
|
||||
const that = this
|
||||
// needle.request(method, url, data[, options][, callback])
|
||||
needle.request('GET',this.url, allParams, {
|
||||
headers: getHeaders()
|
||||
}, function(error, response) {
|
||||
callback(that._parseResponse(error, response, request))
|
||||
});
|
||||
},
|
||||
_postForm: function (request, callback) {
|
||||
const allParams = this._buildParams(request)
|
||||
const that = this
|
||||
needle.request('POST',this.url, allParams, {
|
||||
headers: getHeaders({
|
||||
'Content-Type': 'application/x-www-form-urlencoded'
|
||||
})
|
||||
}, function(error, response) {
|
||||
callback(that._parseResponse(error, response, request))
|
||||
});
|
||||
},
|
||||
_postJson: function (request, callback) {
|
||||
const allParams = this._buildParams(request)
|
||||
const that = this
|
||||
needle.request('POST',this.url, allParams, {
|
||||
headers: getHeaders(), json: true
|
||||
}, function(error, response) {
|
||||
callback(that._parseResponse(error, response, request))
|
||||
});
|
||||
},
|
||||
_postFile: function (request, callback) {
|
||||
const allParams = this._buildParams(request)
|
||||
const files = request.files;
|
||||
files.forEach(row => {
|
||||
// 设置成{ file: row.path, content_type: 'application/octet-stream' }格式
|
||||
// needle会认为是上传文件
|
||||
allParams[row.name] = { file: row.path, content_type: 'application/octet-stream' }
|
||||
})
|
||||
const that = this
|
||||
needle.request('POST',this.url, allParams, {
|
||||
headers: getHeaders(), multipart: true
|
||||
}, function(error, response) {
|
||||
callback(that._parseResponse(error, response, request))
|
||||
});
|
||||
},
|
||||
_parseResponse: function (error, response, request) {
|
||||
if (!error && response.statusCode === 200) {
|
||||
return request.parseResponse(response.body)
|
||||
} else {
|
||||
throw '请求异常：' + error
|
||||
}
|
||||
},
|
||||
_buildParams: function (request, token) {
|
||||
const allParams = {
|
||||
'app_id': this.appId,
|
||||
'method': request.getMethod(),
|
||||
'charset': 'UTF-8',
|
||||
'sign_type': 'RSA2',
|
||||
'timestamp': moment().format('YYYY-MM-DD HH:mm:ss'),
|
||||
'version': request.getVersion()
|
||||
}
|
||||
const bizModel = request.bizModel
|
||||
|
||||
for (const key in bizModel) {
|
||||
allParams[key] = bizModel[key]
|
||||
}
|
||||
|
||||
if (token) {
|
||||
allParams['app_auth_token'] = token
|
||||
}
|
||||
// 创建签名
|
||||
const sign = SignUtil.createSign(allParams, this.privateKey, 'RSA2')
|
||||
allParams.sign = sign
|
||||
return allParams;
|
||||
}
|
||||
})
|
||||
|
||||
module.exports = OpenClient
|
||||
6
sop-sdk/sdk-nodejs/common/RequestType.js
Normal file
6
sop-sdk/sdk-nodejs/common/RequestType.js
Normal file
@@ -0,0 +1,6 @@
|
||||
exports.RequestType = {
|
||||
GET: 'GET',
|
||||
POST_FORM: 'POST_FORM',
|
||||
POST_JSON: 'POST_JSON',
|
||||
POST_FILE: 'POST_FILE'
|
||||
}
|
||||
88
sop-sdk/sdk-nodejs/common/SignUtil.js
Normal file
88
sop-sdk/sdk-nodejs/common/SignUtil.js
Normal file
@@ -0,0 +1,88 @@
|
||||
const {KJUR, hextob64} = require('jsrsasign')
|
||||
|
||||
const HashMap = {
|
||||
SHA256withRSA: 'SHA256withRSA',
|
||||
SHA1withRSA: 'SHA1withRSA'
|
||||
}
|
||||
|
||||
const PEM_BEGIN = '-----BEGIN PRIVATE KEY-----\n'
|
||||
const PEM_END = '\n-----END PRIVATE KEY-----'
|
||||
|
||||
/**
|
||||
* rsa签名参考：https://www.jianshu.com/p/145eab95322c
|
||||
*/
|
||||
exports.SignUtil = {
|
||||
/**
|
||||
* 创建签名
|
||||
* @param params 请求参数
|
||||
* @param privateKey 私钥，PKCS8
|
||||
* @param signType 签名类型，RSA,RSA2
|
||||
* @returns 返回签名内容
|
||||
*/
|
||||
createSign(params, privateKey, signType) {
|
||||
const content = this.getSignContent(params)
|
||||
return this.sign(content, privateKey, signType)
|
||||
},
|
||||
sign: function (content, privateKey, signType) {
|
||||
if (signType.toUpperCase() === 'RSA') {
|
||||
return this.rsaSign(content, privateKey, HashMap.SHA1withRSA)
|
||||
} else if (signType.toUpperCase() === 'RSA2') {
|
||||
return this.rsaSign(content, privateKey, HashMap.SHA256withRSA)
|
||||
} else {
|
||||
throw 'signType错误'
|
||||
}
|
||||
},
|
||||
/**
|
||||
* rsa签名
|
||||
* @param content 签名内容
|
||||
* @param privateKey 私钥
|
||||
* @param hash hash算法，SHA256withRSA，SHA1withRSA
|
||||
* @returns 返回签名字符串，base64
|
||||
*/
|
||||
rsaSign: function (content, privateKey, hash) {
|
||||
privateKey = this._formatKey(privateKey)
|
||||
// 创建 Signature 对象
|
||||
const signature = new KJUR.crypto.Signature({
|
||||
alg: hash,
|
||||
//!这里指定 私钥 pem!
|
||||
prvkeypem: privateKey
|
||||
})
|
||||
signature.updateString(content)
|
||||
const signData = signature.sign()
|
||||
// 将内容转成base64
|
||||
return hextob64(signData)
|
||||
},
|
||||
_formatKey: function (key) {
|
||||
if (!key.startsWith(PEM_BEGIN)) {
|
||||
key = PEM_BEGIN + key
|
||||
}
|
||||
if (!key.endsWith(PEM_END)) {
|
||||
key = key + PEM_END
|
||||
}
|
||||
return key
|
||||
},
|
||||
/**
|
||||
* 获取签名内容
|
||||
* @param params 请求参数
|
||||
* @returns {string}
|
||||
*/
|
||||
getSignContent: function (params) {
|
||||
const paramNames = []
|
||||
for(const key in params) {
|
||||
paramNames.push(key)
|
||||
}
|
||||
|
||||
paramNames.sort()
|
||||
|
||||
const paramNameValue = []
|
||||
|
||||
for (let i = 0, len = paramNames.length; i < len; i++) {
|
||||
const paramName = paramNames[i];
|
||||
const val = params[paramName];
|
||||
if (paramName && val) {
|
||||
paramNameValue.push(`${paramName}=${val}`)
|
||||
}
|
||||
}
|
||||
return paramNameValue.join('&')
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user