[关闭]
@Channelchan 2018-11-28T09:56:17.000000Z 字数 6890 阅读 61351

3_StopLoss_TakeProfit

策略逻辑：

  1. 60分钟看长短期MA趋势， 15分钟做均线择时。
  2. 加1：3的止损止盈比例，止损设置为3%

止损需要写在onBar，以最快的速度成交

  1. from vnpy.trader.vtConstant import *
  2. from vnpy.trader.app.ctaStrategy import CtaTemplate
  3. import talib as ta
  5. ########################################################################
  6. # 策略继承CtaTemplate
  7. class MultiFrameMaStrategy(CtaTemplate):
  8.     className = 'MultiFrameMaStrategy'
  9.     author = 'ChannelCMT'
  11.     # 策略参数
  12.     fastPeriod = 20; slowPeriod = 40
  13.     signalMaPeriod = 20
  14.     stopRatio = 0.04
  15.     lot = 1
  17.     # 策略变量
  18.     maTrend = {} # 记录趋势状态，多头1，空头-1
  19.     transactionPrice = {} # 记录成交价格
  21.     # 参数列表，保存了参数的名称
  22.     paramList = [
  23.                  'fastPeriod',
  24.                  'slowPeriod',
  25.                  'signalMaPeriod',
  26.                  'stopRatio'
  27.                 ]    
  29.     # 变量列表，保存了变量的名称
  30.     varList = [
  31.                'maTrend',
  32.                'transactionPrice'
  33.               ]  
  35.     # 同步列表，保存了需要保存到数据库的变量名称
  36.     syncList = ['posDict', 'eveningDict']
  38.     #----------------------------------------------------------------------
  39.     def __init__(self, ctaEngine, setting):
  40.         super().__init__(ctaEngine, setting)
  42.     #----------------------------------------------------------------------
  43.     def onInit(self):
  44.         """初始化策略"""
  45.         self.writeCtaLog(u'策略初始化')
  46.         self.transactionPrice = {s:0 for s in self.symbolList} # 生成成交价格的字典
  47.         self.maTrend = {s:0 for s in self.symbolList}
  48.         self.putEvent()
  50.     #----------------------------------------------------------------------
  51.     def onStart(self):
  52.         """启动策略"""
  53.         self.writeCtaLog(u'策略启动')
  54.         self.putEvent()
  56.     #----------------------------------------------------------------------
  57.     def onStop(self):
  58.         """停止策略"""
  59.         self.writeCtaLog(u'策略停止')
  60.         self.putEvent()
  62.     #----------------------------------------------------------------------
  63.     def onTick(self, tick):
  64.         """收到行情TICK推送"""
  65.         pass
  67.     #----------------------------------------------------------------------
  68.     def onBar(self, bar):
  69.         """收到Bar推送"""
  70.         self.onBarStopLoss(bar)
  72.     def onBarStopLoss(self, bar):
  73.         symbol = bar.vtSymbol
  75.         # 计算止损止盈价位
  76.         longStop = self.transactionPrice[symbol]*(1-self.stopRatio)
  77.         longProfit = self.transactionPrice[symbol]*(1+3*self.stopRatio)
  78.         shortStop = self.transactionPrice[symbol]*(1+self.stopRatio)
  79.         shortProfit = self.transactionPrice[symbol]*(1-3*self.stopRatio)
  82.         # 洗价器
  83.         if (self.posDict[symbol+'_LONG'] > 0):
  84.             if (bar.close < longStop):
  85.                 print('LONG stopLoss')
  86.                 self.cancelAll()
  87.                 self.sell(symbol,bar.close*0.99, self.posDict[symbol+'_LONG'])
  88.             elif  (bar.close > longProfit):
  89.                 print('LONG takeProfit')
  90.                 self.cancelAll()
  91.                 self.sell(symbol,bar.close*0.99, self.posDict[symbol+'_LONG'])
  93.         elif (self.posDict[symbol+'_SHORT'] > 0):
  94.             if (bar.close > shortStop):
  95.                 print('SHORT stopLoss')
  96.                 self.cancelAll()
  97.                 self.cover(symbol,bar.close*1.01, self.posDict[symbol+'_SHORT'])
  98.             elif (bar.close < shortProfit):
  99.                 print('SHORT takeProfit')
  100.                 self.cancelAll()
  101.                 self.cover(symbol,bar.close*1.01, self.posDict[symbol+'_SHORT'])
  103.     #----------------------------------------------------------------------
  104.     def on60MinBar(self, bar):
  105.         """收到60MinBar推送"""
  106.         symbol = bar.vtSymbol
  108.         am60 = self.getArrayManager(symbol, "60m")
  110.         if not am60.inited:
  111.             return
  113.         # 计算均线并判断趋势
  114.         fastMa = ta.MA(am60.close, self.fastPeriod)
  115.         slowMa = ta.MA(am60.close, self.slowPeriod)
  116.         #定义事件信号
  117.         if fastMa[-1] > slowMa[-1]:
  118.             self.maTrend[symbol] = 1
  119.         else:
  120.             self.maTrend[symbol] = -1
  122.     #----------------------------------------------------------------------
  123.     def on15MinBar(self, bar):
  124.         """收到15MinBar推送"""
  125.         symbol = bar.vtSymbol
  127.         am15 = self.getArrayManager(symbol, "15m")
  129.         if not am15.inited:
  130.             return
  132.         signalMa = ta.EMA(am15.close, self.signalMaPeriod)
  134.         maUp = signalMa[-1]>signalMa[-3] # 均线上涨
  135.         maDn = signalMa[-1]<signalMa[-3] # 均线下跌
  137.         # 均线上涨， 趋势为多头， 多头没有持仓
  138.         if maUp and (self.maTrend[symbol]==1) and (self.posDict[symbol+'_LONG']==0):
  139.             if  (self.posDict[symbol+'_SHORT']==0):
  140.                 self.buy(symbol, bar.close*1.01, self.lot)  # 成交价*1.01发送高价位的限价单，以最优市价买入进场
  141.             elif (self.posDict[symbol+'_SHORT'] > 0):
  142.                 self.cancelAll() # 撤销挂单
  143.                 self.cover(symbol, bar.close*1.01, self.posDict[symbol+'_SHORT']) 
  144.                 self.buy(symbol, bar.close*1.01, self.lot)
  146.         # 均线下跌， 趋势为空头， 空头没有持仓
  147.         if maDn and (self.maTrend[symbol]==-1) and (self.posDict[symbol+'_SHORT']==0):
  148.             if (self.posDict[symbol+'_LONG']==0):
  149.                 self.short(symbol, bar.close*0.99, self.lot) # 成交价*0.99发送低价位的限价单，以最优市价卖出进场
  150.             elif (self.posDict[symbol+'_LONG'] > 0):
  151.                 self.cancelAll() # 撤销挂单
  152.                 self.sell(symbol, bar.close*0.99, self.posDict[symbol+'_LONG'])
  153.                 self.short(symbol, bar.close*0.99, self.lot)
  154.         self.putEvent()
  156.     #----------------------------------------------------------------------
  157.     def onOrder(self, order):
  158.         """收到委托变化推送（必须由用户继承实现）"""
  159.         # 对于无需做细粒度委托控制的策略，可以忽略onOrder
  160.         pass
  162.     #----------------------------------------------------------------------
  163.     def onTrade(self, trade):
  164.         """收到成交推送（必须由用户继承实现）"""
  165.         symbol = trade.vtSymbol
  166.         if trade.offset == OFFSET_OPEN:  # 判断成交订单类型
  167.             self.transactionPrice[symbol] = trade.price # 记录成交价格
  168.             print(trade.tradeTime, self.posDict)
  169.     #----------------------------------------------------------------------
  170.     def onStopOrder(self, so):
  171.         """停止单推送"""
  172.         pass

