<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Modules\ProdutoErp\Models\ProdutoErp;
use App\Modules\Empresa\Models\Empresa;
use App\Modules\PedidoEntrega\Models\PedidoEntrega;
use App\Services\ErpService;
use App\Services\GeralService;

use Illuminate\Support\Facades\Log;

class AtualizaProdutosTiny extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'atualiza_produtos_tiny';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Sincronização Automática dos Produtos Tiny';

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

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $produtosPorVez = 20;
        $empresas       = GeralService::buscarEmpresasIntegracao();
        $message        = "Registros sincronizados com sucesso!";
        
        foreach ($empresas as $empresa) {
            $query         = ProdutoErp::where('id_tiny', '=', NULL)->where('log_tiny', '=', NULL);
            $query         = $query->where('produto_id', '>', 4274)->where('empresa_id', '=', $empresa->id);
            $query         = $query->whereRaw('EXISTS (SELECT 1 FROM produto WHERE produto.id = produto_erp.produto_id AND produto.sincronizar_tiny = 1)');
            $listaProdutos = $query->limit($produtosPorVez)->get();
            if(count($listaProdutos) > 0){
                $sync = ErpService::sincronizarProdutos($listaProdutos, $empresa->id);
                if($sync->status == false){
                    $message = $sync;
                }
            }
        }

        if(is_array($message) || is_object($message)){
            Log::info('AtualizaProdutosTiny: ' . json_encode($message));
        }else{
            printf($message);
            printf("\n");
        }

        $this->atualizaPedidosEntrega();

    }

    public function atualizaPedidosEntrega(){

        $pedidosPorVez = 20;
        $Pedidos       = PedidoEntrega::where('disponibilidade', 1)->whereRaw('id_nota_fiscal_erp IS NOT NULL AND peso_nota_fiscal_erp IS NULL AND empresa_id IS NOT NULL AND log_nota IS NULL')->whereYear('data_solicitacao', '>=', 2020)->orderBy('id', 'DESC')->limit($pedidosPorVez)->get();

        foreach ($Pedidos as $pedido) {
            $resultado = GeralService::obterNotaFiscalPedido($pedido);
            if(isset($resultado['status']) && $resultado['status'] == false){
                $pedido->log_nota = json_encode($resultado['message']);
                $pedido->save();
            }
        }

        return true;
    }
}