可转债多因子策略

付息表是可转债持有期间债券固定收益测算的基础，在启动可转债策略回测前，需将付息信息处理成回测引擎要求的数据结构，并通过 stockDividend 参数输入回测引擎，完整付息表数据结构要求可参考：可转债付息表。

需要注意的是，该表登记日和可转债付息日均需预处理成交易日，并要求行情表中有对应的交易日行情，即付息表处理为：

• 对于付息日，如该日为法定节假日或休息日，则顺延至下一个交易日，对于登记日，取付息日的前一交易日。

• 根据行情交易日筛选付息表，要求登记日、付息日在行情交易日中。

该策略为基于因子选债的可转债日频策略，需要准备可转债日频行情和因子数据合并表，作为策略行情输入，通过 appendQuotationMsg 接口向回测引擎注入数据，完整行情数据结构可参考行情数据结构说明。本策略行情表结构如下：

通过 onBar 行情回调函数编写策略主逻辑，在行情到来时执行相应策略操作。同时，用户可根据实际需要运用不同回调函数开发策略逻辑，策略回调函数用法见策略回调函数说明 。本策略行情回调函数主要处理如下：

1. 首先，对前一天生成的仓位信号执行调仓，对卖单列表标的执行卖出，对买单列表标的补充到目标仓位。

2. 其次，基于当天的行情和因子信息，计算所有有效标的得分，写入因子得分字典。

3. 最后，根据得分字典，对于不在得分排名前 topPercent 的标的，记录为卖单，获取当前持仓，目标卖出仓位即为当前持仓，对于在得分排名前 topPercent 的标的，记录为买单，对入选标的等权分配资金，并根据当前持仓市值和目标持仓市值比较，确定补仓量。

