Update app.py

app.py

@@ -223,16 +223,21 @@ def load_data_from_json(json_data):
 
     for item in items:
         user_data = dict(zip(fields, item))
-        
         # Проверяем наличие значений для полей и устанавливаем значения по умолчанию, если они отсутствуют
-        default_fields = [
-            'vk_id', 'chat_id', 'ws_st', 'ws_stop', 'web_st', 'fin_prog', 
-            'shop_st', 'curator', 'pr1', 'pr2', 'pr3', 'pr4', 'pr5', 
-            'ad_url', 'key_pr', 'canal', 'data_t'
-        ]
-        for field in default_fields:
-            if field not in user_data:
-                user_data[field] = ''
+        user_data.setdefault('vk_id', '')
+        user_data.setdefault('chat_id', '')
+        user_data.setdefault('ws_st', '')
+        user_data.setdefault('ws_stop', '')
+        user_data.setdefault('web_st', '')
+        user_data.setdefault('fin_prog', '')
+        user_data.setdefault('shop_st', '')
+        user_data.setdefault('curator', '')
+        user_data.setdefault('pr1', '')
+        user_data.setdefault('pr2', '')
+        user_data.setdefault('pr3', '')
+        user_data.setdefault('pr4', '')
+        user_data.setdefault('pr5', '')
+        user_data.setdefault('ad_url', '')
 
         # Убираем плюс в начале телефона, если он присутствует
         if 'Телефон' in user_data and user_data['Телефон'].startswith('+'):
@@ -240,38 +245,33 @@ def load_data_from_json(json_data):
 
         query = '''
         INSERT INTO contacts (
-         name, phone, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, canal, data_t  
+         name, phone, email, vk_id, chat_id, ws_statys, ws_stop, web_statys, fin_progress, shop_statys_full, pr1, pr2, pr3, pr4, pr5, ad_url, curator, key_pr, canal, data_t
         ) VALUES (
          :Имя, :Телефон, :Email, :vk_id, :chat_id, :ws_st, :ws_stop, :web_st, :fin_prog, :shop_st, :pr1, :pr2, :pr3, :pr4, :pr5, :ad_url, :curator, :key_pr, :canal, :data_t
         )
-
         '''
         cursor.execute(query, user_data)
 
     conn.commit()
     conn.close()
 
-
 @app.route('/start', methods=['GET'])
 def start():
     export_id = request.args.get('export_id')
     api_key_sys_control = request.args.get('api_sys')
 
     if export_id is None:
-        return jsonify({"error": "export_id is required"}), 400
+        return json.dumps({"error": "export_id is required"}), 400
 
     if api_key_sys_control != api_key_sys:
-        return jsonify({"error": "Unauthorized access"}), 403
+        return json.dumps({"error": "Unauthorized access"}), 403
 
     try:
-        json_data = send_second_request(export_id)  # Ваша функция для получения JSON данных
+        json_data = send_second_request(export_id)
         load_data_from_json(json_data)
         return "Data loaded successfully", 200
     except Exception as e:
-        return jsonify({"error": str(e)}), 500
-
-
-
+        return json.dumps({"error": str(e)}), 500