SysUserServiceImpl.java 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555
  1. package com.ruoyi.system.service.impl;
  2. import java.util.ArrayList;
  3. import java.util.List;
  4. import java.util.stream.Collectors;
  5. import org.slf4j.Logger;
  6. import org.slf4j.LoggerFactory;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.stereotype.Service;
  9. import org.springframework.transaction.annotation.Transactional;
  10. import com.ruoyi.common.annotation.DataScope;
  11. import com.ruoyi.common.constant.UserConstants;
  12. import com.ruoyi.common.core.domain.entity.SysRole;
  13. import com.ruoyi.common.core.domain.entity.SysUser;
  14. import com.ruoyi.common.exception.ServiceException;
  15. import com.ruoyi.common.utils.SecurityUtils;
  16. import com.ruoyi.common.utils.StringUtils;
  17. import com.ruoyi.common.utils.spring.SpringUtils;
  18. import com.ruoyi.system.domain.SysPost;
  19. import com.ruoyi.system.domain.SysUserPost;
  20. import com.ruoyi.system.domain.SysUserRole;
  21. import com.ruoyi.system.mapper.SysPostMapper;
  22. import com.ruoyi.system.mapper.SysRoleMapper;
  23. import com.ruoyi.system.mapper.SysUserMapper;
  24. import com.ruoyi.system.mapper.SysUserPostMapper;
  25. import com.ruoyi.system.mapper.SysUserRoleMapper;
  26. import com.ruoyi.system.service.ISysConfigService;
  27. import com.ruoyi.system.service.ISysUserService;
  28. import org.springframework.util.CollectionUtils;
  29. /**
  30. * 用户 业务层处理
  31. *
  32. * @author ruoyi
  33. */
  34. @Service
  35. public class SysUserServiceImpl implements ISysUserService
  36. {
  37. private static final Logger log = LoggerFactory.getLogger(SysUserServiceImpl.class);
  38. @Autowired
  39. private SysUserMapper userMapper;
  40. @Autowired
  41. private SysRoleMapper roleMapper;
  42. @Autowired
  43. private SysPostMapper postMapper;
  44. @Autowired
  45. private SysUserRoleMapper userRoleMapper;
  46. @Autowired
  47. private SysUserPostMapper userPostMapper;
  48. @Autowired
  49. private ISysConfigService configService;
  50. /**
  51. * 根据条件分页查询用户列表
  52. *
  53. * @param user 用户信息
  54. * @return 用户信息集合信息
  55. */
  56. @Override
  57. @DataScope(deptAlias = "d", userAlias = "u")
  58. public List<SysUser> selectUserList(SysUser user)
  59. {
  60. return userMapper.selectUserList(user);
  61. }
  62. /**
  63. * 根据条件分页查询已分配用户角色列表
  64. *
  65. * @param user 用户信息
  66. * @return 用户信息集合信息
  67. */
  68. @Override
  69. @DataScope(deptAlias = "d", userAlias = "u")
  70. public List<SysUser> selectAllocatedList(SysUser user)
  71. {
  72. return userMapper.selectAllocatedList(user);
  73. }
  74. /**
  75. * 根据条件分页查询未分配用户角色列表
  76. *
  77. * @param user 用户信息
  78. * @return 用户信息集合信息
  79. */
  80. @Override
  81. @DataScope(deptAlias = "d", userAlias = "u")
  82. public List<SysUser> selectUnallocatedList(SysUser user)
  83. {
  84. return userMapper.selectUnallocatedList(user);
  85. }
  86. /**
  87. * 通过用户名查询用户
  88. *
  89. * @param userName 用户名
  90. * @return 用户对象信息
  91. */
  92. @Override
  93. public SysUser selectUserByUserName(String userName)
  94. {
  95. return userMapper.selectUserByUserName(userName);
  96. }
  97. /**
  98. * 通过用户ID查询用户
  99. *
  100. * @param userId 用户ID
  101. * @return 用户对象信息
  102. */
  103. @Override
  104. public SysUser selectUserById(Long userId)
  105. {
  106. return userMapper.selectUserById(userId);
  107. }
  108. /**
  109. * 查询用户所属角色组
  110. *
  111. * @param userName 用户名
  112. * @return 结果
  113. */
  114. @Override
  115. public String selectUserRoleGroup(String userName)
  116. {
  117. List<SysRole> list = roleMapper.selectRolesByUserName(userName);
  118. if (CollectionUtils.isEmpty(list))
  119. {
  120. return StringUtils.EMPTY;
  121. }
  122. return list.stream().map(SysRole::getRoleName).collect(Collectors.joining(","));
  123. }
  124. /**
  125. * 查询用户所属岗位组
  126. *
  127. * @param userName 用户名
  128. * @return 结果
  129. */
  130. @Override
  131. public String selectUserPostGroup(String userName)
  132. {
  133. List<SysPost> list = postMapper.selectPostsByUserName(userName);
  134. if (CollectionUtils.isEmpty(list))
  135. {
  136. return StringUtils.EMPTY;
  137. }
  138. return list.stream().map(SysPost::getPostName).collect(Collectors.joining(","));
  139. }
  140. /**
  141. * 校验用户名称是否唯一
  142. *
  143. * @param userName 用户名称
  144. * @return 结果
  145. */
  146. @Override
  147. public String checkUserNameUnique(String userName)
  148. {
  149. int count = userMapper.checkUserNameUnique(userName);
  150. if (count > 0)
  151. {
  152. return UserConstants.NOT_UNIQUE;
  153. }
  154. return UserConstants.UNIQUE;
  155. }
  156. /**
  157. * 校验手机号码是否唯一
  158. *
  159. * @param user 用户信息
  160. * @return
  161. */
  162. @Override
  163. public String checkPhoneUnique(SysUser user)
  164. {
  165. Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
  166. SysUser info = userMapper.checkPhoneUnique(user.getPhonenumber());
  167. if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())
  168. {
  169. return UserConstants.NOT_UNIQUE;
  170. }
  171. return UserConstants.UNIQUE;
  172. }
  173. /**
  174. * 校验email是否唯一
  175. *
  176. * @param user 用户信息
  177. * @return
  178. */
  179. @Override
  180. public String checkEmailUnique(SysUser user)
  181. {
  182. Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
  183. SysUser info = userMapper.checkEmailUnique(user.getEmail());
  184. if (StringUtils.isNotNull(info) && info.getUserId().longValue() != userId.longValue())
  185. {
  186. return UserConstants.NOT_UNIQUE;
  187. }
  188. return UserConstants.UNIQUE;
  189. }
  190. /**
  191. * 校验用户是否允许操作
  192. *
  193. * @param user 用户信息
  194. */
  195. @Override
  196. public void checkUserAllowed(SysUser user)
  197. {
  198. if (StringUtils.isNotNull(user.getUserId()) && user.isAdmin())
  199. {
  200. throw new ServiceException("不允许操作超级管理员用户");
  201. }
  202. }
  203. /**
  204. * 校验用户是否有数据权限
  205. *
  206. * @param userId 用户id
  207. */
  208. @Override
  209. public void checkUserDataScope(Long userId)
  210. {
  211. if (!SysUser.isAdmin(SecurityUtils.getUserId()))
  212. {
  213. SysUser user = new SysUser();
  214. user.setUserId(userId);
  215. List<SysUser> users = SpringUtils.getAopProxy(this).selectUserList(user);
  216. if (StringUtils.isEmpty(users))
  217. {
  218. throw new ServiceException("没有权限访问用户数据!");
  219. }
  220. }
  221. }
  222. /**
  223. * 新增保存用户信息
  224. *
  225. * @param user 用户信息
  226. * @return 结果
  227. */
  228. @Override
  229. @Transactional
  230. public int insertUser(SysUser user)
  231. {
  232. // 新增用户信息
  233. int rows = userMapper.insertUser(user);
  234. // 新增用户岗位关联
  235. insertUserPost(user);
  236. // 新增用户与角色管理
  237. insertUserRole(user);
  238. return rows;
  239. }
  240. /**
  241. * 注册用户信息
  242. *
  243. * @param user 用户信息
  244. * @return 结果
  245. */
  246. @Override
  247. public boolean registerUser(SysUser user)
  248. {
  249. return userMapper.insertUser(user) > 0;
  250. }
  251. /**
  252. * 修改保存用户信息
  253. *
  254. * @param user 用户信息
  255. * @return 结果
  256. */
  257. @Override
  258. @Transactional
  259. public int updateUser(SysUser user)
  260. {
  261. Long userId = user.getUserId();
  262. // 删除用户与角色关联
  263. userRoleMapper.deleteUserRoleByUserId(userId);
  264. // 新增用户与角色管理
  265. insertUserRole(user);
  266. // 删除用户与岗位关联
  267. userPostMapper.deleteUserPostByUserId(userId);
  268. // 新增用户与岗位管理
  269. insertUserPost(user);
  270. return userMapper.updateUser(user);
  271. }
  272. /**
  273. * 用户授权角色
  274. *
  275. * @param userId 用户ID
  276. * @param roleIds 角色组
  277. */
  278. @Override
  279. @Transactional
  280. public void insertUserAuth(Long userId, Long[] roleIds)
  281. {
  282. userRoleMapper.deleteUserRoleByUserId(userId);
  283. insertUserRole(userId, roleIds);
  284. }
  285. /**
  286. * 修改用户状态
  287. *
  288. * @param user 用户信息
  289. * @return 结果
  290. */
  291. @Override
  292. public int updateUserStatus(SysUser user)
  293. {
  294. return userMapper.updateUser(user);
  295. }
  296. /**
  297. * 修改用户基本信息
  298. *
  299. * @param user 用户信息
  300. * @return 结果
  301. */
  302. @Override
  303. public int updateUserProfile(SysUser user)
  304. {
  305. return userMapper.updateUser(user);
  306. }
  307. /**
  308. * 修改用户头像
  309. *
  310. * @param userName 用户名
  311. * @param avatar 头像地址
  312. * @return 结果
  313. */
  314. @Override
  315. public boolean updateUserAvatar(String userName, String avatar)
  316. {
  317. return userMapper.updateUserAvatar(userName, avatar) > 0;
  318. }
  319. /**
  320. * 重置用户密码
  321. *
  322. * @param user 用户信息
  323. * @return 结果
  324. */
  325. @Override
  326. public int resetPwd(SysUser user)
  327. {
  328. return userMapper.updateUser(user);
  329. }
  330. /**
  331. * 重置用户密码
  332. *
  333. * @param userName 用户名
  334. * @param password 密码
  335. * @return 结果
  336. */
  337. @Override
  338. public int resetUserPwd(String userName, String password)
  339. {
  340. return userMapper.resetUserPwd(userName, password);
  341. }
  342. /**
  343. * 新增用户角色信息
  344. *
  345. * @param user 用户对象
  346. */
  347. public void insertUserRole(SysUser user)
  348. {
  349. Long[] roles = user.getRoleIds();
  350. if (StringUtils.isNotNull(roles))
  351. {
  352. // 新增用户与角色管理
  353. List<SysUserRole> list = new ArrayList<SysUserRole>();
  354. for (Long roleId : roles)
  355. {
  356. SysUserRole ur = new SysUserRole();
  357. ur.setUserId(user.getUserId());
  358. ur.setRoleId(roleId);
  359. list.add(ur);
  360. }
  361. if (list.size() > 0)
  362. {
  363. userRoleMapper.batchUserRole(list);
  364. }
  365. }
  366. }
  367. /**
  368. * 新增用户岗位信息
  369. *
  370. * @param user 用户对象
  371. */
  372. public void insertUserPost(SysUser user)
  373. {
  374. Long[] posts = user.getPostIds();
  375. if (StringUtils.isNotNull(posts))
  376. {
  377. // 新增用户与岗位管理
  378. List<SysUserPost> list = new ArrayList<SysUserPost>();
  379. for (Long postId : posts)
  380. {
  381. SysUserPost up = new SysUserPost();
  382. up.setUserId(user.getUserId());
  383. up.setPostId(postId);
  384. list.add(up);
  385. }
  386. if (list.size() > 0)
  387. {
  388. userPostMapper.batchUserPost(list);
  389. }
  390. }
  391. }
  392. /**
  393. * 新增用户角色信息
  394. *
  395. * @param userId 用户ID
  396. * @param roleIds 角色组
  397. */
  398. public void insertUserRole(Long userId, Long[] roleIds)
  399. {
  400. if (StringUtils.isNotNull(roleIds))
  401. {
  402. // 新增用户与角色管理
  403. List<SysUserRole> list = new ArrayList<SysUserRole>();
  404. for (Long roleId : roleIds)
  405. {
  406. SysUserRole ur = new SysUserRole();
  407. ur.setUserId(userId);
  408. ur.setRoleId(roleId);
  409. list.add(ur);
  410. }
  411. if (list.size() > 0)
  412. {
  413. userRoleMapper.batchUserRole(list);
  414. }
  415. }
  416. }
  417. /**
  418. * 通过用户ID删除用户
  419. *
  420. * @param userId 用户ID
  421. * @return 结果
  422. */
  423. @Override
  424. @Transactional
  425. public int deleteUserById(Long userId)
  426. {
  427. // 删除用户与角色关联
  428. userRoleMapper.deleteUserRoleByUserId(userId);
  429. // 删除用户与岗位表
  430. userPostMapper.deleteUserPostByUserId(userId);
  431. return userMapper.deleteUserById(userId);
  432. }
  433. /**
  434. * 批量删除用户信息
  435. *
  436. * @param userIds 需要删除的用户ID
  437. * @return 结果
  438. */
  439. @Override
  440. @Transactional
  441. public int deleteUserByIds(Long[] userIds)
  442. {
  443. for (Long userId : userIds)
  444. {
  445. checkUserAllowed(new SysUser(userId));
  446. }
  447. // 删除用户与角色关联
  448. userRoleMapper.deleteUserRole(userIds);
  449. // 删除用户与岗位关联
  450. userPostMapper.deleteUserPost(userIds);
  451. return userMapper.deleteUserByIds(userIds);
  452. }
  453. /**
  454. * 导入用户数据
  455. *
  456. * @param userList 用户数据列表
  457. * @param isUpdateSupport 是否更新支持,如果已存在,则进行更新数据
  458. * @param operName 操作用户
  459. * @return 结果
  460. */
  461. @Override
  462. public String importUser(List<SysUser> userList, Boolean isUpdateSupport, String operName)
  463. {
  464. if (StringUtils.isNull(userList) || userList.size() == 0)
  465. {
  466. throw new ServiceException("导入用户数据不能为空!");
  467. }
  468. int successNum = 0;
  469. int failureNum = 0;
  470. StringBuilder successMsg = new StringBuilder();
  471. StringBuilder failureMsg = new StringBuilder();
  472. String password = configService.selectConfigByKey("sys.user.initPassword");
  473. for (SysUser user : userList)
  474. {
  475. try
  476. {
  477. // 验证是否存在这个用户
  478. SysUser u = userMapper.selectUserByUserName(user.getUserName());
  479. if (StringUtils.isNull(u))
  480. {
  481. user.setPassword(SecurityUtils.encryptPassword(password));
  482. user.setCreateBy(operName);
  483. this.insertUser(user);
  484. successNum++;
  485. successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 导入成功");
  486. }
  487. else if (isUpdateSupport)
  488. {
  489. user.setUpdateBy(operName);
  490. this.updateUser(user);
  491. successNum++;
  492. successMsg.append("<br/>" + successNum + "、账号 " + user.getUserName() + " 更新成功");
  493. }
  494. else
  495. {
  496. failureNum++;
  497. failureMsg.append("<br/>" + failureNum + "、账号 " + user.getUserName() + " 已存在");
  498. }
  499. }
  500. catch (Exception e)
  501. {
  502. failureNum++;
  503. String msg = "<br/>" + failureNum + "、账号 " + user.getUserName() + " 导入失败:";
  504. failureMsg.append(msg + e.getMessage());
  505. log.error(msg, e);
  506. }
  507. }
  508. if (failureNum > 0)
  509. {
  510. failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
  511. throw new ServiceException(failureMsg.toString());
  512. }
  513. else
  514. {
  515. successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
  516. }
  517. return successMsg.toString();
  518. }
  519. }