fix: new approach to update

services/indicator.py

@@ -7,8 +7,8 @@ from pymongo import MongoClient, ASCENDING, DESCENDING
 from utils.config import DATE_FORMAT, VN100_URL
 from .utils import Utility
 import os
-# from dotenv import load_dotenv
-# load_dotenv()
+from dotenv import load_dotenv
+load_dotenv()
 
 PREFIX = "https://www.hsx.vn/Modules/Chart/StaticChart/"
 TIME = {"1m": 2, "3m": 3, "6m": 4, "1y": 5, "2y": 6, "5y": 7}
@@ -53,7 +53,8 @@ class Indicator:
     def update_daily_price() -> dict:
         global updating_price
         if updating_price:
-            return {"message": "The data has been updating."}
+            print("The data has been updating.")
+            return
         updating_price = True
         datetime_now = datetime.utcnow()
         hour = datetime_now.hour
@@ -76,7 +77,8 @@ class Indicator:
                                             "stock").reset_index(drop=True)
                 if tmp_df.shape[0] == 0:
                     updating_price = False
-                    return {"message": "There is no data to updated"}
+                    print("There is no data to updated")
+                    return
                 tmp_df = tmp_df.iloc[-1]
                 last_date = str(tmp_df["time"])
                 newest_record = \
@@ -107,14 +109,14 @@ class Indicator:
                         values.append(df.to_dict())
                     record["value"] = values
                     collection.insert_one(record)
-                    ret = {"message": "Updated data."}
+                    ret = "Updated data."
                 else:
-                    ret = {"message": "The data is up to date."}
+                    ret = "The data is up to date."
                 updating_price = False
-                return ret
+                print(ret)
         except Exception as e:
             updating_price = False
-            return {"message": f"Caught error {e}."}
+            print(f"Caught error {e}.")
 
     @staticmethod
     def update_entire_price() -> None:
@@ -228,10 +230,12 @@ class Indicator:
                 )
 
     @staticmethod
-    def update_daily_rsi() -> None:
+    async def update_daily_rsi() -> None:
         global updating_rsi
         if updating_rsi:
-            return {"message": "The data has been updating."}
+            print("The data has been updating.")
+            return
+            # return {"message": "The data has been updating."}
         updating_rsi = True
         datetime_now = datetime.utcnow()
         hour = datetime_now.hour
@@ -255,7 +259,9 @@ class Indicator:
                                             "stock").reset_index(drop=True)
                 if tmp_df.shape[0] == 0:
                     updating_rsi = False
-                    return {"message": "The market is in trading."}
+                    print("The market is in trading.")
+                    return
+                    # return {"message": "The market is in trading."}
                 tmp_df = tmp_df.iloc[-1]
                 last_date = str(tmp_df["time"])
                 newest_record = \
@@ -271,16 +277,16 @@ class Indicator:
                         for i in data["data"]:
                             record[i["t"]] = i["rsi"]
                     collection.insert_one(record)
-                    ret = {"message": "Updated data."}
+                    ret = "Updated data."
                 else:
-                    ret = {"message": "The data is up to date."}
+                    ret = "The data is up to date."
             else:
-                ret = {"message": "The market is in trading."}
+                ret = "The market is in trading."
             updating_rsi = False
-            return ret
+            print(ret)
         except Exception as e:
             updating_rsi = False
-            return {"message": f"Caught error {e}."}
+            print(f"Caught error {e}.")
 
     @staticmethod
     def update_entire_rsi() -> None:
@@ -380,7 +386,8 @@ class Indicator:
     async def update_entire_macd() -> None:
         global updating_macd
         if updating_macd:
-            return {"message": "The data has been updating."}
+            print("The data has been updating.")
+            return
         updating_macd = True
         datetime_now = datetime.utcnow()
         hour = datetime_now.hour
@@ -390,12 +397,14 @@ class Indicator:
             lst_symbols = symbol_dict["symbols"]
             if weekday < 5 and hour < 12:
                 updating_macd = False
-                return {"message": "The market is in trading."}
+                print("The market is in trading.")
+                return
             get_time = True
             lst_values = {}
             if len(lst_symbols) != 100:
                 updating_macd = False
-                return {"message": "Not enough 100 symbols."}
+                print("Not enough 100 symbols.")
+                return
             cnt = 0
             for symbol in lst_symbols:
                 cnt += 1
@@ -420,10 +429,10 @@ class Indicator:
                 collection.drop()
             collection.insert_many(records)
             updating_macd = False
-            return {"message": "Updated data."}
+            print("Updated data.")
         except Exception as e:
             updating_macd = False
-            return {"message": f"Caught error {e}."}
+            print(f"Caught error {e}.")
 
     @staticmethod
     def get_macd(