Update app.py

app.py

@@ -95,7 +95,7 @@ def init_db(db_name):
             pr3 TEXT,
             pr4 TEXT,
             pr5 TEXT,
-            ad_url TEXT,
+            gc_url TEXT,
             key_pr TEXT,
             n_con TEXT,
             canal TEXT,
@@ -306,7 +306,7 @@ def load_data_from_json(json_data):
         user_data.setdefault('pr3', '')
         user_data.setdefault('pr4', '')
         user_data.setdefault('pr5', '')
-        user_data.setdefault('ad_url', '')
+        user_data.setdefault('gc_url', '')
         user_data.setdefault('key_pr', '')
         user_data.setdefault('n_con', '')        
         user_data.setdefault('canal', '')
@@ -317,9 +317,9 @@ def load_data_from_json(json_data):
 
         query = '''
             INSERT INTO contacts (
-                name, phone, email, vk_id, chat_id, ws_st, ws_stop, web_st, fin_prog, b_city, b_fin, b_ban, b_ign, b_baners, b_butt, b_mess, shop_st, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, n_con, canal, data_t
+                name, phone, email, vk_id, chat_id, ws_st, ws_stop, web_st, fin_prog, b_city, b_fin, b_ban, b_ign, b_baners, b_butt, b_mess, shop_st, pr1, pr2, pr3, pr4, pr5, gc_url, curator, key_pr, n_con, canal, data_t
             ) VALUES (
-                :Имя, :Телефон, :Email, :vk_id, :chat_id, :ws_st, :ws_stop, :web_st, :fin_prog, :b_city, :b_fin, :b_ban, :b_ign, :b_baners, :b_butt, :b_mess, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :ad_url, :curator, :key_pr, :n_con, :canal, :data_t
+                :Имя, :Телефон, :Email, :vk_id, :chat_id, :ws_st, :ws_stop, :web_st, :fin_prog, :b_city, :b_fin, :b_ban, :b_ign, :b_baners, :b_butt, :b_mess, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :gc_url, :curator, :key_pr, :n_con, :canal, :data_t
             )
             '''
         cursor.execute(query, user_data)
@@ -449,169 +449,6 @@ def start_mailings():
         
 
 
