|
|
|
@ -215,6 +215,18 @@ public class RefreshChannelDataHandler : IRequestHandler<RefreshChannelData> |
|
|
|
.AsSplitQuery() |
|
|
|
.AsSplitQuery() |
|
|
|
.ToListAsync(cancellationToken); |
|
|
|
.ToListAsync(cancellationToken); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// apply playout offset to all items consistently
|
|
|
|
|
|
|
|
foreach (Playout playout in playouts) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
foreach (PlayoutItem item in playout.Items) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
item.Start += playoutOffset; |
|
|
|
|
|
|
|
item.GuideStart += playoutOffset; |
|
|
|
|
|
|
|
item.Finish += playoutOffset; |
|
|
|
|
|
|
|
item.GuideFinish += playoutOffset; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
await using RecyclableMemoryStream ms = _recyclableMemoryStreamManager.GetStream(); |
|
|
|
await using RecyclableMemoryStream ms = _recyclableMemoryStreamManager.GetStream(); |
|
|
|
await using var xml = XmlWriter.Create( |
|
|
|
await using var xml = XmlWriter.Create( |
|
|
|
ms, |
|
|
|
ms, |
|
|
|
@ -238,11 +250,6 @@ public class RefreshChannelDataHandler : IRequestHandler<RefreshChannelData> |
|
|
|
.OrderBy(pi => pi.Start) |
|
|
|
.OrderBy(pi => pi.Start) |
|
|
|
.Filter(pi => pi.StartOffset <= finish) |
|
|
|
.Filter(pi => pi.StartOffset <= finish) |
|
|
|
.ToList(); |
|
|
|
.ToList(); |
|
|
|
foreach (var item in floodSorted) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
item.Start += playoutOffset; |
|
|
|
|
|
|
|
item.Finish += playoutOffset; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await WritePlayoutXml( |
|
|
|
await WritePlayoutXml( |
|
|
|
request, |
|
|
|
request, |
|
|
|
@ -264,11 +271,6 @@ public class RefreshChannelDataHandler : IRequestHandler<RefreshChannelData> |
|
|
|
.OrderBy(pi => pi.Start) |
|
|
|
.OrderBy(pi => pi.Start) |
|
|
|
.Filter(pi => pi.StartOffset <= finish) |
|
|
|
.Filter(pi => pi.StartOffset <= finish) |
|
|
|
.ToList(); |
|
|
|
.ToList(); |
|
|
|
foreach (var item in blockSorted) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
item.Start += playoutOffset; |
|
|
|
|
|
|
|
item.Finish += playoutOffset; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await WriteBlockPlayoutXml( |
|
|
|
await WriteBlockPlayoutXml( |
|
|
|
request, |
|
|
|
request, |
|
|
|
@ -288,11 +290,6 @@ public class RefreshChannelDataHandler : IRequestHandler<RefreshChannelData> |
|
|
|
var externalJsonSorted = (await CollectExternalJsonItems(playout.ScheduleFile)) |
|
|
|
var externalJsonSorted = (await CollectExternalJsonItems(playout.ScheduleFile)) |
|
|
|
.Filter(pi => pi.StartOffset <= finish) |
|
|
|
.Filter(pi => pi.StartOffset <= finish) |
|
|
|
.ToList(); |
|
|
|
.ToList(); |
|
|
|
foreach (var item in externalJsonSorted) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
item.Start += playoutOffset; |
|
|
|
|
|
|
|
item.Finish += playoutOffset; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await WritePlayoutXml( |
|
|
|
await WritePlayoutXml( |
|
|
|
request, |
|
|
|
request, |
|
|
|
|