<?php

declare(strict_types=1);

$dialect = getenv('POC_DIALECT');
if (!in_array($dialect, ['mysql', 'dm'], true)) exit(2);
$host = getenv('POC_AI_HOST');
$port = getenv('POC_AI_PORT');
$schema = getenv('POC_AI_SCHEMA');
$dsn = $dialect === 'dm'
    ? "dm:host=$host;port=$port;schema=$schema"
    : "mysql:host=$host;port=$port;dbname=$schema;charset=utf8mb4";
$pdo = new PDO($dsn, getenv('POC_AI_USER'), getenv('POC_AI_PASSWORD'),
    [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]);
$table = $dialect === 'dm' ? 'YOSHOP_SPORT_ITEM' : 'yoshop_sport_item';
$sql = 'SELECT ID,INTENSITY FROM ' . $table
    . ' WHERE STORE_ID=10001 AND IS_DELETE=0 AND INTENSITY>0 ORDER BY ID '
    . ($dialect === 'dm' ? 'FETCH FIRST 1 ROWS ONLY' : 'LIMIT 1');
$row = array_change_key_case($pdo->query($sql)->fetch(PDO::FETCH_ASSOC) ?: [], CASE_LOWER);
echo json_encode(['dialect' => $dialect, 'candidate_id' => (int)($row['id'] ?? 0),
    'intensity_positive' => (float)($row['intensity'] ?? 0) > 0]) . PHP_EOL;