Boersendchcker update

modules/boersenchecker/pages/chart_data.php

@@ -17,9 +17,10 @@ $pdo = module_fn('boersenchecker', 'pdo');
 module_fn('boersenchecker', 'ensure_schema');
 $instrumentTable = module_fn('boersenchecker', 'table', 'instruments');
 $positionTable = module_fn('boersenchecker', 'table', 'positions');
+$quoteTable = module_fn('boersenchecker', 'table', 'quotes');
 
 $stmt = $pdo->prepare(
-    'SELECT i.id, i.name, i.symbol, i.isin
+    'SELECT i.id, i.name, i.symbol, i.isin, i.quote_currency
      FROM ' . $instrumentTable . ' i
      INNER JOIN ' . $positionTable . ' p ON p.instrument_id = i.id
      WHERE i.id = :id AND p.owner_sub = :owner_sub
@@ -37,12 +38,93 @@ if (!is_array($instrument)) {
     exit;
 }
 
-$symbol = strtoupper(trim((string) ($instrument['symbol'] ?? '')));
-if ($symbol === '') {
-    echo json_encode(['ok' => false, 'message' => 'Fuer diese Aktie ist kein Symbol hinterlegt.'], JSON_UNESCAPED_UNICODE);
+$quoteStmt = $pdo->prepare(
+    'SELECT id, price, currency, quoted_at, source, created_at
+     FROM ' . $quoteTable . '
+     WHERE instrument_id = :instrument_id
+     ORDER BY quoted_at ASC, created_at ASC, id ASC'
+);
+$quoteStmt->execute([
+    'instrument_id' => $instrumentId,
+]);
+$quotes = $quoteStmt->fetchAll(PDO::FETCH_ASSOC) ?: [];
+
+if ($quotes === []) {
+    echo json_encode([
+        'ok' => false,
+        'message' => 'Keine lokalen Kursdaten fuer diese Aktie vorhanden.',
+    ], JSON_UNESCAPED_UNICODE);
     exit;
 }
 
-$result = module_fn('boersenchecker', 'alpha_vantage_fetch_chart_series', $symbol);
-echo json_encode($result, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
+$dailyMap = [];
+foreach ($quotes as $quote) {
+    $localDate = trim((string) module_fn(
+        'boersenchecker',
+        'format_datetime_for_display',
+        (string) ($quote['quoted_at'] ?? ''),
+        (string) ($quote['source'] ?? ''),
+        'Y-m-d'
+    ));
+    $localDateTime = trim((string) module_fn(
+        'boersenchecker',
+        'format_datetime_for_display',
+        (string) ($quote['quoted_at'] ?? ''),
+        (string) ($quote['source'] ?? ''),
+        'Y-m-d H:i:s'
+    ));
+    if ($localDate === '' || !is_numeric($quote['price'] ?? null)) {
+        continue;
+    }
+
+    $point = [
+        'date' => $localDate,
+        'close' => (float) $quote['price'],
+        'currency' => strtoupper(trim((string) ($quote['currency'] ?? ''))),
+        'quoted_at' => $localDateTime,
+        'source' => (string) ($quote['source'] ?? ''),
+    ];
+
+    if (!isset($dailyMap[$localDate]) || strcmp($localDateTime, (string) ($dailyMap[$localDate]['quoted_at'] ?? '')) >= 0) {
+        $dailyMap[$localDate] = $point;
+    }
+}
+
+$daily = array_values($dailyMap);
+usort($daily, static fn (array $left, array $right): int => strcmp((string) $left['date'], (string) $right['date']));
+
+if ($daily === []) {
+    echo json_encode([
+        'ok' => false,
+        'message' => 'Keine gueltigen lokalen Schlusskurse fuer diese Aktie vorhanden.',
+    ], JSON_UNESCAPED_UNICODE);
+    exit;
+}
+
+$aggregate = static function (array $points, string $format): array {
+    $result = [];
+    $timezone = new DateTimeZone('Europe/Berlin');
+    foreach ($points as $point) {
+        $date = DateTimeImmutable::createFromFormat('Y-m-d', (string) ($point['date'] ?? ''), $timezone);
+        if (!$date instanceof DateTimeImmutable) {
+            continue;
+        }
+        $bucket = $date->format($format);
+        $result[$bucket] = $point;
+    }
+    return array_values($result);
+};
+
+echo json_encode([
+    'ok' => true,
+    'symbol' => strtoupper(trim((string) ($instrument['symbol'] ?? ''))),
+    'isin' => strtoupper(trim((string) ($instrument['isin'] ?? ''))),
+    'instrument_name' => (string) ($instrument['name'] ?? ''),
+    'currency' => strtoupper(trim((string) ($instrument['quote_currency'] ?? ''))),
+    'daily' => $daily,
+    'weekly' => $aggregate($daily, 'o-W'),
+    'monthly' => $aggregate($daily, 'Y-m'),
+    'source' => 'database:quotes',
+    'source_label' => 'Lokale Kurshistorie',
+], JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
 exit;