Competitive Securities
最后更新于：2022-04-01 21:57:20
# Competitive Securities
> 来源：https://uqer.io/community/share/54b5c373f9f06c276f651a18
## 策略实现：
+ 计算三只同一行业股票过去4天内前3天的平均成交价（VWAP），这里选用的是中国平安 (601318.XSHG)、中国太保 (601601.XSHG)和中国人寿 (601628.XSHG)
+ 当某两只股票的价格低于`0.995 * VWAP`，同时另一只股票价格高于VWAP时，买入后者
+ 当某两只股票的价格高于`1.025 * VWAP`，同时另一只股票价格低于VWAP时，清空后者
```py
import pandas as pd
import numpy as np
from datetime import datetime
from matplotlib import pylab
import quartz
import quartz.backtest as qb
import quartz.performance as qp
from quartz.api import *
```
```py
"Competitive Securities"
start = pd.datetime(2012, 1, 1)
end = pd.datetime(2014, 12, 1)
bm = 'HS300'
universe = ['601601.XSHG', '601318.XSHG', '601628.XSHG']
csvs = []
capital_base = 5000
window = 4
threshold_dn = 0.995
threshold_up = 1.025
refresh_rate = 4
def initialize(account):
account.amount = 1000
account.universe = universe
add_history('hist', window)
def handle_data(account):
vwap3, price = {}, {}
for stk in account.universe:
if stk not in account.hist:
continue
vwap3[stk] = sum(account.hist[stk]['turnoverValue'][:3])/sum(account.hist[stk]['turnoverVol'][:3])
price[stk] = account.hist[stk].iloc[window-1,:]['closePrice']
if len(vwap3)!=3:
return
stk_0 = account.universe[0]
stk_1 = account.universe[1]
stk_2 = account.universe[2]
if price[stk_1] <= threshold_dn * vwap3[stk_1] and price[stk_2] <= threshold_dn * vwap3[stk_2] and price[stk_0] > vwap3[stk_0]:
order(stk_0, account.amount)
if price[stk_2] <= threshold_dn * vwap3[stk_2] and price[stk_0] <= threshold_dn * vwap3[stk_0] and price[stk_1] > vwap3[stk_1]:
order(stk_1, account.amount)
if price[stk_0] <= threshold_dn * vwap3[stk_0] and price[stk_1] <= threshold_dn * vwap3[stk_1] and price[stk_2] > vwap3[stk_2]:
order(stk_2, account.amount)
if price[stk_1] >= threshold_up * vwap3[stk_1] and price[stk_2] >= threshold_up * vwap3[stk_2] and price[stk_0] < vwap3[stk_0]:
order_to(stk_0, 0)
if price[stk_2] >= threshold_up * vwap3[stk_2] and price[stk_0] >= threshold_up * vwap3[stk_0] and price[stk_1] < vwap3[stk_1]:
order_to(stk_1, 0)
if price[stk_0] >= threshold_up * vwap3[stk_0] and price[stk_1] >= threshold_up * vwap3[stk_1] and price[stk_2] < vwap3[stk_2]:
order_to(stk_2, 0)
```
```py
perf = qp.perf_parse(bt)
out_keys = ['annualized_return', 'volatility', 'information',
'sharpe', 'max_drawdown', 'alpha', 'beta']
for k in out_keys:
print '%s: %s' % (k, perf[k])
annualized_return: 0.14708285
volatility: 0.285959506628
information: 0.525131029268
sharpe: 0.395275720443
max_drawdown: 0.391931712536
alpha: 0.089663482291
beta: 1.15117691695
```
```py
perf['cumulative_return'].plot()
perf['benchmark_cumulative_return'].plot()
pylab.legend(['current_strategy','HS300'])
```
';