记得上下班打卡 | 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
d2543871
Commit
d2543871
authored
Jul 01, 2022
by
anjiabin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
实现xuper发行购买功能
parent
a088097d
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
56 additions
and
27 deletions
+56
-27
Xuper013HistoryRespDto.java
...uidnet/common/third/xuper/dto/Xuper013HistoryRespDto.java
+21
-0
XuperSdkUtil.java
...a/com/liquidnet/common/third/xuper/util/XuperSdkUtil.java
+9
-3
TestXuperSdkUtil.java
...liquidnet/service/goblin/test/xuper/TestXuperSdkUtil.java
+26
-24
No files found.
liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-xuper/src/main/java/com/liquidnet/common/third/xuper/dto/Xuper013HistoryRespDto.java
View file @
d2543871
...
@@ -2,6 +2,8 @@ package com.liquidnet.common.third.xuper.dto;
...
@@ -2,6 +2,8 @@ package com.liquidnet.common.third.xuper.dto;
import
lombok.Data
;
import
lombok.Data
;
import
java.util.ArrayList
;
/**
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @version V1.0
...
@@ -13,6 +15,25 @@ import lombok.Data;
...
@@ -13,6 +15,25 @@ import lombok.Data;
*/
*/
@Data
@Data
public
class
Xuper013HistoryRespDto
{
public
class
Xuper013HistoryRespDto
{
public
long
requestId
;
public
int
errNo
;
public
String
errMsg
;
public
ArrayList
<
AssetInfo
>
list
;
public
int
totalCnt
;
@Data
public
static
class
AssetInfo
{
public
long
assetId
;
public
long
type
;
public
long
shardId
;
public
long
price
;
public
String
txId
;
public
String
from
;
public
String
to
;
public
long
ctime
;
}
private
static
final
Xuper013HistoryRespDto
obj
=
new
Xuper013HistoryRespDto
();
private
static
final
Xuper013HistoryRespDto
obj
=
new
Xuper013HistoryRespDto
();
public
static
Xuper013HistoryRespDto
getNew
()
{
public
static
Xuper013HistoryRespDto
getNew
()
{
try
{
try
{
...
...
liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-xuper/src/main/java/com/liquidnet/common/third/xuper/util/XuperSdkUtil.java
View file @
d2543871
...
@@ -520,9 +520,9 @@ public class XuperSdkUtil {
...
@@ -520,9 +520,9 @@ public class XuperSdkUtil {
Xuper014FreezeAssetRespDto
respDto
=
Xuper014FreezeAssetRespDto
.
getNew
();
Xuper014FreezeAssetRespDto
respDto
=
Xuper014FreezeAssetRespDto
.
getNew
();
try
{
try
{
//创建资产区块链账户
//创建资产区块链账户
Account
account
=
null
;
Account
account
=
this
.
getAccount
(
reqDto
.
getMnemonic
());
;
//资产id
//资产id
long
assetId
=
123
;
long
assetId
=
reqDto
.
getAssetId
()
;
BaseDef
.
Resp
<
BaseDef
.
BaseResp
>
baseResp
=
getAsset
().
freezeAsset
(
assetId
,
account
);
BaseDef
.
Resp
<
BaseDef
.
BaseResp
>
baseResp
=
getAsset
().
freezeAsset
(
assetId
,
account
);
log
.
info
(
"xuper014FreezeAsset resp : "
+
JsonUtils
.
toJson
(
baseResp
));
log
.
info
(
"xuper014FreezeAsset resp : "
+
JsonUtils
.
toJson
(
baseResp
));
BaseDef
.
RequestRes
requestRes
=
baseResp
.
res
;
BaseDef
.
RequestRes
requestRes
=
baseResp
.
res
;
...
@@ -547,7 +547,13 @@ public class XuperSdkUtil {
...
@@ -547,7 +547,13 @@ public class XuperSdkUtil {
try
{
try
{
//资产id
//资产id
long
assetId
=
123
;
long
assetId
=
123
;
BaseDef
.
Resp
<
XassetDef
.
GetEvidenceInfoResp
>
evidenceInfoResp
=
getAsset
().
getEvidenceInfo
(
assetId
);
BaseDef
.
Resp
<
XassetDef
.
GetEvidenceInfoResp
>
baseResp
=
getAsset
().
getEvidenceInfo
(
assetId
);
log
.
info
(
"xuper015GetEvidenceInfo resp : "
+
JsonUtils
.
toJson
(
baseResp
));
BaseDef
.
RequestRes
requestRes
=
baseResp
.
res
;
if
(
requestRes
.
httpCode
==
200
){
log
.
info
(
"xuper015GetEvidenceInfo apiResp : "
+
JsonUtils
.
toJson
(
baseResp
.
apiResp
));
respDto
=
JsonUtils
.
fromJson
(
JsonUtils
.
toJson
(
baseResp
.
apiResp
),
new
TypeReference
<
Xuper015GetEvidenceInfoRespDto
>(){});
}
}
catch
(
Exception
e
){
}
catch
(
Exception
e
){
log
.
error
(
e
.
getMessage
(),
e
);
log
.
error
(
e
.
getMessage
(),
e
);
throw
new
XupterException
(
XuperErrorEnum
.
SERVER_INNER_ERROR
.
getCode
(),
XuperErrorEnum
.
SERVER_INNER_ERROR
.
getMsg
());
throw
new
XupterException
(
XuperErrorEnum
.
SERVER_INNER_ERROR
.
getCode
(),
XuperErrorEnum
.
SERVER_INNER_ERROR
.
getMsg
());
...
...
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/test/java/com/liquidnet/service/goblin/test/xuper/TestXuperSdkUtil.java
View file @
d2543871
...
@@ -548,47 +548,49 @@ public class TestXuperSdkUtil {
...
@@ -548,47 +548,49 @@ public class TestXuperSdkUtil {
log
.
info
(
"testXuper013History resp : "
+
JsonUtils
.
toJson
(
respDto
));
log
.
info
(
"testXuper013History resp : "
+
JsonUtils
.
toJson
(
respDto
));
}
}
/**
* 资产冻结操作-谨慎使用
*/
@Test
@Test
public
void
testXuper014FreezeAsset
(){
public
void
testXuper014FreezeAsset
(){
Xuper014FreezeAssetReqDto
reqDto
=
Xuper014FreezeAssetReqDto
.
getNew
();
//
Xuper014FreezeAssetReqDto reqDto = Xuper014FreezeAssetReqDto.getNew();
// 定义返回结果对象
//
// 定义返回结果对象
Xuper014FreezeAssetRespDto
respDto
=
null
;
//
Xuper014FreezeAssetRespDto respDto = null;
long
assetId
=
171095615845019437
l
;
//
long assetId = 171095615845019437l;
// long assetId = 1532351545249738541l;
//
//
long assetId = 1532351545249738541l;
try
{
//
try {
reqDto
.
setMnemonic
(
creatorMnemonic
);
//
reqDto.setMnemonic(creatorMnemonic);
reqDto
.
setAssetId
(
assetId
);
//
reqDto.setAssetId(assetId);
XuperResponseDto
<
Xuper014FreezeAssetRespDto
>
xuperResponseDto
=
xuperSdkUtil
.
xuper014FreezeAsset
(
reqDto
);
//
XuperResponseDto<Xuper014FreezeAssetRespDto> xuperResponseDto = xuperSdkUtil.xuper014FreezeAsset(reqDto);
if
(
xuperResponseDto
.
isSuccess
()){
//
if(xuperResponseDto.isSuccess()){
respDto
=
xuperResponseDto
.
getParseData
(
Xuper014FreezeAssetRespDto
.
class
);
//
respDto = xuperResponseDto.getParseData(Xuper014FreezeAssetRespDto.class);
}
//
}
}
catch
(
XupterException
e
)
{
//
}catch (XupterException e) {
log
.
error
(
"biz error msg "
+
e
.
getMessage
(),
e
);
//
log.error("biz error msg "+e.getMessage(),e);
}
catch
(
Exception
e
)
{
//
}catch (Exception e) {
log
.
error
(
"sys error msg "
+
e
.
getMessage
(),
e
);
//
log.error("sys error msg "+e.getMessage(),e);
}
//
}
log
.
info
(
"testXuper014FreezeAsset resp : "
+
JsonUtils
.
toJson
(
respDto
));
//
log.info("testXuper014FreezeAsset resp : "+ JsonUtils.toJson(respDto));
}
}
@Test
@Test
public
void
testXuper015GetEvidenceInfo
(){
public
void
testXuper015GetEvidenceInfo
(){
Xuper0
04PublishAssetReqDto
reqDto
=
Xuper004PublishAsset
ReqDto
.
getNew
();
Xuper0
15GetEvidenceInfoReqDto
reqDto
=
Xuper015GetEvidenceInfo
ReqDto
.
getNew
();
// 定义返回结果对象
// 定义返回结果对象
Xuper0
04PublishAsset
RespDto
respDto
=
null
;
Xuper0
15GetEvidenceInfo
RespDto
respDto
=
null
;
long
assetId
=
171095615845019437
l
;
long
assetId
=
171095615845019437
l
;
// long assetId = 1532351545249738541l;
// long assetId = 1532351545249738541l;
try
{
try
{
reqDto
.
setMnemonic
(
creatorMnemonic
);
reqDto
.
setAssetId
(
assetId
);
reqDto
.
setAssetId
(
assetId
);
XuperResponseDto
<
Xuper0
04PublishAssetRespDto
>
xuperResponseDto
=
xuperSdkUtil
.
xuper004PublishAsset
(
reqDto
);
XuperResponseDto
<
Xuper0
15GetEvidenceInfoRespDto
>
xuperResponseDto
=
xuperSdkUtil
.
xuper015GetEvidenceInfo
(
reqDto
);
if
(
xuperResponseDto
.
isSuccess
()){
if
(
xuperResponseDto
.
isSuccess
()){
respDto
=
xuperResponseDto
.
getParseData
(
Xuper0
04PublishAsset
RespDto
.
class
);
respDto
=
xuperResponseDto
.
getParseData
(
Xuper0
15GetEvidenceInfo
RespDto
.
class
);
}
}
}
catch
(
XupterException
e
)
{
}
catch
(
XupterException
e
)
{
log
.
error
(
"biz error msg "
+
e
.
getMessage
(),
e
);
log
.
error
(
"biz error msg "
+
e
.
getMessage
(),
e
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
error
(
"sys error msg "
+
e
.
getMessage
(),
e
);
log
.
error
(
"sys error msg "
+
e
.
getMessage
(),
e
);
}
}
log
.
info
(
"testXuper0
04PublishAsset
resp : "
+
JsonUtils
.
toJson
(
respDto
));
log
.
info
(
"testXuper0
15GetEvidenceInfo
resp : "
+
JsonUtils
.
toJson
(
respDto
));
}
}
}
}
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