import ccxt

# Binance Testnetで練習する例
exchange = ccxt.binance({
    'apiKey': 'YOUR_TESTNET_API_KEY',
    'secret': 'YOUR_TESTNET_SECRET',
    'options': {
        'defaultType': 'spot',
    },
})

# サンドボックスモードを有効化
exchange.set_sandbox_mode(True)

# 接続確認
print(exchange.fetch_time())

import ccxt

exchange = ccxt.binance({
    'apiKey': 'YOUR_API_KEY',
    'secret': 'YOUR_SECRET',
    'enableRateLimit': True,  # 必ずTrueに設定すること
})

import ccxt
import time

exchange = ccxt.binance({
    'apiKey': 'YOUR_API_KEY',
    'secret': 'YOUR_SECRET',
    'enableRateLimit': True,
})

# 手動スロットリングの例
time.sleep(exchange.rateLimit / 1000)  # ミリ秒を秒に変換

balance = exchange.fetch_balance()

# USDTの残高を確認
usdt_balance = balance['USDT']

print(f"利用可能残高（free）: {usdt_balance['free']}")   # 注文に使える残高
print(f"注文中残高（used）: {usdt_balance['used']}")     # 注文に拘束中の残高
print(f"合計残高（total）: {usdt_balance['total']}")     # free + used

# BTC/USDTを成行で0.001BTC買う
order = exchange.create_order(
    symbol='BTC/USDT',  # 取引ペア
    type='market',       # 成行注文
    side='buy',          # buy（買い）or sell（売り）
    amount=0.001,        # 数量
)

print(order)

# BTC/USDTを60,000ドルで0.001BTC指値買い
buy_order = exchange.create_order(
    symbol='BTC/USDT',
    type='limit',
    side='buy',
    amount=0.001,
    price=60000,  # 指値価格を指定
)

# BTC/USDTを70,000ドルで0.001BTC指値売り
sell_order = exchange.create_order(
    symbol='BTC/USDT',
    type='limit',
    side='sell',
    amount=0.001,
    price=70000,
)

print(f"買い注文ID: {buy_order['id']}")
print(f"売り注文ID: {sell_order['id']}")

# ストップロス注文（Binanceの場合）
# 現在価格が58,000ドルの時、57,000ドルでストップロスを設定する例
stop_loss_order = exchange.create_order(
    symbol='BTC/USDT',
    type='stop_loss_limit',
    side='sell',
    amount=0.001,
    price=56800,      # 実際に約定させる指値価格
    params={
        'stopPrice': 57000,  # トリガーとなる価格
    }
)

print(stop_loss_order)

# 注文IDで個別の注文状況を確認
order_id = buy_order['id']
order_status = exchange.fetch_order(order_id, 'BTC/USDT')

print(f"注文ステータス: {order_status['status']}")
# open     → 未約定（待ち中）
# closed   → 約定済み
# canceled → キャンセル済み

import time

# 未決済注文を一覧取得
open_orders = exchange.fetch_open_orders('BTC/USDT')
print(f"未決済注文数: {len(open_orders)}件")

# 指定時間内に約定しなければ自動キャンセルする例
timeout_seconds = 300  # 5分

for order in open_orders:
    order_id = order['id']
    created_at = order['timestamp'] / 1000  # ミリ秒→秒

    elapsed = time.time() - created_at
    if elapsed > timeout_seconds:
        canceled = exchange.cancel_order(order_id, 'BTC/USDT')
        print(f"注文 {order_id} をキャンセルしました")

# 取引履歴から損益を簡易計算する例
trades = exchange.fetch_my_trades('BTC/USDT')

total_cost = 0    # 購入にかかった総コスト
total_amount = 0  # 保有BTC総量

for trade in trades:
    if trade['side'] == 'buy':
        total_cost += trade['cost']      # 購入金額（USDT）
        total_amount += trade['amount']  # 購入数量（BTC）

if total_amount > 0:
    avg_price = total_cost / total_amount
    print(f"平均取得単価: {avg_price:.2f} USDT")
    print(f"保有量: {total_amount:.6f} BTC")

    # 現在価格を取得して含み損益を計算
    ticker = exchange.fetch_ticker('BTC/USDT')
    current_price = ticker['last']
    unrealized_pnl = (current_price - avg_price) * total_amount
    print(f"含み損益: {unrealized_pnl:.2f} USDT")

import ccxt
import time
import logging

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

def place_order_with_retry(exchange, symbol, order_type, side, amount, price=None, max_retries=3):
    """
    リトライ機能付きの注文関数
    指数バックオフでリトライする
    """
    for attempt in range(max_retries):
        try:
            if order_type == 'market':
                order = exchange.create_order(symbol, order_type, side, amount)
            else:
                order = exchange.create_order(symbol, order_type, side, amount, price)

            logger.info(f"注文成功: {order['id']}")
            return order

        except ccxt.InsufficientFunds as e:
            # 残高不足はリトライしても意味がないため即終了
            logger.error(f"残高不足: {e}")
            raise

        except ccxt.RateLimitExceeded as e:
            # レートリミットは待機してからリトライ
            wait_time = (2 ** attempt) * 1  # 指数バックオフ: 1秒 → 2秒 → 4秒
            logger.warning(f"レートリミット超過。{wait_time}秒待機してリトライ... (試行{attempt + 1}/{max_retries})")
            time.sleep(wait_time)

        except ccxt.InvalidOrder as e:
            # 注文パラメータが不正はリトライしても意味なし
            logger.error(f"不正な注文パラメータ: {e}")
            raise

        except ccxt.NetworkError as e:
            # ネットワークエラーはリトライ
            wait_time = (2 ** attempt) * 2
            logger.warning(f"ネットワークエラー。{wait_time}秒待機してリトライ... (試行{attempt + 1}/{max_retries})")
            time.sleep(wait_time)

        except ccxt.ExchangeError as e:
            logger.error(f"取引所エラー: {e}")
            raise

    raise Exception(f"最大リトライ回数({max_retries}回)を超えました")