Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
Z
zhichan
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
蒋勇
zhichan
Commits
56ea3fb2
Commit
56ea3fb2
authored
Jul 02, 2020
by
王昆
Browse files
Options
Browse Files
Download
Plain Diff
gsb
parents
bed102db
a2c948a6
Hide whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
517 additions
and
455 deletions
+517
-455
esign-api/app/base/api/impl/op/action.js
+6
-2
esign-api/app/base/api/impl/test/testApi.js
+9
-9
esign-api/app/base/service/impl/engine/enginesignSve.js
+119
-49
esign-api/app/base/service/svems.base.js
+244
-257
esign-api/app/base/system.js
+2
-3
esign-api/app/config/settings.js
+136
-135
esign-api/package-lock.json
+0
-0
esign-api/package.json
+1
-0
No files found.
esign-api/app/base/api/impl/op/action.js
View file @
56ea3fb2
...
...
@@ -7,6 +7,8 @@ class ActionAPI extends APIBase {
super
();
this
.
authSve
=
system
.
getObject
(
"service.sign.authSve"
);
this
.
merchantSve
=
system
.
getObject
(
"service.merchant.merchantSve"
);
// this.userSve = system.getObject("service.user.userSve");
this
.
enginsignSve
=
system
.
getObject
(
"service.engine.enginesignSve"
);
}
/**
* 接口跳转
...
...
@@ -67,6 +69,9 @@ class ActionAPI extends APIBase {
case
"autoSign"
:
// opResult = await this.userSve.info(action_body);
break
;
case
"test"
:
opResult
=
await
this
.
enginsignSve
.
autoSign
(
action_body
);
break
;
default
:
opResult
=
system
.
getResult
(
null
,
"action_type参数错误"
);
break
;
...
...
@@ -155,4 +160,4 @@ class ActionAPI extends APIBase {
];
}
}
module
.
exports
=
ActionAPI
;
\ No newline at end of file
module
.
exports
=
ActionAPI
;
esign-api/app/base/api/impl/test/testApi.js
View file @
56ea3fb2
var
APIBase
=
require
(
"../../api.base"
);
var
system
=
require
(
"../../../system"
);
class
TestAPI
extends
APIBase
{
constructor
()
{
super
();
this
.
enginesignSve
=
system
.
getObject
(
"service.engine.enginesignSve"
);
}
async
test
(
pobj
,
query
,
req
)
{
// var tmp = await this.orderSve.createLicense(pobj.action_body);
//获取验证码
// await this.platformUtils.fetchVCode(pobj.action_body.mobile);
//创建用户
// var result = await this.platformUtils.createUserInfo("13075556691", "13075556693", "9366");
//创建用户
return
{};
return
await
this
.
enginesignSve
.
createAccount
(
pobj
);
}
exam
()
{
return
""
;
}
classDesc
()
{
return
{
groupName
:
""
,
...
...
@@ -25,6 +24,7 @@ class TestAPI extends APIBase {
exam
:
""
,
};
}
methodDescs
()
{
return
[
{
...
...
@@ -44,4 +44,5 @@ class TestAPI extends APIBase {
];
}
}
module
.
exports
=
TestAPI
;
\ No newline at end of file
module
.
exports
=
TestAPI
;
esign-api/app/base/service/impl/engine/enginesignSve.js
View file @
56ea3fb2
const
system
=
require
(
"../../../system"
);
const
settings
=
require
(
"../../../../config/settings"
);
const
ServiceBase
=
require
(
"../../svems.base"
)
const
axios
=
require
(
"axios"
)
class
EngineSignService
extends
ServiceBase
{
constructor
()
{
super
();
// "createAccount": `${domain}/sign/account/create/person`,
// "createTemplate": `${domain}/sign/template/create`,
// "autoSign": `${domain}/sign/contract/autoSign`,
// "handSign": `${domain}/sign/contract/handSign`,
// "signCallBack": `${domain}/sign/contract${domain}/signCallBack`,
// "signQuery": `${domain}/sign/contract${domain}/signQuery`
this
.
API
=
settings
.
signApi
();
}
// 创建模板
async
createTemplate
(
params
)
{
try
{
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 创建账户
async
createAccount
(
params
)
{
try
{
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 手动签
async
handSign
(
params
)
{
try
{
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 静默签
async
autoSign
(
params
)
{
try
{
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 签约回调
async
signCallBack
(
params
)
{
try
{
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
constructor
()
{
super
();
// "createAccount": `${domain}/sign/account/create/person`,
// "createTemplate": `${domain}/sign/template/create`,
// "autoSign": `${domain}/sign/contract/autoSign`,
// "handSign": `${domain}/sign/contract/handSign`,
// "signCallBack": `${domain}/sign/contract${domain}/signCallBack`,
// "signQuery": `${domain}/sign/contract${domain}/signQuery`
this
.
API
=
settings
.
signApi
();
}
//二要素验证
async
TwoFactorVerification
(
params
)
{
try
{
return
await
this
.
callms
(
"engine_auth"
,
"TwoFactorVerification"
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
//三要素验证
async
ThreeFactorVerification
(
params
)
{
try
{
return
await
this
.
callms
(
"engine_auth"
,
"ThreeFactorVerification"
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
//四要素验证
async
FourFactorVerification
(
params
)
{
try
{
return
await
this
.
callms
(
"engine_auth"
,
"FourFactorVerification"
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 创建模板
async
createTemplate
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
createTemplate
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 创建个人账户
async
createAccount
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
createAccount
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 手动签
async
handSign
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
handSign
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 静默签
async
autoSign
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
autoSign
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 签约回调
async
signCallBack
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
signCallBack
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 签约查询
async
signQuery
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
signQuery
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 企业模板印章
async
signQuery
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
signQuery
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 企业图片印章
async
signQuery
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
signQuery
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
// 个人图片印章
async
signQuery
(
params
)
{
try
{
return
await
this
.
callApi
(
this
.
API
.
signQuery
,
params
);
}
catch
(
error
)
{
return
system
.
getResult
(
null
,
`系统错误 错误信息
${
error
}
`
);
}
}
}
module
.
exports
=
EngineSignService
;
\ No newline at end of file
module
.
exports
=
EngineSignService
;
esign-api/app/base/service/svems.base.js
View file @
56ea3fb2
...
...
@@ -6,291 +6,278 @@ const md5 = require("MD5");
const
axios
=
require
(
'axios'
);
class
ServiceBase
{
constructor
()
{
this
.
restClient
=
system
.
getObject
(
"util.restClient"
);
this
.
synlogDao
=
system
.
getObject
(
"db.log.synlogDao"
);
this
.
micro
=
system
.
microsetting
();
}
async
getEncryptStr
(
str
)
{
if
(
!
str
)
{
throw
new
Error
(
"字符串不能为空"
);
constructor
()
{
this
.
restClient
=
system
.
getObject
(
"util.restClient"
);
this
.
micro
=
system
.
microsetting
();
}
var
md5
=
this
.
md5
(
str
+
"_"
+
settings
.
salt
);
return
md5
.
toString
().
toLowerCase
();
}
/**
* 验证签名
* @param {*} params 要验证的参数
* @param {*} app_key 应用的校验key
*/
async
verifySign
(
params
,
app_key
)
{
if
(
!
params
)
{
return
system
.
getResult
(
null
,
"请求参数为空"
);
}
if
(
!
params
.
sign
)
{
return
system
.
getResult
(
null
,
"请求参数sign为空"
);
}
var
signArr
=
[];
var
keys
=
Object
.
keys
(
params
).
sort
();
if
(
keys
.
length
==
0
)
{
return
system
.
getResult
(
null
,
"请求参数信息为空"
);
}
for
(
let
k
=
0
;
k
<
keys
.
length
;
k
++
)
{
const
tKey
=
keys
[
k
];
if
(
tKey
!=
"sign"
&&
params
[
tKey
]
&&
!
(
params
[
tKey
]
instanceof
Array
))
{
signArr
.
push
(
tKey
+
"="
+
params
[
tKey
]);
}
}
if
(
signArr
.
length
==
0
)
{
return
system
.
getResult
(
null
,
"请求参数组装签名参数信息为空"
);
}
var
resultSignStr
=
signArr
.
join
(
"&"
)
+
"&key="
+
app_key
;
var
resultTmpSign
=
md5
(
resultSignStr
).
toUpperCase
();
if
(
params
.
sign
!=
resultTmpSign
)
{
return
system
.
getResult
(
null
,
"返回值签名验证失败"
);
}
return
system
.
getResultSuccess
();
}
/**
* 创建签名
* @param {*} params 要验证的参数
* @param {*} app_key 应用的校验key
*/
async
createSign
(
params
,
app_key
)
{
if
(
!
params
)
{
return
system
.
getResultFail
(
-
310
,
"请求参数为空"
);
}
var
signArr
=
[];
var
keys
=
Object
.
keys
(
params
).
sort
();
if
(
keys
.
length
==
0
)
{
return
system
.
getResultFail
(
-
330
,
"请求参数信息为空"
);
}
for
(
let
k
=
0
;
k
<
keys
.
length
;
k
++
)
{
const
tKey
=
keys
[
k
];
if
(
tKey
!=
"sign"
&&
params
[
tKey
]
&&
!
(
params
[
tKey
]
instanceof
Array
))
{
signArr
.
push
(
tKey
+
"="
+
params
[
tKey
]);
}
}
if
(
signArr
.
length
==
0
)
{
return
system
.
getResultFail
(
-
350
,
"请求参数组装签名参数信息为空"
);
}
var
resultSignStr
=
signArr
.
join
(
"&"
)
+
"&key="
+
app_key
;
var
resultTmpSign
=
md5
(
resultSignStr
).
toUpperCase
();
return
system
.
getResultSuccess
(
resultTmpSign
);
}
/**
* 验证参数信息不能为空
* @param {*} params 验证的参数
* @param {*} verifyParamsCount 需要验证参数的数量,如至少验证3个,则传入3
* @param {*} columnList 需要过滤掉的验证参数列表,格式:[]
*/
async
verifyParams
(
params
,
verifyParamsCount
,
columnList
)
{
if
(
!
params
)
{
return
system
.
getResult
(
null
,
"请求参数为空"
);
}
if
(
!
columnList
)
{
columnList
=
[];
async
getEncryptStr
(
str
)
{
if
(
!
str
)
{
throw
new
Error
(
"字符串不能为空"
);
}
var
md5
=
this
.
md5
(
str
+
"_"
+
settings
.
salt
);
return
md5
.
toString
().
toLowerCase
();
}
var
keys
=
Object
.
keys
(
params
);
if
(
keys
.
length
==
0
)
{
return
system
.
getResult
(
null
,
"请求参数信息为空"
);
/**
* 验证签名
* @param {*} params 要验证的参数
* @param {*} app_key 应用的校验key
*/
async
verifySign
(
params
,
app_key
)
{
if
(
!
params
)
{
return
system
.
getResult
(
null
,
"请求参数为空"
);
}
if
(
!
params
.
sign
)
{
return
system
.
getResult
(
null
,
"请求参数sign为空"
);
}
var
signArr
=
[];
var
keys
=
Object
.
keys
(
params
).
sort
();
if
(
keys
.
length
==
0
)
{
return
system
.
getResult
(
null
,
"请求参数信息为空"
);
}
for
(
let
k
=
0
;
k
<
keys
.
length
;
k
++
)
{
const
tKey
=
keys
[
k
];
if
(
tKey
!=
"sign"
&&
params
[
tKey
]
&&
!
(
params
[
tKey
]
instanceof
Array
))
{
signArr
.
push
(
tKey
+
"="
+
params
[
tKey
]);
}
}
if
(
signArr
.
length
==
0
)
{
return
system
.
getResult
(
null
,
"请求参数组装签名参数信息为空"
);
}
var
resultSignStr
=
signArr
.
join
(
"&"
)
+
"&key="
+
app_key
;
var
resultTmpSign
=
md5
(
resultSignStr
).
toUpperCase
();
if
(
params
.
sign
!=
resultTmpSign
)
{
return
system
.
getResult
(
null
,
"返回值签名验证失败"
);
}
return
system
.
getResultSuccess
();
}
if
(
keys
.
length
<
verifyParamsCount
)
{
return
system
.
getResult
(
null
,
"请求参数不完整"
);
/**
* 创建签名
* @param {*} params 要验证的参数
* @param {*} app_key 应用的校验key
*/
async
createSign
(
params
,
app_key
)
{
if
(
!
params
)
{
return
system
.
getResultFail
(
-
310
,
"请求参数为空"
);
}
var
signArr
=
[];
var
keys
=
Object
.
keys
(
params
).
sort
();
if
(
keys
.
length
==
0
)
{
return
system
.
getResultFail
(
-
330
,
"请求参数信息为空"
);
}
for
(
let
k
=
0
;
k
<
keys
.
length
;
k
++
)
{
const
tKey
=
keys
[
k
];
if
(
tKey
!=
"sign"
&&
params
[
tKey
]
&&
!
(
params
[
tKey
]
instanceof
Array
))
{
signArr
.
push
(
tKey
+
"="
+
params
[
tKey
]);
}
}
if
(
signArr
.
length
==
0
)
{
return
system
.
getResultFail
(
-
350
,
"请求参数组装签名参数信息为空"
);
}
var
resultSignStr
=
signArr
.
join
(
"&"
)
+
"&key="
+
app_key
;
var
resultTmpSign
=
md5
(
resultSignStr
).
toUpperCase
();
return
system
.
getResultSuccess
(
resultTmpSign
);
}
var
tResult
=
system
.
getResultSuccess
();
for
(
let
k
=
0
;
k
<
keys
.
length
;
k
++
)
{
const
tKeyValue
=
keys
[
k
];
if
(
columnList
.
length
==
0
||
columnList
.
indexOf
(
tKeyValue
)
<
0
)
{
if
(
!
tKeyValue
)
{
tResult
=
system
.
getResult
(
null
,
k
+
"参数不能为空"
);
break
;
/**
* 验证参数信息不能为空
* @param {*} params 验证的参数
* @param {*} verifyParamsCount 需要验证参数的数量,如至少验证3个,则传入3
* @param {*} columnList 需要过滤掉的验证参数列表,格式:[]
*/
async
verifyParams
(
params
,
verifyParamsCount
,
columnList
)
{
if
(
!
params
)
{
return
system
.
getResult
(
null
,
"请求参数为空"
);
}
}
//白名单为空或不在白名单中,则需要验证不能为空
if
(
!
columnList
)
{
columnList
=
[];
}
var
keys
=
Object
.
keys
(
params
);
if
(
keys
.
length
==
0
)
{
return
system
.
getResult
(
null
,
"请求参数信息为空"
);
}
if
(
keys
.
length
<
verifyParamsCount
)
{
return
system
.
getResult
(
null
,
"请求参数不完整"
);
}
var
tResult
=
system
.
getResultSuccess
();
for
(
let
k
=
0
;
k
<
keys
.
length
;
k
++
)
{
const
tKeyValue
=
keys
[
k
];
if
(
columnList
.
length
==
0
||
columnList
.
indexOf
(
tKeyValue
)
<
0
)
{
if
(
!
tKeyValue
)
{
tResult
=
system
.
getResult
(
null
,
k
+
"参数不能为空"
);
break
;
}
}
//白名单为空或不在白名单中,则需要验证不能为空
}
return
tResult
;
}
return
tResult
;
}
async
apiCallWithAk
(
url
,
params
)
{
var
acckapp
=
await
this
.
cacheManager
[
"ApiAccessKeyCache"
].
cache
(
settings
.
appKey
);
var
acck
=
acckapp
.
accessKey
;
//按照访问token
var
restResult
=
await
this
.
restClient
.
execPostWithAK
(
params
,
url
,
acck
);
if
(
restResult
)
{
if
(
restResult
.
status
==
0
)
{
var
resultRtn
=
restResult
.
data
;
return
resultRtn
;
}
else
{
await
this
.
cacheManager
[
"ApiAccessKeyCache"
].
invalidate
(
settings
.
appKey
);
async
apiCallWithAk
(
url
,
params
)
{
var
acckapp
=
await
this
.
cacheManager
[
"ApiAccessKeyCache"
].
cache
(
settings
.
appKey
);
var
acck
=
acckapp
.
accessKey
;
//按照访问token
var
restResult
=
await
this
.
restClient
.
execPostWithAK
(
params
,
url
,
acck
);
if
(
restResult
)
{
if
(
restResult
.
status
==
0
)
{
var
resultRtn
=
restResult
.
data
;
return
resultRtn
;
}
else
{
await
this
.
cacheManager
[
"ApiAccessKeyCache"
].
invalidate
(
settings
.
appKey
);
return
null
;
}
}
return
null
;
}
}
return
null
;
}
/*
返回20位业务订单号
prefix:业务前缀
*/
async
getBusUid
(
prefix
)
{
prefix
=
(
prefix
||
""
);
if
(
prefix
)
{
prefix
=
prefix
.
toUpperCase
();
}
var
prefixlength
=
prefix
.
length
;
var
subLen
=
8
-
prefixlength
;
var
uidStr
=
""
;
if
(
subLen
>
0
)
{
uidStr
=
await
this
.
getUidInfo
(
subLen
,
60
);
}
var
timStr
=
moment
().
format
(
"YYYYMMDDHHmm"
);
return
prefix
+
timStr
+
uidStr
;
}
/*
len:返回长度
radix:参与计算的长度,最大为62
*/
async
getUidInfo
(
len
,
radix
)
{
var
chars
=
'0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ'
.
split
(
''
);
//长度62,到yz长度为长36
var
uuid
=
[],
i
;
radix
=
radix
||
chars
.
length
;
if
(
len
)
{
for
(
i
=
0
;
i
<
len
;
i
++
)
uuid
[
i
]
=
chars
[
0
|
Math
.
random
()
*
radix
];
}
else
{
var
r
;
uuid
[
8
]
=
uuid
[
13
]
=
uuid
[
18
]
=
uuid
[
23
]
=
'-'
;
uuid
[
14
]
=
'4'
;
for
(
i
=
0
;
i
<
36
;
i
++
)
{
if
(
!
uuid
[
i
])
{
r
=
0
|
Math
.
random
()
*
16
;
uuid
[
i
]
=
chars
[(
i
==
19
)
?
(
r
&
0x3
)
|
0x8
:
r
];
/*
返回20位业务订单号
prefix:业务前缀
*/
async
getBusUid
(
prefix
)
{
prefix
=
(
prefix
||
""
);
if
(
prefix
)
{
prefix
=
prefix
.
toUpperCase
();
}
var
prefixlength
=
prefix
.
length
;
var
subLen
=
8
-
prefixlength
;
var
uidStr
=
""
;
if
(
subLen
>
0
)
{
uidStr
=
await
this
.
getUidInfo
(
subLen
,
60
);
}
}
var
timStr
=
moment
().
format
(
"YYYYMMDDHHmm"
);
return
prefix
+
timStr
+
uidStr
;
}
return
uuid
.
join
(
''
);
}
handleDate
(
row
,
fields
,
pattern
,
addHours
)
{
pattern
=
pattern
||
"YYYY-MM-DD HH:mm"
;
if
(
!
row
)
{
return
;
}
for
(
var
field
of
fields
)
{
if
(
row
[
field
])
{
if
(
addHours
)
{
row
[
field
]
=
moment
(
row
[
field
]).
add
(
addHours
,
"hours"
).
format
(
pattern
);
/*
len:返回长度
radix:参与计算的长度,最大为62
*/
async
getUidInfo
(
len
,
radix
)
{
var
chars
=
'0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ'
.
split
(
''
);
//长度62,到yz长度为长36
var
uuid
=
[],
i
;
radix
=
radix
||
chars
.
length
;
if
(
len
)
{
for
(
i
=
0
;
i
<
len
;
i
++
)
uuid
[
i
]
=
chars
[
0
|
Math
.
random
()
*
radix
];
}
else
{
row
[
field
]
=
moment
(
row
[
field
]).
format
(
pattern
);
var
r
;
uuid
[
8
]
=
uuid
[
13
]
=
uuid
[
18
]
=
uuid
[
23
]
=
'-'
;
uuid
[
14
]
=
'4'
;
for
(
i
=
0
;
i
<
36
;
i
++
)
{
if
(
!
uuid
[
i
])
{
r
=
0
|
Math
.
random
()
*
16
;
uuid
[
i
]
=
chars
[(
i
==
19
)
?
(
r
&
0x3
)
|
0x8
:
r
];
}
}
}
}
return
uuid
.
join
(
''
);
}
}
addWhereTime
(
where
,
field
,
begin
,
end
)
{
if
(
!
begin
&&
!
end
)
{
return
;
}
handleDate
(
row
,
fields
,
pattern
,
addHours
)
{
pattern
=
pattern
||
"YYYY-MM-DD HH:mm"
;
if
(
!
row
)
{
return
;
}
for
(
var
field
of
fields
)
{
if
(
row
[
field
])
{
if
(
addHours
)
{
row
[
field
]
=
moment
(
row
[
field
]).
add
(
addHours
,
"hours"
).
format
(
pattern
);
}
else
{
row
[
field
]
=
moment
(
row
[
field
]).
format
(
pattern
);
}
if
(
begin
&&
end
)
{
where
[
field
]
=
{
[
this
.
db
.
Op
.
between
]:
[
begin
,
end
]
};
}
else
if
(
begin
&&
!
end
)
{
where
[
field
]
=
{
[
this
.
db
.
Op
.
gte
]:
begin
};
}
else
if
(
!
begin
&&
end
)
{
where
[
field
]
=
{
[
this
.
db
.
Op
.
lte
]:
end
};
}
}
}
}
async
callms
(
sveName
,
apiName
,
params
)
{
var
reqUrl
=
this
.
micro
[
sveName
];
console
.
log
(
reqUrl
,
"-----------------------------"
);
addWhereTime
(
where
,
field
,
begin
,
end
)
{
if
(
!
begin
&&
!
end
)
{
return
;
}
if
(
!
reqUrl
)
{
return
system
.
getResult
(
null
,
"未找到【"
+
sveName
+
"】服务,请检查settings文件是否存在"
);
}
if
(
!
apiName
)
{
return
system
.
getResult
(
null
,
"apiName不能为空"
);
if
(
begin
&&
end
)
{
where
[
field
]
=
{
[
this
.
db
.
Op
.
between
]:
[
begin
,
end
]
};
}
else
if
(
begin
&&
!
end
)
{
where
[
field
]
=
{
[
this
.
db
.
Op
.
gte
]:
begin
};
}
else
if
(
!
begin
&&
end
)
{
where
[
field
]
=
{
[
this
.
db
.
Op
.
lte
]:
end
};
}
}
try
{
var
params
=
{
"action_process"
:
"esign-api"
,
"action_type"
:
apiName
,
"action_body"
:
params
||
{},
}
if
(
settings
.
env
==
'dev'
)
{
let
rs
=
await
axios
({
method
:
'post'
,
url
:
reqUrl
,
data
:
params
});
async
callms
(
sveName
,
apiName
,
params
)
{
var
reqUrl
=
this
.
micro
[
sveName
];
console
.
log
(
reqUrl
,
"-----------------------------"
);
console
.
log
(
rs
);
return
rs
.
data
;
}
var
rs
=
await
this
.
restClient
.
execPost
(
params
,
reqUrl
);
if
(
rs
&&
rs
.
stdout
)
{
return
JSON
.
parse
(
rs
.
stdout
);
}
return
system
.
getResult
(
null
,
rs
);
}
catch
(
error
)
{
console
.
log
(
error
);
this
.
logCtl
.
error
({
optitle
:
"微服务请求失败"
,
op
:
"sveName = "
+
sveName
+
"; apiName = "
+
apiName
,
content
:
"params = "
+
JSON
.
stringify
(
params
),
clientIp
:
""
});
return
system
.
getResult
(
null
,
error
.
message
);
}
}
if
(
!
reqUrl
)
{
return
system
.
getResult
(
null
,
"未找到【"
+
sveName
+
"】服务,请检查settings文件是否存在"
)
;
}
if
(
!
apiName
)
{
return
system
.
getResult
(
null
,
"apiName不能为空"
);
}
try
{
var
params
=
{
"action_process"
:
"esign-api"
,
"action_type"
:
apiName
,
"action_body"
:
params
||
{},
}
if
(
settings
.
env
==
'dev'
)
{
let
rs
=
await
axios
({
method
:
'post'
,
url
:
reqUrl
,
data
:
params
});
async
callApi
(
url
,
data
,
name
)
{
let
res
;
let
log
=
await
this
.
addSynLog
(
url
,
data
,
name
);
try
{
res
=
await
axios
({
method
:
'post'
,
url
:
url
,
data
:
data
});
if
(
log
)
{
log
.
apiRes
=
JSON
.
stringify
(
res
.
data
);
log
.
save
();
}
return
res
.
data
;
}
catch
(
e
)
{
console
.
log
(
e
);
console
.
log
(
rs
);
return
rs
.
data
;
}
var
rs
=
await
this
.
restClient
.
execPost
(
params
,
reqUrl
);
if
(
rs
&&
rs
.
stdout
)
{
return
JSON
.
parse
(
rs
.
stdout
);
}
return
system
.
getResult
(
null
,
rs
);
}
catch
(
error
)
{
console
.
log
(
error
);
this
.
logCtl
.
error
({
optitle
:
"微服务请求失败"
,
op
:
"sveName = "
+
sveName
+
"; apiName = "
+
apiName
,
content
:
"params = "
+
JSON
.
stringify
(
params
),
clientIp
:
""
});
return
system
.
getResult
(
null
,
error
.
message
);
}
}
return
res
.
data
;
}
async
addSynLog
(
url
,
data
,
name
)
{
try
{
return
await
this
.
synlogDao
.
create
({
apiUrl
:
url
,
apiName
:
name
,
apiReq
:
JSON
.
stringify
(
data
),
apiRes
:
""
,
});
}
catch
(
e
)
{
console
.
log
(
e
)
async
callApi
(
url
,
data
)
{
let
res
;
try
{
res
=
await
axios
({
method
:
'post'
,
url
:
url
,
data
:
data
});
console
.
log
(
res
)
return
res
.
data
;
}
catch
(
error
)
{
console
.
log
(
error
);
return
system
.
getResultFail
(
-
1
,
error
.
message
);
}
}
return
null
;
}
trim
(
o
)
{
if
(
!
o
)
{
return
""
;
trim
(
o
)
{
if
(
!
o
)
{
return
""
;
}
return
o
.
toString
().
trim
();
}
return
o
.
toString
().
trim
();
}
}
module
.
exports
=
ServiceBase
;
esign-api/app/base/system.js
View file @
56ea3fb2
...
...
@@ -178,7 +178,7 @@ class System {
// 认证引擎
engine_auth
:
local
+
":3573"
+
path
,
// 签约引擎
engine_sign
:
local
+
":3574"
+
path
,
engine_sign
:
dev
+
":3574"
+
path
,
// 用户服务
sve_uc
:
local
+
":3651"
+
path
,
...
...
@@ -230,4 +230,4 @@ System.appidFail = 1200;
System
.
signFail
=
1300
;
//获取访问token失败
System
.
getAppInfoFail
=
1130
;
module
.
exports
=
System
;
\ No newline at end of file
module
.
exports
=
System
;
esign-api/app/config/settings.js
View file @
56ea3fb2
var
path
=
require
(
'path'
);
var
ENVINPUT
=
{
DB_HOST
:
process
.
env
.
DB_HOST
,
DB_PORT
:
process
.
env
.
DB_PORT
,
DB_USER
:
process
.
env
.
DB_USER
,
DB_PWD
:
process
.
env
.
DB_PWD
,
REDIS_HOST
:
process
.
env
.
REDIS_HOST
,
REDIS_PORT
:
process
.
env
.
REDIS_PORT
,
REDIS_PWD
:
process
.
env
.
REDIS_PWD
,
DB_NAME
:
process
.
env
.
ESIGNAPI_DB_NAME
,
REDIS_DB
:
process
.
env
.
ESIGNAPI_REDIS_DB
,
APP_ENV
:
process
.
env
.
APP_ENV
?
process
.
env
.
APP_ENV
:
"dev"
DB_HOST
:
process
.
env
.
DB_HOST
,
DB_PORT
:
process
.
env
.
DB_PORT
,
DB_USER
:
process
.
env
.
DB_USER
,
DB_PWD
:
process
.
env
.
DB_PWD
,
REDIS_HOST
:
process
.
env
.
REDIS_HOST
,
REDIS_PORT
:
process
.
env
.
REDIS_PORT
,
REDIS_PWD
:
process
.
env
.
REDIS_PWD
,
DB_NAME
:
process
.
env
.
ESIGNAPI_DB_NAME
,
REDIS_DB
:
process
.
env
.
ESIGNAPI_REDIS_DB
,
APP_ENV
:
process
.
env
.
APP_ENV
?
process
.
env
.
APP_ENV
:
"dev"
};
var
settings
=
{
env
:
ENVINPUT
.
APP_ENV
,
appKey
:
"40d64e586551405c9bcafab87266bb04"
,
paasKey
:
"wx76a324c5d201d1a4"
,
secret
:
"f99d413b767f09b5dff0b3610366cc46"
,
salt
:
"%iatpD1gcxz7iF#B"
,
cacheprefix
:
"sjb"
,
usertimeout
:
3600
,
//单位秒
basepath
:
path
.
normalize
(
path
.
join
(
__dirname
,
'../..'
)),
port
:
process
.
env
.
NODE_PORT
||
3603
,
defaultPassWord
:
"987456"
,
paasUrl
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
return
"http://p.apps.com:3001/"
;
}
else
{
return
"http://www.telecredit.cn/"
;
}
},
reqEsAddr
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
"http://43.247.184.94:7200/"
;
//localsettings.reqEsDevUrl;
}
else
{
return
"http://43.247.184.94:7200/"
;
}
},
signApi
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
let
domain
=
"http://39.107.234.14:8026/"
;
return
{
// 创建个人账户
"createAccount"
:
`
${
domain
}
/sign/account/create/person`
,
// 创建模板
"createTemplate"
:
`
${
domain
}
/sign/template/create`
,
// 静默签
"autoSign"
:
`
${
domain
}
/sign/contract/autoSign`
,
// 手动签
"handSign"
:
`
${
domain
}
/sign/contract/handSign`
,
// 签约查询
"signQuery"
:
`
${
domain
}
/sign/contract
${
domain
}
/signQuery`
,
// 签约回调
"signCallBack"
:
`
${
domain
}
/sign/contract
${
domain
}
/signCallBack`
,
};
}
else
{
// return "http://43.247.184.94:7200/";
}
},
apiconfig
:
{
opLogUrl
:
function
()
{
return
settings
.
reqEsAddr
()
+
"bigdata_zc_op_log/_doc?pretty"
;
env
:
ENVINPUT
.
APP_ENV
,
appKey
:
"40d64e586551405c9bcafab87266bb04"
,
paasKey
:
"wx76a324c5d201d1a4"
,
secret
:
"f99d413b767f09b5dff0b3610366cc46"
,
salt
:
"%iatpD1gcxz7iF#B"
,
cacheprefix
:
"sjb"
,
usertimeout
:
3600
,
//单位秒
basepath
:
path
.
normalize
(
path
.
join
(
__dirname
,
'../..'
)),
port
:
process
.
env
.
NODE_PORT
||
3603
,
defaultPassWord
:
"987456"
,
paasUrl
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
return
"http://p.apps.com:3001/"
;
}
else
{
return
"http://www.telecredit.cn/"
;
}
},
opLogEsIsAdd
:
function
()
{
return
1
;
}
},
homePage
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
localsettings
.
reqHomePageDevUrl
;
}
else
{
return
"http://boss.gongsibao.com/"
;
}
},
redis
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
localsettings
.
redis
;
}
else
{
return
{
host
:
ENVINPUT
.
REDIS_HOST
,
port
:
ENVINPUT
.
REDIS_PORT
,
password
:
ENVINPUT
.
REDIS_PWD
,
db
:
ENVINPUT
.
REDIS_DB
,
};
}
},
database
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
localsettings
.
database
;
}
else
{
return
{
dbname
:
ENVINPUT
.
DB_NAME
,
user
:
ENVINPUT
.
DB_USER
,
password
:
ENVINPUT
.
DB_PWD
,
config
:
{
host
:
ENVINPUT
.
DB_HOST
,
dialect
:
'mysql'
,
operatorsAliases
:
false
,
pool
:
{
max
:
5
,
min
:
0
,
acquire
:
90000000
,
idle
:
1000000
},
debug
:
false
,
dialectOptions
:
{
requestTimeout
:
999999
,
// instanceName:'DEV'
}
//设置MSSQL超时时间
},
};
}
},
//阿里短信配置
aliSmsConfig
:
function
(){
return
{
accessKeyId
:
'LTAIurdHMmfgXJjr'
,
accessKeySecret
:
'OBP8jxN5ZTgZnEIFgXHkvBB0QEN4E2'
,
endpoint
:
'https://dysmsapi.aliyuncs.com'
,
apiVersion
:
'2017-05-25'
,
signName
:
"薪必果"
,
template
:{
loginTemplate
:{
order
:
"125944682"
,
code
:
"SMS_181196624"
},
authenticationTemplate
:{
order
:
"125949710"
,
code
:
"SMS_181201598"
reqEsAddr
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
"http://43.247.184.94:7200/"
;
//localsettings.reqEsDevUrl;
}
else
{
return
"http://43.247.184.94:7200/"
;
}
},
signApi
:
function
()
{
let
domain
=
''
;
if
(
this
.
env
==
"dev"
)
{
domain
=
"http://39.107.234.14:8026/bpo-sign"
;
}
else
{
domain
=
"http://39.107.234.14:8026/bpo-sign"
;
}
return
{
// 创建个人账户
"createAccount"
:
`
${
domain
}
/sign/account/create/person`
,
// 创建模板
"createTemplate"
:
`
${
domain
}
/sign/template/create`
,
// 静默签
"autoSign"
:
`
${
domain
}
/sign/contract/autoSign`
,
// 手动签
"handSign"
:
`
${
domain
}
/sign/contract/handSign`
,
// 签约查询
"signQuery"
:
`
${
domain
}
/sign/contract
${
domain
}
/signQuery`
,
// 签约回调
"signCallBack"
:
`
${
domain
}
/sign/contract
${
domain
}
/signCallBack`
,
};
},
apiconfig
:
{
opLogUrl
:
function
()
{
return
settings
.
reqEsAddr
()
+
"bigdata_zc_op_log/_doc?pretty"
;
},
smsTemplate
:{
order
:
"125939639"
,
code
:
"SMS_181191611"
opLogEsIsAdd
:
function
()
{
return
1
;
}
},
homePage
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
localsettings
.
reqHomePageDevUrl
;
}
else
{
return
"http://boss.gongsibao.com/"
;
}
},
redis
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
localsettings
.
redis
;
}
else
{
return
{
host
:
ENVINPUT
.
REDIS_HOST
,
port
:
ENVINPUT
.
REDIS_PORT
,
password
:
ENVINPUT
.
REDIS_PWD
,
db
:
ENVINPUT
.
REDIS_DB
,
};
}
},
database
:
function
()
{
if
(
this
.
env
==
"dev"
)
{
var
localsettings
=
require
(
"./localsettings"
);
return
localsettings
.
database
;
}
else
{
return
{
dbname
:
ENVINPUT
.
DB_NAME
,
user
:
ENVINPUT
.
DB_USER
,
password
:
ENVINPUT
.
DB_PWD
,
config
:
{
host
:
ENVINPUT
.
DB_HOST
,
dialect
:
'mysql'
,
operatorsAliases
:
false
,
pool
:
{
max
:
5
,
min
:
0
,
acquire
:
90000000
,
idle
:
1000000
},
debug
:
false
,
dialectOptions
:
{
requestTimeout
:
999999
,
// instanceName:'DEV'
}
//设置MSSQL超时时间
},
};
}
},
//阿里短信配置
aliSmsConfig
:
function
()
{
return
{
accessKeyId
:
'LTAIurdHMmfgXJjr'
,
accessKeySecret
:
'OBP8jxN5ZTgZnEIFgXHkvBB0QEN4E2'
,
endpoint
:
'https://dysmsapi.aliyuncs.com'
,
apiVersion
:
'2017-05-25'
,
signName
:
"薪必果"
,
template
:
{
loginTemplate
:
{
order
:
"125944682"
,
code
:
"SMS_181196624"
},
authenticationTemplate
:
{
order
:
"125949710"
,
code
:
"SMS_181201598"
},
smsTemplate
:
{
order
:
"125939639"
,
code
:
"SMS_181191611"
}
}
}
}
}
}
};
module
.
exports
=
settings
;
\ No newline at end of file
module
.
exports
=
settings
;
esign-api/package-lock.json
View file @
56ea3fb2
This source diff could not be displayed because it is too large. You can
view the blob
instead.
esign-api/package.json
View file @
56ea3fb2
...
...
@@ -13,6 +13,7 @@
"
MD5
"
:
"^1.3.0"
,
"
after
"
:
"^0.8.2"
,
"
ali-oss
"
:
"^4.12.2"
,
"
axios
"
:
"^0.19.2"
,
"
babel-polyfill
"
:
"^6.26.0"
,
"
base64id
"
:
"^1.0.0"
,
"
bluebird
"
:
"^3.5.1"
,
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment