Enhanced File Manager

Edit File

<?php
require_once __DIR__ . '/src/Services/Logger.php';

class RateConProcessor {
    private $mcleodApiKey;
    private $mcleodApiEndpoint;
    private $storagePath;
    private $logger;

public function __construct($mcleodApiKey, $mcleodApiEndpoint, $storagePath = null) {
        $this->mcleodApiKey = $mcleodApiKey;
        $this->mcleodApiEndpoint = $mcleodApiEndpoint;
        
        // Fallback log and storage paths
        $fallbackLogDir = '/tmp/mcleod_logs/';
        $fallbackStoragePath = '/tmp/mcleod_storage/';

// Ensure fallback directories exist
        if (!file_exists($fallbackLogDir)) {
            @mkdir($fallbackLogDir, 0755, true);
        }
        if (!file_exists($fallbackStoragePath)) {
            @mkdir($fallbackStoragePath, 0755, true);
        }
        
        // Set storage path with fallback
        if ($storagePath === null) {
            $this->storagePath = $fallbackStoragePath;
        } else {
            $this->storagePath = rtrim($storagePath, '/') . '/';
            
            // If provided path is not writable, use fallback
            if (!is_writable($this->storagePath)) {
                $this->storagePath = $fallbackStoragePath;
            }
        }
        
        // Initialize logger with fallback log path
        $this->logger = new \Services\Logger($fallbackLogDir . 'mcleod_integration.log');
    }

private function generateMcLeodOrder($extractedData) {
        // Parse temperature requirements
        $tempData = $this->parseTemperature($extractedData['TEMP']);
        
        // Calculate total charge - convert to whole number
        $totalCharge = (int)floatval(preg_replace('/[^0-9.]/', '', $extractedData['RATE']));
    
        // Remove spaces from commodity
        $commodity = str_replace(' ', '', strtoupper($extractedData['COMMODITY']));
    
        // Build order data structure
        $orderData = [
            '__type' => 'orders',
            'company_id' => 'TMS',
            'status' => 'A',
            'blnum' => $extractedData['BOL'],
            'commodity' => $commodity,
            'collection_method' => 'P',
            'customer_id' => '10ROHOIL',
            'equipment_type_id' => 'R',
            'ordered_date' => $this->formatDateTime($extractedData['DATE']),
            'bill_date' => $this->formatDateTime($extractedData['DATE']),
            'revenue_code_id' => 'DRYCD',
            'temperature_min' => (int)$tempData['min_temp'],
            'temperature_max' => (int)$tempData['min_temp'], // Use min_temp for both
            'setpoint_temp' => -10,
            'freight_charge' => $totalCharge,
            'total_charge' => $totalCharge,
            'stops' => $this->generateStops($extractedData),
            'freightGroup' => $this->generateFreightGroup($extractedData, $commodity),
            'otherCharges' => $this->generateOtherCharges($extractedData)
        ];
    
        return $orderData;
    }
    
