32 lines
1.0 KiB
C#
32 lines
1.0 KiB
C#
|
using AutoBet.DataRecorded.RaceResultsDataCollector;
|
||
|
|
using BritishHorseRacingApi;
|
||
|
|
using Microsoft.EntityFrameworkCore;
|
||
|
|
using SwiftyMessageHub.Core;
|
||
|
|
using System;
|
||
|
|
using System.Linq;
|
||
|
|
using System.Threading.Tasks;
|
||
|
|
|
||
|
|
namespace AutoBet.DataRecorded.MessageControllers
|
||
|
|
{
|
||
|
|
public class PostRaceDataCollectorController : MessageController
|
||
|
|
{
|
||
|
|
[MessageRoute]
|
||
|
|
public async Task LoadRaces(PostRaceDataCollectorDetails details)
|
||
|
|
{
|
||
|
|
var api = new ApiClient();
|
||
|
|
Console.WriteLine("Loading races");
|
||
|
|
using (var db = new Db.HorseRacingDataContext())
|
||
|
|
{
|
||
|
|
var results = await db.Races.Where(e => e.RaceDate.Date == details.DateToCollect.Date)
|
||
|
|
.Where(e => !db.RunnerResults.Any(e1 => e1.RaceId == e.RaceId))
|
||
|
|
.ToListAsync();
|
||
|
|
|
||
|
|
foreach (var result in results)
|
||
|
|
{
|
||
|
|
await CurrentContext.Hub.SendMessage(result);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|