boursecu_server/app/Services/ConfigService.php

<?php

namespace App\Services;

use App\Models\Cnt;
use App\Models\Price;
use App\Models\PriceCandle;
use App\Models\Product;
use App\Models\Setting;
use Carbon\Carbon;
use Symfony\Component\HttpKernel\Exception\UnprocessableEntityHttpException;

class ConfigService
{
    public const PRICE_PROVIDERS = ['montzar', 'main_product', 'zaarbox'];

    public function Config($name)
    {
        return $this->get($name, false);
    }

    /**
     * مقدار setting؛ اگر نبود از config/price_providers.php یا default پارامتر.
     */
    public function get(string $key, $default = null)
    {
        try {
            $row = Setting::where('key', $key)->first();

            if ($row !== null && $row->is_active && $row->value !== null && $row->value !== '') {
                return $row->value;
            }
        } catch (\Throwable $e) {
            // DB در دسترس نیست (deploy / .env اشتباه) — از config/price_providers.php استفاده شود
        }

        $fromFile = config("price_providers.{$key}");

        return $fromFile !== null ? $fromFile : $default;
    }

    public function getString(string $key, string $default = ''): string
    {
        $value = $this->get($key, $default);

        return trim((string) ($value === false ? $default : $value));
    }

    public function getBool(string $key, bool $default = false): bool
    {
        $value = $this->get($key, $default);

        if ($value === false || $value === null || $value === '') {
            return $default;
        }

        return filter_var($value, FILTER_VALIDATE_BOOLEAN);
    }

    /** فروشگاهی (قطره / کشکول) — روت‌ها و رفتار store فقط وقتی true باشد فعال می‌شوند */
    public function isStore(): bool
    {
        return $this->getBool('is_store', false);
    }

    public function getInt(string $key, int $default = 0): int
    {
        $value = $this->get($key, $default);

        return (int) ($value === false || $value === null || $value === '' ? $default : $value);
    }

    /** X-Client-Id برای API خارجی (HMAC) — اول settings، بعد .env NODE_CLIENT_ID */
    public function nodeClientId(): string
    {
        $fromDb = $this->getString('node_client_id', '');

        return $fromDb !== '' ? $fromDb : (string) env('NODE_CLIENT_ID', '');
    }

    /** کلید امضای HMAC — اول settings، بعد .env NODE_SHARED_SECRET */
    public function nodeSharedSecret(): string
    {
        $fromDb = $this->getString('node_shared_secret', '');

        return $fromDb !== '' ? $fromDb : (string) env('NODE_SHARED_SECRET', '');
    }

    /** اختلاف خرید نمایش (/api/price/last) — fee_single / buy_fee */
    public function displayBuySpreadRial(): float
    {
        $feeSingle = (float) $this->get('fee_single', 0);
        $buyFee = (float) $this->get('buy_fee', $feeSingle);

        return $buyFee > 0 ? $buyFee : $feeSingle;
    }

    /** اختلاف فروش نمایش — fee_single / sell_fee */
    public function displaySellSpreadRial(): float
    {
        $feeSingle = (float) $this->get('fee_single', 0);
        $sellFee = (float) $this->get('sell_fee', $feeSingle);

        return $sellFee > 0 ? $sellFee : $feeSingle;
    }

    /**
     * sell / buy / price_last — یک منبع حقیقت برای lastPrice و buildFromDatabase.
     *
     * @param  float  $priceValue  قیمت پایه (ریال/گرم) — از API یا DB
     * @param  string|null  $priceSource  montzar | zaarbox | main_product | database_last | null
     * @param  array{montzar_open_buy?:bool,montzar_open_sell?:bool}  $montzarFlags  فقط وقتی API تازه خوانده شده
     * @return array{sell:int,buy:int,priceLast:int}
     */
    public function buildTradeDisplayPrices(
        float $priceValue,
        ?string $priceSource = null,
        array $montzarFlags = []
    ): array {
        $diffBuy = (float) $this->displayBuySpreadRial();
        $diffSell = (float) $this->displaySellSpreadRial();
        $feeSingle = (float) $this->get('fee_single', 0);

        $openBuy = true;
        $openSell = true;

        if ($priceSource === 'montzar') {
            $montzarProfit = (float) $this->get('montzar_diff', 0);
            $finalBuyDiff = $diffBuy + $montzarProfit;
            $finalSellDiff = $diffSell + $montzarProfit;
            $openBuy = $montzarFlags['montzar_open_buy'] ?? $this->getBool('montzar_open_buy', true);
            $openSell = $montzarFlags['montzar_open_sell'] ?? $this->getBool('montzar_open_sell', true);

            $sell = $openSell ? (int) ceil($priceValue - $finalSellDiff) : 0;
            $buy = $openBuy ? (int) ceil($priceValue + $finalBuyDiff) : 0;
            $priceLast = (int) ceil($priceValue + $finalBuyDiff);

            return compact('sell', 'buy', 'priceLast');
        }

        $sell = $openSell ? (int) ceil($priceValue - $feeSingle) : 0;
        $buy = $openBuy ? (int) ceil($priceValue + $feeSingle) : 0;
        $priceLast = (int) ceil($priceValue + $feeSingle);

        $provider = $this->priceProvider();
        if (in_array($provider, ['main_product', 'zaarbox'], true)) {
            $sell = $openSell ? (int) ceil($priceValue - $diffSell) : 0;
            $buy = $openBuy ? (int) ceil($priceValue + $diffBuy) : 0;
            $priceLast = (int) ceil($priceValue + $diffBuy);
        }

        return compact('sell', 'buy', 'priceLast');
    }

