API функции для OANDA - Python

Узнай цену своей работы

Формулировка задачи:

Может будет нужно тем кто занимается разработкой торговых роботов. Если кто увидит серьезные огрехи, буду рад если поправите. Python изучаю только пол года. Специально для этой темы.
Листинг программы 
  1. #!/usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. import openpyxl
  4. import httplib
  5. import urllib
  6. import urllib2
  7. import json
  8. import datetime
  9. from datetime import datetime, timedelta, date, time
  10. import os
  11. import msvcrt
  12. import time
  13. import shutil  # копирование
  14. import ssl
  15. import requests
  16. import sys
  17. ssl._create_default_https_context = ssl._create_unverified_context  # убирает ошибку [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed (_ssl.c:590)
  18. #в”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв–’в–“в–‘в–€в•ђв–Њв–* в–ђв‰Ўв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђ
  19. url = "api-fxtrade.oanda.com"
  20. access_token = "Bearer 099935ef71b8203fxxxxxxxxxxxxxxxxdbd7b30dbdb3019d673671020752f"
  21. headers = {'Authorization': access_token, "Content-Type": "application/x-www-form-urlencoded"}
  22. accounts = []
  23. account_id = ""
  24. instrument = ""
  25. sentSMS = True
  26.  
  27. #в”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђ
  28.  
  29. print u'в–€' * 11 + '  Oanda API script started  ' + u'в–€' * 11
  30.  
  31. #в”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђ
  32. mypairs = ['AUD_HKD', 'AUD_JPY', 'AUD_USD', 'CAD_HKD', 'CAD_JPY', 'CHF_JPY', 'EUR_AUD', 'EUR_GBP', 'EUR_HKD', 'EUR_JPY',
  33.            'EUR_USD', 'GBP_AUD', 'GBP_CAD', 'GBP_CHF', 'GBP_HKD', 'GBP_JPY', 'GBP_NZD', 'GBP_USD', 'NZD_HKD', 'NZD_JPY',
  34.            'NZD_USD', 'USD_CAD', 'USD_JPY']
  35. #в”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђ
  36. data_pair = dict((x, [0] * 2) for x in mypairs)  # генерация словаря
  37. #в”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђ
  38. p_prices = {'USD': {'USD': 1.00000,
  39.                     'CAD': 0.76620,
  40.                     'CHF': 1.01360,
  41.                     'JPY': 0.93000,
  42.                     'AUD': 0.74820,
  43.                     'GBP': 1.31650,
  44.                     'NZD': 0.70230,
  45.                     'EUR': 1.10190,
  46.                     'HKD': 0.12900},
  47.             'CHF': {'CHF': 1.00000,
  48.                     'CAD': 0.76090,
  49.                     'USD': 0.98230,
  50.                     'JPY': 0.93000,
  51.                     'AUD': 0.74980,
  52.                     'GBP': 1.31030,
  53.                     'NZD': 0.70240,
  54.                     'EUR': 1.10190,
  55.                     'HKD': 0.12710}}
  56.  
  57. #в”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђв”Ђ
  58.  
  59. def get_currency_rates(currency):
  60.     params = urllib.urlencode({'number': '1'})
  61.     headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64; rv:23.0)'}
  62.     dictfull = False
  63.     while True:
  64.         try:
  65.             print 'в•ђ' * 30
  66.             print 'GETTING CURRENCY RATES for ' + currency
  67.             print 'в•ђ' * 30
  68.             for key in sorted(p_prices[currency]):
  69.                 pairforprice = key + '-' + currency
  70.                 time.sleep(0.5)
  71.                 url = 'https://www.mataf.net/ru/currency/converter-' + pairforprice
  72.                 request = urllib2.Request(url, params, headers)
  73.                 resptext = urllib2.urlopen(request).read()
  74.                 line = resptext
  75.                 line = line.strip()
  76.                 linekurs = line.find('<title>')
  77.                 startkurs = line.find('=', linekurs)
  78.                 endkurs = line.find(')</title>', linekurs)
  79.                 kurs = float(line[startkurs + 1:endkurs])
  80.                 if 'JPY' in key:
  81.                     kurs *= 100
  82.                 kurs = "%.4f" % kurs
  83.                 print pairforprice, kurs
  84.                 p_prices[currency][key] = float(kurs)
  85.             dictfull = True
  86.         except Exception as e:
  87.             print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  88.         if dictfull:
  89.             return datetime.utcnow()
  90.         else:
  91.             print 'CURRENCY RATES DATA PROBLEM!'
  92.             time.sleep(60)
  93.  
  94. def close_position(account_id, instrument):
  95.     try:
  96.         time.sleep(0.5)
  97.         params = urllib.urlencode({'accountId': account_id})
  98.         conn = httplib.HTTPSConnection(url)
  99.         conn.request("DELETE", "/v1/accounts/" + account_id + "/positions/" + instrument, params, headers)
  100.         response = conn.getresponse()
  101.         resptext = response.read()
  102.         if response.status == 403:
  103.             print instrument + ' position not closed'
  104.         elif response.status == 200:
  105.             print instrument + ' position closed'
  106.         return response.status
  107.     except Exception as e:
  108.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  109.  
  110. def get_position(account_id, instrument):
  111.     try:
  112.         time.sleep(1)
  113.         params = urllib.urlencode({})
  114.         conn = httplib.HTTPSConnection(url)
  115.         # GET /v1/accounts/:account_id/positions/:instrument
  116.         conn.request("GET", "/v1/accounts/" + account_id +
  117.                      "/positions/" + instrument, params, headers)
  118.         response = conn.getresponse()
  119.         resptext = response.read()
  120.         return resptext
  121.     except Exception as e:
  122.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  123.  
  124. def get_instrument(account_id, instrument):
  125.     try:
  126.         time.sleep(1)
  127.         params = urllib.urlencode({})
  128.         conn = httplib.HTTPSConnection(url)
  129.         conn.request("GET", "/v1/instruments?accountId=" + account_id +
  130.                      "&instruments=" + instrument +
  131.                      "&fields=instrument%2CdisplayName%2Cpip%2CmarginRate%2Chalted", params, headers)
  132.         response = conn.getresponse()
  133.         resptext = response.read()
  134.         return resptext
  135.     except Exception as e:
  136.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  137.  
  138. def get_all_instrument(account_id):
  139.     try:
  140.         time.sleep(1)
  141.         params = urllib.urlencode({})
  142.         conn = httplib.HTTPSConnection(url)
  143.         conn.request("GET", "/v1/instruments?accountId=" + account_id, params, headers)
  144.         response = conn.getresponse()
  145.         resptext = response.read()
  146.         return resptext
  147.     except Exception as e:
  148.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  149.  
  150. def get_price(instrument):
  151.     try:
  152.         time.sleep(1)
  153.         params = urllib.urlencode({})
  154.         conn = httplib.HTTPSConnection(url)
  155.         conn.request("GET", "/v1/prices?instruments=" + instrument, params, headers)
  156.         response = conn.getresponse()
  157.         resptext = response.read()
  158.         return resptext
  159.     except Exception as e:
  160.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  161.  
  162. def get_FXdata1(instrument, granularity, start, end):  # пара, таймфрейм
  163.     try:
  164.         time.sleep(1)
  165.         # start = str(date.today()) + 'T00%3A00%3A00Z'
  166.         # end = str(date.today()) + 'T03%3A00%3A00Z'
  167.         conn = httplib.HTTPSConnection(url)
  168.         conn.request("GET", "/v1/candles?instrument=" + instrument +
  169.                      "&granularity=" + granularity +
  170.                      "&candleFormat=" + 'midpoint' +
  171.                      "&dailyAlignment=" + str(0) +
  172.                      "&alignmentTimezone=" + 'UTC' +
  173.                      "&start=" + start +
  174.                      "&end=" + end)
  175.         response = conn.getresponse()
  176.         resptext = response.read()
  177.         return resptext
  178.     except Exception as e:
  179.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  180.  
  181. def get_FXdata2(instrument, granularity, count):  # пара, таймфрейм
  182.     try:
  183.         time.sleep(1)
  184.         conn = httplib.HTTPSConnection(url)
  185.         conn.request("GET", "/v1/candles?instrument=" + instrument +
  186.                      "&count=" + str(count) +
  187.                      "&granularity=" + granularity +
  188.                      "&candleFormat=" + 'midpoint' +
  189.                      "&dailyAlignment=" + str(0) +
  190.                      "&alignmentTimezone=" + 'UTC')
  191.         response = conn.getresponse()
  192.         resptext = response.read()
  193.         return resptext
  194.     except Exception as e:
  195.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  196.  
  197. def send_sms(text):
  198.     if sentSMS:
  199.         url = "http://sms.ru/sms/send?api_id=4760338A-D9xxxxxxxxxxxxxxxx2D5C&to=79205616220&from=Forex Robot&text=" + text
  200.         try:
  201.             answer = requests.get(url)
  202.             print "SMS sended"
  203.         except Exception as e:
  204.             print "SMS not sended"
  205.             print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  206.  
  207. def get_range(instrument, granularity, count):
  208.     try:
  209.         time.sleep(1)
  210.         count += 1  # для незакрытой свечи
  211.         data = get_FXdata2(instrument, granularity, count)
  212.         data = json.loads(data)
  213.         max_highMid = 0
  214.         min_lowMid = 999999
  215.         for key in data['candles']:
  216.             if max_highMid < key[u'highMid']:
  217.                 max_highMid = key[u'highMid']
  218.             if min_lowMid > key[u'lowMid']:
  219.                 min_lowMid = key[u'lowMid']
  220.         return max_highMid, min_lowMid
  221.     except Exception as e:
  222.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  223.  
  224. def get_avg_volatil(instrument, granularity, count):
  225.     try:
  226.         time.sleep(1)
  227.         count += 1  # для незакрытой свечи
  228.         data = get_FXdata2(instrument, granularity, count)
  229.         data = json.loads(data)
  230.         maxcandle = 0
  231.         mincandle = 99999
  232.         sumcandle = 0
  233.         for key in data['candles']:
  234.             if key[u'complete']:
  235.                 volatilcandle = (key[u'highMid'] - key[u'lowMid']) * 10000
  236.                 if 'JPY' in instrument:
  237.                     volatilcandle = volatilcandle / 100
  238.                 if maxcandle < volatilcandle:
  239.                     maxcandle = volatilcandle
  240.                 if mincandle > volatilcandle:
  241.                     mincandle = volatilcandle
  242.                 sumcandle += volatilcandle
  243.         if count >= 4:
  244.             avgvolatil = int(round((sumcandle - maxcandle - mincandle) / (count - 3)))
  245.         else:
  246.             avgvolatil = int(round(sumcandle / (count - 1)))
  247.         return avgvolatil
  248.     except Exception as e:
  249.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  250.  
  251. def get_today_volatil(instrument, granularity, count):
  252.     try:
  253.         time.sleep(1)
  254.         count += 1  # для незакрытой свечи
  255.         data = get_FXdata2(instrument, granularity, count)
  256.         data = json.loads(data)
  257.         max_highMid = 0
  258.         min_lowMid = 999999
  259.         max_body = 0
  260.         min_body = 999999
  261.         if 'candles' in data.keys():
  262.             for key in data['candles']:
  263.                 if max_highMid < key[u'highMid']:
  264.                     max_highMid = key[u'highMid']
  265.                 if min_lowMid > key[u'lowMid']:
  266.                     min_lowMid = key[u'lowMid']
  267.                 #===============================
  268.                 if key[u'openMid'] >= key[u'closeMid']:
  269.                     high_body = key[u'openMid']
  270.                     low_body = key[u'closeMid']
  271.                 else:
  272.                     high_body = key[u'closeMid']
  273.                     low_body = key[u'openMid']
  274.                 #=================================
  275.                 if max_body < high_body:
  276.                     max_body = high_body
  277.                 if min_body > low_body:
  278.                     min_body = low_body
  279.  
  280.             volatil_candle = (max_highMid - min_lowMid) * 10000
  281.             volatil_body = (max_body - min_body) * 10000
  282.             if 'JPY' in instrument:
  283.                 volatil_body = float(volatil_body) / 100
  284.                 volatil_candle = float(volatil_candle) / 100
  285.             hightoday = round(float(max_body + ((max_highMid - max_body)) / 2), 5)
  286.             lowtoday = round(float(min_body - ((min_body - min_lowMid)) / 2), 5)
  287.             todayvolatil = round(float((volatil_body + volatil_candle)) / 2, 1)
  288.  
  289.             return hightoday, lowtoday, todayvolatil
  290.     except Exception as e:
  291.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  292.  
  293. def get_history_instrument(account_id, instrument, count):
  294.     try:
  295.         time.sleep(1)
  296.         params = urllib.urlencode({})
  297.         conn = httplib.HTTPSConnection(url)
  298.         conn.request("GET", "/v1/accounts/" + account_id + "/transactions?instrument=" + instrument + '&count=' + str(count), params, headers)
  299.         response = conn.getresponse()
  300.         resptext = response.read()
  301.         return resptext
  302.     except Exception as e:
  303.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  304.  
  305. def get_history(account_id, count):
  306.     try:
  307.         time.sleep(1)
  308.         params = urllib.urlencode({})
  309.         conn = httplib.HTTPSConnection(url)
  310.         conn.request("GET", "/v1/accounts/" + account_id + "/transactions?count=" + str(count), params, headers)
  311.         response = conn.getresponse()
  312.         resptext = response.read()
  313.         return resptext
  314.     except Exception as e:
  315.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)

