import time
import os
import csv
import numpy as np
import pandas as pd
import talib as ta
# 初始化
def init(context):
context.s = 'DQJ01'
context.account = '097977'
def before_trading(context):
pass
def handle_bar(context):
# 获得当前账户持仓信息
portfolio = get_portfolio(context.s,2)
cur_buy_position = portfolio.buy_quantity #多头持仓
cur_sell_position = portfolio.sell_quantity #空头持仓
#处理多单
if cur_buy_position>0:
write_logging("多头持仓量:"+str(cur_buy_position))
# 如果有持仓,自动止损
cur_price = get_dynainf(context.s, 7)
stp_buy = portfolio.buy_avg_open_price-10
if cur_price > stp_buy:
sell_close(context.s, "Stop", stp_buy, cur_buy_position)
else:
write_logging("多头未持仓")
#处理空单
if cur_sell_position>0:
write_logging("空头持仓量:"+str(cur_sell_position))
#初次止损
cur_price = get_dynainf(context.s, 7)
stp_sell = portfolio.sell_avg_open_price+10
if cur_price < stp_sell:
buy_close(context.s,"Stop",stp_sell,cur_sell_position)
def after_trading(context):
pass