Update app.py

app.py

@@ -11,15 +11,43 @@ import base64
 from unidecode import unidecode
 
 api_key_sys = os.getenv('api_key_sys')  
-gc_api = os.getenv('gc_api')
-gc_url = os.getenv('gc_url_use')
-gc_url_gru = os.getenv('gc_url_gru')
-gc_url_export = os.getenv('gc_url_export')
+
+
+gc_api = os.getenv('gc_api')  #Good
+gc_url = os.getenv('gc_url_use')   
+
+
+gc_url_gru = os.getenv('gc_url_gru') #Good
+gc_url_export = os.getenv('gc_url_export') 
+
 id_gru = os.getenv('id_gru')
+# Дата
+date_from = "2022-01-01"
+
+# Статус
+status = "active"
+
+
+
+
+
+
+
+
+
+
+
+
 wa_url = os.getenv('wa_url') 
 wa_api_key = os.getenv('wa_api_key') 
+
+
 start_up = os.getenv('start_up') 
+
 export_id = ""
+
+
+
 json_data = '''
 
 
@@ -27,6 +55,9 @@ json_data = '''
 
 '''
 
+
+
+
 app = Flask(__name__, template_folder="./")
 app.config['DEBUG'] = True
 UPLOAD_FOLDER = 'static'
@@ -67,49 +98,34 @@ def init_db(db_name):
 for db in DATABASES:
     init_db(db)
 
-def load_data_from_json():
-    data = json.loads(json_data)
-    items = data['info']['items']
-    fields = data['info']['fields']
 
-    db = 'data_gc.db'  # Указываем конкретную базу данных
-    conn = sqlite3.connect(db)
-    cursor = conn.cursor()
 
-    for item in items:
-        user_data = dict(zip(fields, item))
-        user_data.setdefault('vk_id', '')
-        user_data.setdefault('chat_id', '')
-        user_data.setdefault('ws_st', '')
-        user_data.setdefault('ws_stop', '')
-        user_data.setdefault('web_st', '')
-        user_data.setdefault('fin_prog', '')
-        user_data.setdefault('shop_st', '')
-        user_data.setdefault('curator', '')
-        user_data.setdefault('pr1', '')
-        user_data.setdefault('pr2', '')
-        user_data.setdefault('pr3', '')
-        user_data.setdefault('pr4', '')
-        user_data.setdefault('pr5', '')
-        user_data.setdefault('ad_url', '')
 
-        if 'Телефон' in user_data and user_data['Телефон'].startswith('+'):
-            user_data['Телефон'] = user_data['Телефон'][1:]
 
-        query = '''
-        INSERT INTO contacts (
-         name, phone, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator
-        ) VALUES (
-         :Имя, :Телефон, :Email, :vk_id, :chat_id, :ws_st, :ws_stop, :web_st, :fin_prog, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :ad_url, :curator
-        )
-        '''
-        cursor.execute(query, user_data)
 
-    conn.commit()
-    conn.close()
+
+
+
+
+
+
+
+
+
+
+
+
 
 # Если start_up равна '1', выполним запросы
 if start_up == '1':
+    # Ваши API-ключи и другие переменные
+    gc_url_gru = os.getenv('gc_url_gru')
+    gc_api = os.getenv('gc_api')
+    gc_url_export = os.getenv('gc_url_export')
+    id_gru = "2993783"
+    date_from = "2022-01-01"
+    status = "active"
+
     # Формирование URL для первого запроса
     url_template = f"{gc_url_gru}/{id_gru}/users?key={gc_api}&created_at[from]={date_from}&status={status}"
 
@@ -124,7 +140,7 @@ if start_up == '1':
             export_id = data.get("info", {}).get("export_id", "")
             print("Export ID:", export_id)
             
-            # Задержка в 1 минуту перед вторым запросом (в миллисекундах)
+            # Задержка в 5 минут перед вторым запросом (в миллисекундах)
             time_delay = 1 * 60
             time.sleep(time_delay)
 
@@ -147,9 +163,6 @@ if start_up == '1':
     else:
         print("Ошибка при выполнении первого запроса")
         print("Статус код:", response.status_code)
-
-    # Загрузка данных из JSON в базу данных
-    load_data_from_json()
 else:
     print("Системная переменная start_up не равна '1', код не выполняется при старте сервера.")
 
@@ -172,6 +185,71 @@ else:
 
 
 
+
+
+
+def load_data_from_json():
+    data = json.loads(json_data)
+    items = data['info']['items']
+    fields = data['info']['fields']
+
+    db = 'data_gc.db'  # Указываем конкретную базу данных
+    conn = sqlite3.connect(db)
+    cursor = conn.cursor()
+
+    for item in items:
+        user_data = dict(zip(fields, item))
+        # Проверяем наличие значений для полей и устанавливаем значения по умолчанию, если они отсутствуют
+        user_data.setdefault('vk_id', '')
+        user_data.setdefault('chat_id', '')
+        user_data.setdefault('ws_st', '')
+        user_data.setdefault('ws_stop', '')
+        user_data.setdefault('web_st', '')
+        user_data.setdefault('fin_prog', '')
+        user_data.setdefault('shop_st', '')
+        user_data.setdefault('curator', '')
+        user_data.setdefault('pr1', '')
+        user_data.setdefault('pr2', '')
+        user_data.setdefault('pr3', '')
+        user_data.setdefault('pr4', '')
+        user_data.setdefault('pr5', '')
+        user_data.setdefault('ad_url', '')
+
+        # Убираем плюс в начале телефона, если он присутствует
+        if 'Телефон' in user_data and user_data['Телефон'].startswith('+'):
+            user_data['Телефон'] = user_data['Телефон'][1:]
+
+        query = '''
+        INSERT INTO contacts (
+         name, phone, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator
+        ) VALUES (
+         :Имя, :Телефон, :Email, :vk_id, :chat_id, :ws_st, :ws_stop, :web_st, :fin_prog, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :ad_url, :curator
+        )
+        '''
+        cursor.execute(query, user_data)
+
+    conn.commit()
+    conn.close()
+
+@app.before_first_request
+def before_first_request():
+    load_data_from_json()
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
 
     
 def randomize_message(template):