记得上下班打卡 | 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
6cf79097
Commit
6cf79097
authored
Dec 06, 2021
by
sunyuntian
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改bug
parent
96ab35ef
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
21 additions
and
12 deletions
+21
-12
MaoDengImageHandler.java
.../liquidnet/service/sweet/handler/MaoDengImageHandler.java
+9
-4
TextMsgHandler.java
...a/com/liquidnet/service/sweet/handler/TextMsgHandler.java
+10
-6
sqlmap.properties
...uidnet-service-sweet/src/main/resources/sqlmap.properties
+2
-2
No files found.
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/MaoDengImageHandler.java
View file @
6cf79097
...
...
@@ -39,6 +39,7 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
public
WxMpXmlOutMessage
handle
(
WxMpXmlMessage
wxMessage
,
Map
<
String
,
Object
>
map
,
WxMpService
wxMpService
,
WxSessionManager
wxSessionManager
)
throws
WxErrorException
{
String
fromUser
=
wxMessage
.
getFromUser
();
//用户id
String
picUrl
=
wxMessage
.
getPicUrl
();
//图片url
String
maoId
=
IDGenerator
.
nextSnowId
();
//图片非法判断
//此处判断不需要用户登录,所以使用时间代替
...
...
@@ -57,20 +58,24 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
if
(
StringUtil
.
isNotEmpty
(
i
)){
//活动已开启 持久化 redis
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDeng
(
fromUser
);
//是否上传了文字
String
maoIdText
=
null
;
if
(
sweetMaoDeng
!=
null
){
maoIdText
=
sweetMaoDeng
.
getMaoId
();
}
if
(
StringUtil
.
isNotEmpty
(
maoIdText
)){
String
textMsg
=
sweetMaoDeng
.
getTextMsg
();
sweetMaoDengVo
.
setTextMsg
(
textMsg
);
maoId
=
sweetMaoDeng
.
getMaoId
();
//更新mysql
LinkedList
<
String
>
sqls
=
CollectionUtil
.
linkedListString
();
LinkedList
<
Object
[]>
sqlsDataA
=
CollectionUtil
.
linkedListObjectArr
();
sqls
.
add
(
SqlMapping
.
get
(
"sweet_wechat_maodeng.img.update"
));
sqlsDataA
.
add
(
new
Object
[]{
picUrl
,
fromUser
});
sqlsDataA
.
add
(
new
Object
[]{
picUrl
,
fromUser
,
maoId
});
queueUtils
.
sendMsgByRedis
(
MQConst
.
SweetQueue
.
SWEET_WECHAT_MAODENG_TEXT_INSERT
.
getKey
(),
SqlMapping
.
gets
(
sqls
,
sqlsDataA
));
}
else
{
//redis队列入库
String
maoId
=
IDGenerator
.
nextSnowId
(
);
sweetMaoDengVo
.
setMaoId
(
maoId
);
LinkedList
<
String
>
sqls
=
CollectionUtil
.
linkedListString
();
LinkedList
<
Object
[]>
sqlsDataA
=
CollectionUtil
.
linkedListObjectArr
();
sqls
.
add
(
SqlMapping
.
get
(
"sweet_wechat_maodeng.insert"
));
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/TextMsgHandler.java
View file @
6cf79097
...
...
@@ -55,6 +55,7 @@ public class TextMsgHandler implements WxMpMessageHandler {
SweetMaoDengVo
sweetMaoDengVo
=
SweetMaoDengVo
.
getNew
();
sweetMaoDengVo
.
setUserId
(
fromUser
);
sweetMaoDengVo
.
setTextMsg
(
maoContent
);
String
maoId
=
IDGenerator
.
nextSnowId
();
//敏感词判断
//此处判断不需要用户登录,所以使用时间代替
String
currentUid
=
DateUtil
.
now
().
getTime
()
+
""
;
...
...
@@ -77,21 +78,24 @@ public class TextMsgHandler implements WxMpMessageHandler {
if
(
StringUtil
.
isNotEmpty
(
i
))
{
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDeng
(
fromUser
);
//是否上传了图
if
(
sweetMaoDeng
!=
null
)
{
String
maoIdText
=
null
;
if
(
sweetMaoDeng
!=
null
){
maoIdText
=
sweetMaoDeng
.
getMaoId
();
}
if
(
StringUtil
.
isNotEmpty
(
maoIdText
))
{
String
picUrl
=
sweetMaoDeng
.
getPicUrl
();
sweetMaoDengVo
.
setPicUrl
(
picUrl
);
maoId
=
sweetMaoDeng
.
getMaoId
();
//更新mysql
LinkedList
<
String
>
sqls
=
CollectionUtil
.
linkedListString
();
LinkedList
<
Object
[]>
sqlsDataA
=
CollectionUtil
.
linkedListObjectArr
();
sqls
.
add
(
SqlMapping
.
get
(
"sweet_wechat_maodeng.text.update"
));
sqlsDataA
.
add
(
new
Object
[]{
fromUser
,
maoContent
});
sqlsDataA
.
add
(
new
Object
[]{
fromUser
,
maoContent
,
maoId
});
queueUtils
.
sendMsgByRedis
(
MQConst
.
SweetQueue
.
SWEET_WECHAT_MAODENG_TEXT_INSERT
.
getKey
(),
SqlMapping
.
gets
(
sqls
,
sqlsDataA
));
}
else
{
//redis队列入库
String
maoId
=
IDGenerator
.
nextSnowId
();
}
else
{
LinkedList
<
String
>
sqls
=
CollectionUtil
.
linkedListString
();
LinkedList
<
Object
[]>
sqlsDataA
=
CollectionUtil
.
linkedListObjectArr
();
sqls
.
add
(
SqlMapping
.
get
(
"sweet_wechat_maodeng.insert"
));
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties
View file @
6cf79097
...
...
@@ -60,8 +60,8 @@ sweet_strawberry_poster_Musician=INSERT INTO sweet_strawberry_poster_lineup(line
#---------------------------猫登天空--------------------------------
sweet_wechat_maodeng.insert
=
INSERT INTO sweet_wechat_maodeng(mao_id,user_id,text_msg,pic_url) VALUES (?,?,?,?)
sweet_wechat_maodeng.insert_img
=
INSERT INTO sweet_wechat_maodeng_img(mao_id,user_id,img_url) VALUES (?,?,?)
sweet_wechat_maodeng.text.update
=
UPDATE sweet_wechat_maodeng SET text_msg=? WHERE user_id=?
sweet_wechat_maodeng.img.update
=
UPDATE sweet_wechat_maodeng SET pic_url=? WHERE user_id=?
sweet_wechat_maodeng.text.update
=
UPDATE sweet_wechat_maodeng SET text_msg=? WHERE user_id=?
AND mao_id=?
sweet_wechat_maodeng.img.update
=
UPDATE sweet_wechat_maodeng SET pic_url=? WHERE user_id=?
AND mao_id=?
...
...
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