<?php

namespace Modules\M3\Console;

use Illuminate\Console\Command;

use Modules\M3\Http\Controllers\Controller;
use DB;
use Config;
use Illuminate\Http\Request;
use Symfony\Component\HttpFoundation\Response;
use Log;
use Str;


use Storage;

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()
    {
        //$this->info('Start CallCloseAPI...');
        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   = isset($CO) ? trim($CO) : '110';
            $COMPANY   = '110';
            $PWHS      = $this->argument('whs');
            // $WHS       = isset($PWHS) ? trim($PWHS) : '321';
            $WHS       = '321';
            $PPL       = $this->argument('pl');
            // $PLANT     = isset($PPL) ? trim($PPL) : '143';
            $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
                    ");
                // dd($ICM700MHeadSel);
                    
                $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);

                // $this->info($ICM700MHeadCol);
                // 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(">>> Detail Content");
            // 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(\Modules\M3\Services\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::error($th);
            Log::channel('dailyCron')->error($th);
        }
    }
}