刷新用户信息接口

flossom-common/flossom-common-security/src/main/java/com/flossom/common/security/service/TokenService.java

@@ -56,8 +56,8 @@ public class TokenService
         loginUser.setUserid(userId);
         loginUser.setUsername(userName);
         if(loginUser.getWxUserMember() != null) {
-            loginUser.setWxUserid(loginUser.getWxUserid());
-            loginUser.setWxUsername(loginUser.getWxUsername());
+            loginUser.setWxUserid(loginUser.getWxUserMember().getId());
+            loginUser.setWxUsername(loginUser.getWxUserMember().getNickname());
         }
         loginUser.setIpaddr(IpUtils.getIpAddr());
         refreshToken(loginUser);

flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/controller/UserMemberController.java

@@ -1,5 +1,6 @@
 package com.flossom.miniProgram.controller;
 
+import com.flossom.common.core.domain.R;
 import com.flossom.common.core.utils.StringUtils;
 import com.flossom.common.core.web.controller.BaseController;
 import com.flossom.common.core.web.domain.AjaxResult;
@@ -63,4 +64,13 @@ public class UserMemberController extends BaseController {
         return AjaxResult.success();
     }
 
+    /**
+     * 刷新用户信息
+     * 1、重构用户缓存信息
+     * 2、返回用户信息给前端缓存
+     */
+    @GetMapping("/refreshWxUserInfo")
+    public R refreshWxUserInfo() {
+        return R.ok(wxUserMemberService.refreshWxUserInfo());
+    }
 }

flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/IWxUserMemberService.java

@@ -11,4 +11,7 @@ public interface IWxUserMemberService {
     String upgradeMember(String code) throws Exception;
 
     void updateUser(UserMemberUpdateVo userMemberUpdateVo);
+
+    LoginUserVo refreshWxUserInfo();
+
 }

flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java

@@ -16,6 +16,7 @@ import com.flossom.miniProgram.domain.vo.*;
 import com.flossom.miniProgram.service.IWxUserMemberService;
 import com.flossom.miniProgram.utils.MiniProgramUtils;
 import com.flossom.system.api.RemoteAuthService;
+import com.flossom.system.api.model.LoginUser;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
@@ -127,6 +128,40 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService {
         BeanUtils.copyProperties(userMemberUpdateVo, wxUserMember);
         wxUserMember.setUpdateTime(DateUtils.getNowDate());
         wxUserMemberMapper.updateWxUserMember(wxUserMember);
+
+        // 重新构建用户信息缓存
+
+    }
+
+    /**
+     * 重构用户缓存信息
+     *
+     * @return
+     */
+    @Override
+    public LoginUserVo refreshWxUserInfo() {
+        // 1、获取用户最新信息
+        String openid = SecurityUtils.getLoginUser().getWxUserMember().getOpenid();
+        WxUserMember wxUserMember = wxUserMemberMapper.selectWxUserMemberByOpenId(openid);
+        if (wxUserMember == null) {
+            logger.error("刷新用户信息失败");
+            throw new ServiceException("刷新用户信息失败");
+        }
+
+        // 2、刷新redis缓存信息
+        String userKey = SecurityUtils.getUserKey();
+        LoginUser loginUser = redisService.getCacheObject(CacheConstants.LOGIN_TOKEN_KEY + userKey);
+        loginUser.setWxUserMember(wxUserMember);
+        loginUser.setWxUserid(wxUserMember.getId());
+        loginUser.setUsername(wxUserMember.getNickname());
+        loginUser.setExpireTime(loginUser.getLoginTime() + CacheConstants.EXPIRATION * 60 * 1000);
+        redisService.setCacheObject(userKey, loginUser, CacheConstants.EXPIRATION, TimeUnit.MINUTES);
+
+        // 3、构建前端缓存对象
+        LoginUserVo loginUserVo = new LoginUserVo();
+        BeanUtils.copyProperties(wxUserMember, loginUserVo);
+        loginUserVo.setToken(loginUser.getToken());
+        return loginUserVo;
     }