Update app.py

app.py

@@ -50,7 +50,7 @@ status = "active"
 app = Flask(__name__, template_folder="./")
 app.config['DEBUG'] = True
 UPLOAD_FOLDER = 'static'
-
+logging.basicConfig(level=logging.DEBUG)
 if not os.path.exists(UPLOAD_FOLDER):
     os.makedirs(UPLOAD_FOLDER)
 
@@ -776,9 +776,11 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     cursor = conn.cursor()
 
     email = user_data.get('email')
+    logging.debug(f"Processing user with email: {email}")
     
     cursor.execute("SELECT web_st FROM contacts WHERE email = ?", (email,))
     user = cursor.fetchone()
+    logging.debug(f"User found: {user}")
 
     transformed_data = {}
     for json_key, db_column in mapping_template.items():
@@ -787,6 +789,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
             transformed_data[db_column] = "-1" if value else "0"
         else:
             transformed_data[db_column] = str(value)
+    logging.debug(f"Transformed data: {transformed_data}")
 
     required_fields = [
         "vk_id", "chat_id", "ws_st", "ws_stop", "web_st", "fin_prog",
@@ -798,17 +801,20 @@ def update_or_insert_user(db_name, user_data, mapping_template):
     for field in required_fields:
         if field not in transformed_data:
             transformed_data[field] = ""
+    logging.debug(f"Transformed data after adding required fields: {transformed_data}")
 
     if 'phone' in user_data:
         phone = user_data['phone']
         if phone.startswith('+'):
             phone = phone[1:]
         transformed_data['phone'] = phone
+    logging.debug(f"Transformed data after phone processing: {transformed_data}")
 
     web_st_value = 0
     if user:
         web_st_value = int(user[0]) if user[0] else 0
         web_st_value += 1
+    logging.debug(f"Calculated web_st_value: {web_st_value}")
 
     update_query = "UPDATE contacts SET "
     update_values = []
@@ -817,6 +823,7 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         update_values.append(value)
     update_query += "web_st = ? WHERE email = ?"
     update_values.extend([web_st_value, email])
+    logging.debug(f"Update query: {update_query} with values: {update_values}")
     cursor.execute(update_query, update_values)
 
     if cursor.rowcount == 0:
@@ -824,10 +831,12 @@ def update_or_insert_user(db_name, user_data, mapping_template):
         placeholders = ', '.join('?' for _ in transformed_data) + ", ?"
         insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
         insert_values = list(transformed_data.values()) + [web_st_value]
+        logging.debug(f"Insert query: {insert_query} with values: {insert_values}")
         cursor.execute(insert_query, insert_values)
 
     conn.commit()
     conn.close()
+    logging.debug(f"User with email {email} processed successfully")
 
 @app.route('/send_get_request', methods=['GET'])
 def send_get_request():
@@ -876,10 +885,6 @@ def send_get_request():
 
 
 
-
-
-
-
 @app.route('/biz_v', methods=['GET'])
 def biz_v():
     api_sys_control = request.args.get('api_sys')