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 repository; public LocaleService(IApplicationService service) { this.service = service; repository = service.GetRepository>(); } [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 l = new List(); 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 list = new List(); 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(); 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(); 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; } } }