";
                //print_r($existingSubscription);
                $row['subscription'] = $existingSubscription;

                // Insert subscription record in same table with required field changes.
                if (!empty($existingSubscription)) {
					
					if (
    $notificationType === 'SUBSCRIPTION_PURCHASED'
    && ($existingSubscription['platform'] ?? '') === 'platform'
    && ($existingSubscription['purchase_type'] ?? '') === 'PURCHASED'
) {
    // Existing record me webhook payload save karna optional hai.
    $existingId = (int)$existingSubscription['id'];
    $webhookPayload = $row['log_data'];

    $updateStmt = $conn->prepare(
        "UPDATE tbl_customer_subscriptions
         SET pg_payment_data = ?, updated_at = NOW()
         WHERE id = ?
         LIMIT 1"
    );

    if ($updateStmt) {
        $updateStmt->bind_param("si", $webhookPayload, $existingId);
        $updateStmt->execute();
        $updateStmt->close();
    }

    // Webhook log ko processed mark karo.
    $webhookLogId = (int)$row['id'];

    $syncStmt = $conn->prepare(
        "UPDATE roku_webhook_log
         SET sync = 1
         WHERE id = ?
         LIMIT 1"
    );

    if ($syncStmt) {
        $syncStmt->bind_param("i", $webhookLogId);
        $syncStmt->execute();
        $syncStmt->close();
        $row['sync'] = 1;
    }

    $row['subscription_insert'] = [
        'ok' => true,
        'insert_id' => 0,
        'error' => null,
        'message' => 'Existing platform purchase found; duplicate webhook insert skipped'
    ];

    $subscriptionStmt->close();
    $logs[] = $row;
    continue;
}
					
                    unset($existingSubscription['id']); // New row should have new PK.

                    // period_interval: use existing value if valid, else fallback to 1.
                    $allowedIntervals = ['1', '2', '3', '6', '12'];
                    $periodInterval = trim((string)($existingSubscription['period_interval'] ?? ''));
                    if (!in_array($periodInterval, $allowedIntervals, true)) {
                        $periodInterval = '1';
                    }

                    // period: support Month/Year, fallback to Month.
                    $periodRaw = strtolower(trim((string)($existingSubscription['period'] ?? 'month')));
                    $period = ($periodRaw === 'year' || $periodRaw === 'years') ? 'Year' : 'Month';

                    // start_date from webhook timestamp (epoch milliseconds).
                    if (is_numeric((string)$webhookTimestampMs) && (int)$webhookTimestampMs > 0) {
                        $startTs = (int)floor(((int)$webhookTimestampMs) / 1000);
                    } else {
                        $startTs = time();
                    }
                    $startDate = date('Y-m-d H:i:s', $startTs);

                    // end_date = start_date + period_interval (Month/Year).
                    if ($period === 'Year') {
                        $endTs = strtotime('+' . (int)$periodInterval . ' year', $startTs);
                    } else {
                        $endTs = strtotime('+' . (int)$periodInterval . ' month', $startTs);
                    }
                    if ($endTs === false) {
                        $endTs = $startTs;
                    }
                    $endDate = date('Y-m-d H:i:s', $endTs);

                    
                    list($orderRow, $orderDetailRow) = fetchAmazonOrderContext($conn, $existingSubscription['order_id'] ?? 0);
                    if (!$orderRow || !$orderDetailRow) {
                        $row['subscription_insert'] = [
                            'ok' => false,
                            'insert_id' => 0,
                            'error' => 'Order or order details not found for order_id=' . ($existingSubscription['order_id'] ?? 0)
                        ];
                        $logs[] = $row;
                        $subscriptionStmt->close();
                        continue;
                    }

                    $existingSubscription = buildAmazonSubscriptionInsertRow(
                        $existingSubscription,
                        $orderRow,
                        $orderDetailRow,
                        [
                            'receipt_id' => $receiptId,
                            'purchase_type' => $purchaseType,
                            'price' => $orderDetailRow['item_price'] ?? $orderDetailRow['total'] ?? ($existingSubscription['price'] ?? '0.00'),
                            'period' => $period,
                            'period_interval' => $periodInterval,
                            'start_date' => $startDate,
                            'end_date' => $endDate,
                            'created_at' => date('Y-m-d H:i:s'),
                            'webhook_payload' => $row['log_data'],
                        ]
                    );

                    $duplicateTransIdRow = fetchAmazonSubscriptionByTransId($conn, $existingSubscription['trans_id'] ?? '');
                    if ($duplicateTransIdRow) {
                        $webhookLogId = isset($row['id']) ? (int)$row['id'] : 0;
                        if ($webhookLogId > 0) {
                            $syncStmt = $conn->prepare("UPDATE roku_webhook_log SET sync = 1 WHERE id = ? LIMIT 1");
                            if ($syncStmt) {
                                $syncStmt->bind_param("i", $webhookLogId);
                                $syncStmt->execute();
                                $syncStmt->close();
                                $row['sync'] = 1;
                            }
                        }

                        $row['subscription_insert'] = [
                            'ok' => true,
                            'insert_id' => 0,
                            'error' => null,
                            'message' => 'Duplicate trans_id found; insert skipped',
                            'duplicate_subscription_id' => (int)($duplicateTransIdRow['id'] ?? 0),
                        ];
                        $subscriptionStmt->close();
                        $logs[] = $row;
                        continue;
                    }


                    $columns = [];
                    $values = [];
                    foreach ($existingSubscription as $column => $value) {
                        $safeColumn = str_replace('`', '``', (string)$column);
                        $columns[] = "`{$safeColumn}`";

                        if ($value === null) {
                            $values[] = "NULL";
                        } else {
                            $values[] = "'" . $conn->real_escape_string((string)$value) . "'";
                        }
                    }

//echo "
";
                     $insertSql = "INSERT INTO tbl_customer_subscriptions (" . implode(', ', $columns) . ") VALUES (" . implode(', ', $values) . ")";

                    $insertOk = $conn->query($insertSql);
                    if ($insertOk) {
                        $row['subscription_insert'] = [
                            'ok' => true,
                            'insert_id' => (int)$conn->insert_id,
                            'error' => null
                        ];

                        //update the roku_webhook_log table with colm sync= 1
                        $webhookLogId = isset($row['id']) ? (int)$row['id'] : 0;
                        if ($webhookLogId > 0) {
                            $syncStmt = $conn->prepare("UPDATE roku_webhook_log SET sync = 1 WHERE id = ? LIMIT 1");
                            if ($syncStmt) {
                                $syncStmt->bind_param("i", $webhookLogId);
                                $syncStmt->execute();
                                $syncStmt->close();
                                $row['sync'] = 1;
                            }
                        }

                    } else {
                        $row['subscription_insert'] = [
                            'ok' => false,
                            'insert_id' => 0,
                            'error' => $conn->error
                        ];
                    }
                } else {
                    $row['subscription_insert'] = [
                        'ok' => false,
                        'insert_id' => 0,
                        'error' => 'Source subscription row is empty'
                    ];
                }
            } else {
               
						$row['subscription_insert'] = [
        'ok' => false,
        'insert_id' => 0,
        'error' => 'No existing subscription found for receiptId; customer/order cannot be identified'
    ];

    $webhookLogId = (int)$row['id'];

    $syncStmt = $conn->prepare(
        "UPDATE roku_webhook_log
         SET sync = 1
         WHERE id = ?
         LIMIT 1"
    );

    if ($syncStmt) {
        $syncStmt->bind_param("i", $webhookLogId);
        $syncStmt->execute();
        $syncStmt->close();
        $row['sync'] = 1;
    }
               
               
            }

            $subscriptionStmt->close();
        }else{
			
			echo "i am here";
			}
    }else{
		
		$row['subscription_insert'] = [
        'ok' => false,
        'insert_id' => 0,
        'error' => 'Notification type not handled: ' . $notificationType
    ];

    $webhookLogId = (int)$row['id'];

    $syncStmt = $conn->prepare(
        "UPDATE roku_webhook_log
         SET sync = 1
         WHERE id = ?
         LIMIT 1"
    );

    if ($syncStmt) {
        $syncStmt->bind_param("i", $webhookLogId);
        $syncStmt->execute();
        $syncStmt->close();

        $row['sync'] = 1;
    }


		}

    $logs[] = $row;
}

$stmt->close();
$conn->close();

header('Content-Type: application/json');
echo json_encode([
    'status' => 'success',
    'count' => count($logs),
    'data' => $logs
]);
?>