630 lines
44 KiB
Python
630 lines
44 KiB
Python
import socket # Обращаться к LUA скриптам QuikSharp будем через соединения
|
||
import threading # Результат работы функций обратного вызова будем получать в отдельном потоке
|
||
import json # Передавать и принимать данные в QUIK будем через JSON
|
||
|
||
|
||
class Singleton(type):
|
||
"""Метакласс для создания Singleton классов"""
|
||
def __init__(cls, *args, **kwargs):
|
||
"""Инициализация класса"""
|
||
super(Singleton, cls).__init__(*args, **kwargs)
|
||
cls._singleton = None # Экземпляра класса еще нет
|
||
|
||
def __call__(cls, *args, **kwargs):
|
||
"""Вызов класса"""
|
||
if cls._singleton is None: # Если класса нет в экземплярах класса
|
||
cls._singleton = super(Singleton, cls).__call__(*args, **kwargs)
|
||
return cls._singleton # Возвращаем экземпляр класса
|
||
|
||
|
||
class QuikPy(metaclass=Singleton): # Singleton класс
|
||
"""Работа с Quik из Python через LUA скрипты QuikSharp https://github.com/finsight/QUIKSharp/tree/master/src/QuikSharp/lua
|
||
На основе Документации по языку LUA в QUIK из https://arqatech.com/ru/support/files/
|
||
"""
|
||
bufferSize = 1048576 # Размер буфера приема в байтах (1 МБайт)
|
||
socketRequests = None # Соединение для запросов
|
||
callbackThread = None # Поток обработки функций обратного вызова
|
||
|
||
def DefaultHandler(self, data):
|
||
"""Пустой обработчик события по умолчанию. Его можно заменить на пользовательский"""
|
||
pass
|
||
|
||
def CallbackHandler(self):
|
||
"""Поток обработки результатов функций обратного вызова"""
|
||
socketCallbacks = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # Соединение для функций обратного вызова
|
||
socketCallbacks.connect((self.Host, self.CallbacksPort)) # Открываем соединение для функций обратного вызова
|
||
currentThread = threading.currentThread() # Получаем текущий поток
|
||
fragments = [] # Будем получать ответ в виде списка фрагментов. Они могут быть разной длины. Ответ может состоять из нескольких фрагментов
|
||
while getattr(currentThread, 'process', True): # Пока поток нужен
|
||
while True: # Пока есть что-то в буфере ответов
|
||
try:
|
||
fragment = socketCallbacks.recv(self.bufferSize) # Читаем фрагмент из буфера
|
||
except TimeoutError:
|
||
print("Истёк таймаут чтения из буфера")
|
||
except ConnectionResetError:
|
||
print("Соединение сброшено")
|
||
else:
|
||
fragments.append(fragment.decode('cp1251')) # Переводим фрагмент в Windows кодировку 1251, добавляем в список
|
||
if len(fragment) < self.bufferSize: # Если в принятом фрагменте данных меньше чем размер буфера
|
||
break # то, возможно, это был последний фрагмент, выходим из чтения буфера
|
||
data = ''.join(fragments) # Собираем список фрагментов в строку
|
||
dataList = data.split('\n') # Одновременно могут прийти несколько функций обратного вызова, разбираем их по одной
|
||
fragments = [] # Сбрасываем фрагменты. Если последнюю строку не сможем разобрать, то занесем ее сюда
|
||
for data in dataList: # Пробегаемся по всем функциям обратного вызова
|
||
if data == '': # Если функция обратного вызова пустая
|
||
continue # то ее не разбираем, переходим на следующую функцию, дальше не продолжаем
|
||
try: # Пробуем разобрать функцию обратного вызова
|
||
data = json.loads(data) # Возвращаем полученный ответ в формате JSON
|
||
except json.decoder.JSONDecodeError: # Если разобрать не смогли (пришла не вся строка)
|
||
fragments.append(data) # то, что не разобрали ставим в список фрагментов
|
||
break # т.к. неполной может быть только последняя строка, то выходим из разбора функций обратного выходва
|
||
|
||
# Разбираем функцию обратного вызова QUIK LUA
|
||
if data['cmd'] == 'OnFirm': # 1. Новая фирма
|
||
self.OnFirm(data)
|
||
elif data['cmd'] == 'OnAllTrade': # 2. Получение обезличенной сделки
|
||
self.OnAllTrade(data)
|
||
elif data['cmd'] == 'OnTrade': # 3. Получение новой / изменение существующей сделки
|
||
self.OnTrade(data)
|
||
elif data['cmd'] == 'OnOrder': # 4. Получение новой / изменение существующей заявки
|
||
self.OnOrder(data)
|
||
elif data['cmd'] == 'OnAccountBalance': # 5. Изменение позиций по счету
|
||
self.OnAccountBalance(data)
|
||
elif data['cmd'] == 'OnFuturesLimitChange': # 6. Изменение ограничений по срочному рынку
|
||
self.OnFuturesLimitChange(data)
|
||
elif data['cmd'] == 'OnFuturesLimitDelete': # 7. Удаление ограничений по срочному рынку
|
||
self.OnFuturesLimitDelete(data)
|
||
elif data['cmd'] == 'OnFuturesClientHolding': # 8. Изменение позиции по срочному рынку
|
||
self.OnFuturesClientHolding(data)
|
||
elif data['cmd'] == 'OnMoneyLimit': # 9. Изменение денежной позиции
|
||
self.OnMoneyLimit(data)
|
||
elif data['cmd'] == 'OnMoneyLimitDelete': # 10. Удаление денежной позиции
|
||
self.OnMoneyLimitDelete(data)
|
||
elif data['cmd'] == 'OnDepoLimit': # 11. Изменение позиций по инструментам
|
||
self.OnDepoLimit(data)
|
||
elif data['cmd'] == 'OnDepoLimitDelete': # 12. Удаление позиции по инструментам
|
||
self.OnDepoLimitDelete(data)
|
||
elif data['cmd'] == 'OnAccountPosition': # 13. Изменение денежных средств
|
||
self.OnAccountPosition(data)
|
||
# OnNegDeal - 14. Получение новой / изменение существующей внебиржевой заявки
|
||
# OnNegTrade - 15. Получение новой / изменение существующей сделки для исполнения
|
||
elif data['cmd'] == 'OnStopOrder': # 16. Получение новой / изменение существующей стоп-заявки
|
||
self.OnStopOrder(data)
|
||
elif data['cmd'] == 'OnTransReply': # 17. Ответ на транзакцию пользователя
|
||
self.OnTransReply(data)
|
||
elif data['cmd'] == 'OnParam': # 18. Изменение текущих параметров
|
||
self.OnParam(data)
|
||
elif data['cmd'] == 'OnQuote': # 19. Изменение стакана котировок
|
||
self.OnQuote(data)
|
||
elif data['cmd'] == 'OnDisconnected': # 20. Отключение терминала от сервера QUIK
|
||
self.OnDisconnected(data)
|
||
elif data['cmd'] == 'OnConnected': # 21. Соединение терминала с сервером QUIK
|
||
self.OnConnected(data)
|
||
# OnCleanUp - 22. Смена сервера QUIK / Пользователя / Сессии
|
||
elif data['cmd'] == 'OnClose': # 23. Закрытие терминала QUIK
|
||
self.OnClose(data)
|
||
elif data['cmd'] == 'OnStop': # 24. Остановка LUA скрипта в терминале QUIK / закрытие терминала QUIK
|
||
self.OnStop(data)
|
||
elif data['cmd'] == 'OnInit': # 25. Запуск LUA скрипта в терминале QUIK
|
||
self.OnInit(data)
|
||
# Разбираем функции обратного вызова QuikSharp
|
||
elif data['cmd'] == 'NewCandle': # Получение новой свечки
|
||
self.OnNewCandle(data)
|
||
elif data['cmd'] == 'OnError': # Получено сообщение об ошибке
|
||
self.OnError(data)
|
||
socketCallbacks.close() # Закрываем соединение для ответов
|
||
|
||
def ProcessRequest(self, Request):
|
||
"""Отправляем запрос в QUIK, получаем ответ из QUIK"""
|
||
rawData = json.dumps(Request) # Переводим запрос в формат JSON
|
||
# self.socketRequests.settimeout(1)
|
||
# print(self.socketRequests.timeout)
|
||
# self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK
|
||
try:
|
||
self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK
|
||
except Exception:
|
||
# raise TimeoutError("Истёк таймаут подключения к QUIK")
|
||
print("Истёк таймаут подключения к QUIK")
|
||
data = {"data": "error"}
|
||
return data
|
||
fragments = [] # Гораздо быстрее получать ответ в виде списка фрагментов
|
||
|
||
while True: # Пока фрагменты есть в буфере
|
||
# print(fragments)
|
||
try:
|
||
fragment = self.socketRequests.recv(self.bufferSize) # Читаем фрагмент из буфера
|
||
assert len(fragment) > 0
|
||
except (TimeoutError, AssertionError):
|
||
print("Истёк таймаут подключения к QUIK")
|
||
data = {"data": "error"}
|
||
return data
|
||
except ConnectionResetError:
|
||
print("Соединение сброшено")
|
||
data = {"data": "error"}
|
||
return data
|
||
|
||
fragments.append(fragment.decode('cp1251')) # Переводим фрагмент в Windows кодировку 1251, добавляем в список
|
||
if len(fragment) < self.bufferSize: # Если в принятом фрагменте данных меньше чем размер буфера
|
||
data = ''.join(fragments) # Собираем список фрагментов в строку
|
||
try: # Бывает ситуация, когда данных приходит меньше, но это еще не конец данных
|
||
return json.loads(data) # Попробуем вернуть ответ в формате JSON в Windows кодировке 1251
|
||
except json.decoder.JSONDecodeError: # Если это еще не конец данных
|
||
pass # то ждем фрагментов в буфере дальше
|
||
|
||
# Инициализация и вход
|
||
|
||
def __init__(self, Host='127.0.0.1', RequestsPort=34130, CallbacksPort=34131, connection_timeout=None):
|
||
"""Инициализация"""
|
||
# 2.2. Функции обратного вызова
|
||
self.OnFirm = self.DefaultHandler # 1. Новая фирма
|
||
self.OnAllTrade = self.DefaultHandler # 2. Получение обезличенной сделки
|
||
self.OnTrade = self.DefaultHandler # 3. Получение новой / изменение существующей сделки
|
||
self.OnOrder = self.DefaultHandler # 4. Получение новой / изменение существующей заявки
|
||
self.OnAccountBalance = self.DefaultHandler # 5. Изменение позиций
|
||
self.OnFuturesLimitChange = self.DefaultHandler # 6. Изменение ограничений по срочному рынку
|
||
self.OnFuturesLimitDelete = self.DefaultHandler # 7. Удаление ограничений по срочному рынку
|
||
self.OnFuturesClientHolding = self.DefaultHandler # 8. Изменение позиции по срочному рынку
|
||
self.OnMoneyLimit = self.DefaultHandler # 9. Изменение денежной позиции
|
||
self.OnMoneyLimitDelete = self.DefaultHandler # 10. Удаление денежной позиции
|
||
self.OnDepoLimit = self.DefaultHandler # 11. Изменение позиций по инструментам
|
||
self.OnDepoLimitDelete = self.DefaultHandler # 12. Удаление позиции по инструментам
|
||
self.OnAccountPosition = self.DefaultHandler # 13. Изменение денежных средств
|
||
# OnNegDeal - 14. Получение новой / изменение существующей внебиржевой заявки
|
||
# OnNegTrade - 15. Получение новой / изменение существующей сделки для исполнения
|
||
self.OnStopOrder = self.DefaultHandler # 16. Получение новой / изменение существующей стоп-заявки
|
||
self.OnTransReply = self.DefaultHandler # 17. Ответ на транзакцию пользователя
|
||
self.OnParam = self.DefaultHandler # 18. Изменение текущих параметров
|
||
self.OnQuote = self.DefaultHandler # 19. Изменение стакана котировок
|
||
self.OnDisconnected = self.DefaultHandler # 20. Отключение терминала от сервера QUIK
|
||
self.OnConnected = self.DefaultHandler # 21. Соединение терминала с сервером QUIK
|
||
# OnCleanUp - 22. Смена сервера QUIK / Пользователя / Сессии
|
||
self.OnClose = self.DefaultHandler # 23. Закрытие терминала QUIK
|
||
self.OnStop = self.DefaultHandler # 24. Остановка LUA скрипта в терминале QUIK / закрытие терминала QUIK
|
||
self.OnInit = self.DefaultHandler # 25. Запуск LUA скрипта в терминале QUIK
|
||
|
||
# Функции обратного вызова QuikSharp
|
||
self.OnNewCandle = self.DefaultHandler # Получение новой свечки
|
||
self.OnError = self.DefaultHandler # Получено сообщение об ошибке
|
||
|
||
self.Host = Host # IP адрес или название хоста
|
||
self.RequestsPort = RequestsPort # Порт для отправки запросов и получения ответов
|
||
self.CallbacksPort = CallbacksPort # Порт для функций обратного вызова
|
||
self.socketRequests = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # Создаем соединение для запросов
|
||
if connection_timeout is not None:
|
||
self.socketRequests.settimeout(connection_timeout)
|
||
self.callbackThread = threading.Thread(target=self.CallbackHandler,
|
||
name='CallbackThread') # Создаем поток обработки функций обратного вызова
|
||
|
||
try:
|
||
self.socketRequests.connect((self.Host, self.RequestsPort)) # Открываем соединение для запросов
|
||
except TimeoutError:
|
||
raise ConnectionError("Истёк таймаут подключения к QUIK")
|
||
else:
|
||
self.callbackThread.start() # Запускаем поток
|
||
|
||
|
||
def __enter__(self):
|
||
"""Вход в класс, например, с with"""
|
||
return self
|
||
|
||
# Фукнции связи с QuikSharp
|
||
|
||
def Ping(self, TransId=0):
|
||
"""Проверка соединения. Отправка ping. Получение pong"""
|
||
return self.ProcessRequest({'data': 'Ping', 'id': TransId, 'cmd': 'ping', 't': ''})
|
||
|
||
def Echo(self, Message, TransId=0):
|
||
"""Эхо. Отправка и получение одного и того же сообщения"""
|
||
return self.ProcessRequest({'data': Message, 'id': TransId, 'cmd': 'echo', 't': ''})
|
||
|
||
def DivideStringByZero(self, TransId=0):
|
||
"""Тест обработки ошибок. Выполняется деление на 0 с выдачей ошибки"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'divide_string_by_zero', 't': ''})
|
||
|
||
def IsQuik(self, TransId=0):
|
||
"""Скрипт запущен в Квике"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'is_quik', 't': ''})
|
||
|
||
# 2.1 Сервисные функции
|
||
|
||
def IsConnected(self, TransId=0): # 1
|
||
"""Состояние подключения терминала к серверу QUIK. Возвращает 1 - подключено / 0 - не подключено"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'isConnected', 't': ''})
|
||
|
||
def GetScriptPath(self, TransId=0): # 2
|
||
"""Путь скрипта без завершающего обратного слэша"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getScriptPath', 't': ''})
|
||
|
||
def GetInfoParam(self, Params, TransId=0): # 3
|
||
"""Значения параметров информационного окна"""
|
||
return self.ProcessRequest({'data': Params, 'id': TransId, 'cmd': 'getInfoParam', 't': ''})
|
||
|
||
# message - 4. Сообщение в терминале QUIK. Реализовано в виде 3-х отдельных функций в QuikSharp
|
||
|
||
def Sleep(self, Time, TransId=0): # 5
|
||
"""Приостановка скрипта. Время в миллисекундах"""
|
||
return self.ProcessRequest({'data': Time, 'id': TransId, 'cmd': 'sleep', 't': ''})
|
||
|
||
def GetWorkingFolder(self, TransId=0): # 6
|
||
"""Путь к info.exe, исполняющего скрипт без завершающего обратного слэша"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getWorkingFolder', 't': ''})
|
||
|
||
def PrintDbgStr(self, Message, TransId=0): # 7
|
||
"""Вывод отладочной информации. Можно посмотреть с помощью DebugView"""
|
||
return self.ProcessRequest({'data': Message, 'id': TransId, 'cmd': 'PrintDbgStr', 't': ''})
|
||
|
||
# sysdate - 8. Системные дата и время
|
||
# isDarkTheme - 9. Тема оформления. true - тёмная, false - светлая
|
||
|
||
# Сервисные функции QuikSharp
|
||
|
||
def MessageInfo(self, Message, TransId=0): # В QUIK LUA message icon_type=1
|
||
"""Отправка информационного сообщения в терминал QUIK"""
|
||
return self.ProcessRequest({'data': Message, 'id': TransId, 'cmd': 'message', 't': ''})
|
||
|
||
def MessageWarning(self, Message, TransId=0): # В QUIK LUA message icon_type=2
|
||
"""Отправка сообщения с предупреждением в терминал QUIK"""
|
||
return self.ProcessRequest({'data': Message, 'id': TransId, 'cmd': 'warning_message', 't': ''})
|
||
|
||
def MessageError(self, Message, TransId=0): # В QUIK LUA message icon_type=3
|
||
"""Отправка сообщения об ошибке в терминал QUIK"""
|
||
return self.ProcessRequest({'data': Message, 'id': TransId, 'cmd': 'error_message', 't': ''})
|
||
|
||
# 3.1. Функции для обращения к строкам произвольных таблиц
|
||
|
||
# getItem - 1. Строка таблицы
|
||
# getOrderByNumber - 2. Заявка
|
||
# getNumberOf - 3. Кол-во записей в таблице
|
||
# SearchItems - 4. Быстрый поиск по таблице заданной функцией поиска
|
||
|
||
# Функции для обращения к строкам произвольных таблиц QuikSharp
|
||
|
||
def GetTradeAccounts(self, TransId=0):
|
||
"""Торговые счета, у которых указаны поддерживаемые классы инструментов"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getTradeAccounts', 't': ''})
|
||
|
||
def GetTradeAccount(self, ClassCode, TransId=0):
|
||
"""Торговый счет для запрашиваемого кода класса"""
|
||
return self.ProcessRequest({'data': ClassCode, 'id': TransId, 'cmd': 'getTradeAccount', 't': ''})
|
||
|
||
def GetAllOrders(self, TransId=0):
|
||
"""Таблица заявок (вся)"""
|
||
return self.ProcessRequest({'data': f'', 'id': TransId, 'cmd': 'get_orders', 't': ''})
|
||
|
||
def GetOrders(self, ClassCode, SecCode, TransId=0):
|
||
"""Таблица заявок (по инструменту)"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'get_orders', 't': ''})
|
||
|
||
def GetOrderByNumber(self, OrderId, TransId=0):
|
||
"""Заявка по номеру"""
|
||
return self.ProcessRequest({'data': OrderId, 'id': TransId, 'cmd': 'getOrder_by_Number', 't': ''})
|
||
|
||
def GetOrderById(self, ClassCode, SecCode, OrderTransId, TransId=0):
|
||
"""Заявка по инструменту и Id транзакции"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{OrderTransId}', 'id': TransId, 'cmd': 'getOrder_by_ID', 't': ''})
|
||
|
||
def GetOrderByClassNumber(self, ClassCode, OrderId, TransId=0):
|
||
"""Заявка по классу инструмента и номеру"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{OrderId}', 'id': TransId, 'cmd': 'getOrder_by_Number', 't': ''})
|
||
|
||
def GetMoneyLimits(self, TransId=0):
|
||
"""Все денежные лимиты"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getMoneyLimits', 't': ''})
|
||
|
||
def GetClientCode(self, TransId=0):
|
||
"""Основной (первый) код клиента"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getClientCode', 't': ''})
|
||
|
||
def GetClientCodes(self, TransId=0):
|
||
"""Все коды клиента"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getClientCode', 't': ''})
|
||
|
||
def GetAllDepoLimits(self, TransId=0):
|
||
"""Лимиты по бумагам (всем)"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'get_depo_limits', 't': ''})
|
||
|
||
def GetDepoLimits(self, SecCode, TransId=0):
|
||
"""Лимиты по бумагам (по инструменту)"""
|
||
return self.ProcessRequest({'data': SecCode, 'id': TransId, 'cmd': 'get_depo_limits', 't': ''})
|
||
|
||
def GetAllTrades(self, TransId=0):
|
||
"""Таблица сделок (вся)"""
|
||
return self.ProcessRequest({'data': f'', 'id': TransId, 'cmd': 'get_trades', 't': ''})
|
||
|
||
def GetTrades(self, ClassCode, SecCode, TransId=0):
|
||
"""Таблица сделок (по инструменту)"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'get_trades', 't': ''})
|
||
|
||
def GetTradesByOrderNumber(self, OrderNum, TransId=0):
|
||
"""Таблица сделок по номеру заявки"""
|
||
return self.ProcessRequest({'data': OrderNum, 'id': TransId, 'cmd': 'get_Trades_by_OrderNumber', 't': ''})
|
||
|
||
def GetAllStopOrders(self, TransId=0):
|
||
"""Стоп заявки (все)"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'get_stop_orders', 't': ''})
|
||
|
||
def GetStopOrders(self, ClassCode, SecCode, TransId=0):
|
||
"""Стоп заявки (по инструменту)"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'get_stop_orders', 't': ''})
|
||
|
||
def GetAllTrade(self, TransId=0):
|
||
"""Таблица обезличенных сделок (вся)"""
|
||
return self.ProcessRequest({'data': f'', 'id': TransId, 'cmd': 'get_all_trades', 't': ''})
|
||
|
||
def GetTrade(self, ClassCode, SecCode, TransId=0):
|
||
"""Таблица обезличенных сделок (по инструменту)"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'get_all_trades', 't': ''})
|
||
|
||
# 3.2 Функции для обращения к спискам доступных параметров
|
||
|
||
def GetClassesList(self, TransId=0): # 1
|
||
"""Список классов"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getClassesList', 't': ''})
|
||
|
||
def GetClassInfo(self, ClassCode, TransId=0): # 2
|
||
"""Информация о классе"""
|
||
return self.ProcessRequest({'data': ClassCode, 'id': TransId, 'cmd': 'getClassInfo', 't': ''})
|
||
|
||
def GetClassSecurities(self, ClassCode, TransId=0): # 3
|
||
"""Список инструментов класса"""
|
||
return self.ProcessRequest({'data': ClassCode, 'id': TransId, 'cmd': 'getClassSecurities', 't': ''})
|
||
|
||
# Функции для обращения к спискам доступных параметров QuikSharp
|
||
|
||
def GetOptionBoard(self, ClassCode, SecCode, TransId=0):
|
||
"""Доска опционов"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'getOptionBoard', 't': ''})
|
||
|
||
# 3.3 Функции для получения информации по денежным средствам
|
||
|
||
def GetMoney(self, ClientCode, FirmId, Tag, CurrCode, TransId=0): # 1
|
||
"""Денежные позиции"""
|
||
return self.ProcessRequest({'data': f'{ClientCode}|{FirmId}|{Tag}|{CurrCode}', 'id': TransId, 'cmd': 'getMoney', 't': ''})
|
||
|
||
def GetMoneyEx(self, FirmId, ClientCode, Tag, CurrCode, LimitKind, TransId=0): # 2
|
||
"""Денежные позиции указанного типа"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{ClientCode}|{Tag}|{CurrCode}|{LimitKind}', 'id': TransId, 'cmd': 'getMoneyEx', 't': ''})
|
||
|
||
# 3.4 Функции для получения позиций по инструментам
|
||
|
||
def GetDepo(self, ClientCode, FirmId, SecCode, Account, TransId=0): # 1
|
||
"""Позиции по инструментам"""
|
||
return self.ProcessRequest({'data': f'{ClientCode}|{FirmId}|{SecCode}|{Account}', 'id': TransId, 'cmd': 'getDepo', 't': ''})
|
||
|
||
def GetDepoEx(self, FirmId, ClientCode, SecCode, Account, LimitKind, TransId=0): # 2
|
||
"""Позиции по инструментам указанного типа"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{ClientCode}|{SecCode}|{Account}|{LimitKind}', 'id': TransId, 'cmd': 'getDepoEx', 't': ''})
|
||
|
||
# 3.5 Функция для получения информации по фьючерсным лимитам
|
||
|
||
def GetFuturesLimit(self, FirmId, AccountId, LimitType, CurrCode, TransId=0): # 1
|
||
"""Фьючерсные лимиты"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{AccountId}|{LimitType}|{CurrCode}', 'id': TransId, 'cmd': 'getFuturesLimit', 't': ''})
|
||
|
||
# Функция для получения информации по фьючерсным лимитам QuikSharp
|
||
|
||
def GetFuturesClientLimits(self, TransId=0):
|
||
"""Все фьючерсные лимиты"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getFuturesClientLimits', 't': ''})
|
||
|
||
# 3.6 Функция для получения информации по фьючерсным позициям
|
||
|
||
def GetFuturesHolding(self, FirmId, AccountId, SecCode, PositionType, TransId=0): # 1
|
||
"""Фьючерсные позиции"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{AccountId}|{SecCode}|{PositionType}', 'id': TransId, 'cmd': 'getFuturesHolding', 't': ''})
|
||
|
||
# Функция для получения информации по фьючерсным позициям QuikSharp
|
||
|
||
def GetFuturesHoldings(self, TransId=0):
|
||
"""Все фьючерсные позиции"""
|
||
return self.ProcessRequest({'data': '', 'id': TransId, 'cmd': 'getFuturesHolding', 't': ''})
|
||
|
||
# 3.7 Функция для получения информации по инструменту
|
||
|
||
def GetSecurityInfo(self, ClassCode, SecCode, TransId=0): # 1
|
||
"""Информация по инструменту"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'getSecurityInfo', 't': ''})
|
||
|
||
# Функция для получения информации по инструменту QuikSharp
|
||
|
||
def GetSecurityInfoBulk(self, ClassCodes, SecCodes, TransId=0):
|
||
"""Информация по инструментам"""
|
||
return self.ProcessRequest({'data': f'{ClassCodes}|{SecCodes}', 'id': TransId, 'cmd': 'getSecurityInfoBulk', 't': ''})
|
||
|
||
def GetSecurityClass(self, ClassesList, SecCode, TransId=0):
|
||
"""Класс по коду инструмента из заданных классов"""
|
||
return self.ProcessRequest({'data': f'{ClassesList}|{SecCode}', 'id': TransId, 'cmd': 'getSecurityClass', 't': ''})
|
||
|
||
# 3.8 Функция для получения даты торговой сессии
|
||
|
||
# getTradeDate - 1. Дата текущей торговой сессии
|
||
|
||
# 3.9 Функция для получения стакана по указанному классу и инструменту
|
||
|
||
def GetQuoteLevel2(self, ClassCode, SecCode, TransId=0): # 1
|
||
"""Стакан по классу и инструменту"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'GetQuoteLevel2', 't': ''})
|
||
|
||
# 3.10 Функции для работы с графиками
|
||
|
||
# getLinesCount - 1. Кол-во линий в графике
|
||
|
||
def GetNumCandles(self, Tag, TransId=0): # 2
|
||
"""Кол-во свечей по тэгу"""
|
||
return self.ProcessRequest({'data': Tag, 'id': TransId, 'cmd': 'get_num_candles', 't': ''})
|
||
|
||
# getCandlesByIndex - 3. Информация о свечках (реализовано в get_candles)
|
||
# CreateDataSource - 4. Создание источника данных c функциями: (реализовано в get_candles_from_data_source)
|
||
# - SetUpdateCallback - Привязка функции обратного вызова на изменение свечи
|
||
# - O, H, L, C, V, T - Функции получения цен, объемов и времени
|
||
# - Size - Функция кол-ва свечек в источнике данных
|
||
# - Close - Функция закрытия источника данных. Терминал прекращает получать данные с сервера
|
||
# - SetEmptyCallback - Функция сброса функции обратного вызова на изменение свечи
|
||
|
||
# Функции для работы с графиками QuikSharp
|
||
|
||
def GetCandles(self, Tag, Line, FirstCandle, Count, TransId=0):
|
||
"""Свечки по идентификатору графика"""
|
||
return self.ProcessRequest({'data': f'{Tag}|{Line}|{FirstCandle}|{Count}', 'id': TransId, 'cmd': 'get_candles', 't': ''})
|
||
|
||
def GetCandlesFromDataSource(self, ClassCode, SecCode, Interval, Count): # ichechet - Добавлен выход по таймауту
|
||
"""Свечки"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{Interval}|{Count}', 'id': '1', 'cmd': 'get_candles_from_data_source', 't': ''})
|
||
|
||
def SubscribeToCandles(self, ClassCode, SecCode, Interval, TransId=0):
|
||
"""Подписка на свечки"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{Interval}', 'id': TransId, 'cmd': 'subscribe_to_candles', 't': ''})
|
||
|
||
def IsSubscribed(self, ClassCode, SecCode, Interval, TransId=0):
|
||
"""Есть ли подписка на свечки"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{Interval}', 'id': TransId, 'cmd': 'is_subscribed', 't': ''})
|
||
|
||
def UnsubscribeFromCandles(self, ClassCode, SecCode, Interval, TransId=0):
|
||
"""Отмена подписки на свечки"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{Interval}', 'id': TransId, 'cmd': 'unsubscribe_from_candles', 't': ''})
|
||
|
||
# 3.11 Функции для работы с заявками
|
||
|
||
def SendTransaction(self, Transaction, TransId=0): # 1
|
||
"""Отправка транзакции в торговую систему"""
|
||
return self.ProcessRequest({'data': Transaction, 'id': TransId, 'cmd': 'sendTransaction', 't': ''})
|
||
|
||
# CalcBuySell - 2. Максимальное кол-во лотов в заявке
|
||
|
||
# 3.12 Функции для получения значений таблицы "Текущие торги"
|
||
|
||
def GetParamEx(self, ClassCode, SecCode, ParamName, TransId=0): # 1
|
||
"""Таблица текущих торгов"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{ParamName}', 'id': TransId, 'cmd': 'getParamEx', 't': ''})
|
||
|
||
def GetParamEx2(self, ClassCode, SecCode, ParamName, TransId=0): # 2
|
||
"""Таблица текущих торгов по инструменту с возможностью отказа от получения"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{ParamName}', 'id': TransId, 'cmd': 'getParamEx2', 't': ''})
|
||
|
||
# Функция для получения значений таблицы "Текущие торги" QuikSharp
|
||
|
||
def GetParamEx2Bulk(self, ClassCodes, SecCodes, ParamNames, TransId=0):
|
||
"""Таблица текущих торгов по инструментам с возможностью отказа от получения"""
|
||
return self.ProcessRequest({'data': f'{ClassCodes}|{SecCodes}|{ParamNames}', 'id': TransId, 'cmd': 'getParamEx2Bulk', 't': ''})
|
||
|
||
# 3.13 Функции для получения параметров таблицы "Клиентский портфель"
|
||
|
||
def GetPortfolioInfo(self, FirmId, ClientCode, TransId=0): # 1
|
||
"""Клиентский портфель"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{ClientCode}', 'id': TransId, 'cmd': 'getPortfolioInfo', 't': ''})
|
||
|
||
def GetPortfolioInfoEx(self, FirmId, ClientCode, LimitKind, TransId=0): # 2
|
||
"""Клиентский портфель по сроку расчетов"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{ClientCode}|{LimitKind}', 'id': TransId, 'cmd': 'getPortfolioInfoEx', 't': ''})
|
||
|
||
# 3.14 Функции для получения параметров таблицы "Купить/Продать"
|
||
|
||
# getBuySellInfo - 1. Параметры таблицы купить/продать
|
||
# getBuySellInfoEx - 2. Параметры таблицы купить/продать с дополнительными полями вывода
|
||
|
||
# 3.15 Функции для работы с таблицами Рабочего места QUIK
|
||
|
||
# AddColumn - 1. Добавление колонки в таблицу
|
||
# AllocTable - 2. Структура, описывающая таблицу
|
||
# Clear - 3. Удаление содержимого таблицы
|
||
# CreateWindow - 4. Создание окна таблицы
|
||
# DeleteRow - 5. Удаление строки из таблицы
|
||
# DestroyTable - 6. Закрытие окна таблицы
|
||
# InsertRow - 7. Добавление строки в таблицу
|
||
# IsWindowClosed - 8. Закрыто ли окно с таблицей
|
||
# GetCell - 9. Данные ячейки таблицы
|
||
# GetTableSize - 10. Кол-во строк и столбцов таблицы
|
||
# GetWindowCaption - 11. Заголовок окна таблицы
|
||
# GetWindowRect - 12. Координаты верхнего левого и правого нижнего углов таблицы
|
||
# SetCell - 13. Установка значения ячейки таблицы
|
||
# SetWindowCaption - 14. Установка заголовка окна таблицы
|
||
# SetWindowPos - 15. Установка верхнего левого угла, и размеры таблицы
|
||
# SetTableNotificationCallback - 16. Установка функции обратного вызова для обработки событий в таблице
|
||
# RGB - 17. Преобразование каждого цвета в одно число для функци SetColor
|
||
# SetColor - 18. Установка цвета ячейки, столбца или строки таблицы
|
||
# Highlight - 19. Подсветка диапазона ячеек цветом фона и цветом текста на заданное время с плавным затуханием
|
||
# SetSelectedRow - 20. Выделение строки таблицы
|
||
|
||
# 3.16 Функции для работы с метками
|
||
|
||
def AddLabel(self, Price, CurDate, CurTime, Qty, Path, LabelId, Alignment, Background, TransId=0): # 1
|
||
"""Добавление метки на график"""
|
||
return self.ProcessRequest({'data': f'{Price}|{CurDate}|{CurTime}|{Qty}|{Path}|{LabelId}|{Alignment}|{Background}', 'id': TransId, 'cmd': 'AddLabel', 't': ''})
|
||
|
||
def DelLabel(self, ChartTag, LabelId, TransId=0): # 2
|
||
"""Удаление метки с графика"""
|
||
return self.ProcessRequest({'data': f'{ChartTag}|{LabelId}', 'id': TransId, 'cmd': 'DelLabel', 't': ''})
|
||
|
||
def DelAllLabels(self, ChartTag, TransId=0): # 3
|
||
"""Удаление всех меток с графика"""
|
||
return self.ProcessRequest({'data': ChartTag, 'id': TransId, 'cmd': 'DelAllLabels', 't': ''})
|
||
|
||
def GetLabelParams(self, ChartTag, LabelId, TransId=0): # 4
|
||
"""Получение параметров метки"""
|
||
return self.ProcessRequest({'data': f'{ChartTag}|{LabelId}', 'id': TransId, 'cmd': 'GetLabelParams', 't': ''})
|
||
|
||
# SetLabelParams - 5. Установка параметров метки
|
||
|
||
# 3.17 Функции для заказа стакана котировок
|
||
|
||
def SubscribeLevel2Quotes(self, ClassCode, SecCode, TransId=0): # 1
|
||
"""Подписка на стакан по Классу|Коду бумаги"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'Subscribe_Level_II_Quotes', 't': ''})
|
||
|
||
def UnsubscribeLevel2Quotes(self, ClassCode, SecCode, TransId=0): # 2
|
||
"""Отмена подписки на стакан по Классу|Коду бумаги"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'Unsubscribe_Level_II_Quotes', 't': ''})
|
||
|
||
def IsSubscribedLevel2Quotes(self, ClassCode, SecCode, TransId=0): # 3
|
||
"""Есть ли подписка на стакан по Классу|Коду бумаги"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}', 'id': TransId, 'cmd': 'IsSubscribed_Level_II_Quotes', 't': ''})
|
||
|
||
# 3.18 Функции для заказа параметров Таблицы текущих торгов
|
||
|
||
def ParamRequest(self, ClassCode, SecCode, ParamName, TransId=0): # 1
|
||
"""Заказ получения таблицы текущих торгов по инструменту"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{ParamName}', 'id': TransId, 'cmd': 'paramRequest', 't': ''})
|
||
|
||
def CancelParamRequest(self, ClassCode, SecCode, ParamName, TransId=0): # 2
|
||
"""Отмена заказа получения таблицы текущих торгов по инструменту"""
|
||
return self.ProcessRequest({'data': f'{ClassCode}|{SecCode}|{ParamName}', 'id': TransId, 'cmd': 'cancelParamRequest', 't': ''})
|
||
|
||
# Функции для заказа параметров Таблицы текущих торгов QuikSharp
|
||
|
||
def ParamRequestBulk(self, ClassCodes, SecCodes, ParamNames, TransId=0):
|
||
"""Заказ получения таблицы текущих торгов по инструментам"""
|
||
return self.ProcessRequest({'data': f'{ClassCodes}|{SecCodes}|{ParamNames}', 'id': TransId, 'cmd': 'paramRequestBulk', 't': ''})
|
||
|
||
def CancelParamRequestBulk(self, ClassCodes, SecCodes, ParamNames, TransId=0):
|
||
"""Отмена заказа получения таблицы текущих торгов по инструментам"""
|
||
return self.ProcessRequest({'data': f'{ClassCodes}|{SecCodes}|{ParamNames}', 'id': TransId, 'cmd': 'cancelParamRequestBulk', 't': ''})
|
||
|
||
# 3.19 Функции для получения информации по единой денежной позиции
|
||
|
||
def GetTrdAccByClientCode(self, FirmId, ClientCode, TransId=0): # 1
|
||
"""Торговый счет срочного рынка по коду клиента фондового рынка"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{ClientCode}', 'id': TransId, 'cmd': 'getTrdAccByClientCode', 't': ''})
|
||
|
||
def GetClientCodeByTrdAcc(self, FirmId, TradeAccountId, TransId=0): # 2
|
||
"""Код клиента фондового рынка с единой денежной позицией по торговому счету срочного рынка"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{TradeAccountId}', 'id': TransId, 'cmd': 'getClientCodeByTrdAcc', 't': ''})
|
||
|
||
def IsUcpClient(self, FirmId, Client, TransId=0): # 3
|
||
"""Имеет ли клиент единую денежную позицию"""
|
||
return self.ProcessRequest({'data': f'{FirmId}|{Client}', 'id': TransId, 'cmd': 'IsUcpClient', 't': ''})
|
||
|
||
# Выход и закрытие
|
||
|
||
def CloseConnectionAndThread(self):
|
||
"""Закрытие соединения для запросов и потока обработки функций обратного вызова"""
|
||
self.socketRequests.close() # Закрываем соединение для запросов
|
||
self.callbackThread.process = False # Поток обработки функций обратного вызова больше не нужен
|
||
|
||
def __exit__(self, exc_type, exc_val, exc_tb):
|
||
"""Выход из класса, например, с with"""
|
||
self.CloseConnectionAndThread() # Закрываем соединение для запросов и поток обработки функций обратного вызова
|
||
|
||
def __del__(self):
|
||
self.CloseConnectionAndThread() # Закрываем соединение для запросов и поток обработки функций обратного вызова
|
||
|