<?php
namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Models\Product;
use Illuminate\Support\Facades\Http;
use App\Http\Controllers\Site\ReportController;
use App\Services\ProductPriceService;

// مدل محصول خود را ایمپورت کنید

class UpdateProductStatus extends Command
{
    /**
     * نام دستور که در زمان‌بندی استفاده می‌شود
     */
    protected $signature = 'product:update-status';

    /**
     * توضیحات دستور
     */
    protected $description = 'Updates product prices and auto closes/opens products';

    public function handle()
    {
        $this->info('Starting update...');

        // 0. فید zaarbox — reading_method به شکل key (مثل 1_29_5) با این فید sync می‌شود
        try {
            app(\App\Services\ZaarboxPriceService::class)->syncProductsFromApi();
        } catch (\Throwable $e) {
            \Illuminate\Support\Facades\Log::warning('Zaarbox product sync failed', ['message' => $e->getMessage()]);
        }

        // 1. فید قدیمی — reading_method به شکل name (سازگاری با پروژه‌های قدیمی)
        try {
            $RPrices = Http::timeout(40)->get('http://212.23.201.173:8381/price_list', [])->json();
        } catch (\Throwable $e) {
            $RPrices = null;
        }

        $CP = null;
        try{
            $cooper =Http::timeout(40)->get('https://www.livedata.ir/main/static/p.json', [])->json();
            if(isset($cooper['s_301006']) && isset($cooper['s_200103'])){
                $CP = (($cooper['s_301006']/1000000)*$cooper['s_200103'])*10;
//                Cnt::where('key', 'cu_price')
            }
        }catch (\Exception $e){}
        $products = Product::with([])->whereNotNull('reading_method')->get();
        $current_time = now()->format('H:i:s');

        foreach ($products as $product) {
            $show = ($current_time >= $product->auto_open_at && $current_time <= $product->auto_close_at);

            foreach (is_array($RPrices) ? $RPrices : [] as $RPrice) {
                if ($product->reading_method == $RPrice['name']) {
                    ProductPriceService::syncFromReference(
                        $product,
                        (int) $RPrice['price'],
                        (int) ($RPrice['profit'] ?? 0)
                    );

                    if($product->bubble== 1){
                        $ReportController = new ReportController();
                        $liquidGold= $ReportController->lastPrice();
                        $p = Product::find($product->id);

                        $p->amount = $RPrice['price'] / $liquidGold['price'];
                        $p->show = $show;
                        $p->save();

                    }
                }
            }

            if ($product->reading_method == 'مس' && $CP) {
                ProductPriceService::syncFromReference($product, (int) $CP, 0);
                Product::where('id', $product->id)->update(['show' => $show]);
            }
        }
        // 2. Auto Close/Open Logic
        // $this->auto_close_open(); -> کد داخل این تابع را اینجا قرار دهید

        $this->info('Product statuses updated successfully.');
    }
}