File Manager

✏️ Edit File: /home/u625410797/domains/monothailand.com/public_html/smart_panel/api/v1/telemetry.php

<?php
// =============================================================================
// API: TELEMETRY INGESTION
// Method: POST
// Description: Accepts batch telemetry logs from devices/gateways
// =============================================================================
header("Content-Type: application/json; charset=UTF-8");
header('Access-Control-Allow-Origin: *');
header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE, OPTIONS');
header('Access-Control-Allow-Headers: Content-Type, Authorization, X-Api-Key');
require_once '../../config.php';
require_once '../../core/DatabaseRouter.php';

// Security Guard (X-Api-Key required)
// [FIX] Accept both JWT and API Key for telemetry
$auth = Security::getAuthContext();
if (!$auth) {
    Response::error(401, "Unauthorized");
}

// [MASTERPIECE] LOG HEALTH SHIELD
// Explicitly ensure the log file exists and is writable on Hostinger.
$prodLogPath = __DIR__ . '/telemetry_error.log';
if (!file_exists($prodLogPath)) {
    @touch($prodLogPath);
    @chmod($prodLogPath, 0666);
}
if (is_writable($prodLogPath)) {
    ini_set('log_errors', 1);
    ini_set('error_log', $prodLogPath);
}

if ($_SERVER['REQUEST_METHOD'] === 'GET') {
    // -------------------------------------------------------------------------
    // GET: Fetch Telemetry with Server-Side Pagination (Admin/UI)
    // -------------------------------------------------------------------------
    $mac_address = $_GET['mac_address'] ?? '';
    // อธิบายการป้องกันคอขวด: เพิ่ม LIMIT และ OFFSET ในการ Query
    // บังคับทำ Pagination ป้องกัน Web Admin ประมวลผลจนเกิด Memory Limit Reached
    $limit = isset($_GET['limit']) ? max(1, min(1000, (int)$_GET['limit'])) : 100;
    $page = isset($_GET['page']) ? max(1, (int)$_GET['page']) : 1;
    $offset = ($page - 1) * $limit;

if (empty($mac_address)) {
        Response::error(400, "Missing mac_address parameter");
    }

try {
        // Safe schema detection
        $ampCol = 'current_a';
        try {
            $pdo->query("SELECT amp_a FROM telemetry LIMIT 1");
            $ampCol = 'amp_a';
        } catch (Exception $e) {}

$stmt = $pdo->prepare("
            SELECT 
                t.id, t.slot_id, t.mac_address, 
                t.voltage_v, t.$ampCol as amp_a, t.power_w, t.energy_kwh, 
                t.hz, t.pf, t.temp_c, t.humidity_rh, 
                t.compressor_state, 
                t.alarm_data, 
                t.recorded_at,
                ds.has_pzem,
                ds.has_dht11
            FROM telemetry t
            LEFT JOIN device_slots ds ON t.slot_id = ds.id
            WHERE t.mac_address = :mac_address
            ORDER BY t.recorded_at DESC
            LIMIT :limit OFFSET :offset   
        ");

$stmt->bindValue(':mac_address', $mac_address, PDO::PARAM_STR);
        $stmt->bindValue(':limit', $limit, PDO::PARAM_INT);
        $stmt->bindValue(':offset', $offset, PDO::PARAM_INT);
        $stmt->execute();
        $results = $stmt->fetchAll(PDO::FETCH_ASSOC);

// อธิบายการแปลข้อมูล (จุดซับซ้อนที่ 2):  
        // แปลง String JSON กลับเป็น Array อย่างระมัดระวัง เพื่อส่งออกแบบ Realtime
        // ให้ Web Admin (เช่น Next.js/React) เรียกใช้ Object `alarm_data.type` ได้ทันทีแบบไม่ต้อง Parse ใหม่
        foreach ($results as &$row) {
            if (!empty($row['alarm_data'])) {
                 // true = Assoc. Array Return
                 $row['alarm_data'] = json_decode($row['alarm_data'], true);
            }
        }

Response::success([
            'metadata' => [
                'limit' => $limit,
                'page' => $page,
                'offset' => $offset
            ],
            'data' => $results
        ], "Telemetry paginated data fetched");

} catch (Exception $e) {
        Response::error(500, "Fetch failed", null, $e->getMessage());
    }
    exit;
}

if ($_SERVER['REQUEST_METHOD'] !== 'POST') {
    Response::error(405, "Method Not Allowed");
}

// Input: JSON Array of logs
$input = json_decode(file_get_contents('php://input'), true);

if (!$input || !isset($input['logs']) || !is_array($input['logs'])) {
    Response::error(400, "Invalid Payload", "Expected JSON with 'logs' array");
}

$logs = $input['logs'];
$signature = $input['sig'] ?? ''; // [MASTERPIECE V7] Mandatory HMAC Signature

// [MASTERPIECE V7] RUTHLESS SECURITY CHECK
// Verify that the payload hasn't been tampered with using HMAC-SHA256
$gatewayMac = $input['gateway_mac'] ?? ($logs[0]['mac'] ?? '');
$gatewayMac = strtoupper(str_replace([':', '-', '.'], '', $gatewayMac));

$serverKey = MASTER_API_KEY; // Fallback from config.php
if (!empty($gatewayMac)) {
    try {
        $keyStmt = $pdo->prepare("SELECT secret_key FROM nodes WHERE mac_address = ? LIMIT 1");
        $keyStmt->execute([$gatewayMac]);
        $dbKey = $keyStmt->fetchColumn();
        if ($dbKey) $serverKey = $dbKey;
    } catch (Exception $e) {}
}

$payloadToSign = json_encode(['logs' => $logs]); 
$expectedSig = hash_hmac('sha256', $payloadToSign, $serverKey);

if (empty($signature) || $signature !== $expectedSig) {
    error_log("[SECURITY] Signature mismatch for Gateway $gatewayMac. Recv: $signature, Exp: $expectedSig");
    Response::error(403, "Invalid Payload Signature (Tampering Detected)");
}

$insertedCount = 0;

try {
    /**
     * [MASTERPIECE] Telemetry Sanity Guard
     * Validates and masks physically impossible data to prevent dashboard corruption.
     */
    $isSaneLog = function ($log, $mac) {
        $ts = $log['ts'] ?? 0;
        // Allow missing/zero TS (firmware fallback to server time)
        // Only reject if TS is explicitly garbage (non-numeric or non-zero and too old)
        if ($ts > 0 && $ts <= 946684800) { // If TS provided, it must be > Year 2000
            error_log("[JUNK DATA] Reject from $mac: Invalid Timestamp ($ts)");
            return false;
        }
        
        // Bounds Check (Masterpiece V6 thresholds)
        // PF: Allow 0.0 to 1.2
        if (isset($log['pf']) && ($log['pf'] < 0.0 || $log['pf'] > 1.2)) {
            // Log once per 100 failures to prevent disk bloat
            if (mt_rand(1, 100) == 1) error_log("[JUNK DATA] Throttled Log: PF ({$log['pf']}) out of bounds from $mac");
            return false;
        }

// Humidity: Allow -99.0 (Sensor Error) but reject crazy noise (> 105)
        if (isset($log['hum']) && $log['hum'] != -99.0 && ($log['hum'] < -15 || $log['hum'] > 105)) {
            if (mt_rand(1, 100) == 1) error_log("[JUNK DATA] Throttled Log: Humidity ({$log['hum']}) out of bounds from $mac");
            return false;
        }

// Frequency: Allow 0 (Inactive) or 40-75Hz
        if (isset($log['hz']) && $log['hz'] != 0 && ($log['hz'] < 40 || $log['hz'] > 75)) {
            if (mt_rand(1, 100) == 1) error_log("[JUNK DATA] Throttled Log: Hz ({$log['hz']}) out of bounds from $mac");
            return false;
        }

// Voltage: Single phase max 500V (High spike), 3-phase phase-to-phase can be ~450V.
        if (isset($log['v']) && ($log['v'] < 0 || $log['v'] > 500)) {
            error_log("[JUNK DATA] Reject from $mac (TS: $ts): Voltage ({$log['v']}) out of bounds");
            return false;
        }
        
        return true;
    };

// 0. SHARDING ROUTER INITIALIZATION
    global $ARCHIVE_DBS;
    $router = new DatabaseRouter($ARCHIVE_DBS, $pdo);
    $pdoLog = $router->getActiveWriteConnection();
    
    if (!$pdoLog) {
        throw new Exception("Telemetry Shard Unavailable");
    }

// [MASTERPIECE] Concurrency Shield: Execute core ingestion with retry capability
    Database::executeWithRetry(function() use ($pdo, $pdoLog, $logs, $isSaneLog) {
        $insertedCount = 0;
        $batchSize = 0;

$pdo->beginTransaction(); // RapidSolar Transaction (Metadata)
        $pdoLog->beginTransaction(); // Shard Transaction (Logs)

// [DEBUG] Log raw POST body for 3-phase trace
    $rawBody = file_get_contents('php://input');
    $logPath = __DIR__ . '/';
    file_put_contents($logPath . 'telemetry_raw.log', "[" . date('Y-m-d H:i:s') . "] RAW: " . $rawBody . "\n", FILE_APPEND);
    
    // --- DYNAMIC SCHEMA DETECTION [GOD-MODE FALLBACK] ---
    // [FIX] Schema detection must run on BOTH targets to avoid INSERT failures
    // caused by columns existing in one but not the other.
    $checkCols = [];
    $potentialSlotCols = ['last_seen_at', 'is_online', 'has_pzem', 'has_dht11', 'operating_mode', 'power_state', 'slot_index', 'firmware_version', 'meter_type'];
    foreach ($potentialSlotCols as $col) {
        try {
            $pdo->query("SELECT $col FROM device_slots LIMIT 1");
            $checkCols[] = $col;
        } catch (Exception $e) {}
    }

$telemetryColsMain = [];
    try {
        $q = $pdo->query("DESCRIBE telemetry");
        if ($q) $telemetryColsMain = $q->fetchAll(PDO::FETCH_COLUMN);
    } catch (Exception $e) {}

$telemetryColsShard = [];
    try {
        $q = $pdoLog->query("DESCRIBE telemetry");
        if ($q) $telemetryColsShard = $q->fetchAll(PDO::FETCH_COLUMN);
    } catch (Exception $e) {}

// [MASTERPIECE] Intersection of columns ensures No-Fail Dual Ingestion
    $telemetryCols = array_intersect($telemetryColsMain, $telemetryColsShard);

// 1. Prepare Telemetry INSERT - BUILD DYNAMICALLY based on what actually exists
    // [MASTERPIECE] Only include columns that EXIST in the schema to prevent 500 errors.
    $tFields = [
        'slot_id'          => ':slot_id',
        'mac_address'      => ':mac',
        'voltage_v'        => ':v',
        'power_w'          => ':w',
        'energy_kwh'       => ':kwh',
        'temp_c'           => ':sq_temp',
        'humidity_rh'      => ':rh',
        'pf'               => ':pf',
        'hz'               => ':hz',
        'compressor_state' => ':comp',
        'alarm_data'       => ':alarm_data',
        'recorded_at'      => ':time'
    ];

// Optional columns: only add if they exist in the DB
    $ampCol = in_array('amp_a', $telemetryCols) ? 'amp_a' : 'current_a';
    $tFields[$ampCol] = ':a';

if (in_array('source_identity', $telemetryCols))      $tFields['source_identity']      = ':source_id';
    if (in_array('packet_hash', $telemetryCols))          $tFields['packet_hash']          = ':p_hash';
    if (in_array('operating_mode', $telemetryCols))       $tFields['operating_mode']       = ':op_mode';
    if (in_array('health_index', $telemetryCols))         $tFields['health_index']         = ':health';
    if (in_array('error_code', $telemetryCols))           $tFields['error_code']           = ':err';
    if (in_array('firmware_version', $telemetryCols))     $tFields['firmware_version']     = ':fw';
    if (in_array('outdoor_temp_c', $telemetryCols))       $tFields['outdoor_temp_c']       = ':out_temp';
    if (in_array('outdoor_humidity_rh', $telemetryCols))  $tFields['outdoor_humidity_rh']  = ':out_hum';
    
    // 3-Phase Columns
    if (in_array('voltage_v2', $telemetryCols)) $tFields['voltage_v2'] = ':v2';
    if (in_array('amp_a2',     $telemetryCols)) $tFields['amp_a2']     = ':a2';
    if (in_array('power_w2',   $telemetryCols)) $tFields['power_w2']   = ':w2';
    if (in_array('energy_kwh2', $telemetryCols)) $tFields['energy_kwh2'] = ':kwh2';
    if (in_array('hz2',        $telemetryCols)) $tFields['hz2']        = ':hz2';
    if (in_array('pf2',        $telemetryCols)) $tFields['pf2']        = ':pf2';
    
    if (in_array('voltage_v3', $telemetryCols)) $tFields['voltage_v3'] = ':v3';
    if (in_array('amp_a3',     $telemetryCols)) $tFields['amp_a3']     = ':a3';
    if (in_array('power_w3',   $telemetryCols)) $tFields['power_w3']   = ':w3';
    if (in_array('energy_kwh3', $telemetryCols)) $tFields['energy_kwh3'] = ':kwh3';
    if (in_array('hz3',        $telemetryCols)) $tFields['hz3']        = ':hz3';
    if (in_array('pf3',        $telemetryCols)) $tFields['pf3']        = ':pf3';
    
    if (in_array('total_power_w',   $telemetryCols)) $tFields['total_power_w']   = ':total_w';
    if (in_array('total_energy_kwh', $telemetryCols)) $tFields['total_energy_kwh'] = ':total_k';
 
    // [V19.0 WORLD-CLASS] Industrial Diagnostics
    if (in_array('rssi', $telemetryCols))        $tFields['rssi']        = ':rssi';
    if (in_array('free_heap', $telemetryCols))   $tFields['free_heap']   = ':heap';
    if (in_array('uptime_sec', $telemetryCols))  $tFields['uptime_sec']  = ':uptime';
    if (in_array('stack_min', $telemetryCols))   $tFields['stack_min']   = ':stack';

// 1. Prepare Telemetry INSERT - BIND TO SHARD CONNECTION (Archive)
    $sqlArchive = "INSERT INTO telemetry (" . implode(", ", array_keys($tFields)) . ") 
                   VALUES (" . implode(", ", array_values($tFields)) . ")
                   ON DUPLICATE KEY UPDATE id=id"; 
    $stmtArchive = $pdoLog->prepare($sqlArchive);

// 2. Prepare Telemetry INSERT - BIND TO MAIN CONNECTION (Live Cache)
    $sqlLive = "INSERT INTO telemetry (" . implode(", ", array_keys($tFields)) . ") 
                VALUES (" . implode(", ", array_values($tFields)) . ")
                ON DUPLICATE KEY UPDATE id=id";
    $stmtLive = $pdo->prepare($sqlLive);

// 3. Prepare Slot UPDATE
    $heartbeatFields = [];
    if (in_array('last_seen_at', $checkCols)) $heartbeatFields[] = "last_seen_at = NOW()";
    if (in_array('is_online', $checkCols)) $heartbeatFields[] = "is_online = 1";
    if (in_array('has_pzem', $checkCols)) $heartbeatFields[] = "has_pzem = :hp";
    if (in_array('has_dht11', $checkCols)) $heartbeatFields[] = "has_dht11 = :hd";
    if (in_array('operating_mode', $checkCols)) $heartbeatFields[] = "operating_mode = :op_mode";
    if (in_array('firmware_version', $checkCols)) $heartbeatFields[] = "firmware_version = :fw_heartbeat";
    if (in_array('meter_type', $checkCols))       $heartbeatFields[] = "meter_type = :meter_check";
    
    // [MASTERPIECE] Auto-Sync Reset: Clear the pending flag when data arrives
    // This removes the "SYNCING..." status in the app automatically.
    $heartbeatFields[] = "is_pending_sync = 0";

if (in_array('power_state', $checkCols)) {
        // [MASTERPIECE] Transition-Aware Timestamping (Atomic Logic)
        // state_updated_at ONLY updates if the power_state actually flips.
        // IMPORTANT: Must happen BEFORE power_state is overwritten in this same UPDATE statement.
        $heartbeatFields[] = "state_updated_at = CASE WHEN power_state != :power_check THEN NOW() ELSE state_updated_at END";
        $heartbeatFields[] = "power_state = :power_update";
    }

$updateSlotSql = !empty($heartbeatFields) 
        ? "UPDATE device_slots SET " . implode(", ", $heartbeatFields) . " WHERE id = :slot_id_update"
        : "SELECT 1"; 
    $stmtSlot = $pdo->prepare($updateSlotSql);

// --- DATA MAPPING CONTEXT ---
    $slotIndexCol = in_array('slot_index', $checkCols);

foreach ($logs as $index => $log) {
        $slotId = $log['slot_id'] ?? null;
        $mac = $log['mac'] ?? null;

// [MASTERPIECE] Sanity Check before processing
        if (!$isSaneLog($log, $mac)) {
            error_log("[JUNK DATA] Discarded malformed log from $mac (TS: " . ($log['ts'] ?? 'NULL') . ")");
            continue; 
        }

// [MASTERPIECE] MICRO-BATCHING: Commit and breathe every 10 rows to release locks
        // Prevents a single 100-log sync from blocking the entire table for seconds.
        if ($batchSize >= 10) {
            $pdo->commit();
            $pdoLog->commit();
            $pdo->beginTransaction();
            $pdoLog->beginTransaction();
            $batchSize = 0;
        }
        $batchSize++;

// [OPTIMIZATION] Local Cache for Slot Identity & Config to speed up batch ingestion
        static $slotConfigCache = [];
        $role = 'UNKNOWN';
        $config = null;

if (!$slotId && $mac) {
            // Find slot by MAC
            try {
                // [MASTERPIECE OPTIMIZATION] Robust Index Lookup (Format-Agnostic)
                // We use REPLACE to strip colons/dashes from DB columns to match clean hex MACs.
                $resStmt = $pdo->prepare("
                    SELECT id, mac_address, mac_pzem, mac_dht, has_pzem, has_dht11, operating_mode 
                    FROM device_slots 
                    WHERE REPLACE(REPLACE(REPLACE(mac_address, ':', ''), '-', ''), '.', '') = :m1 
                       OR REPLACE(REPLACE(REPLACE(mac_pzem, ':', ''), '-', ''), '.', '') = :m2 
                       OR REPLACE(REPLACE(REPLACE(mac_dht, ':', ''), '-', ''), '.', '') = :m3 
                    LIMIT 1
                ");
                $resStmt->execute([':m1' => $mac, ':m2' => $mac, ':m3' => $mac]);
                $config = $resStmt->fetch(PDO::FETCH_ASSOC);
                
                if ($config) {
                    $slotId = $config['id'];
                    $slotConfigCache[$slotId] = $config;
                }
            } catch (Exception $e) { /* Resolution failed */ }
        }

if ($slotId) {
            // Retrieve config from cache if not already fetched
            if (!isset($slotConfigCache[$slotId])) {
                try {
                    $cfgStmt = $pdo->prepare("SELECT id, mac_address, mac_pzem, mac_dht, has_pzem, has_dht11, operating_mode FROM device_slots WHERE id = ?");
                    $cfgStmt->execute([$slotId]);
                    $slotConfigCache[$slotId] = $cfgStmt->fetch(PDO::FETCH_ASSOC);
                } catch (Exception $e) {}
            }
            $config = $slotConfigCache[$slotId];
            
            // Determine Role of the current packet's MAC
            if ($config && $mac) {
                // [MASTERPIECE] Standardized Sanitization (Strip all separators and Uppercase)
                $cleanMac    = strtoupper(str_replace([':', '-', '.'], '', $mac));
                $cMaster     = strtoupper(str_replace([':', '-', '.'], '', $config['mac_address'] ?? ''));
                $cPzem       = strtoupper(str_replace([':', '-', '.'], '', $config['mac_pzem'] ?? ''));
                $cDht        = strtoupper(str_replace([':', '-', '.'], '', $config['mac_dht'] ?? ''));

if ($cleanMac === $cMaster) {
                    $role = 'MASTER';
                } else if ($cleanMac === $cPzem) {
                    $role = 'PZEM_NODE';
                } else if ($cleanMac === $cDht) {
                    $role = 'DHT_NODE';
                } else {
                    // [HACKER GUARD] If MAC doesn't match any role in this slot, it's a "Ghost Packet"
                    // We allow it to be recorded for debugging but MASK ALL sensitive data.
                    $role = 'GHOST';
                }
            }
        }

if (!$slotId) continue;

// Resolve Smart_Panel_ format (MAC-based) to actual UUID if existing
        if (strpos($slotId, 'Smart_Panel_') === 0) {
            if (isset($macCache[$slotId])) {
                $slotId = $macCache[$slotId];
            } else {
                $rawMacForResolve = substr($slotId, 8);
                try {
                    // [MASTERPIECE] Robust MAC resolution using character-stripping to bypass colon/case differences
                    $resolveStmt = $pdo->prepare("
                        SELECT id FROM device_slots 
                        WHERE (
                            REPLACE(REPLACE(REPLACE(mac_address, ':', ''), '-', ''), '.', '') = UPPER(?)
                            OR REPLACE(REPLACE(REPLACE(mac_pzem, ':', ''), '-', ''), '.', '') = UPPER(?)
                        )
                        AND id NOT LIKE 'Smart_Panel_%'
                        ORDER BY is_online DESC, last_seen_at DESC
                        LIMIT 1
                    ");
                    $resolveStmt->execute([$rawMacForResolve, $rawMacForResolve]);
                    $resolvedId = $resolveStmt->fetchColumn();
                    if ($resolvedId) {
                        $macCache[$slotId] = $resolvedId;
                        $slotId = $resolvedId;
                    }
                } catch (Exception $e) { /* Resolution failed */ }
            }
        }

// --- AUTO-PROVISIONING (Self-Healing) ---
        if (strpos($slotId, 'Smart_Panel_') === 0) {
            $rawMac = substr($slotId, 8);
            
            // [MASTERPIECE] Suppression Check (Nuclear Wipe Protocol)
            // If the hardware was recently wiped by the user, don't auto-heal it.
            $stmtBlacklist = $pdo->prepare("SELECT id FROM audit_logs WHERE action = 'PERMANENT_DELETE_HARDWARE' AND target_id = ? LIMIT 1");
            $stmtBlacklist->execute([$rawMac]);
            if ($stmtBlacklist->fetch()) {
                error_log("[TELEMETRY] Suppression: Skipping auto-provision for deleted MAC $rawMac");
                continue; 
            }

$checkStmt = $pdo->prepare("SELECT COUNT(*) FROM device_slots WHERE id = ?");
            $checkStmt->execute([$slotId]);
            
            if ($checkStmt->fetchColumn() == 0) {
                $macDisplay = implode(':', str_split($rawMac, 2));
                
                // System Auto-Provisioning to Staging Area
                $opsUserId = 'SYSTEM_AUTO_STAGING'; 
                $stagingSiteId = 'SITE_STAGING_AREA'; 
                $stagingRoomId = 'ROOM_STAGING_AREA';

$pdo->prepare("INSERT IGNORE INTO users (id, email, display_name) VALUES (?, ?, ?)")
                    ->execute([$opsUserId, 'system@Smart_Panel.local', 'System Staging']);
                
                // Fix: 'home' is a valid ENUM type in V13.0, 'other' is not
                $pdo->prepare("INSERT IGNORE INTO sites (id, user_id, name, type) VALUES (?, ?, 'Staging Area', 'home')")
                    ->execute([$stagingSiteId, $opsUserId]);
                
                $pdo->prepare("INSERT IGNORE INTO rooms (id, site_id, name) VALUES (?, ?, 'Unassigned Devices')")
                    ->execute([$stagingRoomId, $stagingSiteId]);

// Calculate next slot index safely (avoiding same-table subquery issues in some MySQL versions)
                $nextIdx = 1;
                if ($slotIndexCol) {
                    $idxStmt = $pdo->prepare("SELECT COALESCE(MAX(slot_index), 0) + 1 FROM device_slots WHERE room_id = ?");
                    $idxStmt->execute([$stagingRoomId]);
                    $nextIdx = $idxStmt->fetchColumn();
                }

$cols = ["id", "room_id", "name", "mac_address"];
                $vals = ["?", "?", "?", "?"];
                $params = [$slotId, $stagingRoomId, "New Device ($macDisplay)", $rawMac];

if ($slotIndexCol) { $cols[] = "slot_index"; $vals[] = "?"; $params[] = $nextIdx; }
                if (in_array('is_online', $checkCols)) { $cols[] = "is_online"; $vals[] = "1"; }
                if (in_array('last_seen_at', $checkCols)) { $cols[] = "last_seen_at"; $vals[] = "NOW()"; }
                
                $pdo->prepare("INSERT INTO device_slots (" . implode(", ", $cols) . ") VALUES (" . implode(", ", $vals) . ")")
                    ->execute($params);
            }
        }

$recordedAt = (isset($log['ts']) && (int)$log['ts'] > 0) 
            ? date('Y-m-d H:i:s', (int)($log['ts'] / (strlen((string)$log['ts']) > 11 ? 1000 : 1))) 
            : date('Y-m-d H:i:s');

// Normalize MAC address for database (remove colons/dashes)
        $normalizedMac = $mac ? strtoupper(str_replace([':', '-', '.'], '', $mac)) : 'UNKNOWN';

$sourceIdentity = $log['source'] ?? 'DIRECT';
        
        // [MASTERPIECE SECURITY] Source Identity Authentication
        // Verify if the claim of being "DIRECT" or "MASTER" is legitimate based on Slot MAC mapping.
        try {
            $verifyStmt = $pdo->prepare("SELECT mac_address FROM device_slots WHERE id = ? LIMIT 1");
            $verifyStmt->execute([$slotId]);
            $assignedMac = $verifyStmt->fetchColumn();
            
            if ($assignedMac) {
                $cleanAssignedMac = strtoupper(str_replace([':', '-', '.'], '', $assignedMac));
                if (($sourceIdentity === 'DIRECT' || $sourceIdentity === 'MASTER') && $normalizedMac !== $cleanAssignedMac) {
                    // Logic: This packet claims to be Direct from the device, but the MAC doesn't match the Slot owner.
                    // This implies it's being proxied through the mesh or is a spoofing attempt.
                    $sourceIdentity = 'MESH_PROXY'; 
                }
            }
        } catch (Exception $e) { /* Fallback to reported identity */ }

// [MASTERPIECE - CYCLE 4] SELECTIVE DATA OWNERSHIP
        // 1. Identify "Owners" of specific telemetry fields for this slot.
        // [AUDIT] All MACs must be strictly sanitized (stripped + uppercase) for reliable matching
        $masterMac  = strtoupper(str_replace([':', '-', '.'], '', $config['mac_address'] ?? ''));
        $pzemMac    = strtoupper(str_replace([':', '-', '.'], '', $config['mac_pzem'] ?? ''));
        $dhtMac     = strtoupper(str_replace([':', '-', '.'], '', $config['mac_dht'] ?? ''));
        $currentMac = strtoupper(str_replace([':', '-', '.'], '', $mac ?? ''));

// [MASTERPIECE] Unified Key Ingestion: Prioritize short keys for efficiency
        $v = $log['v'] ?? $log['voltage'] ?? $log['v1'] ?? 0;
        $a = $log['curr'] ?? $log['amp'] ?? $log['a'] ?? $log['a1'] ?? 0;
        $w = $log['watt'] ?? $log['w'] ?? $log['power'] ?? $log['w1'] ?? 0;
        $kwh = (float)($log['kwh'] ?? $log['kwh1'] ?? 0);
        
        $pf = $log['pf'] ?? $log['pf1'] ?? 1.0;
        $hz = $log['hz'] ?? $log['hz1'] ?? 50.0;
        $temp = isset($log['temp']) ? (float)$log['temp'] : (isset($log['temperature']) ? (float)$log['temperature'] : null);
        // [MASTERPIECE MITIGATION] Prevent 0.0 or sentinel -99.0 from wiping history
        if ($temp === 0.0 || $temp === -99.0) $temp = null; 
        
        $hum = isset($log['hum']) ? (float)$log['hum'] : (isset($log['humidity']) ? (float)$log['humidity'] : null);
        if ($hum === 0.0 || $hum === -99.0) $hum = null; 
        
        // [MASTERPIECE] Total Electrical Metrics
        $totalW = $log['total_watt'] ?? $log['total_w'] ?? $w;
        $totalK = $log['total_kwh'] ?? $log['total_k'] ?? $kwh;
        $meterType = (int)($log['meter_type'] ?? 1); // [MASTERPIECE] Default to Single-Phase for legacy

// [REMOVED COIL TEMP]

$out_temp = $log['out_temp'] ?? null;
        if ($out_temp !== null) {
            $out_temp = (float)$out_temp;
            if ($out_temp === 0.0 || $out_temp === -99.0) $out_temp = null;
        }

$out_hum = $log['out_hum'] ?? null;
        if ($out_hum !== null) {
            $out_hum = (float)$out_hum;
            if ($out_hum === 0.0 || $out_hum === -99.0) $out_hum = null;
        }

// [MASTERPIECE] Role-Based Mapping (Architecture Reconfiguration)
        // [FIX] Priority: SHM-Sanitized MAC Ownership
        // 1. PZEM_NODE (Slave 1) owns Electrical Data (V, A, W, WH).
        // 2. DHT_NODE (Slave 2) owns Climate Data (Temp, Hum).
        // 3. MASTER (Controller) owns Control State, Coil Temp, and can fallback to Climate.

// [MASTERPIECE] Rule 1: PZEM (Electrical) Ownership
        // [HYBRID PROTOCOL] We record data from both Master and designated Slave.
        // This ensures No Data Loss if a node goes offline. 
        // Strict Priority is handled by latest.php during retrieval.
        $hasSlavePzem = (!empty($pzemMac) && $pzemMac !== '000000000000');
        
        if ($hasSlavePzem) {
            if ($currentMac !== $pzemMac && $currentMac !== $masterMac) {
                // Ignore random mesh nodes trying to report for this slot
                $v = null; $a = null; $w = null; $pf = null; $hz = null;
            } else {
                // [CONCURRENT ARCHITECTURE]
                // We allow Master data to be recorded alongside Slave data for history.
                // However, we mask Master's 0.0V readings to prevent them from 
                // flickering in the 'latest' display if the Slave is active.
                if ($currentMac === $masterMac && (float)$v <= 10.0) { 
                    $v = null; $a = null; $w = null; 
                }
            }
        } else if ($masterMac !== '' && $currentMac !== $masterMac) {
            // No Slave PZEM? Only designated Master allowed.
            $v = null; $a = null; $w = null; $pf = null; $hz = null;
        }

// [MASTERPIECE] Rule 2: DHT (Climate) Ownership with Master Fallback
        if (!empty($dhtMac)) {
            if ($currentMac !== $dhtMac && $currentMac !== $masterMac) {
                // Ignore climate from non-designated slaves
                $temp = null; $hum = null;
            } else {
                // [SANITIZATION] Map sentinel/error values to NULL for deep backfill
                if ((float)$temp === 0.0 || (float)$temp === -99.0) { $temp = null; $hum = null; }
            }
        }

// [MASTERPIECE] Rule 3: Coil & Control Ownership (STRICT MASTER ONLY)
        if (!empty($masterMac) && $currentMac !== $masterMac) {
            $coil = null;
            // [HACKER GUARD] Prevent Slaves from reporting saturation or op_mode changes
            $sat = 0; 
            $op_mode = null;
        }

// [MASTERPIECE] Rule 4: Ghost Packet Isolation
        if ($role === 'GHOST') {
            // Mask everything except the fact that it's online
            $v=$a=$w=$pf=$hz=$temp=$hum=$coil=$kwh = null;
            $comp = 0; $alarms = '[]';
        }

// [FIX] Only bind params that are actually in the SQL query ($tFields).
        $tParams = [
            ':slot_id'   => $slotId,
            ':mac'       => $normalizedMac,
            ':v'         => $v,
            ':a'         => $a,
            ':w'         => $w,
            ':kwh'       => $kwh,
            ':pf'        => $pf,
            ':hz'        => $hz,
            ':sq_temp'   => $temp,
            ':rh'        => $hum,
            ':comp'      => $log['comp'] ?? $log['compressor_state'] ?? 0,
            ':alarm_data'=> (isset($log['alarms']) && is_array($log['alarms'])) ? json_encode($log['alarms']) : null,
            ':time'      => $recordedAt,
        ];
        // Conditionally bind optional params only when the column exists in this DB
        if (isset($tFields['source_identity']))   $tParams[':source_id'] = $sourceIdentity;
        if (isset($tFields['packet_hash']))       $tParams[':p_hash']    = $log['hash'] ?? null;
        if (isset($tFields['operating_mode'])) {
            $fallbackMode = ($config && isset($config['operating_mode'])) ? $config['operating_mode'] : 'normal';
            $tParams[':op_mode'] = $log['op_mode'] ?? $fallbackMode;
        }
        if (isset($tFields['packet_hash']))       $tParams[':p_hash']    = $log['hash'] ?? null;
        if (isset($tFields['outdoor_temp_c']))    $tParams[':out_temp']  = $out_temp;
        if (isset($tFields['outdoor_humidity_rh'])) $tParams[':out_hum'] = $out_hum;

if (isset($tFields['operating_mode'])) {
            // [MASTERPIECE] Mode Attribution Logic
            // If log has mode, use it. Otherwise, fallback to the current known mode of the slot.
            $fallbackMode = ($config && isset($config['operating_mode'])) ? $config['operating_mode'] : 'normal';
            $tParams[':op_mode'] = $log['op_mode'] ?? $fallbackMode;
        }
        if (isset($tFields['health_index'])) $tParams[':health'] = $log['hlth'] ?? $log['health'] ?? 100.0;
        if (isset($tFields['error_code'])) $tParams[':err'] = $log['err'] ?? 0;
        if (isset($tFields['firmware_version'])) $tParams[':fw'] = $log['ver'] ?? $log['fw'] ?? null;
 
        // [V19.0 WORLD-CLASS] Diagnostic Parameters
        if (isset($tFields['rssi']))      $tParams[':rssi']   = $log['rssi'] ?? null;
        if (isset($tFields['free_heap'])) $tParams[':heap']   = $log['free_heap'] ?? null;
        if (isset($tFields['uptime_sec']))$tParams[':uptime'] = $log['uptime'] ?? null;
        if (isset($tFields['stack_min'])) $tParams[':stack']  = $log['stack_min'] ?? null;
        
        // 3-Phase Parameters
        if (isset($tFields['voltage_v2'])) $tParams[':v2'] = (float)($log['v2'] ?? 0);
        if (isset($tFields['amp_a2']))     $tParams[':a2'] = (float)($log['a2'] ?? 0);
        if (isset($tFields['power_w2']))   $tParams[':w2'] = (float)($log['w2'] ?? 0);
        if (isset($tFields['energy_kwh2'])) $tParams[':kwh2'] = (float)($log['kwh2'] ?? 0);
        if (isset($tFields['hz2']))        $tParams[':hz2'] = (float)($log['hz2'] ?? 50.0);
        if (isset($tFields['pf2']))        $tParams[':pf2'] = (float)($log['pf2'] ?? 1.0);
        
        if (isset($tFields['voltage_v3'])) $tParams[':v3'] = (float)($log['v3'] ?? 0);
        if (isset($tFields['amp_a3']))     $tParams[':a3'] = (float)($log['a3'] ?? 0);
        if (isset($tFields['power_w3']))   $tParams[':w3'] = (float)($log['w3'] ?? 0);
        if (isset($tFields['energy_kwh3'])) $tParams[':kwh3'] = (float)($log['kwh3'] ?? 0);
        if (isset($tFields['hz3']))        $tParams[':hz3'] = (float)($log['hz3'] ?? 50.0);
        if (isset($tFields['pf3']))        $tParams[':pf3'] = (float)($log['pf3'] ?? 1.0);
        
        if (isset($tFields['total_power_w']))   $tParams[':total_w'] = $totalW;
        if (isset($tFields['total_energy_kwh'])) $tParams[':total_k'] = $totalK;

// [ADDITIVE HOOK] Energy Integration Engine (Riemann Sum Fallback)
        // Must be called BEFORE execute() to patch $tParams
        require 'energy_integration_engine.php';

$stmtArchive->execute($tParams);
        $stmtLive->execute($tParams);

// [WORLD-CLASS] Grid Integrity & Hardware Fault Logging
        if (isset($input['analytics']) && !empty($input['gateway_mac'])) {
            $analytics = $input['analytics'];
            $gatewayMac = strtoupper(str_replace([':', '-', '.'], '', $input['gateway_mac']));
            
            // Resolve node_id from gateway_mac
            $nodeStmt = $pdo->prepare("SELECT id FROM nodes WHERE mac_address = ? LIMIT 1");
            $nodeStmt->execute([$gatewayMac]);
            $nodeId = $nodeStmt->fetchColumn();
            
            if ($nodeId) {
                // [GRID INTEGRITY]
                $gridStmt = $pdo->prepare("INSERT INTO grid_integrity_logs 
                    (node_id, imbalance_v, imbalance_a, status) 
                    VALUES (?, ?, ?, ?)");
                $gridStmt->execute([
                    $nodeId,
                    $analytics['unbalance_v'] ?? 0,
                    $analytics['unbalance_p'] ?? 0, 
                    $analytics['grid_status'] ?? 'stable'
                ]);

// [HARDWARE FAULTS] - New V19.0 Masterpiece logic
                if (isset($input['faults']) && is_array($input['faults'])) {
                    $faultStmt = $pdo->prepare("INSERT INTO hardware_fault_logs 
                        (node_id, slot_index, fault_code, severity, description) 
                        VALUES (?, ?, ?, ?, ?)");
                    foreach ($input['faults'] as $fault) {
                        $faultStmt->execute([
                            $nodeId,
                            $fault['slot_index'] ?? null,
                            $fault['code'] ?? 'UNKNOWN_FAULT',
                            $fault['severity'] ?? 'warning',
                            $fault['desc'] ?? ''
                        ]);
                    }
                }
            }
        }

// [ADDITIVE HOOK] Energy Anchor Plugin (V2 High-Precision)
        require 'energy_anchor.php';

// --- SLOT HEARTBEAT UPDATE (Selective) ---
        $cleanCurrentMac = strtoupper(str_replace([':', '-', '.'], '', $mac ?? ''));
        
        $stmtSlotParams = [':slot_id_update' => $slotId];
        $roleFields = ["last_seen_at = NOW()", "is_online = 1"];
        
        $isAuthoritative = false;
        if ($cleanCurrentMac === $masterMac || ($pzemMac && $cleanCurrentMac === $pzemMac) || ($dhtMac && $cleanCurrentMac === $dhtMac)) {
            $isAuthoritative = true;
            $roleFields[] = "is_pending_sync = 0";
        }

if ($cleanCurrentMac === $masterMac || empty($masterMac)) {
            if (in_array('operating_mode', $checkCols) && isset($log['op_mode'])) {
                $telemetryOpMode = $log['op_mode'];
                $finalOpMode = $telemetryOpMode;
                try {
                    // [MASTERPIECE] Consensus-Based State Protection V4 (Bypass)
                    // Fetch the LATEST intended state from the commands table.
                    $latestCmdStmt = $pdo->prepare("
                        SELECT payload, created_at FROM commands 
                        WHERE slot_id = ? AND command = 'bypass' 
                        ORDER BY created_at DESC LIMIT 1
                    ");
                    $latestCmdStmt->execute([$slotId]);
                    $latestCmd = $latestCmdStmt->fetch();

if ($latestCmd) {
                        $cmdAge = time() - strtotime($latestCmd['created_at']);
                        $logAge = time() - strtotime($recordedAt);
                        
                        // [MASTERPIECE] Increased Grace Period (60s) for slow server/network
                        // Rule: If command is fresh (<60s) OR log is older than command
                        if ($cmdAge < 60 || strtotime($recordedAt) < strtotime($latestCmd['created_at'])) {
                            $payload = json_decode($latestCmd['payload'], true);
                            $intendedState = (strtoupper($payload['value'] ?? '') === 'ON') ? 'bypass' : 'normal';
                            
                            // If telemetry contradicts our newest intent, we discard telemetry's opinion.
                            if ($telemetryOpMode !== $intendedState) {
                                $finalOpMode = $intendedState; // FORCE to intent
                            }
                        }
                    }
                } catch (Exception $e) {}

if ($finalOpMode !== null) {
                    $roleFields[] = "operating_mode = :op_mode";
                    $stmtSlotParams[':op_mode'] = $finalOpMode;
                }
            }
            if (in_array('firmware_version', $checkCols) && (isset($log['ver']) || isset($log['fw']))) {
                $roleFields[] = "firmware_version = :fw_heartbeat";
                $stmtSlotParams[':fw_heartbeat'] = $log['ver'] ?? $log['fw'] ?? '1.0.0';
            }
            if (in_array('power_state', $checkCols) && isset($log['power_on'])) {
                $telemetryPowerOn = ($log['power_on'] === true || $log['power_on'] === 1) ? 1 : 0;
                $finalPowerState = $telemetryPowerOn;
                try {
                    // [MASTERPIECE] Consensus-Based State Protection V4 (Power)
                    $latestCmdStmt = $pdo->prepare("
                        SELECT payload, created_at FROM commands 
                        WHERE slot_id = ? AND command = 'power' 
                        ORDER BY created_at DESC LIMIT 1
                    ");
                    $latestCmdStmt->execute([$slotId]);
                    $latestCmd = $latestCmdStmt->fetch();

if ($latestCmd) {
                        $cmdAge = time() - strtotime($latestCmd['created_at']);
                        // [MASTERPIECE] Increased Grace Period (60s)
                        if ($cmdAge < 60 || strtotime($recordedAt) < strtotime($latestCmd['created_at'])) {
                            $payload = json_decode($latestCmd['payload'], true);
                            $intendedState = (strtoupper($payload['value'] ?? '') === 'ON' || ($payload['value'] ?? '') == 1) ? 1 : 0;
                            
                            if ($telemetryPowerOn !== $intendedState) {
                                $finalPowerState = $intendedState; // FORCE to intent
                            }
                        }
                    }
                } catch (Exception $e) {}

if ($finalPowerState !== null) {
                    // [MASTERPIECE UI FIX] If mode is BYPASS, we MUST be Power ON for the UI to display correctly
                    if ($finalOpMode === 'bypass') {
                        $finalPowerState = 1;
                    }
                    $roleFields[] = "power_state = :power_update";
                    $stmtSlotParams[':power_check'] = $finalPowerState;
                    $stmtSlotParams[':power_update'] = $finalPowerState;
                }
            }

// [MASTERPIECE] Added Target Temp Protection
            if (in_array('target_temp', $checkCols) && isset($log['target_temp'])) {
                $telemetryTemp = (float)$log['target_temp'];
                $finalTemp = $telemetryTemp;
                try {
                    $latestCmdStmt = $pdo->prepare("
                        SELECT payload, created_at FROM commands 
                        WHERE slot_id = ? AND command = 'target_temp' 
                        ORDER BY created_at DESC LIMIT 1
                    ");
                    $latestCmdStmt->execute([$slotId]);
                    $latestCmd = $latestCmdStmt->fetch();

if ($latestCmd) {
                        $cmdAge = time() - strtotime($latestCmd['created_at']);
                        if ($cmdAge < 60 || strtotime($recordedAt) < strtotime($latestCmd['created_at'])) {
                            $payload = json_decode($latestCmd['payload'], true);
                            $intendedTemp = (float)($payload['value'] ?? $payload);
                            if (abs($telemetryTemp - $intendedTemp) > 0.1) {
                                $finalTemp = $intendedTemp;
                            }
                        }
                    }
                } catch (Exception $e) {}

if ($finalTemp !== null) {
                    $roleFields[] = "target_temp = :target_temp_update";
                    $stmtSlotParams[':target_temp_update'] = $finalTemp;
                }
            }
        }
        
        if (in_array('has_pzem', $checkCols) && $currentMac === $masterMac && isset($log['has_pzem'])) {
            $roleFields[] = "has_pzem = :hp";
            $stmtSlotParams[':hp'] = $log['has_pzem'] ? 1 : 0;
        }
        if (in_array('has_dht11', $checkCols) && $currentMac === $masterMac && isset($log['has_dht11'])) {
            $roleFields[] = "has_dht11 = :hd";
            $stmtSlotParams[':hd'] = $log['has_dht11'] ? 1 : 0;
        }
        if (in_array('meter_type', $checkCols) && $currentMac === $masterMac && isset($log['meter_type'])) {
            $roleFields[] = "meter_type = :mt";
            $stmtSlotParams[':mt'] = (int)$log['meter_type'];
        }

$updateSql = "UPDATE device_slots SET " . implode(", ", $roleFields) . " WHERE id = :slot_id_update";
        $pdo->prepare($updateSql)->execute($stmtSlotParams);
        
        $insertedCount++;
    }

// --- PROXY MESH DATA HANDLING ---
    if (isset($input['mesh']) && is_array($input['mesh']) && !empty($input['mesh'])) {
        foreach ($input['mesh'] as $m) {
            $mac = strtoupper(str_replace([':', '-', '.'], '', $m['mac']));
            $meshSlotId = 'Smart_Panel_' . $mac;
            $mPzemMac = ''; $mDhtMac = ''; $mMasterMac = '';
            
            static $macToSlotIdLookup = []; 
            if (isset($macToSlotIdLookup[$mac])) {
                $meshSlotId = $macToSlotIdLookup[$mac];
            }

try {
                $resStmtMesh = $pdo->prepare("
                    SELECT id, mac_address, mac_pzem, mac_dht FROM device_slots 
                    WHERE REPLACE(mac_address, ':', '') = :m1 
                       OR REPLACE(mac_pzem, ':', '') = :m2 
                       OR REPLACE(mac_dht, ':', '') = :m3 
                    LIMIT 1
                ");
                $resStmtMesh->execute([':m1' => $mac, ':m2' => $mac, ':m3' => $mac]);
                $mConfig = $resStmtMesh->fetch(PDO::FETCH_ASSOC);
                if ($mConfig) {
                    $meshSlotId = $mConfig['id'];
                    $macToSlotIdLookup[$mac] = $meshSlotId;
                    $mMasterMac = str_replace([':', '-', '.'], '', strtoupper($mConfig['mac_address'] ?? ''));
                    $mPzemMac = str_replace([':', '-', '.'], '', strtoupper($mConfig['mac_pzem'] ?? ''));
                    $mDhtMac = str_replace([':', '-', '.'], '', strtoupper($mConfig['mac_dht'] ?? ''));
                }
            } catch (Exception $e) { /* Fallback */ }

$normalizedMeshMac = $mac;
            $currentMeshMac = $mac;

$mv = $m['v'] ?? 0;
            $ma = $m['curr'] ?? $m['amp'] ?? 0;
            $mw = $m['w'] ?? $m['watt'] ?? 0;
            $mpf = $m['pf'] ?? 1.0;
            $mhz = $m['hz'] ?? 50.0;
            $mkwh = (float)($m['kwh'] ?? 0);
            
            $mt = isset($m['temp']) ? (float)$m['temp'] : null;
            if ($mt === 0.0) $mt = null;
            $mh = isset($m['hum']) ? (float)$m['hum'] : null;
            if ($mh === 0.0) $mh = null;
            $mc = isset($m['coil']) ? (float)$m['coil'] : null;

$mtotalW = $m['total_watt'] ?? $m['total_w'] ?? $mw;
            $mtotalK = $m['total_kwh'] ?? $m['total_k'] ?? $mkwh;

if (!empty($mPzemMac) && $currentMeshMac !== $mPzemMac) {
                $mv = null; $ma = null; $mw = null; $mpf = null; $mhz = null;
            }
            $isMeshClimateOwner = (empty($mDhtMac) || $currentMeshMac === $mDhtMac || $currentMeshMac === $mMasterMac);
            if (!$isMeshClimateOwner) {
                $mt = null; $mh = null;
            }
            if ($currentMeshMac !== $mMasterMac) {
                $mc = null;
            }

$mParams = [
                ':slot_id' => $meshSlotId,
                ':mac'     => $normalizedMeshMac,
                ':v'       => $mv,
                ':a'       => $ma,
                ':w'       => $mw,
                ':kwh'     => $mkwh,
                ':pf'      => $mpf ?? 1.0,
                ':hz'      => $mhz ?? 50.0,
                ':sq_temp' => $mt,
                ':rh'      => $mh,
                ':coil_temp' => $mc,
                ':comp'    => $m['state'] ?? $m['comp'] ?? 0,
                ':alarm_data' => isset($m['alarms']) ? json_encode($m['alarms']) : null,
                ':source_id' => 'MESH',
                ':p_hash'   => isset($m['hash']) ? $m['hash'] : null,
                ':time'    => $recordedAt
            ];
            
            if (isset($tFields['total_power_w']))   $mParams[':total_w'] = $mtotalW;
            if (isset($tFields['total_energy_kwh'])) $mParams[':total_k'] = $mtotalK;

if (isset($tFields['operating_mode'])) $mParams[':op_mode'] = $m['op_mode'] ?? 'normal';
            if (isset($tFields['saturation_detected'])) $mParams[':sat'] = $m['sat'] ?? 0;
            if (isset($tFields['saturation_timestamp'])) $mParams[':sat_ts'] = $m['sat_ts'] ?? null;
            if (isset($tFields['health_index'])) $mParams[':health'] = $m['hlth'] ?? $m['health'] ?? 100.0;
            if (isset($tFields['error_code'])) $mParams[':err'] = $m['err'] ?? 0;
            if (isset($tFields['firmware_version'])) $mParams[':fw'] = $m['ver'] ?? $m['fw'] ?? null;

$stmtArchive->execute($mParams);
            $stmtLive->execute($mParams);

$slotId = $meshSlotId; $kwh = $mkwh;
            require 'energy_anchor.php';
            
            $meshHeartbeatSql = "UPDATE device_slots SET is_online = 1, last_seen_at = NOW()";
            if (in_array('meter_type', $checkCols) && isset($m['meter_type'])) {
                $meshHeartbeatSql .= ", meter_type = " . (int)$m['meter_type'];
            }
            $meshHeartbeatSql .= " WHERE id = ?";
            $pdo->prepare($meshHeartbeatSql)->execute([$meshSlotId]);
            
            $insertedCount++;
        }
    }

$pdo->commit();
        $pdoLog->commit();
    });

// [HYBRID] KEEP MAIN DB CLEAN - Out-of-Transaction & Rate-Limited
    // We only run the expensive DELETE once every 10 minutes to prevent Lock Timeouts.
    $purgeLockFile = __DIR__ . '/purge_lock.timestamp';
    $lastPurge = file_exists($purgeLockFile) ? (int)file_get_contents($purgeLockFile) : 0;
    if (time() - $lastPurge > 600) { // 10 Minute Cooldown
        try {
            // [MASTERPIECE] Optimized Purge: LIMIT 1000 prevents long table locks
            $pdo->exec("DELETE FROM telemetry WHERE recorded_at < (NOW() - INTERVAL 1 DAY) LIMIT 1000");
            file_put_contents($purgeLockFile, time());
        } catch (Exception $e) {
            error_log("[PURGE] Failed to clean old telemetry: " . $e->getMessage());
        }
    }

Response::success(['inserted' => $insertedCount], "Telemetry ingested");

} catch (Exception $e) {
    if ($pdo && $pdo->inTransaction()) { $pdo->rollBack(); }
    if (isset($pdoLog) && $pdoLog && $pdoLog->inTransaction()) { $pdoLog->rollBack(); }

$errMsg = $e->getMessage();
    $logPath = __DIR__ . '/';
    file_put_contents($logPath . 'telemetry_error.log', "[" . date('Y-m-d H:i:s') . "] 500 ERROR: " . $errMsg . "\n" . $e->getTraceAsString() . "\n", FILE_APPEND);
    Response::error(500, "Ingestion Failed", "An unexpected error occurred during telemetry ingestion.", $errMsg);
}
?>

Batal

⬅ Naik ke api 83 item

Nama	Tipe	Ukuran	Diubah	Aksi
📁admin	dir	—	2026-04-30 04:28	📂 Buka
📁alerts	dir	—	2026-04-30 04:28	📂 Buka
📁auth	dir	—	2026-04-30 04:28	📂 Buka
📁dashboard	dir	—	2026-04-30 07:02	📂 Buka
📁industrial	dir	—	2026-07-06 17:04	📂 Buka
📁ota	dir	—	2026-04-30 04:28	📂 Buka
🐘active_ping.php	php	744 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘active_tracker.php	php	2.7 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘alert_history.php	php	4.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘analytics_engine.php	php	5.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
📝asset_fix_summary.txt	txt	805 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘audit_logs.php	php	1.7 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘backfill_energy.php	php	935 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘bind_hardware.php	php	4.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘bot_slots.php	php	2.3 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘check_serial.php	php	4.6 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘complete_command.php	php	2.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘control.php	php	13.5 KB	2026-05-01 01:53	✏️ Edit 👁️ View
🐘control_mass.php	php	1.6 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘control_route.php	php	2.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘db_explain.php	php	899 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘db_optimize.php	php	1.1 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘debug_cumulative.php	php	1.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘debug_db.php	php	3.1 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘debug_db_check.php	php	505 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘debug_energy.php	php	649 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘debug_slot.php	php	600 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘debug_wana.php	php	721 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘delete_node_permanent.php	php	6.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘delete_site.php	php	4.3 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘delete_slot.php	php	2.3 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘dump_debug.php	php	850 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘energy_anchor.php	php	1.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘energy_integration_engine.php	php	2.5 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘firmware_core.php	php	3.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘fix_gateway_schema.php	php	1.3 KB	2026-05-01 01:52	✏️ Edit 👁️ View
🐘fix_schema.php	php	6.4 KB	2026-05-01 01:52	✏️ Edit 👁️ View
🐘fleet_stats.php	php	4.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘geo_intelligence.php	php	3.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘get_commands.php	php	6.1 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘get_hidden_nodes.php	php	1009 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘get_hierarchy.php	php	16.6 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘health_analysis.php	php	6.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘history.php	php	13.6 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘history_new_bug.php	php	17.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘history_precision.php	php	9.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘history_v42.php	php	8.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘hive_core.php	php	5.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘inspect_db.php	php	1.6 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘inspect_schema.php	php	734 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘latest.php	php	17.3 KB	2026-05-01 01:52	✏️ Edit 👁️ View
🐘list_devices.php	php	271 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘list_slots.php	php	1.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘mass_command.php	php	5.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘mesh_sync.php	php	2.7 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘migrate_3phase.php	php	2.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘migrate_commands_signature.php	php	298 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘move_hardware.php	php	4.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘ota_manager.php	php	3.6 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘peek_data.php	php	452 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘peek_recent.php	php	407 B	2026-04-30 09:54	✏️ Edit 👁️ View
🐘push_structure.php	php	12.5 KB	2026-05-01 01:53	✏️ Edit 👁️ View
🐘register_hardware.php	php	2.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘room_status.php	php	4.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘security_digest.php	php	3.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘seed_admin.php	php	1.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘server_health.php	php	1.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘set_node_visibility.php	php	1.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘set_room_master.php	php	1.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘sharing.php	php	4.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘simulate_history.php	php	5.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘sync.php	php	8.1 KB	2026-05-01 01:52	✏️ Edit 👁️ View
🐘sync_location_slots.php	php	3.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘system_config.php	php	1.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘telemetry.php	php	49.8 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘telemetry_batch.php	php	17.4 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘telemetry_engine.php	php	5.9 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘telemetry_raw.php	php	6.1 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘telemetry_v2.php	php	11 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘unlink_device.php	php	2.1 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘update_sensor_config.php	php	3.2 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘update_user.php	php	4.1 KB	2026-04-30 09:54	✏️ Edit 👁️ View
🐘user_manager.php	php	6.3 KB	2026-04-30 09:54	✏️ Edit 👁️ View