' . $safePreheader . '
'
. '' . diagnostic_email_escape((string)($copy['intro'] ?? '')) . '
'
. ')(?:\s*]*>\s*)*~u',
'$1' . diagnostic_email_brand_marker_html(),
$html,
1
) ?? $html;
if (strpos($html, 'Przejdź do bloga DoktorBiznes.pl') === false && strpos($html, 'DoktorBiznes.pl') === false) {
$html = preg_replace(
'~()~u',
'$1' . diagnostic_email_brand_marker_html(),
$html,
1
) ?? $html;
}
}
if ($text !== '') {
$text = preg_replace('/^.*omówić wynik z zespołem.*$/miu', '', $text) ?? $text;
$text = preg_replace('/^DOKTOR BIZNES\s*$/miu', '', $text) ?? $text;
$text = preg_replace('/^DoktorBiznes\.pl\s*$/miu', '', $text) ?? $text;
$text = preg_replace('/^Gdy Twój biznes potrzebuje trafnej diagnozy\s*$/miu', '', $text) ?? $text;
$text = preg_replace('~^https?://(?:www\.)?doktorbiznes\.pl/?\s*$~miu', '', $text) ?? $text;
$text = 'DoktorBiznes.pl' . "\n" . diagnostic_brand_home_url() . "\n\n" . ltrim($text);
$text = preg_replace('/\n{3,}/', "\n\n", $text) ?? $text;
$text = trim($text);
}
return [
'subject' => $subject,
'html' => $html,
'text' => $text,
];
}
function diagnostic_store_report_content(int $attemptId, array $package): void
{
$stmt = db()->prepare(
"UPDATE diagnostic_attempts
SET report_subject = :report_subject,
report_html = :report_html,
report_text = :report_text,
report_generated_at = NOW(),
ai_summary_text = :ai_summary_text,
ai_summary_generated_at = CASE WHEN :ai_summary_text = '' THEN ai_summary_generated_at ELSE NOW() END,
updated_at = NOW()
WHERE id = :id"
);
$summary = diagnostic_report_limit((string)($package['result_overview'] ?? ''), 1000);
$stmt->execute([
':report_subject' => (string)($package['subject'] ?? ''),
':report_html' => (string)($package['html'] ?? ''),
':report_text' => (string)($package['text'] ?? ''),
':ai_summary_text' => $summary,
':id' => $attemptId,
]);
}
function diagnostic_cached_report_content(array $attempt): ?array
{
$package = diagnostic_strip_legacy_report_cta([
'subject' => (string)($attempt['report_subject'] ?? ''),
'html' => (string)($attempt['report_html'] ?? ''),
'text' => (string)($attempt['report_text'] ?? ''),
]);
$subject = $package['subject'];
$html = $package['html'];
$text = $package['text'];
$resultOverview = diagnostic_report_limit((string)($attempt['ai_summary_text'] ?? ''), 1000);
if ($subject === '' || $html === '' || $text === '') {
return null;
}
if ($resultOverview === '') {
return null;
}
$overviewHtml = diagnostic_build_report_result_overview_html($resultOverview);
$overviewText = diagnostic_build_report_result_overview_text($resultOverview);
if ($overviewHtml !== '' && strpos($html, 'Co ten wynik mówi o Twojej organizacji') === false) {
$needle = '';
if (strpos($html, $needle) !== false) {
$html = str_replace($needle, $overviewHtml . $needle, $html);
} else {
return null;
}
}
if ($overviewText !== '' && strpos($text, 'Co ten wynik mówi o Twojej organizacji:') === false) {
$needle = "\n\nCo ten wynik oznacza:\n";
if (strpos($text, $needle) !== false) {
$text = str_replace($needle, "\n\n" . $overviewText . $needle, $text);
} else {
return null;
}
}
if (!empty($attempt['id']) && (
$subject !== (string)($attempt['report_subject'] ?? '')
|| $html !== (string)($attempt['report_html'] ?? '')
|| $text !== (string)($attempt['report_text'] ?? '')
)) {
diagnostic_store_report_content((int)$attempt['id'], [
'subject' => $subject,
'html' => $html,
'text' => $text,
'result_overview' => $resultOverview,
]);
}
return [
'success' => true,
'subject' => $subject,
'html' => $html,
'text' => $text,
'result_overview' => $resultOverview,
'source' => 'cache',
];
}
function diagnostic_generate_report_content(array $attempt): array
{
if (empty($attempt['result'])) {
return ['success' => false, 'error' => 'Brak wyniku potrzebnego do wygenerowania raportu.'];
}
$ai = diagnostic_generate_ai_report_copy($attempt);
$copy = $ai['copy'] ?? diagnostic_default_report_copy($attempt);
return [
'success' => true,
'subject' => (string)($copy['subject'] ?? 'Raport z diagnozy dojrzałości procesowej'),
'html' => diagnostic_build_report_html($attempt, $copy),
'text' => diagnostic_build_report_text($attempt, $copy),
'result_overview' => diagnostic_report_limit((string)($copy['result_overview'] ?? ''), 1000),
'source' => (string)($ai['source'] ?? 'fallback'),
];
}
function diagnostic_resolve_result_overview(array $attempt): string
{
$cached = diagnostic_report_limit((string)($attempt['ai_summary_text'] ?? ''), 1000);
if ($cached !== '') {
return $cached;
}
$report = diagnostic_resolve_report_content($attempt, true);
if (!empty($report['success'])) {
$generated = diagnostic_report_limit((string)($report['result_overview'] ?? ''), 1000);
if ($generated !== '') {
return $generated;
}
}
return diagnostic_default_result_overview($attempt);
}
function diagnostic_resolve_report_content(array $attempt, bool $forceRegenerate = false): array
{
if (!$forceRegenerate) {
$cached = diagnostic_cached_report_content($attempt);
if ($cached !== null) {
return $cached;
}
}
$generated = diagnostic_generate_report_content($attempt);
if (!empty($generated['success']) && !empty($attempt['id'])) {
diagnostic_store_report_content((int)$attempt['id'], $generated);
}
return $generated;
}
function diagnostic_send_report_email(array $attempt, bool $forceRegenerate = false): array
{
if (empty($attempt['email']) || !filter_var((string)$attempt['email'], FILTER_VALIDATE_EMAIL)) {
return ['success' => false, 'error' => 'Brak poprawnego adresu e-mail klienta'];
}
$report = diagnostic_resolve_report_content($attempt, $forceRegenerate);
if (empty($report['success'])) {
return $report;
}
return MailService::sendMail(
$attempt['email'],
(string)$report['subject'],
(string)$report['html'],
(string)$report['text']
);
}
function diagnostic_admin_setting_get(string $key): ?string
{
$stmt = db()->prepare('SELECT setting_value FROM diagnostic_settings WHERE setting_key = :setting_key LIMIT 1');
$stmt->execute([':setting_key' => $key]);
$value = $stmt->fetchColumn();
if ($value === false || $value === null) {
return null;
}
return trim((string)$value);
}
function diagnostic_admin_setting_set(string $key, ?string $value): void
{
$stmt = db()->prepare(
'INSERT INTO diagnostic_settings (setting_key, setting_value)
VALUES (:setting_key, :setting_value)
ON DUPLICATE KEY UPDATE setting_value = VALUES(setting_value), updated_at = CURRENT_TIMESTAMP'
);
$stmt->bindValue(':setting_key', $key, PDO::PARAM_STR);
if ($value === null || $value === '') {
$stmt->bindValue(':setting_value', null, PDO::PARAM_NULL);
} else {
$stmt->bindValue(':setting_value', $value, PDO::PARAM_STR);
}
$stmt->execute();
}
function diagnostic_admin_notification_config(): array
{
$configuredEmail = diagnostic_admin_setting_get('admin_notification_email') ?? '';
if ($configuredEmail !== '' && !filter_var($configuredEmail, FILTER_VALIDATE_EMAIL)) {
$configuredEmail = '';
}
$fallbackEmail = trim((string)(getenv('MAIL_TO') ?: ''));
if ($fallbackEmail !== '' && !filter_var($fallbackEmail, FILTER_VALIDATE_EMAIL)) {
$fallbackEmail = '';
}
$effectiveEmail = $configuredEmail !== '' ? $configuredEmail : $fallbackEmail;
$source = $configuredEmail !== '' ? 'panel' : ($fallbackEmail !== '' ? 'env' : 'none');
return [
'configured_email' => $configuredEmail,
'fallback_email' => $fallbackEmail,
'effective_email' => $effectiveEmail,
'source' => $source,
];
}
function diagnostic_admin_notification_email(): ?string
{
$config = diagnostic_admin_notification_config();
return $config['effective_email'] !== '' ? $config['effective_email'] : null;
}
function diagnostic_mask_secret(string $value, int $visibleTail = 4): string
{
$normalized = preg_replace('/\s+/', '', trim($value)) ?? '';
if ($normalized === '') {
return '';
}
$length = function_exists('mb_strlen') ? mb_strlen($normalized) : strlen($normalized);
if ($length <= $visibleTail) {
return str_repeat('•', max($length, 8));
}
$tail = function_exists('mb_substr') ? mb_substr($normalized, -$visibleTail) : substr($normalized, -$visibleTail);
return str_repeat('•', max($length - $visibleTail, 8)) . $tail;
}
function diagnostic_openai_api_key_is_valid(string $value): bool
{
$normalized = preg_replace('/\s+/', '', trim($value)) ?? '';
if ($normalized === '' || strlen($normalized) < 20) {
return false;
}
return preg_match('/^[A-Za-z0-9_\-]+$/', $normalized) === 1;
}
function diagnostic_admin_openai_key_config(): array
{
$configuredKey = diagnostic_admin_setting_get('openai_api_key') ?? '';
$configuredKey = preg_replace('/\s+/', '', $configuredKey) ?? '';
if ($configuredKey !== '' && !diagnostic_openai_api_key_is_valid($configuredKey)) {
$configuredKey = '';
}
return [
'configured' => $configuredKey !== '',
'masked_key' => $configuredKey !== '' ? diagnostic_mask_secret($configuredKey) : '',
];
}
function diagnostic_admin_openai_api_key(): ?string
{
$config = diagnostic_admin_openai_key_config();
if (empty($config['configured'])) {
return null;
}
$key = diagnostic_admin_setting_get('openai_api_key') ?? '';
$key = preg_replace('/\s+/', '', $key) ?? '';
return $key !== '' ? $key : null;
}
function diagnostic_send_consultation_notification(array $attempt): array
{
$recipient = diagnostic_admin_notification_email();
if ($recipient === null) {
return ['success' => false, 'error' => 'Brak skonfigurowanego adresu powiadomień administratora', 'reason' => 'missing_recipient'];
}
$phone = trim((string)($attempt['contact_phone'] ?? ''));
if ($phone === '') {
return ['success' => false, 'error' => 'Brak numeru telefonu do przekazania', 'reason' => 'missing_phone'];
}
$result = $attempt['result'] ?? [];
$score = isset($result['percentage_score']) ? (int)$result['percentage_score'] . '%' : '—';
$segment = (string)($result['segment_label'] ?? '—');
$requestedAt = (string)($attempt['consultation_requested_at'] ?? date('Y-m-d H:i:s'));
$respondentEmail = trim((string)($attempt['email'] ?? ''));
$marketingConsent = ((int)($attempt['marketing_consent'] ?? 0)) === 1 ? 'Tak' : 'Nie';
$subject = 'Nowa prośba o konsultację po diagnozie';
$html = diagnostic_email_document(
$subject,
'Użytkownik zakończył diagnozę i poprosił o kontakt telefoniczny.',
' Użytkownik zakończył diagnozę i poprosił o dalszą konsultację. '
. ' '
. ' Telefon kontaktowy '
. ' ' . diagnostic_email_escape($phone) . ' '
. ' '
. diagnostic_email_data_table([
'ID próby' => (string)(int)($attempt['id'] ?? 0),
'E-mail respondenta' => $respondentEmail !== '' ? $respondentEmail : '—',
'Data zgłoszenia' => $requestedAt,
'Wynik diagnozy' => $score,
'Segment' => $segment,
'Zgoda marketingowa' => $marketingConsent,
])
);
$text = "Nowa prośba o kontakt
"
. "ID próby: " . (int)($attempt['id'] ?? 0) . "
"
. "E-mail respondenta: " . ($respondentEmail !== '' ? $respondentEmail : '—') . "
"
. "Telefon kontaktowy: {$phone}
"
. "Data zgłoszenia: {$requestedAt}
"
. "Wynik diagnozy: {$score}
"
. "Segment: {$segment}
"
. "Zgoda marketingowa: {$marketingConsent}
";
$opts = [];
if ($respondentEmail !== '' && filter_var($respondentEmail, FILTER_VALIDATE_EMAIL)) {
$opts['reply_to'] = $respondentEmail;
}
return MailService::sendMail($recipient, $subject, $html, $text, $opts);
}
function diagnostic_flash_set(string $type, string $message): void
{
$_SESSION['diagnostic_flash'] = ['type' => $type, 'message' => $message];
}
function diagnostic_flash_get(): ?array
{
if (empty($_SESSION['diagnostic_flash'])) {
return null;
}
$flash = $_SESSION['diagnostic_flash'];
unset($_SESSION['diagnostic_flash']);
return is_array($flash) ? $flash : null;
}
function diagnostic_admin_credentials(): array
{
return [
'username' => getenv('DIAGNOSTIC_ADMIN_USER') ?: 'admin',
'password' => getenv('DIAGNOSTIC_ADMIN_PASS') ?: 'admin123',
'using_default' => !getenv('DIAGNOSTIC_ADMIN_USER') && !getenv('DIAGNOSTIC_ADMIN_PASS'),
];
}
function diagnostic_admin_is_authenticated(): bool
{
return !empty($_SESSION['diagnostic_admin_authenticated']);
}
function diagnostic_admin_login(string $username, string $password): bool
{
$credentials = diagnostic_admin_credentials();
$valid = hash_equals($credentials['username'], $username) && hash_equals($credentials['password'], $password);
if ($valid) {
$_SESSION['diagnostic_admin_authenticated'] = true;
}
return $valid;
}
function diagnostic_admin_logout(): void
{
unset($_SESSION['diagnostic_admin_authenticated']);
}
function diagnostic_admin_attempts(): array
{
$stmt = db()->query('SELECT * FROM diagnostic_attempts ORDER BY started_at DESC');
$rows = $stmt->fetchAll();
foreach ($rows as &$row) {
$row['answers'] = diagnostic_decode_json_map($row['answers_json'] ?? '');
$row['result'] = diagnostic_decode_json_map($row['result_json'] ?? '');
}
unset($row);
return $rows;
}
function diagnostic_admin_stats(): array
{
$attempts = diagnostic_admin_attempts();
$total = count($attempts);
$completed = 0;
$averageScore = 0;
$totalScore = 0;
foreach ($attempts as $attempt) {
if (($attempt['status'] ?? '') === 'completed') {
$completed++;
$totalScore += (int)($attempt['result']['percentage_score'] ?? 0);
}
}
$completionRate = $total > 0 ? (int)round(($completed / $total) * 100) : 0;
$averageScore = $completed > 0 ? (int)round($totalScore / $completed) : 0;
return [
'total_attempts' => $total,
'completed_attempts' => $completed,
'completion_rate' => $completionRate,
'average_score' => $averageScore,
];
}
function diagnostic_admin_export_csv(): string
{
$rows = diagnostic_admin_attempts();
$stream = fopen('php://temp', 'r+');
fputcsv($stream, ['ID próby', 'E-mail', 'Telefon', 'Data prośby o kontakt', 'Status', 'Rozpoczęto', 'Zakończono', 'Wynik %', 'Segment', 'Zgoda marketingowa', 'Raport e-mail']);
foreach ($rows as $row) {
fputcsv($stream, [
$row['id'],
$row['email'],
$row['contact_phone'] ?? '',
$row['consultation_requested_at'] ?? '',
$row['status'],
$row['started_at'],
$row['completed_at'],
$row['result']['percentage_score'] ?? '',
$row['result']['segment_label'] ?? '',
((int)$row['marketing_consent']) === 1 ? 'Tak' : 'Nie',
$row['email_report_status'],
]);
}
rewind($stream);
$csv = stream_get_contents($stream) ?: '';
fclose($stream);
return $csv;
}
| |