记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
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
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
18ab9372
Commit
18ab9372
authored
Nov 09, 2021
by
anjiabin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
提交unionpay代码
parent
4bb7fbf3
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
167 additions
and
5 deletions
+167
-5
liquidnet-service-dragon.yml
...-bus-config/liquidnet-config/liquidnet-service-dragon.yml
+1
-1
TestAcpService.java
...est/java/com/liquidnet/service/scpsdk/TestAcpService.java
+166
-4
No files found.
liquidnet-bus-config/liquidnet-config/liquidnet-service-dragon.yml
View file @
18ab9372
...
@@ -178,7 +178,7 @@ acpsdk:
...
@@ -178,7 +178,7 @@ acpsdk:
version
:
5.1.0
version
:
5.1.0
# 签名方式,证书方式固定01,请勿改动
# 签名方式,证书方式固定01,请勿改动
signMethod
:
01
signMethod
:
'
01'
# 是否验证验签证书的CN,测试环境请设置false,生产环境请设置true。非false的值默认都当true处理。
# 是否验证验签证书的CN,测试环境请设置false,生产环境请设置true。非false的值默认都当true处理。
ifValidateCNName
:
false
ifValidateCNName
:
false
...
...
liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/test/java/com/liquidnet/service/scpsdk/TestAcpService.java
View file @
18ab9372
...
@@ -42,11 +42,12 @@ public class TestAcpService {
...
@@ -42,11 +42,12 @@ public class TestAcpService {
public
void
testAppTrans
()
public
void
testAppTrans
()
throws
ServletException
,
IOException
{
throws
ServletException
,
IOException
{
String
merId
=
"821690048160PQY"
;
// String merId = "821690048160PQY";
String
txnAmt
=
"1"
;
String
merId
=
"777290058194736"
;
String
txnAmt
=
"100"
;
String
orderId
=
IDGenerator
.
payCode
();
String
orderId
=
IDGenerator
.
payCode
();
//设置订单过期时间
//设置订单过期时间
String
txnTime
=
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMddHHmmss
);
String
txnTime
=
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMddHHmmss
Trim
);
Map
<
String
,
String
>
contentData
=
new
HashMap
<
String
,
String
>();
Map
<
String
,
String
>
contentData
=
new
HashMap
<
String
,
String
>();
...
@@ -102,9 +103,12 @@ public class TestAcpService {
...
@@ -102,9 +103,12 @@ public class TestAcpService {
//成功,获取tn号
//成功,获取tn号
//String tn = resmap.get("tn");
//String tn = resmap.get("tn");
//TODO
//TODO
log
.
info
(
"成功返回结果 :{}"
);
}
else
{
}
else
{
//其他应答码为失败请排查原因或做失败处理
//其他应答码为失败请排查原因或做失败处理
//TODO
//TODO
String
respMsg
=
rspData
.
get
(
"respMsg"
)
;
log
.
info
(
"失败返回结果 respMsg:{}"
,
respMsg
);
}
}
}
else
{
}
else
{
log
.
error
(
"验证签名失败"
);
log
.
error
(
"验证签名失败"
);
...
@@ -116,6 +120,164 @@ public class TestAcpService {
...
@@ -116,6 +120,164 @@ public class TestAcpService {
}
}
String
reqMessage
=
DemoBase
.
genHtmlResult
(
reqData
);
String
reqMessage
=
DemoBase
.
genHtmlResult
(
reqData
);
String
rspMessage
=
DemoBase
.
genHtmlResult
(
rspData
);
String
rspMessage
=
DemoBase
.
genHtmlResult
(
rspData
);
log
.
info
(
"请求报文:<br/>"
+
reqMessage
+
"<br/>"
+
"应答报文:</br>"
+
rspMessage
+
""
);
log
.
info
(
"请求报文:<br/>"
+
reqMessage
+
"<br/>"
);
log
.
info
(
"应答报文:</br>"
+
rspMessage
+
""
);
}
@Test
public
void
testSingleQuery
()
throws
ServletException
,
IOException
{
// String merId = "821690048160PQY";
String
merId
=
"777290058194736"
;
String
orderId
=
"PAY202111091417193102493371"
;
String
txnTime
=
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMddHHmmssTrim
);
Map
<
String
,
String
>
data
=
new
HashMap
<
String
,
String
>();
/***银联全渠道系统,产品参数,除了encoding自行选择外其他不需修改***/
data
.
put
(
"version"
,
sdkConfig
.
getVersion
());
//版本号
data
.
put
(
"encoding"
,
DemoBase
.
encoding
);
//字符集编码 可以使用UTF-8,GBK两种方式
data
.
put
(
"signMethod"
,
sdkConfig
.
getSignMethod
());
//签名方法
data
.
put
(
"txnType"
,
"00"
);
//交易类型 00-默认
data
.
put
(
"txnSubType"
,
"00"
);
//交易子类型 默认00
data
.
put
(
"bizType"
,
"000201"
);
//业务类型
/***商户接入参数***/
data
.
put
(
"merId"
,
merId
);
//商户号码,请改成自己申请的商户号或者open上注册得来的777商户号测试
data
.
put
(
"accessType"
,
"0"
);
//接入类型,商户接入固定填0,不需修改
/***要调通交易以下字段必须修改***/
data
.
put
(
"orderId"
,
orderId
);
//****商户订单号,每次发交易测试需修改为被查询的交易的订单号
data
.
put
(
"txnTime"
,
txnTime
);
//****订单发送时间,每次发交易测试需修改为被查询的交易的订单发送时间
/**请求参数设置完毕,以下对请求参数进行签名并发送http post请求,接收同步应答报文------------->**/
Map
<
String
,
String
>
reqData
=
acpService
.
sign
(
data
,
DemoBase
.
encoding
);
//报文中certId,signature的值是在signData方法中获取并自动赋值的,只要证书配置正确即可。
String
url
=
sdkConfig
.
getSingleQueryUrl
();
//交易请求url从配置文件读取对应属性文件acp_sdk.properties中的 acpsdk.singleQueryUrl
Map
<
String
,
String
>
rspData
=
acpService
.
post
(
reqData
,
url
,
DemoBase
.
encoding
);
//发送请求报文并接受同步应答(默认连接超时时间30秒,读取返回结果超时时间30秒);这里调用signData之后,调用submitUrl之前不能对submitFromData中的键值对做任何修改,如果修改会导致验签不通过
/**对应答码的处理,请根据您的业务逻辑来编写程序,以下应答码处理逻辑仅供参考------------->**/
//应答码规范参考open.unionpay.com帮助中心 下载 产品接口规范 《平台接入接口规范-第5部分-附录》
if
(!
rspData
.
isEmpty
()){
if
(
acpService
.
validate
(
rspData
,
DemoBase
.
encoding
)){
log
.
info
(
"验证签名成功"
);
if
((
"00"
).
equals
(
rspData
.
get
(
"respCode"
))){
//如果查询交易成功
String
origRespCode
=
rspData
.
get
(
"origRespCode"
);
if
((
"00"
).
equals
(
origRespCode
)){
//交易成功,更新商户订单状态
//TODO
}
else
if
((
"03"
).
equals
(
origRespCode
)||
(
"04"
).
equals
(
origRespCode
)||
(
"05"
).
equals
(
origRespCode
)){
//订单处理中或交易状态未明,需稍后发起交易状态查询交易 【如果最终尚未确定交易是否成功请以对账文件为准】
//TODO
}
else
{
//其他应答码为交易失败
//TODO
}
}
else
if
((
"34"
).
equals
(
rspData
.
get
(
"respCode"
))){
//订单不存在,可认为交易状态未明,需要稍后发起交易状态查询,或依据对账结果为准
}
else
{
//查询交易本身失败,如应答码10/11检查查询报文是否正确
//TODO
}
}
else
{
log
.
error
(
"验证签名失败"
);
//TODO 检查验证签名失败的原因
}
}
else
{
//未返回正确的http状态
log
.
error
(
"未获取到返回报文或返回http状态码非200"
);
}
String
reqMessage
=
DemoBase
.
genHtmlResult
(
reqData
);
String
rspMessage
=
DemoBase
.
genHtmlResult
(
rspData
);
log
.
info
(
"请求报文:<br/>"
+
reqMessage
+
"<br/>"
);
log
.
info
(
"应答报文:</br>"
+
rspMessage
+
""
);
}
@Test
public
void
testRefund
()
throws
ServletException
,
IOException
{
// String merId = "821690048160PQY";
String
merId
=
"777290058194736"
;
String
orderId
=
"PAY202111091417193102493371"
;
String
txnTime
=
DateUtil
.
format
(
LocalDateTime
.
now
(),
DateUtil
.
Formatter
.
yyyyMMddHHmmssTrim
);
String
txnAmt
=
"100"
;
String
origQryId
=
"892111091417195454008"
;
Map
<
String
,
String
>
data
=
new
HashMap
<
String
,
String
>();
/***银联全渠道系统,产品参数,除了encoding自行选择外其他不需修改***/
data
.
put
(
"version"
,
sdkConfig
.
getVersion
());
//版本号
data
.
put
(
"encoding"
,
DemoBase
.
encoding
);
//字符集编码 可以使用UTF-8,GBK两种方式
data
.
put
(
"signMethod"
,
sdkConfig
.
getSignMethod
());
//签名方法
data
.
put
(
"txnType"
,
"04"
);
//交易类型 04-退货
data
.
put
(
"txnSubType"
,
"00"
);
//交易子类型 默认00
data
.
put
(
"bizType"
,
"000201"
);
//业务类型
data
.
put
(
"channelType"
,
"08"
);
//渠道类型,07-PC,08-手机
/***商户接入参数***/
data
.
put
(
"merId"
,
merId
);
//商户号码,请改成自己申请的商户号或者open上注册得来的777商户号测试
data
.
put
(
"accessType"
,
"0"
);
//接入类型,商户接入固定填0,不需修改
data
.
put
(
"orderId"
,
orderId
);
//商户订单号,8-40位数字字母,不能含“-”或“_”,可以自行定制规则,重新产生,不同于原消费
data
.
put
(
"txnTime"
,
txnTime
);
//订单发送时间,格式为yyyyMMddHHmmss,必须取当前时间,否则会报txnTime无效
data
.
put
(
"currencyCode"
,
"156"
);
//交易币种(境内商户一般是156 人民币)
data
.
put
(
"txnAmt"
,
txnAmt
);
//****退货金额,单位分,不要带小数点。退货金额小于等于原消费金额,当小于的时候可以多次退货至退货累计金额等于原消费金额
data
.
put
(
"backUrl"
,
sdkConfig
.
getBackUrl
());
//后台通知地址,后台通知参数详见open.unionpay.com帮助中心 下载 产品接口规范 网关支付产品接口规范 退货交易 商户通知,其他说明同消费交易的后台通知
/***要调通交易以下字段必须修改***/
data
.
put
(
"origQryId"
,
origQryId
);
//****原消费交易返回的的queryId,可以从消费交易后台通知接口中或者交易状态查询接口中获取
// 请求方保留域,
// 透传字段,查询、通知、对账文件中均会原样出现,如有需要请启用并修改自己希望透传的数据。
// 出现部分特殊字符时可能影响解析,请按下面建议的方式填写:
// 1. 如果能确定内容不会出现&={}[]"'等符号时,可以直接填写数据,建议的方法如下。
// data.put("reqReserved", "透传信息1|透传信息2|透传信息3");
// 2. 内容可能出现&={}[]"'符号时:
// 1) 如果需要对账文件里能显示,可将字符替换成全角&={}【】“‘字符(自己写代码,此处不演示);
// 2) 如果对账文件没有显示要求,可做一下base64(如下)。
// 注意控制数据长度,实际传输的数据长度不能超过1024位。
// 查询、通知等接口解析时使用new String(Base64.decodeBase64(reqReserved), DemoBase.encoding);解base64后再对数据做后续解析。
// data.put("reqReserved", Base64.encodeBase64String("任意格式的信息都可以".toString().getBytes(DemoBase.encoding)));
/**请求参数设置完毕,以下对请求参数进行签名并发送http post请求,接收同步应答报文------------->**/
Map
<
String
,
String
>
reqData
=
acpService
.
sign
(
data
,
DemoBase
.
encoding
);
//报文中certId,signature的值是在signData方法中获取并自动赋值的,只要证书配置正确即可。
String
url
=
sdkConfig
.
getBackTransUrl
();
//交易请求url从配置文件读取对应属性文件acp_sdk.properties中的 acpsdk.backTransUrl
Map
<
String
,
String
>
rspData
=
acpService
.
post
(
reqData
,
url
,
DemoBase
.
encoding
);
//这里调用signData之后,调用submitUrl之前不能对submitFromData中的键值对做任何修改,如果修改会导致验签不通过
/**对应答码的处理,请根据您的业务逻辑来编写程序,以下应答码处理逻辑仅供参考------------->**/
//应答码规范参考open.unionpay.com帮助中心 下载 产品接口规范 《平台接入接口规范-第5部分-附录》
if
(!
rspData
.
isEmpty
()){
if
(
acpService
.
validate
(
rspData
,
DemoBase
.
encoding
)){
log
.
info
(
"验证签名成功"
);
String
respCode
=
rspData
.
get
(
"respCode"
)
;
if
((
"00"
).
equals
(
respCode
)){
//交易已受理(不代表交易已成功),等待接收后台通知更新订单状态,也可以主动发起 查询交易确定交易状态。
//TODO
}
else
if
((
"03"
).
equals
(
respCode
)||
(
"04"
).
equals
(
respCode
)||
(
"05"
).
equals
(
respCode
)){
//后续需发起交易状态查询交易确定交易状态
//TODO
}
else
{
//其他应答码为失败请排查原因
//TODO
}
}
else
{
log
.
error
(
"验证签名失败"
);
//TODO 检查验证签名失败的原因
}
}
else
{
//未返回正确的http状态
log
.
error
(
"未获取到返回报文或返回http状态码非200"
);
}
String
reqMessage
=
DemoBase
.
genHtmlResult
(
reqData
);
String
rspMessage
=
DemoBase
.
genHtmlResult
(
rspData
);
log
.
info
(
"请求报文:<br/>"
+
reqMessage
+
"<br/>"
);
log
.
info
(
"应答报文:</br>"
+
rspMessage
+
""
);
}
}
}
}
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