SysUserController.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677
  1. package com.xunmei.system.controller;
  2. import cn.hutool.core.util.ObjectUtil;
  3. import com.alibaba.excel.EasyExcel;
  4. import com.alibaba.excel.context.AnalysisContext;
  5. import com.alibaba.excel.event.AnalysisEventListener;
  6. import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;
  7. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  8. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  9. import com.xunmei.common.core.domain.R;
  10. import com.xunmei.common.core.domain.message.domain.CoreAnnouncementNotificationToRole;
  11. import com.xunmei.common.core.utils.DateUtils;
  12. import com.xunmei.common.core.utils.StringUtils;
  13. import com.xunmei.common.core.vo.IdNameVo;
  14. import com.xunmei.common.core.web.controller.BaseController;
  15. import com.xunmei.common.core.web.domain.AjaxResult;
  16. import com.xunmei.common.core.web.page.TableDataInfo;
  17. import com.xunmei.common.log.annotation.Log;
  18. import com.xunmei.common.log.enums.BusinessType;
  19. import com.xunmei.common.security.annotation.InnerAuth;
  20. import com.xunmei.common.security.annotation.RequiresPermissions;
  21. import com.xunmei.common.security.utils.SaltHelper;
  22. import com.xunmei.common.security.utils.SecurityUtils;
  23. import com.xunmei.system.api.domain.*;
  24. import com.xunmei.system.api.model.LoginUser;
  25. import com.xunmei.system.domain.SysUserRole;
  26. import com.xunmei.system.domain.vo.SysUserListVo;
  27. import com.xunmei.system.domain.vo.UserRoleVo;
  28. import com.xunmei.system.api.dto.SysPlanOrgDTO;
  29. import com.xunmei.system.mapper.SysOrgMapper;
  30. import com.xunmei.system.service.*;
  31. import com.xunmei.system.util.UserExport;
  32. import com.xunmei.system.util.UserImport;
  33. import io.swagger.annotations.ApiOperation;
  34. import org.apache.commons.lang3.ArrayUtils;
  35. import org.springframework.beans.BeanUtils;
  36. import org.springframework.beans.factory.annotation.Autowired;
  37. import org.springframework.transaction.annotation.Transactional;
  38. import org.springframework.validation.annotation.Validated;
  39. import org.springframework.web.bind.annotation.*;
  40. import org.springframework.web.multipart.MultipartFile;
  41. import javax.servlet.http.HttpServletResponse;
  42. import java.io.File;
  43. import java.io.IOException;
  44. import java.net.URLEncoder;
  45. import java.util.*;
  46. import java.util.concurrent.atomic.AtomicInteger;
  47. import java.util.stream.Collectors;
  48. /**
  49. * 用户信息
  50. *
  51. * @author xunmei
  52. */
  53. @RestController
  54. @RequestMapping("/user")
  55. public class SysUserController extends BaseController {
  56. @Autowired
  57. private ISysUserService userService;
  58. @Autowired
  59. private ISysRoleService roleService;
  60. @Autowired
  61. private ISysDeptService deptService;
  62. @Autowired
  63. private ISysPostService postService;
  64. @Autowired
  65. private ISysPermissionService permissionService;
  66. @Autowired
  67. private ISysConfigService configService;
  68. @Autowired
  69. private ISysUserRoleService sysUserRoleService;
  70. @Autowired
  71. private ISysUserInformationService sysUserInformationService;
  72. @Autowired
  73. private SysOrgMapper orgMapper;
  74. /**
  75. * 获取用户列表
  76. */
  77. @RequiresPermissions("system:user:list")
  78. @GetMapping("/list")
  79. public AjaxResult list(SysUser user) {
  80. AjaxResult ajax = AjaxResult.success();
  81. com.xunmei.common.core.web.page.TableDataInfo<com.xunmei.system.api.domain.SysUser> sysUserTableDataInfo = userService.selectUserList(user);
  82. ajax.put("data", sysUserTableDataInfo);
  83. boolean admin = false;
  84. SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
  85. if (null != sysUser && "Y".equals(sysUser.getIsManage())) {
  86. admin = true;
  87. }
  88. ajax.put("check", admin);
  89. String orgName="福建农信";
  90. if (null!=user.getOrgId()){
  91. SysOrg sysOrg = orgMapper.selectSysOrgById(user.getOrgId());
  92. orgName=sysOrg.getShortName();
  93. }
  94. ajax.put("orgName",orgName);
  95. return ajax;
  96. }
  97. /**
  98. * 获取用户列表
  99. */
  100. @RequiresPermissions("system:user:list")
  101. @GetMapping("/userselector/list")
  102. public AjaxResult userSelectorList(SysUser user) {
  103. TableDataInfo<SysUser> sysUserTableDataInfo = userService.userSelectorList(user);
  104. return success(sysUserTableDataInfo);
  105. }
  106. @RequiresPermissions("system:user:list")
  107. @GetMapping("/dictionlist")
  108. public R<List<SysUser>> list2(SysUser user) {
  109. try {
  110. if (ObjectUtil.isEmpty(user.getOrgId())) {
  111. user.setOrgId(SecurityUtils.getLoginUser().getOrgId());
  112. }
  113. return R.ok(userService.selectSyncUserList(user));
  114. } catch (Exception e) {
  115. return R.fail(e.getMessage());
  116. }
  117. }
  118. // @RequiresPermissions("system:user:list")
  119. @GetMapping("/userListData")
  120. public R<List<SysUser>> userListData(SysUser user) {
  121. if (ObjectUtil.isEmpty(user.getOrgId())) {
  122. user.setOrgId(SecurityUtils.getLoginUser().getOrgId());
  123. }
  124. return R.ok(userService.selectUserListData(user));
  125. }
  126. /**
  127. * 获取当前用户信息
  128. */
  129. @InnerAuth
  130. @GetMapping("/info/{username}")
  131. public R<LoginUser> info(@PathVariable("username") String username) {
  132. SysUser sysUser = userService.selectUserByUserName(username);
  133. if (StringUtils.isNull(sysUser)) {
  134. return R.fail("用户名或密码错误");
  135. }
  136. //获取当前用户的角色数据。
  137. List<SysRole> sysRoles = roleService.selectRolesByUserId(sysUser.getId());
  138. sysUser.setRoles(sysRoles);
  139. // 角色集合
  140. Set<String> roles = permissionService.getRolePermission(sysUser);
  141. // 权限集合
  142. Set<String> permissions = permissionService.getMenuPermission(sysUser);
  143. LoginUser sysUserVo = new LoginUser();
  144. sysUserVo.setOrgId(sysUser.getOrgId());
  145. sysUserVo.setName(sysUser.getName());
  146. sysUserVo.setSysUser(sysUser);
  147. sysUserVo.setRoles(roles);
  148. sysUserVo.setPermissions(permissions);
  149. return R.ok(sysUserVo);
  150. }
  151. /**
  152. * 注册用户信息
  153. */
  154. @InnerAuth
  155. @PostMapping("/register")
  156. public R<Boolean> register(@RequestBody SysUser sysUser) {
  157. String username = sysUser.getUsername();
  158. if (!("true".equals(configService.selectConfigByKey("sys.account.registerUser")))) {
  159. return R.fail("当前系统没有开启注册功能!");
  160. }
  161. if (!userService.checkUserNameUnique(sysUser)) {
  162. return R.fail("保存用户'" + username + "'失败,注册账号已存在");
  163. }
  164. return R.ok(userService.registerUser(sysUser));
  165. }
  166. /**
  167. * 获取用户信息
  168. *
  169. * @return 用户信息
  170. */
  171. @GetMapping("getInfo")
  172. public AjaxResult getInfo() {
  173. SysUser user = userService.selectUserById(SecurityUtils.getUserId());
  174. SysOrg org = orgMapper.selectOne(new LambdaQueryWrapper<SysOrg>()
  175. .eq(SysOrg::getId, user.getOrgId())
  176. .select(SysOrg::getType, SysOrg::getShortName));
  177. if (ObjectUtil.isNotEmpty(org)) {
  178. user.setOrgType(org.getType());
  179. user.setOrgShortName(org.getShortName());
  180. }
  181. // 角色集合
  182. Set<String> roles = permissionService.getRolePermission(user);
  183. // 权限集合
  184. Set<String> permissions = permissionService.getMenuPermission(user);
  185. List<UserRoleVo> userRoleVos = sysUserRoleService.selectUserRoleVoList(user.getId());
  186. AjaxResult ajax = AjaxResult.success();
  187. ajax.put("user", user);
  188. ajax.put("roles", roles);
  189. //用户角色信息
  190. ajax.put("roleList", userRoleVos);
  191. ajax.put("permissions", permissions);
  192. return ajax;
  193. }
  194. /**
  195. * 根据用户编号获取详细信息
  196. */
  197. @RequiresPermissions("system:user:query")
  198. @GetMapping(value = {"/", "/{userId}"})
  199. public AjaxResult getInfo(@PathVariable(value = "userId", required = false) Long userId) {
  200. userService.checkUserDataScope(userId);
  201. AjaxResult ajax = AjaxResult.success();
  202. List<SysRole> roles = roleService.selectRoleAll();
  203. ajax.put("roles", roles);
  204. ajax.put("posts", null);
  205. if (StringUtils.isNotNull(userId)) {
  206. SysUserInformation informationByUserId = sysUserInformationService.getInformationByUserId(userId);
  207. if (null == informationByUserId) {
  208. informationByUserId = new SysUserInformation();
  209. }
  210. SysUser sysUser = userService.selectUserById(userId);
  211. sysUser.setOrgId(sysUser.getOriginalOrgId());
  212. List<SysUserRole> userRoles = sysUserRoleService.list(new QueryWrapper<SysUserRole>().eq("user_id", userId));
  213. sysUser.setRoles(roles);
  214. String sex = "-";
  215. String status = "禁用";
  216. if (null != sysUser) {
  217. if (null != sysUser.getGender()) {
  218. if (sysUser.getGender().equals("1")) {
  219. sex = "女";
  220. } else {
  221. sex = "男";
  222. }
  223. }
  224. if (sysUser.getIsLock().equals("0")) {
  225. status = "启用";
  226. }
  227. }
  228. ajax.put(AjaxResult.DATA_TAG, sysUser);
  229. ajax.put("information", informationByUserId);
  230. ajax.put("postIds", null);
  231. ajax.put("roleIds", userRoles.stream().map(SysUserRole::getRoleId).collect(Collectors.toList()));
  232. ajax.put("roleName", roleService.getRoleName(userId));
  233. ajax.put("sex", sex);
  234. ajax.put("status", status);
  235. ajax.put("source", sysUser.getSource());
  236. }
  237. return ajax;
  238. }
  239. /**
  240. * 新增用户
  241. */
  242. @RequiresPermissions("system:user:add")
  243. @Log(title = "用户管理", businessType = BusinessType.INSERT)
  244. @PostMapping
  245. @Transactional(rollbackFor = Exception.class)
  246. public AjaxResult add(@Validated @RequestBody SysUser user) {
  247. if (!userService.checkUserNameUnique(user)) {
  248. return error("新增用户'" + user.getUsername() + "'失败,账号已存在");
  249. } else if (StringUtils.isNotEmpty(user.getPhone()) && !userService.checkPhoneUnique(user)) {
  250. return error("新增用户'" + user.getUsername() + "'失败,手机号码已存在");
  251. }
  252. user.setCreateBy(SecurityUtils.getUsername());
  253. user.setSource(0);
  254. user.setCreateTime(new Date());
  255. //isp的加密方式
  256. final String salt = SaltHelper.salt();
  257. user.setSalt(salt);
  258. user.setPassword(SaltHelper.exec(user.getPassword(), salt));
  259. user.setOriginalOrgId(user.getOrgId());
  260. userService.insertUser(user);
  261. return AjaxResult.success();
  262. }
  263. @GetMapping("/selectrolesByOrgId")
  264. public AjaxResult selectrolesByOrgId(Long orgId) {
  265. return AjaxResult.success(userService.selectrolesByOrgId(orgId));
  266. }
  267. /**
  268. * 修改用户
  269. */
  270. @RequiresPermissions("system:user:edit")
  271. @Log(title = "用户管理", businessType = BusinessType.UPDATE)
  272. @PutMapping
  273. public AjaxResult edit(@Validated @RequestBody SysUser user) {
  274. userService.checkUserAllowed(user);
  275. userService.checkUserDataScope(user.getId());
  276. if (!userService.checkUserNameUnique(user)) {
  277. return error("修改用户'" + user.getUsername() + "'失败,账号已存在");
  278. } else if (StringUtils.isNotEmpty(user.getPhone()) && !userService.checkPhoneUnique(user)) {
  279. return error("修改用户'" + user.getUsername() + "'失败,手机号码已存在");
  280. }
  281. if (user.getRoleIds() != null && user.getRoleIds().length > 0) {
  282. sysUserRoleService.remove(new QueryWrapper<SysUserRole>().eq("user_id", user.getId()));
  283. for (Long roleId :
  284. user.getRoleIds()) {
  285. SysUserRole sysUserRole = new SysUserRole();
  286. sysUserRole.setUserId(user.getId());
  287. sysUserRole.setRoleId(roleId);
  288. sysUserRole.setCreateTime(new Date());
  289. sysUserRoleService.insertSysUserRole(sysUserRole);
  290. }
  291. }
  292. user.setOriginalOrgId(user.getOrgId());
  293. user.setUpdateBy(SecurityUtils.getUsername());
  294. return toAjax(userService.updateUser(user));
  295. }
  296. /**
  297. * 删除用户
  298. */
  299. @RequiresPermissions("system:user:remove")
  300. @Log(title = "用户管理", businessType = BusinessType.DELETE)
  301. @DeleteMapping("/{userIds}")
  302. public AjaxResult remove(@PathVariable Long[] userIds) {
  303. if (ArrayUtils.contains(userIds, SecurityUtils.getUserId())) {
  304. return error("当前用户不能删除");
  305. }
  306. return toAjax(userService.deleteUserByIds(userIds));
  307. }
  308. /**
  309. * 重置密码
  310. */
  311. @RequiresPermissions("system:user:edit")
  312. @Log(title = "用户管理", businessType = BusinessType.UPDATE)
  313. @PutMapping("/resetPwd")
  314. public AjaxResult resetPwd(@RequestBody SysUser user) {
  315. userService.checkUserAllowed(user);
  316. userService.checkUserDataScope(user.getId());
  317. final String salt = SaltHelper.salt();
  318. user.setSalt(salt);
  319. // user.setPassword(SaltHelper.exec(user.getPassword(), userService.selectUserById(user.getId()).getSalt()));
  320. user.setPassword(SaltHelper.exec(user.getPassword(), salt));
  321. user.setUpdateBy(SecurityUtils.getUsername());
  322. return toAjax(userService.resetPwd(user));
  323. }
  324. /**
  325. * 状态修改
  326. */
  327. @RequiresPermissions("system:user:edit")
  328. @Log(title = "用户管理", businessType = BusinessType.UPDATE)
  329. @PutMapping("/changeStatus")
  330. public AjaxResult changeStatus(@RequestBody SysUser user) {
  331. userService.checkUserAllowed(user);
  332. userService.checkUserDataScope(user.getId());
  333. user.setUpdateBy(SecurityUtils.getUsername());
  334. return toAjax(userService.updateUserStatus(user));
  335. }
  336. /**
  337. * 根据用户编号获取授权角色
  338. */
  339. @RequiresPermissions("system:user:query")
  340. @GetMapping("/authRole/{userId}")
  341. public AjaxResult authRole(@PathVariable("userId") Long userId) {
  342. AjaxResult ajax = AjaxResult.success();
  343. SysUser user = userService.selectUserById(userId);
  344. List<SysRole> roles = roleService.selectRolesByUserId(userId);
  345. List<SysUserRole> userRoles = sysUserRoleService.selectSysUserRoleListByUserId(userId);
  346. ajax.put("user", user);
  347. ajax.put("roles", roles);
  348. ajax.put("userRoles", userRoles);
  349. return ajax;
  350. }
  351. /**
  352. * 用户授权角色
  353. */
  354. @RequiresPermissions("system:user:edit")
  355. @Log(title = "用户管理", businessType = BusinessType.GRANT)
  356. @PutMapping("/authRole")
  357. public AjaxResult insertAuthRole(Long userId, Long[] roleIds) {
  358. userService.checkUserDataScope(userId);
  359. userService.insertUserAuth(userId, roleIds);
  360. return success();
  361. }
  362. /**
  363. * 获取用户列表
  364. */
  365. @InnerAuth
  366. @PostMapping("/sync/list")
  367. public R<List<SysUser>> syncUserList(@RequestBody SysUser user) {
  368. try {
  369. return R.ok(userService.selectSyncUserList(user));
  370. } catch (Exception e) {
  371. return R.fail(e.getMessage());
  372. }
  373. }
  374. @InnerAuth
  375. @GetMapping("/getUserById")
  376. public SysUser getUserById(Long id) {
  377. return userService.selectUserById(id);
  378. }
  379. /**
  380. * 查询机构列表
  381. */
  382. @ApiOperation(value = "批量保存同步用户数据")
  383. @InnerAuth
  384. @PostMapping("/sync/batch")
  385. public R<Boolean> batchSaveSyncSysOrgs(@RequestBody List<SysUser> sysUserList) {
  386. userService.batchSaveOrUpdate(sysUserList);
  387. return R.ok(true);
  388. }
  389. /**
  390. * 查询机构列表
  391. */
  392. @ApiOperation(value = "记录用户最后一次登录")
  393. @InnerAuth
  394. @PostMapping("/userLoginInfo")
  395. public R<Boolean> userLoginInfo(Long id, Date loginTime, String loginIp) {
  396. SysUser sysUser = userService.selectUserById(id);
  397. sysUser.setLastIp(loginIp);
  398. if (null == loginTime) {
  399. loginTime = DateUtils.getNowDate();
  400. }
  401. sysUser.setLastTime(loginTime);
  402. userService.saveOrUpdate(sysUser);
  403. return R.ok(true);
  404. }
  405. @ApiOperation(value = "根据机构id查询用户")
  406. @GetMapping("/getByOrgId/{orgId}")
  407. public R<List<SysUserListVo>> getByOrgId(@PathVariable Long orgId) {
  408. List<SysUserListVo> sysUsers = userService.selectUserByOrgId(orgId);
  409. return R.ok(sysUsers);
  410. }
  411. @InnerAuth
  412. @PostMapping("/allUserList")
  413. public List<SysUser> allUserList() {
  414. return userService.list();
  415. }
  416. @ApiOperation(value = "通过角色获取用户")
  417. @InnerAuth
  418. @PostMapping("/userListByRole")
  419. public List<SysUser> userLoginInfo(@RequestBody List<CoreAnnouncementNotificationToRole> notificationToRoles) {
  420. return userService.selectUserListByRole(notificationToRoles);
  421. }
  422. @GetMapping("/selectAllUser")
  423. public AjaxResult selectAllUser(@PathVariable(value = "userName", required = false) String userName) {
  424. return success(userService.selectAllUser(userName));
  425. }
  426. @ApiOperation(value = "通过角色和机构获取用户")
  427. @InnerAuth
  428. @PostMapping("/userListByRoleAndOrg")
  429. public List<SysUser> userListByRoleAndOrg(@RequestBody SysPlanOrgDTO sysRoleOrgDTO) {
  430. return userService.selectUserListByRoleAndOrg(sysRoleOrgDTO);
  431. }
  432. /**
  433. * 获取用户的角色id及名称
  434. *
  435. * @param
  436. * @return
  437. */
  438. @ApiOperation(value = "获取用户的角色id及名称")
  439. @InnerAuth
  440. @GetMapping("/getroleinfoofuser")
  441. public List<IdNameVo> getRoleInfoOfUser(@RequestParam Long userId) {
  442. List<UserRoleVo> vos = sysUserRoleService.selectUserRoleVoList(userId);
  443. return vos.stream().map(v -> {
  444. IdNameVo vo = new IdNameVo();
  445. vo.setId(v.getRoleId());
  446. vo.setName(v.getRoleName());
  447. return vo;
  448. }).collect(Collectors.toList());
  449. }
  450. /**
  451. * 导出用户数据
  452. */
  453. @RequiresPermissions("system:user:export")
  454. @PostMapping("/export")
  455. public void export(SysUser user, HttpServletResponse response) {
  456. List<UserExport> list = null;
  457. Set<String> excludeColumnFiledNames = new HashSet<String>();
  458. //如果导出模板
  459. if (user.getTemplate() != null && user.getTemplate()) {
  460. excludeColumnFiledNames.add("lastIp");
  461. excludeColumnFiledNames.add("lastTime");
  462. list = new ArrayList<>();
  463. } else {
  464. list = userService.down(user);
  465. if (ObjectUtil.isEmpty(list)) {
  466. throw new RuntimeException("导出数据为空!");
  467. }
  468. AtomicInteger xh = new AtomicInteger();
  469. xh.getAndIncrement();
  470. list.forEach(e -> {
  471. if (e.getIsManage() == null) {
  472. e.setIsManage("N");
  473. }
  474. e.setXh(String.valueOf(xh.getAndIncrement()));
  475. });
  476. if (list.size() > 10000) {
  477. throw new RuntimeException("导出数据量过大(单次导出限量10000条数据),请填写条件分批导出");
  478. }
  479. }
  480. try {
  481. // 设置响应头
  482. response.addHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode("用户数据", "utf-8"));
  483. response.setContentType("application/octet-stream;charset=UTF-8");
  484. response.setCharacterEncoding("utf-8");
  485. // 数据导出
  486. EasyExcel.write(response.getOutputStream(), UserExport.class).excludeColumnFiledNames(excludeColumnFiledNames)
  487. .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).sheet("用户数据").doWrite(list);
  488. } catch (Exception e) {
  489. // 重置response
  490. response.reset();
  491. response.setContentType("application/json");
  492. response.setCharacterEncoding("utf-8");
  493. }
  494. }
  495. /**
  496. * 导出管理人员数据
  497. */
  498. @RequiresPermissions("system:user:exportManager")
  499. @PostMapping("/exportManager")
  500. public void exportManager(SysUser user, HttpServletResponse response) {
  501. List<UserExport> list = userService.down(user);
  502. if (ObjectUtil.isEmpty(list)) {
  503. throw new RuntimeException("导出数据为空!");
  504. }
  505. list = list.stream().filter(e -> "Y".equals(e.getIsManage())).collect(Collectors.toList());
  506. AtomicInteger xh = new AtomicInteger();
  507. xh.getAndIncrement();
  508. list.forEach(e -> {
  509. if (e.getIsManage() == null) {
  510. e.setIsManage("N");
  511. }
  512. e.setXh(String.valueOf(xh.getAndIncrement()));
  513. });
  514. if (list.size() > 10000) {
  515. throw new RuntimeException("导出数据量过大(单次导出限量10000条数据),请填写条件分批导出");
  516. }
  517. try {
  518. // 设置响应头
  519. response.addHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode("用户数据", "utf-8"));
  520. response.setContentType("application/octet-stream;charset=UTF-8");
  521. response.setCharacterEncoding("utf-8");
  522. // 数据导出
  523. EasyExcel.write(response.getOutputStream(), UserExport.class)
  524. .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).sheet("用户数据").doWrite(list);
  525. } catch (Exception e) {
  526. // 重置response
  527. response.reset();
  528. response.setContentType("application/json");
  529. response.setCharacterEncoding("utf-8");
  530. }
  531. }
  532. /**
  533. * 导入
  534. */
  535. @RequiresPermissions("system:user:import")
  536. @ResponseBody
  537. @PostMapping("/importData")
  538. @Transactional(rollbackFor = {RuntimeException.class, Exception.class})
  539. public AjaxResult importData(MultipartFile file, boolean updateSupport) {
  540. List<UserImport> list = new ArrayList<>();
  541. // 读取excel
  542. EasyExcel.read(multipartFileToFile(file), UserImport.class, new AnalysisEventListener<UserImport>() {
  543. // 每解析一行数据,该方法会被调用一次
  544. @Override
  545. public void invoke(UserImport user, AnalysisContext analysisContext) {
  546. // System.out.println("解析数据为:" + user.toString());
  547. if (user.getName() != null) {
  548. list.add(user);
  549. }
  550. }
  551. // 全部解析完成被调用
  552. @Override
  553. public void doAfterAllAnalysed(AnalysisContext analysisContext) {
  554. // System.out.println("解析完成...");
  555. List<String> names = list.stream().map(UserImport::getName).collect(Collectors.toList());
  556. List<String> exist = userService.selectCountByNames(names);
  557. if (exist.size() > 0) {
  558. throw new RuntimeException("用户" + exist + "已存在");
  559. }
  560. // 将解析的数据保存到数据库
  561. for (UserImport u : list) {
  562. //构建基础user对象
  563. SysUser user = new SysUser();
  564. BeanUtils.copyProperties(u, user);
  565. user.setDeleted(0);
  566. user.setIsLock("正常".equals(u.getIsLock()) ? "0" : "1");
  567. user.setGender("男".equals(u.getGender()) ? "0" : "1");
  568. user.setIsManage("是".equals(u.getIsManage()) ? "Y" : "N");
  569. SysOrg org = orgMapper.selectOne(new LambdaQueryWrapper<SysOrg>().eq(SysOrg::getShortName, u.getOrgName()).eq(SysOrg::getDeleted, 0));
  570. if (org == null) {
  571. throw new RuntimeException("机构" + u.getOrgName() + "不存在");
  572. }
  573. user.setOrgName(org.getName());
  574. user.setOrgPath(org.getPath());
  575. user.setOrgId(org.getId());
  576. user.setOrgType(org.getType());
  577. user.setCreateBy(SecurityUtils.getUsername());
  578. user.setSource(0);
  579. user.setCreateTime(new Date());
  580. //isp的加密方式
  581. final String salt = SaltHelper.salt();
  582. user.setSalt(salt);
  583. user.setPassword(SaltHelper.exec("Admin1234", salt));
  584. user.setOriginalOrgId(user.getOrgId());
  585. userService.insertUser(user);
  586. //构建用户角色关联关系
  587. String[] roleNames = user.getRoleNames().split(",");
  588. List<SysRole> roles = roleService.list(new LambdaQueryWrapper<SysRole>().in(SysRole::getRoleName, roleNames));
  589. if (roles.size() != roleNames.length) {
  590. throw new RuntimeException("角色" + Arrays.toString(roleNames) + "存在异常");
  591. }
  592. for (SysRole r :
  593. roles) {
  594. SysUserRole sysUserRole = new SysUserRole();
  595. sysUserRole.setUserId(user.getId());
  596. sysUserRole.setRoleId(r.getId());
  597. sysUserRoleService.insertSysUserRole(sysUserRole);
  598. }
  599. }
  600. }
  601. }).sheet().doRead();
  602. return success("导入成功!");
  603. }
  604. /***
  605. * 功能描述:
  606. * MultipartFile 转 File
  607. * @return: java.io.File
  608. */
  609. public static File multipartFileToFile(MultipartFile multipartFile) {
  610. // 获取文件名
  611. String fileName = multipartFile.getOriginalFilename();
  612. // 获取文件后缀
  613. assert fileName != null;
  614. String suffix = fileName.substring(fileName.lastIndexOf("."));
  615. // 若需要防止临时文件重复,需要在文件名后加上UUID
  616. try {
  617. File file = File.createTempFile(fileName.substring(0, fileName.lastIndexOf(".")) + UUID.randomUUID(), suffix);
  618. multipartFile.transferTo(file);
  619. return file;
  620. } catch (IOException e) {
  621. e.printStackTrace();
  622. }
  623. return null;
  624. }
  625. }