DmitrMakeev
commited on
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()
|