????

File manager - Edit - /var/www/html/desktop/ongSystems/update_ong_system.php

Back
<?php error_reporting(E_ALL); ini_set('display_errors', 1); include '../helper.php'; require_once '../cors_config.php'; $requestData = json_decode(file_get_contents('php://input'), true); $id = $requestData['id'] ?? null; $token = $requestData['token'] ?? null; $data = $requestData['data'] ?? null; $current_time = $requestData['current_time'] ?? null; if (!$data \|\| !$id \|\| !$token) { jsonResponse('error', 'Invalid data', null, 400); } $db = connect_to_database(); // Validate user if (!validateUser($id, $token, $db)) { jsonResponse('error', 'Unauthorized', null, 401); } try{ // Retrieve ong_system_id and session data from 'data' $ong_system_id = $data['id']; $gamer_id = $data['gamer_id']; $hourly_price = $data['hourly_price']; $station_number = $data['station_number']; $extra_controller_count = $data['extra_controller_count']; $extra_controller_price = $data['extra_controller_price']; $tariff_title = $data['tariff_title']; $ringtone = $data['ringtone']; $notified = $data['notified']; $endTime = $data['end_time']; // Fetch current details of the ong_system using prepared statement $current_details_sql = "SELECT * FROM ong_systems WHERE id = ?"; $stmt = $db->prepare($current_details_sql); $stmt->bind_param("i", $ong_system_id); $stmt->execute(); $current_details_result = $stmt->get_result(); $current_details = $current_details_result->fetch_assoc(); $stmt->close(); // Check if any relevant fields have changed $has_changes = ( $current_details['station_number'] != $station_number \|\| $current_details['hourly_price'] != $hourly_price \|\| $current_details['extra_controller_count'] != $extra_controller_count \|\| $current_details['extra_controller_price'] != $extra_controller_price \|\| $current_details['tariff_title'] != $tariff_title ); // $client_time = $current_time; // First, update the ong_system $update_sql = "UPDATE ong_systems SET station_number = ?, gamer_id = ?, tariff_title = ?, hourly_price = ?, extra_controller_count = ?, extra_controller_price = ?, notified = ?, note = ?, ringtone = ?, end_time = ? WHERE id = ? "; $stmt = $db->prepare($update_sql); $stmt->bind_param( "iisiiiisssi", $data['station_number'], $data['gamer_id'], $tariff_title, $hourly_price, $extra_controller_count, $extra_controller_price, $notified, $data['note'], $ringtone, $endTime, $ong_system_id ); $stmt->execute(); // echo $stmt->affected_rows; // if ($stmt->affected_rows <= 0) { // $stmt->close(); // jsonResponse('error', 'خطا در آپدیت', null, 500); // } $stmt->close(); if ($has_changes && $current_details['stopped'] == 0) { // If there are changes, update the last session and add a new session // Step 1: Get the last session for this ong_system using created_at for ordering $last_session_sql = " SELECT * FROM sessions WHERE ong_system_id = ? ORDER BY created_at DESC LIMIT 1 "; $stmt = $db->prepare($last_session_sql); $stmt->bind_param("i", $ong_system_id); $stmt->execute(); $last_session_result = $stmt->get_result(); if ($last_session_result->num_rows > 0) { $last_session = $last_session_result->fetch_assoc(); $stmt->close(); $last_session_id = $last_session['session_id']; $last_start_time = $last_session['start_time']; // Step 2: Calculate the total cost based on the last session's start time and current (client-provided) time $total_cost = calculateTotalCost($last_start_time, $current_time, $last_session['hourly_price'], $last_session['extra_controller_count'], $last_session['extra_controller_price']); // Step 3: Update the last session with the client time as end time and the calculated total cost $update_session_sql = "UPDATE sessions SET end_time = NOW(), total_cost = ? WHERE session_id = ? "; $stmt = $db->prepare($update_session_sql); $stmt->bind_param("ii", $total_cost, $last_session_id); $stmt->execute(); $stmt->close(); } // Step 4: Insert the new session with the client time as the new start time $new_session_sql = "INSERT INTO sessions (ong_system_id, game_net_id, tariff_title, user_id, station_number, start_time, hourly_price, extra_controller_count, extra_controller_price) VALUES (?, ?, ?, ?, ?, NOW(), ?, ?, ?)"; $stmt = $db->prepare($new_session_sql); $stmt->bind_param( "iisiiiii", $ong_system_id, $data['game_net_id'], $tariff_title, $data['gamer_id'], $data['station_number'], $hourly_price, $extra_controller_count, $extra_controller_price ); $stmt->execute(); $stmt->close(); } // Step 5: Retrieve all sessions for the user $all_sessions_sql = " SELECT * FROM sessions WHERE ong_system_id = ? ORDER BY created_at DESC "; $stmt = $db->prepare($all_sessions_sql); $stmt->bind_param("i", $ong_system_id); $stmt->execute(); $all_sessions_result = $stmt->get_result(); $all_sessions = array(); while ($session = $all_sessions_result->fetch_assoc()) { $all_sessions[] = $session; } $stmt->close(); $response = array( "status" => "success", "message" => "Ong system updated successfully.", "sessions" => $all_sessions // Include all sessions in the response ); if ($gamer_id != $current_details['gamer_id']) { if ($gamer_id === null) { $sql = "UPDATE sessions SET user_id = NULL WHERE ong_system_id = ?"; $stmt = $db->prepare($sql); $stmt->bind_param("i", $ong_system_id); } else { $sql = "UPDATE sessions SET user_id = ? WHERE ong_system_id = ?"; $stmt = $db->prepare($sql); $stmt->bind_param("ii", $gamer_id, $ong_system_id); } $stmt->execute(); $stmt->close(); if ($gamer_id === null) { $sql = "UPDATE ong_systems_payments SET gamer_id = NULL WHERE ong_system_id = ?"; $stmt = $db->prepare($sql); $stmt->bind_param("i", $ong_system_id); } else { $sql = "UPDATE ong_systems_payments SET gamer_id = ? WHERE ong_system_id = ?"; $stmt = $db->prepare($sql); $stmt->bind_param("ii", $gamer_id, $ong_system_id); } $stmt->execute(); $stmt->close(); if ($gamer_id === null) { $sql = "UPDATE ong_systems_cart SET gamer_id = NULL WHERE ong_system_id = ?"; $stmt = $db->prepare($sql); $stmt->bind_param("i", $ong_system_id); } else { $sql = "UPDATE ong_systems_cart SET gamer_id = ? WHERE ong_system_id = ?"; $stmt = $db->prepare($sql); $stmt->bind_param("ii", $gamer_id, $ong_system_id); } $stmt->execute(); $stmt->close(); } jsonResponse('success', 'Ong system updated successfully.', ["sessions" => $all_sessions ]); }catch (Exception $e) { jsonResponse('error', $e->getMessage(), null, 500); }finally { $db->close(); } // Helper function to calculate total cost function calculateTotalCost($start_time, $end_time, $hourly_price, $extra_controller_count, $extra_controller_price) { $start = strtotime($start_time); $end = strtotime($end_time); // Calculate duration in seconds $duration_in_seconds = $end - $start; // Calculate total cost using hourly rate and extra controllers $extra_controller_cost = $extra_controller_count * $extra_controller_price; $total_hourly_price = $hourly_price + $extra_controller_cost; // Calculate the total cost // Convert seconds to hours for the cost calculation $total_cost = ($duration_in_seconds / 3600) * $total_hourly_price; // Round total cost to avoid fractional costs, if needed return (int) round($total_cost); }

| ver. 1.4 | Github | . | PHP 8.3.6 | Generation time: 0.49 | proxy | phpinfo | Settings