    /**
     * تنها منبع فعال قیمت — montzar | main_product | zaarbox
     *
     * اولویت:
     * 1) price_provider (یا price_primary_source قدیمی) — فقط مقادیر معتبر
     * 2) montzar_price=true → montzar (ابشده خانگی و پروژه‌های فعلی)
     * 3) main_product_price=true → main_product (legacy)
     * 4) پیش‌فرض فایل: montzar
     */
    public function priceProvider(): string
    {
        foreach (['price_provider', 'price_primary_source'] as $key) {
            $explicit = strtolower($this->getString($key, ''));
            if (in_array($explicit, self::PRICE_PROVIDERS, true)) {
                return $explicit;
            }
        }

        if ($this->getBool('montzar_price', false)) {
            return 'montzar';
        }

        if ($this->getBool('main_product_price', false)) {
            return 'main_product';
        }

        $default = strtolower((string) config('price_providers.price_provider', 'montzar'));

        return in_array($default, self::PRICE_PROVIDERS, true) ? $default : 'montzar';
    }

    /**
     * محصولات متصل به کیف اصلی — setting `main_wallet_products`.
     * مقدار: idها با کاما (مثل «13,25») یا آرایه JSON (مثل «[13,25]»).
     * موجودی این محصولات = gold کیف اصلی (دارایی جدا ندارند).
     * فقط opt-in: اگر ست نباشد آرایه خالی برمی‌گردد و رفتار قبلی حفظ می‌شود.
     */
    public function mainWalletProductIds(): array
    {
        $raw = trim($this->getString('main_wallet_products', ''));
        if ($raw === '') {
            return [];
        }

        $decoded = json_decode($raw, true);
        $parts = is_array($decoded) ? $decoded : explode(',', $raw);

        $ids = [];
        foreach ($parts as $part) {
            $id = (int) trim((string) $part);
            if ($id > 0) {
                $ids[] = $id;
            }
        }

        return array_values(array_unique($ids));
    }

    public function isMainWalletProduct(int $productId): bool
    {
        return in_array($productId, $this->mainWalletProductIds(), true);
    }

    /**
     * شناسه محصول آبشده: اول settings، بعد const.
     * مقدار settings می‌تواند id عددی (مثل 13) یا reading_method (مثل estjt_...) باشد.
     */
    public function mainProductId(): ?int
    {
        $product = $this->mainProduct();

        return $product?->id;
    }

    public function mainProduct(): ?Product
    {
        foreach ([$this->getString('main_product', ''), (string) (Cnt::where('key', 'main_product')->value('value') ?? '')] as $raw) {
            $raw = trim($raw);
            if ($raw === '') {
                continue;
            }

            if (is_numeric($raw)) {
                $product = Product::find((int) $raw);
                if ($product) {
                    return $product;
                }
            }

            $byMethod = Product::where('reading_method', $raw)->first();
            if ($byMethod) {
                return $byMethod;
            }
        }

        return null;
    }

    /** @deprecated از priceProvider() استفاده کن */
    public function pricePrimarySource(): string
    {
        $provider = $this->priceProvider();

        return in_array($provider, ['montzar'], true) ? $provider : 'montzar';
    }

    public function usesMontzarPricing(): bool
    {
        return $this->priceProvider() === 'montzar';
    }

    /** @deprecated منبع etehadie حذف شده */
    public function usesEtehadiePricing(): bool
    {
        return false;
    }

