记得上下班打卡 | 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
7bf45d5c
Commit
7bf45d5c
authored
Dec 09, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
需求改回来
parent
500f3cec
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
8 additions
and
8 deletions
+8
-8
SweetWechatMaoDengController.java
...ervice/sweet/controller/SweetWechatMaoDengController.java
+1
-1
MaoDengImageHandler.java
.../liquidnet/service/sweet/handler/MaoDengImageHandler.java
+1
-1
SweetWechatMaoDengServiceImpl.java
...ice/sweet/service/impl/SweetWechatMaoDengServiceImpl.java
+2
-2
WechatUsersRedisUtils.java
.../liquidnet/service/sweet/utils/WechatUsersRedisUtils.java
+4
-4
No files found.
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetWechatMaoDengController.java
View file @
7bf45d5c
...
@@ -38,7 +38,7 @@ public class SweetWechatMaoDengController {
...
@@ -38,7 +38,7 @@ public class SweetWechatMaoDengController {
if
(
null
==
wechatUsers
)
{
if
(
null
==
wechatUsers
)
{
return
ResponseDto
.
failure
(
"获取信息失败"
);
return
ResponseDto
.
failure
(
"获取信息失败"
);
}
}
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDeng
(
wechatUsers
.
getOpenId
()
,
maoId
);
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDeng
(
wechatUsers
.
getOpenId
());
if
(
sweetMaoDeng
!=
null
)
{
if
(
sweetMaoDeng
!=
null
)
{
String
textMsg
=
sweetMaoDeng
.
getTextMsg
();
String
textMsg
=
sweetMaoDeng
.
getTextMsg
();
String
image
=
sweetMaoDeng
.
getPicUrl
();
String
image
=
sweetMaoDeng
.
getPicUrl
();
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/MaoDengImageHandler.java
View file @
7bf45d5c
...
@@ -91,7 +91,7 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
...
@@ -91,7 +91,7 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
}
}
String
maoId
=
IDGenerator
.
nextSnowId
();
String
maoId
=
IDGenerator
.
nextSnowId
();
redisUtils
.
setSweetMaoDeng
(
sweetMaoDengVo
,
maoId
);
redisUtils
.
setSweetMaoDeng
(
sweetMaoDengVo
);
if
(
StringUtil
.
isNotEmpty
(
textMsg
)
&&
StringUtil
.
isNotEmpty
(
picUrl
))
{
if
(
StringUtil
.
isNotEmpty
(
textMsg
)
&&
StringUtil
.
isNotEmpty
(
picUrl
))
{
//redis队列入库
//redis队列入库
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetWechatMaoDengServiceImpl.java
View file @
7bf45d5c
...
@@ -37,14 +37,14 @@ public class SweetWechatMaoDengServiceImpl {
...
@@ -37,14 +37,14 @@ public class SweetWechatMaoDengServiceImpl {
if
(
null
==
wechatUsers
)
{
if
(
null
==
wechatUsers
)
{
return
ResponseDto
.
failure
(
"请求失败"
);
return
ResponseDto
.
failure
(
"请求失败"
);
}
}
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDeng
(
wechatUsers
.
getOpenId
()
,
maoId
);
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDeng
(
wechatUsers
.
getOpenId
());
if
(
sweetMaoDeng
!=
null
)
{
if
(
sweetMaoDeng
!=
null
)
{
sweetMaoDeng
.
setImgUrl
(
imgUrl
);
sweetMaoDeng
.
setImgUrl
(
imgUrl
);
}
}
String
textMsg
=
sweetMaoDeng
.
getTextMsg
();
String
textMsg
=
sweetMaoDeng
.
getTextMsg
();
String
picUrl
=
sweetMaoDeng
.
getPicUrl
();
String
picUrl
=
sweetMaoDeng
.
getPicUrl
();
sweetMaoDeng
.
setCreatedAt
(
localDateTime
);
sweetMaoDeng
.
setCreatedAt
(
localDateTime
);
redisUtils
.
setSweetMaoDeng
(
sweetMaoDeng
,
maoId
);
redisUtils
.
setSweetMaoDeng
(
sweetMaoDeng
);
if
(
StringUtil
.
isNotEmpty
(
textMsg
)
&&
StringUtil
.
isNotEmpty
(
picUrl
))
{
if
(
StringUtil
.
isNotEmpty
(
textMsg
)
&&
StringUtil
.
isNotEmpty
(
picUrl
))
{
//redis队列入库
//redis队列入库
LinkedList
<
String
>
sqls
=
CollectionUtil
.
linkedListString
();
LinkedList
<
String
>
sqls
=
CollectionUtil
.
linkedListString
();
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/WechatUsersRedisUtils.java
View file @
7bf45d5c
...
@@ -133,8 +133,8 @@ public class WechatUsersRedisUtils {
...
@@ -133,8 +133,8 @@ public class WechatUsersRedisUtils {
}
}
//整体取
//整体取
public
SweetMaoDengVo
getSweetMaoDeng
(
String
userId
,
String
maoId
)
{
public
SweetMaoDengVo
getSweetMaoDeng
(
String
userId
)
{
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER
.
concat
(
":"
+
userId
+
":"
+
maoId
);
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER
.
concat
(
":"
+
userId
);
SweetMaoDengVo
obj
=
(
SweetMaoDengVo
)
redisUtil
.
get
(
redisKey
);
SweetMaoDengVo
obj
=
(
SweetMaoDengVo
)
redisUtil
.
get
(
redisKey
);
if
(
null
==
obj
)
{
if
(
null
==
obj
)
{
return
null
;
return
null
;
...
@@ -144,8 +144,8 @@ public class WechatUsersRedisUtils {
...
@@ -144,8 +144,8 @@ public class WechatUsersRedisUtils {
}
}
//整体存
//整体存
public
void
setSweetMaoDeng
(
SweetMaoDengVo
sweetMaoDengVo
,
String
maoId
)
{
public
void
setSweetMaoDeng
(
SweetMaoDengVo
sweetMaoDengVo
)
{
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER
.
concat
(
":"
+
sweetMaoDengVo
.
getUserId
()
+
":"
+
maoId
);
String
redisKey
=
SweetConstant
.
REDIS_KEY_SWEET_WECHAT_MAODENG_POSTER
.
concat
(
":"
+
sweetMaoDengVo
.
getUserId
());
redisUtil
.
set
(
redisKey
,
sweetMaoDengVo
);
redisUtil
.
set
(
redisKey
,
sweetMaoDengVo
);
}
}
...
...
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