diff --git a/api/app/services/sqlite_service.py b/api/app/services/sqlite_service.py index e96d1d9..682e458 100644 --- a/api/app/services/sqlite_service.py +++ b/api/app/services/sqlite_service.py @@ -65,6 +65,7 @@ async def upsert_order(sync_run_id: str, order_number: str, order_date: str, delivery_cost, discount_total) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON CONFLICT(order_number) DO UPDATE SET + customer_name = excluded.customer_name, status = CASE WHEN orders.status = 'IMPORTED' AND excluded.status = 'ALREADY_IMPORTED' THEN orders.status @@ -133,6 +134,7 @@ async def save_orders_batch(orders_data: list[dict]): delivery_cost, discount_total) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON CONFLICT(order_number) DO UPDATE SET + customer_name = excluded.customer_name, status = CASE WHEN orders.status = 'IMPORTED' AND excluded.status = 'ALREADY_IMPORTED' THEN orders.status