记得上下班打卡 | 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
f38c5527
Commit
f38c5527
authored
Sep 29, 2021
by
Administrator
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'pre' into 'master'
Pre See merge request
!63
parents
dd33cbc7
126e45d9
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
30 additions
and
16 deletions
+30
-16
AdamMemberOrderAdminServiceImpl.java
...ai/adam/service/impl/AdamMemberOrderAdminServiceImpl.java
+4
-1
ChimeUserBiz.java
...in/java/com/liquidnet/service/chime/biz/ChimeUserBiz.java
+1
-0
PlatformMemberRefundService.java
...atform/service/impl/adam/PlatformMemberRefundService.java
+25
-15
No files found.
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/adam/service/impl/AdamMemberOrderAdminServiceImpl.java
View file @
f38c5527
...
...
@@ -171,6 +171,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
updateInfoMemberOrder
.
setMid
(
memberOrder
.
getMid
());
updateInfoMemberOrder
.
setState
(
4
);
updateInfoMemberOrder
.
setUpdatedAt
(
now
);
updateInfoMemberOrder
.
setComment
(
"R"
);
adamMemberOrderMapper
.
updateById
(
updateInfoMemberOrder
);
String
moKey
=
AdamRedisConst
.
INFO_MEMBER_ORDER
+
memberOrder
.
getUid
();
...
...
@@ -184,9 +185,10 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
vos
.
set
(
idx
,
vo
);
redisUtil
.
set
(
moKey
,
vos
);
if
(
memberRefund
.
getRenewable
()
==
2
)
{
if
(
memberRefund
.
getRenewable
()
==
2
)
{
// 拉黑用户,直接更新用户会员状态信息
AdamUserMember
updateUserMember
=
new
AdamUserMember
();
updateUserMember
.
setState
(
2
);
updateUserMember
.
setExpiryAt
(
now
);
updateUserMember
.
setUpdatedAt
(
now
);
updateUserMember
.
setComment
(
"R"
);
...
...
@@ -198,6 +200,7 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
AdamUserMemberVo
userMemberVo
=
(
AdamUserMemberVo
)
redisUtil
.
get
(
umkey
);
userMemberVo
.
setState
(
2
);
userMemberVo
.
setExpiryAt
(
now
);
userMemberVo
.
setUpdatedAt
(
now
);
redisUtil
.
set
(
umkey
,
userMemberVo
);
...
...
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/biz/ChimeUserBiz.java
View file @
f38c5527
...
...
@@ -198,6 +198,7 @@ public class ChimeUserBiz {
KylinPerformanceVo
kylinPerformanceVo
=
responseDto
.
getData
();
if
(
kylinPerformanceVo
.
getAppStatus
()
==
KylinPerformanceStatusEnum
.
PERFORMANCESTATUS6
.
getIndex
()
||
kylinPerformanceVo
.
getAppStatus
()
==
KylinPerformanceStatusEnum
.
PERFORMANCESTATUS8
.
getIndex
()
||
kylinPerformanceVo
.
getAppStatus
()
==
KylinPerformanceStatusEnum
.
PERFORMANCESTATUS11
.
getIndex
()
||
kylinPerformanceVo
.
getAppStatus
()
==
KylinPerformanceStatusEnum
.
PERFORMANCESTATUS9
.
getIndex
()){
isOnline
=
true
;
}
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/PlatformMemberRefundService.java
View file @
f38c5527
...
...
@@ -18,6 +18,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.stereotype.Service
;
import
javax.servlet.http.HttpServletRequest
;
import
java.time.LocalDate
;
import
java.time.LocalDateTime
;
import
java.util.ArrayList
;
import
java.util.stream.IntStream
;
...
...
@@ -96,31 +97,40 @@ public class PlatformMemberRefundService extends ServiceImpl<AdamMemberRefundMap
vo
.
setUpdatedAt
(
now
);
vos
.
set
(
idx
,
vo
);
boolean
syncVo
=
redisUtil
.
set
(
moKey
,
vos
);
log
.
warn
(
"###会员退款回调处理成功:更新REDIS会员订单状态
{}[orderNo:{},uid:{}]"
,
syncVo
?
"成功"
:
"失败"
,
orderNo
,
memberOrder
.
getUid
());
log
.
info
(
"###会员退款回调处理成功:更新REDIS会员订单信息
{}[orderNo:{},uid:{}]"
,
syncVo
?
"成功"
:
"失败"
,
orderNo
,
memberOrder
.
getUid
());
String
umKey
=
AdamRedisConst
.
INFO_USER_MEMBER
.
concat
(
memberOrder
.
getUid
());
AdamUserMemberVo
userMemberVo
=
(
AdamUserMemberVo
)
redisUtil
.
get
(
umKey
);
newExpiryAt
=
userMemberVo
.
getExpiryAt
().
minusDays
(
memberOrder
.
getDays
());
userMemberVo
.
setExpiryAt
(
newExpiryAt
);
userMemberVo
.
setUpdatedAt
(
now
);
if
(
userMemberVo
.
getState
()
==
1
)
{
// 非拉黑用户,则更新到期时间为减去订单标记的会员有效期的日期
newExpiryAt
=
userMemberVo
.
getExpiryAt
().
minusDays
(
memberOrder
.
getDays
());
syncVo
=
redisUtil
.
set
(
umKey
,
userMemberVo
);
log
.
warn
(
"###会员退款回调处理成功:更新REDIS会员状态{}[orderNo:{},uid:{}]"
,
syncVo
?
"成功"
:
"失败"
,
orderNo
,
memberOrder
.
getUid
());
}
LocalDate
nowDate
=
now
.
toLocalDate
();
LocalDate
newExpiryDate
=
newExpiryAt
.
toLocalDate
();
if
(
newExpiryDate
.
isEqual
(
nowDate
))
{
// 新的过期时间如果和当前时间为同一天,则重置到期时间为当天00:00:00
newExpiryAt
=
now
.
withHour
(
0
).
withMinute
(
0
).
withSecond
(
0
);
}
userMemberVo
.
setExpiryAt
(
newExpiryAt
);
userMemberVo
.
setUpdatedAt
(
now
);
AdamUserMember
updateInfoUserMember
=
new
AdamUserMember
();
updateInfoUserMember
.
setExpiryAt
(
newExpiryAt
);
updateInfoUserMember
.
setUpdatedAt
(
now
);
updateInfoUserMember
.
setComment
(
"R"
);
int
updateRst
=
adamUserMemberMapper
.
update
(
updateInfoUserMember
,
Wrappers
.
lambdaUpdate
(
AdamUserMember
.
class
).
eq
(
AdamUserMember:
:
getUid
,
memberOrder
.
getUid
()));
log
.
warn
(
"###会员退款回调处理成功:更新用户会员状态{}[orderNo:{},uid:{}]"
,
updateRst
<=
0
?
"失败"
:
"成功"
,
orderNo
,
memberOrder
.
getUid
());
syncVo
=
redisUtil
.
set
(
umKey
,
userMemberVo
);
log
.
info
(
"###会员退款回调处理成功:更新REDIS会员信息{}[orderNo:{},uid:{}]"
,
syncVo
?
"成功"
:
"失败"
,
orderNo
,
memberOrder
.
getUid
());
AdamUserMember
updateInfoUserMember
=
new
AdamUserMember
();
updateInfoUserMember
.
setExpiryAt
(
newExpiryAt
);
updateInfoUserMember
.
setUpdatedAt
(
now
);
updateInfoUserMember
.
setComment
(
"R"
);
int
updateRst
=
adamUserMemberMapper
.
update
(
updateInfoUserMember
,
Wrappers
.
lambdaUpdate
(
AdamUserMember
.
class
).
eq
(
AdamUserMember:
:
getUid
,
memberOrder
.
getUid
()));
log
.
info
(
"###会员退款回调处理成功:更新DB会员信息{}[orderNo:{},uid:{}]"
,
updateRst
<=
0
?
"失败"
:
"成功"
,
orderNo
,
memberOrder
.
getUid
());
}
}
AdamMemberOrder
updateInfoMemberOrder
=
new
AdamMemberOrder
();
updateInfoMemberOrder
.
setMid
(
memberOrder
.
getMid
());
updateInfoMemberOrder
.
setState
(
5
);
updateInfoMemberOrder
.
setUpdatedAt
(
now
);
updateRst
=
adamMemberOrderMapper
.
updateById
(
updateInfoMemberOrder
);
log
.
warn
(
"###会员退款回调处理成功:更新会员订单状态
{}[orderNo:{}]"
,
updateRst
<=
0
?
"失败"
:
"成功"
,
orderNo
);
int
updateRst
=
adamMemberOrderMapper
.
updateById
(
updateInfoMemberOrder
);
log
.
info
(
"###会员退款回调处理成功:更新DB订单信息
{}[orderNo:{}]"
,
updateRst
<=
0
?
"失败"
:
"成功"
,
orderNo
);
}
}
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