Update app.py

app.py

@@ -1627,6 +1627,160 @@ def gc_forms():
 
 
 
+# Функция для проверки номера телефона
+def verify_phone_number(phone_number):
+    verifikation_start = os.getenv('verifikation_start')
+
+    if verifikation_start == "1":
+
+
+        full_url_ver = f"{wa_url}{wa_ak}{ws_url_ver}{wa_api_key}"
+
+        payload = json.dumps({
+            "phoneNumber": phone_number
+        })
+        headers = {
+            'Content-Type': 'application/json'
+        }
+
+        response = requests.post(full_url_ver, headers=headers, data=payload)
+
+        if response.status_code == 200:
+            result = response.json()
+            return result
+        else:
+            return {"existsWhatsapp": False}
+    else:
+        return {"existsWhatsapp": False}
+
+# Flask route для добавления или обновления контакта с проверкой номера
+@app.route('/add_data_ver', methods=['GET'])
+def add_data_ver():
+    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')
+        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')
+        canal = request.args.get('canal', '')
+
+        if not name or not phone or not email:
+            return "Parameters 'name', 'phone', and 'email' are required.", 400
+
+        # Очистка номера телефона от знака "+"
+        if phone.startswith('+'):
+            phone = phone[1:]
+
+        # Верификация номера телефона
+        verification_result = verify_phone_number(phone)
+        ws_status = verification_result.get('existsWhatsapp', False)
+
+        # Получение текущего времени в московском часовом поясе
+        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:
+            update_query = '''
+                UPDATE contacts SET
+                    name = ?, email = ?, vk_id = ?, chat_id = ?, ws_st = ?, ws_stop = ?, 
+                    web_st = ?, fin_prog = ?, shop_st = ?, ad_url = ?, curator = ?, key_pr = ?, n_con = ?, 
+                    canal = ?, data_t = ?
+            '''
+            params = [name, email, vk_id, chat_id, ws_status, ws_stop, web_statys, fin_progress,
+                      shop_statys_full, ad_url, curator, key_pr, n_con, canal, data_t]
+
+            if pr1 is not None:
+                update_query += ", pr1 = ?"
+                params.append(pr1)
+            if pr2 is not None:
+                update_query += ", pr2 = ?"
+                params.append(pr2)
+            if pr3 is not None:
+                update_query += ", pr3 = ?"
+                params.append(pr3)
+            if pr4 is not None:
+                update_query += ", pr4 = ?"
+                params.append(pr4)
+            if pr5 is not None:
+                update_query += ", pr5 = ?"
+                params.append(pr5)
+
+            update_query += " WHERE phone = ? OR email = ?"
+            params.extend([phone, email])
+
+            cursor.execute(update_query, params)
+        else:
+            insert_query = '''
+                INSERT INTO contacts (
+                    name, phone, email, vk_id, chat_id, ws_st, ws_stop, web_st, fin_prog, 
+                    shop_st, ad_url, curator, key_pr, n_con, canal, data_t
+            '''
+            params = [name, phone, email, vk_id, chat_id, ws_status, ws_stop, web_statys, fin_progress,
+                      shop_statys_full, ad_url, curator, key_pr, n_con, canal, data_t]
+
+            if pr1 is not None:
+                insert_query += ", pr1"
+                params.append(pr1)
+            if pr2 is not None:
+                insert_query += ", pr2"
+                params.append(pr2)
+            if pr3 is not None:
+                insert_query += ", pr3"
+                params.append(pr3)
+            if pr4 is not None:
+                insert_query += ", pr4"
+                params.append(pr4)
+            if pr5 is not None:
+                insert_query += ", pr5"
+                params.append(pr5)
+
+            insert_query += ") VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?"
+            placeholders = ["?"] * len(params)
+
+            if pr1 is not None:
+                insert_query += ", ?"
+                placeholders.append("?")
+            if pr2 is not None:
+                insert_query += ", ?"
+                placeholders.append("?")
+            if pr3 is not None:
+                insert_query += ", ?"
+                placeholders.append("?")
+            if pr4 is not None:
+                insert_query += ", ?"
+                placeholders.append("?")
+            if pr5 is not None:
+                insert_query += ", ?"
+                placeholders.append("?")
+
+            insert_query += ")"
+            placeholders.append("?)")
+            insert_query = insert_query.replace("?", ", ".join(placeholders))
+
+            cursor.execute(insert_query, params)
+
+        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