添加或修改推送token

7944c67b · giaogiao · eb4c13c0 · 7944c67b · 7944c67b · 7944c67b
Commit 7944c67b authored Oct 27, 2020 by giaogiao
6 changed files
--- a/api-app/src/main/java/com/jumeirah/api/app/controller/AppUserController.java
+++ b/api-app/src/main/java/com/jumeirah/api/app/controller/AppUserController.java
 package com.jumeirah.api.app.controller;
-import com.jumeirah.api.app.entity.param.DeviceTokenParam;
 import com.jumeirah.api.app.service.AppUserApiService;
-import com.jumeirah.common.entity.AppUser;
 import com.jumeirah.common.param.app.AppSmsRegisterParam;
 import com.jumeirah.common.param.app.AppUserInfoParam;
 import com.jumeirah.common.param.app.AppUserPhoneUpdateParam;
+import com.jumeirah.common.param.app.DeviceTokenParam;
 import com.jumeirah.common.service.AppUserService;
 import com.jumeirah.common.vo.app.LoginAppUserTokenVo;
 import io.geekidea.springbootplus.framework.common.api.ApiResult;
@@ -13,11 +12,9 @@ import io.geekidea.springbootplus.framework.common.controller.BaseController;
 import io.geekidea.springbootplus.framework.log.annotation.Module;
 import io.geekidea.springbootplus.framework.log.annotation.OperationLog;
 import io.geekidea.springbootplus.framework.log.enums.OperationLogType;
