Update app.py

app.py

@@ -10,8 +10,6 @@ token = os.getenv('token')  # Ваш токен
 
 @app.route('/save_db', methods=['GET'])
 def save_db():
-    err = 0
-
     if request.args.get('api') == api_key:
         # Получаем данные из запроса
         name = request.args.get('name')
@@ -22,19 +20,20 @@ def save_db():
         pr2 = request.args.get('pr2')
 
         # Проверка значений переменных
-        if not all([name, email, phone, grup_id, pr1, pr2]):
+        if not all([email, name, phone, grup_id, pr1, pr2]):
             return jsonify({"status": "error", "message": "Some required data is missing"}), 400
 
         # Создаем данные для отправки
         data = {
-            'list_id': grup_id,
-            'email': email,
-            'values': [
-                {'value': name, 'parameter_id': 'name'},
-                {'value': phone, 'parameter_id': 'phone'},
-                {'value': pr1, 'parameter_id': 'utm1'},
-                {'value': pr2, 'parameter_id': 'utm2'}
-            ]
+            "email": email,
+            "unconfirmed": True,  # Создаем неподтвержденного получателя
+            "values": [
+                {"parameter_id": "name", "value": name},
+                {"parameter_id": "phone", "value": phone},
+                {"parameter_id": "utm1", "value": pr1},
+                {"parameter_id": "utm2", "value": pr2}
+            ],
+            "tags": ["buyer", "regular customer"]  # Пример тегов
         }
 
         # Отправляем запрос
@@ -42,17 +41,13 @@ def save_db():
             'Authorization': f'Bearer {token}',
             'Content-Type': 'application/json'
         }
-        response = requests.post(f"{base_url}lists/{data['list_id']}/recipients", json=data, headers=headers)
+        response = requests.post(f"{base_url}lists/{grup_id}/recipients", json=data, headers=headers)
 
         # Проверяем статус ответа
         if response.status_code == 200:
-            err = 1
-            message = "Operation completed successfully"
+            return jsonify({"status": "success", "message": "Recipient created successfully"}), 200
         else:
-            message = f"Error: {response.status_code} - {response.text}"
-            err = 0
-
-        return jsonify({"status": "success" if err == 1 else "error", "message": message}), 200 if err == 1 else 400
+            return jsonify({"status": "error", "message": f"Error: {response.status_code} - {response.text}"}), 400
 
     else:
         return jsonify({"status": "error", "message": "Invalid API key"}), 401
@@ -69,13 +64,6 @@ def save_db():
 
 
 
-
-
-
-
-
-
-
 
 if __name__ == '__main__':
     app.run(host='0.0.0.0', port=int(os.environ.get('PORT', 7860)))