298 lines
13 KiB
C#
298 lines
13 KiB
C#
using CloudBuilder.Core.DatabaseAccessor;
|
|
using CloudBuilder.Core.DatabaseAccessor.Entity;
|
|
using CloudBuilder.Core.Service;
|
|
using CloudBuilder.Security.Data;
|
|
using CloudBuilder.Security.Entity;
|
|
using CloudBuilder.Security.Policy;
|
|
using CloudBuilder.Security.SearchCriteria;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
namespace CloudBuilder.Security.Service
|
|
{
|
|
public class LocaleService : ILocaleService
|
|
{
|
|
private readonly IApplicationService service;
|
|
|
|
private IRepository<LocaleEntity> repository;
|
|
public LocaleService(IApplicationService service)
|
|
{
|
|
this.service = service;
|
|
repository = service.GetRepository<IRepository<LocaleEntity>>();
|
|
}
|
|
|
|
[AllowAnonymous]
|
|
[HttpGet]
|
|
public LocaleEntity[] FindAll()
|
|
{
|
|
return repository.DetachedEntities.ToArray();
|
|
}
|
|
|
|
[AllowAnonymous]
|
|
[HttpPost]
|
|
public SelectOption[] FindSelectOption(string groupName, bool blank = true)
|
|
{
|
|
LocaleEntity[] ents = repository.DetachedEntities.Where(x => x.GroupName == groupName && x.Lang == service.Locale).OrderBy(x => x.OrderBy).ToArray();
|
|
|
|
List<SelectOption> l = new List<SelectOption>();
|
|
|
|
SelectOption selectOption;
|
|
if (blank)
|
|
{
|
|
selectOption = new SelectOption();
|
|
l.Add(selectOption);
|
|
}
|
|
|
|
foreach (var ent in ents)
|
|
{
|
|
selectOption = new SelectOption();
|
|
selectOption.BindValue = ent.Name;
|
|
selectOption.DisplayName = ent.Value;
|
|
l.Add(selectOption);
|
|
}
|
|
return l.ToArray();
|
|
}
|
|
|
|
[AllowAnonymous]
|
|
public LocaleResultData FindBySearchCriteria(LocaleSearchCriteria criteria)
|
|
{
|
|
LocaleResultData data = new LocaleResultData();
|
|
LocaleEntity[] list = null;
|
|
|
|
Int64 count = 0;
|
|
|
|
string sqlWhere = null;
|
|
|
|
if (criteria.Filter != null && criteria.Filter.Length > 0)
|
|
{
|
|
sqlWhere = SearchFilter.ComposeWhereClause(criteria.Filter);
|
|
}
|
|
|
|
LocaleEntity entity = LocaleEntity.GetInstance(repository.GetDbContext().Database.ProviderName);
|
|
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 = Convert.ToInt64(repository.ExecuteScalar(sql));
|
|
|
|
data.Datas = list.Select(x => new LocaleDisplayData(x)).ToArray();
|
|
}
|
|
else
|
|
{
|
|
data.Datas = null;
|
|
}
|
|
|
|
data.Limit = criteria.limit;
|
|
data.Page = criteria.page;
|
|
|
|
data.Total = count;
|
|
//data.Sql = sql;
|
|
data.ErrorMessage = err;
|
|
return data;
|
|
}
|
|
|
|
[AllowAnonymous]
|
|
public LocaleEntity FindByKey(LocaleEntityKey key)
|
|
{
|
|
return repository.DetachedEntities.Where(x => 1 == 1
|
|
&& x.GroupName == key.GroupName
|
|
&& x.Lang == key.Lang
|
|
&& x.Name == key.Name
|
|
).FirstOrDefault()!;
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.Locale, operate: Operate.Insert)]
|
|
[UnitOfWork]
|
|
public LocaleEntity Insert(LocaleEntity data)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.Locale, operate: Operate.Update)]
|
|
[UnitOfWork]
|
|
public LocaleEntity Update(LocaleEntity data)
|
|
{
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.Locale, operate: Operate.Update)]
|
|
[UnitOfWork]
|
|
public void UpdateLocaleData(LocaleData data)
|
|
{
|
|
List<LocaleEntity> list = new List<LocaleEntity>();
|
|
LocaleEntity locale;
|
|
if (data.Deletes != null)
|
|
{
|
|
foreach (var item in data.Deletes)
|
|
{
|
|
locale = new LocaleEntity() { GroupName = item.OrgGroupName, Name = item.OrgName, Lang = item.OrgLang };
|
|
list.Add(locale);
|
|
}
|
|
repository.DeleteNow(list);
|
|
}
|
|
if (data.Inserts != null)
|
|
{
|
|
repository.InsertNow(data.Inserts);
|
|
}
|
|
if (data.Updates != null)
|
|
{
|
|
list = new List<LocaleEntity>();
|
|
foreach (var item in data.Updates)
|
|
{
|
|
locale = new LocaleEntity() { GroupName = item.OrgGroupName, Name = item.OrgName, Lang = item.OrgLang };
|
|
list.Add(locale);
|
|
}
|
|
repository.DeleteNow(list);
|
|
|
|
list = new List<LocaleEntity>();
|
|
foreach (var item in data.Updates)
|
|
{
|
|
locale = new LocaleEntity();
|
|
ObjectCopyHelper.Copy(item, locale);
|
|
list.Add(locale);
|
|
}
|
|
repository.InsertNow(list);
|
|
}
|
|
}
|
|
|
|
|
|
[PermissionOperate(name: SecurityPermissionPolicy.Locale, operate: Operate.Delete)]
|
|
public void Delete(LocaleEntityKey key)
|
|
{
|
|
LocaleEntity ent = repository.DetachedEntities.Where(x => 1 == 1
|
|
&& x.GroupName == key.GroupName
|
|
&& x.Lang == key.Lang
|
|
&& x.Name == key.Name
|
|
).FirstOrDefault()!;
|
|
if (ent != null) { repository.DeleteNow(ent); }
|
|
}
|
|
|
|
|
|
[AllowAnonymous]
|
|
[HttpGet]
|
|
public dynamic Copy()
|
|
{
|
|
repository.ChangeSecondaryDatabase();
|
|
//repositorySecurityUser.ChangeSecondaryDatabase();
|
|
//repositorySecurityUserActor.ChangeSecondaryDatabase();
|
|
//repositorySecurityActor.ChangeSecondaryDatabase();
|
|
//repositorySecurityActorGroup.ChangeSecondaryDatabase();
|
|
//repositorySecurityGroup.ChangeSecondaryDatabase();
|
|
//repositorySecurityGroupPermission.ChangeSecondaryDatabase();
|
|
//repositorySecurityGroupPermissionDependent.ChangeSecondaryDatabase();
|
|
//repositorySecurityPermission.ChangeSecondaryDatabase();
|
|
//repositorySecurityPermissionDependent.ChangeSecondaryDatabase();
|
|
//repositorySecurityPermissionFunctionMap.ChangeSecondaryDatabase();
|
|
//repositorySecurityFunction.ChangeSecondaryDatabase();
|
|
//repositorySecurityFunctionMap.ChangeSecondaryDatabase();
|
|
//repositorySecurityMaster.ChangeSecondaryDatabase();
|
|
//repositorySecurityGeneratorNumber.ChangeSecondaryDatabase();
|
|
|
|
|
|
var locales = repository.DetachedEntities.ToArray();
|
|
//var SecurityUsers = repositorySecurityUser.DetachedEntities.ToArray();
|
|
//var SecurityUserActors = repositorySecurityUserActor.DetachedEntities.ToArray();
|
|
//var SecurityActors = repositorySecurityActor.DetachedEntities.ToArray();
|
|
//var SecurityActorGroups = repositorySecurityActorGroup.DetachedEntities.ToArray();
|
|
//var SecurityGroups = repositorySecurityGroup.DetachedEntities.ToArray();
|
|
//var SecurityGroupPermissions = repositorySecurityGroupPermission.DetachedEntities.ToArray();
|
|
//var SecurityGroupPermissionDependents = repositorySecurityGroupPermissionDependent.DetachedEntities.ToArray();
|
|
//var SecurityPermissions = repositorySecurityPermission.DetachedEntities.ToArray();
|
|
//var SecurityPermissionDependents = repositorySecurityPermissionDependent.DetachedEntities.ToArray();
|
|
//var SecurityPermissionFunctionMaps = repositorySecurityPermissionFunctionMap.DetachedEntities.ToArray();
|
|
//var SecurityFunctions = repositorySecurityFunction.DetachedEntities.ToArray();
|
|
//var SecurityFunctionMaps = repositorySecurityFunctionMap.DetachedEntities.ToArray();
|
|
//var SecurityMasters = repositorySecurityMaster.DetachedEntities.ToArray();
|
|
//var SecurityGeneratorNumbers = repositorySecurityGeneratorNumber.DetachedEntities.ToArray();
|
|
|
|
repository.ChangeMasterDatabase();
|
|
//repositorySecurityUser.ChangeMasterDatabase();
|
|
//repositorySecurityUserActor.ChangeMasterDatabase();
|
|
//repositorySecurityActor.ChangeMasterDatabase();
|
|
//repositorySecurityActorGroup.ChangeMasterDatabase();
|
|
//repositorySecurityGroup.ChangeMasterDatabase();
|
|
//repositorySecurityGroupPermission.ChangeMasterDatabase();
|
|
//repositorySecurityGroupPermissionDependent.ChangeMasterDatabase();
|
|
//repositorySecurityPermission.ChangeMasterDatabase();
|
|
//repositorySecurityPermissionDependent.ChangeMasterDatabase();
|
|
//repositorySecurityPermissionFunctionMap.ChangeMasterDatabase();
|
|
//repositorySecurityFunction.ChangeMasterDatabase();
|
|
//repositorySecurityFunctionMap.ChangeMasterDatabase();
|
|
//repositorySecurityMaster.ChangeMasterDatabase();
|
|
//repositorySecurityGeneratorNumber.ChangeMasterDatabase();
|
|
|
|
// 取得 MasterDbContext，開啟跳審計，保留原始 CreatedBy / UpdatedBy
|
|
var secDbCtx = repository.GetDbContext() as MasterDbContext;
|
|
if (secDbCtx != null)
|
|
{
|
|
secDbCtx.SkipAudit = true;
|
|
}
|
|
|
|
repository.ExecuteNonQuery("TRUNCATE TABLE " + LocaleEntity.DB_NAME_LOCALE);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityUserEntity.DB_NAME_SECURITY_USER);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityActorEntity.DB_NAME_SECURITY_ACTOR);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityUserActorEntity.DB_NAME_SECURITY_USER_ACTOR);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityActorGroupEntity.DB_NAME_SECURITY_ACTOR_GROUP);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityGroupEntity.DB_NAME_SECURITY_GROUP);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityGroupPermissionEntity.DB_NAME_SECURITY_GROUP_PERMISSION);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityGroupPermissionDependentEntity.DB_NAME_SECURITY_GROUP_PERMISSION_DEPENDENT);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityPermissionEntity.DB_NAME_SECURITY_PERMISSION);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityPermissionDependentEntity.DB_NAME_SECURITY_PERMISSION_DEPENDENT);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityPermissionFunctionMapEntity.DB_NAME_SECURITY_PERMISSION_FUNCTION_MAP);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityFunctionEntity.DB_NAME_SECURITY_FUNCTION);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityFunctionMapEntity.DB_NAME_SECURITY_FUNCTION_MAP);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityMasterEntity.DB_NAME_SECURITY_MASTER);
|
|
//repository.ExecuteNonQuery("TRUNCATE TABLE " + SecurityGeneratorNumberEntity.DB_NAME_SECURITY_GENERATOR_NUMBER);
|
|
|
|
repository.InsertNow(locales);
|
|
//repositorySecurityUser.InsertNow(SecurityUsers);
|
|
//repositorySecurityUserActor.InsertNow(SecurityUserActors);
|
|
//repositorySecurityActor.InsertNow(SecurityActors);
|
|
//repositorySecurityActorGroup.InsertNow(SecurityActorGroups);
|
|
//repositorySecurityGroup.InsertNow(SecurityGroups);
|
|
//repositorySecurityGroupPermission.InsertNow(SecurityGroupPermissions);
|
|
//repositorySecurityGroupPermissionDependent.InsertNow(SecurityGroupPermissionDependents);
|
|
//repositorySecurityPermission.InsertNow(SecurityPermissions);
|
|
//repositorySecurityPermissionDependent.InsertNow(SecurityPermissionDependents);
|
|
//repositorySecurityPermissionFunctionMap.InsertNow(SecurityPermissionFunctionMaps);
|
|
//repositorySecurityFunction.InsertNow(SecurityFunctions);
|
|
//repositorySecurityFunctionMap.InsertNow(SecurityFunctionMaps);
|
|
//repositorySecurityMaster.InsertNow(SecurityMasters);
|
|
|
|
////Copy 到 MySQL 不需要
|
|
//if (secDbCtx.Database.ProviderName.Contains("SqlServer"))
|
|
//{
|
|
// repository.ExecuteNonQuery("SET IDENTITY_INSERT " + SecurityGeneratorNumberEntity.DB_NAME_SECURITY_GENERATOR_NUMBER + " ON;");
|
|
//}
|
|
|
|
//repositorySecurityGeneratorNumber.InsertNow(SecurityGeneratorNumbers);
|
|
|
|
////Copy 到 MySQL 不需要
|
|
//if (secDbCtx.Database.ProviderName.Contains("SqlServer"))
|
|
//{
|
|
// repository.ExecuteNonQuery("SET IDENTITY_INSERT " + SecurityGeneratorNumberEntity.DB_NAME_SECURITY_GENERATOR_NUMBER + " OFF;");
|
|
//}
|
|
|
|
// ⚠️務必關閉 SkipAudit，避免後續正常業務失效
|
|
if (secDbCtx != null)
|
|
{
|
|
secDbCtx.SkipAudit = false;
|
|
}
|
|
|
|
return string.Empty;
|
|
}
|
|
}
|
|
}
|