配置引擎参数

  1. from vnpy.trader.app.ctaStrategy import BacktestingEngine
  2. import pandas as pd
  4. def runBacktesting(strategyClass, settingDict,
  5.                    startDate, endDate, slippage, rate):
  6.     engine = BacktestingEngine()
  7.     engine.setBacktestingMode(engine.BAR_MODE)  # 设置引擎的回测模式为K线
  8.     engine.setDatabase('VnTrader_1Min_Db')    # 设置使用的历史数据库
  9.     engine.setStartDate(startDate, initHours=200)   # 设置回测用的数据起始日期
  10.     engine.setEndDate(endDate)     # 设置回测用的数据结束日期
  11.     engine.setSlippage(slippage)    # 设置滑点
  12.     engine.setRate(rate)             # 设置手续费万0.3
  13.     engine.initStrategy(strategyClass, settingDict)
  14.     engine.setCapital(100000)     # 设置回测本金
  15.     engine.runBacktesting()
  16.     #显示逐日回测结果
  17.     engine.showDailyResult()
  18.     #显示逐笔回测结果
  19.     engine.showBacktestingResult()
  20.     # 计算回测结果
  21.     perfromance = engine.calculateDailyResult()
  22.     perfromanceDf , result = engine.calculateDailyStatistics(perfromance)
  23.     tradeReport = pd.DataFrame([obj.__dict__ for obj in engine.tradeDict.values()])
  24.     tradeDf = tradeReport.set_index('dt')
  25.     return perfromanceDf, tradeDf
  1. parameterDict = {'symbolList':['BTCUSDT:binance']}
  2. runBacktesting(MultiFrameMaStrategy, parameterDict, '20180901 12:00', '20181121 12:00', 0.002, 5/10000)