    public function usesMainProductPricing(): bool
    {
        return $this->priceProvider() === 'main_product';
    }

    public function usesZaarboxPricing(): bool
    {
        return $this->priceProvider() === 'zaarbox';
    }

    public function UpdateConfig($name, $value)
    {
        return Setting::updateOrCreate(
            ['key' => $name],
            ['value' => $value]
        );
    }

    public function trackDailyPriceExtreme(float $price): void
    {
        if ($price <= 0) {
            return;
        }

        $upSetting = Setting::where('key', 'up_price')->first();
        $downSetting = Setting::where('key', 'down_price')->first();

        if (!$upSetting || !$downSetting) {
            return;
        }

        $priceInt = (int) round($price);
        $today = now()->toDateString();
        $extremeDate = $this->Config('price_extreme_date');

        if ($extremeDate !== $today) {
            $this->UpdateConfig('up_price', $priceInt);
            $this->UpdateConfig('down_price', $priceInt);
            $this->UpdateConfig('price_extreme_date', $today);
            return;
        }

        $currentUp = (float) ($upSetting->value ?: 0);
        $currentDown = (float) ($downSetting->value ?: 0);

        if ($currentUp > 0 && $priceInt < (int) ($currentUp * 0.9)) {
            return;
        }

        if ($currentUp <= 0 || $priceInt > $currentUp) {
            $this->UpdateConfig('up_price', $priceInt);
        }
        if ($currentDown <= 0 || $priceInt < $currentDown) {
            $this->UpdateConfig('down_price', $priceInt);
        }
    }

    /**
     * بیشترین/کمترین قیمت پایه امروز — با اصلاح outlier در down_price.
     *
     * @return array{up: int, down: int}
     */
    public function resolvedDailyBaseExtremes(): array
    {
        $up = $this->getInt('up_price', 0);
        $down = $this->getInt('down_price', 0);

        $candle = PriceCandle::whereDate('date_at', now()->toDateString())->first();
        $candleHigh = $candle ? (int) round((float) $candle->high) : 0;
        $candleLow = $candle ? (int) round((float) $candle->low) : 0;

        if ($up > 0 && $down > 0 && $down < (int) ($up * 0.9)) {
            $correctedDown = $candleLow >= (int) ($up * 0.9) ? $candleLow : $up;
            $down = $correctedDown;
            $this->UpdateConfig('down_price', $correctedDown);
        }

        if ($up <= 0 || $down <= 0) {
            $fromTable = $this->filteredTodayMinMax();
            if ($up <= 0 && $fromTable['max'] > 0) {
                $up = $fromTable['max'];
            }
            if ($down <= 0 && $fromTable['min'] > 0) {
                $down = $fromTable['min'];
            }
        }

        if ($up <= 0 && $candleHigh > 0) {
            $up = $candleHigh;
        }
        if ($down <= 0 && $candleLow > 0) {
            $down = $candleLow;
        }

        if ($up > 0 && $down > 0 && $down > $up) {
            [$up, $down] = [$down, $up];
        }

        return ['up' => $up, 'down' => $down];
    }

    /**
     * @return array{min: int, max: int}
     */
    public function filteredTodayMinMax(): array
    {
        $prices = Price::query()
            ->whereDate('date_at', now()->toDateString())
            ->pluck('price')
            ->map(fn ($price) => (int) round((float) $price))
            ->filter(fn (int $price) => $price > 0)
            ->values();

        if ($prices->isEmpty()) {
            return ['min' => 0, 'max' => 0];
        }

        $max = (int) $prices->max();
        $threshold = (int) ($max * 0.9);
        $valid = $prices->filter(fn (int $price) => $price >= $threshold);

        if ($valid->isEmpty()) {
            return ['min' => $max, 'max' => $max];
        }

        return [
            'min' => (int) $valid->min(),
            'max' => $max,
        ];
    }

    public function isClosePriceEnabled(): bool
    {
        return $this->getBool('close_price', false);
    }

    /** @return array{start: string, end: string} */
    public function tradingHourBounds(): array
    {
        return [
            'start' => $this->normalizeTradingTime($this->getString('startDay', '00:00'), '00:00'),
            'end' => $this->normalizeTradingTime($this->getString('endDay', '23:59'), '23:59'),
        ];
    }

