From c338aa60df58bee9f4c25afedf94fe6930a119c1 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 29 七月 2020 19:01:56 +0800
Subject: [PATCH] SpringContext中的循环任务优化,添加业务监控
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java | 39 +++++++++++++++++++++++++++++++--------
1 files changed, 31 insertions(+), 8 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
index 0e5f944..3553d52 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
@@ -2,6 +2,10 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.entity.SystemEnum;
+import com.yeshi.fanli.entity.SystemFunction;
+import com.yeshi.fanli.service.inter.user.UserInfoService;
+import com.yeshi.fanli.util.SystemInfoUtil;
import org.springframework.stereotype.Component;
import com.aliyun.openservices.ons.api.Action;
@@ -28,6 +32,8 @@
@Resource
private SpreadUserImgService spreadUserImgService;
+ @Resource
+ private UserInfoService userInfoService;
@Override
public Action consume(Message message, ConsumeContext context) {
@@ -41,20 +47,37 @@
if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteCodeActive.name())) {// 閭�璇风爜婵�娲�
InviteCodeActiveMQMsg inviteCodeActiveMQMsg = new Gson().fromJson(new String(message.getBody()),
InviteCodeActiveMQMsg.class);
+
+ //鏄惁鏈変笁绾у垎閿�鏉冮檺
+ SystemEnum system = userInfoService.getUserSystem(inviteCodeActiveMQMsg.getUid());
+ if (!SystemInfoUtil.hasFunctions(system, SystemFunction.threeSale))
+ return Action.CommitMessage;
+
if (inviteCodeActiveMQMsg != null && inviteCodeActiveMQMsg.getUid() != null)
spreadUserImgService.deleteImgUrl(inviteCodeActiveMQMsg.getUid());
return Action.CommitMessage;
- } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 璁㈠崟缁熻
- UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),
- UserInfoUpdateMQMsg.class);
- if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait
- || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {
- if (userInfoUpdateMQMsg.getUid() != null)
- spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());
+ } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 鐢ㄦ埛淇℃伅鏇存柊
+
+ try {
+ UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),
+ UserInfoUpdateMQMsg.class);
+
+ //鏄惁鏈変笁绾у垎閿�鏉冮檺
+ SystemEnum system = userInfoService.getUserSystem(userInfoUpdateMQMsg.getUid());
+ if (!SystemInfoUtil.hasFunctions(system, SystemFunction.threeSale))
+ return Action.CommitMessage;
+
+ if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait
+ || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {
+ if (userInfoUpdateMQMsg.getUid() != null)
+ spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());
+ }
+ return Action.CommitMessage;
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e, "msgId:" + message.getMsgID(), "");
}
- return Action.CommitMessage;
}
}
return Action.CommitMessage;
--
Gitblit v1.8.0