Update app.py

app.py

@@ -1595,7 +1595,7 @@ def add_or_update_contact(contact_data):
     conn.commit()
     replace_null_with_empty_string(conn)
     conn.close()
-@app.route('/add_data_ver_cur', methods=['GET'])
+@app.route('/ver_cur', methods=['GET'])
 def add_data_ver_cur():
     global current_curator_index
 
@@ -1635,7 +1635,58 @@ def add_data_ver_cur():
         return jsonify({'status': 'error', 'message': str(e)}), 500
 
 
+@app.route('/ver_bonus', methods=['GET'])
+def add_data_ver_cur():
+    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" назначение куратора
+    
+    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]
+        current_curator_index = (current_curator_index + 1) % len(curators)
+    else:
+        user_data['curator'] = user_data.get('curator', '')
+
+    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'] = '1' if phone_verification_response else '0'
+    else:
+        user_data['ws_st'] = user_data.get('ws_st', '')
 
+    # Обработка pr1
+    email = user_data.get('email')
+    new_pr1 = user_data.get('pr1')
+    if email and new_pr1:
+        conn = sqlite3.connect(DATABASE_NAME3)
+        cursor = conn.cursor()
+        cursor.execute("SELECT pr1 FROM contacts WHERE email = ?", (email,))
+        result = cursor.fetchone()
+        if result and result[0]:
+            user_data['pr1'] = str(int(result[0]) + int(new_pr1))
+        else:
+            user_data['pr1'] = new_pr1
+        conn.close()
+
+    try:
+        add_or_update_contact(user_data)
+        return jsonify({'status': 'success', 'message': f'User added with curator {user_data.get("curator", "not assigned")}'})
+    except Exception as e:
+        logging.error(f"Error adding user: {e}")
+        return jsonify({'status': 'error', 'message': str(e)}), 500