smallchill
6 years ago
21 changed files with 470 additions and 1 deletions
@ -0,0 +1,32 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?> |
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" |
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
||||
<parent> |
||||
<artifactId>blade-service-api</artifactId> |
||||
<groupId>org.springblade</groupId> |
||||
<version>2.0.4.RELEASE</version> |
||||
</parent> |
||||
<modelVersion>4.0.0</modelVersion> |
||||
|
||||
<artifactId>blade-datascope-api</artifactId> |
||||
<name>${project.artifactId}</name> |
||||
<version>${bladex.project.version}</version> |
||||
<packaging>jar</packaging> |
||||
|
||||
<dependencies> |
||||
<dependency> |
||||
<groupId>org.springblade</groupId> |
||||
<artifactId>blade-starter-cache</artifactId> |
||||
<version>${bladex.tool.version}</version> |
||||
</dependency> |
||||
<dependency> |
||||
<groupId>org.springblade</groupId> |
||||
<artifactId>blade-starter-datascope</artifactId> |
||||
<version>${bladex.tool.version}</version> |
||||
</dependency> |
||||
</dependencies> |
||||
|
||||
|
||||
|
||||
</project> |
||||
@ -0,0 +1,92 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.system.cache; |
||||
|
||||
import org.springblade.core.cache.utils.CacheUtil; |
||||
import org.springblade.core.datascope.model.DataScopeModel; |
||||
import org.springblade.core.tool.utils.CollectionUtil; |
||||
import org.springblade.core.tool.utils.SpringUtil; |
||||
import org.springblade.core.tool.utils.StringPool; |
||||
import org.springblade.system.feign.IDataScopeClient; |
||||
|
||||
import java.util.List; |
||||
|
||||
import static org.springblade.core.cache.constant.CacheConstant.SYS_CACHE; |
||||
|
||||
/** |
||||
* 数据权限缓存 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public class DataScopeCache { |
||||
|
||||
private static final String SCOPE_CACHE_CODE = "scope:code:"; |
||||
private static final String SCOPE_CACHE_CLASS = "scope:class:"; |
||||
private static final String DEPT_CACHE_ANCESTORS = "dept:ancestors:"; |
||||
|
||||
private static IDataScopeClient dataScopeClient; |
||||
|
||||
static { |
||||
dataScopeClient = SpringUtil.getBean(IDataScopeClient.class); |
||||
} |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param mapperId 数据权限mapperId |
||||
* @param roleId 用户角色集合 |
||||
* @return DataScopeModel |
||||
*/ |
||||
public static DataScopeModel getDataScopeByMapper(String mapperId, String roleId) { |
||||
DataScopeModel dataScope = CacheUtil.get(SYS_CACHE, SCOPE_CACHE_CLASS, mapperId + StringPool.COLON + roleId, DataScopeModel.class); |
||||
if (dataScope == null) { |
||||
dataScope = dataScopeClient.getDataScopeByMapper(mapperId, roleId); |
||||
CacheUtil.put(SYS_CACHE, SCOPE_CACHE_CLASS, mapperId + StringPool.COLON + roleId, dataScope); |
||||
} |
||||
return dataScope; |
||||
} |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param code 数据权限资源编号 |
||||
* @return DataScopeModel |
||||
*/ |
||||
public static DataScopeModel getDataScopeByCode(String code) { |
||||
DataScopeModel dataScope = CacheUtil.get(SYS_CACHE, SCOPE_CACHE_CODE, code, DataScopeModel.class); |
||||
if (dataScope == null) { |
||||
dataScope = dataScopeClient.getDataScopeByCode(code); |
||||
CacheUtil.put(SYS_CACHE, SCOPE_CACHE_CODE, code, dataScope); |
||||
} |
||||
return dataScope; |
||||
} |
||||
|
||||
/** |
||||
* 获取部门子级 |
||||
* |
||||
* @param deptId 部门id |
||||
* @return deptIds |
||||
*/ |
||||
public static List<Long> getDeptAncestors(Long deptId) { |
||||
List ancestors = CacheUtil.get(SYS_CACHE, DEPT_CACHE_ANCESTORS, deptId, List.class); |
||||
if (CollectionUtil.isEmpty(ancestors)) { |
||||
ancestors = dataScopeClient.getDeptAncestors(deptId); |
||||
CacheUtil.put(SYS_CACHE, DEPT_CACHE_ANCESTORS, deptId, ancestors); |
||||
} |
||||
return ancestors; |
||||
} |
||||
} |
||||
@ -0,0 +1,40 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.system.config; |
||||
|
||||
|
||||
import lombok.AllArgsConstructor; |
||||
import org.springblade.core.datascope.rule.ScopeModelRule; |
||||
import org.springblade.system.rule.DataScopeModelRule; |
||||
import org.springframework.context.annotation.Bean; |
||||
import org.springframework.context.annotation.Configuration; |
||||
|
||||
/** |
||||
* 公共封装包配置类 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
@Configuration |
||||
@AllArgsConstructor |
||||
public class DataScopeConfiguration { |
||||
|
||||
@Bean |
||||
public ScopeModelRule scopeModelRule() { |
||||
return new DataScopeModelRule(); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,72 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.system.feign; |
||||
|
||||
import org.springblade.core.datascope.model.DataScopeModel; |
||||
import org.springblade.core.launch.constant.AppConstant; |
||||
import org.springframework.cloud.openfeign.FeignClient; |
||||
import org.springframework.web.bind.annotation.GetMapping; |
||||
import org.springframework.web.bind.annotation.RequestParam; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 数据权限Feign接口类 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
@FeignClient( |
||||
value = AppConstant.APPLICATION_SYSTEM_NAME, |
||||
fallback = IDataScopeClientFallback.class |
||||
) |
||||
public interface IDataScopeClient { |
||||
|
||||
String API_PREFIX = "/client/data-scope"; |
||||
String GET_DATA_SCOPE_BY_MAPPER = API_PREFIX + "/by-mapper"; |
||||
String GET_DATA_SCOPE_BY_CODE = API_PREFIX + "/by-code"; |
||||
String GET_DEPT_ANCESTORS = API_PREFIX + "/dept-ancestors"; |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param mapperId 数据权限mapperId |
||||
* @param roleId 用户角色集合 |
||||
* @return DataScopeModel |
||||
*/ |
||||
@GetMapping(GET_DATA_SCOPE_BY_MAPPER) |
||||
DataScopeModel getDataScopeByMapper(@RequestParam("mapperId") String mapperId, @RequestParam("roleId") String roleId); |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param code 数据权限资源编号 |
||||
* @return DataScopeModel |
||||
*/ |
||||
@GetMapping(GET_DATA_SCOPE_BY_CODE) |
||||
DataScopeModel getDataScopeByCode(@RequestParam("code") String code); |
||||
|
||||
/** |
||||
* 获取部门子级 |
||||
* |
||||
* @param deptId 部门id |
||||
* @return deptIds |
||||
*/ |
||||
@GetMapping(GET_DEPT_ANCESTORS) |
||||
List<Long> getDeptAncestors(@RequestParam("deptId") Long deptId); |
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,45 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.system.feign; |
||||
|
||||
import org.springblade.core.datascope.model.DataScopeModel; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* IDataScopeClientFallback |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
@Component |
||||
public class IDataScopeClientFallback implements IDataScopeClient { |
||||
@Override |
||||
public DataScopeModel getDataScopeByMapper(String mapperId, String roleId) { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public DataScopeModel getDataScopeByCode(String code) { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public List<Long> getDeptAncestors(Long deptId) { |
||||
return null; |
||||
} |
||||
} |
||||
@ -0,0 +1,65 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.system.rule; |
||||
|
||||
import org.springblade.core.datascope.model.DataScopeModel; |
||||
import org.springblade.core.datascope.rule.ScopeModelRule; |
||||
import org.springblade.system.cache.DataScopeCache; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 通用数据权限规则 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public class DataScopeModelRule implements ScopeModelRule { |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param mapperId 数据权限mapperId |
||||
* @param roleId 用户角色集合 |
||||
* @return DataScopeModel |
||||
*/ |
||||
@Override |
||||
public DataScopeModel getDataScopeByMapper(String mapperId, String roleId) { |
||||
return DataScopeCache.getDataScopeByMapper(mapperId, roleId); |
||||
} |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param code 数据权限资源编号 |
||||
* @return DataScopeModel |
||||
*/ |
||||
@Override |
||||
public DataScopeModel getDataScopeByCode(String code) { |
||||
return DataScopeCache.getDataScopeByCode(code); |
||||
} |
||||
|
||||
/** |
||||
* 获取部门子级 |
||||
* |
||||
* @param deptId 部门id |
||||
* @return deptIds |
||||
*/ |
||||
@Override |
||||
public List<Long> getDeptAncestors(Long deptId) { |
||||
return DataScopeCache.getDeptAncestors(deptId); |
||||
} |
||||
} |
||||
@ -0,0 +1,95 @@
|
||||
/* |
||||
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are met: |
||||
* |
||||
* Redistributions of source code must retain the above copyright notice, |
||||
* this list of conditions and the following disclaimer. |
||||
* Redistributions in binary form must reproduce the above copyright |
||||
* notice, this list of conditions and the following disclaimer in the |
||||
* documentation and/or other materials provided with the distribution. |
||||
* Neither the name of the dreamlu.net developer nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* Author: Chill 庄骞 (smallchill@163.com) |
||||
*/ |
||||
package org.springblade.system.feign; |
||||
|
||||
import lombok.RequiredArgsConstructor; |
||||
import org.springblade.core.datascope.constant.DataScopeConstant; |
||||
import org.springblade.core.datascope.model.DataScopeModel; |
||||
import org.springblade.core.tool.utils.CollectionUtil; |
||||
import org.springblade.core.tool.utils.Func; |
||||
import org.springframework.jdbc.core.BeanPropertyRowMapper; |
||||
import org.springframework.jdbc.core.JdbcTemplate; |
||||
import org.springframework.web.bind.annotation.GetMapping; |
||||
import org.springframework.web.bind.annotation.RestController; |
||||
import springfox.documentation.annotations.ApiIgnore; |
||||
|
||||
import java.util.ArrayList; |
||||
import java.util.Collections; |
||||
import java.util.List; |
||||
|
||||
/** |
||||
* 数据权限Feign实现类 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
@ApiIgnore |
||||
@RestController |
||||
@RequiredArgsConstructor |
||||
public class DataScopeClient implements IDataScopeClient { |
||||
|
||||
private final JdbcTemplate jdbcTemplate; |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param mapperId 数据权限mapperId |
||||
* @param roleId 用户角色集合 |
||||
* @return DataScopeModel |
||||
*/ |
||||
@Override |
||||
@GetMapping(GET_DATA_SCOPE_BY_MAPPER) |
||||
public DataScopeModel getDataScopeByMapper(String mapperId, String roleId) { |
||||
List<Object> args = new ArrayList<>(Collections.singletonList(mapperId)); |
||||
List<Long> roleIds = Func.toLongList(roleId); |
||||
args.addAll(roleIds); |
||||
DataScopeModel dataScope = null; |
||||
List<DataScopeModel> list = jdbcTemplate.query(DataScopeConstant.dataByMapper(roleIds.size()), args.toArray(), new BeanPropertyRowMapper<>(DataScopeModel.class)); |
||||
if (CollectionUtil.isNotEmpty(list)) { |
||||
dataScope = list.iterator().next(); |
||||
} |
||||
return dataScope; |
||||
} |
||||
|
||||
/** |
||||
* 获取数据权限 |
||||
* |
||||
* @param code 数据权限资源编号 |
||||
* @return DataScopeModel |
||||
*/ |
||||
@Override |
||||
@GetMapping(GET_DATA_SCOPE_BY_CODE) |
||||
public DataScopeModel getDataScopeByCode(String code) { |
||||
DataScopeModel dataScope = null; |
||||
List<DataScopeModel> list = jdbcTemplate.query(DataScopeConstant.DATA_BY_CODE, new Object[]{code}, new BeanPropertyRowMapper<>(DataScopeModel.class)); |
||||
if (CollectionUtil.isNotEmpty(list)) { |
||||
dataScope = list.iterator().next(); |
||||
} |
||||
return dataScope; |
||||
} |
||||
|
||||
/** |
||||
* 获取部门子级 |
||||
* |
||||
* @param deptId 部门id |
||||
* @return deptIds |
||||
*/ |
||||
@Override |
||||
@GetMapping(GET_DEPT_ANCESTORS) |
||||
public List<Long> getDeptAncestors(Long deptId) { |
||||
return jdbcTemplate.queryForList(DataScopeConstant.DATA_BY_DEPT, new Object[]{deptId}, Long.class); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue