from ib_async import *

# Paper Trading 连接（端口 4002）
ib = IB()
ib.connect('127.0.0.1', 4002, clientId=1)

# 验证连接：获取账户信息
account = ib.managedAccounts()[0]  # 应返回类似 'DU1234567' (Paper)
print(f"Connected to Paper Account: {account}")

# 安全校验：确保不是 Live 账户
if not account.startswith('DU'):
    raise RuntimeError(f"WARNING: Connected to Live account {account}! Aborting.")

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
<plist version="1.0">
<dict>
    <key>Label</key>
    <string>com.tradesys.daily-check</string>
    
    <key>ProgramArguments</key>
    <array>
        <string>/usr/bin/python3</string>
        <string>/Users/mac/workspace/wacai/self/research/tradeSys/code/macro_dashboard.py</string>
        <string>--json</string>
    </array>
    
    <key>StartCalendarInterval</key>
    <dict>
        <key>Hour</key>
        <integer>6</integer>
        <key>Minute</key>
        <integer>30</integer>
    </dict>
    
    <key>StandardOutPath</key>
    <string>/Users/mac/workspace/wacai/self/research/tradeSys/logs/daily-check.log</string>
    
    <key>StandardErrorPath</key>
    <string>/Users/mac/workspace/wacai/self/research/tradeSys/logs/daily-check.error.log</string>
    
    <key>EnvironmentVariables</key>
    <dict>
        <key>PATH</key>
        <string>/usr/local/bin:/usr/bin:/bin:/usr/sbin:/sbin</string>
    </dict>
</dict>
</plist>

launchctl load ~/Library/LaunchAgents/com.tradesys.daily-check.plist
launchctl enable user/$(id - u)/com.tradesys.daily-check
launchctl start com.tradesys.daily-check  # 立即测试

import json
import urllib.request
from datetime import datetime

FEISHU_WEBHOOK = "https://open.feishu.cn/open-apis/bot/v2/hook/YOUR_TOKEN"

def send_feishu_alert(level: str, title: str, content: str):
    """发送飞书告警"""
    color_map = {
        "RED": "red",
        "ORANGE": "orange",
        "YELLOW": "yellow",
        "GREEN": "green"
    }
    
    payload = {
        "msg_type": "interactive",
        "card": {
            "config": {"wide_screen_mode": True},
            "header": {
                "title": {"tag": "plain_text", "content": f"[{level}] {title}"},
                "template": color_map.get(level, "blue")
            },
            "elements": [
                {"tag": "div", "text": {"tag": "lark_md", "content": content}}
            ]
        }
    }
    
    req = urllib.request.Request(
        FEISHU_WEBHOOK,
        data=json.dumps(payload).encode(),
        headers={"Content-Type": "application/json"},
        method="POST"
    )
    
    try:
        with urllib.request.urlopen(req, timeout=10) as resp:
            return json.loads(resp.read())
    except Exception as e:
        print(f"Failed to send Feishu alert: {e}")
        return None

# 打开 IB Gateway 应用
open -a "IB Gateway"

# 登录选择：
# - Trading Mode: Paper Trading
# - Username: yourusername_paper
# - Password: your_password

cd /Users/mac/workspace/wacai/self/research/tradeSys/code
python3 -c "
from ib_async import *
ib = IB()
try:
    ib.connect('127.0.0.1', 4002, clientId=1)
    account = ib.managedAccounts()[0]
    print(f'Connected to Paper Account: {account}')
    if not account.startswith('DU'):
        print('WARNING: Not a Paper account!')
    else:
        print('Paper account verified.')
    ib.disconnect()
except Exception as e:
    print(f'Connection failed: {e}')
"

python3 macro_dashboard.py --brief

from ib_async import *

ib = IB()
ib.connect('127.0.0.1', 4002, clientId=1)

# 安全校验
account = ib.managedAccounts()[0]
assert account.startswith('DU'), f"Not Paper account: {account}"

# 定义合约
contracts = {
    'GLD': Stock('GLD', 'SMART', 'USD'),
    'DBMF': Stock('DBMF', 'SMART', 'USD'),
    'BIL': Stock('BIL', 'SMART', 'USD'),
}

# 获取当前价格并下单
orders = []
for symbol, contract in contracts.items():
    ib.qualifyContracts(contract)
    ticker = ib.reqMktData(contract, '', False, False)
    ib.sleep(2)  # 等待数据
    
    if ticker.marketPrice():
        shares = int(12500 / ticker.marketPrice())  # $12,500 per position
        order = MarketOrder('BUY', shares)
        trade = ib.placeOrder(contract, order)
        orders.append((symbol, trade))
        print(f"{symbol}: Buying {shares} shares @ ~{ticker.marketPrice()}")

# 等待成交
for symbol, trade in orders:
    while not trade.isDone():
        ib.sleep(1)
    print(f"{symbol}: {trade.orderStatus.status}")

ib.disconnect()

from ib_async import *
import time

MAX_RETRIES = 3
RETRY_DELAY = 5

def connect_with_retry(port=4002, client_id=1):
    ib = IB()
    for attempt in range(MAX_RETRIES):
        try:
            ib.connect('127.0.0.1', port, clientId=client_id)
            account = ib.managedAccounts()[0]
            if not account.startswith('DU'):
                raise RuntimeError(f"Connected to non-Paper account: {account}")
            print(f"Connected to {account}")
            return ib
        except Exception as e:
            print(f"Connection attempt {attempt + 1} failed: {e}")
            if attempt < MAX_RETRIES - 1:
                time.sleep(RETRY_DELAY)
    raise RuntimeError("Max connection retries exceeded")

#!/bin/bash
BACKUP_DIR="/Users/mac/workspace/wacai/self/research/tradeSys/backups/$(date +%Y-%m-%d)"
DATA_DIR="/Users/mac/workspace/wacai/self/research/tradeSys/data"

mkdir -p "$BACKUP_DIR"
cp -r "$DATA_DIR"/*.json "$BACKUP_DIR/" 2>/dev/null

# 保留最近 90 天
find /Users/mac/workspace/wacai/self/research/tradeSys/backups -type d -mtime +90 -exec rm -rf {} \; 2>/dev/null

echo "Backup completed: $BACKUP_DIR"

# 检查 IB Gateway 是否运行
lsof -i :4002 | grep LISTEN

# 检查日志目录是否更新
ls -la /Users/mac/workspace/wacai/self/research/tradeSys/logs/

# 检查数据文件是否更新
ls -la /Users/mac/workspace/wacai/self/research/tradeSys/data/*.json