Examples/Transactions.py - master - ichechet/AlorPy

Examples/Transactions.py
122 строки8 KB
cia76
price_to_alor_price
10 дек 2025, 15:43
10 дек 2025, 15:43ca8472f
import logging  # Выводим лог на консоль и в файл
from datetime import datetime  # Дата и время
from time import sleep  # Задержка в секундах перед выполнением операций

from AlorPy import AlorPy  # Работа с Alor OpenAPI V2


def _on_order(order): logger.info(f'Заявка - {order["data"]}')


def _on_stop_order(stop_order): logger.info(f'Стоп заявка - {stop_order["data"]}')


def _on_position(position): logger.info(f'Позиция - {position["data"]}')


def _on_trade(trade): logger.info(f'Сделка - {trade["data"]}')


if __name__ == '__main__':  # Точка входа при запуске этого скрипта
    logger = logging.getLogger('AlorPy.Transactions')  # Будем вести лог
    ap_provider = AlorPy()  # Подключаемся ко всем торговым счетам
    ap_provider.on_error = lambda error: logger.error(error)  # Будем выводить ошибки торговли

    logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',  # Формат сообщения
                        datefmt='%d.%m.%Y %H:%M:%S',  # Формат даты
                        level=logging.DEBUG,  # Уровень логируемых событий NOTSET/DEBUG/INFO/WARNING/ERROR/CRITICAL
                        handlers=[logging.FileHandler('Transactions.log', encoding='utf-8'), logging.StreamHandler()])  # Лог записываем в файл и выводим на консоль
    logging.Formatter.converter = lambda *args: datetime.now(tz=ap_provider.tz_msk).timetuple()  # В логе время указываем по МСК
    logging.getLogger('urllib3').setLevel(logging.CRITICAL + 1)  # Не пропускать в лог
    logging.getLogger('websockets').setLevel(logging.CRITICAL + 1)  # события в этих библиотеках

    dataname = 'TQBR.SBER'  # Тикер

    alor_board, symbol = ap_provider.dataname_to_alor_board_symbol(dataname)  # Код режима торгов Алора и код и тикер
    exchange = ap_provider.get_exchange(alor_board, symbol)  # Код биржи
    portfolio = ap_provider.get_account(alor_board)['portfolio']  # Название портфеля по коду режима торгов

    quotes = ap_provider.get_quotes(f'{exchange}:{symbol}')[0]  # Последнюю котировку получаем через запрос
    last_price = quotes['last_price']  # Последняя цена сделки
    logger.info(f'Последняя цена сделки {dataname}: {last_price}')

    ap_provider.on_order.subscribe(_on_order)  # Подписываемся на заявки
    ap_provider.on_stop_order.subscribe(_on_stop_order)  # Подписываемся на стоп заявки
    ap_provider.on_position.subscribe(_on_position)  # Подписываемся на позиции
    ap_provider.on_trade.subscribe(_on_trade)  # Подписываемся на сделки

    # Создание подписок
    orders_guid = ap_provider.orders_get_and_subscribe_v2(portfolio, exchange)  # Подписка на заявки
    logger.info(f'Подписка на заявки {orders_guid} создана')
    stop_orders_guid = ap_provider.stop_orders_get_and_subscribe_v2(portfolio, exchange)  # Подписка на стоп заявки
    logger.info(f'Подписка на стоп заявки {stop_orders_guid} создана')
    positions_guid = ap_provider.positions_get_and_subscribe_v2(portfolio, exchange)  # Подписка на позиции
    logger.info(f'Подписка на позиции {positions_guid} создана')
    trades_guid = ap_provider.trades_get_and_subscribe_v2(portfolio, exchange)  # Подписка на сделки
    logger.info(f'Подписка на сделки {trades_guid} создана')

    sleep(10)  # Ждем 10 секунд

    # Новая рыночная заявка (открытие позиции)
    # logger.info(f'Заявка {exchange}.{symbol} на покупку минимального лота по рыночной цене')
    # response = ap_provider.create_market_order(portfolio, exchange, symbol, 'buy', 1)
    # logger.debug(response)
    # logger.info(f'Номер заявки: {response["orderNumber"]}')
    #
    # sleep(10)  # Ждем 10 секунд

    # Новая рыночная заявка (закрытие позиции)
    # logger.info(f'Заявка {exchange}.{symbol} на продажу минимального лота по рыночной цене')
    # response = ap_provider.create_market_order(portfolio, exchange, symbol, 'sell', 1)
    # logger.debug(response)
    # logger.info(f'Номер заявки: {response["orderNumber"]}')
    #
    # sleep(10)  # Ждем 10 секунд

    # Новая лимитная заявка
    limit_price = ap_provider.price_to_alor_price(exchange, symbol, last_price * 0.99)  # Лимитная цена на 1% ниже последней цены сделки
    logger.info(f'Заявка {exchange}.{symbol} на покупку минимального лота по лимитной цене {limit_price}')
    response = ap_provider.create_limit_order(portfolio, exchange, symbol, 'buy', 1, limit_price)
    logger.debug(response)
    order_id = response['orderNumber']  # Номер заявки
    logger.info(f'Номер заявки: {order_id}')

    sleep(10)  # Ждем 10 секунд

    # Удаление существующей лимитной заявки
    logger.info(f'Удаление заявки: {order_id}')
    response = ap_provider.delete_order(portfolio, exchange, order_id, False)
    logger.info(f'Статус: {response}')

    sleep(10)  # Ждем 10 секунд

    # Новая стоп заявка
    stop_price = ap_provider.price_to_alor_price(exchange, symbol, last_price * 1.01)  # Стоп цена на 1% выше последней цены сделки
    logger.info(f'Заявка {exchange}.{symbol} на покупку минимального лота по стоп цене {stop_price}')
    response = ap_provider.create_stop_order(portfolio, exchange, symbol, 'buy', 1, stop_price, alor_board, 'MoreOrEqual')
    logger.debug(response)
    order_id = response['orderNumber']  # Номер заявки
    logger.info(f'Номер заявки: {order_id}')

    sleep(10)  # Ждем 10 секунд

    # Удаление существующей стоп заявки
    logger.info(f'Удаление стоп заявки: {order_id}')
    response = ap_provider.delete_order(portfolio, exchange, order_id, True)
    logger.info(f'Статус: {response}')

    sleep(10)  # Ждем 10 секунд

    # Отмена подписок
    logger.info(f'Подписка на заявки {ap_provider.unsubscribe(orders_guid)} отменена')
    logger.info(f'Подписка на стоп заявки {ap_provider.unsubscribe(stop_orders_guid)} отменена')
    logger.info(f'Подписка на позиции {ap_provider.unsubscribe(positions_guid)} отменена')
    logger.info(f'Подписка на сделки {ap_provider.unsubscribe(trades_guid)} отменена')

    ap_provider.on_order.unsubscribe(_on_order)  # Отменяем подписку на заявки
    ap_provider.on_stop_order.unsubscribe(_on_stop_order)  # Отменяем подписку на стоп заявки
    ap_provider.on_position.unsubscribe(_on_position)  # Отменяем подписку на позиции
    ap_provider.on_trade.unsubscribe(_on_trade)  # Отменяем подписку на сделки

    # Выход
    ap_provider.close_web_socket()  # Перед выходом закрываем соединение с WebSocket