Code: Select all

#!/usr/bin/python

##  by mcbusrider 2015  
'''
The MIT License (MIT)

'closeAllProfitableTrades.py' Copyright (c) 2015 mcbusrider (Steve Hopwood Forex forum user)

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.
'''
## Import relevant modules
import httplib, json
import sys
import json
import urllib
import time
import datetime
import oandapy ## see below for more info on this module 
'''
'oandapy' is available from GitHub (or from Oanda's REST API developer pages) and released under the following license:

The MIT License (MIT)

Copyright (c) 2014 OANDA Corporation

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
'''

## Declare Global Variables ##
oanda = oandapy.API(environment="practice", access_token="xxxxxxxxxxxxxxxxxxxxxxxxxx1234567890yyyyyyyyyyyyyyyyyyyyyyyyyyyy")## get your "access_token" from Oanda - this will allow the script to access your accounts - SO USE IT WITH CARE!!!
## There are 3 potential 'environments': 'live', 'practice' and 'sandbox'.  Check out the docs at Oanda REST API developer pages for more information.
account_id=123456 ## this will eventually be set to the account number item in the account list
ask=None ## declare 'ask' variable 
price=None ## declare 'price' variable
prices=None ## declare 'prices' variable
bid=None ## declare 'bid' variable
pair=None ## declare 'pair' variable
account_list= [123456, 789012] ## add your Oanda account/sub-account numbers to this list, seperated by commas
account=0 ## declare ' account' variable - this is used as a counter to iterate through the 'account_list' list 
account_list_end=(len(account_list)) ## account_list_end' variable contains the number of items in the account_list.  Used in conjunction with the 'account' variable to enable us to loop through the accounts, calling the 'closeAllTrades' function for each account

### "CloseAllTrades" Function ###
def closeAllTrades(account_id):##define the main function of the script
	print "Account number: "+str(account_id)	## print the Account number we're working on
  	trades_response = oanda.get_trades(account_id) ## gets a list of all open trades for this account
	trades = trades_response.get("trades")	## 'trades' variable now set to contain information for all open trades on this account
## set up loop to iterate through all open trades
	i=0	## start loop at first trade
	j=(len(trades))## finish loop at last trade
## j=length of list of trades (giving length of list)
	while i<j: ## if there are still some trades left to check...
## loop until end of list of trades is reached
		instrument=trades[i].get("instrument") ## 'instrument' is now set to currency pair for this trade
		print "instrument: "+str(instrument) ## print currency pair for this trade
		prices_response = oanda.get_prices(instruments=instrument) ## get market prices for this currency pair from Oanda
		prices = prices_response.get("prices")## 'prices' variable now set to market info for the currency pair
		print "current trade info: "+str(prices) ## print info for the currency pair
## Set current ask and bid prices for this currency pair
		ask = prices[0].get("ask")
		bid = prices[0].get("bid")
## Print current ask and bid prices for this currency pair
		print "closeAllTrades ask: "+str(ask) 	
		print "closeAllTrades bid: "+str(bid) 
		trade_id=trades[i].get("id") ## 'trade_id' variable now contains the current trade number
		print "trade_id: "+str(trade_id) ## print 'trade_id' (current trade number)
		price = trades[i].get("price")	## price' variable now contains the original opening price for the current trade
		print "price: "+str(price) ## print 'price' (the original opening price for the current trade)
		side=trades[i].get("side")	## is current trade a buy or a sell trade?  'side' variable now contains this information
		print "side: "+str(side)	## print 'side' (whether it's a buy or a sell trade)
		instrument=trades[i].get("instrument") ## 'instrument' variable is now set to the currency pair of the current trade
		pair=instrument	## set 'pair' variable equal to 'instrument' variable (currency pair of current trade)
		print "instrument: "+str(instrument) ## print 'instrument' (equal to 'instrument' variable (currency pair of current trade))'''
##  
		if pair == "AUD_JPY" or pair == "CAD_JPY" or pair == "CHF_JPY" or pair == "EUR_JPY" or pair == "GBP_JPY" or pair == "NZD_JPY" or pair == "USD_JPY":## if 'pair' is one of the above, one pip is worth 0.01...
			offset=.05 ## ...so 'offset' variable is set to the "Take Profit" in pips - this is used to offset the market price by a number of pips.  Default = 5 pips...
		else:
			offset=.0005 ## if 'pair' is not one of the above pairs, must amend offset to reflect correct pip price, as one pip is now worth 0.0001.  Again, Default = 5 pips		
  		if side=='buy':	## if it's a buy trade...					
				print "Account number: "+str(account_id)
				print "checking: buy trade number: "+str(trade_id)
