| | |
| | | if(list !=null && list.size()>0) { |
| | | List<Member> addList = new ArrayList<>(); |
| | | List<Member> updateList = new ArrayList<>(); |
| | | List<Integer> delIds = new ArrayList<>(); |
| | | List<Integer> delIds = new ArrayList<>(); |
| | | List<Member> delList = new ArrayList<>(); |
| | | List<Member> allList = memberMapper.selectList(new QueryWrapper<Member>().lambda() |
| | | .eq(Member::getIsdeleted,Constants.ZERO) |
| | | .eq(Member::getType, Constants.memberType.internal)); |
| | | dealUserChangeList(list,addList,updateList,delIds,allList); |
| | | dealUserChangeList(list,addList,updateList,delList,allList); |
| | | if(addList.size()>0){ |
| | | for (Member member:addList) { |
| | | dealRoleEmpower(member,param.getStartTime(), param.getEndTime()); |
| | | } |
| | | memberMapper.insertBatchSomeColumn(addList); |
| | | } |
| | | if(updateList.size()>0){ |
| | | for(Member c : updateList){ |
| | | dealRoleEmpower(c,param.getStartTime(), param.getEndTime()); |
| | | memberMapper.updateById(c); |
| | | } |
| | | } |
| | | if(delIds.size()>0){ |
| | | //删除所有需要删除的组织信息(逻辑删除) |
| | | if(delList.size()>0){ |
| | | for (Member member:delList) { |
| | | dealRoleEmpower(member,param.getStartTime(), param.getEndTime()); |
| | | } |
| | | delIds = delList.stream().map(m->m.getId()).collect(Collectors.toList()); |
| | | memberMapper.update(null,new UpdateWrapper<Member>().lambda().set(Member::getHkStatus,Constants.ZERO) |
| | | .set(Member::getIsdeleted, Constants.ONE).in(Member::getId,delIds)); |
| | | } |
| | | |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "同步ERP数据为空!"); |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | private void dealUserChangeList(List<UserListRespone> list, List<Member> addList, List<Member> updateList, List<Integer> delIds, List<Member> allList) { |
| | | public void dealRoleEmpower(Member member,Date startTime , Date endTime){ |
| | | List<Integer> doorIds = null; |
| | | doorIds = getRoleIdByParam(member.getRoleIds(),member); |
| | | //如果有授权门禁数据,进行用户授权数据下发任务创建 |
| | | dealMemberRoleEmpower(member,doorIds,startTime,endTime); |
| | | } |
| | | |
| | | |
| | | private void dealUserChangeList(List<UserListRespone> list, List<Member> addList, List<Member> updateList,List<Member> delList, List<Member> allList) { |
| | | Date date = new Date(); |
| | | for(UserListRespone response : list){ |
| | | //根据 erpId 查询用户信息,判断是新增还是更新 |
| | |
| | | //如果是更新 |
| | | if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){ |
| | | //如果已删除,加入删除集合中 |
| | | delIds.add(member.getId()); |
| | | member.setRoleIds(response.getRoleIds()); |
| | | delList.add(member); |
| | | // delIds.add(member.getId()); |
| | | |
| | | continue; |
| | | } |
| | | updateList.add(addUpdateMemberModel(response,member,date)); |
| | |
| | | if(allList!=null && allList.size()>0){ |
| | | for(Member c : allList){ |
| | | if(isUserDeleted(c,list)){ |
| | | delIds.add(c.getId()); |
| | | delList.add(c); |
| | | // delIds.add(c.getId()); |
| | | } |
| | | } |
| | | } |
| | |
| | | member.setIdcardDecode(Constants.getTuominStr(param.getIdNo())); |
| | | member.setCompanyId(param.getOrgId()); |
| | | member.setHkStatus(Constants.ZERO); |
| | | member.setRoleIds(param.getRoleIds()); |
| | | return member; |
| | | } |
| | | |
| | |
| | | member.setEditDate(new Date()); |
| | | member.setErpDate(new Date()); |
| | | member.setHkStatus(Constants.ZERO); |
| | | member.setRoleIds(param.getRoleIds()); |
| | | return member; |
| | | } |
| | | |
| | | private boolean isUserDeleted(Member c, List<UserListRespone> list) { |
| | | for(UserListRespone m : list){ |
| | | if(StringUtils.equals(c.getErpId(),m.getId().toString())){ |
| | | c.setRoleIds(m.getRoleIds()); |
| | | return true; |
| | | } |
| | | } |
| | |
| | | */ |
| | | private void dealMemberRoleEmpower(Member member, List<Integer> doorIds,Date startTime,Date endTime ) { |
| | | //删除所有老的授权信息 |
| | | empowerMapper.update(null,new UpdateWrapper<Empower>().lambda() |
| | | // empowerMapper.update(null,new UpdateWrapper<Empower>().lambda() |
| | | // .eq(Empower::getMemberId,member.getId()) |
| | | // .set(Empower::getIsdeleted,Constants.ONE) |
| | | // .set(Empower::getSendStatus,Constants.ZERO) |
| | | // ); |
| | | empowerMapper.delete(new UpdateWrapper<Empower>().lambda() |
| | | .eq(Empower::getMemberId,member.getId()) |
| | | .set(Empower::getIsdeleted,Constants.ONE) |
| | | .set(Empower::getSendStatus,Constants.ZERO) |
| | | ); |
| | | if(doorIds==null || doorIds.size() == 0){ |
| | | return; |
| | |
| | | try{ |
| | | if(Objects.isNull(param) |
| | | ||Objects.isNull(param.getId()) |
| | | ||Objects.isNull(param.getStatus()) |
| | | ){ |
| | | ||Objects.isNull(param.getStatus())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | if(!(param.getStatus()==Constants.ZERO||param.getStatus()==Constants.ONE)){ |