madbob/GASdottoNG

<?php

namespace App\Printers;

use Illuminate\Support\Str;
use Illuminate\Support\Arr;

use App;
use PDF;
use ezcArchive;

use App\Printers\Concerns\Orders;
use App\Printers\Components\Document;
use App\Printers\Components\Header;
use App\Printers\Components\Title;
use App\Formatters\User as UserFormatter;
use App\Delivery;

class Aggregate extends Printer
{
    use Orders;

    protected function handleShipping($obj, $request)
    {
        $subtype = $request['format'] ?? 'pdf';
        $required_fields = $request['fields'] ?? [];

        $fields = splitFields($required_fields);
        $status = $request['status'] ?? 'pending';
        $shipping_place = $request['shipping_place'] ?? 'all_by_name';

        $temp_data = [];
        foreach($obj->orders as $order) {
            $temp_data[] = $this->formatShipping($order, $fields, $status, $shipping_place, true);
        }

        if (empty($temp_data)) {
            $data = (object) [
                'headers' => [],
                'contents' => []
            ];
        }
        else {
            $data = (object) [
                'headers' => $temp_data[0]->headers,
                'contents' => []
            ];

            foreach($temp_data as $td_row) {
                foreach($td_row->contents as $td) {
                    $found = false;

                    // @phpstan-ignore-next-line
                    foreach($data->contents as $d) {
                        if ($d->user_id == $td->user_id) {
                            $d->products = array_merge($d->products, $td->products);
                            $d->notes = array_merge($d->notes, $td->notes);

                            /*
                                Nell'array "totals" si trova il totale della
                                prenotazione, ma anche i totali dei modificatori
                            */
                            foreach($td->totals as $index => $t) {
                                $d->totals[$index] = ($d->totals[$index] ?? 0) + $t;
                            }

                            $found = true;
                            break;
                        }
                    }

                    // @phpstan-ignore-next-line
                    if ($found == false) {
                        $data->contents[] = $td;
                    }
                }
            }

            $all_gas = (App::make('GlobalScopeHub')->enabled() == false);

            usort($data->contents, function($a, $b) use ($shipping_place, $all_gas) {
                if ($shipping_place == 'all_by_place' && $a->shipping_sorting != $b->shipping_sorting) {
                    return $a->shipping_sorting <=> $b->shipping_sorting;
                }

                if ($all_gas) {
                    return $a->gas_sorting <=> $b->gas_sorting;
                }

                return $a->user_sorting <=> $b->user_sorting;
            });
        }

        $title = _i('Dettaglio Consegne Ordini');
        $filename = sanitizeFilename($title . '.' . $subtype);

        if ($subtype == 'pdf') {
            $pdf = PDF::loadView('documents.order_shipping_pdf', [
                'fields' => $fields,
                'aggregate' => $obj,
                'shipping_place' => $shipping_place,
                'data' => $data
            ]);

            enablePdfPagesNumbers($pdf);
            return $pdf->download($filename);
        }
        else if ($subtype == 'csv') {
            $flat_contents = [];

            // @phpstan-ignore-next-line
            foreach($data->contents as $c) {
                foreach($c->products as $p) {
                    $flat_contents[] = array_merge($c->user, $p);
                }
            }

            return output_csv($filename, $data->headers, $flat_contents, function($row) {
                return $row;
            });
        }
    }

    private function handleGDXP($obj)
    {
        $hub = App::make('GlobalScopeHub');
        if ($hub->enabled() == false) {
            $gas = $obj->gas->pluck('id');
        }
        else {
            $gas = Arr::wrap($hub->getGas());
        }

        $working_dir = sys_get_temp_dir();
        chdir($working_dir);

        $files = [];
        $printer = new Order();

        foreach($gas as $g) {
            $hub->enable(true);
            $hub->setGas($g);

            foreach($obj->orders as $order) {
                /*
                    Attenzione: la funzione document() nomina il
                    file sempre nello stesso modo, a prescindere dal
                    GAS. Se non lo si rinomina in altro modo, le
                    diverse iterazioni sovrascrivono sempre lo
                    stesso file
                */
                $f = $printer->document($order, 'summary', ['format' => 'gdxp', 'status' => 'pending']);
                $new_f = Str::random(10);
                rename($f, $new_f);
                $files[] = $new_f;
            }
        }

        $archivepath = sprintf('%s/prenotazioni.zip', $working_dir);
        zipAll($archivepath, $files);

        return response()->download($archivepath)->deleteFileAfterSend(true);
    }

