'; print_r($RenewRow);

	             if ($RenewRow && ($RenewRow['status'] == '2' || $RenewRow['status'] == '3')) {
	                $id = (int)$RenewRow['id'];
	                $crt_date = date('Y-m-d H:i:s');
	                //echo $purchaseDate;
	                $exp_query = "UPDATE tbl_customer_subscriptions SET status = '7' , end_date = '$crt_date'  WHERE id = $id AND status IN ('2','3') AND (end_date < NOW() OR date(end_date) ='".date('Y-m-d', strtotime($purchaseDate))."') ";
	                mysqli_query($mysqli, $exp_query);
	                if (mysqli_affected_rows($mysqli) > 0) {
	                    $RenewRow['status'] = '7';
	                }
	            }

	            
	            if ($RenewRow && $RenewRow['status'] == '7') {
	                $existingRenewalRow = fetch_subscription_by_transaction_id($mysqli, $transactionId);
	                if ($existingRenewalRow) {
	                    file_put_contents($subscriptionUpdateLog, "Skipped renewal insert: transaction_id=$transactionId already exists with subscription_id=" . ($existingRenewalRow['id'] ?? '') . PHP_EOL, FILE_APPEND);
	                } else {
	                    list($renewOrderRow, $renewOrderDetailRow) = fetch_order_context($mysqli, (int)($RenewRow['order_id'] ?? 0));
	                    if ($renewOrderRow && $renewOrderDetailRow) {
	                        $insertRenewalQuery = build_subscription_insert_sql_from_order(
	                            $mysqli,
	                            $renewOrderRow,
	                            $renewOrderDetailRow,
	                            [
	                                'transaction_id' => $transactionId,
	                                'gateway_subscription_id' => $originalTransactionId,
	                                'pg_payment_data' => $pgPaymentData,
	                                'price' => $price,
	                                'currency' => $currency,
	                                'purchase_date' => $purchaseDate,
	                                'expires_date' => $expiresDateFormatted,
	                                'is_free_trial' => $isFreeTrial,
	                                'product_id' => $productId,
	                                'purchase_type' => 'RENEWED',
	                                'recurring' => 1,
	                            ]
	                        );

	                        file_put_contents($subscriptionUpdateLog, "Insert Query: $insertRenewalQuery" . PHP_EOL, FILE_APPEND);
	                        if (mysqli_query($mysqli, $insertRenewalQuery)) {
								echo "Record Inserted";
	                            file_put_contents($subscriptionUpdateLog, "Inserted renewal: gateway_subscription_id=$originalTransactionId, transaction_id=$transactionId, status=2, end_date=$expiresDateFormatted" . PHP_EOL, FILE_APPEND);

	                            // $updateOrderSql = "UPDATE tbl_order SET payment_status='2', order_status='2' WHERE id='".$RenewRow['order_id']."'";
	                            // mysqli_query($mysqli, $updateOrderSql);

	                            ################################## FIREBASE NOTIFICATION #########################################
	                            /**$deviceQuery = "SELECT push_device_token, device_type FROM customer_device WHERE user_id='" . $renewOrderRow['subscriber_id'] . "'";
	                            $result = mysqli_query($mysqli, $deviceQuery);
	                            if ($result && mysqli_num_rows($result) > 0) {
	                                while ($deviceRow = mysqli_fetch_assoc($result)) {
	                                    $DeviceID = $deviceRow['push_device_token'];
	                                    $device   = $deviceRow['device_type']; // e.g., 'mobile', 'tv', 'ios'
	                                    if ($DeviceID) {
	                                        $notificationSent = SendPurchaseSuccessFCMNotification($DeviceID, $device);
	                                        if ($notificationSent) {
	                                            error_log("FCM Purchase Success sent successfully for user ID " . $renewOrderRow['subscriber_id'] . ", device $device\n", 3, $errorLog);
	                                        } else {
	                                            error_log("FCM Purchase Success failed for user ID " . $renewOrderRow['subscriber_id'] . ", device $device\n", 3, $errorLog);
	                                        }
	                                    }
	                                }
	                            } else {
	                                error_log("No device found for user ID " . $renewOrderRow['subscriber_id'], 3, $errorLog);
	                            }  **/
	                            ################################### FIREBASE NOTIFICATION #########################################

	                        } else {
	                            error_log("Insert failed: " . mysqli_error($mysqli), 3, $errorLog);
	                            file_put_contents($subscriptionUpdateLog, "Insert failed for gateway_subscription_id=$originalTransactionId: " . mysqli_error($mysqli) . PHP_EOL, FILE_APPEND);
	                        }
	                    } else {
	                        file_put_contents($subscriptionUpdateLog, "Skipped renewal insert: order/order_details missing for order_id=" . ($RenewRow['order_id'] ?? '') . PHP_EOL, FILE_APPEND);
	                    }
	                }
	            } else if(isset($appAccountToken) && $appAccountToken != '') {
	                $existingOneTimeRow = fetch_subscription_by_transaction_id($mysqli, $transactionId);
	                if ($existingOneTimeRow) {
	                    file_put_contents($subscriptionUpdateLog, "Skipped one-time insert: transaction_id=$transactionId already exists with subscription_id=" . ($existingOneTimeRow['id'] ?? '') . PHP_EOL, FILE_APPEND);
	                } else {
	                    $chkOrderSql = "SELECT * FROM tbl_order WHERE gateway_consent_id='" . mysqli_real_escape_string($mysqli, $appAccountToken) . "' AND order_status='2' ORDER BY id DESC LIMIT 1";
	                    $chkResult = mysqli_query($mysqli, $chkOrderSql);
	                    $chkOrderRow = mysqli_fetch_assoc($chkResult);
	                    if(!empty($chkOrderRow)){
	                        list($resolvedOrderRow, $chkOrderDetailRow) = fetch_order_context($mysqli, (int)$chkOrderRow['id']);
	                        if(!empty($resolvedOrderRow) && !empty($chkOrderDetailRow)){
	                            $insertQuery = build_subscription_insert_sql_from_order(
	                                $mysqli,
	                                $resolvedOrderRow,
	                                $chkOrderDetailRow,
	                                [
	                                    'transaction_id' => $transactionId,
	                                    'gateway_subscription_id' => $originalTransactionId,
	                                    'pg_payment_data' => $pgPaymentData,
	                                    'price' => $price,
	                                    'currency' => $currency,
	                                    'purchase_date' => $purchaseDate,
	                                    'expires_date' => $expiresDateFormatted,
	                                    'is_free_trial' => $isFreeTrial,
	                                    'product_id' => $productId,
	                                    'purchase_type' => 'PURCHASED',
	                                    'recurring' => 1,
	                                ]
	                            );

	                            file_put_contents($subscriptionUpdateLog, "Insert Query: $insertQuery" . PHP_EOL, FILE_APPEND);
	                            if (mysqli_query($mysqli, $insertQuery)) {
	                                $updateOrderSql = "UPDATE tbl_order SET payment_status='2', order_status='2' WHERE id='".$resolvedOrderRow['id']."'";
	                                mysqli_query($mysqli, $updateOrderSql);

	                                ################################## FIREBASE NOTIFICATION #########################################
	                                $deviceQuery = "SELECT push_device_token, device_type FROM customer_device WHERE user_id='" . $resolvedOrderRow['subscriber_id'] . "'";
	                                $result = mysqli_query($mysqli, $deviceQuery);
	                                if ($result && mysqli_num_rows($result) > 0) {
	                                    while ($deviceRow = mysqli_fetch_assoc($result)) {
	                                        $DeviceID = $deviceRow['push_device_token'];
	                                        $device   = $deviceRow['device_type']; // e.g., 'mobile', 'tv', 'ios'
	                                        if ($DeviceID) {
	                                            $notificationSent = SendPurchaseSuccessFCMNotification($DeviceID, $device);
	                                            if ($notificationSent) {
	                                                error_log("FCM Purchase Success sent successfully for user ID " . $resolvedOrderRow['subscriber_id'] . ", device $device\n", 3, $errorLog);
	                                            } else {
	                                                error_log("FCM Purchase Success failed for user ID " . $resolvedOrderRow['subscriber_id'] . ", device $device\n", 3, $errorLog);
	                                            }
	                                        }
	                                    }
	                                } else {
	                                    error_log("No device found for user ID " . $resolvedOrderRow['subscriber_id'], 3, $errorLog);
	                                }
	                                ################################### FIREBASE NOTIFICATION #########################################

	                                file_put_contents($subscriptionUpdateLog, "Inserted one-time purchase: gateway_subscription_id=$originalTransactionId, transaction_id=$transactionId, status=2, end_date=$expiresDateFormatted" . PHP_EOL, FILE_APPEND);
	                            } else {
	                                error_log("Insert failed: " . mysqli_error($mysqli), 3, $errorLog);
	                                file_put_contents($subscriptionUpdateLog, "Insert failed for gateway_subscription_id=$originalTransactionId: " . mysqli_error($mysqli) . PHP_EOL, FILE_APPEND);
	                            }
	                        } else {
	                            file_put_contents($subscriptionUpdateLog, "Skipped one-time insert: order_details missing for order_id=" . ($chkOrderRow['id'] ?? '') . PHP_EOL, FILE_APPEND);
	                        }
	                    }
	                }

            } else {
                error_log("No expired subscription found for gateway_subscription_id=$originalTransactionId", 3, $errorLog);
                file_put_contents($subscriptionUpdateLog, "No expired subscription (status=7) found for gateway_subscription_id=$originalTransactionId" . PHP_EOL, FILE_APPEND);
            }
            mysqli_free_result($result);
        } else {
            error_log("Missing required fields or not a valid RENEWAL: originalTransactionId=$originalTransactionId, expiresDate=$expiresDate, productId=$productId, notificationType=$notificationType, expiresDateValid=" . ($expiresDate > $currentDate ? 'true' : 'false'), 3, $errorLog);
            file_put_contents($subscriptionUpdateLog, "Skipped processing: Invalid RENEWAL or fields for transactionId=$originalTransactionId" . PHP_EOL, FILE_APPEND);
        }

    } catch (Exception $e) {
        error_log("signedTransactionInfo error: " . $e->getMessage(), 3, $errorLog);
        file_put_contents($logDir . 'transaction_jwt_verify.log', "signedTransactionInfo error: " . $e->getMessage() . PHP_EOL, FILE_APPEND);
    }
}


