TAdminController.java 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635
  1. package com.szwl.controller;
  2. import cn.hutool.core.bean.BeanUtil;
  3. import cn.hutool.core.collection.CollUtil;
  4. import cn.hutool.core.lang.UUID;
  5. import cn.hutool.core.util.IdUtil;
  6. import com.alibaba.fastjson.JSONObject;
  7. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  8. import com.baomidou.mybatisplus.core.metadata.IPage;
  9. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  10. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  11. import com.szwl.annotation.Audit;
  12. import com.szwl.constant.AuditEnum;
  13. import com.szwl.constant.ResponseCodesEnum;
  14. import com.szwl.exception.BizException;
  15. import com.szwl.manager.TokenManager;
  16. import com.szwl.model.bo.R;
  17. import com.szwl.model.bo.ResponseModel;
  18. import com.szwl.model.bo.UserDetailBO;
  19. import com.szwl.model.entity.*;
  20. import com.szwl.model.param.AddLoginUserParam;
  21. import com.szwl.model.param.UpdateLoginUserParam;
  22. import com.szwl.model.param.UpdateSysRoleParam;
  23. import com.szwl.service.*;
  24. import io.swagger.annotations.Api;
  25. import io.swagger.annotations.ApiOperation;
  26. import lombok.extern.slf4j.Slf4j;
  27. import org.apache.commons.codec.digest.DigestUtils;
  28. import org.apache.commons.lang.StringUtils;
  29. import org.springframework.beans.factory.annotation.Autowired;
  30. import org.springframework.data.repository.query.Param;
  31. import org.springframework.transaction.annotation.Transactional;
  32. import org.springframework.web.bind.annotation.*;
  33. import javax.validation.Valid;
  34. import java.util.*;
  35. import java.util.stream.Collectors;
  36. /**
  37. * <p>
  38. * 短信验证码 前端控制器
  39. * </p>
  40. *
  41. * @author wuhs
  42. * @since 2022-04-14
  43. */
  44. @Slf4j
  45. @Api(value = "/tAdmin", tags = {"账户"})
  46. @RestController
  47. @RequestMapping("/tAdmin")
  48. public class TAdminController {
  49. @Autowired
  50. SysRoleService sysRoleService;
  51. @Autowired
  52. SysUserRoleService sysUserRoleService;
  53. @Autowired
  54. TokenManager tokenManager;
  55. @Autowired
  56. TAdminService tAdminService;
  57. @Autowired
  58. TAdminEquipmentService tAdminEquipmentService;
  59. @Autowired
  60. TMessageCodeService tMessageCodeService;
  61. @ApiOperation(value = "添加子账号")
  62. @PostMapping("/addLoginUser")
  63. @Transactional
  64. @Audit(type = AuditEnum.INSERT,content = "#loginUser.name + '添加账号'")
  65. public ResponseModel<?> addLoginUser(@RequestBody @Valid AddLoginUserParam param) {
  66. // public ResponseModel<?> addLoginUser(@RequestBody AddLoginUserParam param) {
  67. //获取当前操作人员
  68. UserDetailBO loginUser = tokenManager.getLoginUserDetails();
  69. // 保存用户实体
  70. Date now = new Date();
  71. Long parentId = param.getAdminId();
  72. if(parentId==null){
  73. return R.fail(ResponseCodesEnum.A0001);
  74. }
  75. param.setAdminId(null);
  76. TAdmin entity = BeanUtil.copyProperties(param,TAdmin.class);
  77. entity.setParentId(parentId);
  78. if(parentId.toString().equals("1")){
  79. entity.setType(1);
  80. }else {
  81. entity.setType(3);
  82. }
  83. // entity.setParentId(34l);
  84. entity.setIsAdmined(false);
  85. entity.setCreateDate(now);
  86. entity.setModifyDate(now);
  87. entity.setIsLocked(false);
  88. entity.setIsEnabled(true);
  89. entity.setLoginFailureCount(0);
  90. entity.setEmail(param.getEmail());
  91. entity.setPhone(param.getPhone());
  92. tAdminService.save(entity);
  93. // 管理的机器 需要再建立一个关系表 type区分全部还是部分
  94. String equipmentIds = param.getEquipmentIds();
  95. if(StringUtils.isNotEmpty(equipmentIds)){
  96. if(equipmentIds.equals("all")){
  97. //管理全部机器
  98. TAdminEquipment tAdminEquipment = new TAdminEquipment();
  99. tAdminEquipment.setAdminId(entity.getId());
  100. //0:全部机器,1:部分机器
  101. tAdminEquipment.setType("0");
  102. tAdminEquipmentService.save(tAdminEquipment);
  103. }else {
  104. //部分机器
  105. TAdminEquipment tAdminEquipment = new TAdminEquipment();
  106. tAdminEquipment.setAdminId(entity.getId());
  107. //0:全部机器,1:部分机器
  108. tAdminEquipment.setType("1");
  109. tAdminEquipment.setEquipmentIds(param.getEquipmentIds());
  110. tAdminEquipmentService.save(tAdminEquipment);
  111. }
  112. }
  113. log.debug("添加账号 id:{},TAdmin:{}",entity.getId(),entity);
  114. // 保存用户角色关系
  115. List<SysUserRole> userRoleList = param.getRoleList()
  116. .stream()
  117. .map(e -> new SysUserRole().setRoleId(e).setUserId(String.valueOf(entity.getId())) )
  118. .collect(Collectors.toList());
  119. if(CollUtil.isNotEmpty(userRoleList)){
  120. sysUserRoleService.saveBatch(userRoleList);
  121. }
  122. return R.ok(entity);
  123. }
  124. @ApiOperation(value = "修改子账号")
  125. @PostMapping("/updateLoginUser")
  126. @Transactional
  127. @Audit(type = AuditEnum.UPDATE,content = "#loginUser.name + '修改账号'")
  128. public ResponseModel<?> updateLoginUser(@RequestBody @Valid UpdateLoginUserParam param) {
  129. // public ResponseModel<?> addLoginUser(@RequestBody AddLoginUserParam param) {
  130. //获取当前操作人员
  131. UserDetailBO loginUser = tokenManager.getLoginUserDetails();
  132. // 保存用户实体
  133. Date now = new Date();
  134. Long parentId = param.getAdminId();
  135. if(parentId==null){
  136. return R.fail(ResponseCodesEnum.A0001);
  137. }
  138. param.setAdminId(null);
  139. // TAdmin entity = BeanUtil.copyProperties(param,TAdmin.class);
  140. // entity.setParentId(parentId);
  141. //// entity.setParentId(34l);
  142. // entity.setIsAdmined(false);
  143. // entity.setCreateDate(now);
  144. // entity.setModifyDate(now);
  145. // entity.setIsLocked(false);
  146. // entity.setIsEnabled(true);
  147. // entity.setLoginFailureCount(0);
  148. // entity.setEmail(param.getEmail());
  149. // entity.setPhone(param.getPhone());
  150. // tAdminService.save(entity);
  151. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  152. query.eq(TAdmin::getParentId,parentId);
  153. query.eq(TAdmin::getId,param.getId());
  154. List<TAdmin> list = tAdminService.list(query);
  155. if(list.size()>0){
  156. TAdmin admin = list.get(0);
  157. // 管理的机器 需要再建立一个关系表 type区分全部还是部分
  158. String equipmentIds = param.getEquipmentIds();
  159. if(StringUtils.isNotEmpty(equipmentIds)){
  160. LambdaQueryWrapper<TAdminEquipment> query1 = Wrappers.lambdaQuery();
  161. query1.eq(TAdminEquipment::getAdminId,admin.getId());
  162. List<TAdminEquipment> list1 = tAdminEquipmentService.list(query1);
  163. if(list1.size()>0){
  164. TAdminEquipment tAdminEquipment1 = list1.get(0);
  165. if(equipmentIds.equals("all")){
  166. //管理全部机器
  167. //0:全部机器,1:部分机器
  168. tAdminEquipment1.setType("0");
  169. tAdminEquipment1.setEquipmentIds(null);
  170. }else {
  171. //部分机器
  172. //0:全部机器,1:部分机器
  173. tAdminEquipment1.setType("1");
  174. tAdminEquipment1.setEquipmentIds(param.getEquipmentIds());
  175. }
  176. tAdminEquipmentService.updateById(tAdminEquipment1);
  177. }
  178. }
  179. LambdaQueryWrapper<SysUserRole> query1 = Wrappers.lambdaQuery();
  180. query1.eq(SysUserRole::getUserId,admin.getId());
  181. List<SysUserRole> list1 = sysUserRoleService.list(query1);
  182. if(list1.size()>0){
  183. for(SysUserRole sysUserRole:list1){
  184. sysUserRoleService.removeById(sysUserRole.getId());
  185. }
  186. }
  187. // 保存用户角色关系
  188. List<SysUserRole> userRoleList = param.getRoleList()
  189. .stream()
  190. .map(e -> new SysUserRole().setRoleId(e).setUserId(String.valueOf(admin.getId())) )
  191. .collect(Collectors.toList());
  192. if(CollUtil.isNotEmpty(userRoleList)){
  193. sysUserRoleService.saveBatch(userRoleList);
  194. }
  195. admin.setIsEnabled(param.getIsEnabled());
  196. admin.setPhone(param.getPhone());
  197. admin.setEmail(param.getEmail());
  198. admin.setIsEnabled(param.getIsEnabled());
  199. if(StringUtils.isNotEmpty(param.getPassword())){
  200. admin.setPassword(param.getPassword());
  201. }
  202. tAdminService.updateById(admin);
  203. log.debug("修改账号 id:{},TAdmin:{}",admin.getId(),admin);
  204. return R.ok(admin);
  205. }
  206. return R.fail(ResponseCodesEnum.A0100);
  207. }
  208. @ApiOperation(value = "删除子账号")
  209. @PostMapping("/deleteLoginUser")
  210. @Transactional
  211. @Audit(type = AuditEnum.DELETE,content = "#loginUser.name + '删除账号'")
  212. public ResponseModel<?> deleteLoginUser(@RequestBody @Valid UpdateLoginUserParam param) {
  213. // public ResponseModel<?> addLoginUser(@RequestBody AddLoginUserParam param) {
  214. //获取当前操作人员
  215. UserDetailBO loginUser = tokenManager.getLoginUserDetails();
  216. // 保存用户实体
  217. Date now = new Date();
  218. Long parentId = param.getAdminId();
  219. if(parentId==null){
  220. return R.fail(ResponseCodesEnum.A0001);
  221. }
  222. param.setAdminId(null);
  223. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  224. query.like(TAdmin::getParentId,parentId);
  225. query.like(TAdmin::getId,param.getId());
  226. List<TAdmin> list = tAdminService.list(query);
  227. if(list.size()>0){
  228. TAdmin admin = list.get(0);
  229. // 管理的机器 需要再建立一个关系表 type区分全部还是部分
  230. String equipmentIds = param.getEquipmentIds();
  231. if(StringUtils.isNotEmpty(equipmentIds)){
  232. LambdaQueryWrapper<TAdminEquipment> query1 = Wrappers.lambdaQuery();
  233. query1.eq(TAdminEquipment::getAdminId,admin.getId());
  234. List<TAdminEquipment> list1 = tAdminEquipmentService.list(query1);
  235. if(list1.size()>0){
  236. TAdminEquipment tAdminEquipment1 = list1.get(0);
  237. tAdminEquipmentService.removeById(tAdminEquipment1.getAdminId());
  238. }
  239. }
  240. // 用户角色关系
  241. LambdaQueryWrapper<SysUserRole> query2 = Wrappers.lambdaQuery();
  242. query2.eq(SysUserRole::getUserId,admin.getId());
  243. List<SysUserRole> list2 = sysUserRoleService.list(query2);
  244. if(list2.size()>0){
  245. SysUserRole sysUserRole = list2.get(0);
  246. sysUserRoleService.removeById(sysUserRole.getId());
  247. }
  248. tAdminService.removeById(admin.getId());
  249. log.debug("删除账号 id:{},TAdmin:{}",admin.getId(),admin);
  250. return R.ok(admin);
  251. }
  252. return R.fail(ResponseCodesEnum.A0100);
  253. }
  254. @ApiOperation(value = "获取所有子账号信息")
  255. @GetMapping("/getChildDrenAdminList")
  256. public ResponseModel<?> getChildDrenAdminList(String adminId,String userName,String name) {
  257. List<AddLoginUserParam> returnList = new ArrayList<>();
  258. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  259. query.eq(TAdmin::getParentId,adminId);
  260. if(StringUtils.isNotEmpty(userName)){
  261. query.eq(TAdmin::getUsername,userName);
  262. }
  263. if(StringUtils.isNotEmpty(name)){
  264. query.eq(TAdmin::getName,name);
  265. }
  266. if(StringUtils.isNotEmpty(adminId)){
  267. if(adminId.equals("1")){
  268. // query.in(TAdmin::getType,"1","3");
  269. query.eq(TAdmin::getType,"1");
  270. }else {
  271. query.eq(TAdmin::getType,"3");
  272. }
  273. }else {
  274. return R.fail(ResponseCodesEnum.A0100);
  275. }
  276. query.eq(TAdmin::getIsAdmined,false);
  277. List<TAdmin> list = tAdminService.list(query);
  278. if(list.size()>0){
  279. for(TAdmin admin:list){
  280. AddLoginUserParam addLoginUserParam = new AddLoginUserParam();
  281. JSONObject jsonObject = new JSONObject();
  282. addLoginUserParam.setUsername(admin.getUsername());
  283. addLoginUserParam.setName(admin.getName());
  284. addLoginUserParam.setEmail(admin.getEmail());
  285. addLoginUserParam.setPhone(admin.getPhone());
  286. addLoginUserParam.setIsEnabled(admin.getIsEnabled());
  287. addLoginUserParam.setId(admin.getId());
  288. LambdaQueryWrapper<TAdminEquipment> query2 = Wrappers.lambdaQuery();
  289. query2.eq(TAdminEquipment::getAdminId,admin.getId());
  290. List<TAdminEquipment> list1 = tAdminEquipmentService.list(query2);
  291. if(list1.size()>0){
  292. TAdminEquipment tAdminEquipment1 = list1.get(0);
  293. if(tAdminEquipment1.getType().equals("0")){
  294. //管理全部机器
  295. //0:全部机器,1:部分机器
  296. tAdminEquipment1.setType("0");
  297. tAdminEquipment1.setEquipmentIds(null);
  298. addLoginUserParam.setEquipmentIds("all");
  299. }else {
  300. //部分机器
  301. //0:全部机器,1:部分机器
  302. tAdminEquipment1.setType("1");
  303. addLoginUserParam.setEquipmentIds(tAdminEquipment1.getEquipmentIds());
  304. }
  305. }
  306. LambdaQueryWrapper<SysUserRole> query1 = Wrappers.lambdaQuery();
  307. query1.eq(SysUserRole::getUserId,admin.getId());
  308. List<SysUserRole> roleList = sysUserRoleService.list(query1);
  309. List<String> ids = new ArrayList<>();
  310. StringBuilder roleName = new StringBuilder();
  311. if(roleList.size()>0){
  312. for(int i=0;i<roleList.size();i++){
  313. SysUserRole sysUserRole = roleList.get(0);
  314. ids.add(sysUserRole.getRoleId());
  315. SysRole sysRole = sysRoleService.getById(sysUserRole.getRoleId());
  316. if(i<roleList.size()-1){
  317. roleName.append(sysRole.getRoleName()).append(",");
  318. }else {
  319. roleName.append(sysRole.getRoleName());
  320. }
  321. // addLoginUserParam.setRoleName(roleName);
  322. // List<String> list2 = Arrays.asList(sysRole.getMenuCodesJson().split(","));
  323. // addLoginUserParam.setRoleList(list2);
  324. }
  325. }
  326. addLoginUserParam.setRoleName(roleName.toString());
  327. addLoginUserParam.setRoleList(ids);
  328. returnList.add(addLoginUserParam);
  329. }
  330. }
  331. return R.ok(returnList);
  332. }
  333. @ApiOperation(value = "注册")
  334. @PostMapping("/save")
  335. @Transactional
  336. @Audit(type = AuditEnum.INSERT,content = "#loginUser.name + '注册账号'")
  337. public ResponseModel<?> save(@RequestBody TAdmin admin) {
  338. if(StringUtils.isEmpty(admin.getUsername())||StringUtils.isEmpty(admin.getName())||StringUtils.isEmpty(admin.getPassword())){
  339. return R.fail(ResponseCodesEnum.A0100,"数据有空!");
  340. }
  341. if(admin.getIfForeign().equals("0")){
  342. //国内用户注册
  343. if(StringUtils.isEmpty(admin.getPhone())){
  344. return R.fail(ResponseCodesEnum.A0100,"手机号为空!");
  345. }
  346. }else {
  347. //国外用户注册
  348. if(StringUtils.isEmpty(admin.getEmail())){
  349. return R.fail(ResponseCodesEnum.A0100,"邮箱为空!");
  350. }
  351. }
  352. if (StringUtils.isEmpty(admin.getCode())){
  353. return R.fail(ResponseCodesEnum.A0100,"验证码为空!");
  354. }
  355. //校验是否有重复的
  356. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  357. query.eq(TAdmin::getUsername,admin.getUsername());
  358. List<TAdmin> list = tAdminService.list(query);
  359. if(list.size()>0){
  360. return R.fail(ResponseCodesEnum.A0201,"用户登录名已存在");
  361. }
  362. LambdaQueryWrapper<TAdmin> query1 = Wrappers.lambdaQuery();
  363. if(admin.getIfForeign().equals("0")){
  364. query1.eq(TAdmin::getPhone,admin.getPhone());
  365. }else {
  366. query1.eq(TAdmin::getEmail,admin.getEmail());
  367. }
  368. List<TAdmin> list1 = tAdminService.list(query1);
  369. if(list1.size()>0){
  370. return R.fail(ResponseCodesEnum.A0203,"用户手机/邮箱已存在");
  371. }
  372. //校验验证码是否正确
  373. LambdaQueryWrapper<TMessageCode> query2 = Wrappers.lambdaQuery();
  374. if(admin.getIfForeign().equals("0")){
  375. query2.eq(TMessageCode::getPhone,admin.getPhone());
  376. }else {
  377. query2.eq(TMessageCode::getPhone,admin.getEmail());
  378. }
  379. query2.eq(TMessageCode::getType,"0");//0,代表注册验证码
  380. query2.eq(TMessageCode::getStatus,"0");
  381. List<TMessageCode> messageCodeList = tMessageCodeService.list(query2);
  382. if(messageCodeList.size()>0){
  383. TMessageCode tMessageCode = messageCodeList.get(messageCodeList.size() - 1);
  384. if(!tMessageCode.getCode().equals(admin.getCode())){
  385. return R.fail(ResponseCodesEnum.A0002,"验证码错误");
  386. }
  387. tMessageCode.setStatus("1");
  388. admin.setCreateDate(new Date());
  389. admin.setModifyDate(new Date());
  390. admin.setIsAdmined(false);
  391. admin.setIsEnabled(true);
  392. admin.setLoginFailureCount(0);
  393. admin.setIsLocked(false);
  394. //默认是商家
  395. admin.setType(2);
  396. admin.setIsAdmined(true);
  397. admin.setPassword(DigestUtils.md5Hex(admin.getPassword()));
  398. boolean b = tAdminService.save(admin);
  399. //todo 绑定商家角色
  400. tMessageCode.setModifyDate(new Date());
  401. tMessageCodeService.saveOrUpdate(tMessageCode);
  402. if(b){
  403. admin.setManagerId(admin.getManager());
  404. tAdminService.getById(admin);
  405. }
  406. return R.ok(b);
  407. }else {
  408. return R.fail(ResponseCodesEnum.A0002,"没有找到验证码");
  409. }
  410. }
  411. @ApiOperation(value = "登录")
  412. @PostMapping("/login")
  413. @Audit(type = AuditEnum.LOGIN,content = "#username + '请求登录'")
  414. public ResponseModel<UserDetailBO> login(String username, String password) {
  415. if(StringUtils.isEmpty(username)||StringUtils.isEmpty(password)){
  416. return R.fail(ResponseCodesEnum.A0001,"参数有空");
  417. }
  418. //验证用户名登录
  419. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  420. // query.eq(TAdmin::getUsername,username);
  421. query.eq(TAdmin::getPassword,password);
  422. query.and(
  423. wrapper -> {
  424. wrapper.eq(TAdmin::getUsername,username)
  425. .or().eq(TAdmin::getPhone,username);
  426. }
  427. );
  428. TAdmin tAdmin = Optional.ofNullable(tAdminService.getOnly(query))
  429. .orElseThrow(() -> new BizException(ResponseCodesEnum.L0002));
  430. UserDetailBO userDetailBO = BeanUtil.copyProperties(tAdmin,UserDetailBO.class);
  431. String token = IdUtil.simpleUUID();
  432. userDetailBO.setCurrentToken(token);
  433. // 获取拥有的权限菜单
  434. Set<String> menuList = sysRoleService.listAuthMenuByUserId(userDetailBO.getId());
  435. userDetailBO.setMenuCodeList(CollUtil.newArrayList(menuList));
  436. // 抹除密码
  437. userDetailBO.setPassword(null);
  438. // 保存到redis
  439. tokenManager.saveAuthentication(token,userDetailBO);
  440. return R.ok(userDetailBO);
  441. }
  442. @ApiOperation(value = "修改密码")
  443. @PostMapping("/updatePassword")
  444. public ResponseModel<?> updatePassword(String username,String password) {
  445. if(StringUtils.isEmpty(username)||StringUtils.isEmpty(password)){
  446. return R.fail(ResponseCodesEnum.A0001,"参数有空");
  447. }
  448. //查找用户名
  449. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  450. query.eq(TAdmin::getUsername,username);
  451. List<TAdmin> list = tAdminService.list(query);
  452. if(list.size()>0){
  453. TAdmin admin = list.get(0);
  454. admin.setPassword(password);
  455. boolean b = tAdminService.saveOrUpdate(admin);
  456. return R.ok(b);
  457. }
  458. return R.fail(ResponseCodesEnum.A0001,"修改失败");
  459. }
  460. @ApiOperation(value = "获取账号信息")
  461. @GetMapping("/getAdmin")
  462. public ResponseModel<TAdmin> getAdmin(@RequestParam String id) {
  463. TAdmin tAdmin = tAdminService.getById(id);
  464. return R.ok(tAdmin);
  465. }
  466. @ApiOperation(value = "获取账号列表 分页")
  467. @GetMapping("/pageAdmin")
  468. public ResponseModel<IPage<?>> pageAdmin(String id,String name,String userName,String ifForeign,long current,long size ) {
  469. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  470. if(StringUtils.isNotEmpty(name)){
  471. query.eq(TAdmin::getName,name);
  472. }
  473. if(StringUtils.isNotEmpty(userName)){
  474. query.like(TAdmin::getUsername,userName);
  475. }
  476. if(StringUtils.isNotEmpty(ifForeign)){
  477. query.like(TAdmin::getIfForeign,ifForeign);
  478. }
  479. if(StringUtils.isNotEmpty(id)){
  480. query.like(TAdmin::getRelationAdminId,id);
  481. }
  482. Page<TAdmin> page = new Page<>(current, size, true);
  483. IPage<TAdmin> iPage = tAdminService.page(page, query);
  484. return R.ok(iPage);
  485. }
  486. @ApiOperation(value = "获取账号列表 分页")
  487. @GetMapping("/pageAdmin2")
  488. public ResponseModel<IPage<TAdmin>> pageAdmin2(@RequestParam(value = "current") long current, @RequestParam(value = "size") long size ) {
  489. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  490. Page<TAdmin> page = new Page<>(current, size, true);
  491. IPage<TAdmin> iPage = tAdminService.page(page, query);
  492. return R.ok(iPage);
  493. }
  494. @ApiOperation(value = "获取账号列表")
  495. @GetMapping("/listAdmin")
  496. public ResponseModel<?> listAdmin(String adminId ) {
  497. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  498. if(StringUtils.isNotEmpty(adminId)){
  499. query.like(TAdmin::getRelationAdminId,adminId);
  500. }
  501. List<TAdmin> list = tAdminService.list(query);
  502. return R.ok(list);
  503. }
  504. @ApiOperation(value = "修改账号")
  505. @PostMapping("/update")
  506. @Transactional
  507. public ResponseModel<?> update(@RequestBody TAdmin admin) {
  508. //校验是否有重复的
  509. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  510. query.eq(TAdmin::getUsername,admin.getUsername());
  511. List<TAdmin> list = tAdminService.list(query);
  512. TAdmin oldAdmin = list.get(0);
  513. if(StringUtils.isNotEmpty(admin.getPassword())){
  514. oldAdmin.setPassword(admin.getPassword());
  515. }
  516. if(StringUtils.isNotEmpty(admin.getName())){
  517. oldAdmin.setName(admin.getName());
  518. }
  519. if(StringUtils.isNotEmpty(admin.getIfForeign())){
  520. oldAdmin.setIfForeign(admin.getIfForeign());
  521. }
  522. if(StringUtils.isNotEmpty(admin.getTradeMerchantNo())){
  523. oldAdmin.setTradeMerchantNo(admin.getTradeMerchantNo());
  524. }
  525. if(StringUtils.isNotEmpty(admin.getPayPlatform())){
  526. oldAdmin.setPayPlatform(admin.getPayPlatform());
  527. }
  528. if(StringUtils.isNotEmpty(admin.getPromoCodeOpen())){
  529. oldAdmin.setPromoCodeOpen(admin.getPromoCodeOpen());
  530. }
  531. if(StringUtils.isNotEmpty(admin.getPhone())){
  532. oldAdmin.setPhone(admin.getPhone());
  533. }
  534. if(StringUtils.isNotEmpty(admin.getEmail())){
  535. oldAdmin.setEmail(admin.getEmail());
  536. }
  537. if(admin.getApplyStartTime()!=null){
  538. oldAdmin.setApplyStartTime(admin.getApplyStartTime());
  539. }
  540. if(admin.getApplyEndTime()!=null){
  541. oldAdmin.setApplyEndTime(admin.getApplyEndTime());
  542. }
  543. oldAdmin.setModifyDate(new Date());
  544. tAdminService.updateById(oldAdmin);
  545. return R.ok();
  546. }
  547. @ApiOperation(value = "绑定上级账户")
  548. @PostMapping("/setRelationAdmin")
  549. @Transactional
  550. public ResponseModel<?> setRelationAdmin(Long adminId,String username) {
  551. TAdmin admin = tAdminService.getById(adminId);
  552. if(StringUtils.isNotEmpty(username)){
  553. if(StringUtils.isNotEmpty(admin.getRelationAdminId())){
  554. return R.fail("已有绑定关系");
  555. }
  556. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  557. query.eq(TAdmin::getUsername,username);
  558. List<TAdmin> list = tAdminService.list(query);
  559. if(list.size()>0){
  560. TAdmin parentAdmin = list.get(0);
  561. if(StringUtils.isNotEmpty(parentAdmin.getRelationAdminId())&&parentAdmin.getRelationAdminId().equals(admin.getId().toString())){
  562. return R.fail("不能互为绑定关系");
  563. }else{
  564. admin.setRelationAdminId(String.valueOf(parentAdmin.getId()));
  565. tAdminService.updateById(admin);
  566. }
  567. }else {
  568. return R.fail("找不到账户");
  569. }
  570. }else {
  571. return R.fail(ResponseCodesEnum.A0001);
  572. }
  573. return R.ok();
  574. }
  575. @ApiOperation(value = "获取所有关联(下级)账号信息")
  576. @GetMapping("/getAdminIdList")
  577. public ResponseModel<List<Long>> getAdminIdList(@RequestParam String adminId) {
  578. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  579. query.eq(TAdmin::getRelationAdminId,adminId);
  580. List<TAdmin> list = tAdminService.list(query);
  581. List<Long> idList =new ArrayList<>();
  582. for(TAdmin admin:list){
  583. idList.add(admin.getId());
  584. }
  585. return R.ok(idList);
  586. }
  587. @ApiOperation(value = "获取所有关联(下级)账号信息")
  588. @GetMapping("/getAdminList")
  589. public ResponseModel<?> getAdminList(String adminId) {
  590. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  591. query.eq(TAdmin::getRelationAdminId,adminId);
  592. List<TAdmin> list = tAdminService.list(query);
  593. return R.ok(list);
  594. }
  595. @ApiOperation(value = "获取账号信息byname")
  596. @GetMapping("/getAdminByUsername")
  597. public ResponseModel<TAdmin> getAdminByUsername(@RequestParam String username) {
  598. LambdaQueryWrapper<TAdmin> query = Wrappers.lambdaQuery();
  599. query.eq(TAdmin::getUsername,username);
  600. List<TAdmin> list = tAdminService.list(query);
  601. TAdmin tAdmin = list.get(0);
  602. return R.ok(tAdmin);
  603. }
  604. @ApiOperation(value = "获取上级账号名")
  605. @GetMapping("/getRelationAdminUsername")
  606. public String getRelationAdminUsername(String relationAdminId) {
  607. TAdmin admin = tAdminService.getById(relationAdminId);
  608. return admin.getUsername();
  609. }
  610. }