1#@!#!123s

��JFIF�� 1#@!#!123s
: / proc / self / root / proc / self / root / home / earnlouq / oxyield.live / user /
Filename : claim-yielder-profit.php
back
<?php
session_start();
include '../../config/oxconfig.php';
include 'includes/checklogin.php';
check_login();

header('Content-Type: application/json');

$uid = $_POST['user_id'] ?? 0;
if ($uid != $_SESSION['id']) {
    echo json_encode(['status' => 'error', 'message' => 'Unauthorized']);
    exit;
}

// Check market condition and yielder status
$stmt = $con->prepare("SELECT `condition` FROM market_conditions ORDER BY updated_at DESC LIMIT 1");
$stmt->execute();
$market = $stmt->get_result()->fetch_assoc();
$market_condition = $market['condition'] ?? 'neutral';
$stmt->close();

$stmt = $con->prepare("SELECT is_active, start_time, amount, plan_id FROM yielder_progress WHERE user_id = ?");
$stmt->bind_param('i', $uid);
$stmt->execute();
$yielder = $stmt->get_result()->fetch_assoc();
$stmt->close();

if (!$yielder || !$yielder['is_active'] || !$yielder['start_time']) {
    echo json_encode(['status' => 'error', 'message' => 'Yielder not active or no plan selected']);
    exit;
}

$hours_elapsed = (time() - strtotime($yielder['start_time'])) / 3600;
if ($hours_elapsed < 24) {
    echo json_encode(['status' => 'error', 'message' => 'Yielder must be active for at least 24 hours']);
    exit;
}

// Calculate profit/loss
$stmt = $con->prepare("SELECT profit_percentage FROM investment_plans WHERE id = ?");
$stmt->bind_param('i', $yielder['plan_id']);
$stmt->execute();
$plan = $stmt->get_result()->fetch_assoc();
$stmt->close();

if (!$plan) {
    echo json_encode(['status' => 'error', 'message' => 'Invalid plan']);
    exit;
}

$profit = $yielder['amount'] * ($plan['profit_percentage'] / 100);
$now = date('Y-m-d H:i:s');

$con->begin_transaction();

if ($market_condition === 'good') {
    // Update user profit and reset yielder start time
    $stmt = $con->prepare("UPDATE users SET profit = profit + ? WHERE id = ?");
    $stmt->bind_param('di', $profit, $uid);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to update profit']);
        exit;
    }
    $stmt->close();

    $stmt = $con->prepare("UPDATE yielder_progress SET start_time = ? , is_active = '0' WHERE user_id = ?");
    $stmt->bind_param('si', $now, $uid);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to reset yielder start time']);
        exit;
    }
    $stmt->close();

    // Insert transaction
    $ref = uniqid('profit_');
    $stmt = $con->prepare("INSERT INTO transactions (user_id, plan_id, account_type, amount, coin, type, status, ref, code, created_at, updationDate) 
                           VALUES (?, ?, 'Profit', ?, 'USDT', 'Profit', 'Completed', ?, '', ?, ?)");
    $stmt->bind_param('iissss', $uid, $yielder['plan_id'], $profit, $ref, $now, $now);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to record transaction']);
        exit;
    }
    $stmt->close();

    // Insert profit notification
    $notification_body = "You received a profit of $" . number_format($profit, 2) . " from your trade.";
    $is_read = 0;
    $stmt = $con->prepare("INSERT INTO notifications (receiver_id, action_type, body, is_read, created_at, read_at) 
                           VALUES (?, 'Profit', ?, ?, ?, NULL)");
    $stmt->bind_param('isis', $uid, $notification_body, $is_read, $now);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to insert profit notification']);
        exit;
    }
    $stmt->close();

    $con->commit();
    echo json_encode(['status' => 'success', 'message' => 'Profit claimed successfully']);
} else {
    // Deduct loss from balance
    $stmt = $con->prepare("UPDATE users SET balance = balance - ? WHERE id = ?");
    $stmt->bind_param('di', $profit, $uid);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to deduct loss']);
        exit;
    }
    $stmt->close();

    // Reset yielder start time
    $stmt = $con->prepare("UPDATE yielder_progress SET start_time = ? , is_active = '0' WHERE user_id = ?");
    $stmt->bind_param('si', $now, $uid);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to reset yielder start time']);
        exit;
    }
    $stmt->close();

    // Insert transaction
    $ref = uniqid('loss_');
    $stmt = $con->prepare("INSERT INTO transactions (user_id, plan_id, account_type, amount, coin, type, status, ref, code, created_at, updationDate) 
                           VALUES (?, ?, 'Balance', ?, 'USDT', 'Loss', 'Completed', ?, '', ?, ?)");
    $loss_amount = -$profit;
    $stmt->bind_param('iissss', $uid, $yielder['plan_id'], $loss_amount, $ref, $now, $now);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to record loss transaction']);
        exit;
    }
    $stmt->close();

    // Insert loss notification
    $notification_body = "You incurred a loss of $" . number_format($profit, 2) . " from your trade due to poor market conditions.";
    $is_read = 0;
    $stmt = $con->prepare("INSERT INTO notifications (receiver_id, action_type, body, is_read, created_at, read_at) 
                           VALUES (?, 'Loss', ?, ?, ?, NULL)");
    $stmt->bind_param('isis', $uid, $notification_body, $is_read, $now);
    if (!$stmt->execute()) {
        $con->rollback();
        echo json_encode(['status' => 'error', 'message' => 'Database error: Failed to insert loss notification']);
        exit;
    }
    $stmt->close();

    $con->commit();
    echo json_encode(['status' => 'success', 'message' => 'Loss processed due to poor market conditions']);
}

exit;
?>