-@app.route('/add_data_gc', methods=['GET'])
-def add_data_gc():
-    try:
-        api_sys_control = request.args.get('api_sys')
-
-        if api_sys_control != api_key_sys:
-            return "err api key", 200
-
-        name = request.args.get('name')
-        phone = request.args.get('phone')
-        email = request.args.get('email')
-        vk_id = request.args.get('vk_id', '')
-        chat_id = request.args.get('chat_id')
-        ws_statys = request.args.get('ws_st')
-        ws_stop = request.args.get('ws_stop')
-        web_statys = request.args.get('web_st', 0, type=int)
-        fin_progress = request.args.get('fin_prog', 0, type=int)
-        shop_statys_full = request.args.get('shop_st')
-        pr1 = request.args.get('pr1')
-        pr2 = request.args.get('pr2')
-        pr3 = request.args.get('pr3')
-        pr4 = request.args.get('pr4')
-        pr5 = request.args.get('pr5')
-        ad_url = request.args.get('ad_url')
-        curator = request.args.get('curator')
-        key_pr = request.args.get('key_pr', '')
-        n_con = request.args.get('n_con', '')
-        canal = request.args.get('canal', '')
-
-        if not name or not phone or not email:
-            return "Parameters 'name', 'phone', and 'email' are required.", 400
-
-        # Clean up phone number by removing any leading plus sign
-        if phone.startswith('+'):
-            phone = phone[1:]
-
-        # Получение текущего времени в московском часовом поясе
-        utc_now = datetime.utcnow()
-        msk_tz = pytz.timezone('Europe/Moscow')
-        msk_now = utc_now.replace(tzinfo=pytz.utc).astimezone(msk_tz)
-        data_t = msk_now.strftime('%Y-%m-%d %H:%M:%S')
-
-        conn = sqlite3.connect('data_gc.db')
-        cursor = conn.cursor()
-        cursor.execute('SELECT * FROM contacts WHERE phone = ? OR email = ?', (phone, email))
-        existing_contact = cursor.fetchone()
-
-        if existing_contact:
-            cursor.execute('''
-                UPDATE contacts SET
-                    name = ?, email = ?, vk_id = ?, chat_id = ?, ws_st = ?, ws_stop = ?, 
-                    web_st = ?, fin_prog = ?, shop_st = ?, pr1 = ?, pr2 = ?, 
-                    pr3 = ?, pr4 = ?, pr5 = ?, ad_url = ?, curator = ?, key_pr = ?, n_con = ?, 
-                    canal = ?, data_t = ?
-                WHERE phone = ? OR email = ?
-            ''', (name, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, 
-                  shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, n_con, 
-                  canal, data_t, phone, email))
-        else:
-            cursor.execute('''
-                INSERT INTO contacts (
-                    name, phone, email, vk_id, chat_id, ws_st, ws_stop, web_st, fin_prog, 
-                    shop_st, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, n_con, canal, data_t
-                ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
-            ''', (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, key_pr, n_con, canal, data_t))
-
-        conn.commit()
-        conn.close()
-
-        return f"Contact updated/added: {name} - {phone} - {email}", 200
-    except Exception as e:
-        print(f"Error adding/updating contact: {e}")
-        return "Internal Server Error", 500
-
-
-
-
-
-
-
-
-@app.route('/add_data_ras', methods=['GET'])
-def add_data_ras():
-    try:
-        api_sys_control = request.args.get('api_sys')
-
-        if api_sys_control != api_key_sys:
-            return "EUR 22", 200
-
-        name = request.args.get('name')
-        phone = request.args.get('phone')
-        email = request.args.get('email')
-        vk_id = request.args.get('vk_id', '')
-        chat_id = request.args.get('chat_id', '')
-        ws_statys = request.args.get('ws_st', '')
-        ws_stop = request.args.get('ws_stop', '')
-        web_statys = request.args.get('web_st', 0, type=int)
-        fin_progress = request.args.get('fin_prog', 0, type=int)
-        shop_statys_full = request.args.get('shop_st', '')
-        pr1 = request.args.get('pr1', '')
-        pr2 = request.args.get('pr2', '')
-        pr3 = request.args.get('pr3', '')
-        pr4 = request.args.get('pr4', '')
-        pr5 = request.args.get('pr5', '')
-        ad_url = request.args.get('ad_url', '')
-        curator = request.args.get('curator', '')
-        key_pr = request.args.get('key_pr', '')
-        n_con = request.args.get('n_con', '')
-        canal = request.args.get('canal', '')
-
-        if not name or not phone or not email:
-            return "Parameters 'name', 'phone', and 'email' are required.", 400
-
-        # Clean up phone number by removing any leading plus sign
-        if phone.startswith('+'):
-            phone = phone[1:]
-
-        # Получение текущего времени в московском часовом поясе
-        utc_now = datetime.utcnow()
-        msk_tz = pytz.timezone('Europe/Moscow')
-        msk_now = utc_now.replace(tzinfo=pytz.utc).astimezone(msk_tz)
-        data_t = msk_now.strftime('%Y-%m-%d %H:%M:%S')
-
-        conn = sqlite3.connect('data1.db')
-        cursor = conn.cursor()
-        cursor.execute('SELECT * FROM contacts WHERE phone = ? OR email = ?', (phone, email))
-        existing_contact = cursor.fetchone()
-
-        if existing_contact:
-            cursor.execute('''
-                UPDATE contacts SET
-                    name = ?, email = ?, vk_id = ?, chat_id = ?, ws_st = ?, ws_stop = ?, 
-                    web_st = ?, fin_prog = ?, shop_st = ?, pr1 = ?, pr2 = ?, 
-                    pr3 = ?, pr4 = ?, pr5 = ?, ad_url = ?, curator = ?, key_pr = ?, n_con = ?, 
-                    canal = ?, data_t = ?
-                WHERE phone = ? OR email = ?
-            ''', (name, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, 
-                  shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, n_con, 
-                  canal, data_t, phone, email))
-        else:
-            cursor.execute('''
-                INSERT INTO contacts (
-                    name, phone, email, vk_id, chat_id, ws_st, ws_stop, web_st, fin_prog, 
-                    shop_st, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, n_con, canal, data_t
-                ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
-            ''', (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, key_pr, n_con, canal, data_t))
-
-        conn.commit()
-        conn.close()
-
-        return f"Contact updated/added: {name} - {phone} - {email}", 200
-    except Exception as e:
-        print(f"Error adding/updating contact: {e}")
-        return "Internal Server Error", 500
-
-
-
-    
-
-
-       
 
 
 
@@ -721,7 +558,7 @@ def data_gc_tab_out():
         cursor.execute('''
             SELECT id, name, phone, email, vk_id, chat_id, ws_st, ws_stop, web_st, fin_prog,
             b_city, b_fin, b_ban, b_ign, b_baners, b_butt, b_mess, shop_st, curator,
-            pr1, pr2, pr3, pr4, pr5, ad_url, key_pr, n_con, canal, data_t, utm_source, utm_medium, utm_campaign, utm_term, utm_content
+            pr1, pr2, pr3, pr4, pr5, gc_url, key_pr, n_con, canal, data_t, utm_source, utm_medium, utm_campaign, utm_term, utm_content
             FROM contacts
         ''')
         contacts = cursor.fetchall()
@@ -734,7 +571,7 @@ def data_gc_tab_out():
             'b_ban': contact[12], 'b_ign': contact[13], 'b_baners': contact[14], 'b_butt': contact[15],
             'b_mess': contact[16], 'shop_st': contact[17], 'curator': contact[18], 'pr1': contact[19],
             'pr2': contact[20], 'pr3': contact[21], 'pr4': contact[22], 'pr5': contact[23],
-            'ad_url': contact[24], 'key_pr': contact[25], 'n_con': contact[26], 'canal': contact[27],
+            'gc_url': contact[24], 'key_pr': contact[25], 'n_con': contact[26], 'canal': contact[27],
             'data_t': contact[28],'utm_source': contact[29], 'utm_medium': contact[30], 'utm_campaign': contact[31],
             'utm_term': contact[32], 'utm_content': contact[33]
         } for contact in contacts]