code/app/Aggregate.php
<?php
namespace App;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Relations\HasMany;
use Auth;
use URL;
use Log;
use App\Helpers\Status;
use App\Models\Concerns\ModifiableTrait;
use App\Models\Concerns\ReducibleTrait;
use App\Models\Concerns\WithinGas;
use App\Events\AttachableToGas;
class Aggregate extends Model
{
use HasFactory, GASModel, ModifiableTrait, ReducibleTrait, WithinGas;
protected $dispatchesEvents = [
'created' => AttachableToGas::class
];
public function orders(): HasMany
{
return $this->hasMany('App\Order')->with(['supplier'])->orderBy('aggregate_sorting', 'asc');
}
public function scopeSupplier($query, $supplier_id)
{
$query->whereHas('orders', function ($query) use ($supplier_id) {
$query->where('supplier_id', '=', $supplier_id);
});
}
public function getStatusAttribute()
{
$priority = [];
foreach(Status::orders() as $identifier => $meta) {
$priority[$meta->aggregate_priority] = $identifier;
}
$index = 999;
foreach ($this->orders as $order) {
$a = array_search($order->status, $priority);
if ($a < $index) {
$index = $a;
}
}
if ($index == 999) {
return 'closed';
}
return $priority[$index];
}
public function getDeliveriesAttribute()
{
foreach ($this->orders as $order) {
return $order->deliveries;
}
return new Collection();
}
public function hasPendingPackages()
{
return $this->innerCache('pending_packages', function($obj) {
foreach($obj->orders as $o) {
if ($o->keep_open_packages != 'no' && $o->status == 'closed' && $o->pendingPackages()->isEmpty() == false) {
return true;
}
}
return false;
});
}
public function computeStrings()
{
$names = [];
$dates = [];
$orders = $this->orders;
if ($orders->count() > aggregatesConvenienceLimit()) {
$start_date = PHP_INT_MAX;
$end_date = 0;
$shipping_date = PHP_INT_MAX;
foreach ($orders as $order) {
$names[] = $order->printableName();
$this_start = strtotime($order->start);
if ($this_start < $start_date) {
$start_date = $this_start;
}
$this_end = strtotime($order->end);
if ($this_end > $end_date) {
$end_date = $this_end;
}
if ($order->shipping != null && $order->shipping != '0000-00-00') {
$this_shipping = strtotime($order->shipping);
if ($this_shipping < $shipping_date) {
$shipping_date = $this_shipping;
}
}
}
if (!empty($this->comment)) {
$names = [];
}
$date_string = sprintf('da %s a %s', printableDate($start_date), printableDate($end_date));
if ($shipping_date != PHP_INT_MAX) {
$date_string .= sprintf(', in consegna %s', printableDate($shipping_date));
}
$dates[] = $date_string;
}
else {
foreach ($orders as $order) {
$names[] = $order->printableName();
$dates[] = $order->printableDates();
}
}
return [implode(' | ', $names), implode(' / ', array_unique($dates))];
}
public function printableName()
{
$all_contents = [];
if (!empty($this->comment)) {
$all_contents[] = $this->comment;
}
$names = $this->innerCache('names', function($obj) {
list($name, $date) = $obj->computeStrings();
$obj->setInnerCache('dates', $date);
return $name;
});
if (!empty($names)) {
$all_contents[] = $names;
}
return join(': ', $all_contents);
}
public function printableDates()
{
return $this->innerCache('dates', function($obj) {
list($name, $date) = $obj->computeStrings();
$obj->setInnerCache('names', $name);
return $date;
});
}
public function printableHeader()
{
return $this->printableName() . $this->headerIcons() . sprintf('<br/><small>%s</small>', $this->printableDates());
}
public function printableUserHeader()
{
$ret = $this->printableHeader();
$user = Auth::user();
$tot = 0;
$friends_tot = 0;
foreach($this->orders as $o) {
$o->setRelation('aggregate', $this);
$b = $o->userBooking($user);
$tot += $b->getValue('effective', false);
$friends_tot += $b->total_friends_value;
}
if($tot == 0 && $friends_tot == 0) {
$message = _i("Non hai partecipato a quest'ordine");
$extra_class = 'text-more-muted';
}
else {
if ($friends_tot == 0)
$message = _i('Hai ordinato %s', printablePriceCurrency($tot));
else
$message = _i('Hai ordinato %s + %s', [printablePriceCurrency($tot), printablePriceCurrency($friends_tot)]);
$extra_class = '';
}
$ret .= '<span class="appended-loadable-message d-block text-end ' . $extra_class . '">' . $message . '</span>';
return $ret;
}
public function getBookingURL()
{
return route('booking.index') . '#' . $this->id;
}
public function isActive()
{
foreach ($this->orders as $order) {
if ($order->isActive()) {
return true;
}
}
return false;
}
public function isRunning()
{
foreach ($this->orders as $order) {
if ($order->isRunning()) {
return true;
}
}
return false;
}
public function hasChangedProdcts()
{
$has_changed_products = false;
if ($this->isActive()) {
$shipped = array_filter($this->bookings, function($b) {
return $b->status == 'shipped';
});
$dates = [];
foreach($shipped as $s) {
foreach($s->bookings as $b) {
if ($b->delivery) {
$dates[$b->delivery] = true;
}
}
}
$dates = array_keys($dates);
if (empty($dates) == false) {
sort($dates);
$date = $dates[0];
foreach($this->orders as $order) {
$newer = $order->products()->where('updated_at', '>=', $date)->count();
if ($newer > 0) {
$has_changed_products = true;
break;
}
}
}
}
return $has_changed_products;
}
public function canShip()
{
$user = Auth::user();
foreach ($this->orders as $order) {
if ($user->can('supplier.shippings', $order->supplier)) {
return true;
}
}
return false;
}
private function sortByStatus($ret)
{
uasort($ret, function($a, $b) {
$a_status = $a->status;
$b_status = $b->status;
$comp = -1;
if ($a_status == $b_status) {
$comp = strcmp($a->user->printableName(), $b->user->printableName());
}
else {
if ($a_status == 'pending') {
$comp = -1;
}
else if ($b_status == 'pending') {
$comp = 1;
}
else if ($a_status == 'saved') {
$comp = -1;
}
else if ($b_status == 'saved') {
$comp = 1;
}
}
return $comp;
});
return $ret;
}
public function getBookingsAttribute()
{
$ret = [];
foreach ($this->orders as $order) {
foreach ($order->topLevelBookings() as $booking) {
$user_id = $booking->user->id;
if (!isset($ret[$user_id])) {
$ret[$user_id] = new AggregateBooking($user_id, $this);
}
$ret[$user_id]->add($booking);
}
}
/*
Dopo aver raccolto le prenotazioni degli utenti principali, ripesco
anche quelle degli utenti "amici" il cui utente principale non ha
effettuato prenotazioni.
In tal caso creo una prenotazione anche per l'utente principale,
lasciandola vuota, in modo che sia comunque possibile accedere
successivamente alle sotto-prenotazioni ed assegnare il movimento di
pagamento
*/
$collected_users = array_keys($ret);
$recovered_master_users = [];
foreach ($this->orders as $order) {
$bookings_by_friends = $order->bookings()->whereHas('user', function($query) use ($collected_users) {
$query->whereNotNull('parent_id')->whereNotIn('parent_id', $collected_users);
})->get();
foreach($bookings_by_friends as $booking) {
$user_id = $booking->user->parent_id;
if (isset($recovered_master_users[$user_id])) {
continue;
}
if (!isset($ret[$user_id])) {
$ret[$user_id] = new AggregateBooking($user_id, $this);
}
$fake_booking = $order->userBooking($user_id);
$fake_booking->status = $booking->status;
$fake_booking->save();
$ret[$user_id]->add($fake_booking);
$recovered_master_users[$user_id] = true;
}
}
return $this->sortByStatus($ret);
}
public function getLastNotifyAttribute()
{
return $this->innerCache('last_notify', function($obj) {
if ($obj->orders->count() != 0) {
return $obj->orders->first()->last_notify;
}
else {
Log::error('Aggregato senza ordini inclusi: ' . $this->id);
return null;
}
});
}
public function getSupplierNameAttribute()
{
return $this->innerCache('supplier_name', function($obj) {
if ($obj->orders->count() != 0) {
return $obj->orders->first()->supplier->name;
}
else {
Log::error('Aggregato senza ordini inclusi: ' . $this->id);
return '';
}
});
}
private function getDateReference($name, $operator)
{
return $this->innerCache($name, function($obj) use ($name, $operator) {
if ($operator == 'min') {
$test = '3000-12-31';
}
else {
$test = '1000-01-01';
}
foreach($obj->orders as $order) {
if ($operator == 'min') {
if ($order->$name < $test) {
$test = $order->$name;
}
}
else {
if ($order->$name > $test) {
$test = $order->$name;
}
}
}
return $test;
});
}
public function getStartAttribute()
{
return $this->getDateReference('start', 'min');
}
public function getEndAttribute()
{
return $this->getDateReference('end', 'max');
}
public function getShippingAttribute()
{
return $this->getDateReference('shipping', 'min');
}
public function bookingBy($user_id)
{
$ret = new AggregateBooking($user_id, $this);
foreach ($this->orders as $order) {
$booking = $order->userBooking($user_id);
$ret->add($booking);
}
return $ret;
}
public function getPermissionsProxies()
{
$suppliers = [];
foreach($this->orders as $order)
$suppliers[] = $order->supplier;
return $suppliers;
}
/********************************************************* ReducibleTrait */
protected function reduxBehaviour()
{
$ret = $this->emptyReduxBehaviour();
$ret->children = function($item, $filters) {
if (isset($filters['orders'])) {
return $filters['orders'];
}
return $item->orders;
};
$ret->optimize = function($item, $child) {
$child->setRelation('aggregate', $item);
return $child;
};
$ret->collected = 'orders';
return $ret;
}
/******************************************************** ModifiableTrait */
public function sameModificationTypes()
{
return $this->orders->first();
}
/************************************************************** WithinGas */
public function guessGas()
{
$candidates = [];
$valid = [];
$threshold = $this->orders->count();
foreach($this->orders as $order) {
foreach($order->supplier->gas as $gas) {
if (isset($candidates[$gas->id]) == false) {
$candidates[$gas->id] = 0;
}
$candidates[$gas->id]++;
}
}
foreach($candidates as $id => $count) {
if ($count == $threshold) {
$valid[] = $id;
}
}
return Gas::whereIn('id', $valid)->get();
}
}