init

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...")

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...")

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...")

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...")