<?php
include('include/headscript.php');
header('Content-Type: application/json');

try {
    $input = json_decode(file_get_contents('php://input'), true);
    $templateId = intval($input['template_id'] ?? 0);
    $importRefFromClient = trim($input['importreferencecode'] ?? '');

    if (!$templateId) {
        throw new Exception('Template ID missing');
    }

    $userId = $iduserlogin ?? 1;

    $db = DBHandlerSelect::getInstance();
    $pdo = $db->getConnection();

    // Get default idclient from template
    $stmt = $pdo->prepare("SELECT idclient FROM excel_templates WHERE id = ?");
    $stmt->execute([$templateId]);
    $template = $stmt->fetch(PDO::FETCH_ASSOC);
    $idclient = $template['idclient'] ?? null;

    // Use provided importreferencecode (from filtered page) or generate new
    $importReferenceCode = $importRefFromClient !== '' ? $importRefFromClient : date('YmdHis') . '-' . uniqid();

    // Insert empty record
    $stmt = $pdo->prepare("
        INSERT INTO datadb (templateid, user_id, status, idclient, importreferencecode, importdate)
        VALUES (?, ?, 'i', ?, ?, NOW())
    ");
    $stmt->execute([$templateId, $userId, $idclient, $importReferenceCode]);
    $iddatadb = (int)$pdo->lastInsertId();

    // Create empty import_data_details for all mappings
    $mappingStmt = $pdo->prepare("SELECT id FROM template_mapping WHERE template_id = ?");
    $mappingStmt->execute([$templateId]);
    $mappings = $mappingStmt->fetchAll(PDO::FETCH_COLUMN);

    if (!empty($mappings)) {
        $insertStmt = $pdo->prepare("INSERT INTO import_data_details (id, mapping_id, field_value) VALUES (?, ?, '')");
        foreach ($mappings as $mappingId) {
            $insertStmt->execute([$iddatadb, $mappingId]);
        }
    }

    // Get user name
    $userStmt = $pdo->prepare("SELECT CONCAT(first_name, ' ', last_name) AS user_name FROM auth_users WHERE id = ?");
    $userStmt->execute([$userId]);
    $userName = $userStmt->fetchColumn() ?: '';

    echo json_encode([
        'success' => true,
        'iddatadb' => $iddatadb,
        'importreferencecode' => $importReferenceCode,
        'user_name' => $userName,
    ]);
} catch (Exception $e) {
    http_response_code(500);
    echo json_encode(['success' => false, 'message' => $e->getMessage()]);
}