init
This commit is contained in:
26
hts/HTS.py
26
hts/HTS.py
@@ -638,7 +638,8 @@ class HTS:
|
|||||||
return
|
return
|
||||||
|
|
||||||
def buyRealTime(self, stock_code, given_day):
|
def buyRealTime(self, stock_code, given_day):
|
||||||
buy_count = 0
|
previous_price = 0
|
||||||
|
buy_count = 50
|
||||||
logFp = open(given_day+".log", "w")
|
logFp = open(given_day+".log", "w")
|
||||||
|
|
||||||
timecheckList = pd.read_csv("timecheck.csv").values.tolist()
|
timecheckList = pd.read_csv("timecheck.csv").values.tolist()
|
||||||
@@ -678,17 +679,26 @@ class HTS:
|
|||||||
logFp.write("%s,%s, %d\n" % ("BUY", second, price))
|
logFp.write("%s,%s, %d\n" % ("BUY", second, price))
|
||||||
logFp.flush()
|
logFp.flush()
|
||||||
|
|
||||||
count = 20
|
if previous_price > 0:
|
||||||
buy_count += 1
|
if previous_price > price:
|
||||||
if buy_count > 5:
|
if buy_count < 40:
|
||||||
buy_count = 2
|
buy_count = 40
|
||||||
|
buy_count += 10
|
||||||
|
if buy_count > 80:
|
||||||
|
buy_count = 80
|
||||||
|
elif previous_price < price:
|
||||||
|
if buy_count > 60:
|
||||||
|
buy_count = 60
|
||||||
|
buy_count -= 10
|
||||||
|
if buy_count < 30:
|
||||||
|
buy_count = 30
|
||||||
|
previous_price = price
|
||||||
|
|
||||||
# 매수 주문
|
# 매수 주문
|
||||||
self.requestOrder("2", stock_code, count * buy_count, price)
|
self.requestOrder("2", stock_code, buy_count , price)
|
||||||
## 매도 주문 (아래 잔고를 체킇서 매도를 호출하는 것으로 시도한다.)
|
## 매도 주문 (아래 잔고를 체킇서 매도를 호출하는 것으로 시도한다.)
|
||||||
#time.sleep(60)
|
#time.sleep(60)
|
||||||
#self.requestOrder("1", stock_code, count, price + 5)
|
#self.requestOrder("1", stock_code, buy_count , price + 5)
|
||||||
|
|
||||||
|
|
||||||
# 가져온 만큼 데이터를 누적해서 파일로 작성한다.
|
# 가져온 만큼 데이터를 누적해서 파일로 작성한다.
|
||||||
self.write(given_day, result)
|
self.write(given_day, result)
|
||||||
|
|||||||
Reference in New Issue
Block a user