From 489d470c7b90907784fe8d58f32899ab0f588118 Mon Sep 17 00:00:00 2001
From: admin <fakc445@gmail.com>
Date: Fri, 15 Aug 2025 04:22:03 +0300
Subject: [PATCH] feat: add response for users with existing active assemblies

---
 routes/assembly.py | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/routes/assembly.py b/routes/assembly.py
index 2ed9313..b134ae2 100644
--- a/routes/assembly.py
+++ b/routes/assembly.py
@@ -56,6 +56,22 @@ def create_assembly():
                 'statusCode': 'USER_ALREADY_HAS_ACTIVE_ASSEMBLY'
             }
             return jsonify(response)
+        assembled_assembly = (
+            database.Assembly.query
+            .filter(
+                database.Assembly.order_id == order_id,
+                database.Assembly.ended_at != None
+            )
+            .first()
+        )
+        if assembled_assembly:
+            response = {
+                'ok': False,
+                'message': 'Вы уже собирали этот товар',
+                'assemblyId': assembled_assembly.id,
+                'statusCode': 'USER_ALREADY_HAS_ACTIVE_ASSEMBLY',
+            }
+            return jsonify(response)
         assembly = database.Assembly(user_id=user_id,
                                      order_id=order_id,
                                      state=AssemblyState.NOT_STARTED,
@@ -79,6 +95,7 @@ def create_assembly():
         }
         return jsonify(response)
 
+
 def close_assembly_by_id(
         assembly_id: int,
 ):
@@ -111,6 +128,7 @@ def close_assembly_by_id(
 
     return sipro_response
 
+
 @assembly_blueprint.post('/close')
 def close_assembly():
     args = request.json