1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123
'''
ptrade西蒙斯逆回购
作者:西蒙斯量化
微信:xg_quant
时间:20250829
'''
importmath
importpandasaspd
definitialize(context):
# 初始化策略
#一天期的深圳逆回购标的
    g.stock='131810.SZ'
#保留的资金，避免新股，可转债等申购
g.cash=0
print('开始运行逆回购策略*********************')
run_daily(context,func=run_reverse_repurchase,time='14:55')
defrun_reverse_repurchase(context):
    '''
    逆回购函数
    '''
current_dt=context.blotter.current_dt
current_dt=current_dt.strftime('%Y-%m-%d')
account=get_xg_account(context)
ifaccount.shape[0]>0:
        cash=account['可用金额'].tolist()[-1]
print('可以金额****************',cash)
cash=cash-g.cash
#逆回购最低1000元10张一手
ifcash>=1000:
            amount=int(cash/1000)*10
ifamount>=10:
#全部逆回购卖出
                order(g.stock,-1*amount)
print(current_dt,'逆回购回购成功')
else:
                print(current_dt,'逆回购回购失败，低于最低数量')
else:
           print(current_dt,'逆回购回购失败，低于最低金额')
else:
        print(current_dt,'逆回购回购失败，没有金额')
defget_xg_account(context):
    '''
    获取账户数据
    '''
df=pd.DataFrame()
df['可用金额']=[context.portfolio.cash]
df['总资产']=[context.portfolio.portfolio_value]
df['持仓价值']=[context.portfolio.positions_value]
df['已使用现金']=[context.portfolio.capital_used]
df['当前收益比例']=[context.portfolio.returns]
df['初始账户总资产']=[context.portfolio.pnl]
df['开始时间']=[context.portfolio.start_date]
returndf
defget_xg_position(context):
    '''
    获取持股数据
    '''
data=pd.DataFrame()
positions=context.portfolio.positions
stock_list=list(set(positions.keys()))
print('持股数量{}'.format(len(stock_list)))
forstockinstock_list:
        df=pd.DataFrame()
df['证券代码']=[positions[stock].sid]
df['可用数量']=[positions[stock].enable_amount]
df['持有数量']=[positions[stock].amount]
df['最新价']=[positions[stock].last_sale_price]
df['成本价']=[positions[stock].cost_basis]
df['今日买入']=[positions[stock].today_amount]
df['持股类型']=[positions[stock].business_type]
data=pd.concat([data,df],ignore_index=True)
'''
    if data.shape[0]>0:
        if g.is_del=='是':
            print('开始策略隔离**********')
            data['隔离']=data['证券代码'].apply(lambda x: '是' if x in g.stock_list else '不是')
            data=data[data['隔离']=='是']
        else:
            print('不开启策略隔离*********')
    '''
returndata
defget_xg_order(context):
    '''
    获取委托数据
    '''
orders=get_orders()
print("委托数量{}".format(len(orders)))
data=pd.DataFrame()
iflen(orders)>0:
        fororsinorders:
            df=pd.DataFrame()
df['订单号']=[ors.id]
df['订单产生时间']=[ors.dt]
df['指定价格']=[ors.limit]
df['证券代码']=[ors.symbol]
df['委托数量']=[ors.amount]
df['订单生成时间']=[ors.created]
df['成交数量']=[ors.filled]
df['委托编号']=[ors.entrust_no]
df['盘口档位']=[ors.priceGear]
df['订单状态']=[ors.status]
data=pd.concat([data,df],ignore_index=True)

else:
        data=data
returndata
defget_xg_position_on(context,security=''):
    ''''
    获取单股的持股情况
    '''
pos=get_positions(security=security)
df=pd.DataFrame()
iflen(pos)>0:
        df['证券代码']=[pos[security].sid]
df['可以数量']=[pos[security].enable_amount]
df['持有数量']=[pos[security].amount]
df['最新价']=[pos[security].last_sale_price]
df['成本价']=[pos[security].cost_basis]
df['今日买入']=[pos[security].today_amount]
df['持股类型']=[pos[security].business_type]
else:
        df=df
returndf