记得上下班打卡 | 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
d508549a
Commit
d508549a
authored
Dec 08, 2021
by
sunyuntian
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改bug
parent
c297047b
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
8 additions
and
22 deletions
+8
-22
MaoDengImageHandler.java
.../liquidnet/service/sweet/handler/MaoDengImageHandler.java
+7
-21
TextMsgHandler.java
...a/com/liquidnet/service/sweet/handler/TextMsgHandler.java
+1
-1
No files found.
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/MaoDengImageHandler.java
View file @
d508549a
package
com
.
liquidnet
.
service
.
sweet
.
handler
;
package
com
.
liquidnet
.
service
.
sweet
.
handler
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.common.third.shumei.util.ShumeiUtil
;
import
com.liquidnet.common.third.shumei.util.ShumeiUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.commons.lang.util.IDGenerator
;
import
com.liquidnet.commons.lang.util.StringUtil
;
import
com.liquidnet.commons.lang.util.StringUtil
;
import
com.liquidnet.service.sweet.config.WechatMaConfigure
;
import
com.liquidnet.service.sweet.config.WechatMaConfigure
;
import
com.liquidnet.service.sweet.utils.QueueUtils
;
import
com.liquidnet.service.sweet.utils.WechatUsersRedisUtils
;
import
com.liquidnet.service.sweet.utils.WechatUsersRedisUtils
;
import
com.liquidnet.service.sweet.vo.SweetMaoDengVo
;
import
com.liquidnet.service.sweet.vo.SweetMaoDengVo
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
...
@@ -32,23 +29,16 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
...
@@ -32,23 +29,16 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
@Autowired
@Autowired
private
ShumeiUtil
shumeiUtil
;
private
ShumeiUtil
shumeiUtil
;
@Autowired
@Autowired
QueueUtils
queueUtils
;
@Autowired
private
RedisUtil
redisUtil
;
@Autowired
WechatMaConfigure
maConfigure
;
WechatMaConfigure
maConfigure
;
@Override
@Override
public
WxMpXmlOutMessage
handle
(
WxMpXmlMessage
wxMessage
,
Map
<
String
,
Object
>
map
,
WxMpService
wxMpService
,
WxSessionManager
wxSessionManager
)
throws
WxErrorException
{
public
WxMpXmlOutMessage
handle
(
WxMpXmlMessage
wxMessage
,
Map
<
String
,
Object
>
map
,
WxMpService
wxMpService
,
WxSessionManager
wxSessionManager
)
throws
WxErrorException
{
String
fromUser
=
wxMessage
.
getFromUser
();
//用户id
String
fromUser
=
wxMessage
.
getFromUser
();
//用户id
String
picUrl
=
wxMessage
.
getPicUrl
();
//图片url
String
picUrl
=
wxMessage
.
getPicUrl
();
//图片url
String
maoId
=
IDGenerator
.
nextSnowId
();
//图片非法判断
//图片非法判断
//此处判断不需要用户登录,所以使用时间代替
if
(!
shumeiUtil
.
checkImage
(
fromUser
,
picUrl
))
{
String
currentUid
=
DateUtil
.
now
().
getTime
()+
""
;
if
(!
shumeiUtil
.
checkImage
(
currentUid
,
picUrl
))
{
//图片非法 提示,发送文本消息
//图片非法 提示,发送文本消息
WxMpXmlOutTextMessage
build
=
WxMpXmlOutMessage
.
TEXT
().
content
(
"
无法识别,你家猫猫还有别的图吗?
"
)
WxMpXmlOutTextMessage
build
=
WxMpXmlOutMessage
.
TEXT
().
content
(
"
图片无法识别,吸猫上瘾的你一定还有其他的“猫片”,重新发一张吧!
"
)
.
fromUser
(
wxMessage
.
getToUser
()).
toUser
(
wxMessage
.
getFromUser
())
.
fromUser
(
wxMessage
.
getToUser
()).
toUser
(
wxMessage
.
getFromUser
())
.
build
();
.
build
();
return
build
;
return
build
;
...
@@ -60,29 +50,25 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
...
@@ -60,29 +50,25 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
if
(
StringUtil
.
isNotEmpty
(
i
)){
if
(
StringUtil
.
isNotEmpty
(
i
)){
//活动已开启 持久化 redis
//活动已开启 持久化 redis
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDengTransfer
(
fromUser
);
SweetMaoDengVo
sweetMaoDeng
=
redisUtils
.
getSweetMaoDengTransfer
(
fromUser
);
String
textMsg
=
null
;
if
(
sweetMaoDeng
!=
null
){
if
(
sweetMaoDeng
!=
null
){
textMsg
=
sweetMaoDeng
.
getTextMsg
();
String
textMsg
=
sweetMaoDeng
.
getTextMsg
();
sweetMaoDengVo
.
setTextMsg
(
textMsg
);
sweetMaoDengVo
.
setTextMsg
(
textMsg
);
}
}
redisUtils
.
setSweetMaoDeng
(
sweetMaoDengVo
);
redisUtils
.
setSweetMaoDeng
(
sweetMaoDengVo
);
WxMpXmlOutTextMessage
build
=
WxMpXmlOutMessage
.
TEXT
().
content
(
"你好,"
+
textMsg
+
" 点击下方小程序卡片\n"
+
WxMpXmlOutTextMessage
build
=
WxMpXmlOutMessage
.
TEXT
().
content
(
"成了!点击下方小程序卡片查看猫咪的隐藏音乐技能。"
)
"查看你的猫咪隐藏音乐技能。\n"
+
"(小程序卡片,点击进入活动)\n"
)
.
fromUser
(
wxMessage
.
getToUser
()).
toUser
(
wxMessage
.
getFromUser
())
.
fromUser
(
wxMessage
.
getToUser
()).
toUser
(
wxMessage
.
getFromUser
())
.
build
();
.
build
();
// 发送活动小程序卡片
// 发送活动小程序卡片
WxMpKefuMessage
message
=
WxMpKefuMessage
.
MINIPROGRAMPAGE
()
WxMpKefuMessage
message
=
WxMpKefuMessage
.
MINIPROGRAMPAGE
()
.
appId
(
maConfigure
.
getWxMaAppid
(
4
))
.
appId
(
maConfigure
.
getWxMaAppid
(
4
))
.
pagePath
(
"
/pages/index?nickname="
.
concat
(
textMsg
))
.
pagePath
(
"
pages/webview?query=catActivity"
)
//小程序路径
.
thumbMediaId
(
"ov08q51In7bXX6tXv7FewxFNN0G78n-pPRsbi3LZbPE"
)
.
thumbMediaId
(
"ov08q51In7bXX6tXv7FewxFNN0G78n-pPRsbi3LZbPE"
)
//图片地址
.
title
(
"在猫登天空,每一只猫咪都有自己的隐藏音乐技能!"
)
.
title
(
"在猫登天空,每一只猫咪都有自己的隐藏音乐技能!"
)
.
toUser
(
wxMessage
.
getFromUser
())
.
toUser
(
wxMessage
.
getFromUser
())
.
build
();
.
build
();
wxMpService
.
getKefuService
().
sendKefuMessage
(
message
);
wxMpService
.
getKefuService
().
sendKefuMessage
(
message
);
return
build
;
return
build
;
}
}
return
null
;
return
null
;
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/TextMsgHandler.java
View file @
d508549a
...
@@ -124,7 +124,7 @@ public class TextMsgHandler implements WxMpMessageHandler {
...
@@ -124,7 +124,7 @@ public class TextMsgHandler implements WxMpMessageHandler {
long
expire
=
redisUtil
.
getExpire
(
SweetConstant
.
REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER
+
openId
);
long
expire
=
redisUtil
.
getExpire
(
SweetConstant
.
REDIS_KEY_SWEET_WECHAT_MAODENG_OPEN_POSTER
+
openId
);
redisUtils
.
setSweetMaoDengTransfer
(
sweetMaoDengVo
,
expire
);
redisUtils
.
setSweetMaoDengTransfer
(
sweetMaoDengVo
,
expire
);
WxMpXmlOutTextMessage
build
=
WxMpXmlOutMessage
.
TEXT
().
content
(
"
请发我猫咪的图片
"
)
WxMpXmlOutTextMessage
build
=
WxMpXmlOutMessage
.
TEXT
().
content
(
"
再发给我们一张猫咪的可爱照片吧!
"
)
.
fromUser
(
wxMessage
.
getToUser
()).
toUser
(
wxMessage
.
getFromUser
())
.
fromUser
(
wxMessage
.
getToUser
()).
toUser
(
wxMessage
.
getFromUser
())
.
build
();
.
build
();
return
build
;
return
build
;
...
...
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