取消事件

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/SubscribeHandler.java

@@ -39,7 +39,7 @@ public class SubscribeHandler implements WxMpMessageHandler {
     @Override
     public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService,
                                     WxSessionManager sessionManager) throws WxErrorException {
-        log.info("接收到一个扫码订阅事件:[{}]", wxMessage.toString());
+        log.info("接收到一个订阅事件:[{}]", wxMessage.toString());
         // 1、获取微信用户信息
         WxMpUser wxMpUser = wxMpService.getUserService().userInfo(wxMessage.getFromUser());
         if (null == wxMpUser) {

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/UnsubscribeHandler.java

 package com.liquidnet.service.sweet.handler;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.liquidnet.service.sweet.entity.SweetWechatUser;
+import com.liquidnet.service.sweet.mapper.SweetWechatUserMapper;
+import com.liquidnet.service.sweet.utils.RedisDataUtils;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.common.session.WxSessionManager;
@@ -7,6 +11,8 @@ import me.chanjar.weixin.mp.api.WxMpMessageHandler;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.Map;
@@ -23,10 +29,32 @@ import java.util.Map;
 @Slf4j
 public class UnsubscribeHandler implements WxMpMessageHandler {
 
+    @Autowired
+    private SweetWechatUserMapper sweetWechatUserMapper;
+    @Autowired
+    private RedisDataUtils redisDataUtils;
+
     @Override
     public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService,
                                     WxSessionManager sessionManager) throws WxErrorException {
-        log.info("接收到一个扫码取消订阅事件:[{}]", wxMessage.toString());
+        log.info("接收到一个取消订阅事件:[{}]", wxMessage.toString());
+
+        // 1、获取微信用户信息
+        WxMpUser wxMpUser = wxMpService.getUserService().userInfo(wxMessage.getFromUser());
+        if (null == wxMpUser) {
+            log.warn("从微信公众号获取用户(FromUser)信息:[{}]失败.", wxMessage.getFromUser());
+            return null;
+        }
+        log.info("根据 openId:[{}]获取到的微信用户信息:[{}]", wxMessage.getFromUser(), wxMpUser.toString());
+        // 删除用户信息
+        SweetWechatUser userInfo = sweetWechatUserMapper.selectOne(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getOpenId, wxMpUser.getOpenId()));
+        if (null != userInfo) {
+            int resNum = sweetWechatUserMapper.delete(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getUserId, userInfo.getUserId()));
+        }
+        String unionId = wxMpUser.getUnionId();
+        if (!unionId.isEmpty()) {
+            redisDataUtils.delSweetRemind(unionId);
+        }
         return null;
     }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetWechatCallbackServiceImpl.java

@@ -70,10 +70,10 @@ public class SweetWechatCallbackServiceImpl {
                 .end();
 
         // 取消关注事件
-        /*router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
+        router.rule().async(false).msgType(WxConsts.XmlMsgType.EVENT)
                 .event(WxConsts.EventType.UNSUBSCRIBE)
                 .handler(unsubscribeHandler)
-                .end();*/
+                .end();
 
         return router;
     }