    private function normalizeTradingTime(string $value, string $default): string
    {
        $value = trim($value);
        if ($value === '') {
            $value = $default;
        }

        if (preg_match('/^(\d{1,2}):(\d{2})(?::(\d{2}))?$/', $value, $matches)) {
            return sprintf('%02d:%02d', (int) $matches[1], (int) $matches[2]);
        }

        return $default;
    }

    public function isOutsideTradingHours(?Carbon $now = null): bool
    {
        if (!$this->isClosePriceEnabled()) {
            return false;
        }

        $now = $now ?? Carbon::now();
        $bounds = $this->tradingHourBounds();
        [$startHour, $startMinute] = array_map('intval', explode(':', $bounds['start']));
        [$endHour, $endMinute] = array_map('intval', explode(':', $bounds['end']));

        $start = $now->copy()->startOfDay()->setTime($startHour, $startMinute);
        $end = $now->copy()->startOfDay()->setTime($endHour, $endMinute);

        return !$now->between($start, $end);
    }

    public function syncAppClosedFlag(?Carbon $now = null): bool
    {
        $closed = $this->isOutsideTradingHours($now);
        Cnt::where('key', 'app_closed')->update(['value' => $closed ? 'true' : 'false']);

        if ($closed) {
            $this->UpdateConfig('montzar_closed', 'true');
        }

        return $closed;
    }

    public function formatTradingTimeForDisplay(string $time): string
    {
        $normalized = $this->normalizeTradingTime($time, '00:00');

        return $normalized . ':00';
    }

    public function tradingClosedMessage(?Carbon $now = null): string
    {
        $bounds = $this->tradingHourBounds();
        $start = $this->formatTradingTimeForDisplay($bounds['start']);
        $end = $this->formatTradingTimeForDisplay($bounds['end']);

        return "فروشگاه در حال حاضر بسته است. ساعت کاری از {$start} تا {$end} می‌باشد.";
    }

    public function assertTradingOpen(?Carbon $now = null): void
    {
        if ($this->isOutsideTradingHours($now)) {
            throw new UnprocessableEntityHttpException($this->tradingClosedMessage($now));
        }
    }

    public function hasProductTradingWindow(?string $open, ?string $close): bool
    {
        if ($open === null || $close === null || trim($open) === '' || trim($close) === '') {
            return false;
        }

        return $this->formatProductTime($open) !== $this->formatProductTime($close);
    }

    public function formatProductTime(?string $time): string
    {
        if ($time === null || trim($time) === '') {
            return '00:00:00';
        }

        $time = trim($time);
        if (preg_match('/(\d{1,2}:\d{2}(?::\d{2})?)/', $time, $matches)) {
            $parts = explode(':', $matches[1]);

            return sprintf(
                '%02d:%02d:%02d',
                (int) ($parts[0] ?? 0),
                (int) ($parts[1] ?? 0),
                (int) ($parts[2] ?? 0)
            );
        }

        return '00:00:00';
    }

    public function isWithinTimeWindow(?string $open, ?string $close, ?Carbon $now = null): bool
    {
        if (!$this->hasProductTradingWindow($open, $close)) {
            return true;
        }

        $now = $now ?? Carbon::now();
        $current = $now->format('H:i:s');
        $openStr = $this->formatProductTime($open);
        $closeStr = $this->formatProductTime($close);

        return $current >= $openStr && $current <= $closeStr;
    }

    /** ساعت کاری سراسری (close_price) + بازه auto_open_at/auto_close_at هر محصول */
    public function isProductWithinTradingHours(Product $product, ?Carbon $now = null): bool
    {
        if ($this->isClosePriceEnabled() && $this->isOutsideTradingHours($now)) {
            return false;
        }

        return $this->isWithinTimeWindow($product->auto_open_at, $product->auto_close_at, $now);
    }

    public function productTradingClosedMessage(Product $product): string
    {
        $title = trim((string) ($product->title ?? 'محصول'));

        if ($this->hasProductTradingWindow($product->auto_open_at, $product->auto_close_at)) {
            $open = $this->formatProductTime($product->auto_open_at);
            $close = $this->formatProductTime($product->auto_close_at);

            return "محصول «{$title}» در حال حاضر بسته است. ساعت فعال‌سازی از {$open} تا {$close} می‌باشد.";
        }

        return $this->tradingClosedMessage();
    }

    public function assertProductTradingOpen(Product $product, ?Carbon $now = null): void
    {
        $this->assertTradingOpen($now);

        if (!$this->isProductWithinTradingHours($product, $now)) {
            throw new UnprocessableEntityHttpException($this->productTradingClosedMessage($product));
        }
    }
}