    private function generateStops($extractedData) {
        $this->logger->info('Generating stops - Start');
        $this->logger->info('Delivery data received: ' . json_encode($extractedData['DELIVERY']));
    
        $stops = [];
        
        // Pickup Stop
        $pickupStop = [
            '__type' => 'stop',
            '__name' => 'stops',
            'stop_type' => 'PU',
            'sequence' => 1,
            'location_id' => $extractedData['PICKUPLOCATIONID'] ?? '',
            'location_name' => $extractedData['PICKUPNAME'],
            'address' => $extractedData['PICKUPADDRESS'],
            'city_name' => strtoupper($extractedData['PICKUPCITY']),
            'state' => strtoupper($extractedData['PICKUPSTATE']),
            'zip_code' => $extractedData['PICKUPZIP'],
            'city_id' => '259451',
            'driver_load_unload' => 'LL',
            'sched_arrive_early' => $this->formatFullDateTime($extractedData['PICKUPTIME']),
            'sched_arrive_late' => $this->formatFullDateTime($extractedData['PICKUPENDTIME'])
        ];
        $stops[] = $pickupStop;
    
        // Delivery Stops
        if (isset($extractedData['DELIVERY']) && is_array($extractedData['DELIVERY'])) {
            $this->logger->info('Number of delivery stops: ' . count($extractedData['DELIVERY']));
            
            foreach ($extractedData['DELIVERY'] as $index => $delivery) {
                // Ensure $delivery is an array or can be split
                $parts = is_string($delivery) ? explode('|', $delivery) : $delivery;
                
                $this->logger->info('Delivery stop parts: ' . json_encode($parts));
                
                if (count($parts) >= 7) {
                    $deliveryStop = [
                        '__type' => 'stop',
                        '__name' => 'stops',
                        'stop_type' => 'SO',
                        'sequence' => $index + 2,
                        'location_id' => $parts[7] ?? '', // Add location ID if available
                        'location_name' => trim($parts[0]),
                        'address' => trim($parts[1]),
                        'city_name' => strtoupper(trim($parts[2])),
                        'state' => strtoupper(trim($parts[3])),
                        'zip_code' => trim($parts[4]),
                        'city_id' => '93293',
                        'driver_load_unload' => 'LU',
                        'sched_arrive_early' => $this->formatFullDateTime($parts[5]),
                        'sched_arrive_late' => $this->formatFullDateTime($parts[6])
                    ];
                    
                    $this->logger->info('Adding delivery stop: ' . json_encode($deliveryStop));
                    $stops[] = $deliveryStop;
                } else {
                    $this->logger->warning('Insufficient delivery stop data: ' . json_encode($parts));
                }
            }
        } else {
            $this->logger->warning('No delivery stops found');
        }
    
        $this->logger->info('Total stops generated: ' . count($stops));
        return $stops;
    }
    
    private function formatFullDateTime($dateTime) {
        return date('YmdHis', strtotime($dateTime)) . '00-0600';
    }
    
    private function generateFreightGroup($extractedData, $commodity) {
        return [
            '__type' => 'freight_group',
            '__name' => 'freightGroup',
            'description' => $commodity,
            'freightGroupItems' => [
                [
                    '__type' => 'freight_group_item',
                    '__name' => 'freightGroupItems',
                    'pieces' => 1,
                    'weight' => 0,
                    'description' => $commodity
                ]
            ]
        ];
    }
    