Решение задачи: «API функции для OANDA»

textual
Листинг программы 
  1. def make_order(account_id, instrument, units, side,  exp, price, takeprofit, stoploss, trailingstop, upperbound, lowerbound):
  2.     try:
  3.         time.sleep(1)
  4.         #now = datetime.now()
  5.         now = datetime.utcnow()
  6.         expire = now + timedelta(hours=exp)
  7.         expire = expire.isoformat('T') + "Z"
  8.         params = urllib.urlencode({"instrument": instrument,
  9.                                    "units": units,
  10.                                    "side": side,
  11.                                    "type": "marketIfTouched",
  12.                                    "expiry": expire,
  13.                                    "price": price,
  14.                                    "takeProfit": takeprofit,
  15.                                    "stopLoss": stoploss,
  16.                                    "trailingStop": trailingstop,
  17.                                    "upperBound": upperbound,
  18.                                    "lowerBound": lowerbound})
  19.         conn = httplib.HTTPSConnection(url)
  20.         conn.request("POST", "/v1/accounts/" + account_id + "/orders", params, headers)
  21.         response = conn.getresponse()
  22.         resptext = response.read()
  23.         return resptext
  24.     except Exception as e:
  25.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  26.  
  27.  
  28. def make_limit_order(account_id, instrument, units, side,  exp, price, takeprofit, stoploss, trailingstop):
  29.     try:
  30.         time.sleep(1)
  31.         #now = datetime.now()
  32.         now = datetime.utcnow()
  33.         expire = now + timedelta(days=exp)
  34.         expire = expire.isoformat('T') + "Z"
  35.         params = urllib.urlencode({"instrument": instrument,
  36.                                    "units": units,
  37.                                    "side": side,
  38.                                    "type": "limit",
  39.                                    "expiry": expire,
  40.                                    "price": price,
  41.                                    "takeProfit": takeprofit,
  42.                                    "stopLoss": stoploss,
  43.                                    "trailingStop": trailingstop})
  44.         conn = httplib.HTTPSConnection(url)
  45.         conn.request("POST", "/v1/accounts/" + account_id + "/orders", params, headers)
  46.         response = conn.getresponse()
  47.         resptext = response.read()
  48.         return resptext
  49.     except Exception as e:
  50.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  51.  
  52.  
  53. def del_orders(account_id, id):
  54.     try:
  55.         time.sleep(0.5)
  56.         params = urllib.urlencode({'accountId': account_id})
  57.         conn = httplib.HTTPSConnection(url)
  58.         conn.request("DELETE", "/v1/accounts/" + account_id + "/orders/" + str(id), params, headers)
  59.         response = conn.getresponse()
  60.         resptext = response.read()
  61.         if response.status == 403:
  62.             print str(id) + ' not closed'
  63.         elif response.status == 200:
  64.             print str(id) + ' closed'
  65.         return response.status
  66.     except Exception as e:
  67.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  68.  
  69.  
  70. def del_trades(account_id, id):
  71.     try:
  72.         time.sleep(0.5)
  73.         params = urllib.urlencode({'accountId': account_id})
  74.         conn = httplib.HTTPSConnection(url)
  75.         conn.request("DELETE", "/v1/accounts/" + account_id + "/trades/" + str(id), params, headers)
  76.         response = conn.getresponse()
  77.         resptext = response.read()
  78.         if response.status == 403:
  79.             print str(id) + ' not closed'
  80.         elif response.status == 200:
  81.             print str(id) + ' closed'
  82.         return response.status
  83.     except Exception as e:
  84.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  85.  
  86.  
  87. def close_all_orders(account_id):
  88.     try:
  89.         time.sleep(1)
  90.         for p in range(1):
  91.             data = get_orders(account_id)
  92.             data = json.loads(data)
  93.             time.sleep(1)
  94.             if 'orders' in data.keys():
  95.                 if data['orders']:
  96.                     print 'Close all orders for account N ' + str(account_id)
  97.                     for key in data['orders']:
  98.                         # print key[u'instrument']
  99.                         order_id = key['id']
  100.                         stat = del_orders(account_id, order_id)
  101.     except Exception as e:
  102.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  103.  
  104.  
  105. def close_all_trades(account_id):
  106.     try:
  107.         time.sleep(1)
  108.         for p in range(1):
  109.             data = get_trades(account_id)
  110.             data = json.loads(data)
  111.             time.sleep(1)
  112.             if 'trades' in data.keys():
  113.                 if data['trades']:
  114.                     print 'Close all trades for account N ' + str(account_id) + ' trying ' + str(p + 1)
  115.                     for key in data['trades']:
  116.                         order_id = key['id']
  117.                         stat = del_trades(account_id, order_id)
  118.     except Exception as e:
  119.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  120.  
  121.  
  122. def get_orders(account_id):
  123.     try:
  124.         time.sleep(1)
  125.         params = urllib.urlencode({'accountId': account_id})
  126.         conn = httplib.HTTPSConnection(url)
  127.         conn.request("GET", "/v1/accounts/" + account_id + "/orders", params, headers)
  128.         response = conn.getresponse()
  129.         resptext = response.read()
  130.         return resptext
  131.     except Exception as e:
  132.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  133.  
  134.  
  135. def get_orders_instrument(account_id, instrument, count):  # count максимальное количество, ордеров дефаулт 50
  136.     try:
  137.         time.sleep(1)
  138.         params = urllib.urlencode({'accountId': account_id})
  139.         conn = httplib.HTTPSConnection(url)
  140.         # GET "https://api-fxtrade.oanda.com/v1/accounts/12345/orders?instrument=EUR_USD&count=2"
  141.         conn.request("GET", "/v1/accounts/" + account_id + "/orders?instrument=" +
  142.                      instrument + '&count=' + str(count), params, headers)
  143.         response = conn.getresponse()
  144.         resptext = response.read()
  145.         return resptext
  146.     except Exception as e:
  147.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  148.  
  149.  
  150. def get_trades(account_id):
  151.     try:
  152.         time.sleep(1)
  153.         params = urllib.urlencode({'accountId': account_id})
  154.         conn = httplib.HTTPSConnection(url)
  155.         conn.request("GET", "/v1/accounts/" + account_id + "/trades", params, headers)
  156.         response = conn.getresponse()
  157.         resptext = response.read()
  158.         return resptext
  159.     except Exception as e:
  160.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  161.  
  162.  
  163. def get_trades_instrument(account_id, instrument):
  164.     try:
  165.         time.sleep(1)
  166.         params = urllib.urlencode({'accountId': account_id})
  167.         conn = httplib.HTTPSConnection(url)
  168.         conn.request("GET", "/v1/accounts/" + account_id + "/trades?instrument=" + instrument, params, headers)
  169.         response = conn.getresponse()
  170.         resptext = response.read()
  171.         return resptext
  172.     except Exception as e:
  173.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  174.  
  175.  
  176. def rename_file(newnamefile):
  177.     try:
  178.         dir = os.getcwd()  # Текущий каталог
  179.         files = os.listdir(dir)  # Список файлов в текущем каталоге
  180.         filterfiles = filter(lambda x: x.startswith('balans'), files)  # Фильтруем список по началу файла
  181.         if not filterfiles:
  182.             my_file = open('balans', 'w')
  183.             namefile = my_file.name
  184.             my_file.close()
  185.             os.rename(namefile, newnamefile)
  186.         else:
  187.             namefile = filterfiles[0]
  188.             os.rename(namefile, newnamefile)
  189.     except IOError:
  190.         print 'file busy'
  191.  
  192.  
  193. def get_balans(account_id):  # запрос баланса по счету
  194.     try:
  195.         time.sleep(1)
  196.         params = urllib.urlencode({'accountId': account_id})
  197.         conn = httplib.HTTPSConnection(url)
  198.         conn.request("GET", "/v1/accounts/" + account_id, params, headers)
  199.         response = conn.getresponse()
  200.         resptext = response.read()
  201.         if response.status == 200:
  202.             data = json.loads(resptext)
  203.             sredstva = float("%.2f" % data['balance']) + float("%.2f" % data['unrealizedPl'])
  204.             marginused = float("%.2f" % data['marginUsed'])
  205.             marginavail = float("%.2f" % data['marginAvail'])
  206.             currency = data['accountCurrency']
  207.             return sredstva, marginused, marginavail, currency
  208.     except Exception as e:
  209.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)
  210.  
  211.  
  212. def get_spred(instrument, period):
  213.     # 3600  - 1 hour
  214.     # 43200 - 12 hour
  215.     # 86400 - 1 day
  216.     try:
  217.         time.sleep(1)
  218.         params = urllib.urlencode({})
  219.         conn = httplib.HTTPSConnection(url)
  220.         conn.request("GET", "/labs/v1/spreads?instrument=" + instrument + "&period=" + period, params,
  221.                      headers)  # (таблица периодов на сайте Oanda Forex Labs)
  222.         response = conn.getresponse()
  223.         resptext = response.read()
  224.         # print resptext
  225.         if response.status == 200:
  226.             spred = 0
  227.             data = json.loads(resptext)
  228.             sumspred = 0
  229.             nspred = 0
  230.             max_spred = 0  # максимальный
  231.             min_spred = 999999  # минимальный
  232.             avg_spred = 999999  # минимальный
  233.  
  234.             for key in data[u'max']:
  235.                 if max_spred < round(key[1], 2):
  236.                     max_spred = round(key[1], 2)
  237.             for key in data[u'min']:
  238.                 if min_spred > round(key[1], 2):
  239.                     min_spred = round(key[1], 2)
  240.             for key in data[u'avg']:
  241.                 if avg_spred > round(key[1], 2):
  242.                     avg_spred = round(key[1], 2)
  243.             # print instrument, max_spred, min_spred, avg_spred
  244.             return max_spred, min_spred, avg_spred
  245.         else:
  246.             return 0
  247.     except Exception as e:
  248.         print sys._getframe().f_code.co_name + " @ Caught exception when connecting to stream\n" + str(e)

ИИ поможет Вам:

  • решить любую задачу по программированию
  • объяснить код
  • расставить комментарии в коде
  • и т.д
Попробуйте бесплатно

Оцени полезность:

12   голосов , оценка 4.5 из 5

Нужна аналогичная работа?

Оформи быстрый заказ и узнай стоимость

Бесплатно
Оформите заказ и авторы начнут откликаться уже через 10 минут
Похожие ответы