From 9979c2dceeab6b1ddfa4043071dbb12c51cbe691 Mon Sep 17 00:00:00 2001 From: admin Date: Thu, 20 Nov 2025 17:32:16 +0300 Subject: [PATCH] feat: better build docker command --- background/tasks.py | 3 ++- constants.py | 1 + queries/general.py | 6 +++--- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/background/tasks.py b/background/tasks.py index e908e0e..932e523 100644 --- a/background/tasks.py +++ b/background/tasks.py @@ -7,6 +7,7 @@ import background.update from backend.session import get_session from background.broker import taskiq_broker from buffer.core import TasksBuffer +from constants import DEFAULT_PROCESSING_PRICE from database import Marketplace, Company from utils import chunk_list @@ -70,7 +71,7 @@ async def reset_companies_with_zero_balance(): Company ) .where( - Company.balance <= 45, + Company.balance <= DEFAULT_PROCESSING_PRICE, Company.is_deleted == False, Company.is_archived == False, Marketplace.is_deleted == False diff --git a/constants.py b/constants.py index f9af533..341ddfd 100644 --- a/constants.py +++ b/constants.py @@ -2,3 +2,4 @@ import os import sys APP_PATH = os.path.dirname(sys.executable) if getattr(sys, "frozen", False) else os.path.dirname(__file__) +DEFAULT_PROCESSING_PRICE = 45 diff --git a/queries/general.py b/queries/general.py index 168c056..b71c413 100644 --- a/queries/general.py +++ b/queries/general.py @@ -2,8 +2,8 @@ from typing import Union, TypedDict from sqlalchemy import select, func, and_, cast, String, case, or_, exists from sqlalchemy.ext.asyncio import AsyncSession -from sqlalchemy.orm import joinedload +from constants import DEFAULT_PROCESSING_PRICE from database.sipro import * from database.sipro.enums.product import ProductRelationType from database.sipro.models.warehouses import MarketplaceProductFboWarehouseStock @@ -332,8 +332,8 @@ async def get_stocks_data( sell_from_price > price_recommended, is_paused, fbo_stock > 0 and prefer_fbo_over_fbs, - 45 > company.balance, - price_purchase > company.balance + DEFAULT_PROCESSING_PRICE > company.balance, + price_purchase + DEFAULT_PROCESSING_PRICE > company.balance ]) if zero_stock: response.append(base_dict)