## Check Trade/Close Buy Trade if Take Profit is reached					
				if bid>(price+offset): ## if bid price is more than current market price, plus Take Profit...	
						print "closing: sell trade number: "+str(trade_id)
						response = oanda.close_trade(account_id,trade_id) ## run "Oanda close trade script" on this account, this trade
		else:	## otherwise, it must be a sell trade...
## Check Trade/Close Sell Trade if Take Profit is reached				
				print "Account number: "+str(account_id)		
				print "checking: sell trade number: "+str(trade_id) 
				if ask<(price-offset): ## if ask price is less than current market price, minus Take Profit...'''
						print "closing: sell trade number: "+str(trade_id) 
						response = oanda.close_trade(account_id,trade_id)## run "Oanda close trade script" on this account, this trade
		time.sleep(10)	## wait ten seconds between closing trades, so you can see what's going on.
				## This has been tested as working on the open markets with a value of .1 seconds.
				## If this line isn't here, you sometimes get a "too many open connections" error from Oanda.
		i=i+1   ## move on to next trade and loop again
  	return		## end function when last trade check/close complete

## 'closeAllTrades' CALL LOOP ##

## Loop through each account_id in account_list and call 'closeAllTrades' function for each account_id

while account < account_list_end: ## this will loop until each 'account' in the 'account_list' has been checked
	account_id=account_list[account] ## 'account_id' is now set to the 'account'-numbered item in 'account_list' list
	account=account+1		## increase 'account' counter, ready for next time round
	closeAllTrades(account_id)	## call script for this 'account_id'

Code: Select all

#!/usr/bin/python2.7
##  by mcbusrider 2015  
'''
The MIT License (MIT)
 
'placePendingOrders.py' Copyright (c) 2015 mcbusrider (Steve Hopwood Forex forum user)
 
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
 
The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.
 
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.
'''

## placePendingOrders.py
import httplib, json
import sys
import json
import urllib
import time
import datetime
import oandapy

## Start of Buy Order section

#oanda = oandapy.API(environment="practice", access_token="hjdfhdhdfhfu45454754857494874jdhfdfdjfdkfjdfkjd")
#account_id = 1234567
oanda = oandapy.API(environment="live", access_token="djfhdfhdfhdjhdjhdjfdhf7485748574857485745difhdjfdjfhdjfh")
## the access_token is your own personal key to allow this script unlimited access to your accounts.  Use with caution on a live account!!!

