WMS/Modules/M3/Console/WHSMetricsSaveXls.php

<?php

namespace Modules\M3\Console;

use Config;
use DB;
use Illuminate\Console\Command;
use Log;
use Modules\M3\Services\SpreadsheetExport;
use Str;

class WHSMetricsSaveXls extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'command:WHSMetricsSaveXls {user?} {co?} {whs?} {pl?}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Save WHS Metrics to Excel';

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

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        ini_set('max_execution_time', Config::get('arrays.PHPTimeOutCL'));
        ini_set('max_input_time', Config::get('arrays.PHPTimeOutCL'));
        ini_set('default_socket_timeout', Config::get('arrays.PHPTimeOutCL'));
        ini_set('memory_limit', '1024M');

        try {
            Log::channel('dailyCron')->info('Cron...Start Save WHS Metrics to Excel');

            // Get the Calling User
            $userId = $this->argument('user');
            $SHUSER = isset($userId) ? $userId : (m3_user() !== '' ? Str::upper(trim(m3_user())) : '');

            $CO = $this->argument('co');
            $COMPANY = '110';
            $PWHS = $this->argument('whs');
            $WHS = '321';
            $PPL = $this->argument('pl');
            $PLANT = '143';

            $date = new \DateTime;
            $DateToday = $date->format('Y-m-d');

            // Define File Name
            $whsPerfFile = 'WhsPerf/' . $WHS . '/WhsPerfMetrics_' . $DateToday . '-' . $WHS . '.xlsx';
            Log::channel('dailyCron')->info('>>> File Name:');
            Log::channel('dailyCron')->info($whsPerfFile);

            $this->info('Generate Today WHS Performance Report...');

            if ($COMPANY != '' && $WHS != '' && $PLANT != '') {
                // Get Header Content
                $ICM700MHeadSel = DB::connection(config('m3.connection', 'pgsql'))
                    ->select("
                        WITH TEMPFILE AS (
                            SELECT A.*,A4TPCKWGHT,A4NOPICLNS,A4PICKSTS,
                            CASE WHEN UPPER(A4PICKSTS)<>'A' THEN 'Open' ELSE 'Closed' END AS STATUS,
                            CASE WHEN A4TPCKWGHT>16000 THEN 'FTL' ELSE A4SHIPTYPE END AS A4SHIPTYPE,
                            (SELECT SUM(A5RSVQTY*A5SLUNPR) FROM ICM688M2 WHERE A4MACPKR=A5MACPKR) AS DOLLARS
                            FROM ICM700M A LEFT JOIN ICM688M1 B ON A4MACPKR=A3MACPKR
                            WHERE A3MSMTDATE= (SELECT MAX(A3MSMTDATE) FROM ICM700M) AND A3CO='$COMPANY' AND A3WHS='$WHS' AND A3PLT='$PLANT'
                        )
                        SELECT A4SHIPTYPE,STATUS,SOURCE,COUNT(*) AS PICKERS, SUM(A4TPCKWGHT) AS WEIGHT,SUM(A4NOPICLNS) AS LINES,SUM(DOLLARS) AS DOLLARS
                        FROM TEMPFILE
                        GROUP BY A4SHIPTYPE,STATUS,SOURCE
                        ORDER BY 1,3,2
                    ");

                $newItem = ['A4SHIPTYPE' => 'Method', 'STATUS' => 'Status', 'SOURCE' => 'Source', 'PICKERS' => 'Pickers',
                    'WEIGHT' => 'Weight', 'LINES' => 'Lines', 'DOLLARS' => 'Dollars'];

                // Trim All values
                $ICM700MHeadCol = collect($ICM700MHeadSel)->map(function ($item) {
                    foreach ($item as $key => $value) {
                        if (is_string($value)) {
                            $item->{$key} = trim($value);
                        }
                    }

                    return $item;
                });
                // Prepend Header to Collection
                $ICM700MHeadCol->prepend($newItem);

                // Log::channel('dailyCron')->info(">>> Header Content");
                // Log::channel('dailyCron')->info($ICM700MHeadCol);

                // Count records before exporting to excel
                $ICM700MHeadCount = $ICM700MHeadCol->count();

                // Get Details Content
                $ICM700MDetailsSel = DB::connection(config('m3.connection', 'pgsql'))
                    ->select("
                    WITH TEMPFILE AS (
                        SELECT A3CO,A3WHS,A3PLT,A3MACPKR,A4PICKCRTS,SOURCE,
                        (SELECT TO_TIMESTAMP(CAST(SHDT AS TEXT) || ' ' || CAST(SHTIME AS TEXT), 'YYYY-MM-DD HH24:MI:SS') FROM ICM699M WHERE SHMACPKR=A4MACPKR AND SHTYPE='Lisnr-Hold' ORDER BY SHDT DESC, SHTIME DESC FETCH FIRST 1 ROWS ONLY) AS CARRIERASSIGNED,
                        A4ONO,A4SHSHNM,A4SCAC,A42SSVCNAM,A4PICKSTS,
                        CASE WHEN UPPER(A4PICKSTS)<>'A' THEN 'Open' ELSE 'Closed' END AS STATUS,
                        CASE WHEN A4TPCKWGHT>16000 THEN 'FTL' ELSE A4SHIPTYPE END AS A4SHIPTYPE,
                        A4TPCKWGHT,A4NOPICLNS,
                        (SELECT SUM(A5RSVQTY*A5SLUNPR) FROM ICM688M2 WHERE A4MACPKR=A5MACPKR) AS DOLLARS
                        FROM ICM700M A
                        LEFT JOIN ICM688M1 B ON A4MACPKR=A3MACPKR
                        WHERE A3MSMTDATE=(SELECT MAX(A3MSMTDATE) FROM ICM700M) AND A3CO='$COMPANY' AND A3WHS='$WHS' AND A3PLT='$PLANT'
                    )
                    SELECT * FROM TEMPFILE
                ");

                $newItem2 = ['A3CO' => 'Co', 'A3WHS' => 'Whs', 'A3PLT' => 'Plt', 'A3MACPKR' => 'Delivery No', 'A4PICKCRTS' => 'Date Time Arrived in Sentinel',
                    'SOURCE' => 'Source', 'CARRIERASSIGNED' => 'Date carrier Assigned', 'A4ONO' => 'Order No', 'A4SHSHNM' => 'Customer name', 'A4SCAC' => 'Carrier',
                    'A42SSVCNAM' => 'Service', 'A4PICKSTS' => 'Picker Status', 'STATUS' => 'Open or Closed', 'A4SHIPTYPE' => 'Method',
                    'A4TPCKWGHT' => 'Weight', 'A4NOPICLNS' => 'Lines', 'DOLLARS' => 'Dollars'];
                // Trim all values
                $ICM700MDetailsCol = collect($ICM700MDetailsSel)->map(function ($item) {
                    foreach ($item as $key => $value) {
                        if (is_string($value)) {
                            $item->{$key} = trim($value);
                        }
                    }

                    return $item;
                });

                // Prepend Header
                $ICM700MDetailsCol->prepend($newItem2);

                // Count records before exporting to excel
                $ICM700MDetailsCount = $ICM700MDetailsCol->count();
            } else {
                $ICM700MDetailsCol = collect();
            }
            // Log::channel('dailyCron')->info($ICM700MDetailsCol);

            // Save Head and Details to XLS file
            if ($ICM700MHeadCount > 0 && $ICM700MDetailsCount > 0) {
                $this->info('Saving Today WHS Performance Report to Disk...');
                Log::channel('dailyCron')->info('Saving Today WHS Performance Report to Disk...');

                // Store both collections in one XLSX workbook using Core's PhpSpreadsheet dependency.
                app(SpreadsheetExport::class)->storeSheets([
                    'Summary' => $ICM700MHeadCol,
                    'Details' => $ICM700MDetailsCol,
                ], $whsPerfFile, 'publicLabels');

            } else {
                Log::channel('dailyCron')->info('Today WHS Performance Report, no records found: Nothing to save...');
            }

            Log::channel('dailyCron')->info('Cron...End Save Today WHS Performance Report to Excel');
            $this->info('Cron...End Save Today WHS Performance Report to Excel');

        } catch (\Throwable $th) {
            Log::channel('dailyCron')->error($th);
        }
    }
}