function sql_value(mysqli $mysqli, $value) {
    if ($value === null) {
        return "NULL";
    }

    return "'" . mysqli_real_escape_string($mysqli, (string)$value) . "'";
}


function fetch_single_assoc(mysqli $mysqli, string $sql): ?array {
    $result = mysqli_query($mysqli, $sql);
    if (!$result) {
        return null;
    }

    $row = mysqli_fetch_assoc($result) ?: null;
    mysqli_free_result($result);

    return $row;
}


function fetch_subscription_by_transaction_id(mysqli $mysqli, ?string $transactionId): ?array {
    if (!$transactionId) {
        return null;
    }

    $transactionId = mysqli_real_escape_string($mysqli, $transactionId);

    return fetch_single_assoc(
        $mysqli,
        "SELECT id, order_id, subscriber_id FROM tbl_customer_subscriptions WHERE trans_id='" . $transactionId . "' ORDER BY id DESC LIMIT 1"
    );
}


function fetch_latest_subscription_by_gateway_subscription_id(mysqli $mysqli, ?string $gatewaySubscriptionId): ?array {
    if (!$gatewaySubscriptionId) {
        return null;
    }

    $gatewaySubscriptionId = mysqli_real_escape_string($mysqli, $gatewaySubscriptionId);

    return fetch_single_assoc(
        $mysqli,
        "SELECT id, order_id, subscriber_id, status FROM tbl_customer_subscriptions WHERE gateway_subscription_id='" . $gatewaySubscriptionId . "' ORDER BY created DESC, id DESC LIMIT 1"
    );
}


