diff --git a/HTS_etf_122630.py b/HTS_etf_122630.py index 597522e..fb4a057 100644 --- a/HTS_etf_122630.py +++ b/HTS_etf_122630.py @@ -40,6 +40,22 @@ class HTS_etf(HTS): return + def getTodayRSI(self, dbfile_name="stock.db"): + try: + conn = sqlite3.connect(os.path.join(self.RESOURCE_PATH, dbfile_name)) + cursor = conn.cursor() + + cursor.execute('SELECT rsi FROM stock_analysis WHERE CODE=? order by ymd desc', (self.stock_code,)) + db_result = cursor.fetchall() + cursor.close() + conn.close() + + if db_result is not None: + return db_result[0][0] + except: + return 100 + return 100 + def sellStocks(self, stock_code=None, bs_sell_price=None): check = False jangoDic = self.requstJango() @@ -113,6 +129,11 @@ class HTS_etf(HTS): return result def buyRealTime(self, today, analyzed_day=1000): + rsi = self.getTodayRSI() + if rsi > 79: + self.slackBot.sendMsg("exit... {} ({}) RSI: {}".format(self.stock_code, self.stock_name, rsi)) + return + MAX_PRICE = 20000 print("START...") diff --git a/HTS_etf_233740.py b/HTS_etf_233740.py index db0bf54..ef502d8 100644 --- a/HTS_etf_233740.py +++ b/HTS_etf_233740.py @@ -40,6 +40,22 @@ class HTS_etf(HTS): return + def getTodayRSI(self, dbfile_name="stock.db"): + try: + conn = sqlite3.connect(os.path.join(self.RESOURCE_PATH, dbfile_name)) + cursor = conn.cursor() + + cursor.execute('SELECT rsi FROM stock_analysis WHERE CODE=? order by ymd desc', (self.stock_code,)) + db_result = cursor.fetchall() + cursor.close() + conn.close() + + if db_result is not None: + return db_result[0][0] + except: + return 100 + return 100 + def sellStocks(self, stock_code=None, bs_sell_price=None): check = False jangoDic = self.requstJango() @@ -113,6 +129,11 @@ class HTS_etf(HTS): return result def buyRealTime(self, today, analyzed_day=1000): + rsi = self.getTodayRSI() + if rsi > 79: + self.slackBot.sendMsg("exit... {} ({}) RSI: {}".format(self.stock_code, self.stock_name, rsi)) + return + MAX_PRICE = 20000 print("START...") diff --git a/HTS_etf_251340.py b/HTS_etf_251340.py index 20cc289..404d0ed 100644 --- a/HTS_etf_251340.py +++ b/HTS_etf_251340.py @@ -40,6 +40,21 @@ class HTS_etf(HTS): return + def getTodayRSI(self, dbfile_name="stock.db"): + try: + conn = sqlite3.connect(os.path.join(self.RESOURCE_PATH, dbfile_name)) + cursor = conn.cursor() + + cursor.execute('SELECT rsi FROM stock_analysis WHERE CODE=? order by ymd desc', (self.stock_code,)) + db_result = cursor.fetchall() + cursor.close() + conn.close() + + if db_result is not None: + return db_result[0][0] + except: + return 100 + return 100 def sellStocks(self, stock_code=None, bs_sell_price=None): check = False @@ -114,6 +129,11 @@ class HTS_etf(HTS): return result def buyRealTime(self, today, analyzed_day=1000): + rsi = self.getTodayRSI() + if rsi > 79: + self.slackBot.sendMsg("exit... {} ({}) RSI: {}".format(self.stock_code, self.stock_name, rsi)) + return + MAX_PRICE = 100000 print("START...") diff --git a/HTS_etf_252670.py b/HTS_etf_252670.py index cf54ecd..b365217 100644 --- a/HTS_etf_252670.py +++ b/HTS_etf_252670.py @@ -41,6 +41,22 @@ class HTS_etf(HTS): return + def getTodayRSI(self, dbfile_name="stock.db"): + try: + conn = sqlite3.connect(os.path.join(self.RESOURCE_PATH, dbfile_name)) + cursor = conn.cursor() + + cursor.execute('SELECT rsi FROM stock_analysis WHERE CODE=? order by ymd desc', (self.stock_code,)) + db_result = cursor.fetchall() + cursor.close() + conn.close() + + if db_result is not None: + return db_result[0][0] + except: + return 100 + return 100 + def sellStocks(self, stock_code=None, bs_sell_price=None): check = False jangoDic = self.requstJango() @@ -114,6 +130,11 @@ class HTS_etf(HTS): return result def buyRealTime(self, today, analyzed_day=1000): + rsi = self.getTodayRSI() + if rsi > 79: + self.slackBot.sendMsg("exit... {} ({}) RSI: {}".format(self.stock_code, self.stock_name, rsi)) + return + MAX_PRICE = 10000 print("START...")