orga0063
/
BootstrapAdmin
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

refactor: 更新 DictService 服务类

This commit is contained in:
Argo-Lenovo 2022-06-02 10:43:40 +08:00
parent 34e376d712
commit 0e58b81d19
1 changed files with 22 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/blazor/admin/BootstrapAdmin.DataAccess.PetaPoco/Services/DictService.cs
View File

@ -17,7 +17,7 @@ class DictService : IDict
{ {
private const string DictServiceCacheKey = "DictService-GetAll"; private const string DictServiceCacheKey = "DictService-GetAll";
private IDatabase Database { get; } private IDBManager DBManager { get; }
private string AppId { get; set; } private string AppId { get; set; }
@ -26,13 +26,17 @@ class DictService : IDict
/// </summary> /// </summary>
/// <param name="db"></param> /// <param name="db"></param>
/// <param name="configuration"></param> /// <param name="configuration"></param>
public DictService(IDatabase db, IConfiguration configuration) public DictService(IDBManager db, IConfiguration configuration)
{ {
Database = db; DBManager = db;
AppId = configuration.GetValue("AppId", "BA"); AppId = configuration.GetValue("AppId", "BA");
} }
public List<Dict> GetAll() => CacheManager.GetOrAdd(DictServiceCacheKey, entry => Database.Fetch<Dict>()); public List<Dict> GetAll() => CacheManager.GetOrAdd(DictServiceCacheKey, entry =>
{
using var db = DBManager.Create();
return db.Fetch<Dict>();
});
public Dictionary<string, string> GetApps() public Dictionary<string, string> GetApps()
{ {
@ -178,7 +182,8 @@ class DictService : IDict
private bool SaveDict(Dict dict) private bool SaveDict(Dict dict)
{ {
var ret = Database.Update<Dict>("set Code = @Code where Category = @Category and Name = @Name", dict) == 1; using var db = DBManager.Create();
var ret = db.Update<Dict>("set Code = @Code where Category = @Category and Name = @Name", dict) == 1;
if (ret) if (ret)
{ {
// 更新缓存 // 更新缓存
@ -417,9 +422,10 @@ class DictService : IDict
if (!string.IsNullOrEmpty(client.AppId)) if (!string.IsNullOrEmpty(client.AppId))
{ {
DeleteClient(client.AppId); DeleteClient(client.AppId);
using var db = DBManager.Create();
try try
{ {
Database.BeginTransaction(); db.BeginTransaction();
var items = new List<Dict>() var items = new List<Dict>()
{ {
new Dict { Category = "应用程序", Name = client.AppName, Code = client.AppId, Define = EnumDictDefine.System }, new Dict { Category = "应用程序", Name = client.AppName, Code = client.AppId, Define = EnumDictDefine.System },
@ -432,13 +438,13 @@ class DictService : IDict
new Dict { Category = client.AppId, Name = "系统设置地址", Code = client.SettingsUrl, Define = EnumDictDefine.Customer }, new Dict { Category = client.AppId, Name = "系统设置地址", Code = client.SettingsUrl, Define = EnumDictDefine.Customer },
new Dict { Category = client.AppId, Name = "系统通知地址", Code = client.NotificationUrl, Define = EnumDictDefine.Customer } new Dict { Category = client.AppId, Name = "系统通知地址", Code = client.NotificationUrl, Define = EnumDictDefine.Customer }
}; };
Database.InsertBatch(items); db.InsertBatch(items);
Database.CompleteTransaction(); db.CompleteTransaction();
ret = true; ret = true;
} }
catch (DbException) catch (DbException)
{ {
Database.AbortTransaction(); db.AbortTransaction();
throw; throw;
} }
} }
@ -466,12 +472,13 @@ class DictService : IDict
public bool DeleteClient(string appId) public bool DeleteClient(string appId)
{ {
bool ret; bool ret;
using var db = DBManager.Create();
try try
{ {
Database.BeginTransaction(); db.BeginTransaction();
Database.Execute("delete Dicts where Category=@0 and Name=@1 and Define=@2", "应用首页", appId, EnumDictDefine.System); db.Execute("delete Dicts where Category=@0 and Name=@1 and Define=@2", "应用首页", appId, EnumDictDefine.System);
Database.Execute("delete Dicts where Category=@0 and Code=@1 and Define=@2", "应用程序", appId, EnumDictDefine.System); db.Execute("delete Dicts where Category=@0 and Code=@1 and Define=@2", "应用程序", appId, EnumDictDefine.System);
Database.Execute("delete Dicts where Category=@Category and Name in (@Names)", new db.Execute("delete Dicts where Category=@Category and Name in (@Names)", new
{ {
Category = appId, Category = appId,
Names = new List<string> Names = new List<string>
@ -485,12 +492,12 @@ class DictService : IDict
"系统通知地址" "系统通知地址"
} }
}); });
Database.CompleteTransaction(); db.CompleteTransaction();
ret = true; ret = true;
} }
catch (Exception) catch (Exception)
{ {
Database.AbortTransaction(); db.AbortTransaction();
throw; throw;
} }
return ret; return ret;