feat: better build docker command

This commit is contained in:
2025-11-20 17:32:16 +03:00
parent 5006c01fed
commit 9979c2dcee
3 changed files with 6 additions and 4 deletions

View File

@@ -7,6 +7,7 @@ import background.update
from backend.session import get_session from backend.session import get_session
from background.broker import taskiq_broker from background.broker import taskiq_broker
from buffer.core import TasksBuffer from buffer.core import TasksBuffer
from constants import DEFAULT_PROCESSING_PRICE
from database import Marketplace, Company from database import Marketplace, Company
from utils import chunk_list from utils import chunk_list
@@ -70,7 +71,7 @@ async def reset_companies_with_zero_balance():
Company Company
) )
.where( .where(
Company.balance <= 45, Company.balance <= DEFAULT_PROCESSING_PRICE,
Company.is_deleted == False, Company.is_deleted == False,
Company.is_archived == False, Company.is_archived == False,
Marketplace.is_deleted == False Marketplace.is_deleted == False

View File

@@ -2,3 +2,4 @@ import os
import sys import sys
APP_PATH = os.path.dirname(sys.executable) if getattr(sys, "frozen", False) else os.path.dirname(__file__) APP_PATH = os.path.dirname(sys.executable) if getattr(sys, "frozen", False) else os.path.dirname(__file__)
DEFAULT_PROCESSING_PRICE = 45

View File

@@ -2,8 +2,8 @@ from typing import Union, TypedDict
from sqlalchemy import select, func, and_, cast, String, case, or_, exists from sqlalchemy import select, func, and_, cast, String, case, or_, exists
from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.ext.asyncio import AsyncSession
from sqlalchemy.orm import joinedload
from constants import DEFAULT_PROCESSING_PRICE
from database.sipro import * from database.sipro import *
from database.sipro.enums.product import ProductRelationType from database.sipro.enums.product import ProductRelationType
from database.sipro.models.warehouses import MarketplaceProductFboWarehouseStock from database.sipro.models.warehouses import MarketplaceProductFboWarehouseStock
@@ -332,8 +332,8 @@ async def get_stocks_data(
sell_from_price > price_recommended, sell_from_price > price_recommended,
is_paused, is_paused,
fbo_stock > 0 and prefer_fbo_over_fbs, fbo_stock > 0 and prefer_fbo_over_fbs,
45 > company.balance, DEFAULT_PROCESSING_PRICE > company.balance,
price_purchase > company.balance price_purchase + DEFAULT_PROCESSING_PRICE > company.balance
]) ])
if zero_stock: if zero_stock:
response.append(base_dict) response.append(base_dict)