PHPのstrtotimeでAPIデータを期間抽出し、対象データをDBへ保存する方法

<?php

$apiData = [
    ['item_id' => 'A001', 'name' => '商品A', 'published_at' => '2025-12-31T23:00:00+09:00'],
    ['item_id' => 'A002', 'name' => '商品B', 'published_at' => '2026-01-01T00:00:00+09:00'],
    ['item_id' => 'A003', 'name' => '商品C', 'published_at' => '2026-01-15T12:30:00+09:00'],
    ['item_id' => 'A004', 'name' => '商品D', 'published_at' => '2026-01-31T23:59:59+09:00'],
    ['item_id' => 'A005', 'name' => '商品E', 'published_at' => '2026-02-01T00:00:00+09:00'],
];

$startDate = '2026-01-01';
$endDate = '2026-01-31';

// この記事では開始日・終了日の両方を含む範囲として扱う。

<?php

$startTimestamp = strtotime($startDate . ' 00:00:00');
$endTimestamp = strtotime($endDate . ' 23:59:59');

if ($startTimestamp === false || $endTimestamp === false) {
    throw new RuntimeException('期間指定の日付を解釈できません。');
}

$filteredData = [];

foreach ($apiData as $item) {
    $publishedTimestamp = strtotime($item['published_at'] ?? '');

    if ($publishedTimestamp === false) {
        // 実運用ではitem_idや元の値をログへ記録してスキップする。
        continue;
    }

    if ($publishedTimestamp >= $startTimestamp
        && $publishedTimestamp <= $endTimestamp) {
        $filteredData[] = $item;
    }
}

// 期待される対象ID: A002, A003, A004

<?php

$startTimestamp = strtotime('2026-01-01 00:00:00');
$endExclusiveTimestamp = strtotime('2026-02-01 00:00:00');

$publishedTimestamp = strtotime($item['published_at'] ?? '');

if ($publishedTimestamp !== false
    && $publishedTimestamp >= $startTimestamp
    && $publishedTimestamp < $endExclusiveTimestamp) {
    // 2026年1月1日から1月31日までを対象にする。
}

<?php

$pdo = new PDO(
    'mysql:host=localhost;dbname=example;charset=utf8mb4',
    'app_user',
    'password',
    [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_EMULATE_PREPARES => false,
    ]
);

$sql = <<<SQL
INSERT INTO api_items (external_id, name, published_at)
VALUES (:external_id, :name, :published_at)
SQL;

$stmt = $pdo->prepare($sql);

foreach ($filteredData as $item) {
    if (!isset($item['item_id'], $item['name'], $item['published_at'])) {
        // 必須項目が欠けたデータは保存しない。
        continue;
    }

    $stmt->execute([
        'external_id' => $item['item_id'],
        'name' => $item['name'],
        'published_at' => $item['published_at'],
    ]);
}

// 実行環境のDB定義に応じて、日時型や文字列長を調整する。

<?php

$startDate = '2026-01-01';
$endDate = '2026-01-31';

$startTimestamp = strtotime($startDate . ' 00:00:00');
$endExclusiveTimestamp = strtotime($endDate . ' 00:00:00 +1 day');

if ($startTimestamp === false || $endExclusiveTimestamp === false) {
    throw new RuntimeException('期間指定が不正です。');
}

// 実際にはHTTPクライアントでAPIへ接続し、JSON文字列を取得する。
$json = '{"items":[
    {"item_id":"A002","name":"商品B","published_at":"2026-01-01T00:00:00+09:00"},
    {"item_id":"A003","name":"商品C","published_at":"2026-01-15T12:30:00+09:00"},
    {"item_id":"A004","name":"商品D","published_at":"2026-01-31T23:59:59+09:00"}
]}';

$payload = json_decode($json, true, 512, JSON_THROW_ON_ERROR);
$items = $payload['items'] ?? [];

$pdo->beginTransaction();

try {
    $stmt = $pdo->prepare(
        'INSERT INTO api_items (external_id, name, published_at)
         VALUES (:external_id, :name, :published_at)'
    );

    foreach ($items as $item) {
        $publishedTimestamp = strtotime($item['published_at'] ?? '');

        if ($publishedTimestamp === false) {
            // 日付変換失敗はログへ記録してスキップする。
            continue;
        }

        if ($publishedTimestamp < $startTimestamp
            || $publishedTimestamp >= $endExclusiveTimestamp) {
            continue;
        }

        $stmt->execute([
            'external_id' => $item['item_id'],
            'name' => $item['name'],
            'published_at' => $item['published_at'],
        ]);
    }

    $pdo->commit();
    // 期待される挙動: 指定期間内のデータだけが登録される。
} catch (Throwable $e) {
    $pdo->rollBack();
    // 実運用では例外内容を記録し、再試行や通知の方針を決める。
    throw $e;
}

<?php

$timezone = new DateTimeZone('Asia/Tokyo');
$start = new DateTimeImmutable('2026-01-01 00:00:00', $timezone);
$endExclusive = $start->modify('+1 month');

$published = DateTimeImmutable::createFromFormat(
    DateTimeInterface::ATOM,
    $item['published_at'] ?? ''
);

if ($published !== false
    && $published >= $start
    && $published < $endExclusive) {
    // DateTimeImmutableでは変更操作の結果として新しいオブジェクトを扱う。
}