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

Merge remote-tracking branch 'origin/S02-轨迹中台' into S02-轨迹中台

Browse Source
This commit is contained in:
李鹏军 2024-03-15 09:53:44 +08:00
commit 12c439c832
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; _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] [NonAction]
@ -53,7 +59,6 @@ public class TrackPullCacheService : ApplicationService, ITrackPullCacheService
var trackPullConfigEntity = await _trackPullConfigRepository.GetFirstAsync(exp); var trackPullConfigEntity = await _trackPullConfigRepository.GetFirstAsync(exp);
if (trackPullConfigEntity == null) return data; if (trackPullConfigEntity == null) return data;
var trackPullConfigDetail = await _trackPullConfigRepository.GetDetailAsync(trackPullConfigEntity.Id); var trackPullConfigDetail = await _trackPullConfigRepository.GetDetailAsync(trackPullConfigEntity.Id);
if (trackPullConfigDetail is null) return data; if (trackPullConfigDetail is null) return data;
var trackPullContentList = await _trackPullConfigRepository.GetContentListCacheAsync(trackPullConfigEntity.Id); var trackPullContentList = await _trackPullConfigRepository.GetContentListCacheAsync(trackPullConfigEntity.Id);