init
This commit is contained in:
dsyoon
@@ -721,53 +721,54 @@ class Bithumb_minute(HTS):
|
||||
|
||||
if isRealTime and not check_buy_history:
|
||||
|
||||
# 매수 조건
|
||||
#stock = self.getStock(ticker, analyzed_day, day=30)
|
||||
#if stock["slow_k"][len(stock['close'])-1] > 40:
|
||||
# print (datetime.now().strftime('%Y-%m-%d %H:%M:%S'), ",", round(stock["slow_k"][len(stock['close'])-3],2), ",", round(stock["slow_k"][len(stock['close'])-2],2), ",", round(stock["slow_k"][len(stock['close'])-1], ))
|
||||
# return
|
||||
if bsLine > 0:
|
||||
# 매수 조건
|
||||
#stock = self.getStock(ticker, analyzed_day, day=30)
|
||||
#if stock["slow_k"][len(stock['close'])-1] > 40:
|
||||
# print (datetime.now().strftime('%Y-%m-%d %H:%M:%S'), ",", round(stock["slow_k"][len(stock['close'])-3],2), ",", round(stock["slow_k"][len(stock['close'])-2],2), ",", round(stock["slow_k"][len(stock['close'])-1], ))
|
||||
# return
|
||||
|
||||
# [잔고 확인하기]
|
||||
# - 비트코인의 총 잔고
|
||||
# - 거래 중인 비트코인의 수량
|
||||
# - 보유 중인 총원화
|
||||
# - 주문에 사용된 원화
|
||||
# (4.978e-05, 0.0, 3438133.120299, 0)
|
||||
tmp = self.bithumb.get_balance(ticker)
|
||||
balance = tmp[2]
|
||||
#count = round((balance * (bsLine['buy_weight'][len(bsLine['buy_weight']) - 1] / 100)) / bsLine['buy'][len(bsLine['buy']) - 1], 2)
|
||||
if ticker == 'TRX':
|
||||
count = self.getTRXCount(bsLine)
|
||||
elif ticker == 'SOL':
|
||||
count = self.getSOLCount(bsLine)
|
||||
elif ticker == 'EOS':
|
||||
count = self.getEOSCount(bsLine)
|
||||
else:
|
||||
count = self.getXRPCount(bsLine)
|
||||
# [잔고 확인하기]
|
||||
# - 비트코인의 총 잔고
|
||||
# - 거래 중인 비트코인의 수량
|
||||
# - 보유 중인 총원화
|
||||
# - 주문에 사용된 원화
|
||||
# (4.978e-05, 0.0, 3438133.120299, 0)
|
||||
tmp = self.bithumb.get_balance(ticker)
|
||||
balance = tmp[2]
|
||||
#count = round((balance * (bsLine['buy_weight'][len(bsLine['buy_weight']) - 1] / 100)) / bsLine['buy'][len(bsLine['buy']) - 1], 2)
|
||||
if ticker == 'TRX':
|
||||
count = self.getTRXCount(bsLine)
|
||||
elif ticker == 'SOL':
|
||||
count = self.getSOLCount(bsLine)
|
||||
elif ticker == 'EOS':
|
||||
count = self.getEOSCount(bsLine)
|
||||
else:
|
||||
count = self.getXRPCount(bsLine)
|
||||
|
||||
# 매수를 요청한다.
|
||||
order = self.bithumb.buy_limit_order(ticker, bsLine, count)
|
||||
# slackbot에 메시지를 보냄
|
||||
self.slackBot.post_to_slack(ticker, self.stock_code[ticker], "BUY", bsLine, count)
|
||||
# 매수를 요청한다.
|
||||
order = self.bithumb.buy_limit_order(ticker, bsLine, count)
|
||||
# slackbot에 메시지를 보냄
|
||||
self.slackBot.post_to_slack(ticker, self.stock_code[ticker], "BUY", bsLine, count)
|
||||
|
||||
# order: ('bid', 'BTC', 'C0101000000322993432', 'KRW')
|
||||
if len(stock1['close']) > 0:
|
||||
print(ticker, "/", datetime.now().strftime('%Y-%m-%d %H:%M:%S'), "/", stock1['close'][len(stock1['close'])-1], "/", "{:.2f}".format(stock2['slow_k'][len(stock1['slow_k'])-1]), "/", "{:.2f}".format(stock1['slow_k'][len(stock1['slow_k'])-1]), "/", "{:.2f}".format(stock2['avg30'][len(stock2['avg30']) - 1]), "/", "{:.2f}".format(stock1['avg60'][len(stock1['avg60']) - 1]), "/", bsLine, "/", count)
|
||||
datetime_value = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
|
||||
value = {"type": "BUY", "datetime": datetime_value, "order0": order[0], "order1": order[1], "order2": order[2], "order3": order[3], "canceled": 0, "slow_k_30": stock2['slow_k'][len(stock2['slow_k']) - 1], "slow_k_5": stock1['slow_k'][len(stock1['slow_k']) - 1], "price": bsLine, "count": count}
|
||||
value_df = pd.DataFrame(value, index=[datetime_value])
|
||||
value_df["datetime"] = pd.to_datetime(value_df["datetime"], format='%Y-%m-%d %H:%M:%S')
|
||||
indexes1 = order_log_df.index.tolist()
|
||||
indexes1.append(datetime_value)
|
||||
# order: ('bid', 'BTC', 'C0101000000322993432', 'KRW')
|
||||
if len(stock1['close']) > 0:
|
||||
print(ticker, "/", datetime.now().strftime('%Y-%m-%d %H:%M:%S'), "/", stock1['close'][len(stock1['close'])-1], "/", "{:.2f}".format(stock2['slow_k'][len(stock1['slow_k'])-1]), "/", "{:.2f}".format(stock1['slow_k'][len(stock1['slow_k'])-1]), "/", "{:.2f}".format(stock2['avg30'][len(stock2['avg30']) - 1]), "/", "{:.2f}".format(stock1['avg60'][len(stock1['avg60']) - 1]), "/", bsLine, "/", count)
|
||||
datetime_value = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
|
||||
value = {"type": "BUY", "datetime": datetime_value, "order0": order[0], "order1": order[1], "order2": order[2], "order3": order[3], "canceled": 0, "slow_k_30": stock2['slow_k'][len(stock2['slow_k']) - 1], "slow_k_5": stock1['slow_k'][len(stock1['slow_k']) - 1], "price": bsLine, "count": count}
|
||||
value_df = pd.DataFrame(value, index=[datetime_value])
|
||||
value_df["datetime"] = pd.to_datetime(value_df["datetime"], format='%Y-%m-%d %H:%M:%S')
|
||||
indexes1 = order_log_df.index.tolist()
|
||||
indexes1.append(datetime_value)
|
||||
|
||||
order_log_df = order_log_df.append(value_df, ignore_index = True)
|
||||
order_log_df.index = indexes1
|
||||
order_log_df['datetime'] = order_log_df.index
|
||||
order_log_df.to_csv(order_log_filename, index=False)
|
||||
order_log_df = order_log_df.append(value_df, ignore_index = True)
|
||||
order_log_df.index = indexes1
|
||||
order_log_df['datetime'] = order_log_df.index
|
||||
order_log_df.to_csv(order_log_filename, index=False)
|
||||
|
||||
# 파일에 매수 시점 그래프
|
||||
#dirName = os.path.join(RESOURCE_PATH, 'analysis', 'bithumb')
|
||||
#self.writeFile(dirName, ticker, stock1, bsLine, 'buy')
|
||||
# 파일에 매수 시점 그래프
|
||||
#dirName = os.path.join(RESOURCE_PATH, 'analysis', 'bithumb')
|
||||
#self.writeFile(dirName, ticker, stock1, bsLine, 'buy')
|
||||
|
||||
"""
|
||||
if max(bsLine['sell'][len(bsLine['sell']) - 2:]) > 100:
|
||||
|
||||
Reference in New Issue
Block a user