记得上下班打卡 | 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
34a83d40
Commit
34a83d40
authored
Oct 14, 2025
by
wangyifan
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'dev-sql-error-repair' into container
parents
16d929a5
e8a1aab2
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
58 additions
and
5 deletions
+58
-5
AdamNftVo.java
...ain/java/com/liquidnet/service/adam/dto/vo/AdamNftVo.java
+28
-0
AdamUserProfileVo.java
.../com/liquidnet/service/adam/dto/vo/AdamUserProfileVo.java
+3
-0
AdamUserController.java
...liquidnet/service/adam/controller/AdamUserController.java
+5
-0
AdamRdmService.java
...va/com/liquidnet/service/adam/service/AdamRdmService.java
+21
-4
GoblinRechargeWristbandServiceImpl.java
...blin/service/impl/GoblinRechargeWristbandServiceImpl.java
+1
-1
No files found.
liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/dto/vo/AdamNftVo.java
0 → 100644
View file @
34a83d40
package
com
.
liquidnet
.
service
.
adam
.
dto
.
vo
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
@ApiModel
(
value
=
"AdamNftVo"
,
description
=
"个人藏品响应数据"
)
@Data
public
class
AdamNftVo
implements
java
.
io
.
Serializable
,
Cloneable
{
private
static
final
long
serialVersionUID
=
1L
;
// 手动指定
@ApiModelProperty
(
position
=
1
,
value
=
"是否存在NFT 1:存在 2:不存在"
)
private
int
hasNft
;
@ApiModelProperty
(
position
=
2
,
value
=
"是否存在NFT订单 1:存在 2:不存在"
)
private
int
hasNftOrder
;
private
static
final
AdamNftVo
obj
=
new
AdamNftVo
();
public
static
AdamNftVo
getNew
()
{
try
{
return
(
AdamNftVo
)
obj
.
clone
();
}
catch
(
CloneNotSupportedException
e
)
{
return
new
AdamNftVo
();
}
}
}
liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/dto/vo/AdamUserProfileVo.java
View file @
34a83d40
...
...
@@ -22,6 +22,9 @@ public class AdamUserProfileVo implements java.io.Serializable, Cloneable {
private
AdamUserMemberVo
userMemberVo
;
@ApiModelProperty
(
position
=
16
,
value
=
"会员卡信息"
)
private
AdamMemberJoinusVo
memberJoinusVo
;
@ApiModelProperty
(
position
=
17
,
value
=
"藏品信息"
)
private
AdamNftVo
adamNftVo
;
// @ApiModelProperty(position = 17, value = "业务账号信息")
// private List<AdamUserBizAcctVo> bizAcctVoList;
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamUserController.java
View file @
34a83d40
...
...
@@ -434,6 +434,11 @@ public class AdamUserController {
}
userProfileVo
.
setMemberJoinusVo
(
memberJoinusVo
);
AdamNftVo
adamNftVo
=
AdamNftVo
.
getNew
();
adamNftVo
.
setHasNft
(
adamRdmService
.
hasNft
(
currentUid
)
?
1
:
2
);
adamNftVo
.
setHasNftOrder
(
adamRdmService
.
hasNftOrder
(
currentUid
)
?
1
:
2
);
userProfileVo
.
setAdamNftVo
(
adamNftVo
);
return
ResponseDto
.
success
(
userProfileVo
);
}
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/AdamRdmService.java
View file @
34a83d40
...
...
@@ -29,10 +29,7 @@ import java.time.LocalDateTime;
import
java.time.temporal.ChronoField
;
import
java.time.temporal.ChronoUnit
;
import
java.time.temporal.TemporalAdjusters
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.Optional
;
import
java.util.*
;
import
java.util.stream.Collectors
;
@Slf4j
...
...
@@ -1082,6 +1079,26 @@ public class AdamRdmService {
Object
o
=
redisUtil
.
get
(
AdamRedisConst
.
INCR_USER_ENTERS
.
concat
(
uid
));
return
null
==
o
?
-
1
:
(
int
)
o
;
}
public
boolean
hasNft
(
String
currentUid
)
{
final
String
rdsKey
=
"goblin:u_d_art_ct:"
+
currentUid
;
Object
o
=
redisUtil
.
get
(
rdsKey
);
if
(
Objects
.
isNull
(
o
))
{
return
false
;
}
int
num
=
(
int
)
o
;
return
num
>
0
;
}
public
boolean
hasNftOrder
(
String
currentUid
)
{
final
String
rdsKey
=
"goblin:nft:order:idList:"
+
currentUid
;
Object
obj
=
redisUtil
.
get
(
rdsKey
);
if
(
obj
!=
null
)
{
return
true
;
}
return
false
;
}
/* - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | */
/* - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | */
...
...
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinRechargeWristbandServiceImpl.java
View file @
34a83d40
...
...
@@ -292,7 +292,7 @@ public class GoblinRechargeWristbandServiceImpl extends ServiceImpl<GoblinRechar
sqls
.
add
(
SqlMapping
.
get
(
"goblin_bracelet_order_update_refund"
));
LinkedList
<
Object
[]>
sqlDataOrder
=
CollectionUtil
.
linkedListObjectArr
();
sqlDataOrder
.
add
(
new
Object
[]{
orderVo
.
getStatus
(),
orderVo
.
getRefundStatus
(),
orderVo
.
getRefundStatusNote
(),
LocalDateTime
.
now
()
orderVo
.
getStatus
(),
orderVo
.
getRefundStatus
(),
orderVo
.
getRefundStatusNote
(),
LocalDateTime
.
now
()
,
orderId
});
queueUtils
.
sendMsgByRedis
(
MQConst
.
GoblinQueue
.
GOBLIN_NFT_ORDER
.
getKey
(),
...
...
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