Files
quantconnect--lean/Common/Python/FillModelPythonWrapper.cs
T
Jhonathan Abreu b54281b262 Combo orders (#6813)
* Feature combo orders

- Add support for combo orders

* Make fill model wait for all grouped orders to emit fills

* Add ComboFill to model multiple fills for combo orders

* Fill combo limit orders

Add some regression algorithms

* Add fill implementation for combo leg limit orders

* Add IFill as common interface for Fill and ComboFill

* Refactor combo orders removing IGroupOrder interface

Move the group order manager to the base Order class

* Update algorithms

* Handle combo order events atomically

* Refactor brokerage transaction event handler

* Refactor combo fill models

* Process fills in batch

* Combo orders fill model tests

* Combo leg limit orders algorithm

* Regression algorithms cleanup

* Fill and combo fill classes cleanup

* Housekeeping

* Refactor equity fill model to derive from base fill model

* Address review changes request

* Handling the new types of orders in the OrderJsonConverter

* Add regression algorithm to test combo orders update/cancel

* Add regression algorithm to test combo orders update/cancel

* Housekeeping

* Address review changes request

* Minor changes

* Security transaction handler method for setting order request id

* Extend public interface for placing combo orders

* Combo order tickets demo algorithm python version

* Tweaks and updates

* Minor fixes

* Minor changes

* Minor fixes

* Address reviews minor fixes

* Minor fixes

Co-authored-by: Martin-Molinero <martin@quantconnect.com>
2023-01-06 17:58:43 -03:00

180 lines
7.6 KiB
C#

/*
* 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 Python.Runtime;
using QuantConnect.Orders;
using QuantConnect.Orders.Fills;
using QuantConnect.Securities;
namespace QuantConnect.Python
{
/// <summary>
/// Wraps a <see cref="PyObject"/> object that represents a model that simulates order fill events
/// </summary>
public class FillModelPythonWrapper : FillModel
{
private readonly dynamic _model;
/// <summary>
/// Constructor for initialising the <see cref="FillModelPythonWrapper"/> class with wrapped <see cref="PyObject"/> object
/// </summary>
/// <param name="model">Represents a model that simulates order fill events</param>
public FillModelPythonWrapper(PyObject model)
{
_model = model;
using (Py.GIL())
{
_model.SetPythonWrapper(this);
}
}
/// <summary>
/// Return an order event with the fill details
/// </summary>
/// <param name="parameters">A parameters object containing the security and order</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override Fill Fill(FillModelParameters parameters)
{
Parameters = parameters;
using (Py.GIL())
{
return (_model.Fill(parameters) as PyObject).GetAndDispose<Fill>();
}
}
/// <summary>
/// Limit Fill Model. Return an order event with the fill details.
/// </summary>
/// <param name="asset">Stock Object to use to help model limit fill</param>
/// <param name="order">Order to fill. Alter the values directly if filled.</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent LimitFill(Security asset, LimitOrder order)
{
using (Py.GIL())
{
return (_model.LimitFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Limit if Touched Fill Model. Return an order event with the fill details.
/// </summary>
/// <param name="asset">Asset we're trading this order</param>
/// <param name="order"><see cref="LimitIfTouchedOrder"/> Order to Check, return filled if true</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent LimitIfTouchedFill(Security asset, LimitIfTouchedOrder order)
{
using (Py.GIL())
{
return (_model.LimitIfTouchedFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Model the slippage on a market order: fixed percentage of order price
/// </summary>
/// <param name="asset">Asset we're trading this order</param>
/// <param name="order">Order to update</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent MarketFill(Security asset, MarketOrder order)
{
using (Py.GIL())
{
return (_model.MarketFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Market on Close Fill Model. Return an order event with the fill details
/// </summary>
/// <param name="asset">Asset we're trading with this order</param>
/// <param name="order">Order to be filled</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent MarketOnCloseFill(Security asset, MarketOnCloseOrder order)
{
using (Py.GIL())
{
return (_model.MarketOnCloseFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Market on Open Fill Model. Return an order event with the fill details
/// </summary>
/// <param name="asset">Asset we're trading with this order</param>
/// <param name="order">Order to be filled</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent MarketOnOpenFill(Security asset, MarketOnOpenOrder order)
{
using (Py.GIL())
{
return (_model.MarketOnOpenFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Stop Limit Fill Model. Return an order event with the fill details.
/// </summary>
/// <param name="asset">Asset we're trading this order</param>
/// <param name="order">Stop Limit Order to Check, return filled if true</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent StopLimitFill(Security asset, StopLimitOrder order)
{
using (Py.GIL())
{
return (_model.StopLimitFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Stop Market Fill Model. Return an order event with the fill details.
/// </summary>
/// <param name="asset">Asset we're trading this order</param>
/// <param name="order">Stop Order to Check, return filled if true</param>
/// <returns>Order fill information detailing the average price and quantity filled.</returns>
public override OrderEvent StopMarketFill(Security asset, StopMarketOrder order)
{
using (Py.GIL())
{
return (_model.StopMarketFill(asset, order) as PyObject).GetAndDispose<OrderEvent>();
}
}
/// <summary>
/// Get the minimum and maximum price for this security in the last bar:
/// </summary>
/// <param name="asset">Security asset we're checking</param>
/// <param name="direction">The order direction, decides whether to pick bid or ask</param>
protected override Prices GetPrices(Security asset, OrderDirection direction)
{
using (Py.GIL())
{
return (_model.GetPrices(asset, direction) as PyObject).GetAndDispose<Prices>();
}
}
/// <summary>
/// Get the minimum and maximum price for this security in the last bar:
/// </summary>
/// <param name="asset">Security asset we're checking</param>
/// <param name="direction">The order direction, decides whether to pick bid or ask</param>
/// <remarks>This method was implemented temporarily to help the refactoring of fill models (GH #4567)</remarks>
internal Prices GetPricesInternal(Security asset, OrderDirection direction)
{
return GetPrices(asset, direction);
}
}
}