/*
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using QuantConnect.Brokerages;
using QuantConnect.Interfaces;
using QuantConnect.Lean.Engine.Results;
using QuantConnect.Logging;
using QuantConnect.Orders;
using QuantConnect.Orders.Fees;
using QuantConnect.Securities;
using QuantConnect.Util;
namespace QuantConnect.Lean.Engine.TransactionHandlers
{
///
/// Transaction handler for all brokerages
///
public class BrokerageTransactionHandler : ITransactionHandler
{
private IAlgorithm _algorithm;
private IBrokerage _brokerage;
private bool _syncedLiveBrokerageCashToday;
// Counter to keep track of total amount of processed orders
private int _totalOrderCount;
// this bool is used to check if the warning message for the rounding of order quantity has been displayed for the first time
private bool _firstRoundOffMessage = false;
// this value is used for determining how confident we are in our cash balance update
private long _lastFillTimeTicks;
private long _lastSyncTimeTicks;
private readonly object _performCashSyncReentranceGuard = new object();
// 7:45 AM (New York time zone)
private static readonly TimeSpan LiveBrokerageCashSyncTime = new TimeSpan(7, 45, 0);
private const int MaxCashSyncAttempts = 5;
private int _failedCashSyncAttempts;
///
/// OrderQueue holds the newly updated orders from the user algorithm waiting to be processed. Once
/// orders are processed they are moved into the Orders queue awaiting the brokerage response.
///
protected IBusyCollection _orderRequestQueue;
private Thread _processingThread;
private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();
///
/// The _completeOrders dictionary holds all orders.
/// Once the transaction thread has worked on them they get put here while witing for fill updates.
///
private readonly ConcurrentDictionary _completeOrders = new ConcurrentDictionary();
///
/// The orders dictionary holds orders which are open. Status: New, Submitted, PartiallyFilled, None, CancelPending
/// Once the transaction thread has worked on them they get put here while witing for fill updates.
///
private readonly ConcurrentDictionary _openOrders = new ConcurrentDictionary();
///
/// The _openOrderTickets dictionary holds open order tickets that the algorithm can use to reference a specific order. This
/// includes invoking update and cancel commands. In the future, we can add more features to the ticket, such as events
/// and async events (such as run this code when this order fills)
///
private readonly ConcurrentDictionary _openOrderTickets = new ConcurrentDictionary();
///
/// The _completeOrderTickets dictionary holds all order tickets that the algorithm can use to reference a specific order. This
/// includes invoking update and cancel commands. In the future, we can add more features to the ticket, such as events
/// and async events (such as run this code when this order fills)
///
private readonly ConcurrentDictionary _completeOrderTickets = new ConcurrentDictionary();
///
/// The _cancelPendingOrders instance will help to keep track of CancelPending orders and their Status
///
protected readonly CancelPendingOrders _cancelPendingOrders = new CancelPendingOrders();
private IResultHandler _resultHandler;
private readonly object _lockHandleOrderEvent = new object();
///
/// Event fired when there is a new
///
/// Will be called before the
public event EventHandler NewOrderEvent;
///
/// Gets the permanent storage for all orders
///
public ConcurrentDictionary Orders
{
get
{
return _completeOrders;
}
}
///
/// Gets the permanent storage for all order tickets
///
public ConcurrentDictionary OrderTickets
{
get
{
return _completeOrderTickets;
}
}
///
/// Gets the current number of orders that have been processed
///
public int OrdersCount => _totalOrderCount;
///
/// Creates a new BrokerageTransactionHandler to process orders using the specified brokerage implementation
///
/// The algorithm instance
/// The brokerage implementation to process orders and fire fill events
///
public virtual void Initialize(IAlgorithm algorithm, IBrokerage brokerage, IResultHandler resultHandler)
{
if (brokerage == null)
{
throw new ArgumentNullException("brokerage");
}
// multi threaded queue, used for live deployments
_orderRequestQueue = new BusyBlockingCollection();
// we don't need to do this today because we just initialized/synced
_resultHandler = resultHandler;
_syncedLiveBrokerageCashToday = true;
_lastSyncTimeTicks = CurrentTimeUtc.Ticks;
_brokerage = brokerage;
_brokerage.OrderStatusChanged += (sender, fill) =>
{
// log every fill in live mode
if (algorithm.LiveMode)
{
var brokerIds = string.Empty;
var order = GetOrderById(fill.OrderId);
if (order != null && order.BrokerId.Count > 0) brokerIds = string.Join(", ", order.BrokerId);
Log.Trace("BrokerageTransactionHandler.OrderStatusChanged(): " + fill + " BrokerId: " + brokerIds);
}
HandleOrderEvent(fill);
};
_brokerage.AccountChanged += (sender, account) =>
{
HandleAccountChanged(account);
};
_brokerage.OptionPositionAssigned += (sender, fill) =>
{
HandlePositionAssigned(fill);
};
IsActive = true;
_algorithm = algorithm;
InitializeTransactionThread();
}
///
/// Create and start the transaction thread, who will be in charge of processing
/// the order requests
///
protected virtual void InitializeTransactionThread()
{
_processingThread = new Thread(Run) { IsBackground = true, Name = "Transaction Thread" };
_processingThread.Start();
}
///
/// Boolean flag indicating the Run thread method is busy.
/// False indicates it is completely finished processing and ready to be terminated.
///
public bool IsActive { get; private set; }
#region Order Request Processing
///
/// Adds the specified order to be processed
///
/// The order to be processed
public OrderTicket Process(OrderRequest request)
{
if (_algorithm.LiveMode)
{
Log.Trace("BrokerageTransactionHandler.Process(): " + request);
_algorithm.Portfolio.LogMarginInformation(request);
}
switch (request.OrderRequestType)
{
case OrderRequestType.Submit:
return AddOrder((SubmitOrderRequest)request);
case OrderRequestType.Update:
return UpdateOrder((UpdateOrderRequest)request);
case OrderRequestType.Cancel:
return CancelOrder((CancelOrderRequest)request);
default:
throw new ArgumentOutOfRangeException();
}
}
///
/// Add an order to collection and return the unique order id or negative if an error.
///
/// A request detailing the order to be submitted
/// New unique, increasing orderid
public OrderTicket AddOrder(SubmitOrderRequest request)
{
var response = !_algorithm.IsWarmingUp
? OrderResponse.Success(request)
: OrderResponse.WarmingUp(request);
request.SetResponse(response);
var ticket = new OrderTicket(_algorithm.Transactions, request);
Interlocked.Increment(ref _totalOrderCount);
// send the order to be processed after creating the ticket
if (response.IsSuccess)
{
_openOrderTickets.TryAdd(ticket.OrderId, ticket);
_completeOrderTickets.TryAdd(ticket.OrderId, ticket);
_orderRequestQueue.Add(request);
// wait for the transaction handler to set the order reference into the new order ticket,
// so we can ensure the order has already been added to the open orders,
// before returning the ticket to the algorithm.
WaitForOrderSubmission(ticket);
}
else
{
// add it to the orders collection for recall later
var order = Order.CreateOrder(request);
// ensure the order is tagged with a currency
var security = _algorithm.Securities[order.Symbol];
order.PriceCurrency = security.SymbolProperties.QuoteCurrency;
order.Status = OrderStatus.Invalid;
order.Tag = "Algorithm warming up.";
ticket.SetOrder(order);
_completeOrderTickets.TryAdd(ticket.OrderId, ticket);
_completeOrders.TryAdd(order.Id, order);
}
return ticket;
}
///
/// Wait for the order to be handled by the
///
/// The expecting to be submitted
protected virtual void WaitForOrderSubmission(OrderTicket ticket)
{
var orderSetTimeout = Time.OneSecond;
if (!ticket.OrderSet.WaitOne(orderSetTimeout))
{
Log.Error("BrokerageTransactionHandler.WaitForOrderSubmission(): " +
$"The order request (Id={ticket.OrderId}) was not submitted within {orderSetTimeout.TotalSeconds} second(s).");
}
}
///
/// Update an order yet to be filled such as stop or limit orders.
///
/// Request detailing how the order should be updated
/// Does not apply if the order is already fully filled
public OrderTicket UpdateOrder(UpdateOrderRequest request)
{
OrderTicket ticket;
if (!_completeOrderTickets.TryGetValue(request.OrderId, out ticket))
{
return OrderTicket.InvalidUpdateOrderId(_algorithm.Transactions, request);
}
ticket.AddUpdateRequest(request);
try
{
//Update the order from the behaviour
var order = GetOrderByIdInternal(request.OrderId);
if (order == null)
{
// can't update an order that doesn't exist!
request.SetResponse(OrderResponse.UnableToFindOrder(request));
}
else if (order.Status.IsClosed())
{
// can't update a completed order
request.SetResponse(OrderResponse.InvalidStatus(request, order));
}
else if (request.Quantity.HasValue && request.Quantity.Value == 0)
{
request.SetResponse(OrderResponse.ZeroQuantity(request));
}
else if (_algorithm.IsWarmingUp)
{
request.SetResponse(OrderResponse.WarmingUp(request));
}
else
{
request.SetResponse(OrderResponse.Success(request), OrderRequestStatus.Processing);
_orderRequestQueue.Add(request);
}
}
catch (Exception err)
{
Log.Error(err);
request.SetResponse(OrderResponse.Error(request, OrderResponseErrorCode.ProcessingError, err.Message));
}
return ticket;
}
///
/// Remove this order from outstanding queue: user is requesting a cancel.
///
/// Request containing the specific order id to remove
public OrderTicket CancelOrder(CancelOrderRequest request)
{
OrderTicket ticket;
if (!_completeOrderTickets.TryGetValue(request.OrderId, out ticket))
{
Log.Error("BrokerageTransactionHandler.CancelOrder(): Unable to locate ticket for order.");
return OrderTicket.InvalidCancelOrderId(_algorithm.Transactions, request);
}
try
{
// if we couldn't set this request as the cancellation then another thread/someone
// else is already doing it or it in fact has already been cancelled
if (!ticket.TrySetCancelRequest(request))
{
// the ticket has already been cancelled
request.SetResponse(OrderResponse.Error(request, OrderResponseErrorCode.InvalidRequest, "Cancellation is already in progress."));
return ticket;
}
//Error check
var order = GetOrderByIdInternal(request.OrderId);
if (order != null && request.Tag != null)
{
order.Tag = request.Tag;
}
if (order == null)
{
Log.Error("BrokerageTransactionHandler.CancelOrder(): Cannot find this id.");
request.SetResponse(OrderResponse.UnableToFindOrder(request));
}
else if (order.Status.IsClosed())
{
Log.Error("BrokerageTransactionHandler.CancelOrder(): Order already " + order.Status);
request.SetResponse(OrderResponse.InvalidStatus(request, order));
}
else if (_algorithm.IsWarmingUp)
{
request.SetResponse(OrderResponse.WarmingUp(request));
}
else
{
_cancelPendingOrders.Set(order.Id, order.Status);
// update the order status
order.Status = OrderStatus.CancelPending;
// notify the algorithm with an order event
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero));
// send the request to be processed
request.SetResponse(OrderResponse.Success(request), OrderRequestStatus.Processing);
_orderRequestQueue.Add(request);
}
}
catch (Exception err)
{
Log.Error(err);
request.SetResponse(OrderResponse.Error(request, OrderResponseErrorCode.ProcessingError, err.Message));
}
return ticket;
}
///
/// Gets and enumerable of matching the specified
///
/// The filter predicate used to find the required order tickets
/// An enumerable of matching the specified
public IEnumerable GetOrderTickets(Func filter = null)
{
return _completeOrderTickets.Select(x => x.Value).Where(filter ?? (x => true));
}
///
/// Gets and enumerable of opened matching the specified
///
/// The filter predicate used to find the required order tickets
/// An enumerable of opened matching the specified
public IEnumerable GetOpenOrderTickets(Func filter = null)
{
return _openOrderTickets.Select(x => x.Value).Where(filter ?? (x => true));
}
///
/// Gets the order ticket for the specified order id. Returns null if not found
///
/// The order's id
/// The order ticket with the specified id, or null if not found
public OrderTicket GetOrderTicket(int orderId)
{
OrderTicket ticket;
_completeOrderTickets.TryGetValue(orderId, out ticket);
return ticket;
}
#endregion
///
/// Get the order by its id
///
/// Order id to fetch
/// The order with the specified id, or null if no match is found
public Order GetOrderById(int orderId)
{
Order order = GetOrderByIdInternal(orderId);
return order != null ? order.Clone() : null;
}
private Order GetOrderByIdInternal(int orderId)
{
Order order;
return _completeOrders.TryGetValue(orderId, out order) ? order : null;
}
///
/// Gets the order by its brokerage id
///
/// The brokerage id to fetch
/// The first order matching the brokerage id, or null if no match is found
public Order GetOrderByBrokerageId(string brokerageId)
{
var order = _openOrders.FirstOrDefault(x => x.Value.BrokerId.Contains(brokerageId)).Value
?? _completeOrders.FirstOrDefault(x => x.Value.BrokerId.Contains(brokerageId)).Value;
return order?.Clone();
}
///
/// Gets all orders matching the specified filter. Specifying null will return an enumerable
/// of all orders.
///
/// Delegate used to filter the orders
/// All orders this order provider currently holds by the specified filter
public IEnumerable GetOrders(Func filter = null)
{
if (filter != null)
{
// return a clone to prevent object reference shenanigans, you must submit a request to change the order
return _completeOrders.Select(x => x.Value).Where(filter).Select(x => x.Clone());
}
return _completeOrders.Select(x => x.Value).Select(x => x.Clone());
}
///
/// Gets open orders matching the specified filter
///
/// Delegate used to filter the orders
/// All open orders this order provider currently holds
public List GetOpenOrders(Func filter = null)
{
if (filter != null)
{
// return a clone to prevent object reference shenanigans, you must submit a request to change the order
return _openOrders.Select(x => x.Value).Where(filter).Select(x => x.Clone()).ToList();
}
return _openOrders.Select(x => x.Value).Select(x => x.Clone()).ToList();
}
///
/// Primary thread entry point to launch the transaction thread.
///
protected void Run()
{
try
{
foreach (var request in _orderRequestQueue.GetConsumingEnumerable(_cancellationTokenSource.Token))
{
HandleOrderRequest(request);
ProcessAsynchronousEvents();
}
}
catch (Exception err)
{
// unexpected error, we need to close down shop
Log.Error(err);
// quit the algorithm due to error
_algorithm.RunTimeError = err;
}
if (_processingThread != null)
{
Log.Trace("BrokerageTransactionHandler.Run(): Ending Thread...");
IsActive = false;
}
}
///
/// Processes asynchronous events on the transaction handler's thread
///
public virtual void ProcessAsynchronousEvents()
{
// NOP
}
///
/// Processes all synchronous events that must take place before the next time loop for the algorithm
///
public virtual void ProcessSynchronousEvents()
{
// how to do synchronous market orders for real brokerages?
// in backtesting we need to wait for orders to be removed from the queue and finished processing
if (!_algorithm.LiveMode)
{
if (_orderRequestQueue.IsBusy && !_orderRequestQueue.WaitHandle.WaitOne(Time.OneSecond, _cancellationTokenSource.Token))
{
Log.Error("BrokerageTransactionHandler.ProcessSynchronousEvents(): Timed out waiting for request queue to finish processing.");
}
return;
}
Log.Debug("BrokerageTransactionHandler.ProcessSynchronousEvents(): Enter");
// every morning flip this switch back
var currentTimeNewYork = CurrentTimeUtc.ConvertFromUtc(TimeZones.NewYork);
if (_syncedLiveBrokerageCashToday && currentTimeNewYork.Date != LastSyncDate)
{
_syncedLiveBrokerageCashToday = false;
_failedCashSyncAttempts = 0;
}
// we want to sync up our cash balance before market open
if (_algorithm.LiveMode && !_syncedLiveBrokerageCashToday && currentTimeNewYork.TimeOfDay >= LiveBrokerageCashSyncTime)
{
// only perform cash syncs if we haven't had a fill for at least 10 seconds
if (TimeSinceLastFill > TimeSpan.FromSeconds(10))
{
if (!PerformCashSync())
{
if (++_failedCashSyncAttempts >= MaxCashSyncAttempts)
{
throw new Exception("The maximum number of attempts for brokerage cash sync has been reached.");
}
}
}
}
// we want to remove orders older than 10k records, but only in live mode
const int maxOrdersToKeep = 10000;
if (_completeOrders.Count < maxOrdersToKeep + 1)
{
Log.Debug("BrokerageTransactionHandler.ProcessSynchronousEvents(): Exit");
return;
}
int max = _completeOrders.Max(x => x.Key);
int lowestOrderIdToKeep = max - maxOrdersToKeep;
foreach (var item in _completeOrders.Where(x => x.Key <= lowestOrderIdToKeep))
{
Order value;
OrderTicket ticket;
_completeOrders.TryRemove(item.Key, out value);
_completeOrderTickets.TryRemove(item.Key, out ticket);
}
Log.Debug("BrokerageTransactionHandler.ProcessSynchronousEvents(): Exit");
}
///
/// Register an already open Order
///
public void AddOpenOrder(Order order, OrderTicket orderTicket)
{
_openOrders.AddOrUpdate(order.Id, order, (i, o) => order);
_completeOrders.AddOrUpdate(order.Id, order, (i, o) => order);
_openOrderTickets.AddOrUpdate(order.Id, orderTicket);
_completeOrderTickets.AddOrUpdate(order.Id, orderTicket);
}
///
/// Syncs cash from brokerage with portfolio object
///
private bool PerformCashSync()
{
try
{
// prevent reentrance in this method
if (!Monitor.TryEnter(_performCashSyncReentranceGuard))
{
Log.Trace("BrokerageTransactionHandler.PerformCashSync(): Reentrant call, cash sync not performed");
return false;
}
Log.Trace("BrokerageTransactionHandler.PerformCashSync(): Sync cash balance");
var balances = new List();
try
{
balances = _brokerage.GetCashBalance();
}
catch (Exception err)
{
Log.Error(err, "Error in GetCashBalance:");
}
if (balances.Count == 0)
{
Log.Trace("BrokerageTransactionHandler.PerformCashSync(): No cash balances available, cash sync not performed");
return false;
}
//Adds currency to the cashbook that the user might have deposited
foreach (var balance in balances)
{
Cash cash;
if (!_algorithm.Portfolio.CashBook.TryGetValue(balance.Currency, out cash))
{
Log.LogHandler.Trace("BrokerageTransactionHandler.PerformCashSync(): Unexpected cash found {0} {1}", balance.Currency, balance.Amount);
_algorithm.Portfolio.SetCash(balance.Currency, balance.Amount, 0);
}
}
// if we were returned our balances, update everything and flip our flag as having performed sync today
foreach (var kvp in _algorithm.Portfolio.CashBook)
{
var cash = kvp.Value;
//update the cash if the entry if found in the balances
var balanceCash = balances.Find(balance => balance.Currency == cash.Symbol);
if (balanceCash != default(CashAmount))
{
// compare in account currency
var delta = cash.Amount - balanceCash.Amount;
if (Math.Abs(_algorithm.Portfolio.CashBook.ConvertToAccountCurrency(delta, cash.Symbol)) > 5)
{
// log the delta between
Log.LogHandler.Trace("BrokerageTransactionHandler.PerformCashSync(): {0} Delta: {1}", balanceCash.Currency,
delta.ToString("0.00"));
}
_algorithm.Portfolio.CashBook[cash.Symbol].SetAmount(balanceCash.Amount);
}
else
{
//Set the cash amount to zero if cash entry not found in the balances
Log.LogHandler.Trace($"BrokerageTransactionHandler.PerformCashSync(): {cash.Symbol} was not found " +
"in brokerage cash balance, setting the amount to 0");
_algorithm.Portfolio.CashBook[cash.Symbol].SetAmount(0);
}
}
_syncedLiveBrokerageCashToday = true;
_lastSyncTimeTicks = CurrentTimeUtc.Ticks;
}
finally
{
Monitor.Exit(_performCashSyncReentranceGuard);
}
// fire off this task to check if we've had recent fills, if we have then we'll invalidate the cash sync
// and do it again until we're confident in it
Task.Delay(TimeSpan.FromSeconds(10)).ContinueWith(_ =>
{
// we want to make sure this is a good value, so check for any recent fills
if (TimeSinceLastFill <= TimeSpan.FromSeconds(20))
{
// this will cause us to come back in and reset cash again until we
// haven't processed a fill for +- 10 seconds of the set cash time
_syncedLiveBrokerageCashToday = false;
_failedCashSyncAttempts = 0;
Log.Trace("BrokerageTransactionHandler.PerformCashSync(): Unverified cash sync - resync required.");
}
else
{
Log.Trace("BrokerageTransactionHandler.PerformCashSync(): Verified cash sync.");
_algorithm.Portfolio.LogMarginInformation();
}
});
return true;
}
///
/// Signal a end of thread request to stop monitoring the transactions.
///
public void Exit()
{
if (_processingThread != null)
{
// only wait if the processing thread is running
var timeout = TimeSpan.FromSeconds(60);
if (_orderRequestQueue.IsBusy && !_orderRequestQueue.WaitHandle.WaitOne(timeout))
{
Log.Error("BrokerageTransactionHandler.Exit(): Exceed timeout: " + (int)(timeout.TotalSeconds) + " seconds.");
}
}
_cancellationTokenSource.Cancel();
if (_processingThread != null && _processingThread.IsAlive)
{
_processingThread.Abort();
}
IsActive = false;
}
///
/// Handles a generic order request
///
/// to be handled
/// for request
public void HandleOrderRequest(OrderRequest request)
{
OrderResponse response;
switch (request.OrderRequestType)
{
case OrderRequestType.Submit:
response = HandleSubmitOrderRequest((SubmitOrderRequest)request);
break;
case OrderRequestType.Update:
response = HandleUpdateOrderRequest((UpdateOrderRequest)request);
break;
case OrderRequestType.Cancel:
response = HandleCancelOrderRequest((CancelOrderRequest)request);
break;
default:
throw new ArgumentOutOfRangeException();
}
// mark request as processed
request.SetResponse(response, OrderRequestStatus.Processed);
}
///
/// Handles a request to submit a new order
///
private OrderResponse HandleSubmitOrderRequest(SubmitOrderRequest request)
{
OrderTicket ticket;
var order = Order.CreateOrder(request);
// ensure the order is tagged with a currency
var security = _algorithm.Securities[order.Symbol];
order.PriceCurrency = security.SymbolProperties.QuoteCurrency;
// rounds off the order towards 0 to the nearest multiple of lot size
order.Quantity = RoundOffOrder(order, security);
if (!_openOrders.TryAdd(order.Id, order) || !_completeOrders.TryAdd(order.Id, order))
{
Log.Error("BrokerageTransactionHandler.HandleSubmitOrderRequest(): Unable to add new order, order not processed.");
return OrderResponse.Error(request, OrderResponseErrorCode.OrderAlreadyExists, "Cannot process submit request because order with id {0} already exists");
}
if (!_completeOrderTickets.TryGetValue(order.Id, out ticket))
{
Log.Error("BrokerageTransactionHandler.HandleSubmitOrderRequest(): Unable to retrieve order ticket, order not processed.");
return OrderResponse.UnableToFindOrder(request);
}
// rounds the order prices
RoundOrderPrices(order, security);
// save current security time and prices
order.OrderSubmissionData = new OrderSubmissionData(security.GetLastData());
// update the ticket's internal storage with this new order reference
ticket.SetOrder(order);
if (order.Quantity == 0)
{
order.Status = OrderStatus.Invalid;
var response = OrderResponse.ZeroQuantity(request);
_algorithm.Error(response.ErrorMessage);
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
"Unable to add order for zero quantity"));
return response;
}
// check to see if we have enough money to place the order
HasSufficientBuyingPowerForOrderResult hasSufficientBuyingPowerResult;
try
{
hasSufficientBuyingPowerResult = security.BuyingPowerModel.HasSufficientBuyingPowerForOrder(
new HasSufficientBuyingPowerForOrderParameters(_algorithm.Portfolio, security, order));
}
catch (Exception err)
{
Log.Error(err);
_algorithm.Error(string.Format("Order Error: id: {0}, Error executing margin models: {1}", order.Id, err.Message));
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
"Error executing margin models"));
return OrderResponse.Error(request, OrderResponseErrorCode.ProcessingError, "Error in GetSufficientCapitalForOrder");
}
if (!hasSufficientBuyingPowerResult.IsSufficient)
{
order.Status = OrderStatus.Invalid;
var errorMessage = $"Order Error: id: {order.Id}, Insufficient buying power to complete order (Value:{order.GetValue(security).SmartRounding()}), Reason: {hasSufficientBuyingPowerResult.Reason}";
var response = OrderResponse.Error(request, OrderResponseErrorCode.InsufficientBuyingPower, errorMessage);
_algorithm.Error(response.ErrorMessage);
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
errorMessage));
return response;
}
// verify that our current brokerage can actually take the order
BrokerageMessageEvent message;
if (!_algorithm.BrokerageModel.CanSubmitOrder(security, order, out message))
{
// if we couldn't actually process the order, mark it as invalid and bail
order.Status = OrderStatus.Invalid;
if (message == null) message = new BrokerageMessageEvent(BrokerageMessageType.Warning, "InvalidOrder", "BrokerageModel declared unable to submit order: " + order.Id);
var response = OrderResponse.Error(request, OrderResponseErrorCode.BrokerageModelRefusedToSubmitOrder, "OrderID: " + order.Id + " " + message);
_algorithm.Error(response.ErrorMessage);
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
"BrokerageModel declared unable to submit order"));
return response;
}
// set the order status based on whether or not we successfully submitted the order to the market
bool orderPlaced;
try
{
orderPlaced = _brokerage.PlaceOrder(order);
}
catch (Exception err)
{
Log.Error(err);
orderPlaced = false;
}
if (!orderPlaced)
{
// we failed to submit the order, invalidate it
order.Status = OrderStatus.Invalid;
var errorMessage = "Brokerage failed to place order: " + order.Id;
var response = OrderResponse.Error(request, OrderResponseErrorCode.BrokerageFailedToSubmitOrder, errorMessage);
_algorithm.Error(response.ErrorMessage);
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
"Brokerage failed to place order"));
return response;
}
return OrderResponse.Success(request);
}
///
/// Handles a request to update order properties
///
private OrderResponse HandleUpdateOrderRequest(UpdateOrderRequest request)
{
Order order;
OrderTicket ticket;
if (!_completeOrders.TryGetValue(request.OrderId, out order) || !_completeOrderTickets.TryGetValue(request.OrderId, out ticket))
{
Log.Error("BrokerageTransactionHandler.HandleUpdateOrderRequest(): Unable to update order with ID " + request.OrderId);
return OrderResponse.UnableToFindOrder(request);
}
if (!CanUpdateOrder(order))
{
return OrderResponse.InvalidStatus(request, order);
}
// rounds off the order towards 0 to the nearest multiple of lot size
var security = _algorithm.Securities[order.Symbol];
order.Quantity = RoundOffOrder(order, security);
// verify that our current brokerage can actually update the order
BrokerageMessageEvent message;
if (!_algorithm.LiveMode && !_algorithm.BrokerageModel.CanUpdateOrder(_algorithm.Securities[order.Symbol], order, request, out message))
{
if (message == null) message = new BrokerageMessageEvent(BrokerageMessageType.Warning, "InvalidRequest", "BrokerageModel declared unable to update order: " + order.Id);
var response = OrderResponse.Error(request, OrderResponseErrorCode.BrokerageModelRefusedToUpdateOrder, "OrderID: " + order.Id + " " + message);
_algorithm.Error(response.ErrorMessage);
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
"BrokerageModel declared unable to update order"));
return response;
}
// modify the values of the order object
order.ApplyUpdateOrderRequest(request);
// rounds the order prices
RoundOrderPrices(order, security);
ticket.SetOrder(order);
bool orderUpdated;
try
{
orderUpdated = _brokerage.UpdateOrder(order);
}
catch (Exception err)
{
Log.Error(err);
orderUpdated = false;
}
if (!orderUpdated)
{
// we failed to update the order for some reason
var errorMessage = "Brokerage failed to update order with id " + request.OrderId;
_algorithm.Error(errorMessage);
HandleOrderEvent(new OrderEvent(order,
_algorithm.UtcTime,
OrderFee.Zero,
"Brokerage failed to update order"));
return OrderResponse.Error(request, OrderResponseErrorCode.BrokerageFailedToUpdateOrder, errorMessage);
}
return OrderResponse.Success(request);
}
///
/// Returns true if the specified order can be updated
///
/// The order to check if we can update
/// True if the order can be updated, false otherwise
private bool CanUpdateOrder(Order order)
{
return order.Status != OrderStatus.Filled
&& order.Status != OrderStatus.Canceled
&& order.Status != OrderStatus.PartiallyFilled
&& order.Status != OrderStatus.Invalid;
}
///
/// Handles a request to cancel an order
///
private OrderResponse HandleCancelOrderRequest(CancelOrderRequest request)
{
Order order;
OrderTicket ticket;
if (!_completeOrders.TryGetValue(request.OrderId, out order) || !_completeOrderTickets.TryGetValue(request.OrderId, out ticket))
{
Log.Error("BrokerageTransactionHandler.HandleCancelOrderRequest(): Unable to cancel order with ID " + request.OrderId + ".");
_cancelPendingOrders.RemoveAndFallback(order);
return OrderResponse.UnableToFindOrder(request);
}
if (order.Status.IsClosed())
{
_cancelPendingOrders.RemoveAndFallback(order);
return OrderResponse.InvalidStatus(request, order);
}
ticket.SetOrder(order);
bool orderCanceled;
try
{
orderCanceled = _brokerage.CancelOrder(order);
}
catch (Exception err)
{
Log.Error(err);
orderCanceled = false;
}
if (!orderCanceled)
{
// failed to cancel the order
var message = "Brokerage failed to cancel order with id " + order.Id;
_algorithm.Error(message);
_cancelPendingOrders.RemoveAndFallback(order);
return OrderResponse.Error(request, OrderResponseErrorCode.BrokerageFailedToCancelOrder, message);
}
if (request.Tag != null)
{
// update the tag, useful for 'why' we canceled the order
order.Tag = request.Tag;
}
return OrderResponse.Success(request);
}
private void HandleOrderEvent(OrderEvent fill)
{
lock (_lockHandleOrderEvent)
{
Order order;
OrderTicket ticket;
if (fill.Status.IsClosed() && _openOrders.TryRemove(fill.OrderId, out order))
{
_completeOrders[fill.OrderId] = order;
}
else if (!_completeOrders.TryGetValue(fill.OrderId, out order))
{
Log.Error("BrokerageTransactionHandler.HandleOrderEvent(): Unable to locate open Order with id " + fill.OrderId);
return;
}
if (fill.Status.IsClosed() && _openOrderTickets.TryRemove(fill.OrderId, out ticket))
{
_completeOrderTickets[fill.OrderId] = ticket;
}
else if (!_completeOrderTickets.TryGetValue(fill.OrderId, out ticket))
{
Log.Error("BrokerageTransactionHandler.HandleOrderEvent(): Unable to resolve open ticket: " + fill.OrderId);
return;
}
_cancelPendingOrders.UpdateOrRemove(order.Id, fill.Status);
// set the status of our order object based on the fill event
order.Status = fill.Status;
// set the modified time of the order to the fill's timestamp
switch (fill.Status)
{
case OrderStatus.Canceled:
order.CanceledTime = fill.UtcTime;
break;
case OrderStatus.PartiallyFilled:
case OrderStatus.Filled:
order.LastFillTime = fill.UtcTime;
// append fill message to order tag, for additional information
if (fill.Status == OrderStatus.Filled && !string.IsNullOrWhiteSpace(fill.Message))
{
if (string.IsNullOrWhiteSpace(order.Tag))
{
order.Tag = fill.Message;
}
else
{
order.Tag += " - " + fill.Message;
}
}
break;
case OrderStatus.Submitted:
// submit events after the initial submission are all order updates
if (ticket.UpdateRequests.Count > 0)
{
order.LastUpdateTime = fill.UtcTime;
}
break;
}
// save that the order event took place, we're initializing the list with a capacity of 2 to reduce number of mallocs
//these hog memory
//List orderEvents = _orderEvents.GetOrAdd(orderEvent.OrderId, i => new List(2));
//orderEvents.Add(orderEvent);
//Apply the filled order to our portfolio:
if (fill.Status == OrderStatus.Filled || fill.Status == OrderStatus.PartiallyFilled)
{
Interlocked.Exchange(ref _lastFillTimeTicks, CurrentTimeUtc.Ticks);
// check if the fill currency and the order currency match the symbol currency
var security = _algorithm.Securities[fill.Symbol];
// Bug in FXCM API flipping the currencies -- disabling for now. 5/17/16 RFB
//if (fill.FillPriceCurrency != security.SymbolProperties.QuoteCurrency)
//{
// Log.Error(string.Format("Currency mismatch: Fill currency: {0}, Symbol currency: {1}", fill.FillPriceCurrency, security.SymbolProperties.QuoteCurrency));
//}
//if (order.PriceCurrency != security.SymbolProperties.QuoteCurrency)
//{
// Log.Error(string.Format("Currency mismatch: Order currency: {0}, Symbol currency: {1}", order.PriceCurrency, security.SymbolProperties.QuoteCurrency));
//}
var multiplier = security.SymbolProperties.ContractMultiplier;
var securityConversionRate = security.QuoteCurrency.ConversionRate;
var feeInAccountCurrency = _algorithm.Portfolio.CashBook
.ConvertToAccountCurrency(fill.OrderFee.Value).Amount;
try
{
// to be called before updating the Portfolio
NewOrderEvent?.Invoke(this, fill);
_algorithm.Portfolio.ProcessFill(fill);
_algorithm.TradeBuilder.ProcessFill(
fill,
securityConversionRate,
feeInAccountCurrency,
multiplier);
}
catch (Exception err)
{
Log.Error(err);
_algorithm.Error(string.Format("Order Error: id: {0}, Error in Portfolio.ProcessFill: {1}", order.Id, err.Message));
}
}
// update the ticket and order after we've processed the fill, but before the event, this way everything is ready for user code
ticket.AddOrderEvent(fill);
order.Price = ticket.AverageFillPrice;
}
//We have an event! :) Order filled, send it in to be handled by algorithm portfolio.
if (fill.Status != OrderStatus.None) //order.Status != OrderStatus.Submitted
{
//Create new order event:
_resultHandler.OrderEvent(fill);
try
{
//Trigger our order event handler
_algorithm.OnOrderEvent(fill);
}
catch (Exception err)
{
_algorithm.Error("Order Event Handler Error: " + err.Message);
// kill the algorithm
_algorithm.RunTimeError = err;
}
}
}
///
/// Brokerages can send account updates, this include cash balance updates. Since it is of
/// utmost important to always have an accurate picture of reality, we'll trust this information
/// as truth
///
private void HandleAccountChanged(AccountEvent account)
{
// how close are we?
var delta = _algorithm.Portfolio.CashBook[account.CurrencySymbol].Amount - account.CashBalance;
if (delta != 0)
{
Log.Trace(string.Format("BrokerageTransactionHandler.HandleAccountChanged(): {0} Cash Delta: {1}", account.CurrencySymbol, delta));
}
// maybe we don't actually want to do this, this data can be delayed. Must be explicitly supported by brokerage
if (_brokerage.AccountInstantlyUpdated)
{
// override the current cash value so we're always guaranteed to be in sync with the brokerage's push updates
_algorithm.Portfolio.CashBook[account.CurrencySymbol].SetAmount(account.CashBalance);
}
}
///
/// Option assignment/exercise event is received and propagated to the user algo
///
private void HandlePositionAssigned(OrderEvent fill)
{
// informing user algorithm that option position has been assigned
if (fill.IsAssignment)
{
_algorithm.OnAssignmentOrderEvent(fill);
}
}
///
/// Gets the amount of time since the last call to algorithm.Portfolio.ProcessFill(fill)
///
protected virtual TimeSpan TimeSinceLastFill
{
get { return CurrentTimeUtc - new DateTime(Interlocked.Read(ref _lastFillTimeTicks)); }
}
///
/// Gets the date of the last sync (New York time zone)
///
protected DateTime LastSyncDate
{
get { return new DateTime(Interlocked.Read(ref _lastSyncTimeTicks)).ConvertFromUtc(TimeZones.NewYork).Date; }
}
///
/// Gets current time UTC. This is here to facilitate testing
///
protected virtual DateTime CurrentTimeUtc => DateTime.UtcNow;
///
/// Rounds off the order towards 0 to the nearest multiple of Lot Size
///
public decimal RoundOffOrder(Order order, Security security)
{
var orderLotMod = order.Quantity % security.SymbolProperties.LotSize;
if (orderLotMod != 0)
{
order.Quantity = order.Quantity - orderLotMod;
if (!_firstRoundOffMessage)
{
_algorithm.Error(
string.Format(
"Warning: Due to brokerage limitations, orders will be rounded to the nearest lot size of {0}",
security.SymbolProperties.LotSize));
_firstRoundOffMessage = true;
}
return order.Quantity;
}
else
{
return order.Quantity;
}
}
///
/// Rounds the order prices to its security minimum price variation.
///
/// This procedure is needed to meet brokerage precision requirements.
///
///
private void RoundOrderPrices(Order order, Security security)
{
// Do not need to round market orders
if (order.Type == OrderType.Market ||
order.Type == OrderType.MarketOnOpen ||
order.Type == OrderType.MarketOnClose)
{
return;
}
var increment = security.PriceVariationModel.GetMinimumPriceVariation(security);
if (increment == 0) return;
var limitPrice = 0m;
var limitRound = 0m;
var stopPrice = 0m;
var stopRound = 0m;
switch (order.Type)
{
case OrderType.Limit:
limitPrice = ((LimitOrder)order).LimitPrice;
limitRound = Math.Round(limitPrice / increment) * increment;
((LimitOrder)order).LimitPrice = limitRound;
break;
case OrderType.StopMarket:
stopPrice = ((StopMarketOrder)order).StopPrice;
stopRound = Math.Round(stopPrice / increment) * increment;
((StopMarketOrder)order).StopPrice = stopRound;
break;
case OrderType.StopLimit:
limitPrice = ((StopLimitOrder)order).LimitPrice;
limitRound = Math.Round(limitPrice / increment) * increment;
((StopLimitOrder)order).LimitPrice = limitRound;
stopPrice = ((StopLimitOrder)order).StopPrice;
stopRound = Math.Round(stopPrice / increment) * increment;
((StopLimitOrder)order).StopPrice = stopRound;
break;
default:
break;
}
var format = "Warning: To meet brokerage precision requirements, order {0}Price was rounded to {1} from {2}";
if (!limitPrice.Equals(limitRound))
{
_algorithm.Error(string.Format(format, "Limit", limitRound, limitPrice));
}
if (!stopPrice.Equals(stopRound))
{
_algorithm.Error(string.Format(format, "Stop", stopRound, stopPrice));
}
}
}
}