SysUserServiceImpl.java 16 KB

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