function fetch_order_context(mysqli $mysqli, int $orderId): array {
    if ($orderId <= 0) {
        return [null, null];
    }

    $orderRow = fetch_single_assoc($mysqli, "SELECT * FROM tbl_order WHERE id=" . $orderId . " LIMIT 1");
    $orderDetailRow = fetch_single_assoc($mysqli, "SELECT * FROM tbl_order_details WHERE order_id=" . $orderId . " ORDER BY id DESC LIMIT 1");

    return [$orderRow, $orderDetailRow];
}


function format_ist_now(): string {
    return (new DateTime('now', new DateTimeZone('Asia/Kolkata')))->format('Y-m-d H:i:s');
}


function build_subscription_insert_sql_from_order(mysqli $mysqli, array $orderRow, array $orderDetailRow, array $context): string {
    $packageTitle = $orderDetailRow['item_name'] ?? ($context['product_id'] ?? '');
    $price = $context['price'] ?? '0.00';
    $basicAmount = $orderDetailRow['item_price'] ?? $orderDetailRow['real_price'] ?? $orderDetailRow['total'] ?? $price;
    $currency = $context['currency'] ?? ($orderDetailRow['currency'] ?? ($orderRow['currency'] ?? 'USD'));
    $currencyId = $orderDetailRow['currency_id'] ?? ($orderRow['currency_id'] ?? 4);
    $trialPeriod = !empty($context['is_free_trial']) ? ($orderDetailRow['period'] ?? 'FREE_TRIAL') : null;
    $trialLength = !empty($context['is_free_trial']) ? ($orderDetailRow['period_interval'] ?? 0) : 0;

    $data = [
        'app_id' => $orderDetailRow['app_id'] ?? ($orderRow['app_id'] ?? 5013),
        'order_id' => $orderRow['id'] ?? ($orderDetailRow['order_id'] ?? 0),
        'trans_id' => $context['transaction_id'] ?? '',
        'pg_ref_id' => $orderDetailRow['pg_ref_id'] ?? ($orderRow['pg_ref_id'] ?? ($context['transaction_id'] ?? '')),
        'device_id' => $orderRow['device_id'] ?? 0,
        'gateway_subscription_id' => $context['gateway_subscription_id'] ?? ($orderRow['gateway_consent_id'] ?? ''),
        'pg_payment_data' => $context['pg_payment_data'] ?? '',
        'channel' => $orderRow['channel'] ?? '',
        'package_id' => $orderDetailRow['item_id'] ?? 0,
        'package_title' => $packageTitle,
        'package_code' => $context['product_id'] ?? '',
        'package_type' => 0,
        'package_mode' => $orderDetailRow['package_mode'] ?? 'OTT',
        'price' => $price,
        'basic_amount' => $basicAmount,
        'tax_amt' => $orderDetailRow['tax_amt'] ?? '0.00',
        'subscriber_id' => $orderRow['subscriber_id'] ?? ($orderDetailRow['subscriber_id'] ?? 0),
        'msisdn' => $orderDetailRow['s_contact_number'] ?? ($orderDetailRow['b_contact_number'] ?? ''),
        'role_type' => $orderRow['role_type'] ?? ($orderDetailRow['role_type'] ?? 1),
        'gateway_type' => $orderDetailRow['gateway_type'] ?? ($orderRow['gateway_type'] ?? 13),
        'pg_name' => $orderDetailRow['pg_name'] ?? ($orderRow['pg_name'] ?? 'apple_inapp_purchase'),
        'region_type' => $orderDetailRow['region_type'] ?? ($orderRow['region_type'] ?? 1),
        'local_user' => $orderDetailRow['local_user'] ?? 0,
        'state_code' => $orderDetailRow['b_state_code'] ?? 0,
        'period' => $orderDetailRow['period'] ?? 'Month',
        'period_interval' => $orderDetailRow['period_interval'] ?? 1,
        'trial_period' => $trialPeriod,
        'trial_length' => $trialLength,
        'subscription_type' => $orderDetailRow['subscription_type'] ?? 0,
        'output_video_limit' => $orderDetailRow['output_video_limit'] ?? 0,
        'additional_cost_per_unit' => $orderDetailRow['additional_cost_per_unit'] ?? 0,
        'no_videos' => 0,
        'no_plays' => 0,
        'status' => 2,
        'platform' => 'webhook',
        'extended_status' => $orderRow['extended_status'] ?? 0,
        'start_date' => $context['purchase_date'] ?? date('Y-m-d H:i:s'),
        'end_date' => $context['expires_date'] ?? date('Y-m-d H:i:s'),
        'autorenew' => 1,
        'currency_id' => $currencyId,
        'currency' => $currency,
        'created' => $context['purchase_date'] ?? date('Y-m-d H:i:s'),
        'is_cancelled' => 0,
        'deactivation_type' => '',
        'recurring' => $context['recurring'] ?? 1,
        'purchase_token' => '',
        'package_name' => $context['product_id'] ?? $packageTitle,
        'purchase_type' => $context['purchase_type'] ?? 'PURCHASED',
    ];

    $columns = implode(", ", array_keys($data));
    $values = [];
    foreach ($data as $value) {
        $values[] = sql_value($mysqli, $value);
    }

    return "INSERT INTO tbl_customer_subscriptions (" . $columns . ") VALUES (" . implode(", ", $values) . ")";
}


