Update app.py

app.py

@@ -1764,7 +1764,107 @@ def display_form():
 
 
 
+DATABASE6 = 'data_gc.db'
+# Функция для очистки номера телефона
+def clean_phone_number_ss(phone_number):
+    return re.sub(r'\D', '', phone_number)
+
+# Функция для вставки данных в базу данных
+def insert_data_ss(data):
+    conn = sqlite3.connect(DATABASE6)  # Подключаемся к базе данных
+    cursor = conn.cursor()
+
+    for row in data:
+        name = row.get('name', '')
+        phone = row.get('phone', '').lstrip('+')
+        email = row.get('email', '')
+        data_t = row.get('data_t', '').strip('"')
+
+        # Очистка номера телефона
+        phone = clean_phone_number_ss(phone)
+
+        cursor.execute("SELECT 1 FROM contacts WHERE email = ? OR phone = ?", (email, phone))
+        user_exists = cursor.fetchone()
+
+        if user_exists:
+            print(f"User with email {email} or phone {phone} already exists. Skipping insert.")
+            continue
+
+        columns = ['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', 'gc_url', 'key_pr', 'n_con', 'canal', 'data_on', 'data_t', 'utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content', 'gcpc']
+        values = [name, phone, email, row.get('vk_id', ''), row.get('chat_id', ''), row.get('ws_st', ''), row.get('ws_stop', ''), row.get('web_st', 0), row.get('fin_prog', 0), row.get('b_city', ''), row.get('b_fin', ''), row.get('b_ban', ''), row.get('b_ign', ''), row.get('b_baners', ''), row.get('b_butt', ''), row.get('b_mess', ''), row.get('shop_st', ''), row.get('curator', ''), row.get('pr1', ''), row.get('pr2', ''), row.get('pr3', ''), row.get('pr4', ''), row.get('pr5', ''), row.get('gc_url', ''), row.get('key_pr', ''), row.get('n_con', ''), row.get('canal', ''), row.get('data_on', ''), row.get('data_t', ''), row.get('utm_source', ''), row.get('utm_medium', ''), row.get('utm_campaign', ''), row.get('utm_term', ''), row.get('utm_content', ''), row.get('gcpc', '')]
+
+        # Исключение столбцов
+        excluded_columns = ['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', 'gc_url', 'key_pr', 'n_con', 'canal', 'data_on', 'data_t', 'utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content', 'gcpc']
+        columns = [col for col in columns if col not in excluded_columns]
+        values = [values[columns.index(col)] for col in columns]
+
+        placeholders = ', '.join(['?' for _ in columns])
+        columns_str = ', '.join(columns)
+
+        query = f'''
+            INSERT INTO contacts ({columns_str})
+            VALUES ({placeholders})
+        '''
+
+        try:
+            cursor.execute(query, values)
+        except Exception as e:
+            print(f"Error inserting row: {row}")
+            print(f"Error message: {str(e)}")
+            conn.rollback()
+            continue
+
+    conn.commit()
+    conn.close()
+
+# Маршрут для приема GET запроса 
+@app.route('/order', methods=['GET'])
+def from_shop_st():
+    try:
+        api_sys_control = request.args.get('api_sys')
+
+        if api_sys_control != api_key_sys:
+            return json.dumps({"error": "Unauthorized access"}), 403
+
+        email = request.args.get('email', '')
+        order = request.args.get('order', '')
+        status = request.args.get('status', '')
+        del_flag = request.args.get('del', '')
+
+        if not email:
+            return json.dumps({"error": "Email is required"}), 400
 
+        conn = sqlite3.connect(DATABASE6)
+        cursor = conn.cursor()
+
+        cursor.execute("SELECT shop_st FROM contacts WHERE email = ?", (email,))
+        result = cursor.fetchone()
+
+        if result:
+            shop_st = result[0] if result[0] else '{}'
+            shop_st_data = json.loads(shop_st)
+        else:
+            shop_st_data = {"opn_st": "1"}
+
+        if del_flag == '1':
+            shop_st_data = {"opn_st": "1"}
+        elif order and status:
+            shop_st_data[order] = status
+
+        shop_st_json = json.dumps(shop_st_data)
+
+        if result:
+            cursor.execute("UPDATE contacts SET shop_st = ? WHERE email = ?", (shop_st_json, email))
+        else:
+            cursor.execute("INSERT INTO contacts (email, shop_st) VALUES (?, ?)", (email, shop_st_json))
+
+        conn.commit()
+        conn.close()
+
+        return json.dumps(shop_st_data), 200
+
+    except Exception as e:
+        return json.dumps({"error": str(e)}), 500