Toggle navigation
Toggle navigation
This project
Loading...
Sign in
ufo
/
yohoufo-fore
·
Commits
Go to a project
GitLab
Go to group
Project
Activity
Files
Commits
Pipelines
0
Builds
0
Graphs
Milestones
Issues
0
Merge Requests
0
Members
Labels
Wiki
Forks
Network
Create a new issue
Download as
Email Patches
Plain Diff
Browse Files
Authored by
chenchao
5 years ago
Commit
f13a46b77902059fcce6907d09940be1b337d78a
1 parent
80f419e2
add log
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
4 additions
and
0 deletions
msg-center/src/main/java/com/yohoufo/msg/service/impl/MsgService.java
msg-center/src/main/java/com/yohoufo/msg/service/limit/RedisLimitStrategy.java
msg-center/src/main/java/com/yohoufo/msg/service/impl/MsgService.java
View file @
f13a46b
...
...
@@ -152,6 +152,8 @@ public class MsgService {
private
int
sendPrdPush
(
Integer
uid
,
SellerOrderGoods
sellerOrderGoods
,
Product
product
){
logger
.
info
(
logTitle
+
" ready 2 send push, uid {} sku {} prdName {} sceneKey {} securityKey {}"
,
uid
,
sellerOrderGoods
.
getStorageId
(),
product
.
getProductName
(),
sceneKey
,
securityKey
);
MessageCenterEvent
centerEvent
=
buildCommonPrdMsg
(
uid
,
sellerOrderGoods
,
product
);
centerEvent
.
setSendScene
(
sceneKey
);
centerEvent
.
setSecurityKey
(
securityKey
);
...
...
msg-center/src/main/java/com/yohoufo/msg/service/limit/RedisLimitStrategy.java
View file @
f13a46b
...
...
@@ -57,7 +57,9 @@ public class RedisLimitStrategy {
uid
,
storageId
,
result
);
//所有条件都满足后,聚合处理自增
if
(
result
){
logger
.
info
(
"ready call push,uid {} sku {}"
,
uid
,
storageId
);
pushSupplier
.
get
();
logger
.
info
(
"finish call push,uid {} sku {}"
,
uid
,
storageId
);
redisLimitors
.
forEach
(
RedisLimitor:
:
increment
);
}
...
...
Please
register
or
login
to post a comment