121 lines
3.4 KiB
PHP
121 lines
3.4 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use Carbon\Carbon;
|
|
use Codexshaper\WooCommerce\Facades\Product;
|
|
use Illuminate\Console\Command;
|
|
use App\Setting;
|
|
use App\Article;
|
|
use App\Mylog;
|
|
use App\Stock;
|
|
use Codexshaper\WooCommerce\Models\Product as ModelsProduct;
|
|
use Codexshaper\WooCommerce\Facades\Variation;
|
|
use Codexshaper\WooCommerce\Facades\Category;
|
|
use Illuminate\Support\Collection;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Mail;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
|
|
class ProductUpdateQta extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'product:updateqta';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'Aggiorna qta prodotti da GM';
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function handle()
|
|
{
|
|
set_time_limit(0);
|
|
ini_set("memory_limit", "512M");
|
|
$ora_update = Carbon::now();
|
|
$settingora = Setting::where('key', 'update_products_qta')->first();
|
|
$fromtime = str_replace('-', '', $settingora->value);
|
|
|
|
|
|
$loginizio = 'Inizio da ' . $ora_update . "\n";
|
|
|
|
|
|
/* $stocks = Stock::join(DB::raw('(SELECT Codice, MAX(DataOra) as data1 from T_WEB_Disponibile GROUP BY Codice ) b'), function($join)
|
|
{
|
|
$join->on('T_WEB_Disponibile.Codice', '=', 'b.Codice')
|
|
->on('T_WEB_Disponibile.DataOra', '=', 'b.data1');
|
|
} )
|
|
->where('data1','>=',$fromtime)
|
|
->orderBy('DataOra')
|
|
->get();
|
|
*/
|
|
$stocks = Stock::select('Codice', 'QtaDisponibile', DB::raw('MAX(DataOra) as data_recente'))
|
|
->where('DataOra', '>=', $fromtime)
|
|
->groupBy('Codice', 'QtaDisponibile')
|
|
->get();
|
|
$nrprodotti = $stocks->count();
|
|
|
|
foreach ($stocks as $stock) {
|
|
|
|
try {
|
|
|
|
$productsku = Product::where('sku', $stock->Codice)->first();
|
|
|
|
if ($productsku->count() > 0) {
|
|
$data1 = [
|
|
|
|
|
|
'stock_quantity' => $stock->QtaDisponibile,
|
|
|
|
];
|
|
$idprodotto = $productsku['parent_id'];
|
|
if ($idprodotto > 0) {
|
|
$variation = Variation::update($idprodotto, $productsku['id'], $data1);
|
|
} else {
|
|
Product::update($productsku['id'], $data1);
|
|
}
|
|
}
|
|
} catch (\Exception $e) {
|
|
//code error
|
|
}
|
|
}
|
|
$ora_fine = Carbon::now();
|
|
$title = '*** SITO DI PRODUZIONE *** ';
|
|
|
|
$lognrprodotti = $title . ' Prodotti qta aggiornati ' . $nrprodotti . "\n";
|
|
$logfine = 'Terminato il ' . $ora_fine . "\n";
|
|
$settingora->value = $ora_update;
|
|
$settingora->save();
|
|
|
|
Log::channel('updateproductsqta')->notice($loginizio . $lognrprodotti . $logfine);
|
|
Mail::raw($loginizio. $lognrprodotti . $logfine, function ($message) {
|
|
$message->to("log@fioredellavita.it");
|
|
//$message->bcc('luca@pecos.it');
|
|
$message->subject(Mylog::getSubjectEmail("Aggiornam. Qtà Prodotti:"));
|
|
|
|
});
|
|
|
|
}
|
|
}
|