Update app.py

app.py

@@ -1579,15 +1579,16 @@ def add_data_ver_cur2():
         if phone_verification_response is not None:
             user_data['ws_st'] = phone_verification_response
 
-    # Добавляем order и status в shop_st
-    shop_st_data = {'order': order, 'status': status}
-    user_data['shop_st'] = json.dumps(shop_st_data, ensure_ascii=False)
-
     try:
+        # Шаг 1: Сначала записываем пользователя
         add_or_update_contact(user_data)
         if curator_on_off == "1":
             current_curator_index = (current_curator_index + 1) % len(curators)
 
+        # Шаг 2: Обновляем поле shop_st JSON-данными
+        shop_st_data = {'order': order, 'status': status}
+        update_shop_st(user_data['email'], shop_st_data)
+
         response_message = {
             'status': 'success',
             'message': f'User added with curator {user_data.get("curator", "not assigned")}'
@@ -1642,6 +1643,33 @@ def add_or_update_contact(contact_data):
     conn.close()
 
 
+def update_shop_st(email, shop_st_data):
+    conn = sqlite3.connect(DATABASE_NAME3)
+    cursor = conn.cursor()
+
+    cursor.execute("SELECT shop_st FROM contacts WHERE email = ?", (email,))
+    contact = cursor.fetchone()
+
+    if contact:
+        current_shop_st = contact[0]
+        if current_shop_st:
+            try:
+                current_shop_st = json.loads(current_shop_st)
+            except json.JSONDecodeError:
+                current_shop_st = {}
+        else:
+            current_shop_st = {}
+
+        current_shop_st.update(shop_st_data)
+        new_shop_st = json.dumps(current_shop_st, ensure_ascii=False)
+
+        update_query = "UPDATE contacts SET shop_st = ? WHERE email = ?"
+        cursor.execute(update_query, (new_shop_st, email))
+        conn.commit()
+
+    conn.close()
+
+