取关获取不到unid 是openid

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

@@ -19,6 +19,7 @@ public class SweetConstant {
     public static final String REDIS_KEY_SWEET_REMIND_ALL = "sweet:remind:unionId*";
 
     public final static String REDIS_KEY_SWEET_WECHAT_USER_INFO="sweet:wechatUser:unionId:";
+    public final static String REDIS_KEY_SWEET_WECHAT_USER_UNIONID="sweet:wechatUser:openId:";
     public final static String REDIS_KEY_SWEET_ANSWER_PHONE="sweet:answer:phone:";
 
 //    public enum ManualPosition {

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

@@ -55,19 +55,21 @@ public class UnsubscribeHandler implements WxMpMessageHandler {
         }
         log.info("根据 openId:[{}]获取到的微信用户信息:[{}]", wxMessage.getFromUser(), wxMpUser.toString());
         // 删除用户信息
-        SweetWechatUser userInfo = redisDataUtils.getSweetWechatUser(wxMpUser.getUnionId());
-        if (null != userInfo) {
-            LinkedList<String> sqls = CollectionUtil.linkedListString();
-            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-            LocalDateTime now = LocalDateTime.now();
-            sqls.add(SqlMapping.get("sweet_user.update"));
-            sqlsDataA.add(new Object[]{
-                    2, now, wxMpUser.getUnionId()
-            });
-            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
-                    SqlMapping.gets(sqls, sqlsDataA));
-//            int resNum = sweetWechatUserMapper.delete(Wrappers.lambdaQuery(SweetWechatUser.class).eq(SweetWechatUser::getUserId, userInfo.getUserId()));
-            redisDataUtils.delSweetWechatUser(wxMpUser.getUnionId());
+        String sweetWechatUserUnionid = redisDataUtils.getSweetWechatUserUnionid(wxMpUser.getOpenId());
+        if (null != sweetWechatUserUnionid && !sweetWechatUserUnionid.isEmpty()) {
+            SweetWechatUser userInfo = redisDataUtils.getSweetWechatUser(sweetWechatUserUnionid);
+            if (null != userInfo) {
+                LinkedList<String> sqls = CollectionUtil.linkedListString();
+                LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                LocalDateTime now = LocalDateTime.now();
+                sqls.add(SqlMapping.get("sweet_user.update"));
+                sqlsDataA.add(new Object[]{
+                        2, now, sweetWechatUserUnionid
+                });
+                queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
+                        SqlMapping.gets(sqls, sqlsDataA));
+                redisDataUtils.delSweetWechatUser(sweetWechatUserUnionid);
+            }
         }
         return null;
     }

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

@@ -340,7 +340,16 @@ public class RedisDataUtils {
     // 正在现场服务号关注事件储存用户信息
     public void setSweetWechatUser(SweetWechatUser sweetWechatUser) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_INFO.concat(sweetWechatUser.getUnionId());
+        String redisKeyUnid = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_UNIONID.concat(sweetWechatUser.getOpenId());
         redisUtil.set(redisKey, sweetWechatUser);
+        redisUtil.set(redisKeyUnid, sweetWechatUser.getUnionId());
+    }
+    public String getSweetWechatUserUnionid(String openid) {
+        if (openid.isEmpty()) {
+            return null;
+        }
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_UNIONID.concat(openid);
+        return (String) redisUtil.get(redisKey);
     }
     public SweetWechatUser getSweetWechatUser(String unionid) {
         if (unionid.isEmpty()) {