|
@@ -17,7 +17,6 @@ import com.platform.validator.group.UpdateGroup;
|
|
|
import io.swagger.annotations.*;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.shiro.authz.annotation.RequiresPermissions;
|
|
|
-import org.apache.shiro.crypto.hash.Sha256Hash;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.http.ResponseEntity;
|
|
@@ -77,27 +76,27 @@ public class SysUserController extends AbstractController {
|
|
|
|
|
|
/**
|
|
|
* 店铺绑定的用户列表
|
|
|
+ * @return
|
|
|
*/
|
|
|
@GetMapping("/bindList")
|
|
|
@RequiresPermissions("sys:user:list")
|
|
|
- public R userBindList(@RequestParam(name = "deptId") long deptId,
|
|
|
- String key,
|
|
|
- @RequestParam(name = "brandId") long brandId,
|
|
|
- @RequestParam(name = "pageNum") long pageNum,
|
|
|
- @RequestParam(name = "pageSize") long pageSize) {
|
|
|
+ public Result userBindList(@RequestParam(name = "deptId") long deptId,
|
|
|
+ String key,
|
|
|
+ @RequestParam(name = "brandId") long brandId,
|
|
|
+ @RequestParam(name = "pageNum") long pageNum,
|
|
|
+ @RequestParam(name = "pageSize") long pageSize) {
|
|
|
|
|
|
IPage<SysUserEntity> resultPage = sysUserService.getSysUserList(sysDeptService.getSubDeptIdLongList(deptId), key,
|
|
|
brandId , pageNum, pageSize);
|
|
|
if (null == resultPage) {
|
|
|
- return R.error("获取用户列表失败");
|
|
|
+ return Result.failure("获取用户列表失败");
|
|
|
}
|
|
|
resultPage.getRecords().parallelStream().forEach(user->{
|
|
|
if (!ObjectUtils.isEmpty(user.getIsPlatformStreamer()) && user.getIsPlatformStreamer()) {
|
|
|
user.setRoleName("平台主持人");
|
|
|
}
|
|
|
});
|
|
|
- return R.ok(CommonDataUtils.assembleResult(resultPage.getTotal(), resultPage.getPages()
|
|
|
- , resultPage.getCurrent(), resultPage.getRecords()));
|
|
|
+ return Result.success(PageUtilsPlus.page(resultPage));
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -105,7 +104,7 @@ public class SysUserController extends AbstractController {
|
|
|
*/
|
|
|
@GetMapping("/list")
|
|
|
@RequiresPermissions("sys:user:list")
|
|
|
- public R list(@RequestParam Map<String, Object> params) {
|
|
|
+ public Result list(@RequestParam Map<String, Object> params) {
|
|
|
//只有超级管理员,才能查看所有管理员列表
|
|
|
if (getUserId() != Constant.SUPER_ADMIN) {
|
|
|
params.put("deptIdList", sysDeptService.getSubDeptIdList(getDeptId()));
|
|
@@ -126,21 +125,21 @@ public class SysUserController extends AbstractController {
|
|
|
userEntity.setRoleList(curRoleList);
|
|
|
}
|
|
|
);
|
|
|
- PageUtils pageUtil = new PageUtils(userList, total, query.getLimit(), query.getPage());
|
|
|
- return R.ok().put("page", pageUtil);
|
|
|
+ return Result.success( PageUtilsPlus.page(userList, (long) total, (long)query.getLimit(),(long)query.getPage()));
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 员工列表
|
|
|
+ * @return
|
|
|
*/
|
|
|
@ApiOperation("员工列表")
|
|
|
@GetMapping("/staffList")
|
|
|
@RequiresPermissions("sys:user:list")
|
|
|
- public R staffList(String staffName,
|
|
|
- @RequestParam(name = "pageNum") long pageNum,
|
|
|
- @RequestParam(name = "pageSize") long pageSize,
|
|
|
- @RequestParam(name = "deptName",required = false) String deptName,
|
|
|
- @RequestParam(name = "deptId") long deptId) {
|
|
|
+ public Result staffList(String staffName,
|
|
|
+ @RequestParam(name = "pageNum") long pageNum,
|
|
|
+ @RequestParam(name = "pageSize") long pageSize,
|
|
|
+ @RequestParam(name = "deptName",required = false) String deptName,
|
|
|
+ @RequestParam(name = "deptId") long deptId) {
|
|
|
|
|
|
IPage<SysUserEntity> resultPage = null;
|
|
|
|
|
@@ -155,10 +154,9 @@ public class SysUserController extends AbstractController {
|
|
|
}
|
|
|
|
|
|
if (null == resultPage) {
|
|
|
- return R.error("获取员工列表失败");
|
|
|
+ return Result.failure("获取员工列表失败");
|
|
|
}
|
|
|
- return R.ok(CommonDataUtils.assembleResult(resultPage.getTotal(), resultPage.getPages()
|
|
|
- , resultPage.getCurrent(), resultPage.getRecords()));
|
|
|
+ return Result.success(PageUtilsPlus.page(resultPage));
|
|
|
}
|
|
|
|
|
|
@ApiOperation("检验用户是否是四维看看的用户")
|
|
@@ -167,10 +165,10 @@ public class SysUserController extends AbstractController {
|
|
|
@ApiImplicitParams({
|
|
|
@ApiImplicitParam(name = "phoneNum", value = "手机号码", dataType = "String"),
|
|
|
})
|
|
|
- public R getBrandCommentList(@RequestParam(name = "phoneNum") String phoneNum) {
|
|
|
+ public Result getBrandCommentList(@RequestParam(name = "phoneNum") String phoneNum) {
|
|
|
|
|
|
if (StringUtils.isNullOrEmpty(phoneNum)) {
|
|
|
- return R.error("缺少手机号码");
|
|
|
+ return Result.failure("缺少手机号码");
|
|
|
}
|
|
|
Map<String, Object> mp = new HashMap<>();
|
|
|
mp.put("phone", phoneNum);
|
|
@@ -180,21 +178,21 @@ public class SysUserController extends AbstractController {
|
|
|
JSONObject res = JSONObject.parseObject(kankanResult.getBody());
|
|
|
log.info("四维看看返回登录数据:{}", res.toJSONString());
|
|
|
if (!res.containsKey("code")) {
|
|
|
- return R.error("系统故障,请稍后重试");
|
|
|
+ return Result.failure("系统故障,请稍后重试");
|
|
|
}
|
|
|
Boolean exist = res.getBoolean("message");
|
|
|
if (!exist) {
|
|
|
- return R.error("用户不存在!");
|
|
|
+ return Result.failure("用户不存在!");
|
|
|
}
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取登录的用户信息
|
|
|
*/
|
|
|
@GetMapping("/info")
|
|
|
- public R info() {
|
|
|
- return R.ok().put("user", getUser());
|
|
|
+ public Result info() {
|
|
|
+ return Result.success(getUser());
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -202,7 +200,7 @@ public class SysUserController extends AbstractController {
|
|
|
*/
|
|
|
@SysLog("修改密码")
|
|
|
@PostMapping("/bind4dkkUser")
|
|
|
- public R bind4dkkUser(@RequestHeader String token, String fdkkPassword, String fdkkUser) {
|
|
|
+ public Result bind4dkkUser(@RequestHeader String token, String fdkkPassword, String fdkkUser) {
|
|
|
Assert.isBlank(fdkkUser, "手机号不为能空");
|
|
|
Assert.isBlank(fdkkPassword, "密码不为能空");
|
|
|
//更新密码
|
|
@@ -215,7 +213,7 @@ public class SysUserController extends AbstractController {
|
|
|
|
|
|
// 同步数据
|
|
|
sceneService.sync4dkkSceneData(getUser().getMobile(),getUserId());
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -223,7 +221,7 @@ public class SysUserController extends AbstractController {
|
|
|
*/
|
|
|
@SysLog("修改密码")
|
|
|
@PostMapping("/unBind4dkkUser")
|
|
|
- public R unBind4dkkUser(@RequestHeader String token,String fdkkUser) {
|
|
|
+ public Result unBind4dkkUser(@RequestHeader String token,String fdkkUser) {
|
|
|
Assert.isBlank(fdkkUser, "手机号不为能空");
|
|
|
//更新密码
|
|
|
sysUserService.updatePassword(getUser().getMobile(), null, null, fdkkUser);
|
|
@@ -252,26 +250,26 @@ public class SysUserController extends AbstractController {
|
|
|
// 直播间商品删除
|
|
|
goodsService.deleteByBrandId(brandEntity.getId());
|
|
|
});
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 用户信息
|
|
|
*/
|
|
|
@GetMapping("/info/{userId}")
|
|
|
- public R info(@PathVariable("userId") Long userId) {
|
|
|
+ public Result info(@PathVariable("userId") Long userId) {
|
|
|
SysUserEntity user = sysUserService.queryObject(userId);
|
|
|
|
|
|
//获取用户所属的角色列表
|
|
|
List<Long> roleIdList = sysUserRoleService.queryRoleIdList(userId);
|
|
|
user.setRoleIdList(roleIdList);
|
|
|
|
|
|
- return R.ok().put("user", user);
|
|
|
+ return Result.success(user);
|
|
|
}
|
|
|
|
|
|
- @GetMapping("/infoAnon/{userId}")
|
|
|
+ @PostMapping("/infoAnon")
|
|
|
@ResponseBody
|
|
|
- public R infoAnon(@PathVariable("userId") Long userId) {
|
|
|
+ public Result infoAnon(@RequestParam(value = "userId",required = true) Long userId) {
|
|
|
SysUserEntity user = sysUserService.queryObject(userId);
|
|
|
user.setPassword(null);
|
|
|
//获取用户所属的角色列表
|
|
@@ -279,8 +277,7 @@ public class SysUserController extends AbstractController {
|
|
|
if (null != roleIdList) {
|
|
|
user.setRoleIdList(roleIdList);
|
|
|
}
|
|
|
-
|
|
|
- return R.ok().put("user", user);
|
|
|
+ return Result.success(user);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -289,12 +286,12 @@ public class SysUserController extends AbstractController {
|
|
|
@SysLog("保存用户")
|
|
|
@PostMapping("/save")
|
|
|
@RequiresPermissions("sys:user:save")
|
|
|
- public R save(@ApiParam(name = "SysUserEntity对象", value = "传入json格式", required = true) @RequestBody SysUserEntity user) {
|
|
|
+ public Result save(@ApiParam(name = "SysUserEntity对象", value = "传入json格式", required = true) @RequestBody SysUserEntity user) {
|
|
|
ValidatorUtils.validateEntity(user, AddGroup.class);
|
|
|
|
|
|
SysUserEntity sysUserEntity = sysUserService.queryByUserMobile(user.getMobile());
|
|
|
if(null != sysUserEntity){
|
|
|
- return R.error("员工已经存在,请勿重复添加");
|
|
|
+ return Result.failure("员工已经存在,请勿重复添加");
|
|
|
}
|
|
|
|
|
|
user.setCreateUserId(getUserId());
|
|
@@ -305,7 +302,7 @@ public class SysUserController extends AbstractController {
|
|
|
user.setRoleIdList(Collections.singletonList(8L));
|
|
|
}
|
|
|
sysUserService.save(user);
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
|
|
@@ -315,31 +312,31 @@ public class SysUserController extends AbstractController {
|
|
|
@PostMapping("/staffSave")
|
|
|
@RequiresPermissions("sys:user:save")
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public R staffSave(@ApiParam(name = "SysUserEntity对象", value = "传入json格式", required = true) @RequestBody SysUserEntity user) {
|
|
|
+ public Result staffSave(@ApiParam(name = "SysUserEntity对象", value = "传入json格式", required = true) @RequestBody SysUserEntity user) {
|
|
|
ValidatorUtils.validateEntity(user, AddGroup.class);
|
|
|
if(null == user.getDeptId()){
|
|
|
- return R.error("缺失公司数据!");
|
|
|
+ return Result.failure("缺失公司数据!");
|
|
|
}
|
|
|
if(ObjectUtils.isEmpty(user.getRoleId())){
|
|
|
- return R.error("角色为空!");
|
|
|
+ return Result.failure("角色为空!");
|
|
|
}
|
|
|
|
|
|
//TODO:这里需要改成select for update
|
|
|
SysDeptEntity sysDeptEntity = sysDeptService.queryObject(user.getDeptId());
|
|
|
if(null == sysDeptEntity){
|
|
|
- return R.error("公司不存在!");
|
|
|
+ return Result.failure("公司不存在!");
|
|
|
}
|
|
|
int curStaffNum = null != sysDeptEntity.getCurStaffNum() ? sysDeptEntity.getCurStaffNum() : 0;
|
|
|
int maxStaffNum = null != sysDeptEntity.getStaffNum() ? sysDeptEntity.getStaffNum() : 0;
|
|
|
if((curStaffNum + 1) > maxStaffNum){
|
|
|
- return R.error("公司员工已经达到上限!");
|
|
|
+ return Result.failure("公司员工已经达到上限!");
|
|
|
}
|
|
|
|
|
|
user.setCreateUserId(getUserId());
|
|
|
|
|
|
SysUserEntity sysUserEntity = sysUserService.queryByUserMobile(user.getMobile());
|
|
|
if(null != sysUserEntity){
|
|
|
- return R.error("员工已经存在,请勿重复添加!");
|
|
|
+ return Result.failure("员工已经存在,请勿重复添加!");
|
|
|
}
|
|
|
//创建用户,并且创建用户和角色的关联关系
|
|
|
sysUserService.save(user);
|
|
@@ -353,7 +350,7 @@ public class SysUserController extends AbstractController {
|
|
|
|
|
|
sysDeptService.update(sysDeptEntity);
|
|
|
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -362,10 +359,10 @@ public class SysUserController extends AbstractController {
|
|
|
@SysLog("修改用户")
|
|
|
@PostMapping("/update")
|
|
|
@RequiresPermissions("sys:user:update")
|
|
|
- public R update(@RequestBody SysUserEntity user) {
|
|
|
+ public Result update(@RequestBody SysUserEntity user) {
|
|
|
ValidatorUtils.validateEntity(user, UpdateGroup.class);
|
|
|
sysUserService.update(user);
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
@ApiOperation(value = "删除员工")
|
|
@@ -373,26 +370,26 @@ public class SysUserController extends AbstractController {
|
|
|
@PostMapping("/preDeleteStaff")
|
|
|
@RequiresPermissions("sys:user:delete")
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public R preDeleteStaff(@RequestBody Map<String,Long> params) {
|
|
|
+ public Result preDeleteStaff(@RequestBody Map<String,Long> params) {
|
|
|
Long userId = params.get("userId");
|
|
|
if(ObjectUtils.isEmpty(userId)){
|
|
|
- return R.error("参数有误!");
|
|
|
+ return Result.failure("参数有误!");
|
|
|
}
|
|
|
if (userId.equals(-1L)) {
|
|
|
- return R.error("不能删除平台管理员");
|
|
|
+ return Result.failure("不能删除平台管理员");
|
|
|
}
|
|
|
if (getUserId().equals(userId)) {
|
|
|
- return R.error("当前用户不能删除");
|
|
|
+ return Result.failure("当前用户不能删除");
|
|
|
}
|
|
|
|
|
|
SysUserEntity sysUserEntity = sysUserService.queryObject(userId);
|
|
|
if(ObjectUtils.isEmpty(sysUserEntity)){
|
|
|
- return R.error("获取用户信息失败!");
|
|
|
+ return Result.failure("获取用户信息失败!");
|
|
|
}
|
|
|
|
|
|
List<Long> roleList = sysUserRoleService.queryRoleIdList(userId);
|
|
|
if(!CollectionUtils.isEmpty(roleList) && (roleList.contains(6) || roleList.contains(5))){
|
|
|
- return R.error("不能删除平台管理员或者普通管理员");
|
|
|
+ return Result.failure("不能删除平台管理员或者普通管理员");
|
|
|
}
|
|
|
|
|
|
Long deptId = sysUserEntity.getDeptId();
|
|
@@ -400,7 +397,7 @@ public class SysUserController extends AbstractController {
|
|
|
// 更新企业员工信息
|
|
|
long num = sysUserService.getUserNumOfDept(deptId);
|
|
|
if(num <= 1){
|
|
|
- return R.error("删除失败,公司仅剩一个账号");
|
|
|
+ return Result.failure("删除失败,公司仅剩一个账号");
|
|
|
}
|
|
|
// 获取直播间绑定信息
|
|
|
List<Long> bindUsers = mySysUserBrandService.queryBrandIdList(userId);
|
|
@@ -410,12 +407,12 @@ public class SysUserController extends AbstractController {
|
|
|
List<String> phones = userEntities.stream().filter(user -> !user.getUserId().equals(userId))
|
|
|
.map(SysUserEntity::getMobile).collect(Collectors.toList());
|
|
|
if(ObjectUtils.isEmpty(phones)){
|
|
|
- return R.error("删除失败,公司仅剩一名员工,不可进行删除!");
|
|
|
+ return Result.failure("删除失败,公司仅剩一名员工,不可进行删除!");
|
|
|
}
|
|
|
- return R.ok().put("list", phones);
|
|
|
+ return Result.success(phones);
|
|
|
}
|
|
|
}
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
|
|
|
@ApiOperation(value = "删除员工")
|
|
@@ -423,27 +420,27 @@ public class SysUserController extends AbstractController {
|
|
|
@PostMapping("/deleteStaff")
|
|
|
@RequiresPermissions("sys:user:delete")
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public R deleteStaff(@RequestBody Map<String,String> params) {
|
|
|
+ public Result deleteStaff(@RequestBody Map<String,String> params) {
|
|
|
Long userId = Long.parseLong(params.get("userId"));
|
|
|
String toUser = params.get("toUser");
|
|
|
if(ObjectUtils.isEmpty(userId)){
|
|
|
- return R.error("参数有误!");
|
|
|
+ return Result.failure("参数有误!");
|
|
|
}
|
|
|
if (userId.equals(-1L)) {
|
|
|
- return R.error("不能删除平台管理员");
|
|
|
+ return Result.failure("不能删除平台管理员");
|
|
|
}
|
|
|
if (getUserId().equals(userId)) {
|
|
|
- return R.error("当前用户不能删除");
|
|
|
+ return Result.failure("当前用户不能删除");
|
|
|
}
|
|
|
|
|
|
SysUserEntity sysUserEntity = sysUserService.queryObject(userId);
|
|
|
if(ObjectUtils.isEmpty(sysUserEntity)){
|
|
|
- return R.error("获取用户信息失败!");
|
|
|
+ return Result.failure("获取用户信息失败!");
|
|
|
}
|
|
|
|
|
|
List<Long> roleList = sysUserRoleService.queryRoleIdList(userId);
|
|
|
if (!CollectionUtils.isEmpty(roleList) && roleList.contains(5)) {
|
|
|
- return R.error("不能删除平台管理员");
|
|
|
+ return Result.failure("不能删除平台管理员");
|
|
|
}
|
|
|
|
|
|
// 获取情景信息
|
|
@@ -452,11 +449,11 @@ public class SysUserController extends AbstractController {
|
|
|
|
|
|
if (!ObjectUtils.isEmpty(bindUsers)) {
|
|
|
if (ObjectUtils.isEmpty(toUser)) {
|
|
|
- return R.error("没有配置分配用户信息!");
|
|
|
+ return Result.failure("没有配置分配用户信息!");
|
|
|
}
|
|
|
toUserEntity = sysUserService.queryByUserMobile(toUser);
|
|
|
if (ObjectUtils.isEmpty(toUserEntity)) {
|
|
|
- return R.error("分配用户有误!");
|
|
|
+ return Result.failure("分配用户有误!");
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -465,7 +462,7 @@ public class SysUserController extends AbstractController {
|
|
|
if(!ObjectUtils.isEmpty(deptId)){
|
|
|
long num = sysUserService.getUserNumOfDept(deptId);
|
|
|
if(num <= 1){
|
|
|
- return R.error("删除失败,公司仅剩一名员工,不可进行删除");
|
|
|
+ return Result.failure("删除失败,公司仅剩一名员工,不可进行删除");
|
|
|
}
|
|
|
SysDeptEntity sysDeptEntity = sysDeptService.queryObject(deptId);
|
|
|
if(!ObjectUtils.isEmpty(sysDeptEntity)){
|
|
@@ -481,6 +478,6 @@ public class SysUserController extends AbstractController {
|
|
|
|
|
|
// 删除用户信息
|
|
|
sysUserService.deleteBatch(new Long[]{userId});
|
|
|
- return R.ok();
|
|
|
+ return Result.success();
|
|
|
}
|
|
|
}
|