😎增加字典值时更新缓存
This commit is contained in:
parent
91c61d9da5
commit
1569f61bf3
@ -13,11 +13,11 @@ namespace Admin.NET.Core.Service;
|
|||||||
[AllowAnonymous]
|
[AllowAnonymous]
|
||||||
public class SysDictDataService : IDynamicApiController, ITransient
|
public class SysDictDataService : IDynamicApiController, ITransient
|
||||||
{
|
{
|
||||||
private readonly SysCacheService _sysCacheService;
|
|
||||||
private readonly SqlSugarRepository<SysDictData> _sysDictDataRep;
|
private readonly SqlSugarRepository<SysDictData> _sysDictDataRep;
|
||||||
|
private readonly SysCacheService _sysCacheService;
|
||||||
|
|
||||||
public SysDictDataService(SqlSugarRepository<SysDictData> sysDictDataRep
|
public SysDictDataService(SqlSugarRepository<SysDictData> sysDictDataRep,
|
||||||
, SysCacheService sysCacheService)
|
SysCacheService sysCacheService)
|
||||||
{
|
{
|
||||||
_sysDictDataRep = sysDictDataRep;
|
_sysDictDataRep = sysDictDataRep;
|
||||||
_sysCacheService = sysCacheService;
|
_sysCacheService = sysCacheService;
|
||||||
@ -62,6 +62,9 @@ public class SysDictDataService : IDynamicApiController, ITransient
|
|||||||
var isExist = await _sysDictDataRep.IsAnyAsync(u => u.Code == input.Code && u.DictTypeId == input.DictTypeId);
|
var isExist = await _sysDictDataRep.IsAnyAsync(u => u.Code == input.Code && u.DictTypeId == input.DictTypeId);
|
||||||
if (isExist) throw Oops.Oh(ErrorCodeEnum.D3003);
|
if (isExist) throw Oops.Oh(ErrorCodeEnum.D3003);
|
||||||
|
|
||||||
|
var dictTypeCode = await _sysDictDataRep.AsQueryable().Where(u => u.DictTypeId == input.DictTypeId).Select(u => u.DictType.Code).FirstAsync();
|
||||||
|
_sysCacheService.Remove($"{CacheConst.KeyDict}{dictTypeCode}");
|
||||||
|
|
||||||
await _sysDictDataRep.InsertAsync(input.Adapt<SysDictData>());
|
await _sysDictDataRep.InsertAsync(input.Adapt<SysDictData>());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user