package org.jeecg.modules.dnc.service.impl;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.commons.collections4.ListUtils;
|
import org.jeecg.modules.dnc.entity.PermissionStream;
|
import org.jeecg.modules.dnc.entity.PermissionStreamNew;
|
import org.jeecg.modules.dnc.entity.ProductMix;
|
import org.jeecg.modules.dnc.mapper.PermissionStreamNewMapper;
|
import org.jeecg.modules.dnc.service.IPermissionStreamNewService;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class PermissionStreamNewServiceImpl extends ServiceImpl<PermissionStreamNewMapper, PermissionStreamNew> implements IPermissionStreamNewService {
|
|
/**
|
* 根据用户id获取结构树权限
|
* @param userId
|
* @return
|
*/
|
@Override
|
public List<ProductMix> loadProductMix(String userId){
|
return baseMapper.loadProductMix(userId);
|
}
|
|
/**
|
* 通过业务id和业务类型获取权限
|
* @param businessId
|
* @param businessType
|
* @return
|
*/
|
@Override
|
public List<PermissionStreamNew> loadPermissionStreamNewByBusinessId(String businessId,String businessType,String type){
|
QueryWrapper<PermissionStreamNew> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq(StrUtil.isNotEmpty(businessId),"business_id",businessId);
|
queryWrapper.eq(StrUtil.isNotEmpty(businessType),"business_type",businessType);
|
//用户权限，部门字段为空
|
if("0".equals(type)) {
|
queryWrapper.isNotNull("user_id");
|
}else if("1".equals(type)){
|
queryWrapper.isNull("user_id");
|
}
|
queryWrapper.eq("delete_flag",0);
|
return baseMapper.selectList(queryWrapper);
|
}
|
|
/**
|
* 通过业务id和用户id获取权限
|
* @param businessId
|
* @param userId
|
* @return
|
*/
|
@Override
|
public PermissionStreamNew loadPermissionStreamNewByBusinessIdAndUserId(String businessId, String userId,String businessType){
|
QueryWrapper<PermissionStreamNew> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq(StrUtil.isNotEmpty(businessId),"business_id",businessId);
|
queryWrapper.eq(StrUtil.isNotEmpty(userId),"user_id",userId);
|
queryWrapper.eq(StrUtil.isNotEmpty(businessType),"business_type",businessType);
|
queryWrapper.eq("delete_flag",0);
|
queryWrapper.isNull("depart_id");
|
return baseMapper.selectOne(queryWrapper);
|
}
|
|
/**
|
* 通过业务id和业务类型和部门id获取部门权限
|
* @param businessId
|
* @param businessType
|
* @param departId
|
* @return
|
*/
|
@Override
|
public PermissionStreamNew loadPermissionStreamNewByBusinessIdAndDepartId(String businessId, String departId,String businessType){
|
QueryWrapper<PermissionStreamNew> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq(StrUtil.isNotEmpty(businessId),"business_id",businessId);
|
queryWrapper.eq(StrUtil.isNotEmpty(departId),"depart_id",departId);
|
queryWrapper.eq(StrUtil.isNotEmpty(businessType),"business_type",businessType);
|
queryWrapper.eq("delete_flag",0);
|
queryWrapper.isNull("user_id");
|
return baseMapper.selectOne(queryWrapper);
|
}
|
|
/**
|
* 通过businessId获取权限
|
* @param businessId
|
* @return
|
*/
|
@Override
|
public List<PermissionStreamNew> loadProductMixByBusinessId(String businessId,String businessType){
|
QueryWrapper<PermissionStreamNew> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq(StrUtil.isNotEmpty(businessId),"business_id",businessId);
|
queryWrapper.eq(StrUtil.isNotEmpty(businessType),"business_type",businessType);
|
queryWrapper.eq("delete_flag",0);
|
return baseMapper.selectList(queryWrapper);
|
}
|
|
/**
|
* 通过业务id与类型删除权限
|
* @param businessId
|
* @param businessType
|
* @param type 0：用户权限，1：部门权限
|
* @return
|
*/
|
@Override
|
public boolean deletePermissionStreamNewByBusinessId(String businessId,String businessType,String type){
|
QueryWrapper<PermissionStreamNew> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq(StrUtil.isNotEmpty(businessId),"business_id",businessId);
|
queryWrapper.eq(StrUtil.isNotEmpty(businessType),"business_type",businessType);
|
//用户权限，部门字段为空
|
if("0".equals(type)){
|
queryWrapper.isNotNull("user_id");
|
queryWrapper.isNull("depart_id");
|
}else if("1".equals(type)){
|
queryWrapper.isNull("user_id");
|
queryWrapper.isNotNull("depart_id");
|
}
|
queryWrapper.eq("delete_flag",0);
|
return baseMapper.delete(queryWrapper)>0;
|
}
|
|
/**
|
* 通过List<PermissionStreamNew>批量删除
|
* @param permissionStreamNewList
|
* @return
|
*/
|
@Override
|
public boolean deletePermissionStreamNewByList(List<PermissionStreamNew> permissionStreamNewList){
|
if(permissionStreamNewList == null || permissionStreamNewList.isEmpty())
|
return false;
|
if(permissionStreamNewList.size() == 1) {
|
return super.removeById(permissionStreamNewList.get(0).getId());
|
}
|
List<String> ids = new ArrayList<>();
|
permissionStreamNewList.forEach(item -> {
|
ids.add(item.getId());
|
});
|
return super.removeByIds(ids);
|
}
|
|
/**
|
* 通过一组业务id和用户id和类型查询
|
* @param businessIds
|
* @param userIds
|
* @param businessType
|
* @return
|
*/
|
@Override
|
public List<PermissionStreamNew> loadPermissionStreamNewByBusinessIdsAndUserIds(List<String> businessIds,List<String> userIds,String businessType){
|
if(businessIds == null || businessIds.isEmpty() || userIds == null || userIds.isEmpty())
|
return null;
|
List<PermissionStreamNew> total = new ArrayList<>();
|
List<List<String>> compListArr;
|
List<List<String>> userIdsArr;
|
if(businessIds.size() > 1000){
|
compListArr = ListUtils.partition(businessIds, 100);
|
}else {
|
compListArr = ListUtils.partition(businessIds, 1000);
|
}
|
if(userIds.size() > 1000){
|
userIdsArr = ListUtils.partition(userIds, 100);
|
}else {
|
userIdsArr = ListUtils.partition(userIds, 1000);
|
}
|
for(List<String> compList : compListArr) {
|
for(List<String> userIdList : userIdsArr){
|
LambdaQueryWrapper<PermissionStreamNew> queryWrapper = Wrappers.lambdaQuery();
|
queryWrapper.in(PermissionStreamNew::getBusinessId, compList);
|
queryWrapper.in(PermissionStreamNew::getUserId, userIdList);
|
queryWrapper.eq(PermissionStreamNew::getBusinessType, businessType);
|
queryWrapper.isNull(PermissionStreamNew::getDepartId);
|
queryWrapper.eq(PermissionStreamNew::getDeleteFlag,0);
|
List<PermissionStreamNew> list = super.list(queryWrapper);
|
if(list != null && !list.isEmpty()){
|
total.addAll(list);
|
}
|
}
|
}
|
return total;
|
}
|
|
/**
|
* 通过一组业务id和部门id和类型查询
|
* @param businessIds
|
* @param departIds
|
* @param businessType
|
* @return
|
*/
|
@Override
|
public List<PermissionStreamNew> loadPermissionStreamNewByBusinessIdsAndDepartIds(List<String> businessIds,List<String> departIds,String businessType){
|
if(businessIds == null || businessIds.isEmpty() || departIds == null || departIds.isEmpty())
|
return null;
|
List<PermissionStreamNew> total = new ArrayList<>();
|
List<List<String>> compListArr;
|
List<List<String>> departListArr;
|
if(businessIds.size() > 1000){
|
compListArr = ListUtils.partition(businessIds, 100);
|
}else {
|
compListArr = ListUtils.partition(businessIds, 1000);
|
}
|
if(departIds.size() > 1000){
|
departListArr = ListUtils.partition(departIds, 100);
|
}else {
|
departListArr = ListUtils.partition(departIds, 1000);
|
}
|
for(List<String> compList : compListArr) {
|
for(List<String> departList : departListArr){
|
LambdaQueryWrapper<PermissionStreamNew> queryWrapper = Wrappers.lambdaQuery();
|
queryWrapper.in(PermissionStreamNew::getBusinessId, compList);
|
queryWrapper.in(PermissionStreamNew::getDepartId, departList);
|
queryWrapper.eq(PermissionStreamNew::getBusinessType, businessType);
|
queryWrapper.isNull(PermissionStreamNew::getUserId);
|
queryWrapper.eq(PermissionStreamNew::getDeleteFlag,0);
|
List<PermissionStreamNew> list = super.list(queryWrapper);
|
if(list != null && !list.isEmpty()){
|
total.addAll(list);
|
}
|
}
|
}
|
return total;
|
}
|
|
}
|
