Update app.py

app.py

@@ -1551,124 +1551,6 @@ def add_data_ver_cur():
 
 
 
-@app.route('/add_data_ver_cur2', methods=['GET'])
-def add_data_ver_cur2():
-    global current_curator_index
-
-    veref_on_off = request.args.get('ver', '0')  # Включает "1" и выключает "0" верификацию номера вместо verifikation_start
-    curator_on_off = request.args.get('cur', '0')  # Включает "1" и выключает "0" назначение куратора
-    order = request.args.get('order', '')
-    status = request.args.get('status', '')
-    template_key = request.args.get('template_key', 'avp')
-    mapping_template_cur = mapp_templates.get(template_key, mt_avp)
-
-    user_data = {mapping_template_cur[key]: request.args.get(key, "") for key in mapping_template_cur}
-
-    logging.debug(f"Received data: {user_data}")
-
-    if curator_on_off == "1":
-        user_data['curator'] = curators[current_curator_index]
-
-    if veref_on_off == "1":
-        phone_number = user_data.get('phone', '')
-        if not phone_number:
-            logging.error("Phone number is empty")
-            return jsonify({'status': 'error', 'message': 'Phone number is empty'}), 400
-        
-        phone_verification_response = verify_phone_number(phone_number)
-        if phone_verification_response is not None:
-            user_data['ws_st'] = phone_verification_response
-
-    try:
-        # Шаг 1: Сначала записываем пользователя
-        add_or_update_contact(user_data, skip_defaults=True)
-        if curator_on_off == "1":
-            current_curator_index = (current_curator_index + 1) % len(curators)
-
-        # Шаг 2: Обновляем поле shop_st JSON-данными
-        shop_st_data = {order: status}
-        update_shop_st(user_data['email'], shop_st_data)
-
-        response_message = {
-            'status': 'success',
-            'message': f'User added with curator {user_data.get("curator", "not assigned")}'
-        }
-        if status:
-            response_message['status'] = status
-        return jsonify(response_message)
-    except Exception as e:
-        logging.error(f"Error adding user: {e}")
-        return jsonify({'status': 'error', 'message': str(e)}), 500
-
-
-def add_or_update_contact(contact_data, skip_defaults=False):
-    conn = sqlite3.connect(DATABASE_NAME3)
-    cursor = conn.cursor()
-
-    email = contact_data.get('email')
-    if not email:
-        logging.error(f"Missing email in contact data: {contact_data}")
-        return
-
-    utc_now = datetime.utcnow()
-    msk_tz = pytz.timezone('Europe/Moscow')
-    msk_now = utc_now.replace(tzinfo=pytz.utc).astimezone(msk_tz)
-    contact_data['data_t'] = msk_now.strftime('%Y-%m-%d %H:%M:%S')
-
-    # Список всех возможных полей
-    fields = [
-        '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'
-    ]
-
-    # Устанавливаем значения по умолчанию для отсутствующих полей, только если не указан флаг skip_defaults
-    if not skip_defaults:
-        for field in fields:
-            if field not in contact_data:
-                contact_data[field] = ''
-
-    placeholders = ", ".join([f"{field} = ?" for field in fields])
-
-    cursor.execute("SELECT id FROM contacts WHERE email = ?", (email,))
-    contact = cursor.fetchone()
-
-    if contact:
-        update_query = f"UPDATE contacts SET {placeholders} WHERE id = ?"
-        cursor.execute(update_query, (*[contact_data.get(field, '') for field in fields], contact[0]))
-    else:
-        insert_query = f"INSERT INTO contacts ({', '.join(fields)}) VALUES ({', '.join(['?' for _ in fields])})"
-        cursor.execute(insert_query, tuple(contact_data.get(field, '') for field in fields))
-
-    conn.commit()
-    conn.close()
-
-
-def update_shop_st(email, shop_st_data):
-    conn = sqlite3.connect(DATABASE_NAME3)
-    cursor = conn.cursor()
-
-    cursor.execute("SELECT shop_st FROM contacts WHERE email = ?", (email,))
-    contact = cursor.fetchone()
-
-    if contact:
-        current_shop_st = contact[0]
-        if current_shop_st:
-            try:
-                current_shop_st = json.loads(current_shop_st)
-            except json.JSONDecodeError:
-                current_shop_st = {}
-        else:
-            current_shop_st = {}
-
-        current_shop_st.update(shop_st_data)
-        new_shop_st = json.dumps(current_shop_st, ensure_ascii=False)
-
-        update_query = "UPDATE contacts SET shop_st = ? WHERE email = ?"
-        cursor.execute(update_query, (new_shop_st, email))
-        conn.commit()
-
-    conn.close()