ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加拉取配置缓存

Browse Source
This commit is contained in:
柳文翔 2024-03-14 14:07:09 +08:00
parent 8f0f40cc56
commit 786f1f0d25
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/SJZY.Track.Application/Services/TrackPull/TrackPullCacheService.cs
View File

@ -22,9 +22,15 @@ public class TrackPullCacheService : ApplicationService, ITrackPullCacheService
_trackPullConfigRepository = trackPullConfigRepository;
}
public Task<List<TrackPullConfigDto>> GetAllPullConfigsAsync()
[NonAction]
public async Task<List<TrackPullConfigDto>> GetAllPullConfigsAsync()
{
throw new NotImplementedException();
return await _trackPullConfigRepository.GetListAsync(x => true, x => new TrackPullConfigDto
{
SubSystemId = x.SubSystemId,
ServiceProviderId = x.ServiceProviderId,
PullInterval = x.PullInterval
});
}
[NonAction]
@ -53,7 +59,6 @@ public class TrackPullCacheService : ApplicationService, ITrackPullCacheService
var trackPullConfigEntity = await _trackPullConfigRepository.GetFirstAsync(exp);
if (trackPullConfigEntity == null) return data;
var trackPullConfigDetail = await _trackPullConfigRepository.GetDetailAsync(trackPullConfigEntity.Id);
if (trackPullConfigDetail is null) return data;
var trackPullContentList = await _trackPullConfigRepository.GetContentListCacheAsync(trackPullConfigEntity.Id);