Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
F
fzm-joying
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
JIRA
JIRA
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
lei
fzm-joying
Commits
3c676825
Commit
3c676825
authored
Mar 08, 2022
by
33
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
将循环任务的部分日志改为debug级别
parent
2438b614
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
11 additions
and
3 deletions
+11
-3
EvidenceHashLister.java
.../main/java/com/fzm/admin/listener/EvidenceHashLister.java
+3
-1
NftListener.java
...al/src/main/java/com/fzm/portal/listener/NftListener.java
+4
-1
OrderListener.java
.../src/main/java/com/fzm/portal/listener/OrderListener.java
+4
-1
No files found.
joying-admin/src/main/java/com/fzm/admin/listener/EvidenceHashLister.java
View file @
3c676825
...
@@ -40,7 +40,9 @@ public class EvidenceHashLister {
...
@@ -40,7 +40,9 @@ public class EvidenceHashLister {
String
serial_code
=
evidenceHashMessage
.
getSerial_code
();
String
serial_code
=
evidenceHashMessage
.
getSerial_code
();
String
realTxHash
=
paraChainClient
.
getRealTxHashFromGrp
(
hash
);
String
realTxHash
=
paraChainClient
.
getRealTxHashFromGrp
(
hash
);
if
(
StringUtils
.
isBlank
(
realTxHash
))
{
if
(
StringUtils
.
isBlank
(
realTxHash
))
{
log
.
error
(
"存证hash查询为空, 交易hash为: {}, 流水号为: {}"
,
hash
,
serial_code
);
if
(
log
.
isDebugEnabled
())
{
log
.
debug
(
"存证hash查询为空, 交易hash为: {}, 流水号为: {}"
,
hash
,
serial_code
);
}
// 查询失败,拒绝签收
// 查询失败,拒绝签收
channel
.
basicReject
(
deliveryTag
,
true
);
channel
.
basicReject
(
deliveryTag
,
true
);
return
;
return
;
...
...
joying-portal/src/main/java/com/fzm/portal/listener/NftListener.java
View file @
3c676825
...
@@ -59,7 +59,10 @@ public class NftListener {
...
@@ -59,7 +59,10 @@ public class NftListener {
*/
*/
@RabbitListener
(
queues
=
"nft.publish.queue"
)
@RabbitListener
(
queues
=
"nft.publish.queue"
)
public
void
listenNftPublish
(
NftPublishMsg
msg
)
throws
Exception
{
public
void
listenNftPublish
(
NftPublishMsg
msg
)
throws
Exception
{
log
.
info
(
"收到确认nft发行结果的消息: {}"
,
msg
);
if
(
log
.
isDebugEnabled
())
{
log
.
debug
(
"收到确认nft发行结果的消息: {}"
,
msg
);
}
Nft
nft
=
nftService
.
getById
(
msg
.
getId
());
Nft
nft
=
nftService
.
getById
(
msg
.
getId
());
User
user
=
userService
.
getUserByWallet
(
nft
.
getPublishAddress
());
User
user
=
userService
.
getUserByWallet
(
nft
.
getPublishAddress
());
...
...
joying-portal/src/main/java/com/fzm/portal/listener/OrderListener.java
View file @
3c676825
...
@@ -34,7 +34,10 @@ public class OrderListener {
...
@@ -34,7 +34,10 @@ public class OrderListener {
@RabbitListener
(
queues
=
"order.process.queue"
)
@RabbitListener
(
queues
=
"order.process.queue"
)
public
void
listenProcessOrder
(
OrderProcessMsg
msg
)
throws
Exception
{
public
void
listenProcessOrder
(
OrderProcessMsg
msg
)
throws
Exception
{
log
.
info
(
"收到处理订单的消息: {}"
,
msg
);
if
(
log
.
isDebugEnabled
())
{
log
.
debug
(
"收到处理订单的消息: {}"
,
msg
);
}
try
{
try
{
if
(
PayScene
.
NFT
.
getCode
().
equals
(
msg
.
getPayScene
()))
{
if
(
PayScene
.
NFT
.
getCode
().
equals
(
msg
.
getPayScene
()))
{
// 如果支付场景是发行nft的话,需要把此订单的nft发行
// 如果支付场景是发行nft的话,需要把此订单的nft发行
...
...
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