-import io.geekidea.springbootplus.framework.shiro.jwt.JwtToken;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.shiro.SecurityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -51,17 +48,9 @@ public class AppUserController extends BaseController {
    @PostMapping("/iosDeviceToken")
    @OperationLog(name = "ios-添加或修改推送token", type = OperationLogType.ADD)
    @ApiOperation(value = "ios-添加或修改推送token", notes = "添加和修改都调用此接口", response = ApiResult.class)
-    public ApiResult<Boolean> addIosAppDeviceToken(@RequestBody DeviceTokenParam deviceToken) throws Exception {
+    public ApiResult<Boolean> addIosAppDeviceToken(@RequestBody DeviceTokenParam deviceTokenParam) throws Exception {
-        AppUser appUser = new AppUser();
+        boolean flag = appUserService.updateDeviceToken(deviceTokenParam, 2);
-        appUser.setDeviceToken(deviceToken.getDeviceToken());
-        appUser.setDeviceType(2);
-        JwtToken jwtToken = (JwtToken) SecurityUtils.getSubject().getPrincipal();
-        appUser.setId(jwtToken.getUserId());
-        boolean flag = appUserService.updateAppUser(appUser);
        return ApiResult.result(flag);
    }
@@ -71,20 +60,13 @@ public class AppUserController extends BaseController {
    @PostMapping("/androidDeviceToken")
    @OperationLog(name = "android-添加或修改推送token", type = OperationLogType.ADD)
    @ApiOperation(value = "android-添加或修改推送token", notes = "添加和修改都调用此接口", response = ApiResult.class)
-    public ApiResult<Boolean> addAppDeviceToken(@RequestBody DeviceTokenParam deviceToken) throws Exception {
+    public ApiResult<Boolean> addAppDeviceToken(@RequestBody DeviceTokenParam deviceTokenParam) throws Exception {
-        AppUser appUser = new AppUser();
-        appUser.setDeviceToken(deviceToken.getDeviceToken());
-        appUser.setDeviceType(1);
-        JwtToken jwtToken = (JwtToken) SecurityUtils.getSubject().getPrincipal();
+        boolean flag = appUserService.updateDeviceToken(deviceTokenParam, 1);
-        appUser.setId(jwtToken.getUserId());
-        boolean flag = appUserService.updateAppUser(appUser);
        return ApiResult.result(flag);
    }
    /**
     * 补充或修改APP用户信息
     */

--- a/api-app/src/main/java/com/jumeirah/api/app/entity/param/DeviceTokenParam.java
+++ b/api-app/src/main/java/com/jumeirah/api/app/entity/param/DeviceTokenParam.java
-package com.jumeirah.api.app.entity.param;
+package com.jumeirah.common.param.app;
 import lombok.Data;

--- a/common/src/main/java/com/jumeirah/common/service/AppUserService.java
+++ b/common/src/main/java/com/jumeirah/common/service/AppUserService.java
@@ -3,6 +3,7 @@ package com.jumeirah.common.service;
 import com.jumeirah.common.entity.AppUser;
 import com.jumeirah.common.param.AppUserPageParam;
 import com.jumeirah.common.param.app.AppSmsRegisterParam;
+import com.jumeirah.common.param.app.DeviceTokenParam;
 import com.jumeirah.common.vo.AppUserQueryVo;
 import com.jumeirah.common.vo.app.LoginAppUserTokenVo;
 import io.geekidea.springbootplus.framework.common.api.ApiResult;
@@ -63,6 +64,16 @@ public interface AppUserService extends BaseService<AppUser> {
    boolean updateAppUser(AppUser appUser) throws Exception;
    /**
+     * 添加或修改推送token
+     *
+     * @param deviceTokenParam
+     * @param deviceType
+     * @return
+     * @throws Exception
+     */
+    boolean updateDeviceToken(DeviceTokenParam deviceTokenParam, int deviceType) throws Exception;
+    /**
     * 删除
     *
     * @param id

--- a/common/src/main/java/com/jumeirah/common/service/impl/AppUserServiceImpl.java
+++ b/common/src/main/java/com/jumeirah/common/service/impl/AppUserServiceImpl.java
@@ -9,6 +9,7 @@ import com.jumeirah.common.enums.StateEnum;
 import com.jumeirah.common.mapper.AppUserMapper;
 import com.jumeirah.common.param.AppUserPageParam;
 import com.jumeirah.common.param.app.AppSmsRegisterParam;
+import com.jumeirah.common.param.app.DeviceTokenParam;
 import com.jumeirah.common.service.AppUserService;
 import com.jumeirah.common.vo.AppUserQueryVo;
 import com.jumeirah.common.vo.app.LoginAppUserTokenVo;
@@ -161,6 +162,23 @@ public class AppUserServiceImpl extends BaseServiceImpl<AppUserMapper, AppUser> 
    @Transactional(rollbackFor = Exception.class)
    @Override
+    public boolean updateDeviceToken(DeviceTokenParam deviceTokenParam, int deviceType) throws Exception {
+        AppUser appUser = new AppUser();
+        appUser.setDeviceToken(deviceTokenParam.getDeviceToken());
+        appUser.setDeviceType(deviceType);
+        JwtToken jwtToken = (JwtToken) SecurityUtils.getSubject().getPrincipal();
+        appUser.setId(jwtToken.getUserId());
+        // 重置redis中的token
+        return this.updateAppUser(appUser);
+    }
+    @Transactional(rollbackFor = Exception.class)
+    @Override
    public boolean deleteAppUser(Long id) throws Exception {
        return super.removeById(id);
    }

--- a/framework/src/main/java/io/geekidea/springbootplus/framework/shiro/cache/AppLoginRedisService.java
+++ b/framework/src/main/java/io/geekidea/springbootplus/framework/shiro/cache/AppLoginRedisService.java
@@ -64,13 +64,13 @@ public interface AppLoginRedisService {
     */
    LoginUserVo getLoginSysUserVo(String username);
-    /**
+//    /**
-     * 通过用户名称获取盐值
+//     * 通过用户名称获取盐值
-     *
+//     *
-     * @param username
+//     * @param username
-     * @return
+//     * @return
-     */
+//     */
-    String getSalt(String username);
+//    String getSalt(String username);
    /**
     * 删除对应用户的Redis缓存

--- a/framework/src/main/java/io/geekidea/springbootplus/framework/shiro/cache/impl/AppLoginRedisServiceImpl.java
+++ b/framework/src/main/java/io/geekidea/springbootplus/framework/shiro/cache/impl/AppLoginRedisServiceImpl.java
@@ -118,15 +118,15 @@ public class AppLoginRedisServiceImpl implements AppLoginRedisService {
        LoginUserRedisVo userRedisVo = getLoginSysUserRedisVo(username);
        return userRedisVo;
    }
+//
-    @Override
+//    @Override
-    public String getSalt(String username) {
+//    public String getSalt(String username) {
-        if (StringUtils.isBlank(username)) {
+//        if (StringUtils.isBlank(username)) {
-            throw new IllegalArgumentException("username不能为空");
+//            throw new IllegalArgumentException("username不能为空");
-        }
+//        }
-        String salt = (String) redisTemplate.opsForValue().get(String.format(CommonRedisKey.LOGIN_SALT, username));
+//        String salt = (String) redisTemplate.opsForValue().get(String.format(CommonRedisKey.LOGIN_SALT, username));
-        return salt;
+//        return salt;
-    }
+//    }
    @Override
    public void deleteLoginInfo(String token, String username) {