Update app.py
Browse files
app.py
CHANGED
|
@@ -1777,6 +1777,14 @@ def add_user_bot(db_name, user_data, mapping_template3):
|
|
| 1777 |
conn = sqlite3.connect(db_name)
|
| 1778 |
cursor = conn.cursor()
|
| 1779 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1780 |
# Преобразование данных пользователя на основе шаблона сопоставления
|
| 1781 |
transformed_data = {db_column: user_data.get(json_key, "") for json_key, db_column in mapping_template3.items()}
|
| 1782 |
|
|
@@ -1785,9 +1793,6 @@ def add_user_bot(db_name, user_data, mapping_template3):
|
|
| 1785 |
insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
|
| 1786 |
insert_values = list(transformed_data.values())
|
| 1787 |
|
| 1788 |
-
logging.debug(f"Insert query: {insert_query}")
|
| 1789 |
-
logging.debug(f"Insert values: {insert_values}")
|
| 1790 |
-
|
| 1791 |
cursor.execute(insert_query, insert_values)
|
| 1792 |
conn.commit()
|
| 1793 |
conn.close()
|
|
|
|
| 1777 |
conn = sqlite3.connect(db_name)
|
| 1778 |
cursor = conn.cursor()
|
| 1779 |
|
| 1780 |
+
# Проверка наличия пользователя по email
|
| 1781 |
+
email = user_data.get('email')
|
| 1782 |
+
cursor.execute("SELECT 1 FROM contacts WHERE email = ?", (email,))
|
| 1783 |
+
if cursor.fetchone() is not None:
|
| 1784 |
+
logging.warning(f"User with email {email} already exists. Skipping insert.")
|
| 1785 |
+
conn.close()
|
| 1786 |
+
return
|
| 1787 |
+
|
| 1788 |
# Преобразование данных пользователя на основе шаблона сопоставления
|
| 1789 |
transformed_data = {db_column: user_data.get(json_key, "") for json_key, db_column in mapping_template3.items()}
|
| 1790 |
|
|
|
|
| 1793 |
insert_query = f"INSERT INTO contacts ({columns}) VALUES ({placeholders})"
|
| 1794 |
insert_values = list(transformed_data.values())
|
| 1795 |
|
|
|
|
|
|
|
|
|
|
| 1796 |
cursor.execute(insert_query, insert_values)
|
| 1797 |
conn.commit()
|
| 1798 |
conn.close()
|