UserRelationServiceImpl.java 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561
  1. package jnpf.permission.service.impl;
  2. import cn.hutool.core.collection.CollectionUtil;
  3. import com.baomidou.dynamic.datasource.annotation.DSTransactional;
  4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  5. import com.baomidou.mybatisplus.core.metadata.IPage;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.github.yulichang.toolkit.JoinWrappers;
  8. import com.github.yulichang.wrapper.MPJLambdaWrapper;
  9. import com.google.common.collect.Lists;
  10. import jnpf.base.UserInfo;
  11. import jnpf.base.entity.SuperBaseEntity;
  12. import jnpf.base.service.SuperServiceImpl;
  13. import jnpf.constant.MsgCode;
  14. import jnpf.constant.PermissionConst;
  15. import jnpf.message.entity.SynThirdInfoEntity;
  16. import jnpf.message.service.SynThirdInfoService;
  17. import jnpf.message.util.SynThirdConsts;
  18. import jnpf.permission.entity.OrganizeEntity;
  19. import jnpf.permission.entity.PositionEntity;
  20. import jnpf.permission.entity.UserEntity;
  21. import jnpf.permission.entity.UserRelationEntity;
  22. import jnpf.permission.mapper.UserRelationMapper;
  23. import jnpf.permission.model.position.PosistionCurrentModel;
  24. import jnpf.permission.model.user.page.UserPagination;
  25. import jnpf.permission.model.user.vo.UserListVO;
  26. import jnpf.permission.model.userrelation.UserRelationForm;
  27. import jnpf.permission.service.*;
  28. import jnpf.util.RandomUtil;
  29. import jnpf.util.StringUtil;
  30. import jnpf.util.UserProvider;
  31. import org.springframework.beans.factory.annotation.Autowired;
  32. import org.springframework.stereotype.Service;
  33. import java.util.*;
  34. import java.util.stream.Collectors;
  35. /**
  36. * 用户关系
  37. *
  38. * @author JNPF开发平台组
  39. * @version V3.1.0
  40. * @copyright 引迈信息技术有限公司
  41. * @date 2019年9月26日 上午9:18
  42. */
  43. @Service
  44. public class UserRelationServiceImpl extends SuperServiceImpl<UserRelationMapper, UserRelationEntity> implements UserRelationService {
  45. @Autowired
  46. private UserService userService;
  47. @Autowired
  48. private PositionService positionService;
  49. @Autowired
  50. private OrganizeService organizeService;
  51. @Autowired
  52. private RoleRelationService roleRelationService;
  53. @Autowired
  54. private UserRelationService userRelationService;
  55. @Autowired
  56. private SynThirdInfoService synThirdInfoService;
  57. @Override
  58. public List<UserListVO> getListPage(UserPagination pagination) {
  59. String objectType = StringUtil.isNotEmpty(pagination.getPositionId()) ? PermissionConst.POSITION : PermissionConst.ORGANIZE;
  60. String objectId = StringUtil.isNotEmpty(pagination.getPositionId()) ? pagination.getPositionId() : pagination.getOrganizeId();
  61. //是否显示子孙组织用户
  62. List<String> orgIds = new ArrayList<>();
  63. if (Objects.equals(pagination.getShowSubOrganize(), 1)) {
  64. List<OrganizeEntity> allChild = organizeService.getAllChild(pagination.getOrganizeId());
  65. orgIds.addAll(allChild.stream().map(OrganizeEntity::getId).collect(Collectors.toList()));
  66. }
  67. MPJLambdaWrapper<UserRelationEntity> queryWrapper = JoinWrappers.lambda(UserRelationEntity.class);
  68. queryWrapper.selectAs(UserEntity::getId, UserListVO::getId);
  69. queryWrapper.selectAs(UserEntity::getAccount, UserListVO::getAccount);
  70. queryWrapper.selectAs(UserEntity::getRealName, UserListVO::getRealName);
  71. queryWrapper.selectAs(UserEntity::getGender, UserListVO::getGender);
  72. queryWrapper.selectAs(UserEntity::getMobilePhone, UserListVO::getMobilePhone);
  73. queryWrapper.selectAs(UserEntity::getEnabledMark, UserListVO::getEnabledMark);
  74. queryWrapper.selectAs(UserEntity::getUnlockTime, UserListVO::getUnlockTime);
  75. queryWrapper.selectMax(UserRelationEntity::getId, UserListVO::getMaxRelationId);
  76. queryWrapper.leftJoin(UserEntity.class, UserEntity::getId, UserRelationEntity::getUserId);
  77. if (!StringUtil.isEmpty(pagination.getKeyword())) {
  78. queryWrapper.and(
  79. t -> t.like(UserEntity::getAccount, pagination.getKeyword())
  80. .or().like(UserEntity::getRealName, pagination.getKeyword())
  81. .or().like(UserEntity::getMobilePhone, pagination.getKeyword())
  82. );
  83. }
  84. if (pagination.getEnabledMark() != null) {
  85. queryWrapper.eq(UserEntity::getEnabledMark, pagination.getEnabledMark());
  86. }
  87. if (orgIds.size() > 0) {
  88. queryWrapper.in(UserRelationEntity::getObjectId, orgIds);
  89. } else {
  90. queryWrapper.eq(UserRelationEntity::getObjectId, objectId);
  91. }
  92. queryWrapper.eq(UserRelationEntity::getObjectType, objectType);
  93. queryWrapper.orderByDesc("maxRelationId");
  94. queryWrapper.groupBy(UserEntity::getId, UserEntity::getAccount, UserEntity::getRealName, UserEntity::getGender, UserEntity::getMobilePhone,
  95. UserEntity::getEnabledMark, UserEntity::getUnlockTime);
  96. Page<UserListVO> page = new Page<>(pagination.getCurrentPage(), pagination.getPageSize());
  97. IPage<UserListVO> data = this.selectJoinListPage(page, UserListVO.class, queryWrapper);
  98. return pagination.setData(data.getRecords(), page.getTotal());
  99. }
  100. @Override
  101. public List<UserRelationEntity> getListByUserId(String userId) {
  102. return getListByUserIdAll(Collections.singletonList(userId));
  103. }
  104. @Override
  105. public List<UserRelationEntity> getListByUserIdAndObjType(String userId, String objectType) {
  106. QueryWrapper<UserRelationEntity> query = new QueryWrapper<>();
  107. query.lambda().in(UserRelationEntity::getUserId, userId);
  108. query.lambda().in(UserRelationEntity::getObjectType, objectType);
  109. query.lambda().orderByAsc(UserRelationEntity::getSortCode).orderByDesc(UserRelationEntity::getCreatorTime);
  110. return this.list(query);
  111. }
  112. @Override
  113. public List<UserRelationEntity> getListByUserIdAll(List<String> userId) {
  114. if (userId.size() > 0) {
  115. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  116. queryWrapper.lambda().in(UserRelationEntity::getUserId, userId);
  117. return this.list(queryWrapper);
  118. }
  119. return new ArrayList<>();
  120. }
  121. @Override
  122. public List<UserRelationEntity> getListByObjectId(String objectId) {
  123. return getListByObjectId(objectId, null);
  124. }
  125. @Override
  126. public List<UserRelationEntity> getListByObjectType(String objectType) {
  127. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  128. queryWrapper.lambda().eq(UserRelationEntity::getObjectType, objectType);
  129. return this.list(queryWrapper);
  130. }
  131. @Override
  132. public List<UserRelationEntity> getListByObjectId(String objectId, String objectType) {
  133. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  134. queryWrapper.lambda().eq(UserRelationEntity::getObjectId, objectId);
  135. if (objectType != null) {
  136. queryWrapper.lambda().eq(UserRelationEntity::getObjectType, objectType);
  137. }
  138. queryWrapper.lambda().orderByAsc(UserRelationEntity::getSortCode).orderByDesc(UserRelationEntity::getCreatorTime);
  139. return this.list(queryWrapper);
  140. }
  141. @Override
  142. public List<UserRelationEntity> getListByObjectIdAll(List<String> objectId) {
  143. List<UserRelationEntity> list = new ArrayList<>();
  144. if (objectId.size() > 0) {
  145. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  146. queryWrapper.lambda().in(UserRelationEntity::getObjectId, objectId);
  147. list = this.list(queryWrapper);
  148. }
  149. return list;
  150. }
  151. @Override
  152. public void deleteAllByObjId(String objId) {
  153. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  154. queryWrapper.lambda().eq(UserRelationEntity::getObjectId, objId);
  155. this.remove(queryWrapper);
  156. }
  157. @Override
  158. public void deleteAllByUserId(String userId) {
  159. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  160. queryWrapper.lambda().eq(UserRelationEntity::getUserId, userId);
  161. queryWrapper.lambda().ne(UserRelationEntity::getObjectType, PermissionConst.GROUP);
  162. userRelationService.remove(queryWrapper);
  163. }
  164. @Override
  165. public void createByList(List<UserRelationEntity> userRelationEntityList) {
  166. userRelationEntityList.forEach(t -> {
  167. this.save(t);
  168. });
  169. }
  170. @Override
  171. public UserRelationEntity getInfo(String id) {
  172. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  173. queryWrapper.lambda().eq(UserRelationEntity::getId, id);
  174. return this.getOne(queryWrapper);
  175. }
  176. @Override
  177. @DSTransactional
  178. public void save(String objectId, List<UserRelationEntity> entitys) {
  179. List<UserRelationEntity> existList = this.getListByObjectId(objectId);
  180. List<UserRelationEntity> relationList = new ArrayList<>();
  181. for (int i = 0; i < entitys.size(); i++) {
  182. UserRelationEntity entity = entitys.get(i);
  183. entity.setId(RandomUtil.uuId());
  184. entity.setSortCode(Long.parseLong(i + ""));
  185. entity.setCreatorUserId(UserProvider.getUser().getUserId());
  186. if (existList.stream().filter(t -> t.getUserId().equals(entity.getUserId())).count() == 0) {
  187. relationList.add(entity);
  188. }
  189. }
  190. for (UserRelationEntity entity : relationList) {
  191. this.save(entity);
  192. }
  193. }
  194. @Override
  195. public void save(List<UserRelationEntity> list) {
  196. for (UserRelationEntity entity : list) {
  197. this.save(entity);
  198. }
  199. }
  200. @Override
  201. @DSTransactional
  202. public void delete(UserRelationForm form) {
  203. List<String> userIds = form.getUserIds();
  204. String type = form.getObjectType();
  205. if (CollectionUtil.isEmpty(userIds)) {
  206. return;
  207. }
  208. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  209. queryWrapper.lambda().eq(UserRelationEntity::getObjectId, form.getObjectId());
  210. queryWrapper.lambda().eq(UserRelationEntity::getObjectType, type);
  211. queryWrapper.lambda().in(UserRelationEntity::getUserId, userIds);
  212. List<UserRelationEntity> list = this.list(queryWrapper);
  213. if (CollectionUtil.isEmpty(list)) {
  214. return;
  215. }
  216. if (PermissionConst.POSITION.equals(type)) {
  217. PositionEntity info = positionService.getInfo(form.getObjectId());
  218. //如果责任人被移除则清空责任人
  219. if (StringUtil.isNotEmpty(info.getDutyUser()) && userIds.contains(info.getDutyUser())) {
  220. info.setDutyUser(null);
  221. positionService.updateById(info);
  222. }
  223. //岗位时顺便移除组织关系
  224. for (String userId : userIds) {
  225. queryWrapper = new QueryWrapper<>();
  226. queryWrapper.lambda().eq(UserRelationEntity::getObjectId, info.getOrganizeId());
  227. queryWrapper.lambda().eq(UserRelationEntity::getObjectType, PermissionConst.ORGANIZE);
  228. queryWrapper.lambda().in(UserRelationEntity::getUserId, userId);
  229. List<UserRelationEntity> orgList = this.list(queryWrapper);
  230. if (CollectionUtil.isNotEmpty(orgList)) {
  231. list.add(orgList.get(0));
  232. }
  233. }
  234. }
  235. for (UserRelationEntity item : list) {
  236. this.removeById(item);
  237. }
  238. if (PermissionConst.POSITION.equals(type)) {
  239. userService.delCurUser(MsgCode.PS010.get(), form.getUserIds());
  240. }
  241. }
  242. @Override
  243. @DSTransactional
  244. public void saveObjectId(String objectId, UserRelationForm userRelationForm) {
  245. UserInfo userInfo = UserProvider.getUser();
  246. //调整岗位(直接替换用户全部岗位绑定信息)
  247. if (Objects.equals(userRelationForm.getActionType(), 1)) {
  248. List<UserRelationEntity> listByUserIdAll = userRelationService.getListByUserIdAll(userRelationForm.getUserIds());
  249. //用户列表绑定的关系数据
  250. List<UserRelationEntity> collect = listByUserIdAll.stream().filter(t -> Objects.equals(t.getObjectType(), userRelationForm.getObjectType())).collect(Collectors.toList());
  251. //替换::直接移除原有数据添加新的数据
  252. removeBatchByIds(collect);
  253. List<UserRelationEntity> list = new ArrayList<>();
  254. for (String userId : userRelationForm.getUserIds()) {
  255. UserRelationEntity entity = new UserRelationEntity();
  256. entity.setId(RandomUtil.uuId());
  257. entity.setObjectId(objectId);
  258. entity.setObjectType(userRelationForm.getObjectType());
  259. entity.setCreatorUserId(userInfo.getUserId());
  260. entity.setUserId(userId);
  261. list.add(entity);
  262. }
  263. save(list);
  264. return;
  265. }
  266. // 修改前的岗位绑定人员ID
  267. List<UserRelationEntity> listByObjectId = userRelationService.getListByObjectId(objectId, userRelationForm.getObjectType());
  268. List<String> beforeUserIds = listByObjectId.stream().map(UserRelationEntity::getUserId).collect(Collectors.toList());
  269. // 调整前后,岗位全部用户
  270. List<String> allUser = new ArrayList<>(userRelationForm.getUserIds());
  271. allUser.addAll(beforeUserIds);
  272. userRelationForm.setUserIds(userService.getUserList(allUser).stream().map(UserEntity::getId).collect(Collectors.toList()));
  273. //清除原有成员数据
  274. deleteAllByObjId(objectId);
  275. List<UserRelationEntity> list = new ArrayList<>();
  276. int i = 0;
  277. for (String userId : userRelationForm.getUserIds()) {
  278. UserRelationEntity entity = new UserRelationEntity();
  279. entity.setId(RandomUtil.uuId());
  280. entity.setSortCode(Long.parseLong(i + ""));
  281. entity.setObjectId(objectId);
  282. entity.setObjectType(userRelationForm.getObjectType());
  283. entity.setCreatorUserId(userInfo.getUserId());
  284. entity.setUserId(userId);
  285. list.add(entity);
  286. i++;
  287. }
  288. save(objectId, list);
  289. // 移除数据库不在最终用户列表里的人
  290. List<String> allUpdateIds = beforeUserIds.stream().filter(b -> !userRelationForm.getUserIds()
  291. .contains(b)).collect(Collectors.toList());
  292. userService.delCurUser(MsgCode.PS010.get(), allUpdateIds);
  293. }
  294. @Override
  295. public List<UserRelationEntity> getRelationByUserIds(List<String> userIds) {
  296. if (userIds.size() == 0) {
  297. return new ArrayList<>();
  298. }
  299. QueryWrapper<UserRelationEntity> query = new QueryWrapper<>();
  300. query.lambda().in(UserRelationEntity::getUserId, userIds);
  301. return this.list(query);
  302. }
  303. @Override
  304. public List<UserRelationEntity> getListByObjectType(String userId, String objectType) {
  305. QueryWrapper<UserRelationEntity> query = new QueryWrapper<>();
  306. query.lambda().eq(UserRelationEntity::getUserId, userId);
  307. if (StringUtil.isNotEmpty(objectType)) {
  308. query.lambda().eq(UserRelationEntity::getObjectType, objectType);
  309. }
  310. query.lambda().orderByAsc(UserRelationEntity::getSortCode).orderByDesc(UserRelationEntity::getCreatorTime);
  311. return this.list(query);
  312. }
  313. @Override
  314. public List<UserRelationEntity> getAllOrgRelationByUserId(String userId) {
  315. return this.getListByObjectType(userId, PermissionConst.ORGANIZE);
  316. }
  317. @Override
  318. public List<PosistionCurrentModel> getObjectVoList() {
  319. UserInfo user = UserProvider.getUser();
  320. String userId = user.getUserId();
  321. String majorPosId = user.getPositionId();
  322. // 岗位遵循一对多关系
  323. List<PositionEntity> positionList = positionService.getListByUserId(userId);
  324. if (positionList.size() > 0) {
  325. List<PosistionCurrentModel> voList = new ArrayList<>();
  326. for (PositionEntity p : positionList) {
  327. PosistionCurrentModel model = new PosistionCurrentModel();
  328. OrganizeEntity orgInfo = organizeService.getInfo(p.getOrganizeId());
  329. model.setId(p.getId());
  330. model.setPositionId(p.getId());
  331. model.setFullName(p.getFullName());
  332. model.setOrganizeId(orgInfo.getId());
  333. model.setOrgTreeName(orgInfo.getOrgNameTree());
  334. //上级岗位
  335. if (StringUtil.isNotEmpty(p.getParentId())) {
  336. PositionEntity pPosition = positionService.getInfo(p.getParentId());
  337. if (pPosition != null) {
  338. model.setParentId(pPosition.getId());
  339. model.setParentName(pPosition.getFullName());
  340. UserEntity dutyUser = userService.getInfo(pPosition.getDutyUser());
  341. if (dutyUser != null) {
  342. model.setManagerId(dutyUser.getId());
  343. model.setManagerName(dutyUser.getRealName());
  344. }
  345. }
  346. } else {
  347. //没有上级岗位的时候--岗位为空,上级责任人去组织上级责任岗位的责任人
  348. OrganizeEntity pOrgInfo = organizeService.getInfo(orgInfo.getParentId());
  349. if (pOrgInfo != null) {
  350. PositionEntity dutyPos = positionService.getInfo(pOrgInfo.getDutyPosition());
  351. if (dutyPos != null) {
  352. UserEntity dutyUser = userService.getInfo(dutyPos.getDutyUser());
  353. if (dutyUser != null) {
  354. model.setManagerId(dutyUser.getId());
  355. model.setManagerName(dutyUser.getRealName());
  356. }
  357. }
  358. }
  359. }
  360. model.setManagerId(p.getId());
  361. if (p.getId().equals(majorPosId)) {
  362. model.setIsDefault(true);
  363. } else {
  364. model.setIsDefault(false);
  365. }
  366. voList.add(model);
  367. }
  368. return voList;
  369. }
  370. return Collections.EMPTY_LIST;
  371. }
  372. @Override
  373. public Boolean existByObj(String objectType, String objectId) {
  374. return existByObj(objectType, Arrays.asList(objectId));
  375. }
  376. @Override
  377. public Boolean existByObj(String objectType, List<String> objectId) {
  378. if (CollectionUtil.isEmpty(objectId)) return false;
  379. QueryWrapper<UserRelationEntity> query = new QueryWrapper<>();
  380. query.lambda()
  381. .eq(UserRelationEntity::getObjectType, objectType)
  382. .in(UserRelationEntity::getObjectId, objectId);
  383. return this.count(query) > 0;
  384. }
  385. @Override
  386. public List<UserRelationEntity> getListByRoleId(String roleId) {
  387. List<UserRelationEntity> list = new ArrayList<>();
  388. roleRelationService.getListByRoleId(roleId, PermissionConst.ORGANIZE).forEach(o -> {
  389. QueryWrapper<UserRelationEntity> query = new QueryWrapper<>();
  390. query.lambda()
  391. .eq(UserRelationEntity::getObjectType, PermissionConst.ORGANIZE)
  392. .eq(UserRelationEntity::getObjectId, o.getObjectId());
  393. list.addAll(this.list(query));
  394. });
  395. return list;
  396. }
  397. @Override
  398. public List<UserRelationEntity> getListByUserId(String userId, String objectType) {
  399. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  400. queryWrapper.lambda().eq(UserRelationEntity::getUserId, userId);
  401. queryWrapper.lambda().eq(UserRelationEntity::getObjectType, objectType);
  402. return this.list(queryWrapper);
  403. }
  404. @Override
  405. public List<UserRelationEntity> getListByOrgId(List<String> orgIdList) {
  406. if (CollectionUtil.isNotEmpty(orgIdList)) {
  407. QueryWrapper<UserRelationEntity> queryWrapper = new QueryWrapper<>();
  408. queryWrapper.lambda().eq(UserRelationEntity::getObjectType, PermissionConst.ORGANIZE);
  409. List<List<String>> lists = Lists.partition(orgIdList, 1000);
  410. queryWrapper.lambda().and(t->{
  411. for (List<String> ids : lists) {
  412. t.or().in(UserRelationEntity::getObjectId, ids);
  413. }
  414. });
  415. return this.list(queryWrapper);
  416. }
  417. return new ArrayList<>();
  418. }
  419. @Override
  420. public void syncDingUserRelation(String sysObjId, List<Long> deptIdList, String thirdType) {
  421. // 查询对应的中间表,获取到对应的本地组织id
  422. QueryWrapper<SynThirdInfoEntity> wrapper = new QueryWrapper<>();
  423. wrapper.lambda().in(SynThirdInfoEntity::getThirdObjId, deptIdList);
  424. wrapper.lambda().eq(SynThirdInfoEntity::getThirdType, thirdType);
  425. wrapper.lambda().eq(SynThirdInfoEntity::getDataType, Integer.valueOf(SynThirdConsts.DATA_TYPE_ORG));
  426. List<SynThirdInfoEntity> synThirdInfoLists = synThirdInfoService.getBaseMapper().selectList(wrapper);
  427. HashMap<String, String> map = new HashMap<>();
  428. for (SynThirdInfoEntity obj : synThirdInfoLists) {
  429. map.put(obj.getThirdObjId(), obj.getSysObjId());
  430. }
  431. // 已经存在的数据
  432. List<String> collect = synThirdInfoLists.stream().map(SynThirdInfoEntity::getSysObjId).collect(Collectors.toList());
  433. QueryWrapper<UserRelationEntity> relationWrapper = new QueryWrapper<>();
  434. if (CollectionUtil.isNotEmpty(collect)) {
  435. relationWrapper.lambda().in(UserRelationEntity::getObjectId, collect);
  436. }
  437. relationWrapper.lambda().eq(UserRelationEntity::getObjectType, PermissionConst.ORGANIZE);
  438. relationWrapper.lambda().eq(UserRelationEntity::getUserId, sysObjId);
  439. List<UserRelationEntity> userRelationEntities = this.getBaseMapper().selectList(relationWrapper);
  440. ArrayList<UserRelationEntity> entities = new ArrayList<>();
  441. List<UserRelationEntity> relationEntities = userRelationEntities.stream()
  442. .filter(t -> collect.contains(t.getObjectId()))
  443. .collect(Collectors.toList());
  444. List<PositionEntity> positionEntities = positionService.getList(true);
  445. if (CollectionUtil.isEmpty(relationEntities)) {
  446. for (String string : collect) {
  447. UserRelationEntity userRelationEntity = new UserRelationEntity();
  448. userRelationEntity.setObjectType(PermissionConst.ORGANIZE);
  449. userRelationEntity.setUserId(sysObjId);
  450. userRelationEntity.setObjectId(string);
  451. List<PositionEntity> positionEntityList = positionEntities.stream()
  452. .filter(t -> t.getOrganizeId().equals(string)
  453. && t.getDefaultMark().equals(1)).collect(Collectors.toList());
  454. if (CollectionUtil.isNotEmpty(positionEntityList)) {
  455. UserRelationEntity positionUserRelation = new UserRelationEntity();
  456. positionUserRelation.setObjectType(PermissionConst.POSITION);
  457. positionUserRelation.setObjectId(positionEntityList.get(0).getId());
  458. positionUserRelation.setUserId(sysObjId);
  459. entities.add(positionUserRelation);
  460. }
  461. entities.add(userRelationEntity);
  462. }
  463. }
  464. userRelationService.saveBatch(entities);
  465. // UserEntity adminAccount = userService.getUserByAccount(ADMIN_KEY);
  466. // String adminId = adminAccount == null ? null : adminAccount.getId();
  467. // for (Long id : deptIdList) {
  468. // String objectId = String.valueOf(id);
  469. // entity = new UserRelationEntity();
  470. // entity.setId(RandomUtil.uuId());
  471. // entity.setObjectId(map.get(objectId));
  472. // entity.setCreatorUserId(adminId);
  473. // entity.setSortCode(0L);
  474. // entity.setUserId(sysObjId);
  475. // entity.setObjectType("Organize");
  476. // list.add(entity);
  477. // }
  478. // this.saveBatch(list);
  479. }
  480. @Override
  481. public List<UserEntity> getUserProgeny(List<String> idList, String enableMark) {
  482. //查询用户子孙下级。不包含当前岗位的用户
  483. if (CollectionUtil.isEmpty(idList)) return new ArrayList<>();
  484. QueryWrapper<PositionEntity> query = new QueryWrapper<>();
  485. query.lambda()
  486. .eq(enableMark != null, PositionEntity::getEnabledMark, enableMark)
  487. .and(t -> idList.forEach(id -> t.like(PositionEntity::getPositionIdTree, id).or()))
  488. .notIn(PositionEntity::getId, idList)
  489. .orderByAsc(PositionEntity::getSortCode, PositionEntity::getCreatorTime);
  490. List<PositionEntity> list = positionService.list(query).stream().distinct().collect(Collectors.toList());
  491. return getUserEntities(list);
  492. }
  493. @Override
  494. public List<UserEntity> getUserAndSub(List<String> idList, String enableMark) {
  495. if (CollectionUtil.isEmpty(idList)) return new ArrayList<>();
  496. List<PositionEntity> byParentIds = positionService.getListByParentIds(idList);
  497. return getUserEntities(byParentIds);
  498. }
  499. private List<UserEntity> getUserEntities(List<PositionEntity> byParentIds) {
  500. if (CollectionUtil.isEmpty(byParentIds)) return new ArrayList<>();
  501. List<UserRelationEntity> listByObjectIdAll = this.getListByObjectIdAll(byParentIds.stream()
  502. .map(SuperBaseEntity.SuperIBaseEntity::getId).collect(Collectors.toList()));
  503. return userService.getUserList(listByObjectIdAll.stream()
  504. .map(UserRelationEntity::getUserId).collect(Collectors.toList()));
  505. }
  506. }