package com.panzhihua.sangeshenbian.api;
|
|
import com.alibaba.fastjson.JSON;
|
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.common.utlis.HttpClientUtil;
|
import com.panzhihua.common.utlis.ServletUtils;
|
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.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.data.redis.core.StringRedisTemplate;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.IOException;
|
import java.text.MessageFormat;
|
import java.text.SimpleDateFormat;
|
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
|
@RestController
|
@RequestMapping("/systemUser")
|
public class SystemUserController extends BaseController {
|
|
@Resource
|
private ISystemUserService systemUserService;
|
|
@Resource
|
private RedisTemplate redisTemplate;
|
|
@Resource
|
private TokenService tokenService;
|
|
private final Integer max_err = 5;
|
|
@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();
|
Integer size = (Integer) redisTemplate.opsForValue().get(key);
|
if(null != size && max_err.equals(size)){
|
return R.fail("连续登录失败，请稍后重试。");
|
}
|
if(null == size){
|
size = 0;
|
}
|
SystemUser systemUser = systemUserService.getOne(new LambdaQueryWrapper<SystemUser>()
|
.eq(SystemUser::getPhone, vo.getPhone()).ne(SystemUser::getStatus, 3));
|
if(null == systemUser){
|
size++;
|
redisTemplate.opsForValue().set(key, size, 5, TimeUnit.MINUTES);
|
return R.fail("登录失败，手机号/密码错误。");
|
}
|
if(!vo.getPassword().equals(systemUser.getPassword())){
|
size++;
|
redisTemplate.opsForValue().set(key, size, 5, TimeUnit.MINUTES);
|
return R.fail("登录失败，手机号/密码错误。");
|
}
|
if(2 == systemUser.getStatus()){
|
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);
|
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);
|
}
|
@GetMapping("/regionTree")
|
@ApiOperation(value = "获取区县-街道-社区树",tags = {"三个身边后台-人员管理"})
|
public R<List<RegionVO>> regionTree(){
|
SystemUserVo loginUserInfo = getLoginUserInfoSanGeShenBian();
|
List<RegionVO> list = systemUserService.getRegionTree(loginUserInfo);
|
return R.ok(list);
|
}
|
|
|
public static void main(String[] args) {
|
|
}
|
|
// private String ACCESS_TOKEN_URL = "GET https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential";
|
//
|
// public String getAppAccessToken(String appId, String appSecret) throws Exception {
|
// String accessToken = "0";
|
// try {
|
// log.info("获取微信token参数：appid=" + appId + "，appSecret=" + appSecret);
|
// String accessTokenUrl = ACCESS_TOKEN_URL + "&appid=" + appId + "&secret=" + appSecret;
|
// String result = HttpClientUtil.httpGet(accessTokenUrl, null, null);
|
// Map<String, Object> resultMap = JSON.parseObject(result, Map.class);
|
// StringRedisTemplate redisTemplate = wxXCXTempSend.stringRedisTemplate;
|
// if (resultMap.containsKey("access_token")) {
|
// accessToken = resultMap.get("access_token").toString();
|
// redisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken);
|
// }
|
// HttpServletRequest request = ServletUtils.getRequest();
|
// String requestURI = request.getRequestURI();
|
// //加上时间戳
|
// String datetime = new SimpleDateFormat("yyyyMMdd").format(new Date());
|
// //这里是 Redis key的前缀，如: sys:tabieId:表名 如果不需要去掉表名也可以
|
// String key = MessageFormat.format("{0}:{1}:{2}", "access_token_request_incr",datetime,requestURI);
|
// //查询 key 是否存在， 不存在返回 1 ，存在的话则自增加1
|
// redisTemplate.opsForValue().increment(key, 1);
|
//
|
// } catch (IOException ioe) {
|
// log.error("小程序http请求异常");
|
// ioe.printStackTrace();
|
// }
|
// return accessToken;
|
// }
|
|
}
|
