不知道是不是与交易已经失效的合约有关,我回测的是(FG2412)
能看到可用资金、冻结保证金一直在跳动,但是就是成交不了,一直在下单撤单。
#!/usr/bin/env python
# -*- coding: utf-8 -*-
__author__ = "Chaos"
from datetime import date
import pandas as pd
from tqsdk import TqApi, TqAuth, TqBacktest, TargetPosTask, BacktestFinished,TqKq
from tqsdk.ta import ATR
# ===== 全局参数设置 =====
SYMBOL = "CZCE.FG412" # 黄金期货合约
POSITION_SIZE = 30 # 基础持仓手数
START_DATE = date(2024, 6, 1) # 回测开始日期
END_DATE = date(2024, 12, 1) # 回测结束日期
# TRIX指标参数
TRIX_PERIOD = 12 # TRIX计算周期
SIGNAL_PERIOD = 9 # 信号线计算周期
MA_PERIOD = 60 # 长期移动平均线周期,用于趋势过滤
# 信号阈值参数
SIGNAL_THRESHOLD = 0.05 # TRIX与信号线差值的阈值,避免微小交叉
# 风控参数
ATR_PERIOD = 14 # ATR计算周期
STOP_LOSS_MULTIPLIER = 2.0 # 止损ATR倍数
TAKE_PROFIT_MULTIPLIER = 3.0 # 止盈ATR倍数
MAX_HOLDING_DAYS = 15 # 最大持仓天数
# ===== 全局变量 =====
current_direction = 0 # 当前持仓方向:1=多头,-1=空头,0=空仓
entry_price = 0 # 开仓价格
stop_loss_price = 0 # 止损价格
entry_date = None # 开仓日期
trade_count = 0 # 交易次数
win_count = 0 # 盈利次数
# ===== TRIX指标计算函数 =====
def calculate_trix(close_prices, period):
"""计算TRIX指标和信号线"""
# 第一重EMA
ema1 = close_prices.ewm(span=period, adjust=False).mean()
# 第二重EMA
ema2 = ema1.ewm(span=period, adjust=False).mean()
# 第三重EMA
ema3 = ema2.ewm(span=period, adjust=False).mean()
# 计算TRIX
trix = 100 * (ema3 / ema3.shift(1) - 1)
# 计算信号线
signal = trix.rolling(SIGNAL_PERIOD).mean()
return trix, signal
# ===== 策略开始 =====
print("开始运行TRIX指标期货策略...")
print(f"品种: {SYMBOL}, 回测周期: {START_DATE} - {END_DATE}")
print(f"TRIX参数: 周期={TRIX_PERIOD}, 信号线周期={SIGNAL_PERIOD}")
# 创建API实例
api = TqApi(TqKq(),backtest=TqBacktest(start_dt=START_DATE, end_dt=END_DATE),
auth=TqAuth("137584321", "65660697"))
# 订阅合约的K线数据
klines = api.get_kline_serial(SYMBOL, 60 * 60 *24) # 日线数据
# 创建目标持仓任务
target_pos = TargetPosTask(api, SYMBOL)
try:
while True:
# 等待更新
api.wait_update()
# 如果K线有更新
if api.is_changing(klines.iloc[-1], "datetime"):
# 确保有足够的数据计算指标
if len(klines) < max(TRIX_PERIOD, SIGNAL_PERIOD, MA_PERIOD, ATR_PERIOD) + 10:
continue
# 计算TRIX指标和信号线
klines['trix'], klines['signal'] = calculate_trix(klines.close, TRIX_PERIOD)
# 计算长期移动平均线,用于趋势过滤
klines['ma'] = klines.close.rolling(window=MA_PERIOD).mean()
# 计算ATR用于设置止损
atr_data = ATR(klines, ATR_PERIOD)
# 获取最新数据
current_price = float(klines.close.iloc[-1])
current_datetime = pd.to_datetime(klines.datetime.iloc[-1], unit='ns')
current_trix = float(klines.trix.iloc[-1])
previous_trix = float(klines.trix.iloc[-2])
current_signal = float(klines.signal.iloc[-1])
previous_signal = float(klines.signal.iloc[-2])
current_ma = float(klines.ma.iloc[-1])
current_atr = float(atr_data.atr.iloc[-1])
# 计算TRIX与信号线的差值
trix_diff = current_trix - current_signal
previous_trix_diff = previous_trix - previous_signal
# 输出调试信息
print(f"日期: {current_datetime.strftime('%Y-%m-%d')}, 价格: {current_price:.2f}")
print(f"TRIX: {current_trix:.4f}, 信号线: {current_signal:.4f}, 差值: {trix_diff:.4f}")
# ===== 交易逻辑 =====
# 空仓状态 - 寻找开仓机会
if current_direction == 0:
# 多头开仓条件:TRIX上穿信号线
if previous_trix < previous_signal and current_trix > current_signal:
current_direction = 1
target_pos.set_target_volume(POSITION_SIZE)
entry_price = current_price
stop_loss_price = entry_price - STOP_LOSS_MULTIPLIER * current_atr
take_profit_price = entry_price + TAKE_PROFIT_MULTIPLIER * current_atr
print(f"多头开仓: 价格={entry_price}, 止损={stop_loss_price:.2f}, 止盈={take_profit_price:.2f}")
# 空头开仓条件:TRIX下穿信号线
elif previous_trix > previous_signal and current_trix < current_signal:
current_direction = -1
target_pos.set_target_volume(-POSITION_SIZE)
entry_price = current_price
stop_loss_price = entry_price + STOP_LOSS_MULTIPLIER * current_atr
take_profit_price = entry_price - TAKE_PROFIT_MULTIPLIER * current_atr
print(f"空头开仓: 价格={entry_price}, 止损={stop_loss_price:.2f}, 止盈={take_profit_price:.2f}")
# 多头持仓 - 检查平仓条件
elif current_direction == 1:
# 止损条件
if current_price <= stop_loss_price:
profit_pct = (current_price - entry_price) / entry_price * 100
target_pos.set_target_volume(0)
current_direction = 0
print(f"多头止损平仓: 价格={current_price}, 盈亏={profit_pct:.2f}%")
# 止盈条件
elif current_price >= take_profit_price:
profit_pct = (current_price - entry_price) / entry_price * 100
target_pos.set_target_volume(0)
current_direction = 0
print(f"多头止盈平仓: 价格={current_price}, 盈亏={profit_pct:.2f}%")
# 信号平仓:TRIX下穿信号线
elif previous_trix > previous_signal and current_trix < current_signal:
profit_pct = (current_price - entry_price) / entry_price * 100
target_pos.set_target_volume(0)
current_direction = 0
print(f"多头信号平仓: 价格={current_price}, 盈亏={profit_pct:.2f}%")
# 空头持仓 - 检查平仓条件
elif current_direction == -1:
# 止损条件
if current_price >= stop_loss_price:
profit_pct = (entry_price - current_price) / entry_price * 100
target_pos.set_target_volume(0)
current_direction = 0
print(f"空头止损平仓: 价格={current_price}, 盈亏={profit_pct:.2f}%")
# 止盈条件
elif current_price <= take_profit_price:
profit_pct = (entry_price - current_price) / entry_price * 100
target_pos.set_target_volume(0)
current_direction = 0
print(f"空头止盈平仓: 价格={current_price}, 盈亏={profit_pct:.2f}%")
# 信号平仓:TRIX上穿信号线
elif previous_trix < previous_signal and current_trix > current_signal:
profit_pct = (entry_price - current_price) / entry_price * 100
target_pos.set_target_volume(0)
current_direction = 0
print(f"空头信号平仓: 价格={current_price}, 盈亏={profit_pct:.2f}%")
except BacktestFinished as e:
print("回测结束")
api.close()

chaos 已回答的问题 2025年6月12日
有其他问题也欢迎加入官方群聊611806823一起讨论~