缓存改造- sweet:user:service:openId 增加缓存过期时间

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

@@ -62,7 +62,21 @@ public class WechatUsersRedisUtils {
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
         Object obj = redisUtil.get(redisKey);
         if (null == obj) {
-            return null;
+            // 从MySQL查询
+            LambdaQueryWrapper<SweetWechatUsers> lambda = new QueryWrapper<SweetWechatUsers>()
+                    .lambda()
+                    .eq(SweetWechatUsers::getOpenId, openId)
+                    .eq(SweetWechatUsers::getType, type)
+                    .orderByDesc(SweetWechatUsers::getUpdatedAt);
+            List<SweetWechatUsers> sweetWechatUsers = sweetWechatUsersMapper.selectList(lambda);
+            if (!CollectionUtils.isEmpty(sweetWechatUsers)) {
+                SweetWechatUsersVo usersVo = SweetWechatUsersVo.getNew();
+                BeanUtils.copyProperties(sweetWechatUsers.get(0), usersVo);
+                setSweetWechatUsers(usersVo);
+                return usersVo;
+            } else {
+                return null;
+            }
         } else {
             SweetWechatUsersVo sweetWechatUsersVo = (SweetWechatUsersVo) obj;
             return sweetWechatUsersVo;
@@ -76,7 +90,7 @@ public class WechatUsersRedisUtils {
 
         String redisKeyOpenId = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_OPENID.concat(sweetWechatUsersVo.getOpenId())
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
-        redisUtil.set(redisKeyOpenId, sweetWechatUsersVo);
+        redisUtil.set(redisKeyOpenId, sweetWechatUsersVo, RedisKeyExpireConst.SWEET_USER_SERVICE_OPENID_EXPIRE);
     }
 
     public void delSweetWechatUsers(String unionId, String openId, Integer type) {