def onBar(mutable context, msg, indicator){
    // t日，根据t-1日盘后记录的委托单下单撮合
    // 执行卖出
    if (size(context['sellList']) >0){
        for(isbond in context['sellList']){ // 遍历卖单列表
            sellVolume = exec Volume[0] from context['sellOrders'] where symbol = isbond // 从委托单信息获取卖单量
            price = exec price[0] from context['sellOrders'] where symbol = isbond 
            tradeTime = msg[isbond]["tradeTime"]  
            if(sellVolume> 0 && !isNull(price) && !isNull(tradeTime)) {  //执行卖出
                Backtest::submitOrder(context["engine"],(isbond, tradeTime, 5, price, sellVolume, 3), "sell")  
                // submitOrder接口用于下单，对于可转债，参数依次为（回测引擎，(证券代码，交易时间，订单类型，价格，数量，买卖方向)，买卖标签）
                // 订单类型：
                // 0：市价单中最优五档即时成交剩余撤销委托订单
                // 1：市价单中即时成交剩余撤销委托订单
                // 2：市价单中本方最优价格委托订单
                // 3: 市价单中对手方最优价格委托订单
                // 4：市价单中全额成交或撤销委托订单
                // 5：限价单
                // 买卖方向：1-买开，2-卖开，3-卖平，4-买平
            }  
        }  
    }
    
    // 执行买入
    if(size(context['buyList']) >0) {  
        for(isbond in context['buyList']){  // 遍历买单列表
            buyVolume = exec Volume[0] from context['buyOrders'] where symbol = isbond // 从委托单信息获取买单量
            price = exec price[0] from context['buyOrders'] where symbol = isbond 
            tradeTime = msg[isbond]["tradeTime"]  
            if(buyVolume >0 &&!isNull(price) && !isNull(tradeTime)) {// 执行买入
                Backtest::submitOrder(context["engine"], (isbond, tradeTime, 5, price, buyVolume, 1), "buy")  
            }      
        }  
    }

    // 初始化因子得分字典和有效债券列表
    factor_convPremium_Dict = dict(STRING, DOUBLE)  
    validBonds = array(STRING) 

    // 计算标的得分字典与validBonds
    keys = msg.keys()
    for(sym in keys){
        // 获取策略参数（即策略配置中的用户自定义参数）
        maxPosition = context["maxPosition"]
        w_close = context["close_weight"]
        w_cb_over_rate = context["cb_over_rate_weight"]
        w_price_premium_3m = context["price_premium_percentile_3m_weight"]
        w_iv = context["iv_weight"]
        w_mom20d = context["CB_Mom_20D_weight"]
        
        // 获取因子值（因子与行情连接得到，即行情中的字段）
        f_close = msg[sym]["close"]
        f_cb_over_rate = msg[sym]["cb_over_rate"]
        f_double_low_percentile_3m = msg[sym]["double_low_percentile_3m"]
        f_iv = msg[sym]["iv"]
        f_cb_Mom_20D = msg[sym]["cb_Mom_20D"]
        dt = msg[sym]["tradeTime"]

        // 过滤有效标的，计算得分并更新字典与 validBonds
        if(!isNull(f_close) && !isNull(f_cb_over_rate) && !isNull(f_double_low_percentile_3m) && !isNull(f_iv) && !isNull(f_cb_Mom_20D)){
            score = (w_close*f_close + w_cb_over_rate*f_cb_over_rate +
                w_price_premium_3m*f_double_low_percentile_3m +
                w_iv*f_iv + w_mom20d*f_cb_Mom_20D) * (-1)
            factor_convPremium_Dict[sym] = score
            validBonds.append!(sym)
        }
    }

    // t日，根据得分结果，生成委托单列表,用于t+1日交易
    // 初始化委托相关信息
    buyList = array(STRING)  
    sellList = array(STRING)
    buyOrders = table(1:0, `symbol`direction`tradeTime`price`Volume`score,[SYMBOL,INT,TIMESTAMP,DOUBLE,DOUBLE,DOUBLE])
    sellOrders = table(1:0, `symbol`direction`tradeTime`price`Volume`score,[SYMBOL,INT,TIMESTAMP,DOUBLE,DOUBLE,DOUBLE])

    // 计算阈值
    sortedFactors = sort(factor_convPremium_Dict.values(), false)
    topThreshold = sortedFactors[int(size(sortedFactors) * context["topPercent"])] 

    // 获取当前资金
    cash = Backtest::getAvailableCash(context.engine) 
    // 标记第二天下单时间
    tradeTime = temporalAdd(context['tradeTime'],1,'SZSE') 

    // 生成卖单委托
    for(isbond in validBonds){  
        price = msg[isbond]["close"] 
        factor = factor_convPremium_Dict[isbond]
        pos = Backtest::getPosition(context["engine"], isbond)  
        longPos = pos.longPosition[0] // 获取现有持仓量
        if(longPos > 0 and factor < topThreshold){  // 不在目标阈值的债券卖出
            sellList.append!(isbond)  
            sellOrders.tableInsert(isbond,2,tradeTime,price,longPos,factor)
            cash + = price*longPos // 更新可用资金
        } 
    } 

    // 生成买单池子
    for(isbond in validBonds){  
        factor = factor_convPremium_Dict[isbond]
        if(factor >= topThreshold) {  
            buyList.append!(isbond)  
        }  
    }

    // 根据当前资金情况，计算买单目标持仓
    k = size(buyList)
    if(k > 0){
        // 等权分配资金
        perCash = cash / k   
        maxValue = cash * context["maxPosition"]
        for(isbond in buyList){ 
            // 获取当前持仓量
            pos = Backtest::getPosition(context["engine"], isbond)  
            longPos = 0
            if(!isNull(pos.longPosition) && size(pos.longPosition) > 0){
                longPos = pos.longPosition[0]
            }
            // 计算目标持仓
            factor = factor_convPremium_Dict[isbond]
            price = msg[isbond]["close"] 
            currentValue = longPos * price  // 当前持仓市值
            if(currentValue < maxValue) {    
                addValue = min(maxValue-currentValue, perCash) *0.9
                buyVolume = int(addValue / price / 100) * 100 
                if(!isNull(price) && !isNull(tradeTime)) {
                    buyOrders.tableInsert(isbond,1,tradeTime,price,buyVolume,factor)
                }  
            }   
        }
    }
    // 记录t+1日买卖债券列表，委托信息
    context['buyList'] = buyList
    context['sellList'] = sellList
    context['buyOrders'] = buyOrders
    context['sellOrders'] = sellOrders
    context['allOrders'] = unionAll(buyOrders,sellOrders)   
}

