296 lines
12 KiB
C#
296 lines
12 KiB
C#
using CloudBuilder.Core.DatabaseAccessor;
|
|
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
|
using CloudBuilder.Core.Extensions;
|
|
using CloudBuilder.Core.Service;
|
|
using CloudBuilder.Security.Data;
|
|
using CloudBuilder.Security.Entity;
|
|
using CloudBuilder.Security.Policy;
|
|
using CloudBuilder.Security.SearchCriteria;
|
|
using CloudBuilder.Security.Utility;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
namespace CloudBuilder.Security.Service
|
|
{
|
|
public class SecurityGroupService : ISecurityGroupService
|
|
{
|
|
private readonly IApplicationService service;
|
|
|
|
private IRepository<SecurityGroupEntity> repository;
|
|
public SecurityGroupService(IApplicationService service)
|
|
{
|
|
this.service = service;
|
|
repository = service.GetRepository<IRepository<SecurityGroupEntity>>();
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Find)]
|
|
public SecurityGroupData FindByKey(string key)
|
|
{
|
|
SecurityGroupData data = new SecurityGroupData();
|
|
if (string.IsNullOrEmpty(key)) return data;
|
|
|
|
SecurityGroupEntity group = repository.DetachedEntities.Where(x => x.GroupName == key).FirstOrDefault();
|
|
if (group == null) return data;
|
|
|
|
data.SecurityGroup = group;
|
|
|
|
|
|
IRepository<SecurityGroupPermissionViewEntity> repositoryGpv = repository.GetRepository<IRepository<SecurityGroupPermissionViewEntity>>();
|
|
IRepository<SecurityGroupPermissionDependentViewEntity> repositoryGpdv = repository.GetRepository<IRepository<SecurityGroupPermissionDependentViewEntity>>();
|
|
IRepository<SecurityActorGroupViewEntity> repositoryAgv = repository.GetRepository<IRepository<SecurityActorGroupViewEntity>>();
|
|
|
|
SecurityGroupPermissionViewEntity[] sgps = repositoryGpv.DetachedEntities.Where(x => x.GroupName == key).ToArray();
|
|
if (sgps != null && sgps.Length > 0)
|
|
data.SecurityGroupPermissionViews = sgps.Select(x => new SecurityGroupPermissionViewDisplayData(x)).ToArray();
|
|
|
|
SecurityGroupPermissionDependentViewEntity[] sgpds = repositoryGpdv.DetachedEntities.Where(x => x.GroupName == key).ToArray();
|
|
if (sgpds != null && sgpds.Length > 0)
|
|
data.SecurityGroupPermissionDependentViews = sgpds.Select(x => new SecurityGroupPermissionDependentViewDisplayData(x)).ToArray();
|
|
|
|
|
|
data.SecurityActorGroups = repositoryAgv.DetachedEntities.Where(x => x.GroupName == key).ToArray();
|
|
|
|
return data;
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Find)]
|
|
public SecurityGroupEntity[] FindAll()
|
|
{
|
|
return repository.DetachedEntities.ToArray();
|
|
}
|
|
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Find)]
|
|
public SecurityGroupResultData FindBySearchCriteria(SecurityGroupSearchCriteria criteria)
|
|
{
|
|
SecurityGroupResultData data = new SecurityGroupResultData();
|
|
SecurityGroupEntity[] list = null;
|
|
|
|
int count = 0;
|
|
|
|
string sqlWhere = null;
|
|
|
|
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
|
{
|
|
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
|
}
|
|
|
|
SecurityGroupEntity entity = SecurityGroupEntity.GetInstance();
|
|
string sql = entity.GetSelectTopFrom(criteria.limit, criteria.page, criteria.orderby.StringToDbField(), criteria.orderbytag, sqlWhere);
|
|
|
|
string err = null;
|
|
try
|
|
{
|
|
list = repository.FromSql(sql).ToArray();
|
|
}
|
|
catch (System.Exception ex)
|
|
{
|
|
err = ex.Message;
|
|
}
|
|
|
|
|
|
if (list != null && list.Length > 0)
|
|
{
|
|
sql = entity.GetSelectCountFrom(sqlWhere);
|
|
count = (int)repository.ExecuteScalar(sql);
|
|
}
|
|
|
|
data.Limit = criteria.limit;
|
|
data.Page = criteria.page;
|
|
data.Datas = list;
|
|
data.Total = count;
|
|
//data.Sql = sql;
|
|
data.ErrorMessage = err;
|
|
return data;
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Print)]
|
|
public dynamic PrintBySearchCriteria(SecurityGroupSearchCriteria criteria)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Insert)]
|
|
[UnitOfWork]
|
|
public SecurityGroupData Insert(SecurityGroupData data)
|
|
{
|
|
SecurityGroupEntity securityGroup = repository.DetachedEntities.Where(x => x.GroupName == data.SecurityGroup.GroupName).FirstOrDefault();
|
|
if (securityGroup != null)
|
|
{
|
|
throw new ValidatedException("记录已存在.");
|
|
}
|
|
|
|
ValidateHelper.Validate(service, data.SecurityGroup, SecurityGroupEntity.DB_NAME_SECURITY_GROUP);
|
|
|
|
securityGroup = new SecurityGroupEntity();
|
|
|
|
ObjectCopyHelper.Copy(data.SecurityGroup, securityGroup);
|
|
|
|
repository.InsertNow(securityGroup);
|
|
|
|
SaveSecurityGroupPermission(data);
|
|
|
|
SaveSecurityActorGroup(data);
|
|
|
|
return FindByKey(data.SecurityGroup.GroupName);
|
|
}
|
|
|
|
private void SaveSecurityGroupPermission(SecurityGroupData data)
|
|
{
|
|
IRepository<SecurityGroupPermissionEntity> repositoryGp = repository.GetRepository<IRepository<SecurityGroupPermissionEntity>>();
|
|
|
|
SecurityGroupPermissionEntity[] olds = repositoryGp.Entities.Where(x => x.GroupName == data.SecurityGroup.GroupName).ToArray();
|
|
if (olds != null && olds.Length > 0)
|
|
{
|
|
foreach (SecurityGroupPermissionEntity old in olds)
|
|
{
|
|
repositoryGp.DeleteNow(old);
|
|
}
|
|
}
|
|
|
|
if (data.SecurityGroupPermissionViews != null && data.SecurityGroupPermissionViews.Length > 0)
|
|
foreach (SecurityGroupPermissionViewDisplayData dto in data.SecurityGroupPermissionViews)
|
|
{
|
|
repositoryGp.InsertNow(new SecurityGroupPermissionEntity()
|
|
{
|
|
GroupName = data.SecurityGroup.GroupName,
|
|
PermissionName = dto.PermissionName,
|
|
Dependent = dto.Dependent,
|
|
ViewIndc = dto.IsView ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
AmendIndc = dto.IsAmend ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
DeleteIndc = dto.IsDelete ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
CreateIndc = dto.IsCreate ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
});
|
|
}
|
|
IRepository<SecurityGroupPermissionDependentEntity> repositoryGpd = repository.GetRepository<IRepository<SecurityGroupPermissionDependentEntity>>();
|
|
|
|
SecurityGroupPermissionDependentEntity[] oldds = repositoryGpd.Entities.Where(x => x.GroupName == data.SecurityGroup.GroupName).ToArray();
|
|
if (oldds != null && oldds.Length > 0)
|
|
{
|
|
foreach (SecurityGroupPermissionDependentEntity old in oldds)
|
|
{
|
|
repositoryGpd.DeleteNow(old);
|
|
}
|
|
}
|
|
|
|
if (data.SecurityGroupPermissionDependentViews != null && data.SecurityGroupPermissionDependentViews.Length > 0)
|
|
foreach (SecurityGroupPermissionDependentViewDisplayData dto in data.SecurityGroupPermissionDependentViews)
|
|
{
|
|
repositoryGpd.InsertNow(new SecurityGroupPermissionDependentEntity()
|
|
{
|
|
GroupName = data.SecurityGroup.GroupName,
|
|
PermissionName = dto.PermissionName,
|
|
DependentDetailName = dto.DependentDetailName,
|
|
ViewIndc = dto.IsView ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
AmendIndc = dto.IsAmend ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
DeleteIndc = dto.IsDelete ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
CreateIndc = dto.IsCreate ? YesNoPolicy.YES : YesNoPolicy.NO,
|
|
});
|
|
}
|
|
}
|
|
|
|
private void SaveSecurityActorGroup(SecurityGroupData data)
|
|
{
|
|
IRepository<SecurityActorGroupEntity> repositoryAg = repository.GetRepository<IRepository<SecurityActorGroupEntity>>();
|
|
|
|
SecurityActorGroupEntity[] olds = repositoryAg.Entities.Where(x => x.GroupName == data.SecurityGroup.GroupName).ToArray();
|
|
if (olds != null && olds.Length > 0)
|
|
{
|
|
foreach (SecurityActorGroupEntity old in olds)
|
|
{
|
|
repositoryAg.DeleteNow(old);
|
|
}
|
|
}
|
|
|
|
if (data.SecurityActorGroups != null && data.SecurityActorGroups.Length > 0)
|
|
foreach (SecurityActorGroupViewEntity dto in data.SecurityActorGroups)
|
|
{
|
|
repositoryAg.InsertNow(new SecurityActorGroupEntity()
|
|
{
|
|
GroupName = data.SecurityGroup.GroupName,
|
|
ActorName = dto.ActorName,
|
|
});
|
|
}
|
|
|
|
}
|
|
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Update)]
|
|
[UnitOfWork]
|
|
public SecurityGroupData Update(SecurityGroupData data)
|
|
{
|
|
SecurityGroupEntity securityGroup = repository.DetachedEntities.Where(x => x.GroupName == data.SecurityGroup.GroupName).FirstOrDefault();
|
|
if (securityGroup == null)
|
|
{
|
|
throw new ValidatedException("记录不存在.");
|
|
}
|
|
|
|
ValidateHelper.Validate(service, data.SecurityGroup, SecurityGroupEntity.DB_NAME_SECURITY_GROUP);
|
|
|
|
ObjectCopyHelper.Copy(data.SecurityGroup, securityGroup);
|
|
|
|
repository.UpdateNow(securityGroup);
|
|
|
|
SaveSecurityGroupPermission(data);
|
|
|
|
SaveSecurityActorGroup(data);
|
|
|
|
return FindByKey(data.SecurityGroup.GroupName);
|
|
}
|
|
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Delete)]
|
|
[UnitOfWork]
|
|
public void Delete(string key)
|
|
{
|
|
SecurityGroupEntity securityGroup = repository.DetachedEntities.Where(x => x.GroupName == key).FirstOrDefault();
|
|
if (securityGroup == null)
|
|
{
|
|
throw new ValidatedException("记录不存在.");
|
|
}
|
|
|
|
repository.DeleteNow(securityGroup);
|
|
|
|
IRepository<SecurityGroupPermissionEntity> repositoryGp = repository.GetRepository<IRepository<SecurityGroupPermissionEntity>>();
|
|
IRepository<SecurityGroupPermissionDependentEntity> repositoryGpd = repository.GetRepository<IRepository<SecurityGroupPermissionDependentEntity>>();
|
|
|
|
SecurityGroupPermissionEntity[] olds = repositoryGp.Entities.Where(x => x.PermissionName == key).ToArray();
|
|
if (olds != null && olds.Length > 0)
|
|
{
|
|
foreach (SecurityGroupPermissionEntity old in olds)
|
|
{
|
|
repositoryGp.DeleteNow(old);
|
|
}
|
|
}
|
|
|
|
SecurityGroupPermissionDependentEntity[] oldds = repositoryGpd.Entities.Where(x => x.PermissionName == key).ToArray();
|
|
if (oldds != null && oldds.Length > 0)
|
|
{
|
|
foreach (SecurityGroupPermissionDependentEntity old in oldds)
|
|
{
|
|
repositoryGpd.DeleteNow(old);
|
|
}
|
|
}
|
|
|
|
IRepository<SecurityActorGroupEntity> repositoryAg = repository.GetRepository<IRepository<SecurityActorGroupEntity>>();
|
|
SecurityActorGroupEntity[] oldAgs = repositoryAg.Entities.Where(x => x.GroupName == key).ToArray();
|
|
if (oldAgs != null && oldAgs.Length > 0)
|
|
{
|
|
foreach (SecurityActorGroupEntity old in oldAgs)
|
|
{
|
|
repositoryAg.DeleteNow(old);
|
|
}
|
|
}
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.SecurityGroup, operate: Operate.Delete)]
|
|
[UnitOfWork]
|
|
public void Deletes(string[] keys)
|
|
{
|
|
foreach (string key in keys)
|
|
{
|
|
Delete(key);
|
|
}
|
|
}
|
|
}
|
|
}
|