删除user相关接口
This commit is contained in:
fuqingji
@ -1,47 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.controller;
|
|
||||||
|
|
||||||
import com.chinaunicom.mall.ebtp.common.base.entity.BaseCacheUser;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.service.EbtpUserInfoService;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.apache.commons.lang.StringUtils;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.http.HttpStatus;
|
|
||||||
import org.springframework.http.ResponseEntity;
|
|
||||||
import org.springframework.web.bind.annotation.*;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/v1/userinfo/")
|
|
||||||
public class UserInfoController {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private EbtpUserInfoService ebtpUserInfoService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取用户信息
|
|
||||||
*
|
|
||||||
* @param token (认证token)
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@GetMapping("get")
|
|
||||||
public ResponseEntity<BaseCacheUser> getUserInfo(
|
|
||||||
@RequestHeader(name = "Authorization", required = false) String token) {
|
|
||||||
if (StringUtils.isEmpty(token)) {
|
|
||||||
log.error("access token is empty");
|
|
||||||
return ResponseEntity.status(HttpStatus.UNAUTHORIZED).build();
|
|
||||||
}
|
|
||||||
return ResponseEntity.ok(ebtpUserInfoService.getUserInfo(token));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 刷新redis缓存的信息
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@PostMapping("refresh")
|
|
||||||
public ResponseEntity<Boolean> refreshToken() {
|
|
||||||
return ResponseEntity.ok(ebtpUserInfoService.refresh());
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.dao;
|
|
||||||
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.entity.BaseRole;
|
|
||||||
|
|
||||||
public interface BaseRoleMapper extends BaseMapper<BaseRole> {
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.dao;
|
|
||||||
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.entity.BaseUser;
|
|
||||||
|
|
||||||
public interface BaseUserMapper extends BaseMapper<BaseUser> {
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,48 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.entity;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableName;
|
|
||||||
import io.swagger.annotations.ApiModel;
|
|
||||||
import io.swagger.annotations.ApiModelProperty;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.experimental.Accessors;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 功能模块bean
|
|
||||||
*
|
|
||||||
* @author zyx
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@Accessors(chain = true)
|
|
||||||
@ApiModel
|
|
||||||
@TableName(value = "maint_base_role", autoResultMap = true)
|
|
||||||
public class BaseRole implements Serializable {
|
|
||||||
|
|
||||||
private static final Long serialVersionUID = 1L;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 姓名
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "角色")
|
|
||||||
private String role;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 账号
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "备注")
|
|
||||||
private String remarks;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* role_id
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "role_id")
|
|
||||||
private String roleId;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 账号
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "状态，0-默认")
|
|
||||||
private int status;
|
|
||||||
}
|
|
||||||
@ -1,65 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.entity;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableName;
|
|
||||||
import io.swagger.annotations.ApiModel;
|
|
||||||
import io.swagger.annotations.ApiModelProperty;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.experimental.Accessors;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 功能模块bean
|
|
||||||
*
|
|
||||||
* @author zyx
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@Accessors(chain = true)
|
|
||||||
@ApiModel
|
|
||||||
@TableName(value = "maint_base_user", autoResultMap = true)
|
|
||||||
public class BaseUser implements Serializable {
|
|
||||||
|
|
||||||
private static final Long serialVersionUID = 1L;
|
|
||||||
/**
|
|
||||||
* id
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "编号")
|
|
||||||
private String id;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 姓名
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "姓名")
|
|
||||||
private String name;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 账号
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "账号")
|
|
||||||
private String account;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 密码
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "密码")
|
|
||||||
private String password;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 省份
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "省份")
|
|
||||||
private String province;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 角色
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "角色")
|
|
||||||
private String role;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 租户
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "租户")
|
|
||||||
private String tenant;
|
|
||||||
}
|
|
||||||
@ -1,23 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.service;
|
|
||||||
|
|
||||||
import com.chinaunicom.mall.ebtp.common.base.entity.BaseCacheUser;
|
|
||||||
|
|
||||||
public interface EbtpUserInfoService {
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取用户信息
|
|
||||||
*
|
|
||||||
* @param token
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public BaseCacheUser getUserInfo(String token);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 刷新redis缓存的信息
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
public boolean refresh();
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,110 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userinfo.service.impl;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
||||||
import com.chinaunicom.mall.ebtp.cloud.security.starter.entity.AuthorityEntity;
|
|
||||||
import com.chinaunicom.mall.ebtp.cloud.userinfo.starter.service.UserInfoService;
|
|
||||||
import com.chinaunicom.mall.ebtp.common.base.entity.BaseCacheUser;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.dao.BaseRoleMapper;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.dao.BaseUserMapper;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.entity.BaseRole;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.entity.BaseUser;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userinfo.service.EbtpUserInfoService;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.beans.factory.annotation.Qualifier;
|
|
||||||
import org.springframework.data.redis.core.RedisTemplate;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
import java.util.*;
|
|
||||||
import java.util.concurrent.TimeUnit;
|
|
||||||
import java.util.stream.Collectors;
|
|
||||||
|
|
||||||
@Service
|
|
||||||
public class EbtpUserInfoServiceImpl implements EbtpUserInfoService {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private UserInfoService service;
|
|
||||||
@Autowired
|
|
||||||
private BaseUserMapper baseUserMapper;
|
|
||||||
@Autowired
|
|
||||||
private BaseRoleMapper baseRoleMapper;
|
|
||||||
|
|
||||||
@Autowired(required = false)
|
|
||||||
@Qualifier("cacheRedisTemplate")
|
|
||||||
private RedisTemplate<String, Object> redisTemplate;
|
|
||||||
|
|
||||||
private static final String EXTEND_USER_KEY = "ebtpUserTableCache";
|
|
||||||
private static final String USERS = "users";
|
|
||||||
private static final String ROLES = "roles";
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BaseCacheUser getUserInfo(String token) {
|
|
||||||
//查询山分库
|
|
||||||
BaseCacheUser user = service.getUserInfo(token);
|
|
||||||
|
|
||||||
if (Objects.isNull(user)) {
|
|
||||||
return new BaseCacheUser();
|
|
||||||
}
|
|
||||||
|
|
||||||
//获取redis缓存
|
|
||||||
Map<String, Object> userTable = getUserTable();
|
|
||||||
|
|
||||||
//获取用户信息
|
|
||||||
List<BaseUser> users = (List<BaseUser>) userTable.get(USERS);
|
|
||||||
BaseUser baseUser = users.stream().filter(u -> u.getAccount().equals(user.getLoginName())).findFirst().orElse(null);
|
|
||||||
if (Objects.isNull(baseUser)) {
|
|
||||||
return user;
|
|
||||||
}
|
|
||||||
|
|
||||||
List<BaseRole> roles = (List<BaseRole>) userTable.get(ROLES);
|
|
||||||
user.setProvince(baseUser.getProvince())
|
|
||||||
//覆盖角色
|
|
||||||
.setAuthorityList(
|
|
||||||
Optional.of(roles
|
|
||||||
.stream()
|
|
||||||
.filter(r -> baseUser.getRole().contains(r.getRole()))
|
|
||||||
.map(br ->
|
|
||||||
new AuthorityEntity()
|
|
||||||
.setRoleId(br.getRoleId())
|
|
||||||
.setRoleCode(br.getRole())
|
|
||||||
.setRoleName(br.getRemarks())
|
|
||||||
.setRoleScope("EBTP")
|
|
||||||
.setAuthorities(Collections.emptyList()))
|
|
||||||
.collect(Collectors.toList()))
|
|
||||||
.orElseGet(Collections::emptyList));
|
|
||||||
return user;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private Map<String, Object> getUserTable() {
|
|
||||||
Object o = redisTemplate.opsForValue().get(EXTEND_USER_KEY);
|
|
||||||
|
|
||||||
if (Objects.isNull(o)) {
|
|
||||||
o = cacheUserTable();
|
|
||||||
}
|
|
||||||
return (Map<String, Object>) o ;
|
|
||||||
}
|
|
||||||
|
|
||||||
private Map<String, Object> cacheUserTable() {
|
|
||||||
Map<String, Object> map = new HashMap<>();
|
|
||||||
map.put(USERS, baseUserMapper.selectList(Wrappers.lambdaQuery(BaseUser.class).eq(BaseUser::getTenant, "ebtp_mall")));
|
|
||||||
map.put(ROLES, baseRoleMapper.selectList(Wrappers.emptyWrapper()));
|
|
||||||
redisTemplate.opsForValue().set(EXTEND_USER_KEY, map, 8, TimeUnit.HOURS);
|
|
||||||
return map;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除token缓存
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public boolean refresh() {
|
|
||||||
cacheUserTable();
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
public EbtpUserInfoServiceImpl() {
|
|
||||||
super();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,33 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userpassword.controller;
|
|
||||||
|
|
||||||
|
|
||||||
import com.chinaunicom.mall.ebtp.common.base.entity.BaseResponse;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.entity.UserPassword;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.service.IUserPasswordService;
|
|
||||||
import io.swagger.annotations.Api;
|
|
||||||
import io.swagger.annotations.ApiOperation;
|
|
||||||
import io.swagger.annotations.ApiParam;
|
|
||||||
import org.springframework.web.bind.annotation.*;
|
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
|
|
||||||
@RestController
|
|
||||||
@Api(tags = "")
|
|
||||||
@RequestMapping("/v1/userpassword")
|
|
||||||
public class UserPasswordController{
|
|
||||||
|
|
||||||
@Resource
|
|
||||||
private IUserPasswordService iuserPasswordService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询数据
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@ApiOperation("查询数据")
|
|
||||||
@PostMapping("/validatePassword")
|
|
||||||
public BaseResponse<Boolean> validatePassword(@RequestParam("code") String code){
|
|
||||||
return BaseResponse.success(iuserPasswordService.validatePassword(code));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,13 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userpassword.dao;
|
|
||||||
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.entity.UserPassword;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author daixc
|
|
||||||
*/
|
|
||||||
public interface UserPasswordMapper extends BaseMapper<UserPassword> {
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,17 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8" ?>
|
|
||||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
|
||||||
|
|
||||||
<mapper namespace="com.chinaunicom.mall.ebtp.extend.userpassword.dao.UserPasswordMapper">
|
|
||||||
<resultMap id="BaseResultMap"
|
|
||||||
type="com.chinaunicom.mall.ebtp.extend.userpassword.entity.UserPassword">
|
|
||||||
<result column="password" jdbcType="VARCHAR" property="password"/>
|
|
||||||
</resultMap>
|
|
||||||
|
|
||||||
<!--逻辑删除方法 此方法为代码生成器生成 不允许修改 如有特殊需求 请自行新建SQL语句-->
|
|
||||||
<update id="deleteOff" parameterType="java.lang.Long">
|
|
||||||
update user_password
|
|
||||||
set
|
|
||||||
delete_flag="deleted"
|
|
||||||
where ID=#{id,jdbcType=BIGINT}
|
|
||||||
</update>
|
|
||||||
</mapper>
|
|
||||||
@ -1,33 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userpassword.entity;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableName;
|
|
||||||
import io.swagger.annotations.ApiModel;
|
|
||||||
import io.swagger.annotations.ApiModelProperty;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.EqualsAndHashCode;
|
|
||||||
import lombok.experimental.Accessors;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实体类 UserPassword
|
|
||||||
*
|
|
||||||
* @auto.generated
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@Accessors(chain = true)
|
|
||||||
@ApiModel
|
|
||||||
@EqualsAndHashCode(callSuper = false)
|
|
||||||
@TableName(value = "user_password", autoResultMap = true)
|
|
||||||
public class UserPassword implements Serializable {
|
|
||||||
|
|
||||||
private static final long serialVersionUID = 1L;
|
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@ApiModelProperty(value = "")
|
|
||||||
private String password;
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,16 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userpassword.service;
|
|
||||||
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.IService;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.entity.UserPassword;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 对数据表 user_password 操作的 service
|
|
||||||
* @author Auto create
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public interface IUserPasswordService extends IService<UserPassword> {
|
|
||||||
|
|
||||||
|
|
||||||
boolean validatePassword(String code);
|
|
||||||
}
|
|
||||||
@ -1,25 +0,0 @@
|
|||||||
package com.chinaunicom.mall.ebtp.extend.userpassword.service.impl;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.dao.UserPasswordMapper;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.entity.UserPassword;
|
|
||||||
import com.chinaunicom.mall.ebtp.extend.userpassword.service.IUserPasswordService;
|
|
||||||
import org.apache.commons.lang.StringUtils;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
/**
|
|
||||||
* 对数据表 user_password 操作的 serviceImpl
|
|
||||||
* @author daixc
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
public class UserPasswordServiceImpl extends ServiceImpl<UserPasswordMapper, UserPassword> implements IUserPasswordService {
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean validatePassword(String code) {
|
|
||||||
UserPassword userPassword = this.list().get(0);
|
|
||||||
if(StringUtils.isNotBlank(code) && code.equals(userPassword.getPassword())){
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user