<?php

namespace App\Console\Commands;

use App\Models\Machine;
use App\Models\Plant;
use App\Models\ProductionTemp;
use Illuminate\Console\Command;
use App\Services\SftpFileService;
use Filament\Facades\Filament;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Mail;
use Illuminate\Support\Facades\Storage;
use Illuminate\Support\Facades\Schema;

class ProcessSftpFiles extends Command
{
    protected $signature = 'sftp:process-files';
    protected $description = 'Read SFTP files, insert into DB, and move to processed folder';

    protected $sftpService;

    public function __construct(SftpFileService $sftpService)
    {
        parent::__construct(); // calls parent class constructor
        $this->sftpService = $sftpService;
    }

    public function handle()
    {
        $files = Storage::disk('ftp')->allFiles();

        $folders = Storage::disk('ftp')->directories();

        $allFiles = [];

        foreach ($folders as $folder) {

            $this->info("Checking folder: $folder");

            try {

                // Get files inside the current folder
                $files = Storage::disk('ftp')->files($folder);

                foreach ($files as $file) {
                    $this->info("File: " . $file);
                    $allFiles[] = $file;
                }

            } catch (\Exception $e) {

                $this->error("Cannot access folder: " . $folder);
            }
        }

        if (empty($allFiles)) {
            $this->info('No files to process.');
            return;
        }

        $logMessages = [];

        foreach ($allFiles as $file)
        {
            $this->info("Processing file: $file");

            $folderName = explode('/', $file)[0];

            $plant = Plant::where('code', $folderName)->first();

            if (!$plant) {
                $this->warn("No plant found for folder: $folderName. Skipping file.");
                $logMessages[] = $folderName;
                continue;
            }

            $plantId = $plant->id;

            $plantCode = $plant->code ?? null;

            $fileName = basename($file); // GMGLAS03-1818199-1.txt
            $workCenterCode = explode('-', $fileName)[0]; // GMGLAS03

            $machine = Machine::where('work_center', $workCenterCode)->first();
            if (!$machine) {
                $message = "Machine '$workCenterCode' not found and file name '$file'";
                $logMessages[] = $message;
                continue;
            }

            $machineAgaPlant = Machine::where('plant_id', $plantId)->where('work_center', $workCenterCode)->first();
            if (!$machineAgaPlant) {
                $message = "Machine '$workCenterCode' not found for plant code '$plantCode' and file name '$file'";
                $logMessages[] = $message;
                continue;
            }

            $machineId = $machineAgaPlant->id;

            $content = $this->sftpService->getFileContent($file);

            $lines = array_filter(preg_split("/\r\n|\n|\r/", $content));

            $headers = array_map(fn($header) => strtolower(trim($header)), str_getcsv(array_shift($lines)));

            $dbColumns = Schema::getColumnListing('production_temps');

            $missingColumns = array_diff($headers, $dbColumns);

            if (!empty($missingColumns)) {

                $message = "Skipping file: $file. The following columns do not exist in the database. Please add them to the database: " . implode(', ', $missingColumns);

                $logMessages[] = $message;

                $this->warn($message);

                continue;
            }

            $expectedColumns = count($headers);
            $isValidFile = true;
            $isserialNotEmptyFile = true;

            foreach ($lines as $lineNumber => $line) {
                $data = str_getcsv($line);

                if (!empty($data[0])) {
                    if (count($data) != $expectedColumns) {
                        $message = "Column mismatch in file: $file at line " . ($lineNumber + 2) .
                                ". Expected $expectedColumns, got " . count($data);

                        $logMessages[] = $message;

                        $isValidFile = false;
                        break;
                    }
                }
            }

            if (!$isValidFile) {
                $message = "Skipping entire file due to invalid column mismatch: $file";
                $logMessages[] = $message;
                continue;
            }
            else if (!$isserialNotEmptyFile) {
                $message = "serial number not found in file name $file";
                $logMessages[] = $message;
                continue;
            }

            $rows = [];

            // foreach ($lines as $line) {
            //     $data = str_getcsv($line);

            //     if (!empty($data[0])) {
            //         $row = [];
            //         foreach ($headers as $index => $column) {
            //             $row[$column] = isset($data[$index]) ? trim($data[$index]) : null;
            //         }

            //         $row['plant_id'] = $plantId;
            //         $row['machine_id'] = $machineId;
            //         $row['created_at'] = now();
            //         $row['updated_at'] = now();

            //         // $rows[] = $row;
            //         if (!empty($row['gernr'])) {
            //             $rows[] = $row;
            //         }
            //     }
            // }

            foreach ($lines as $line) {

                $data = str_getcsv($line);

                if (!empty($data[0])) {

                    $row = [];

                    foreach ($headers as $index => $column) {
                        $row[$column] = isset($data[$index])
                            ? trim($data[$index])
                            : null;
                    }

                    $row['plant_id'] = $plantId;
                    $row['machine_id'] = $machineId;
                    $row['created_at'] = now();
                    $row['updated_at'] = now();

                    if (empty($row['gernr'])) {
                        $message = "serial number not found in file name $file";
                        $logMessages[] = $message;
                        continue;
                    }

                    $gamng = (float) ($row['gamng'] ?? 0);
                    $lmnga = (float) ($row['lmnga'] ?? 0);

                    $existingRecords = ProductionTemp::where('plant_id', $plantId)
                        ->where('aufnr', ($row['aufnr']))
                        ->get();

                        
                    $existingRecord = $existingRecords->where('gernr', $row['gernr'])->first();

                    $lastStatus = $existingRecords->max('pending_released_status');

                    if ($gamng == $lmnga) {

                        $row['pending_released_status'] = 0;

                        $this->info("Production order {$row['aufnr']} completed. " ."Serial: {$row['gernr']}. " ."GAMNG: {$row['gamng']}, LMNGA: {$row['lmnga']}. " ."pending_released_status = 0" );

                    } elseif ($existingRecord) {

                        $row['pending_released_status'] = (int) $existingRecord->pending_released_status;

                        $this->info("Same serial already exists. " ."Production order: {$row['aufnr']}. " ."Serial: {$row['gernr']}. " ."Keeping pending_released_status = {$row['pending_released_status']}");

                    } else {

                        if ($existingRecords->isEmpty()) {

                            // First release
                            $row['pending_released_status'] = 0;

                        } else {
                            $row['pending_released_status'] = ((int) $lastStatus) + 1;
                        }
                        $this->info("Production order {$row['aufnr']} pending. " ."New serial: {$row['gernr']}. " . "GAMNG: {$row['gamng']}, LMNGA: {$row['lmnga']}. " ."pending_released_status = {$row['pending_released_status']}");
                    }

                    $rows[] = $row;
                }
            }

            if (!empty($rows)) {
                ProductionTemp::upsert($rows, ['plant_id', 'gernr'], array_keys($rows[0]));   //(update + insert)
            }
        }

        if (!empty($logMessages)) {

            $content = implode(PHP_EOL, $logMessages);

            Mail::raw('Please find attached machine error logs.', function ($message) use ($content) {
                $message->to(env('ERROR_LOG_MAIL'))
                    ->subject('Machine Error Logs')
                    ->attachData($content, 'machine_errors.txt', [
                        'mime' => 'text/plain',
                    ]);
            });
        }
    }
}