package com.qianwen.core.datascope.handler;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Objects;
|
import com.qianwen.core.datascope.enums.DataScopeEnum;
|
import com.qianwen.core.datascope.model.DataScopeModel;
|
import com.qianwen.core.secure.BladeUser;
|
import com.qianwen.core.tool.utils.BeanUtil;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.core.tool.utils.PlaceholderUtil;
|
import com.qianwen.core.tool.utils.StringUtil;
|
|
/* loaded from: blade-starter-datascope-9.3.0.1-SNAPSHOT.jar:org/springblade/core/datascope/handler/BladeDataScopeHandler.class */
|
public class BladeDataScopeHandler implements DataScopeHandler {
|
private final ScopeModelHandler scopeModelHandler;
|
|
public BladeDataScopeHandler(final ScopeModelHandler scopeModelHandler) {
|
this.scopeModelHandler = scopeModelHandler;
|
}
|
|
@Override // org.springblade.core.datascope.handler.DataScopeHandler
|
public String sqlCondition(String mapperId, DataScopeModel dataScope, BladeUser bladeUser, String originalSql) {
|
String code = dataScope.getResourceCode();
|
DataScopeModel dataScopeDb = this.scopeModelHandler.getDataScopeByMapper(mapperId, bladeUser.getDeptId());
|
if (dataScopeDb == null && StringUtil.isNotBlank(code) && StringUtil.isNotBlank(bladeUser.getDeptId())) {
|
dataScopeDb = this.scopeModelHandler.getDataScopeByCodeAndDept(code, bladeUser.getDeptId());
|
}
|
DataScopeModel dataScope2 = dataScopeDb != null ? dataScopeDb : dataScope;
|
Integer scopeRule = ((DataScopeModel) Objects.requireNonNull(dataScope2)).getScopeType();
|
DataScopeEnum scopeTypeEnum = DataScopeEnum.of(scopeRule);
|
List<Long> ids = new ArrayList<>();
|
String whereSql = "where scope.{} in ({}) or scope.{} is null";
|
if (DataScopeEnum.ALL == scopeTypeEnum || StringUtil.containsAny(bladeUser.getRoleName(), new CharSequence[]{"administrator"})) {
|
return null;
|
}
|
if (DataScopeEnum.CUSTOM == scopeTypeEnum) {
|
whereSql = PlaceholderUtil.getDefaultResolver().resolveByMap(dataScope2.getScopeValue(), BeanUtil.toMap(bladeUser));
|
} else if (DataScopeEnum.OWN == scopeTypeEnum) {
|
ids.add(bladeUser.getUserId());
|
} else if (DataScopeEnum.OWN_DEPT == scopeTypeEnum) {
|
ids.addAll(Func.toLongList(bladeUser.getDeptId()));
|
} else if (DataScopeEnum.OWN_DEPT_CHILD == scopeTypeEnum) {
|
List<Long> deptIds = Func.toLongList(bladeUser.getDeptId());
|
ids.addAll(deptIds);
|
deptIds.forEach(deptId -> {
|
List<Long> deptIdList = this.scopeModelHandler.getDeptAncestors(deptId);
|
ids.addAll(deptIdList);
|
});
|
}
|
return StringUtil.format(" select {} from ({}) scope " + whereSql, new Object[]{Func.toStr(dataScope2.getScopeField(), "*"), originalSql, dataScope2.getScopeColumn(), StringUtil.join(ids), dataScope2.getScopeColumn()});
|
}
|
}
|