package com.panzhihua.sangeshenbian.api;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.panzhihua.common.controller.BaseController;
|
import com.panzhihua.common.interfaces.OperLog;
|
import com.panzhihua.common.model.vos.LoginReturnVO;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.sangeshenbian.SystemUserVo;
|
import com.panzhihua.common.service.auth.TokenService;
|
import com.panzhihua.sangeshenbian.model.entity.SystemMenu;
|
import com.panzhihua.sangeshenbian.model.entity.SystemRoleMenu;
|
import com.panzhihua.sangeshenbian.model.entity.SystemUser;
|
import com.panzhihua.sangeshenbian.model.vo.RegionVO;
|
import com.panzhihua.sangeshenbian.model.vo.UpdatePasswordDTO;
|
import com.panzhihua.sangeshenbian.service.ISystemMenuService;
|
import com.panzhihua.sangeshenbian.service.ISystemRoleMenuService;
|
import com.panzhihua.sangeshenbian.service.ISystemUserService;
|
import com.panzhihua.sangeshenbian.warpper.LoginVo;
|
import com.panzhihua.sangeshenbian.warpper.SystemUserList;
|
import com.panzhihua.sangeshenbian.warpper.SystemUserListVo;
|
import com.panzhihua.sangeshenbian.warpper.TokenVo;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.validation.Valid;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author zhibing.pu
|
* @Date 2025/2/18 22:30
|
*/
|
@Api
|
@Slf4j
|
@Valid
|
@RestController
|
@RequestMapping("/systemUser")
|
public class SystemUserController extends BaseController {
|
|
@Resource
|
private ISystemUserService systemUserService;
|
|
@Resource
|
private RedisTemplate redisTemplate;
|
|
@Resource
|
private TokenService tokenService;
|
|
// 添加错误次数和冻结时间常量
|
private static final Integer LOCK_ERR = 5; // 锁定账号的错误次数
|
private static final Integer FREEZE_ERR = 3; // 冻结账号的错误次数
|
private static final Integer FREEZE_MINUTES = 3; // 冻结时间（分钟）
|
|
@Resource
|
private ISystemRoleMenuService systemRoleMenuService;
|
|
@Resource
|
private ISystemMenuService systemMenuService;
|
|
|
|
|
|
@PostMapping("/login")
|
@ApiOperation(value = "登录", tags = {"三个身边后台-登录"})
|
@OperLog(operModul = "三个身边后台",operType = 0,businessType = "登录")
|
public R<TokenVo> login(@RequestBody LoginVo vo){
|
String key = "login:" + vo.getPhone();
|
|
SystemUser systemUser = systemUserService.getOne(new LambdaQueryWrapper<SystemUser>()
|
.eq(SystemUser::getPhone, vo.getPhone())
|
.ne(SystemUser::getStatus, 3));
|
|
if(null == systemUser){
|
return R.fail("登录失败，手机号/密码错误。");
|
}
|
|
// 检查用户是否已被锁定
|
if(4 == systemUser.getStatus()){
|
return R.fail("密码连续输入错误五次，账号已被锁定，请联系管理员解锁。");
|
}
|
|
// 检查用户是否已被冻结
|
if(2 == systemUser.getStatus()){
|
return R.fail("当前账号已冻结。");
|
}
|
|
// 检查是否在临时冻结期
|
Integer errorCount = (Integer) redisTemplate.opsForValue().get(key);
|
if(null != errorCount && FREEZE_ERR <= errorCount && errorCount < LOCK_ERR){
|
return R.fail("密码连续输入错误三次，账号已被冻结" + FREEZE_MINUTES + "分钟。");
|
}
|
|
if(null == errorCount){
|
errorCount = 0;
|
}
|
|
if(!vo.getPassword().equals(systemUser.getPassword())){
|
errorCount++;
|
|
// 达到锁定次数，更新用户状态为锁定
|
if(errorCount >= LOCK_ERR) {
|
systemUser.setStatus(4); // 4表示账号锁定
|
systemUserService.updateById(systemUser);
|
redisTemplate.delete(key); // 清除redis中的错误计数
|
return R.fail("密码连续输入错误五次，账号已被锁定，请联系管理员解锁。");
|
}
|
// 达到冻结次数
|
else if(errorCount == FREEZE_ERR) {
|
redisTemplate.opsForValue().set(key, errorCount, FREEZE_MINUTES, TimeUnit.MINUTES);
|
return R.fail("密码连续输入错误三次，账号已被冻结" + FREEZE_MINUTES + "分钟。");
|
}
|
// 普通错误
|
else {
|
redisTemplate.opsForValue().set(key, errorCount, 5, TimeUnit.MINUTES);
|
return R.fail("登录失败，手机号/密码错误。");
|
}
|
}
|
|
//登录成功，创建token
|
R<LoginReturnVO> reult = tokenService.loginThreeAround(systemUser.getId());
|
redisTemplate.delete(key); // 清除错误计数
|
LoginReturnVO loginReturnVO = reult.getData();
|
TokenVo tokenVo = new TokenVo();
|
BeanUtils.copyProperties(loginReturnVO, tokenVo);
|
|
List<SystemRoleMenu> list = systemRoleMenuService.list(new LambdaQueryWrapper<SystemRoleMenu>().eq(SystemRoleMenu::getSystemRoleId, systemUser.getSystemRoleId()));
|
List<Integer> collect = list.stream().map(SystemRoleMenu::getSystemMenuId).collect(Collectors.toList());
|
Set<String> collect1 = new HashSet<>();
|
if(collect.size() > 0){
|
LambdaQueryWrapper<SystemMenu> queryWrapper = new LambdaQueryWrapper<SystemMenu>().in(SystemMenu::getId, collect);
|
switch (systemUser.getAccountLevel()){
|
case 2:
|
queryWrapper.notIn(SystemMenu::getUrl, Arrays.asList("/system_setting/position_management", "/system_setting/position_management/add", "/system_setting/position_management/del",
|
"/system_setting/role_management", "/system_setting/role_management/add", "/system_setting/role_management/edit", "/system_setting/role_management/del",
|
"/work_order_transaction_management/work_order_item_configuration", "/work_order_transaction_management/work_order_item_configuration/save",
|
"/work_order_transaction_management/problem_type_management", "/work_order_transaction_management/problem_type_management/add",
|
"/work_order_transaction_management/problem_type_management/edit", "/work_order_transaction_management/problem_type_management/del", "/work_order_transaction_management/banner_management",
|
"/work_order_transaction_management/banner_management/add", "/work_order_transaction_management/banner_management/edit", "/work_order_transaction_management/banner_management/del"));
|
break;
|
case 3:
|
queryWrapper.notIn(SystemMenu::getUrl, Arrays.asList("/system_setting/position_management", "/system_setting/position_management/add", "/system_setting/position_management/del",
|
"/system_setting/role_management", "/system_setting/role_management/add", "/system_setting/role_management/edit", "/system_setting/role_management/del",
|
"/work_order_transaction_management/work_order_item_configuration", "/work_order_transaction_management/work_order_item_configuration/save",
|
"/work_order_transaction_management/problem_type_management", "/work_order_transaction_management/problem_type_management/add",
|
"/work_order_transaction_management/problem_type_management/edit", "/work_order_transaction_management/problem_type_management/del", "/work_order_transaction_management/banner_management",
|
"/work_order_transaction_management/banner_management/add", "/work_order_transaction_management/banner_management/edit", "/work_order_transaction_management/banner_management/del"));
|
break;
|
case 4:
|
queryWrapper.notIn(SystemMenu::getUrl, Arrays.asList("/system_setting/position_management", "/system_setting/position_management/add", "/system_setting/position_management/del",
|
"/system_setting/role_management", "/system_setting/role_management/add", "/system_setting/role_management/edit", "/system_setting/role_management/del",
|
"/work_order_transaction_management/work_order_item_configuration", "/work_order_transaction_management/work_order_item_configuration/save",
|
"/work_order_transaction_management/problem_type_management", "/work_order_transaction_management/problem_type_management/add",
|
"/work_order_transaction_management/problem_type_management/edit", "/work_order_transaction_management/problem_type_management/del", "/work_order_transaction_management/banner_management",
|
"/work_order_transaction_management/banner_management/add", "/work_order_transaction_management/banner_management/edit", "/work_order_transaction_management/banner_management/del"));
|
break;
|
case 5:
|
queryWrapper.notIn(SystemMenu::getUrl, Arrays.asList("/system_setting/position_management", "/system_setting/position_management/add", "/system_setting/position_management/del",
|
"/system_setting/role_management", "/system_setting/role_management/add", "/system_setting/role_management/edit", "/system_setting/role_management/del",
|
"/system_setting/people_management", "/system_setting/people_management/add", "/system_setting/people_management/edit", "/system_setting/people_management/del",
|
"/system_setting/people_management/freeze", "/system_setting/unit_management", "/system_setting/people_management/detail", "/system_setting/unit_management/add",
|
"/system_setting/unit_management/edit", "/system_setting/unit_management/del", "/work_order_transaction_management/work_order_item_configuration",
|
"/work_order_transaction_management/work_order_item_configuration/save", "/work_order_transaction_management/problem_type_management",
|
"/work_order_transaction_management/problem_type_management/add", "/work_order_transaction_management/problem_type_management/edit",
|
"/work_order_transaction_management/problem_type_management/del", "/work_order_transaction_management/banner_management",
|
"/work_order_transaction_management/banner_management/add", "/work_order_transaction_management/banner_management/edit", "/work_order_transaction_management/banner_management/del"));
|
break;
|
}
|
List<SystemMenu> systemMenus = systemMenuService.list(queryWrapper);
|
collect1 = systemMenus.stream().map(SystemMenu::getUrl).collect(Collectors.toSet());
|
}
|
tokenVo.setMenu(collect1);
|
tokenVo.setName(systemUser.getName());
|
tokenVo.setAccountLevel(systemUser.getAccountLevel());
|
switch (systemUser.getAccountLevel()){
|
case 1:
|
tokenVo.setCityCode("510400");
|
break;
|
case 2:
|
tokenVo.setCityCode("510400");
|
tokenVo.setDistrictsCode(systemUser.getDistrictsCode());
|
break;
|
case 3:
|
tokenVo.setCityCode("510400");
|
tokenVo.setDistrictsCode(systemUser.getDistrictsCode());
|
tokenVo.setStreetId(systemUser.getStreetId());
|
break;
|
case 4:
|
tokenVo.setCityCode("510400");
|
tokenVo.setDistrictsCode(systemUser.getDistrictsCode());
|
tokenVo.setStreetId(systemUser.getStreetId());
|
tokenVo.setCommunityId(systemUser.getCommunityId().toString());
|
break;
|
}
|
return R.ok(tokenVo);
|
}
|
|
|
@PostMapping("logout")
|
@ApiOperation(value = "退出登录", tags = {"三个身边后台-登录"})
|
@OperLog(operModul = "三个身边后台",operType = 0,businessType = "退出登录")
|
public R login() {
|
String token = this.getToken();
|
if (ObjectUtils.isEmpty(token)) {
|
return R.ok();
|
}
|
return tokenService.logout(token);
|
}
|
|
|
@GetMapping("/list")
|
@ApiOperation(value = "获取列表数据", tags = {"三个身边管理后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 0,businessType = "获取人员管理列表数据")
|
public R<IPage<SystemUserListVo>> list(SystemUserList query){
|
Integer id = this.getLoginUserInfoSanGeShenBian().getId();
|
SystemUser user = systemUserService.getById(id);
|
IPage<SystemUserListVo> list = systemUserService.list(user, query);
|
return R.ok(list);
|
}
|
|
|
|
@PostMapping("/add")
|
@ApiOperation(value = "添加人员", tags = {"三个身边管理后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 1,businessType = "添加人员")
|
public R add(@RequestBody SystemUser systemUser){
|
Integer id = this.getLoginUserInfoSanGeShenBian().getId();
|
SystemUser user = systemUserService.getById(id);
|
if(2 == user.getAccountLevel() && 1 == systemUser.getAccountLevel()){
|
return R.fail("不能添加市级账号");
|
}
|
if(3 == user.getAccountLevel() && 3 < systemUser.getAccountLevel()){
|
return R.fail("不能添加区县和市级账号");
|
}
|
if(4 == user.getAccountLevel() && 4 < systemUser.getAccountLevel()){
|
return R.fail("不能添加街道、区县和市级账号");
|
}
|
long count = systemUserService.count(new LambdaQueryWrapper<SystemUser>().eq(SystemUser::getPhone, systemUser.getPhone()).ne(SystemUser::getStatus, 3));
|
if(0 < count){
|
return R.fail("手机号重复。");
|
}
|
systemUser.setStatus(1);
|
systemUser.setCreateTime(LocalDateTime.now());
|
systemUserService.save(systemUser);
|
return R.ok();
|
}
|
|
|
@PostMapping("/edit")
|
@ApiOperation(value = "编辑人员", tags = {"三个身边后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 2,businessType = "编辑人员")
|
public R edit(@RequestBody SystemUser systemUser){
|
long count = systemUserService.count(new LambdaQueryWrapper<SystemUser>().eq(SystemUser::getPhone, systemUser.getPhone())
|
.ne(SystemUser::getStatus, 3).ne(SystemUser::getId, systemUser.getId()));
|
if(0 < count){
|
return R.fail("手机号重复。");
|
}
|
systemUser.setStatus(1);
|
systemUser.setCreateTime(LocalDateTime.now());
|
systemUserService.updateById(systemUser);
|
return R.ok();
|
}
|
|
|
@DeleteMapping("/delete/{id}")
|
@ApiOperation(value = "删除人员", tags = {"三个身边后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 3,businessType = "删除人员")
|
public R delete(@PathVariable("id") Integer id){
|
SystemUser systemUser = systemUserService.getById(id);
|
systemUser.setStatus(3);
|
systemUserService.updateById(systemUser);
|
return R.ok();
|
}
|
|
|
@GetMapping("/getSystemUserInfo/{id}")
|
@ApiOperation(value = "查询人员详情", tags = {"三个身边后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 0,businessType = "查询人员详情")
|
public R<SystemUser> getSystemUserInfo(@PathVariable("id") Integer id){
|
SystemUser systemUser = systemUserService.getById(id);
|
return R.ok(systemUser);
|
}
|
|
|
@PutMapping("/freeze/{id}")
|
@ApiOperation(value = "冻结账号", tags = {"三个身边后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 2,businessType = "冻结账号")
|
public R freeze(@PathVariable("id") Integer id){
|
SystemUser systemUser = systemUserService.getById(id);
|
if(2 == systemUser.getStatus()){
|
return R.fail("不能重复操作");
|
}
|
systemUser.setStatus(2);
|
systemUserService.updateById(systemUser);
|
return R.ok();
|
}
|
|
|
@PutMapping("/unfreeze/{id}")
|
@ApiOperation(value = "解冻/解锁账号", tags = {"三个身边后台-人员管理"})
|
@OperLog(operModul = "三个身边后台",operType = 2,businessType = "解冻/解锁账号")
|
public R unfreeze(@PathVariable("id") Integer id){
|
SystemUser systemUser = systemUserService.getById(id);
|
if(1 == systemUser.getStatus()){
|
return R.fail("不能重复操作");
|
}
|
systemUser.setStatus(1); // 将冻结(2)或锁定(4)状态恢复为正常状态(1)
|
systemUserService.updateById(systemUser);
|
return R.ok();
|
}
|
|
|
/**
|
* 根据用户id获取信息
|
* @param id
|
* @return
|
*/
|
@PostMapping("/getUserById")
|
public R<SystemUserVo> getUserById(@RequestParam("id") String id){
|
SystemUser systemUser = systemUserService.getById(id);
|
SystemUserVo systemUserVo = new SystemUserVo();
|
List<SystemRoleMenu> list = systemRoleMenuService.list(new LambdaQueryWrapper<SystemRoleMenu>().eq(SystemRoleMenu::getSystemRoleId, systemUser.getSystemRoleId()));
|
List<Integer> collect = list.stream().map(SystemRoleMenu::getSystemMenuId).collect(Collectors.toList());
|
Set<String> collect1 = new HashSet<>();
|
if(collect.size() > 0){
|
List<SystemMenu> systemMenus = systemMenuService.listByIds(collect);
|
collect1 = systemMenus.stream().map(SystemMenu::getUrl).collect(Collectors.toSet());
|
}
|
systemUserVo.setPermissions(collect1);
|
BeanUtils.copyProperties(systemUser, systemUserVo);
|
return R.ok(systemUserVo);
|
}
|
|
|
|
@GetMapping("/getAdministrativeDivision/{id}/{tier}")
|
@ApiOperation(value = "获取行政区划层级联动数据", tags = {"三个身边后台-人员管理"})
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id", value = "上级id", required = false, dataType = "string"),
|
@ApiImplicitParam(name = "tier", value = "数据层级（2=区县，3=街道，4=社区）", required = true, dataType = "int"),
|
})
|
@OperLog(operModul = "三个身边后台",operType = 0,businessType = "获取行政区划层级联动数据")
|
public R<List<RegionVO>> getAdministrativeDivision(@PathVariable("id") String id, @PathVariable("tier") Integer tier){
|
List<RegionVO> list = new ArrayList<>();
|
//区县
|
if(2 == tier){
|
list = systemUserService.getRegion("510400");
|
}
|
//街道
|
if(3 == tier){
|
list = systemUserService.getStreet(id);
|
}
|
//社区
|
if(4 == tier){
|
list = systemUserService.getCommunity(id);
|
}
|
log.info("获取行政区划层级联动数据：{}", list);
|
return R.ok(list);
|
}
|
@ApiOperation(value = "修改密码",tags = {"三个身边后台-人员管理"})
|
@PostMapping("/updatePassword")
|
public R<?> updatePassword(@RequestBody @Validated UpdatePasswordDTO dto) {
|
SystemUserVo loginUserInfoSanGeShenBian = getLoginUserInfoSanGeShenBian();
|
systemUserService.updatePassword(dto,loginUserInfoSanGeShenBian);
|
return R.ok();
|
}
|
}
|
