-
Notifications
You must be signed in to change notification settings - Fork 39
/
buy_with_okex.py
181 lines (148 loc) · 6.11 KB
/
buy_with_okex.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
import ccxt
import os
import sys
sys.path.append("py")
import re
import time
import datetime
from fonksiyonlar import *
os.chdir(basladigim_yer) #calisma klasorunu mevcut klasor olarak degistiriyorum
basligi_degistir() #powershell ile cagrilirsam bunu sil
target_altcoin=""
pair=""
#configi dosyadan oku
config = ayarlari_config_json_dosyasindan_oku()
#okunan dosyadan configi serpistir
k_sifreli = config['buy_with_okex']['api_key']
s_sifreli = config['buy_with_okex']['api_secret']
target_coin = config['buy_with_okex']['target_coin']
use_balance = config['buy_with_okex']['use_balance'] #target_coin ile
trade_with_real_account = str_to_bool(config['buy_with_okex']['trade_with_real_account'])
k = sifre_coz(k_sifreli)
s = sifre_coz(s_sifreli)
exchange = ccxt.okex({
'apiKey': k,
'secret': s,
'enableRateLimit': True,
'options': {'adjustForTimeDifference': True}
})
print("Caching the exchange settings....")
#market bilgilerini cacheliyorum ki ccxt daha hizli olsun
exchange.load_markets()
#tickerlar'i en bastan cacheliyorum ki sonradan kontrolu hizli olsun
tickerlar = exchange.fetch_tickers()
#kar_hesaplama
take_profit = ""
stop_loss = ""
order_id = 0
def basla():
global order_id, target_altcoin, use_balance, pair
if not target_altcoin or target_altcoin == "":
if len(sys.argv) > 1:
#parametre ile mi gelmis onu kontrol ediyorum
target_altcoin=sys.argv[1] #1. parametre orn: LTC
if target_altcoin == "i_couldnt_buy_new_altcoin_buy_it_yourself":
print("i_couldnt_buy_new_altcoin_buy_it_yourself")
target_altcoin = input("Type the altcoin to buy..")
else:
print("target_altcoin " + " listings.py dosyasiyla gonderildi: " + target_altcoin)
else:
print("coin manuel girilecek")
target_altcoin = input("Type the altcoin to buy..")
else:
print("target_altcoin daha onceden belirlenmis")
pair = (target_altcoin + "/" + target_coin).upper()
print("pair: " + pair)
real_pair_price = float(fiyat_ogren(pair, "satis"))
print("normal satis fiyati: " + str(notation_temizle(real_pair_price)))
alis_garanti_olsun_diye_yuzde_kac_ekliyorum = 0.02
real_pair_price = real_pair_price + (real_pair_price * alis_garanti_olsun_diye_yuzde_kac_ekliyorum / 100)
print("alis_garanti_olsun_diye_yuzde_kac_ekliyorum: %" + str(alis_garanti_olsun_diye_yuzde_kac_ekliyorum))
print("benim alacagim fiyat: " + str(notation_temizle(real_pair_price)))
if ("%" in str(use_balance)):
#config.json dosyasinda use_balance yuzde ile belirtilmis o yuzden tam olarak hesaplamaya calisiyorum
yuzde = float(str(use_balance).replace("%",""))
bakiyem = bakiye_hesapla(target_coin)
use_balance = yuzde / 100 * bakiyem
print("")
print("toplam: " + str(bakiyem) + target_coin)
print("islem yapilacak: " + str(use_balance) + target_coin + "(" + "bakiyeye orani: %" + str(yuzde) + ")")
#quantity'i hesapliyorum
quantity = use_balance/real_pair_price
if trade_with_real_account == False:
#test emri icin bilgileri yeniden duzeltiyorum
use_balance = 10 / 100 * bakiyem
test_emri_icin_fiyati_yuzde_kac_indiriyorum = 50
real_pair_price = real_pair_price - (real_pair_price * test_emri_icin_fiyati_yuzde_kac_indiriyorum / 100)
print("placing test order yalniz bu emri siteden silmeyi unutma")
print("")
print("Alis emri giriyorum..")
print("===================================")
print("quantity: " + str(quantity))
print("use_balance: " + str(use_balance) + target_coin)
print("alinacak fiyat: " + str(notation_temizle(real_pair_price)))
try:
alis_emri = exchange.create_order(pair, "limit" , "buy", quantity, real_pair_price)
print(alis_emri)
order_id = alis_emri["id"]
print("alis emri basariyla girildi kar hesaplama dosyasini aciyorum")
except Exception as e:
input("alis emri girilemedi\nhata 7709: " + str(e))
logla("islem tamamlandi")
print("")
print("kar hesaplama dosyasini aciyorum")
dosya = basladigim_yer + '\\py\\okex_profit_tracker.py'
komut = 'start cmd @cmd /k ' + dosya + ' ' + target_altcoin + ' ' + order_id + ' ' + take_profit + ' ' + stop_loss
print(komut)
os.system(komut)
bekle(20)
programi_yeniden_ac()
def fiyat_ogren(pair,side="alis"):
ask_bid = ""
if side=="alis": ask_bid="bid" #yesil buy bid
if side=="satis": ask_bid="ask" #kirmizi sell ask
return float(exchange.fetch_ticker(pair)[ask_bid])
def bakiye_hesapla(coin):
try: return exchange.fetch_balance()[coin.upper()]['free']
except: return 0
def txt_dosyasindan_islem_yapilacak_altcoini_cek():
global target_altcoin, take_profit, stop_loss
dosya = log_klasoru + "/" + dosya_adim().replace(".py",".json")
kontrol_sayisi = 0
while True:
try:
kontrol_sayisi += 1
if kontrol_sayisi % 1000 == 1: restart_zamanlarindaysam_programi_yeniden_ac()
dosya_mevcut_mu = os.path.exists(dosya)
os.system('cls')
print("")
print(dosya_adim())
print("=======================")
print("controlled: " + str(kontrol_sayisi))
print(dosya + " exists? " + str(dosya_mevcut_mu))
if dosya_mevcut_mu:
son_modification_time = os.path.getmtime(dosya)
son_modification_uzerinden_gecen_saniye = int(time.time() - son_modification_time)
satin_alinabilir_mi = son_modification_uzerinden_gecen_saniye <= 10
print(str(son_modification_uzerinden_gecen_saniye) + "seconds passed over last overwrite")
print("should i buy? " + str(satin_alinabilir_mi))
if satin_alinabilir_mi:
trade_config = json_dosyasi_oku(dosya)
target_altcoin = trade_config['target_altcoin'].upper()
take_profit = trade_config['take_profit']
stop_loss = trade_config['stop_loss']
if target_altcoin != False:
break
else:
if son_modification_uzerinden_gecen_saniye >= 10 * 60:
dosyayi_arsivle(dosya)
except Exception as e:
print("error 4546: " + str(e))
#while dongusu gecildiyse target_altcoin bulundu demektir
print("")
print("trade config")
print("=================")
print(trade_config)
if __name__ == "__main__":
txt_dosyasindan_islem_yapilacak_altcoini_cek() #fonksiyonlar.py
basla()