92 lines
4.2 KiB
PHP
92 lines
4.2 KiB
PHP
<?php
|
|
require_once __DIR__ . '/../../includes/connect_endpoint_crontabs.php';
|
|
|
|
// Get all user ids
|
|
|
|
$query = "SELECT id, username FROM user";
|
|
$stmt = $db->prepare($query);
|
|
$usersToUpdateExchange = $stmt->execute();
|
|
|
|
while ($userToUpdateExchange = $usersToUpdateExchange->fetchArray(SQLITE3_ASSOC)) {
|
|
$userId = $userToUpdateExchange['id'];
|
|
echo "For user: " . $userToUpdateExchange['username'] . "<br />";
|
|
|
|
$query = "SELECT api_key FROM fixer WHERE user_id = :userId";
|
|
$stmt = $db->prepare($query);
|
|
$stmt->bindParam(':userId', $userId, SQLITE3_INTEGER);
|
|
$result = $stmt->execute();
|
|
|
|
if ($result) {
|
|
$row = $result->fetchArray(SQLITE3_ASSOC);
|
|
|
|
if ($row) {
|
|
$apiKey = $row['api_key'];
|
|
|
|
$codes = "";
|
|
$query = "SELECT id, name, symbol, code FROM currencies WHERE user_id = :userId";
|
|
$stmt = $db->prepare($query);
|
|
$stmt->bindParam(':userId', $userId, SQLITE3_INTEGER);
|
|
$result = $stmt->execute();
|
|
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 = :userId";
|
|
$stmt = $db->prepare($query);
|
|
$stmt->bindParam(':userId', $userId, SQLITE3_INTEGER);
|
|
$result = $stmt->execute();
|
|
$row = $result->fetchArray(SQLITE3_ASSOC);
|
|
$mainCurrencyCode = $row['code'];
|
|
$mainCurrencyId = $row['main_currency'];
|
|
|
|
$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 <br />";
|
|
}
|
|
}
|
|
$currentDate = new DateTime();
|
|
$formattedDate = $currentDate->format('Y-m-d');
|
|
|
|
$deleteQuery = "DELETE FROM last_exchange_update WHERE user_id = :userId";
|
|
$deleteStmt = $db->prepare($deleteQuery);
|
|
$deleteResult = $deleteStmt->execute();
|
|
|
|
$query = "INSERT INTO last_exchange_update (date, user_id) VALUES (:formattedDate, :userId)";
|
|
$stmt = $db->prepare($query);
|
|
$stmt->bindParam(':formattedDate', $formattedDate, SQLITE3_TEXT);
|
|
$stmt->bindParam(':userId', $userId, SQLITE3_INTEGER);
|
|
$result = $stmt->execute();
|
|
|
|
$db->close();
|
|
echo "Rates updated successfully!<br />";
|
|
}
|
|
} else {
|
|
echo "Exchange rates update skipped. No fixer.io api key provided<br />";
|
|
$apiKey = null;
|
|
}
|
|
} else {
|
|
echo "Exchange rates update skipped. No fixer.io api key provided<br />";
|
|
$apiKey = null;
|
|
}
|
|
|
|
}
|
|
|
|
?>
|