package org.jeecg.modules.system.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import org.apache.commons.lang.StringUtils;
|
import org.jeecg.common.constant.CacheConstant;
|
import org.jeecg.common.constant.CommonConstant;
|
import org.jeecg.common.constant.SymbolConstant;
|
import org.jeecg.common.exception.JeecgBootException;
|
import org.jeecg.common.util.oConvertUtils;
|
import org.jeecg.modules.system.entity.SysUser;
|
import org.jeecg.modules.system.entity.SysUserTenant;
|
import org.jeecg.modules.system.mapper.SysUserMapper;
|
import org.jeecg.modules.system.mapper.SysUserTenantMapper;
|
import org.jeecg.modules.system.service.ISysUserTenantService;
|
import org.jeecg.modules.system.vo.SysUserDepVo;
|
import org.jeecg.modules.system.vo.SysUserTenantVo;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.cache.annotation.CacheEvict;
|
import org.springframework.stereotype.Service;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description: sys_user_tenant_relation
|
* @Author: jeecg-boot
|
* @Date: 2022-12-23
|
* @Version: V1.0
|
*/
|
@Service
|
public class SysUserTenantServiceImpl extends ServiceImpl<SysUserTenantMapper, SysUserTenant> implements ISysUserTenantService {
|
|
@Autowired
|
private SysUserTenantMapper userTenantMapper;
|
|
@Autowired
|
private SysUserMapper userMapper;
|
|
@Override
|
public Page<SysUser> getPageUserList(Page<SysUser> page, Integer userTenantId, SysUser user) {
|
return page.setRecords(userTenantMapper.getPageUserList(page,userTenantId,user));
|
}
|
|
@Override
|
public List<SysUser> setUserTenantIds(List<SysUser> records) {
|
if(null == records || records.size() == 0){
|
return records;
|
}
|
for (SysUser sysUser:records) {
|
//查询租户id
|
List<Integer> list = userTenantMapper.getTenantIdsByUserId(sysUser.getId());
|
if(oConvertUtils.isNotEmpty(list)){
|
sysUser.setRelTenantIds(StringUtils.join(list.toArray(), SymbolConstant.COMMA));
|
}else{
|
sysUser.setRelTenantIds("");
|
}
|
}
|
return records;
|
}
|
|
@Override
|
public List<String> getUserIdsByTenantId(Integer tenantId) {
|
return userTenantMapper.getUserIdsByTenantId(tenantId);
|
}
|
|
@Override
|
public List<Integer> getTenantIdsByUserId(String userId) {
|
return userTenantMapper.getTenantIdsByUserId(userId);
|
}
|
|
@Override
|
public List<SysUserTenantVo> getTenantListByUserId(String userId, List<String> userTenantStatus) {
|
return userTenantMapper.getTenantListByUserId(userId, userTenantStatus);
|
}
|
|
@Override
|
public void updateUserTenantStatus(String id, String tenantId, String userTenantStatus) {
|
if (oConvertUtils.isEmpty(tenantId)) {
|
throw new JeecgBootException("租户数据为空");
|
}
|
LambdaQueryWrapper<SysUserTenant> query = new LambdaQueryWrapper<>();
|
query.eq(SysUserTenant::getUserId, id);
|
query.eq(SysUserTenant::getTenantId, Integer.valueOf(tenantId));
|
SysUserTenant userTenant = userTenantMapper.selectOne(query);
|
if (null == userTenant) {
|
throw new JeecgBootException("租户数据为空");
|
}
|
SysUserTenant tenant = new SysUserTenant();
|
tenant.setStatus(userTenantStatus);
|
this.update(tenant, query);
|
}
|
|
@Override
|
public IPage<SysUserTenantVo> getUserTenantPageList(Page<SysUserTenantVo> page, List<String> status, SysUser user, Integer tenantId) {
|
List<SysUserTenantVo> tenantPageList = userTenantMapper.getUserTenantPageList(page, status, user, tenantId);
|
List<String> userIds = tenantPageList.stream().map(SysUserTenantVo::getId).collect(Collectors.toList());
|
if (userIds != null && userIds.size() > 0) {
|
Map<String, String> useDepNames = this.getDepNamesByUserIds(userIds);
|
tenantPageList.forEach(item -> {
|
item.setOrgCodeTxt(useDepNames.get(item.getId()));
|
//查询用户的租户ids
|
List<Integer> list = userTenantMapper.getTenantIdsNoStatus(item.getId());
|
if (oConvertUtils.isNotEmpty(list)) {
|
item.setRelTenantIds(StringUtils.join(list.toArray(), SymbolConstant.COMMA));
|
} else {
|
item.setRelTenantIds("");
|
}
|
});
|
}
|
return page.setRecords(tenantPageList);
|
}
|
|
/**
|
* 根据用户id获取部门名称
|
*
|
* @param userIds
|
* @return
|
*/
|
public Map<String, String> getDepNamesByUserIds(List<String> userIds) {
|
List<SysUserDepVo> list = userMapper.getDepNamesByUserIds(userIds);
|
Map<String, String> res = new HashMap(5);
|
list.forEach(item -> {
|
if (res.get(item.getUserId()) == null) {
|
res.put(item.getUserId(), item.getDepartName());
|
} else {
|
res.put(item.getUserId(), res.get(item.getUserId()) + "," + item.getDepartName());
|
}
|
}
|
);
|
return res;
|
}
|
|
@Override
|
@CacheEvict(value={CacheConstant.SYS_USERS_CACHE}, allEntries=true)
|
@Transactional(rollbackFor = Exception.class)
|
public void putCancelQuit(List<String> userIds, Integer tenantId) {
|
userTenantMapper.putCancelQuit(userIds, tenantId);
|
}
|
|
@Override
|
public Integer userTenantIzExist(String userId, Integer tenantId) {
|
return userTenantMapper.userTenantIzExist(userId,tenantId);
|
}
|
}
|