    private function generateOtherCharges($extractedData) {
        $charges = [];
        
        if (isset($extractedData['FINES'])) {
            $charges[] = [
                '__type' => 'other_charge',
                '__name' => 'otherCharges',
                'charge_id' => 'FINE',
                'calc_method' => 'F',
                'amount' => 50,
                'currency_type' => 'USD',
                'description' => 'Failure to do any of the following will result in a $50.00 fine'
            ];
        }
    
        return $charges;
    }

private function formatDateTime($dateTime) {
        return date('Ymd000000-0600', strtotime($dateTime));
    }
    public function processExtractedData($extractedData) {
        try {
            $orderData = $this->generateMcLeodOrder($extractedData);
            $filename = $this->saveJsonFile($orderData);
            // Comment out API call
            // $response = $this->createOrder($orderData);
            return [
                'success' => true,
                'filename' => $filename,
                'api_response' => $orderData // Return order data instead of API response
            ];
        } catch (Exception $e) {
            $this->logger->error('Processing failed: ' . $e->getMessage());
            throw $e;
        }
    }
    private function parseAddress($addressStr) {
        // More flexible pattern for address parsing
        $pattern = '/^([^0-9]+)([0-9].+?)(?:,\s*|\s+)(\w+)\s+(\w{2})\s+(\d{5})/i';
        preg_match($pattern, $addressStr, $matches);
        
        if (empty($matches)) {
            $this->logger->error('Address parse failed for: ' . $addressStr);
            return [
                'name' => '',
                'street' => '',
                'city' => '',
                'state' => '',
                'zip' => '',
                'appointment_window' => ['start' => '', 'end' => '']
            ];
        }
        
        return [
            'name' => trim($matches[1] ?? ''),
            'street' => trim($matches[2] ?? ''),
            'city' => trim($matches[3] ?? ''),
            'state' => strtoupper($matches[4] ?? ''),
            'zip' => $matches[5] ?? '',
            'appointment_window' => $this->extractDateTime($addressStr)
        ];
    }

private function parseTemperature($tempStr) {
        preg_match('/([-\d.]+).*?([-\d.]+)/', $tempStr, $matches);
        
        return [
            'min_temp' => isset($matches[1]) ? floatval($matches[1]) : null,
            'max_temp' => isset($matches[2]) ? floatval($matches[2]) : null
        ];
    }

private function extractDateTime($str) {
        try {
            preg_match('/(\d{1,2}\/\d{1,2}\/\d{4})\s*(\d{4})\s*-\s*(\d{1,2}\/\d{1,2}\/\d{4})\s*(\d{4})/', 
                $str, $matches);
                
            if (empty($matches)) {
                return [
                    'start' => date('Ymd000000-0600'),
                    'end' => date('Ymd000000-0600')
                ];
            }

return [
                'start' => date('Ymd000000-0600', strtotime($matches[1] . ' ' . $matches[2])),
                'end' => date('Ymd000000-0600', strtotime($matches[3] . ' ' . $matches[4]))
            ];
        } catch (Exception $e) {
            debug_log('DateTime parsing failed:', $e->getMessage());
            return [
                'start' => date('Ymd000000-0600'),
                'end' => date('Ymd000000-0600')
            ];
        }
    }

private function extractAmount($str) {
        preg_match('/\$(\d+(?:\.\d{2})?)/', $str, $matches);
        return isset($matches[1]) ? floatval($matches[1]) : 0;
    }

private function saveJsonFile($jsonData) {
        $filename = 'mcleod_order_' . date('YmdHis') . '.json';
        $filepath = $this->storagePath . $filename;
        
        // Ensure directory is writable, with fallback
        if (!is_writable($this->storagePath)) {
            $filepath = '/tmp/mcleod_storage/' . $filename;
        }
        
        if (file_put_contents($filepath, json_encode($jsonData, JSON_PRETTY_PRINT))) {
            $this->logger->info('JSON file saved: ' . $filepath);
            return $filename;
        }
        
        throw new Exception('Failed to save JSON file');
    }

private function createOrder($orderData) {
        $curl = curl_init($this->mcleodApiEndpoint . '/orders/create');
        
        curl_setopt_array($curl, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_CUSTOMREQUEST => 'PUT',
            CURLOPT_POSTFIELDS => json_encode($orderData),
            CURLOPT_HTTPHEADER => [
                'Content-Type: application/json',
                'Authorization: Bearer ' . $this->mcleodApiKey
            ]
        ]);
        
        $response = curl_exec($curl);
        $httpCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
        
        if ($response === false) {
            throw new Exception('API request failed: ' . curl_error($curl));
        }
        
        if ($httpCode !== 200) {
            throw new Exception('API returned error: ' . $response);
        }
        
        return json_decode($response, true);
    }
}

class Logger {
    private $logFile;
    
    public function __construct($logFile = null) {
        if ($logFile === null) {
            $this->logFile = dirname(__FILE__) . '/logs/mcleod_integration.log';
        } else {
            $this->logFile = $logFile;
        }
        
        // Create logs directory if it doesn't exist
        $logDir = dirname($this->logFile);
        if (!file_exists($logDir)) {
            mkdir($logDir, 0755, true);
        }
    }
    
    public function info($message) {
        $this->log('INFO', $message);
    }
    
    public function error($message) {
        $this->log('ERROR', $message);
    }
    
    private function log($level, $message) {
        $timestamp = date('Y-m-d H:i:s');
        $logMessage = "[$timestamp] [$level] $message\n";
        file_put_contents($this->logFile, $logMessage, FILE_APPEND);
    }
}

Enhanced File Manager

Create New Folder

Create New File

Edit File

Enhanced File Manager

Create New Folder

Create New File

Edit File

Rename Item

Move/Copy Item

Extract Archive

Create ZIP Archive

Confirm Deletion

Confirm Bulk Deletion