112 lines
4.1 KiB
C#
112 lines
4.1 KiB
C#
using KLHZ.Trader.Core.Contracts.Messaging.Dtos;
|
|
using KLHZ.Trader.Core.Contracts.Messaging.Interfaces;
|
|
using KLHZ.Trader.Core.DataLayer;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace KLHZ.Trader.Service.Controllers
|
|
{
|
|
[ApiController]
|
|
[Route("[controller]/[action]")]
|
|
public class PlayController : ControllerBase
|
|
{
|
|
private readonly IDataBus _dataBus;
|
|
private readonly IDbContextFactory<TraderDbContext> _dbContextFactory;
|
|
|
|
public PlayController(IDataBus dataBus, IDbContextFactory<TraderDbContext> dbContextFactory)
|
|
{
|
|
_dbContextFactory = dbContextFactory;
|
|
_dataBus = dataBus;
|
|
}
|
|
|
|
[HttpGet]
|
|
public async Task Run(string figi)
|
|
{
|
|
try
|
|
{
|
|
var time = DateTime.UtcNow.AddMinutes(-50);
|
|
using var context1 = await _dbContextFactory.CreateDbContextAsync();
|
|
context1.ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
|
|
var data = await context1.PriceChanges
|
|
.Where(c => c.Figi == figi && c.Time >= time)
|
|
.OrderBy(c => c.Time)
|
|
.Select(c => new NewPriceMessage()
|
|
{
|
|
Figi = figi,
|
|
Ticker = c.Ticker,
|
|
Time = c.Time,
|
|
Value = c.Value,
|
|
IsHistoricalData = true
|
|
})
|
|
.ToArrayAsync();
|
|
|
|
foreach (var mess in data)
|
|
{
|
|
await _dataBus.Broadcast(mess);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
|
|
}
|
|
}
|
|
|
|
////[HttpGet]
|
|
//public async Task LoadTradesToHistory(string figi)
|
|
//{
|
|
// try
|
|
// {
|
|
// using var context1 = await _dbContextFactory.CreateDbContextAsync();
|
|
// context1.ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
|
|
// var data = await context1.InstrumentTrades
|
|
// .Where(c => c.Figi == figi)
|
|
// .OrderBy(c => c.BoughtAt)
|
|
// .Select(c => new PriceChange()
|
|
// {
|
|
// Figi = figi,
|
|
// Ticker = c.Ticker,
|
|
// Time = c.BoughtAt,
|
|
// Value = c.Price,
|
|
// IsHistoricalData = true
|
|
// })
|
|
// .ToArrayAsync();
|
|
// await context1.PriceChanges.Where(p => p.Figi == figi).ExecuteDeleteAsync();
|
|
// await context1.PriceChanges.AddRangeAsync(data);
|
|
// await context1.SaveChangesAsync();
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
|
|
// }
|
|
//}
|
|
////[HttpGet]
|
|
//public async Task LoadTradesToHistory(string figi)
|
|
//{
|
|
// try
|
|
// {
|
|
// using var context1 = await _dbContextFactory.CreateDbContextAsync();
|
|
// context1.ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
|
|
// var data = await context1.InstrumentTrades
|
|
// .Where(c => c.Figi == figi)
|
|
// .OrderBy(c => c.BoughtAt)
|
|
// .Select(c => new PriceChange()
|
|
// {
|
|
// Figi = figi,
|
|
// Ticker = c.Ticker,
|
|
// Time = c.BoughtAt,
|
|
// Value = c.Price,
|
|
// IsHistoricalData = true
|
|
// })
|
|
// .ToArrayAsync();
|
|
// await context1.PriceChanges.Where(p => p.Figi == figi).ExecuteDeleteAsync();
|
|
// await context1.PriceChanges.AddRangeAsync(data);
|
|
// await context1.SaveChangesAsync();
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
|
|
// }
|
|
//}
|
|
}
|
|
}
|