currencyList = []
##currencyList variable is a list, which will contain the currency pairs you wish to trade
defaultSize = 1
##defaultSize variable will contain the default size of the order you wish to place - initially set at 1
size=defaultSize
##size variable is set to defaultSize.  This is probably poor coding on my part, but it works, and if it ain't broke...
lotSizeIncreaseThreshold=[3,16,42,81,133,198,276,367,471,588,718,861,1017,1186,1368,1563,1771,1992,2226,2473,2733,3006,3292,3591,3903,4228,4566,4917,5281,5658,6048,6451,6867,7296,7738,8193,8661,9142,9636,10143,10663,11196,11742,12301,12873,13458,14056,14667,15291,15928]
##lotSizeIncreaseThreshold variable is another list.  When the account balance is greater than the threshold, the trade size is set to increase in double units, like this: 1,2,4,6,8,10 etc.)
accountSize={}
##accountSize list will contain the size of trade for each account, based on the account balance being greater than the relevant lotSizeIncreaseThreshold
stagger=.0015
##stagger variable is the distance away from market price that you wish to place the first pending order.  Subsequent trades will be calculated at 'stagger' distance from the last trade, e.g. if stagger is set to .0015, orders will be placed 15 pips away/30 pips away/45 pips away etc. from market price.
offset=stagger
##offset variable is set to stagger.  Again, probably poor coding on my part, but it works, so it's staying like that <!-- s:-) --><img src=\"{SMILIES_PATH}/friendly.gif\" alt=\":-)\" title=\"smile\" /><!-- s:-) -->
account_id = 123456
##account_id variable is the account number you wish to set the orders on.
now = datetime.datetime.now()
##now is set to the current time
trade_expire = now + datetime.timedelta(minutes=1)
##the minimum expiry of a pending trade is one hour.  I set the timedelta to one minute, simply because it is the lowest denomination and when I was setting this to one hour, orders were staying open for two hours, for some reason.
trade_expire = trade_expire.isoformat("T") + "Z"
##trade_expire is the time the order is due to expire 
master_account_list= [123456, 789012, 345678, 901234]
##master_account_list contains all the account numbers on your account, if you want to use multiple accounts
account=0
##account is a counter, used for iterating through the master_account_list and account_list items
master_account_list_end=(len(master_account_list))
##master_account_list_end contains the position of the last account number stored in the master_account_list
account_list=[]
##sets account_list to an empty list
allowTrade=False
##allowTrade boolean - if this is set to true, the current account can trade
account_list_end=(len(account_list))
##account_list_end contains the position of the last account number stored in the account_list.  
##The account_list is generated from the master_account_list during the checkAvailBalance function.
##this function will only allow trades from accounts with more than a specified free margin to use (default is 25% of NAV)
##on a successful check, the account_list will be appended with the account number from the master_account_list, otherwise the next account is checked.
def checkAvailBalance(account, account_id, allowTrade):
	response = oanda.get_account(account_id)
	print "Account Info: "+str(response)
	balance = response.get("balance")
	UPL = response.get("unrealizedPl")
	usedMargin = response.get("marginUsed")
	freeMargin = response.get("marginAvail")
	NAV = usedMargin+freeMargin

	print "balance: "+str(balance)	
	print "Unrealized Profit Loss(UPL): "+str(UPL)
	print "usedMargin: "+str(usedMargin)
	print "freeMargin: "+str(freeMargin)
	print "NAV: "+str(NAV)
	NAVfree=NAV/4
	##this check stops trading on this account if available balance is less than 25% of NAV
	print "%free% of NAV: "+str(NAVfree)
	if freeMargin<NAVfree:#if less than 25% available margin, no trade
		allowTrade=False
		print "freeMargin < 25% of NAV, so allowTrade==False"
		return
	else:
		allowTrade=True
		print "freeMargin > 25% of NAV, so allowTrade==True"
		print "adding this account to account_list..."	
		account_list.append(account_id)
		accountSize[account_id]=defaultSize
		print "accountSize dictionary: "+str(accountSize.keys())
		x=1
		while balance>lotSizeIncreaseThreshold[x]:
		##this checks the balance of the account to see what size trade we are allowing
		##if the balance is greater than the amount in lotSizeIncreaseThreshold...
			accountSize[account_id]=(x*2)
			##the accountSize for this account should be set to the position in the list, multiplied by two
			x=x+1
			##check the next one in the list
			if balance<lotSizeIncreaseThreshold[1]:
			##if the balance is lower than the second balance in the list...I know, I know...but it works!
				accountSize[account_id]=1
				##accountSize for this account is set to 1
		print "accountSize dict: "	
		for key, value in accountSize.iteritems():
			print key, value
			##prints a list of accounts we are allowed to trade on, with the size of the trade for each account
	return

def placeBuyOrder(account_id, pair, size, offset):
	response = oanda.get_prices(instruments=pair)
	prices = response.get("prices")	
	asking_price = prices[0].get("bid")+offset
	##asking_price is set to bid price + offset in pips
	TP = asking_price
	##TakeProfit is calculated by using the same offset - e.g., order is placed 15 pips away, with a 15 pip TP
        time.sleep(.25)
	##this causes a quarter of a second delay in an attempt to stop the "too many connections" error from the Oanda server, which crashes the script.  You may need to move this up a bit if you get this error, but it seems to work ok for me on this setting.
	loop=1
	while loop<6:
	##loop contains the number of pending orders you wish to set, minus one
		response = oanda.create_order(account_id, 
    		instrument=pair,
   		units=size,
   		side='buy',
    		type='limit',
    		price=asking_price,
    		takeProfit=TP+offset,
    		expiry=trade_expire
		)	
		TP=TP-offset
		asking_price=asking_price-offset			
		loop=loop+1	
	return
	
def createAccountList(master_account_list,account_list,allowTrade):	
	count=0	
	while count < master_account_list_end:
		account_id=master_account_list[count]
		checkAvailBalance(count,account_id,allowTrade)
		count=count+1	
	return