function SendPurchaseSuccessFCMNotification($DeviceID, $device) {
    $serviceAccountFile = __DIR__ . '/drama-shorts-abb61-firebase-adminsdk-fbsvc-44b0f0865f.json';

    // Initialize Google Client
    $client = new Client();
    $client->setAuthConfig($serviceAccountFile);
    $client->setScopes(['https://www.googleapis.com/auth/firebase.messaging']);

    // Get access token
    $tokenArray = $client->fetchAccessTokenWithAssertion();
    if (!isset($tokenArray['access_token'])) {
        echo "Failed to get access token\n";
        return false;
    }
    $accessToken = $tokenArray['access_token'];

    // Build message payload
  
    $payloadData = [
        'trigger_type' => 'user',
        'trigger_action' => 'purchase_success'
    ];

    $payloadJSON = json_encode($payloadData);

    // Android / TV
    if ($device === 'mobile' || $device === 'tv') {
        $payload = [
            'message' => [
                'token' => $DeviceID,
                'data' => [
                    'title' => 'Purchase Success',
                    'body'  => $payloadJSON
                ]
            ]
        ];
    } else {
        // iOS / APNS
        $payload = [
            'message' => [
                'token' => $DeviceID,
                'apns' => [
                    'payload' => [
                        'aps' => [
                            'content-available' => true
                        ],
                        'customData' => [
                            'title' => 'Purchase Success',
                            'body'  => $payloadJSON
                        ]
                    ]
                ]
            ]
        ];
    }

    // Get project ID from JSON
    $credentials = json_decode(file_get_contents($serviceAccountFile), true);
    $projectId = $credentials['project_id'];

    // Send FCM via HTTP v1 API
    $ch = curl_init("https://fcm.googleapis.com/v1/projects/$projectId/messages:send");
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $accessToken,
        'Content-Type: application/json'
    ]);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
    curl_setopt($ch, CURLOPT_TIMEOUT, 10);

    $response = curl_exec($ch);
    if ($response === false) {
        echo "FCM curl error: " . curl_error($ch);
        curl_close($ch);
        return false;
    }

    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    echo "FCM HTTP Code: $httpCode, Response: $response\n";

    return $httpCode === 200;
}


// Return 200 OK to Apple
http_response_code(200);
echo 'OK';
?>