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)