File Manager

✏️ Edit File: /home/u625410797/domains/monothailand.com/public_html/ecotect_air/api/v1/programs/bulk_assign.php

<?php
// =============================================================================
// API: BULK ASSIGN CONTROL PROGRAM TO MULTIPLE DEVICE SLOTS
// Method: POST
// Description: Assigns a control program to multiple device slots at once
// Auth: JWT Required
// Body: { "program_id": "...", "slot_ids": ["slot1", "slot2", ...] }
// =============================================================================
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';

if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
    http_response_code(200);
    exit;
}

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

$auth = Security::requireAuth();
$userId = $auth['user_id'] ?? $auth['id'] ?? null;

$input = json_decode(file_get_contents('php://input'), true);

if (!isset($input['program_id']) || !isset($input['slot_ids']) || !is_array($input['slot_ids'])) {
    Response::error(400, "Missing Parameters", "program_id and slot_ids[] are required");
}

$programId = Security::sanitize($input['program_id']);
$slotIds = $input['slot_ids'];

if (empty($slotIds)) {
    Response::error(400, "Invalid Parameters", "slot_ids must not be empty");
}

if (count($slotIds) > 16) {
    Response::error(400, "Too Many Slots", "Maximum 16 slots per bulk operation");
}

try {
    // Verify program exists and get parameters
    $progStmt = $pdo->prepare("SELECT id, name, program_type, loop1_start_temp, loop2_saturation_duration, loop3_cut_duration FROM control_programs WHERE id = ?");
    $progStmt->execute([$programId]);
    $program = $progStmt->fetch();

if (!$program) {
        Response::error(404, "Not Found", "Control program not found");
    }

// Verify all slots belong to user (ownership check)
    $placeholders = implode(',', array_fill(0, count($slotIds), '?'));
    $ownershipStmt = $pdo->prepare("
        SELECT ds.id FROM device_slots ds
        JOIN rooms r ON ds.room_id = r.id
        JOIN sites s ON r.site_id = s.id
        WHERE ds.id IN ($placeholders) AND s.user_id = ?
    ");
    $ownershipParams = array_merge($slotIds, [$userId]);
    $ownershipStmt->execute($ownershipParams);
    $ownedSlots = $ownershipStmt->fetchAll(PDO::FETCH_COLUMN);

if (count($ownedSlots) !== count($slotIds)) {
        $unauthorized = array_diff($slotIds, $ownedSlots);
        Response::error(403, "Unauthorized", "Some slots do not belong to you: " . implode(', ', $unauthorized));
    }

// Build command payload
    $payload = json_encode([
        'action' => 'set',
        'program_name' => $program['name'],
        'program_type' => $program['program_type'],
        'loop1_temp' => (float)$program['loop1_start_temp'],
        'loop2' => (int)$program['loop2_saturation_duration'],
        'loop3_duration' => (int)$program['loop3_cut_duration']
    ]);

$pdo->beginTransaction();

$assignStmt = $pdo->prepare("
        INSERT INTO device_program_assignments (slot_id, program_id, assigned_by, assigned_at)
        VALUES (?, ?, ?, NOW())
        ON DUPLICATE KEY UPDATE
            program_id = VALUES(program_id),
            assigned_by = VALUES(assigned_by),
            assigned_at = NOW()
    ");

$cmdStmt = $pdo->prepare("INSERT INTO commands (slot_id, command, payload, status) VALUES (?, 'set_program', ?, 'pending')");

$successCount = 0;
    $commandIds = [];

foreach ($slotIds as $slotId) {
        $cleanSlotId = Security::sanitize($slotId);
        $assignStmt->execute([$cleanSlotId, $programId, $userId]);
        $cmdStmt->execute([$cleanSlotId, $payload]);
        $commandIds[] = $pdo->lastInsertId();
        $successCount++;
    }

$pdo->commit();

Response::success([
        'program_id' => $programId,
        'program_name' => $program['name'],
        'success_count' => $successCount,
        'total_requested' => count($slotIds),
        'command_ids' => $commandIds
    ], "Program deployed to $successCount device(s)");

} catch (Exception $e) {
    if ($pdo->inTransaction()) {
        $pdo->rollBack();
    }
    error_log("Bulk Assign Error: " . $e->getMessage());
    Response::error(500, "Database Error", $e->getMessage());
}
?>

Batal

⬅ Naik ke v1 7 item

Nama	Tipe	Ukuran	Diubah	Aksi
🐘assign.php	php	4.8 KB	2026-07-03 01:36	✏️ Edit 👁️ View
🐘bulk_assign.php	php	4.4 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘create.php	php	7.3 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘get.php	php	2.8 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘get_assignment.php	php	2.8 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘list.php	php	2.4 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘reset.php	php	5 KB	2026-07-03 01:37	✏️ Edit 👁️ View