0f19dd688f
feat: add apilayer as provider for fixer api feat: update exchange rate when saving api key
108 lines
3.9 KiB
PHP
108 lines
3.9 KiB
PHP
<?php
|
|
require_once '../../includes/connect_endpoint.php';
|
|
|
|
$shouldUpdate = true;
|
|
|
|
if (isset($_GET['force']) && $_GET['force'] === "true") {
|
|
$shouldUpdate = true;
|
|
} else {
|
|
$query = "SELECT date FROM last_exchange_update";
|
|
$result = $db->querySingle($query);
|
|
|
|
if ($result) {
|
|
$lastUpdateDate = new DateTime($result);
|
|
$currentDate = new DateTime();
|
|
$lastUpdateDateString = $lastUpdateDate->format('Y-m-d');
|
|
$currentDateString = $currentDate->format('Y-m-d');
|
|
$shouldUpdate = $lastUpdateDateString < $currentDateString;
|
|
}
|
|
|
|
if (!$shouldUpdate) {
|
|
echo "Rates are current, no need to update.";
|
|
exit;
|
|
}
|
|
}
|
|
|
|
$query = "SELECT api_key, provider FROM fixer";
|
|
$result = $db->query($query);
|
|
|
|
if ($result) {
|
|
$row = $result->fetchArray(SQLITE3_ASSOC);
|
|
|
|
if ($row) {
|
|
$apiKey = $row['api_key'];
|
|
$provider = $row['provider'];
|
|
|
|
$codes = "";
|
|
$query = "SELECT id, name, symbol, code FROM currencies";
|
|
$result = $db->query($query);
|
|
while ($row = $result->fetchArray(SQLITE3_ASSOC)) {
|
|
$codes .= $row['code'].",";
|
|
}
|
|
$codes = rtrim($codes, ',');
|
|
$query = "SELECT u.main_currency, c.code FROM user u LEFT JOIN currencies c ON u.main_currency = c.id WHERE u.id = 1";
|
|
$stmt = $db->prepare($query);
|
|
$result = $stmt->execute();
|
|
$row = $result->fetchArray(SQLITE3_ASSOC);
|
|
$mainCurrencyCode = $row['code'];
|
|
$mainCurrencyId = $row['main_currency'];
|
|
|
|
if ($provider === 1) {
|
|
$api_url = "https://api.apilayer.com/fixer/latest?base=EUR&symbols=" . $codes;
|
|
$context = stream_context_create([
|
|
'http' => [
|
|
'method' => 'GET',
|
|
'header' => 'apikey: ' . $apiKey,
|
|
]
|
|
]);
|
|
$response = file_get_contents($api_url, false, $context);
|
|
} else {
|
|
$api_url = "http://data.fixer.io/api/latest?access_key=". $apiKey . "&base=EUR&symbols=" . $codes;
|
|
$response = file_get_contents($api_url);
|
|
}
|
|
|
|
$apiData = json_decode($response, true);
|
|
|
|
$mainCurrencyToEUR = $apiData['rates'][$mainCurrencyCode];
|
|
|
|
if ($apiData !== null && isset($apiData['rates'])) {
|
|
foreach ($apiData['rates'] as $currencyCode => $rate) {
|
|
if ($currencyCode === $mainCurrencyCode) {
|
|
$exchangeRate = 1.0;
|
|
} else {
|
|
$exchangeRate = $rate / $mainCurrencyToEUR;
|
|
}
|
|
$updateQuery = "UPDATE currencies SET rate = :rate WHERE code = :code";
|
|
$updateStmt = $db->prepare($updateQuery);
|
|
$updateStmt->bindParam(':rate', $exchangeRate, SQLITE3_TEXT);
|
|
$updateStmt->bindParam(':code', $currencyCode, SQLITE3_TEXT);
|
|
$updateResult = $updateStmt->execute();
|
|
|
|
if (!$updateResult) {
|
|
echo "Error updating rate for currency: $currencyCode";
|
|
}
|
|
}
|
|
$currentDate = new DateTime();
|
|
$formattedDate = $currentDate->format('Y-m-d');
|
|
|
|
$deleteQuery = "DELETE FROM last_exchange_update";
|
|
$deleteStmt = $db->prepare($deleteQuery);
|
|
$deleteResult = $deleteStmt->execute();
|
|
|
|
$query = "INSERT INTO last_exchange_update (date) VALUES (:formattedDate)";
|
|
$stmt = $db->prepare($query);
|
|
$stmt->bindParam(':formattedDate', $formattedDate, SQLITE3_TEXT);
|
|
$result = $stmt->execute();
|
|
|
|
$db->close();
|
|
echo "Rates updated successfully!";
|
|
}
|
|
} else {
|
|
echo "Exchange rates update skipped. No fixer.io api key provided";
|
|
$apiKey = null;
|
|
}
|
|
} else {
|
|
echo "Exchange rates update skipped. No fixer.io api key provided";
|
|
$apiKey = null;
|
|
}
|
|
?>
|