交易中心与算法工人内部架构,交易中心主要负责接收客户端发送过来的指令,通过风控层后将指令路由至算法工人,由算法工人处理订单逻辑,如:条件单、追单、止损止盈单等,并最终将订单报入交易所场内,同时将回报返回给交易中心,再由交易中心将回报返回给订阅用户。
交易中心还负责路由用户发送的策略指令,并根据指令分发给策略回测工人或者策略仿真工人,对应的去执行回测指令或者启动策略等。
#测试所有代码
def all_test(codes,names,days,begin_count,end_count,earnings_count=30,writefile='codes.csv'):
count_earnings=0
count_suc=0
count_fail=0
earnings_count=(end_count-begin_count)*0.1
name_array=np.array([])
code_array=np.array([])
suc_array=np.array([])
fail_array=np.array([])
earnings_array=np.array([【更全面的开发源码搭建可看我昵称】])
count_hold_days=0
#for code in codes:
for i in range(len(codes)):
earnings,suc,fail,index_array,pct_array,hold_days=test(codes<i>,days=days,begin_count=begin_count,end_count=end_count,name=names<i>)
if suc==-1:
continue
count_earnings=count_earnings+earnings
count_suc=count_suc+suc
count_fail=count_fail+fail
count_hold_days=count_hold_days+hold_days
if earnings>earnings_count:
#print('test==',code,suc,fail,price)
name_array=np.append(name_array,names<i>)
code_array=np.append(code_array,codes<i>)
suc_array=np.append(suc_array,suc)
fail_array=np.append(fail_array,fail)
earnings_array=np.append(earnings_array,earnings)