| Server IP : 54.94.228.101 / Your IP : 172.28.20.13 Web Server : Apache System : Linux ip-172-28-29-189 6.5.0-1014-aws #14~22.04.1-Ubuntu SMP Thu Feb 15 15:27:06 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.2.34-43+ubuntu22.04.1+deb.sury.org+1 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals, MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /var/www/html/vinumday2_0/app/Console/Commands/ |
Upload File : |
<?php
namespace App\Console\Commands;
use Symfony\Component\Console\Output\ConsoleOutput;
use Symfony\Component\Console\Helper\ProgressBar;
use Illuminate\Console\Command;
use App\Modules\PedidoVendaHasProduto\Models\PedidoVendaHasProduto;
use Illuminate\Support\Facades\Log;
use DB;
class AtualizaQuantidadeCanal extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'atualiza_quantidade_canal';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Atualiza Quantidade Original Canais';
protected $options;
/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
$this->output = new ConsoleOutput;
}
/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
$this->info(date('d/m/Y H:i:s') . " - START \n");
$dataAtual = date('Y-m-d H:i');
//Canais Liberados
$listaOfertas = PedidoVendaHasProduto::select(DB::raw('SUM(pedido_venda_has_produto.quantidade) qtde_vendida, canal_has_oferta.id_oferta, canal_has_oferta.id_canal, oferta.estoque'))
->join('pedido_venda', 'pedido_venda.id', '=', 'pedido_venda_has_produto.id_pedido_venda')
->join('canal_has_oferta', 'canal_has_oferta.id_oferta', '=', 'pedido_venda_has_produto.id_oferta')
->join('oferta', 'oferta.id', '=', 'canal_has_oferta.id_oferta')
// ->whereIn('tipo', ['BF','OU'])
->where('canal_has_oferta.id_canal', 31)
->groupBy('canal_has_oferta.id_oferta')
->groupBy('canal_has_oferta.id_canal')
->orderBy('canal_has_oferta.id_canal', 'ASC')
->orderBy('qtde_vendida', 'ASC')
->get();
$total = count($listaOfertas);
$progressBar = new ProgressBar($this->output, $total);
foreach ($listaOfertas as $item) {
$quantidade = $item->qtde_vendida + $item->estoque;
$sql = "UPDATE canal_has_oferta SET quantidade = {$quantidade}, qtde_vendida = {$item->qtde_vendida}, disponibilidade_canal = {$item->estoque} WHERE id_canal = {$item->id_canal} AND id_oferta = {$item->id_oferta} AND deleted_at IS NULL";
DB::update(DB::raw($sql));
$progressBar->advance();
$progressBar->finish();
}
$this->info(date('d/m/Y H:i:s') . " - DONE \n");
}
}