Update app.py

app.py

@@ -806,23 +806,26 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"Processing user with email: {email}")
     
     # Проверка существования пользователя в базе данных по email
-    cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
+    cursor.execute("SELECT b_fin FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
     logging.debug(f"User found: {user}")
 
-    # Вынесение увеличения значения web_st в отдельный блок
-    web_st_value = 1  # Инициализация значения web_st
+    # Вынесение увеличения значения b_fin в отдельный блок
+    b_fin_value = 1  # Инициализация значения b_fin
     if user:
-        # Проверка текущего значения web_st и его инкрементация
-        current_web_st = user[0] if user[0] is not None and user[0] != "" else 0
-        web_st_value = int(current_web_st) + 1
-        logging.debug(f"Calculated web_st_value: {web_st_value}")
+        # Проверка текущего значения b_fin и его инкрементация
+        current_b_fin = user[0] if user[0] is not None and user[0] != "" else 0
+        if user_data.get('finished') == "True":
+            b_fin_value = int(current_b_fin) + 1
+        else:
+            b_fin_value = current_b_fin
+        logging.debug(f"Calculated b_fin_value: {b_fin_value}")
 
-        # Обновление значения web_st
-        cursor.execute("UPDATE contacts SET web_st = ? WHERE email = ?", (web_st_value, email))
+        # Обновление значения b_fin
+        cursor.execute("UPDATE contacts SET b_fin = ? WHERE email = ?", (b_fin_value, email))
         conn.commit()
         conn.close()
-        logging.debug(f"User {email} web_st updated to {web_st_value}")
+        logging.debug(f"User {email} b_fin updated to {b_fin_value}")
     else:
         conn.close()
         logging.debug(f"User {email} not found, proceeding with insert")
@@ -867,8 +870,8 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         transformed_data['phone'] = phone
     logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
-    # Добавление значения web_st в данные для вставки
-    transformed_data['web_st'] = web_st_value
+    # Добавление значения b_fin в данные для вставки
+    transformed_data['b_fin'] = b_fin_value
 
     # Обновление данных пользователя в базе данных
     if user:
@@ -895,7 +898,6 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     logging.debug(f"User with email {email} processed successfully")
 
 
-
 @app.route('/send_get_request', methods=['GET'])
 def send_get_request():
     token = request.args.get('token')
@@ -940,7 +942,6 @@ def send_get_request():
         return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code
 
 
-
 @app.route('/webhookbz', methods=['POST'])
 def webhookbz():
     api_sys_control = request.args.get('api_sys')
@@ -1007,7 +1008,6 @@ def webhookbz():
 
 
 
-
 
 @app.route('/biz_v', methods=['GET'])
 def biz_v():