package org.jeecg.modules.system.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import org.apache.shiro.SecurityUtils;
|
import org.jeecg.common.constant.SymbolConstant;
|
import org.jeecg.common.constant.TenantConstant;
|
import org.jeecg.common.system.vo.LoginUser;
|
import org.jeecg.common.util.SpringContextUtils;
|
import org.jeecg.common.util.oConvertUtils;
|
import org.jeecg.modules.aop.TenantLog;
|
import org.jeecg.modules.system.entity.SysPackPermission;
|
import org.jeecg.modules.system.entity.SysTenant;
|
import org.jeecg.modules.system.entity.SysTenantPack;
|
import org.jeecg.modules.system.entity.SysTenantPackUser;
|
import org.jeecg.modules.system.mapper.SysPackPermissionMapper;
|
import org.jeecg.modules.system.mapper.SysTenantPackMapper;
|
import org.jeecg.modules.system.mapper.SysTenantPackUserMapper;
|
import org.jeecg.modules.system.service.ISysTenantPackService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.sql.DataSource;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description: 租户产品包
|
* @Author: jeecg-boot
|
* @Date: 2022-12-31
|
* @Version: V1.0
|
*/
|
@Service
|
public class SysTenantPackServiceImpl extends ServiceImpl<SysTenantPackMapper, SysTenantPack> implements ISysTenantPackService {
|
|
@Autowired
|
private SysTenantPackMapper sysTenantPackMapper;
|
|
@Autowired
|
private SysTenantPackUserMapper sysTenantPackUserMapper;
|
|
@Autowired
|
private SysPackPermissionMapper sysPackPermissionMapper;
|
|
@Override
|
public void addPackPermission(SysTenantPack sysTenantPack) {
|
sysTenantPackMapper.insert(sysTenantPack);
|
String permissionIds = sysTenantPack.getPermissionIds();
|
if (oConvertUtils.isNotEmpty(permissionIds)) {
|
String packId = sysTenantPack.getId();
|
String[] permissionIdArray = permissionIds.split(SymbolConstant.COMMA);
|
for (String permissionId : permissionIdArray) {
|
this.addPermission(packId, permissionId);
|
}
|
}
|
|
}
|
|
@Override
|
public List<SysTenantPack> setPermissions(List<SysTenantPack> records) {
|
for (SysTenantPack pack : records) {
|
List<String> permissionIds = sysPackPermissionMapper.getPermissionsByPackId(pack.getId());
|
if (null != permissionIds && permissionIds.size() > 0) {
|
String ids = String.join(SymbolConstant.COMMA, permissionIds);
|
pack.setPermissionIds(ids);
|
}
|
}
|
return records;
|
}
|
|
@Override
|
public void editPackPermission(SysTenantPack sysTenantPack) {
|
//数据库汇总的id
|
List<String> oldPermissionIds = sysPackPermissionMapper.getPermissionsByPackId(sysTenantPack.getId());
|
//前台传过来的需要修改的id
|
String permissionIds = sysTenantPack.getPermissionIds();
|
//如果传过来的菜单id为空，那么就删除数据库中所有菜单
|
if (oConvertUtils.isEmpty(permissionIds)) {
|
this.deletePackPermission(sysTenantPack.getId(), null);
|
} else if (oConvertUtils.isNotEmpty(permissionIds) && oConvertUtils.isEmpty(oldPermissionIds)) {
|
//如果传过来的菜单id不为空但是数据库的菜单id为空，那么就新增
|
this.addPermission(sysTenantPack.getId(), permissionIds);
|
} else {
|
//都不为空，需要比较，进行添加或删除
|
if (oConvertUtils.isNotEmpty(oldPermissionIds)) {
|
//找到新的租户id与原来的租户id不同之处，进行删除
|
List<String> permissionList = oldPermissionIds.stream().filter(item -> !permissionIds.contains(item)).collect(Collectors.toList());
|
if (permissionList.size() > 0) {
|
for (String permission : permissionList) {
|
this.deletePackPermission(sysTenantPack.getId(), permission);
|
}
|
}
|
|
//找到原来菜单id与新的菜单id不同之处,进行新增
|
List<String> permissionAddList = Arrays.stream(permissionIds.split(SymbolConstant.COMMA)).filter(item -> !oldPermissionIds.contains(item)).collect(Collectors.toList());
|
if (permissionAddList.size() > 0) {
|
for (String permission : permissionAddList) {
|
this.addPermission(sysTenantPack.getId(), permission);
|
}
|
}
|
}
|
}
|
sysTenantPackMapper.updateById(sysTenantPack);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void deletePackPermissions(String ids) {
|
String[] idsArray = ids.split(SymbolConstant.COMMA);
|
for (String id : idsArray) {
|
this.deletePackPermission(id,null);
|
sysTenantPackMapper.deleteById(id);
|
}
|
}
|
|
@Override
|
public void exitTenant(String tenantId, String userId) {
|
this.getById(tenantId);
|
}
|
|
@Override
|
public void addDefaultTenantPack(Integer tenantId) {
|
// 创建超级管理员
|
SysTenantPack superAdminPack = new SysTenantPack(tenantId, "超级管理员", TenantConstant.SUPER_ADMIN);
|
ISysTenantPackService currentService = SpringContextUtils.getApplicationContext().getBean(ISysTenantPackService.class);
|
String packId = currentService.saveOne(superAdminPack);
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
SysTenantPackUser packUser = new SysTenantPackUser(tenantId, packId, sysUser.getId());
|
packUser.setRealname(sysUser.getRealname());
|
packUser.setPackName(superAdminPack.getPackName());
|
//添加人员和管理员的关系数据
|
currentService.savePackUser(packUser);
|
|
// 创建超级管理员
|
SysTenantPack accountAdminPack = new SysTenantPack(tenantId, "组织账户管理员", TenantConstant.ACCOUNT_ADMIN);
|
currentService.saveOne(accountAdminPack);
|
|
// 创建超级管理员
|
SysTenantPack appAdminPack = new SysTenantPack(tenantId, "组织应用管理员", TenantConstant.APP_ADMIN);
|
currentService.saveOne(appAdminPack);
|
|
}
|
|
@TenantLog(2)
|
@Override
|
public String saveOne(SysTenantPack sysTenantPack) {
|
sysTenantPackMapper.insert(sysTenantPack);
|
return sysTenantPack.getId();
|
}
|
|
@TenantLog(2)
|
@Override
|
public void savePackUser(SysTenantPackUser sysTenantPackUser) {
|
sysTenantPackUser.setStatus(1);
|
sysTenantPackUserMapper.insert(sysTenantPackUser);
|
}
|
|
@Override
|
public SysTenantPack getSysTenantPack(Integer tenantId, String packCode) {
|
LambdaQueryWrapper<SysTenantPack> query = new LambdaQueryWrapper<SysTenantPack>()
|
.eq(SysTenantPack::getPackCode, packCode)
|
.eq(SysTenantPack::getTenantId, tenantId);
|
List<SysTenantPack> list = baseMapper.selectList(query);
|
if(list!=null && list.size()>0){
|
SysTenantPack pack = list.get(0);
|
if(pack!=null && pack.getId()!=null){
|
return pack;
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 添加菜单
|
*
|
* @param packId
|
* @param permissionId
|
*/
|
public void addPermission(String packId, String permissionId) {
|
SysPackPermission permission = new SysPackPermission();
|
permission.setPermissionId(permissionId);
|
permission.setPackId(packId);
|
sysPackPermissionMapper.insert(permission);
|
}
|
|
/**
|
* 根据包名id和菜单id删除关系表
|
*
|
* @param packId
|
* @param permissionId
|
*/
|
public void deletePackPermission(String packId, String permissionId) {
|
LambdaQueryWrapper<SysPackPermission> query = new LambdaQueryWrapper<>();
|
query.eq(SysPackPermission::getPackId, packId);
|
if (oConvertUtils.isNotEmpty(permissionId)) {
|
query.eq(SysPackPermission::getPermissionId, permissionId);
|
}
|
sysPackPermissionMapper.delete(query);
|
}
|
}
|
