取消关注的时候获取不到unid 多存一份openid以便使用

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/constant/SweetConstant.java

@@ -55,5 +55,6 @@ public class SweetConstant {
     // 微信用户相关 新
     public final static String REDIS_KEY_SWEET_WECHAT_USERS = "sweet:user:service:unionId:";
     public final static String REDIS_KEY_SWEET_WECHAT_USERS_TYPE = ":type:";
+    public final static String REDIS_KEY_SWEET_WECHAT_USERS_UNIONID = "sweet:user:service:openId:";
     public final static String REDIS_KEY_SWEET_APPLET_USERS_PHONE = "sweet:user:applet:mobile:";
 }

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

@@ -6,6 +6,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.sweet.config.WechatMpConfigure;
 import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
+import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.common.session.WxSessionManager;
@@ -47,29 +48,33 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
 
         log.info("接收到一个取消订阅事件:[{}]", wxMessage.toString());
         // 1、获取微信用户信息
-        WxMpUser wxMpUser = wxMpService.getUserService().userInfo(wxMessage.getFromUser());
+        /*WxMpUser wxMpUser = wxMpService.getUserService().userInfo(wxMessage.getFromUser());
         if (null == wxMpUser) {
             log.warn("从微信公众号获取用户(FromUser)信息:[{}]失败.", wxMessage.getFromUser());
             return null;
         }
-        log.info("根据 openId:[{}]获取到的微信用户信息:[{}]", wxMessage.getFromUser(), wxMpUser.toString());
+        log.info("根据 openId:[{}]获取到的微信用户信息:[{}]", wxMessage.getFromUser(), wxMpUser.toString());*/
+        String openId = wxMessage.getFromUser();
         Integer type = 0;
         if (zhengzaiAppId.equals(otherAppId)) {// 正在服务号
             type = 1;
         } else {// 摩登服务号
             type = 2;
         }
-        // 删除用户信息
-        if (!wxMpUser.getUnionId().isEmpty()) {
-            redisUtils.delSweetWechatUsers(wxMpUser.getUnionId(), type);
-            LinkedList<String> sqls = CollectionUtil.linkedListString();
-            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-            sqls.add(SqlMapping.get("sweet_wechat_users.delete"));
-            sqlsDataA.add(new Object[]{
-                    wxMpUser.getUnionId(), type
-            });
-            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
-                    SqlMapping.gets(sqls, sqlsDataA));
+        SweetWechatUsersVo sweetWechatUsers = redisUtils.getSweetWechatUsersOfOpenId(openId, type);
+        if (null != sweetWechatUsers) {
+            // 删除用户信息
+            if (!sweetWechatUsers.getUnionId().isEmpty()) {
+                redisUtils.delSweetWechatUsers(sweetWechatUsers.getUnionId(), openId, type);
+                LinkedList<String> sqls = CollectionUtil.linkedListString();
+                LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                sqls.add(SqlMapping.get("sweet_wechat_users.delete"));
+                sqlsDataA.add(new Object[]{
+                        sweetWechatUsers.getUnionId(), type
+                });
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
+                        SqlMapping.gets(sqls, sqlsDataA));
+            }
         }
         return null;
     }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/WechatUsersRedisUtils.java

@@ -26,15 +26,34 @@ public class WechatUsersRedisUtils {
             return sweetWechatUsersVo;
         }
     }
+    public SweetWechatUsersVo getSweetWechatUsersOfOpenId(String openId, Integer type) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(openId)
+                .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
+        Object obj = redisUtil.get(redisKey);
+        if (null == obj) {
+            return null;
+        } else {
+            SweetWechatUsersVo sweetWechatUsersVo = (SweetWechatUsersVo) obj;
+            return sweetWechatUsersVo;
+        }
+    }
     public void setSweetWechatUsers(SweetWechatUsersVo sweetWechatUsersVo) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS.concat(sweetWechatUsersVo.getUnionId())
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
         redisUtil.set(redisKey, sweetWechatUsersVo);
+
+        String redisKeyOpenId = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(sweetWechatUsersVo.getOpenId())
+                .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
+        redisUtil.set(redisKeyOpenId, sweetWechatUsersVo);
     }
-    public void delSweetWechatUsers(String unionId, Integer type) {
+    public void delSweetWechatUsers(String unionId, String openId, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS.concat(unionId)
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
         redisUtil.del(redisKey);
+
+        String redisKeyOpenId = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(openId)
+                .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
+        redisUtil.del(redisKeyOpenId);
     }
 
     public SweetAppletUsersVo getSweetAppletUsers(String mobile) {