✅ article - уникальный, не NULL
✅ name - не NULL, минимум 3 символа
✅ brand - не NULL (по умолчанию "Unknown")
✅ category - не NULL
✅ product_type - не NULL (по умолчанию "simple")
✅ base_price - не NULL (по умолчанию 0.00)
✅ cost_price - не NULL (по умолчанию 0.00)

✅ article - должен существовать в pim_products
✅ salute_type - не NULL
⚠️ shots_count - РЕКОМЕНДУЕТСЯ для батарей, свечей, ракет
⚠️ caliber_inch - РЕКОМЕНДУЕТСЯ для батарей, свечей
⚠️ duration_sec - РЕКОМЕНДУЕТСЯ для фонтанов, дымов

VALID_SALUTE_TYPES = [
    'батарея',
    'фонтан',
    'римская свеча',
    'петарда',
    'ракета',
    'миномет',
    'набор',
    'вулкан',
    'колесо',
    'торт',
    'дым',
    'хлопушка',
    'бенгальские',
    'летающий',
    'наземный'
]

-- Проверка перед вставкой
SELECT article FROM pim_products WHERE article = :article;
SELECT code_1c FROM pim_products WHERE code_1c = :code_1c;
SELECT barcode FROM pim_products WHERE barcode = :barcode AND barcode IS NOT NULL;

def calculate_cost_price(base_price: Decimal, brand: str) -> Decimal:
    """
    Рассчитать себестоимость по правилам

    1. Найти правило для бренда
    2. Применить discount_percent
    3. Вернуть cost_price
    """

    # Получить правило из price_cost_rules
    rule = db.query(PimCostRules).filter(
        PimCostRules.brand == brand,
        PimCostRules.is_active == True
    ).order_by(PimCostRules.priority.desc()).first()

    if not rule:
        # Нет правила - скидка 0%
        return base_price

    # Применить скидку
    discount = rule.discount_percent / 100
    cost_price = base_price * (1 - discount)

    return cost_price.quantize(Decimal('0.01'))

# Обновляются все поля, кроме:
- article (никогда не меняется - PK)
- created_at (сохраняется оригинальное значение)

# Обязательно обновляется:
- updated_at (устанавливается в NOW())

# Если поле в новых данных NULL:
- НЕ затираем существующее значение
- Обновляем только если есть новое значение

async def update_product_from_1c(record: dict):
    """
    Обновить существующий товар из 1С

    1. Проверить существует ли товар
    2. Нормализовать новые данные
    3. Обновить только измененные поля
    4. Сохранить в БД
    """

    article = record['Артикул']

    # Проверить существует
    existing = await db.get(PimProduct, article=article)

    if not existing:
        # Создать новый
        await create_product_from_1c(record)
        return

    # Нормализовать данные
    normalized = await normalize_1c_record(record)

    # Обновить поля (НЕ затирать NULL)
    for field, value in normalized.items():
        if value is not None:
            setattr(existing, field, value)

    # Обновить updated_at
    existing.updated_at = datetime.utcnow()

    await db.commit()