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

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/RedisKeyExpireConst.java

@@ -31,4 +31,10 @@ public class RedisKeyExpireConst {
 
     // sweet:user:applet:mobile 过期时间30天
     public static final long SWEET_USER_APPLET_MOBILE_EXPIRE = 30 * 24 * 60 * 60;
+
+    // sweet:user:service:unionId 过期时间30天
+    public static final long SWEET_USER_SERVICE_UNIONID_EXPIRE = 30 * 24 * 60 * 60;
+
+    // sweet:user:service:openId 过期时间30天
+    public static final long SWEET_USER_SERVICE_OPENID_EXPIRE = 30 * 24 * 60 * 60;
 }

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

@@ -6,7 +6,9 @@ import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.service.base.constant.RedisKeyExpireConst;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.entity.SweetAppletUsers;
+import com.liquidnet.service.sweet.entity.SweetWechatUsers;
 import com.liquidnet.service.sweet.mapper.SweetAppletUsersMapper;
+import com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper;
 import com.liquidnet.service.sweet.vo.SweetAppletUsersVo;
 import com.liquidnet.service.sweet.vo.SweetMaoDengVo;
 import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
@@ -26,13 +28,29 @@ public class WechatUsersRedisUtils {
     private RedisUtil redisUtil;
     @Autowired
     private SweetAppletUsersMapper sweetAppletUsersMapper;
+    @Autowired
+    private SweetWechatUsersMapper sweetWechatUsersMapper;
 
     public SweetWechatUsersVo getSweetWechatUsersOfUnionId(String unionId, Integer type) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(unionId)
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(type));
         Object obj = redisUtil.get(redisKey);
         if (null == obj) {
+            // 从MySQL查询
+            LambdaQueryWrapper<SweetWechatUsers> lambda = new QueryWrapper<SweetWechatUsers>()
+                    .lambda()
+                    .eq(SweetWechatUsers::getUnionId, unionId)
+                    .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;
@@ -54,7 +72,7 @@ public class WechatUsersRedisUtils {
     public void setSweetWechatUsers(SweetWechatUsersVo sweetWechatUsersVo) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_UNIONID.concat(sweetWechatUsersVo.getUnionId())
                 .concat(SweetConstant.REDIS_KEY_SWEET_WECHAT_USERS_TYPE).concat(String.valueOf(sweetWechatUsersVo.getType()));
-        redisUtil.set(redisKey, sweetWechatUsersVo);
+        redisUtil.set(redisKey, sweetWechatUsersVo, RedisKeyExpireConst.SWEET_USER_SERVICE_UNIONID_EXPIRE);
 
         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()));