2018-11-27 17:29:37.762428  计算按日统计结果
2018-11-27 17:29:37.780410  ------------------------------
2018-11-27 17:29:37.780410  首个交易日：  2018-09-01 00:00:00
2018-11-27 17:29:37.780410  最后交易日：  2018-11-21 00:00:00
2018-11-27 17:29:37.780410  总交易日：   82
2018-11-27 17:29:37.780410  盈利交易日   43
2018-11-27 17:29:37.780410  亏损交易日：  38
2018-11-27 17:29:37.780410  起始资金：   100000
2018-11-27 17:29:37.780410  结束资金：   102,226.39
2018-11-27 17:29:37.780410  总收益率：   2.23%
2018-11-27 17:29:37.780410  年化收益：   6.52%
2018-11-27 17:29:37.780410  总盈亏：    2,226.39
2018-11-27 17:29:37.780410  最大回撤:   -408.37
2018-11-27 17:29:37.780410  百分比最大回撤: -0.41%
2018-11-27 17:29:37.780410  总手续费：   388.41
2018-11-27 17:29:37.780410  总滑点：    0.24
2018-11-27 17:29:37.780410  总成交金额：  776,821.7
2018-11-27 17:29:37.780410  总成交笔数：  121
2018-11-27 17:29:37.780410  日均盈亏：   27.15
2018-11-27 17:29:37.780410  日均手续费：  4.74
2018-11-27 17:29:37.780410  日均滑点：   0.0
2018-11-27 17:29:37.780410  日均成交金额： 9,473.44
2018-11-27 17:29:37.780410  日均成交笔数： 1.48
2018-11-27 17:29:37.780410  日均收益率：  0.03%
2018-11-27 17:29:37.780410  收益标准差：  0.14%
2018-11-27 17:29:37.780410  Sharpe Ratio：   2.84

output_5_1.png-55.1kB

2018-11-27 17:29:39.153005  计算回测结果
2018-11-27 17:29:39.157999  ------------------------------
2018-11-27 17:29:39.157999  第一笔交易：  2018-09-04 06:45:00
2018-11-27 17:29:39.157999  最后一笔交易： 2018-11-21 11:58:00
2018-11-27 17:29:39.157999  总交易次数：  61
2018-11-27 17:29:39.157999  总盈亏：    2,224.06
2018-11-27 17:29:39.157999  最大回撤:   -964.09
2018-11-27 17:29:39.157999  平均每笔盈利： 36.46
2018-11-27 17:29:39.157999  平均每笔滑点： 0.0
2018-11-27 17:29:39.157999  平均每笔佣金： 6.41
2018-11-27 17:29:39.157999  胜率      26.23%
2018-11-27 17:29:39.157999  盈利交易平均值 319.33
2018-11-27 17:29:39.157999  亏损交易平均值 -64.11
2018-11-27 17:29:39.157999  盈亏比：    4.98

output_5_3.png-40.5kB

添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注