This commit is contained in:
tidusjar 2017-11-11 23:03:50 +00:00
commit a6ca902479
6 changed files with 31 additions and 37 deletions

View file

@ -22,7 +22,7 @@ namespace Ombi.Store.Repository
public GlobalSettings Insert(GlobalSettings entity)
{
_cache.Remove(GetName(entity.SettingsName));
//_cache.Remove(GetName(entity.SettingsName));
var settings = Db.Settings.Add(entity);
Db.SaveChanges();
return settings.Entity;
@ -30,7 +30,7 @@ namespace Ombi.Store.Repository
public async Task<GlobalSettings> InsertAsync(GlobalSettings entity)
{
_cache.Remove(GetName(entity.SettingsName));
//_cache.Remove(GetName(entity.SettingsName));
var settings = await Db.Settings.AddAsync(entity).ConfigureAwait(false);
await Db.SaveChangesAsync().ConfigureAwait(false);
return settings.Entity;
@ -39,48 +39,48 @@ namespace Ombi.Store.Repository
public GlobalSettings Get(string pageName)
{
return _cache.GetOrCreate(GetName(pageName), entry =>
{
entry.AbsoluteExpiration = DateTimeOffset.Now.AddHours(1);
//return _cache.GetOrCreate(GetName(pageName), entry =>
//{
// entry.AbsoluteExpiration = DateTimeOffset.Now.AddHours(1);
var entity = Db.Settings.AsNoTracking().FirstOrDefault(x => x.SettingsName == pageName);
return entity;
});
//});
}
public async Task<GlobalSettings> GetAsync(string settingsName)
{
return await _cache.GetOrCreateAsync(GetName(settingsName), async entry =>
{
entry.AbsoluteExpiration = DateTimeOffset.Now.AddHours(1);
//return await _cache.GetOrCreateAsync(GetName(settingsName), async entry =>
//{
//entry.AbsoluteExpiration = DateTimeOffset.Now.AddHours(1);
var obj = await Db.Settings.AsNoTracking().FirstOrDefaultAsync(x => x.SettingsName == settingsName);
return obj;
});
//});
}
public async Task DeleteAsync(GlobalSettings entity)
{
_cache.Remove(GetName(entity.SettingsName));
//_cache.Remove(GetName(entity.SettingsName));
Db.Settings.Remove(entity);
await Db.SaveChangesAsync();
}
public async Task UpdateAsync(GlobalSettings entity)
{
_cache.Remove(GetName(entity.SettingsName));
//_cache.Remove(GetName(entity.SettingsName));
Db.Update(entity);
await Db.SaveChangesAsync();
}
public void Delete(GlobalSettings entity)
{
_cache.Remove(GetName(entity.SettingsName));
//_cache.Remove(GetName(entity.SettingsName));
Db.Settings.Remove(entity);
Db.SaveChanges();
}
public void Update(GlobalSettings entity)
{
_cache.Remove(GetName(entity.SettingsName));
//_cache.Remove(GetName(entity.SettingsName));
Db.SaveChanges();
}