<?php

namespace App\Console\Commands;

use DB;
use App\Parameter;
use Carbon\Carbon;
use Illuminate\Console\Command;
use Symfony\Component\Console\Output\BufferedOutput;

class SyncB1Objects extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'b1:sync';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Sincroniza a través del Service Layer de B1 los objetos necesarios para el proyecto';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        // Obtener el branch actual.
        $bo_default_warehouse = $this->getCurrentWarehouse();



        $output = new \Symfony\Component\Console\Output\ConsoleOutput();
        $outputBuffer = new BufferedOutput;

        // $output->writeln("<info>Updating queries B1...</info>");
        // $output->writeln("<info>---------------------</info>");
        // $output->writeln("<info>Deleting queries B1...</info>");
        // $this->call('b1:delete-queries');
        // $output->writeln("<info>Creating queries B1...</info>");
        // $this->call('b1:create-queries');

        $output->writeln("<info>Initializing sync...</info>");
        $currentDate = Carbon::now();
        $output->writeln("<info>$currentDate</info>");
        $output->writeln("<info>Warehouse: $bo_default_warehouse</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-pricelists');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Price List...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:payment-terms');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Payment terms types...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-itemgroups');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Item groups done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-employees-info');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Employees Info done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-salespersons');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Sales Persons...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-salestaxcodes');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Sales tax codes done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-shippingtypes');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Shipping types done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-items');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Items done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-customers');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Customers done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call("b1:sync-inventory", ["warehouse" => $bo_default_warehouse]);
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Inventory done...</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-special-prices');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Special prices done...</info>");
        $output->writeln("<info>---------------------</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-item-manual-prices');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Item manual prices done...</info>");
        $output->writeln("<info>---------------------</info>");
        $output->writeln("<info>---------------------</info>");

        $this->call('b1:sync-credit-cards');
        $response = $outputBuffer->fetch();
        $output->writeln("<info>$response</info>");
        $output->writeln("<info>Credit cards done...</info>");
        $output->writeln("<info>---------------------</info>");
        $output->writeln("<info>---------------------</info>");

        $output->writeln("<info>End process...</info>");
        $currentDate = Carbon::now();
        $output->writeln("<info>$currentDate</info>");
        return 0;
    }

    function getCurrentWarehouse(){
        $parameters = Parameter::first();
        $warehouse = DB::connection('main-db')->table('service_cities')->where('name_database', $parameters->db_name)->first();

        return $warehouse->bo_default_warehouse;
    }
}