pip install ccxt pandas

import time
import ccxt
import pandas as pd

# 1. Khởi tạo kết nối sàn (chế độ Sandbox/Testnet để test Paper Trading)
exchange = ccxt.binance({
    'apiKey': 'YOUR_TESTNET_API_KEY',
    'secret': 'YOUR_TESTNET_SECRET_KEY',
    'enableRateLimit': True,
})
exchange.set_sandbox_mode(True)  # Kích hoạt chế độ Testnet/Sandbox

SYMBOL = 'BTC/USDT'
TIMEFRAME = '1m'
RSI_PERIOD = 14
RSI_OVERBOUGHT = 70
RSI_OVERSOLD = 30

# Biến giả lập trạng thái vị thế (Paper Position Tracker)
paper_position = {
    'has_position': False,
    'entry_price': 0.0,
    'balance_usdt': 1000.0,  # Bắt đầu với 1000 USDT giả lập
    'amount_btc': 0.0
}

def calculate_rsi(df, period=14):
    delta = df['close'].diff()
    gain = (delta.where(delta > 0, 0)).rolling(window=period).mean()
    loss = (-delta.where(delta < 0, 0)).rolling(window=period).mean()
    rs = gain / loss
    return 100 - (100 / (1 + rs))

def run_paper_trading():
    print(f"--- BẮT ĐẦU CHẠY PAPER TRADING CHO {SYMBOL} ---")
    while True:
        try:
            # Lấy dữ liệu nến lịch sử gần nhất (OHLCV)
            ohlcv = exchange.fetch_ohlcv(SYMBOL, TIMEFRAME, limit=50)
            df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])

            # Tính toán chỉ báo RSI
            df['rsi'] = calculate_rsi(df, RSI_PERIOD)
            latest_rsi = df['rsi'].iloc[-1]
            current_price = df['close'].iloc[-1]

            print(f"Giá hiện tại: {current_price} | RSI: {latest_rsi:.2f}")

            # Logic Chiến lược & Đặt lệnh giả lập (Paper Execution)
            if latest_rsi < RSI_OVERSOLD and not paper_position['has_position']:
                # MUA giả lập
                paper_position['amount_btc'] = paper_position['balance_usdt'] / current_price
                paper_position['entry_price'] = current_price
                paper_position['balance_usdt'] = 0.0
                paper_position['has_position'] = True
                print(f"🟢 [MUA Giả Lập] Giá: {current_price} | Đã mua {paper_position['amount_btc']:.5f} BTC")

            elif latest_rsi > RSI_OVERBOUGHT and paper_position['has_position']:
                # BÁN giả lập
                revenue = paper_position['amount_btc'] * current_price
                profit = revenue - (paper_position['amount_btc'] * paper_position['entry_price'])
                paper_position['balance_usdt'] = revenue
                paper_position['amount_btc'] = 0.0
                paper_position['has_position'] = False
                print(f"🔴 [BÁN Giả Lập] Giá: {current_price} | Lợi nhuận: {profit:.2f} USDT | Số dư: {paper_position['balance_usdt']:.2f} USDT")

            # Đợi nến tiếp theo (ví dụ chạy kiểm tra mỗi 10 giây)
            time.sleep(10)

        except Exception as e:
            print(f"⚠️ Có lỗi xảy ra: {e}")
            time.sleep(5)

if __name__ == "__main__":
    run_paper_trading()