From cc9ce86cc24c413c9cbd303b8bb4fd9f5ec5a30f Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 28 Jul 2023 10:04:53 +0800
Subject: [PATCH] 赠送积分更新状态

---
 src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java |   11 +++++++++--
 1 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java b/src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java
index 36d7474..c773cc1 100644
--- a/src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java
+++ b/src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java
@@ -129,8 +129,10 @@
                 log.info("取消关注事件:toUserName{}、fromUserName{}", toUserName, fromUserName);
                 //取消关注则退出商城
                 MallMember mallMember = mallMemberMapper.selectMemberByOpenId(fromUserName);
-                redisUtils.del(AppContants.XCX_LOGIN_PREFIX + mallMember.getId());
-                redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + mallMember.getId());
+                if(ObjectUtil.isNotEmpty(mallMember)){
+                    redisUtils.del(AppContants.XCX_LOGIN_PREFIX + mallMember.getId());
+                    redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + mallMember.getId());
+                }
             }else if ("SCAN".equals(eventType)) {
                 log.info("扫码关注事件:toUserName{}、fromUserName{}", toUserName, fromUserName);
                 if(map.containsKey("EventKey")){
@@ -147,6 +149,11 @@
                         agentProducer.sendMemberSubScanMsg(stringBuffer.toString());
                     }
                 }
+            }else if ("VIEW".equals(eventType)) {
+                /**
+                 * 普通关注事件
+                 */
+                agentProducer.sendMemberSubMsg(fromUserName);
             }
         }
         return result;

--
Gitblit v1.9.1