    protected function handleSummary($obj, $request)
    {
        $subtype = $request['format'] ?? 'pdf';

        if ($subtype == 'gdxp') {
            return $this->handleGDXP($obj);
        }
        else {
            $required_fields = $request['fields'] ?? [];
            $status = $request['status'];

            $shipping_place = $request['shipping_place'] ?? 'no';
            if ($shipping_place == 'no') {
                $shipping_place = null;
            }

            $document = new Document($subtype);

            $document_title = _i('Prodotti') . '<br>';
            if ($obj->orders->count() <= aggregatesConvenienceLimit()) {
                foreach ($obj->orders as $order) {
                    $document_title .= sprintf('%s %s<br>', $order->supplier->name, $order->internal_number);
                }
            }

            $document->append(new Title($document_title));

            $hub = App::make('GlobalScopeHub');
            if ($hub->enabled() == false) {
                $gas = $obj->gas;
            }
            else {
                $gas = Arr::wrap($hub->getGasObj());
            }

            foreach($gas as $g) {
                $hub->enable(true);
                $hub->setGas($g);

                foreach($obj->orders as $order) {
                    $document->append(new Header($order->printableName()));
                    $document = $this->formatSummary($order, $document, $required_fields, $status, $shipping_place, false);
                }
            }

            $title = _i('Prodotti Ordini');
            $filename = sanitizeFilename($title . '.' . $subtype);
            return $document->download($filename);
        }
    }

    private function orderTopBookingsByShipping($aggregate, $shipping_place, $status = null)
    {
        $bookings = $aggregate->bookings;

        if ($status) {
            $bookings = $bookings->filter(function($b) use ($status) {
                return $b->status == $status;
            });
        }

        return Delivery::sortBookingsByShippingPlace($bookings, $shipping_place);
    }

    private function formatTableRows($aggregate, $shipping_place, $status, $fields, &$all_products)
    {
        $bookings = $this->orderTopBookingsByShipping($aggregate, $shipping_place, $status == 'saved' ? 'saved' : null);
        list($get_total, $get_function) = $this->bookingsRules($status);

        $data = [];
        $total_price = 0;

        foreach($bookings as $booking) {
            $row = UserFormatter::format($booking->user, $fields->user_columns);

            foreach($aggregate->orders as $order) {
                $sub_booking = $booking->getOrderBooking($order);
                $subrow = $this->formatBookingInTable($order, $sub_booking, $status, $all_products);
                $row = array_merge($row, $subrow);
            }

            $price = $booking->getValue($get_total, true);
            $total_price += $price;
            $row[] = printablePrice($price);

            $data[] = $row;
        }

        return [$data, $total_price];
    }

    protected function handleTable($obj, $request)
    {
        $status = $request['status'] ?? 'pending';
        $include_missing = $request['include_missing'] ?? 'no';
        $shipping_place = $request['shipping_place'] ?? 0;

        $required_fields = $request['fields'] ?? [];
        $fields = splitFields($required_fields);

        /*
            Formatto riga di intestazione
        */

        $user_columns = UserFormatter::getHeaders($fields->user_columns);
        list($all_products, $headers, $prices_rows) = $this->formatTableHead($user_columns, $obj->orders);

        /*
            Formatto righe delle singole prenotazioni
        */

        list($data, $total_price) = $this->formatTableRows($obj, $shipping_place, $status, $fields, $all_products);
        array_unshift($data, $prices_rows);

        /*
            Formatto riga dei totali
        */

        $row = $this->formatTableFooter($obj->orders, $user_columns, $all_products, $total_price);
        $data[] = $row;
        $data[] = $headers;

        if ($include_missing == 'no') {
            $data = $this->compressTable($user_columns, $data);
            $headers = $data[count($data) - 1];
        }

        /*
            Genero documento
        */

        $filename = sanitizeFilename(_i('Tabella.csv'));
        return output_csv($filename, $headers, $data, null);
    }
}