package com.xzx.gc.user.controller;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.xzx.gc.common.Result;
|
import com.xzx.gc.common.annotations.valid.Update;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.UserEnum;
|
import com.xzx.gc.common.dto.CommonDto;
|
import com.xzx.gc.common.dto.log.OperationAppLog;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.request.BaseController;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.IdUtils;
|
import com.xzx.gc.common.utils.MqUtil;
|
import com.xzx.gc.common.utils.SecurityUtil;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.JsonResult;
|
import com.xzx.gc.model.admin.UserEditroleModel;
|
import com.xzx.gc.model.admin.UserModel;
|
import com.xzx.gc.model.user.SelectUserTypeDTO;
|
import com.xzx.gc.user.dto.RoleDto;
|
import com.xzx.gc.user.dto.SelectOtherUserDto;
|
import com.xzx.gc.user.mapper.OrderMapper;
|
import com.xzx.gc.user.mapper.OtherUserMapper;
|
import com.xzx.gc.user.mapper.SysStorageMapper;
|
import com.xzx.gc.user.mapper.UserRoleMapper;
|
import com.xzx.gc.user.service.*;
|
import com.xzx.gc.util.SessionUtil;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
import tk.mybatis.mapper.entity.Example;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Api(tags = "角色管理")
|
@RestController
|
@Validated
|
public class RoleController extends BaseController {
|
|
@Autowired
|
private OtherUserMapper otherUserMapper;
|
|
@Autowired
|
private FenceService fenceService;
|
|
@Autowired
|
private UserRoleMapper userRoleMapper;
|
|
|
@Autowired
|
private UserRoleService userRoleService;
|
|
@Autowired
|
private OtherUserService otherUserService;
|
|
|
@Autowired
|
private SysStorageMapper sysStorageMapper;
|
|
@Autowired
|
private UserService userService;
|
|
@Autowired
|
private SessionUtil sessionUtil;
|
|
@Autowired
|
private OrderService orderService;
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
|
@ApiOperation(value = "分页查询所有角色")
|
@PostMapping(value = "/role/select")
|
public Result<PageInfo<OtherUserInfo>> selectReceiver(HttpServletRequest request,@RequestBody SelectOtherUserDto selectOtherUserDto){
|
Example example=new Example(OtherUserInfo.class);
|
Example.Criteria criteria = example.createCriteria();
|
criteria.andEqualTo("delFlag",Constants.DEL_NOT_FLAG);
|
// criteria.andEqualTo("isProhibit",Constants.DEL_NOT_FLAG);
|
if(StrUtil.isNotBlank(selectOtherUserDto.getUserType())){
|
criteria.andIn("userType",Arrays.asList(selectOtherUserDto.getUserType().split(",")));
|
}
|
|
String userId=getUserId(request);
|
OtherUserInfo byId = otherUserService.findById(userId);
|
if(byId!=null){
|
criteria.andEqualTo("partnerId",byId.getPartnerId());
|
}
|
|
if(StrUtil.isNotBlank(selectOtherUserDto.getKeyword())){
|
String keyword="%"+selectOtherUserDto.getKeyword()+"%";
|
example.and().orLike("name",keyword).orLike("mobilePhone",keyword);
|
}
|
|
PageHelper.startPage(selectOtherUserDto.getPageNo(),selectOtherUserDto.getPageSize());
|
List<OtherUserInfo> select = otherUserMapper.selectByExample(example);
|
if(CollUtil.isNotEmpty(select)){
|
for (OtherUserInfo userInfo : select) {
|
List<UserRole> byRoleCode = userRoleService.findByRoleCode(userInfo.getUserType());
|
if(CollUtil.isNotEmpty(byRoleCode)){
|
userInfo.setUserTypeName(byRoleCode.get(0).getRoleName());
|
}
|
String townId = userInfo.getTownId();
|
List<Fence> byTownIds = fenceService.findByIds(townId);
|
if(CollUtil.isNotEmpty(byTownIds)){
|
String collect = byTownIds.stream().map(Fence::getFenceName).collect(Collectors.joining(","));
|
userInfo.setTownNames(collect);
|
}
|
|
if(StrUtil.isNotBlank(userInfo.getPassword())){
|
String decrypt = SecurityUtil.decrypt(userInfo.getSalt(), userInfo.getPassword());
|
userInfo.setPassword(decrypt);
|
}
|
userInfo.setSalt(null);
|
|
//转换areaId
|
Integer cityId = userInfo.getCityId();
|
Integer townshipId = userInfo.getTownshipId();
|
if(townshipId!=null){
|
userInfo.setAreaId(townshipId.toString());
|
userInfo.setLevel(3);
|
userInfo.setAreaName(userInfo.getTownship());
|
}else if(cityId!=null){
|
userInfo.setAreaId(cityId.toString());
|
userInfo.setLevel(2);
|
userInfo.setAreaName(userInfo.getCity());
|
}
|
|
String storageId = userInfo.getStorageId();
|
if(StrUtil.isNotBlank(storageId)){
|
String storageName = sysStorageMapper.selectByPrimaryKey(storageId).getStorageName();
|
userInfo.setStorageName(storageName);
|
}
|
|
//是否请假期间
|
String leaveStartTime = userInfo.getLeaveStartTime();
|
String leaveEndTime = userInfo.getLeaveEndTime();
|
if(StrUtil.isNotBlank(leaveStartTime)){
|
if(DateUtil.compare(new Date(),DateUtil.parse(leaveStartTime))>=0&&DateUtil.compare(new Date(),DateUtil.parse(leaveEndTime))<=0){
|
userInfo.setLeaveFlag(true);
|
}
|
}
|
|
}
|
}
|
PageInfo<OtherUserInfo> pageInfo=new PageInfo<>(select);
|
return Result.success(pageInfo);
|
}
|
|
@ApiOperation( value = "查询所有角色")
|
@PostMapping("/role/selectUserType")
|
public Result<List<UserRole>> add(HttpServletRequest request,@RequestBody SelectUserTypeDTO selectUserTypeDTO) {
|
String userId = getUserId(request);
|
List<UserRole> byRoleCode=null;
|
//根据运营员查询其下所属的角色
|
if(StrUtil.isBlank(selectUserTypeDTO.getExtra())) {
|
String mobilePhone = otherUserService.findById(userId).getMobilePhone();
|
//查出所有角色
|
List<OtherUserInfo> byMobile = otherUserService.findByMobile(mobilePhone);
|
List<String> collect = byMobile.stream().map(x -> x.getUserType()).collect(Collectors.toList());
|
if(collect.contains(CommonEnum.打包站运营员.getValue())){
|
byRoleCode = userRoleService.findByRoleCode(CommonEnum.打包员.getValue());
|
}else if(collect.contains(CommonEnum.运营员.getValue())) {
|
byRoleCode = userRoleService.findByRoleCode(null);
|
//排除打包员相关和自己
|
byRoleCode.removeIf(x->CommonEnum.打包站运营员.getValue().equals(x.getRoleCode())||CommonEnum.打包员.getValue().equals(x.getRoleCode())||CommonEnum.运营员.getValue().equals(x.getRoleCode()));
|
}
|
}else {
|
byRoleCode = userRoleService.findByRoleCodes(selectUserTypeDTO.getExtra());
|
}
|
return Result.success(byRoleCode);
|
|
}
|
|
|
@ApiOperation( value = "新增角色")
|
@PostMapping("/role/add")
|
public Result add(HttpServletRequest request, @RequestBody RoleDto roleDto) {
|
//设置合伙人ID
|
OtherUserInfo byId = otherUserService.findById(getUserId(request));
|
String partnerId = byId.getPartnerId();
|
|
List<OtherUserInfo> byMobile = otherUserService.findByMobileForBidden(roleDto.getMobilePhone());
|
if(CollUtil.isNotEmpty(byMobile)){
|
throw new RestException("该手机号已存在别的身份");
|
}
|
|
Result<String> add = userRoleService.add(roleDto,partnerId);
|
if(add.getCode()==0){
|
String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
|
OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
|
.methodName(Constants.USER_MODUL_NAME).operateAction("新增角色-"+roleDto.getUserId()).build();
|
mqUtil.sendApp(build);
|
}
|
return add;
|
}
|
|
@ApiOperation( value = "编辑角色")
|
@PostMapping("/role/update")
|
public Result update(HttpServletRequest request, @Validated(value = {Update.class}) @RequestBody RoleDto roleDto) {
|
roleDto.setLoginUserId(getUserId(request));
|
|
List<OtherUserInfo> byMobile = otherUserService.findByMobileForBidden(roleDto.getMobilePhone());
|
if(CollUtil.isNotEmpty(byMobile)){
|
//修改
|
long count = byMobile.stream().filter(x -> !x.getUserId().equals(roleDto.getUserId())).count();
|
if(count>0) {
|
throw new RestException("该手机号已存在别的身份");
|
}
|
}
|
|
Result edit = userRoleService.edit(roleDto);
|
if(edit.getCode()==0){
|
String mobilePhone = userService.findOtherByUserId(getUserId(request),0);
|
OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
|
.methodName(Constants.USER_MODUL_NAME).operateAction("编辑角色-"+roleDto.getUserId()).build();
|
mqUtil.sendApp(build);
|
}
|
return edit;
|
|
}
|
|
/**
|
* 身份设定查询
|
* @param userModel
|
* @return
|
*/
|
@PostMapping( "/admin/front/role/queryEditroleApi.do")
|
@ApiOperation(value="用户管理-身份设定查询", notes="test: 仅0有正确返回")
|
public JsonResult<Map<String, Object>> queryEditroleApi(@RequestBody UserEditroleModel userModel){
|
Map<String, Object> map = userRoleService.queryEditroleApi(userModel);
|
return JsonResult.success(map);
|
}
|
|
/**
|
* 根据Id删除用户角色
|
* @param userModel
|
*/
|
@PostMapping( "/admin/front/role/delEditroleApi.json")
|
@ApiOperation(value="用户管理-身份设定删除", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name = "userId", value = "用户Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "userType", value = "用户类型", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "mobilePhone", value = "手机号", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> delEditroleApi(@RequestBody UserModel userModel, HttpServletRequest request){
|
CoreUser user = sessionUtil.getCurrentUser();
|
String code=user.getCode();
|
//合伙人的运营员那个账号不能删。其他合伙人的账号都可以通过运营员删
|
// 运营管理员和超管最高权限。都可以删
|
|
if(!SessionUtil.ACCESS_CS_ADMIN.equals(code)&&!SessionUtil.ACCESS_SUPPER_ADMIN.equals(code)){
|
if(userModel.getUserType().equals(CommonEnum.打包站运营员.getValue())){
|
return JsonResult.failMessage("不能删除主打包员的角色！");
|
}
|
if(userModel.getUserType().equals(CommonEnum.运营员.getValue())){
|
return JsonResult.failMessage("不能删除主运营员的角色！");
|
}
|
if(userModel.getUserType().equals(CommonEnum.总部管理员.getValue())){
|
return JsonResult.failMessage("不能删除总部管理员的角色！");
|
}
|
}
|
|
if(userModel.getUserType().equals(CommonEnum.回收员.getValue())){
|
List<OrderInfo> list1 = orderService.findByManageReceiver(userModel.getUserId());
|
if(CollUtil.isNotEmpty(list1)){
|
return JsonResult.failMessage("当前回收员存在未完成的订单");
|
}
|
}
|
|
otherUserService.delCuserById(userModel.getUserId(), userModel.getMobilePhone(), userModel.getUserType());
|
Map<String, Object> map = new HashMap<>();
|
map.put("code",0);
|
map.put("userId",userModel.getUserId());
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("身份设定删除-"+userModel.getUserId()).build();
|
mqUtil.sendApp(build);
|
|
return JsonResult.success(map);
|
}
|
|
/**
|
* @param userModel
|
* @return
|
*/
|
@PostMapping( "/admin/front/role/addEditroleApi.json")
|
@ApiOperation(value="用户管理-身份设定(添加和修改接口合并)", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name = "password", value = "初始密码", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "userType", value = "用户类型", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "mobilePhone", value = "手机号", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "area", value = "地区Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "cityId", value = "市Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "roleId", value = "角色Id", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> addEditroleApi(@RequestBody UserEditroleModel userModel,HttpServletRequest request){
|
Map<String, Object> map = new HashMap<>();
|
CoreUser user = sessionUtil.getCurrentUser();
|
String code=user.getCode();
|
if(SessionUtil.ACCESS_SUPPER_ADMIN.equals(code)||SessionUtil.ACCESS_CS_ADMIN.equals(code)){
|
if(StrUtil.isBlank(userModel.getPartnerId())){
|
return JsonResult.failMessage("超管新增或修改用户身份必须选择合伙人！");
|
}
|
}else{
|
CityPartner partner = cityPartnerService.findById(Convert.toInt(user.getId()));
|
if(null!=partner){
|
if(userModel.getUserType().equals(CommonEnum.总部管理员.getValue())){
|
return JsonResult.failMessage("合伙人不能新建总部管理员！");
|
|
}
|
}
|
}
|
if(userModel.getArea()==null&&"".equals(userModel.getArea())){
|
return JsonResult.failMessage("地区不能为空！");
|
}
|
if(userModel.getUserType().equals(CommonEnum.打包员.getValue())){
|
return JsonResult.failMessage("不能新增或修改打包员，请在手机端进行该操作！");
|
}
|
if(userModel.getUserType().equals(CommonEnum.打包站运营员.getValue())){
|
return JsonResult.failMessage("不能新增主打包员，每个打包站只能有一个主打包员！");
|
}
|
if(userModel.getUserType().equals(CommonEnum.入库员.getValue())){
|
if(StrUtil.isBlank(userModel.getStorageId())){
|
return JsonResult.failMessage("仓管员必须关联仓库！");
|
}
|
}
|
//新增 ： 回收员与入库员不能共存
|
int num = userRoleService.addEditroleApi(userModel);
|
if(num>0){
|
map.put("code",0);
|
map.put("changeNum",num);
|
map.put("msg","添加成功");
|
}else if(num==-1){
|
return JsonResult.failMessage("回收员不能与入库员共存！");
|
}else if(num==-2){
|
return JsonResult.failMessage("不能新增打包员！");
|
}else if(num==-3){
|
return JsonResult.failMessage("不能新增打包员！");
|
}else{
|
return JsonResult.failMessage("添加身份，区域不能为空！");
|
}
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("身份设定-"+userModel.getUserId()).build();
|
mqUtil.sendApp(build);
|
|
return JsonResult.success(map);
|
}
|
/**
|
* 查询字典里面的角色
|
* @return
|
*/
|
@PostMapping( "/admin/front/role/queryAllRoleApi.json")
|
@ApiOperation(value="用户管理-身份设定(查询字典里面的角色)", notes="test: 仅0有正确返回")
|
public JsonResult<List<Map<String, Object>>> queryAllRoleApi(){
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
String partnerId= "";
|
if(null!=partnerIds&&partnerIds.size()>0){
|
partnerId = partnerIds.get(0);
|
}
|
List<Map<String, Object>> list = userRoleMapper.queryAllAPPRoleExt(partnerId);
|
return JsonResult.success(list);
|
}
|
|
}
|