createAccountList(master_account_list,account_list,allowTrade)
##make the account_list from the master_account_list, checking if we are currently allowing trades on each account	
account_list_end=(len(account_list))
print "master_account_list: "+str(master_account_list)
print "length of master account list: "+str(len(master_account_list))
print "account_list: "+str(account_list)
print "length of account list: "+str(len(account_list))
print "account: "+str(account)
##gives info on which accounts are tradeable
while account < account_list_end:
	##loop through all accounts
	account_id=account_list[account]
	##account_id is set to "account" numbered item of the account_list
	size=accountSize[account_id]
	##size is set to the account size for this account
	account=account+1
	##increase this now, before I forget to put it in there...
	if account_id==123456:
		currencyList = ["EUR_JPY","EUR_GBP","GBP_CHF","GBP_JPY","NZD_JPY","GBP_JPY"]
	elif account_id==789012:	
		currencyList = ["GBP_USD","EUR_GBP","GBP_USD","USD_CAD","EUR_JPY","GBP_AUD","AUD_CAD","EUR_CHF"]
	elif account_id==345678:
		currencyList = ["GBP_JPY","EUR_CHF","EUR_AUD","AUD_JPY","GBP_JPY","GBP_CAD"]
	elif account_id==901234:
		currencyList = ["CAD_CHF","AUD_CAD","EUR_AUD","AUD_JPY","GBP_CAD","EUR_GBP","EUR_USD","USD_CAD","EUR_NZD","NZD_JPY"]
	##currencyList contains the pairs you wish to trade on the buy side of things
				
	for pair in currencyList:
		offset=stagger
		##sets the default offset to the stagger variable, which is constant throughout the script
		if pair == "AUD_JPY" or pair == "CAD_JPY"  or pair == "CHF_JPY" or pair == "EUR_JPY" or pair == "GBP_JPY" or pair == "NZD_JPY" or pair == "USD_JPY":
			offset=offset*100
			##this sets the offset to compensate for the pip value on instruments with fewer digits.  If you get a ridiculous number of pending trades around the same price, check how many digits are in the pair's price and change accordingly.
		placeBuyOrder(account_id, pair, size, offset)

## Start of Sell Order section
##this is pretty much similar to the buy section, but for sell trades, obviously...
account_id = 123456
now = datetime.datetime.now()
trade_expire = now + datetime.timedelta(minutes=1)
trade_expire = trade_expire.isoformat("T") + "Z"
account=0
account_list_end=(len(account_list))

def placeSellOrder(account_id, pair, size, offset):
	response = oanda.get_prices(instruments=pair)
	prices = response.get("prices")	
	asking_price = prices[0].get("bid")+offset
	TP = asking_price
        time.sleep(.25)
	loop=1
	while loop<3:	
			response = oanda.create_order(account_id, 
    			instrument=pair,
   			units=size,
   		 	side='sell',
    			type="limit",
    			price=asking_price,
    			takeProfit=TP-offset,
    			expiry=trade_expire
			)
			TP=TP+offset
			asking_price=asking_price+offset
			loop=loop+1	
	return

while account < account_list_end:
	account_id=account_list[account]
	size=accountSize[account_id]
	account=account+1
	if account_id==123456:
		currencyList = ["EUR_USD","USD_JPY","EUR_CHF","GBP_USD","USD_JPY","NZD_USD","USD_JPY","GBP_CAD","CAD_JPY"]
	elif account_id==789012:	
		currencyList = ["EUR_USD","GBP_CAD","USD_JPY","EUR_USD","GBP_CAD","USD_CHF","EUR_USD"]
	elif account_id==345678:	
		currencyList = ["GBP_CHF","CHF_JPY","EUR_USD","USD_CHF","EUR_JPY","GBP_NZD","NZD_JPY","NZD_CAD","GBP_NZD"]
	elif account_id==901234:
		currencyList = ["EUR_CAD","EUR_JPY","EUR_JPY","EUR_CAD","AUD_CHF"]
			
	for pair in currencyList:
			offset=stagger
			if pair == "AUD_JPY" or pair == "CAD_JPY"  or pair == "CHF_JPY" or pair == "EUR_JPY" or pair == "GBP_JPY" or pair == "NZD_JPY" or pair == "USD_JPY":
				offset=offset*100

			placeSellOrder(account_id, pair, size, offset)
	

Code: Select all

if a<b:
      c=d
else:
      e=f

Code: Select all

if a<b:
c=d
else:
e=f

Code: Select all

set TargetProfit in pips
set GrandTotalProfit = 0 ## this is a running total of profit, in pips 

  set a loop to iterate through all open trades
  select trade (using loop number)
  get instrument of current trade
  get ask and bid price of current trade
  get type (buy or sell) of current trade
  get open price of current trade
  calculate profit of current trade, using open price of current trade versus (buy or ask price) of instrument.
  check if instrument of current trade is on the "3 digit pip" list - if so, divide profit by 100 to give standard value of profit in pips across all trades.
  add profit in pips to GrandTotalProfit (even if this is a negative amount, addition will still apply)
  loop through next trade and repeat


when profit (or loss) of all open trades has been added to GrandProfitTotal:
           if GrandTotalProfit>TargetProfit:
                  loop through all trades again
                  close this trade
                  next trade
          else:
                  do not close all trades