From 48d61a3cdf4c0f119456f86d51cd770caf8645e1 Mon Sep 17 00:00:00 2001
From: 疯狂的狮子li <15040126243@163.com>
Date: 星期三, 14 四月 2021 11:19:46 +0800
Subject: [PATCH] update mp化
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java | 60 +++++++++++++++++++++++++++++++++++++++---------------------
1 files changed, 39 insertions(+), 21 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
index 73908c7..74c265c 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
@@ -1,6 +1,8 @@
package com.ruoyi.system.service.impl;
import cn.hutool.core.lang.Validator;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.annotation.DataScope;
import com.ruoyi.common.constant.UserConstants;
@@ -21,6 +23,7 @@
import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.List;
/**
@@ -130,7 +133,7 @@
*/
@Override
public String checkUserNameUnique(String userName) {
- int count = userMapper.checkUserNameUnique(userName);
+ int count = count(new LambdaQueryWrapper<SysUser>().eq(SysUser::getUserName, userName).last("limit 1"));
if (count > 0) {
return UserConstants.NOT_UNIQUE;
}
@@ -146,7 +149,9 @@
@Override
public String checkPhoneUnique(SysUser user) {
Long userId = Validator.isNull(user.getUserId()) ? -1L : user.getUserId();
- SysUser info = userMapper.checkPhoneUnique(user.getPhonenumber());
+ SysUser info = getOne(new LambdaQueryWrapper<SysUser>()
+ .select(SysUser::getUserId, SysUser::getPhonenumber)
+ .eq(SysUser::getPhonenumber, user.getPhonenumber()).last("limit 1"));
if (Validator.isNotNull(info) && info.getUserId().longValue() != userId.longValue()) {
return UserConstants.NOT_UNIQUE;
}
@@ -162,7 +167,9 @@
@Override
public String checkEmailUnique(SysUser user) {
Long userId = Validator.isNull(user.getUserId()) ? -1L : user.getUserId();
- SysUser info = userMapper.checkEmailUnique(user.getEmail());
+ SysUser info = getOne(new LambdaQueryWrapper<SysUser>()
+ .select(SysUser::getUserId, SysUser::getEmail)
+ .eq(SysUser::getEmail, user.getEmail()).last("limit 1"));
if (Validator.isNotNull(info) && info.getUserId().longValue() != userId.longValue()) {
return UserConstants.NOT_UNIQUE;
}
@@ -191,7 +198,7 @@
@Transactional
public int insertUser(SysUser user) {
// 鏂板鐢ㄦ埛淇℃伅
- int rows = userMapper.insertUser(user);
+ int rows = userMapper.insert(user);
// 鏂板鐢ㄦ埛宀椾綅鍏宠仈
insertUserPost(user);
// 鏂板鐢ㄦ埛涓庤鑹茬鐞�
@@ -210,14 +217,14 @@
public int updateUser(SysUser user) {
Long userId = user.getUserId();
// 鍒犻櫎鐢ㄦ埛涓庤鑹插叧鑱�
- userRoleMapper.deleteUserRoleByUserId(userId);
+ userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>().eq(SysUserRole::getUserId,userId));
// 鏂板鐢ㄦ埛涓庤鑹茬鐞�
insertUserRole(user);
// 鍒犻櫎鐢ㄦ埛涓庡矖浣嶅叧鑱�
- userPostMapper.deleteUserPostByUserId(userId);
+ userPostMapper.delete(new LambdaQueryWrapper<SysUserPost>().eq(SysUserPost::getUserId,userId));
// 鏂板鐢ㄦ埛涓庡矖浣嶇鐞�
insertUserPost(user);
- return userMapper.updateUser(user);
+ return userMapper.updateById(user);
}
/**
@@ -228,7 +235,7 @@
*/
@Override
public int updateUserStatus(SysUser user) {
- return userMapper.updateUser(user);
+ return userMapper.updateById(user);
}
/**
@@ -239,7 +246,7 @@
*/
@Override
public int updateUserProfile(SysUser user) {
- return userMapper.updateUser(user);
+ return userMapper.updateById(user);
}
/**
@@ -251,7 +258,10 @@
*/
@Override
public boolean updateUserAvatar(String userName, String avatar) {
- return userMapper.updateUserAvatar(userName, avatar) > 0;
+ return userMapper.update(null,
+ new LambdaUpdateWrapper<SysUser>()
+ .set(SysUser::getAvatar,avatar)
+ .eq(SysUser::getUserName,userName)) > 0;
}
/**
@@ -262,7 +272,7 @@
*/
@Override
public int resetPwd(SysUser user) {
- return userMapper.updateUser(user);
+ return userMapper.updateById(user);
}
/**
@@ -274,7 +284,10 @@
*/
@Override
public int resetUserPwd(String userName, String password) {
- return userMapper.resetUserPwd(userName, password);
+ return userMapper.update(null,
+ new LambdaUpdateWrapper<SysUser>()
+ .set(SysUser::getPassword,password)
+ .eq(SysUser::getUserName,userName));
}
/**
@@ -294,7 +307,9 @@
list.add(ur);
}
if (list.size() > 0) {
- userRoleMapper.batchUserRole(list);
+ for (SysUserRole sysUserRole : list) {
+ userRoleMapper.insert(sysUserRole);
+ }
}
}
}
@@ -316,7 +331,9 @@
list.add(up);
}
if (list.size() > 0) {
- userPostMapper.batchUserPost(list);
+ for (SysUserPost sysUserPost : list) {
+ userPostMapper.insert(sysUserPost);
+ }
}
}
}
@@ -331,10 +348,10 @@
@Transactional
public int deleteUserById(Long userId) {
// 鍒犻櫎鐢ㄦ埛涓庤鑹插叧鑱�
- userRoleMapper.deleteUserRoleByUserId(userId);
+ userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>().eq(SysUserRole::getUserId,userId));
// 鍒犻櫎鐢ㄦ埛涓庡矖浣嶈〃
- userPostMapper.deleteUserPostByUserId(userId);
- return userMapper.deleteUserById(userId);
+ userPostMapper.delete(new LambdaQueryWrapper<SysUserPost>().eq(SysUserPost::getUserId,userId));
+ return userMapper.deleteById(userId);
}
/**
@@ -349,11 +366,12 @@
for (Long userId : userIds) {
checkUserAllowed(new SysUser(userId));
}
+ List<Long> ids = Arrays.asList(userIds);
// 鍒犻櫎鐢ㄦ埛涓庤鑹插叧鑱�
- userRoleMapper.deleteUserRole(userIds);
- // 鍒犻櫎鐢ㄦ埛涓庡矖浣嶅叧鑱�
- userPostMapper.deleteUserPost(userIds);
- return userMapper.deleteUserByIds(userIds);
+ userRoleMapper.delete(new LambdaQueryWrapper<SysUserRole>().in(SysUserRole::getUserId,ids));
+ // 鍒犻櫎鐢ㄦ埛涓庡矖浣嶈〃
+ userPostMapper.delete(new LambdaQueryWrapper<SysUserPost>().in(SysUserPost::getUserId,ids));
+ return userMapper.deleteBatchIds(ids);
}
/**
--
Gitblit v1.9.3