1. context

   策略全局变量 context 为一个字典，用于设置策略的所有自定义变量，在所有回调函数均可调用。通过 context["字段名称"] 或 context.字段名称 调用。若要使用 JIT 优化，context 中用户定义的全局变量不支持表，其他所有 DolphinDB 的数据类型均支持。引擎内部维护了 4 个变量：

   • context.tradeTime 获取行情的最新时间

   • context.tradeDate 获取当前日期

   • context.BarTime 快照降频为低频行情时的当前 Bar 时间戳

   • context.engine 获取回测引擎实例

   其他 context 变量根据用户输入参数确定，可参见 2.2.3.2 用户自定义参数小节。

2. msg

   回测引擎的策略事件函数行情消息 msg 为字典，在 onBar 等策略行情回调函数调用。onBar 行情回调函数中的 msg 为嵌套字典，表示多条消息。第一层的字典的 key 是标的代码（sym），value 值为该标的的行情，例如可以通过 msg.sym.close 获取最新收盘价。该字典部分内容示例如下：

   123045.SZ->symbol->123045.SZ
   tradeTime->2021.03.01T00:00:00.000
   open->101.599999999999994
   low->101.469999999999998
   high->103.89
   close->103.310000000000002
   volume->22536
   upLimitPrice->121.680000000000006
   downLimitPrice->81.120000000000004
   cb_over_rate->12.289999999999999
   double_low_percentile_3m->-1.155022796336155
   iv->-0.131868259038364
   cb_Mom_20D->-0.33366397320168
   
   123046.SZ->symbol->123046.SZ
   tradeTime->2021.03.01T00:00:00.000
   open->136.879999999999995
   low->136.050000000000011
   high->143.5
   close->141.060000000000002
   volume->66437
   upLimitPrice->163.199999999999988
   downLimitPrice->108.800000000000011
   cb_over_rate->6.77
   double_low_percentile_3m->-0.250412235413919
   iv->0.714654335556472
   cb_Mom_20D->-0.976648195453703

3. indicator

   indicator 表示策略中订阅的指标字典，行情指标 indicator 的数据类型同相应行情的 msg 的数据类型一致。在 initialize 策略初始化函数中通过 subscribeIndicator 接口订阅行情指标后，可在 onBar 等策略行情回调函数调用。onBar 行情回调函数中的 indicator 为嵌套字典，表示多条消息。第一层的字典的 key 是标的代码（sym），value 值为该标的的行情，可以通过类似 indicator.sym.mavg 调用。本策略暂未用到 indicator 参数。

设置回测配置参数，例如开始与结束日期、初始资金、手续费等，详细回测参数配置要求可参考引擎配置说明文档。策略初始参数配置如下所示，可根据实际需要进行调整。

dividend=dict(STRING,ANY)
dividend["convertibleBonds"]=couponData
userConfig["stockDividend"]=dividend

除引擎配置参数外，用户还可通过 userConfig['context'] 接口配置自定义参数，本策略用户自定义参数如下表所示。

通过 Backtest::getTradeDetails(long(engine)) 获取每日交易明细表，输出字段详细说明见 getTradeDetails。下表为部分交易明细展示：

通过 Backtest::getDailyPosition(long(engine)) 接口获取账户每日持仓，输出字段详细说明见 getPosition。下表为部分持仓明细展示：

通过 Backtest::getDailyTotalPortfolios(long(engine)) 接口获取账户每日权益信息，输出字段详细说明见 getDailyTotalPortfolios。下表为部分每日权益展示：

通过 Backtest::getReturnSummary(long(engine)) 接口获取策略收益概述，输出字段详细说明见 getReturnSummary。下表为可转债五因子策略的收益概述：

除了上述回测引擎相关输出外，用户还可根据需要调用 Backtest::getContextDict(long(engine)) 接口输出自定义参数，例如本策略中的委托单信息，如下所示为委托买单信息：