主题：请各大神帮忙把这个策略改为金字塔代码

universe = ['RBM0', 'IM0', 'JM0']                          # 策略期货合约

start = '2013-11-01'                       # 回测开始时间

end  = '2016-11-18'                        # 回测结束时间

capital_base = 300000                     # 初试可用资金

refresh_rate = 1                          # 调仓周期

freq = 'd'                                 # 调仓频率：m-> 分钟；d-> 日

diff = []

def initialize(futures_account):           # 初始化虚拟期货账户，一般用于设置计数器，回测辅助变量等。

    futures_account.symbol0 = 'RB1405'

    futures_account.symbol1 = 'I1405'

    futures_account.symbol2 = 'J1405'

    pass

?

def handle_data(futures_account):          # 回测调仓逻辑，每个调仓周期运行一次，可在此函数内实现信号生产，生成调仓指令。

    long_position_0 = futures_account.position.get(futures_account.symbol0, dict()).get('long_position', 0)

    short_position_0 = futures_account.position.get(futures_account.symbol0, dict()).get('short_position', 0)

?

    long_position_1 = futures_account.position.get(futures_account.symbol1, dict()).get('long_position', 0)

    short_position_1 = futures_account.position.get(futures_account.symbol1, dict()).get('short_position', 0)

?

    long_position_2 = futures_account.position.get(futures_account.symbol2, dict()).get('long_position', 0)

    short_position_2 = futures_account.position.get(futures_account.symbol2, dict()).get('short_position', 0)

    if get_symbol(universe[0]) != futures_account.symbol0 or get_symbol(universe[1]) != futures_account.symbol1 or get_symbol(universe[2]) != futures_account.symbol2:

        if long_position_0 != 0:

            print futures_account.current_date, '主力更换， 平仓'

            order(futures_account.symbol0, -long_position_0, 'close')

            order(futures_account.symbol1, short_position_1, 'close')

            order(futures_account.symbol2, short_position_2, 'close')

?

        if short_position_0 != 0:

            print futures_account.current_date, '主力更换， 平仓'

            order(futures_account.symbol0, short_position_0, 'close')

            order(futures_account.symbol1, -long_position_1, 'close')

            order(futures_account.symbol2, -long_position_2, 'close')

        futures_account.symbol0 = get_symbol(universe[0])

        futures_account.symbol1 = get_symbol(universe[1])

        futures_account.symbol2 = get_symbol(universe[2])

        if close0 - 1.6 * close1 - 0.5 * close2 - 1100 < 100:

            if short_position_0 != 0:

                print futures_account.current_date, '平仓'

                print close0 - 1.6 * close1 - 0.5 * close2 - 1100

                order(futures_account.symbol0, short_position_0, 'close')

            if long_position_1 != 0:

                order(futures_account.symbol1, -long_position_1, 'close')

            if long_position_2 != 0:

                order(futures_account.symbol2, -long_position_2, 'close')

        if close0 - 1.6 * close1 - 0.5 * close2 - 1100 > 100:

            if long_position_0 != 0:

                print futures_account.current_date, '平仓'

                print close0 - 1.6 * close1 - 0.5 * close2 - 1100

                order(futures_account.symbol0, short_position_0, 'close')

            if short_position_1 != 0:

                order(futures_account.symbol1, -long_position_1, 'close')

            if short_position_2 != 0:

                order(futures_account.symbol2, -long_position_2, 'close')