- 选股时机
- 选股范围
- 持仓数量
- 风险控制
1. 获取中小板指数成分股 2. 过滤掉新股、ST股和北交所/科创板股票 3. 过滤停牌、涨停、跌停的股票 4. 按市值升序排列,选取前100只 5. 从中最终确定持有前7只小市值股票
def get_stock_list(context):
final_list = []
MKT_index = '399101.XSHE' # 中小板指数
initial_list = get_index_stocks(MKT_index)
initial_list = filter_new_stock(context, initial_list)
initial_list = filter_kcbj_stock(initial_list)
initial_list = filter_st_stock(initial_list)
initial_list = filter_paused_stock(initial_list)
initial_list = filter_limitup_stock(context, initial_list)
initial_list = filter_limitdown_stock(context, initial_list)
q = query(valuation.code, indicator.eps).filter(valuation.code.in_(initial_list)).order_by(valuation.market_cap.asc())
df = get_fundamentals(q)
stock_list = list(df.code)
stock_list = stock_list[:100]
final_list = stock_list[:2 * g.stock_num]
return final_listdef dapan(context):
print('大盘')
print(g.dbl)
if doDecide('399101.XSHE', context)['dead']:
g.dbl.append(True)
print('大盘顶背离,清仓')
for stock in context.portfolio.positions.keys():
order_target_value_(stock, 0)
else:
g.dbl.append(False)suit['dead'] = grid.close[key2] < grid.close[key1] and \
grid.dif[key2] > grid.dif[key1] > 0 and \
grid.macd[-2] > 0 > grid.macd[-1]g.stoploss_strategy = 3 # 1为止损线止损,2为市场趋势止损, 3为联合1、2策略 g.stoploss_limit = 0.88 # 止损线,亏损超过12%止损 g.stoploss_market = 0.94 # 市场趋势止损参数,中小板指当日平均跌幅超过6%时清仓
# 获取中小板指数当日收盘价和开盘价,计算整体市场走势
stock_df = get_price(security=get_index_stocks('399101.XSHE'), end_date=context.previous_date, frequency='daily', fields=['close', 'open'], count=1, panel=False)
down_ratio = (stock_df['close'] / stock_df['open']).mean()
# 如果市场整体大跌,全部清仓
if down_ratio <= g.stoploss_market:
g.reason_to_sell = 'stoploss'
log.debug("大盘惨跌,平均降幅{:.2%}".format(down_ratio))
for stock in context.portfolio.positions.keys():
order_target_value_(stock, 0)
else:
# 如果市场正常,检查个股止损
for stock in context.portfolio.positions.keys():
if context.portfolio.positions[stock].price < context.portfolio.positions[stock].avg_cost * g.stoploss_limit:
order_target_value_(stock, 0)
log.debug("收益止损,卖出{}".format(stock))
g.reason_to_sell = 'stoploss'def today_is_between(context):
today = context.current_dt.strftime('%m-%d')
if g.pass_april is True:
if (('04-01' <= today) and (today <= '04-30')) or (('01-01' <= today) and (today <= '01-30')):
return True
else:
return False
else:
return Falsedef check_limit_up(context):
now_time = context.current_dt
if g.yesterday_HL_list != []:
for stock in g.yesterday_HL_list:
current_data = get_price(stock, end_date=now_time, frequency='1m', fields=['close', 'high_limit'], skip_paused=False, fq='pre', count=1, panel=False, fill_paused=True)
if current_data.iloc[0, 0] < current_data.iloc[0, 1]:
log.info("[%s]涨停打开,卖出" % (stock))
position = context.portfolio.positions[stock]
close_position(position)
g.reason_to_sell = 'limitup'
else:
log.info("[%s]涨停,继续持有" % (stock))def doDecide(stock, context):
# MACD计算与顶背离判断
grid['dif'], grid['dea'], grid['macd'] = MACD(grid.close, SHORT=12, LONG=26, M=9)
# 顶背离判断逻辑
mask = grid['macd'] < 0
mask = mask[mask == True][mask.shift(1) == False]
key2 = mask.keys()[-2]
key1 = mask.keys()[-1]
suit['dead'] = grid.close[key2] < grid.close[key1] and \
grid.dif[key2] > grid.dif[key1] > 0 and \
grid.macd[-2] > 0 > grid.macd[-1]down_ratio = (stock_df['close'] / stock_df['open']).mean()
if down_ratio <= g.stoploss_market: # g.stoploss_market = 0.94,即跌幅超过6%
g.reason_to_sell = 'stoploss'
log.debug("大盘惨跌,平均降幅{:.2%}".format(down_ratio))
for stock in context.portfolio.positions.keys():
order_target_value_(stock, 0)if context.portfolio.positions[stock].price < context.portfolio.positions[stock].avg_cost * g.stoploss_limit:
order_target_value_(stock, 0)
log.debug("收益止损,卖出{}".format(stock))
g.reason_to_sell = 'stoploss'if (('04-01' <= today) and (today <= '04-30')) or (('01-01' <= today) and (today <= '01-30')):
return True # 返回True表示今天需要空仓
g.stock_num = 7 # 持仓数量 g.stoploss_limit = 0.88 # 止损线 g.stoploss_market = 0.94 # 市场趋势止损参数 g.HV_control = False # 是否启用放量判断
def print_position_info(context):
for position in list(context.portfolio.positions.values()):
securities = position.security
cost = position.avg_cost
price = position.price
ret = 100 * (price / cost - 1)
value = position.value
amount = position.total_amount
print('代码:{}'.format(securities))
print('成本价:{}'.format(format(cost, '.2f')))
print('现价:{}'.format(price))
print('收益率:{}%'.format(format(ret, '.2f')))
print('持仓(股):{}'.format(amount))
print('市值:{}'.format(format(value, '.2f')))
print('———————————————————————————————————')
run_dailyrun_weekly
# 设置交易运行时间 run_daily(prepare_stock_list, '9:05') run_daily(dapan, '9:30') run_weekly(weekly_adjustment, 2, '10:30') # 每周二10:30调仓 run_daily(sell_stocks, time='10:00') # 止损函数 run_daily(trade_afternoon, time='14:30') # 检查持仓中的涨停股是否需要卖出 run_daily(close_account, '14:50') run_weekly(print_position_info, 5, time='15:10')
https://www.9db.com/detail/7E3D251B-768C-4204-BD08-5E27AA0A45A0
