<?php
 require_once 'db.php';

 if ($con->connect_error) {
    die(json_encode(['success' => false, 'message' => "Connection failed: " . $con->connect_error]));
 }

 if (isset($_POST['action']) && $_POST['action'] == 'insert_package') {
    $response = ['success' => true, 'message' => '', 'inserted' => 0, 'skipped' => 0];
    $packageData = $_POST['package_data'];
    $con->begin_transaction();
    
    try {
        foreach ($packageData as $item) {
            $name = $con->real_escape_string($item['name']);
            $value = floatval($item['value']);
         
            
            $no_of_pack = '';
            if (is_array($item['no_of_pack'])) {
                $no_of_pack = $con->real_escape_string(implode(',', $item['no_of_pack']));
            } else {
                $no_of_pack = $con->real_escape_string($item['no_of_pack']);
            }

            // Check if the name already exists
            $check_sql = "SELECT COUNT(*) AS count FROM bulkpackage WHERE name = '$name'";
            $result = $con->query($check_sql);
            $row = $result->fetch_assoc();

            if ($row['count'] == 0) { // Only insert if name does not exist
                $sql = "INSERT INTO bulkpackage (name, bvalue, bppaid) 
                        VALUES ('$name', '$value', '$no_of_pack')";
                
                if (!$con->query($sql)) {
                    throw new Exception("Error: " . $sql . "<br>" . $con->error);
                }
                $response['inserted']++; // Increment inserted count
            } else {
                $response['skipped']++; // Increment skipped count
            }
        }
    
        $con->commit();
        $response['message'] = "Package configuration saved successfully. Inserted: {$response['inserted']}, Skipped: {$response['skipped']}.";
        
    } catch (Exception $e) {
        $con->rollback();
        $response['success'] = false;
        $response['message'] = $e->getMessage();
    }
    $con->close();
    
    header('Content-Type: application/json');
    echo json_encode($response);
    exit;
}


elseif ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['action']) && $_POST['action'] === 'delete') {
    $id = intval($_POST['id']);

    if ($id > 0) {
        try {
            $con->autocommit(false);
            $deletebulk = "DELETE FROM bulkpackage WHERE bpid = $id";
            $con->query($deletebulk);
            $con->commit();
            echo json_encode([
                "status" => "success",
                "message" => "Bulk package deleted successfully."
            ]);

        } catch (Exception $e) {
            $con->rollback();
            echo json_encode([
                "status" => "error",
                "message" => "Error deleting Bulk package: " . $e->getMessage()
            ]);
        }
    } else {
        echo json_encode([
            "status" => "error",
            "message" => "Invalid Bulk package ID."
        ]);
    }
} 

?>