缓存改造- sweet:user:applet:mobile 增加缓存过期时间

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

@@ -75,7 +75,20 @@ public class WechatUsersRedisUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_PHONE.concat(mobile);
         Object obj = redisUtil.get(redisKey);
         if (null == obj) {
-            return null;
+            // 从MySQL数据库查询
+            LambdaQueryWrapper<SweetAppletUsers> lambda = new QueryWrapper<SweetAppletUsers>()
+                    .lambda()
+                    .eq(SweetAppletUsers::getPhoneNumber, mobile)
+                    .orderByDesc(SweetAppletUsers::getUpdatedAt);
+            List<SweetAppletUsers> sweetAppletUsers = sweetAppletUsersMapper.selectList(lambda);
+            if (!CollectionUtils.isEmpty(sweetAppletUsers)) {
+                SweetAppletUsersVo usersVo = SweetAppletUsersVo.getNew();
+                BeanUtils.copyProperties(sweetAppletUsers.get(0), usersVo);
+                setSweetAppletUsers(usersVo);
+                return usersVo;
+            } else {
+                return null;
+            }
         } else {
             SweetAppletUsersVo sweetAppletUsersVo = (SweetAppletUsersVo) obj;
             return sweetAppletUsersVo;
@@ -108,7 +121,7 @@ public class WechatUsersRedisUtils {
 
     public void setSweetAppletUsers(SweetAppletUsersVo sweetAppletUsersVo) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_PHONE.concat(sweetAppletUsersVo.getPurePhoneNumber());
-        redisUtil.set(redisKey, sweetAppletUsersVo);
+        redisUtil.set(redisKey, sweetAppletUsersVo, RedisKeyExpireConst.SWEET_USER_APPLET_MOBILE_EXPIRE);
 
         String redisKeyU = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_UNIONID.concat(sweetAppletUsersVo.getUnionId());
         redisUtil.set(redisKeyU, sweetAppletUsersVo, RedisKeyExpireConst.SWEET_USER_APPLET_UNIONID_EXPIRE);