异步日志修改

Administrator

2023-08-25 0dd67c24540b3e638a2da4832a973cf904d48dbd

 trade/trade_manager.py

@@ -482,7 +482,7 @@
    trade_data_manager.TradeBuyDataManager().set_buy_position_info(code, capture_timestamp, use_time, last_data,
                                                                   last_data_index)
    print("买入结束")
    logger_trade.info("{}买入成功".format(code))
    async_log_util.info(logger_trade, "{}买入成功".format(code))
    # kp_client_msg_manager.add_msg(code, "下单成功")


@@ -498,7 +498,7 @@

# 开始取消买入
def start_cancel_buy(code, force=False):
    logger_trade.info("{}进入撤单方法".format(code))
    async_log_util.info(logger_trade, "{}进入撤单方法".format(code))
    trade_state = __CodesTradeStateManager.get_trade_state_cache(code)
    if trade_state == TRADE_STATE_BUY_SUCCESS:
        return None
@@ -506,9 +506,9 @@
        if trade_state != TRADE_STATE_BUY_PLACE_ORDER and trade_state != TRADE_STATE_BUY_DELEGATED:
            return None
    try:
        logger_trade.info("{}开始撤单".format(code))
        async_log_util.info(logger_trade, "{}开始撤单".format(code))
        __CodesTradeStateManager.set_trade_state(code, TRADE_STATE_BUY_CANCEL_ING)
        logger_trade.info("{}撤单方法开始".format(code))
        async_log_util.info(logger_trade, "{}撤单方法开始".format(code))
        if constant.API_TRADE_ENABLE:
            if constant.TRADE_WAY == constant.TRADE_WAY_JUEJIN:
                trade_juejin.cancel_order(code)
@@ -516,7 +516,7 @@
                trade_huaxin.cancel_order(code)
        else:
            guiTrade.cancel_buy(code)
        logger_trade.info("{}撤单方法结束".format(code))
        async_log_util.info(logger_trade, "{}撤单方法结束".format(code))
        __cancel_success(code)
        # 不需要再次撤单了
        # try:
@@ -528,7 +528,7 @@
        CodesTradeStateManager().set_trade_state(code, trade_state)
        logger_trade.error("{}撤单异常：{}".format(code, str(e)))
        raise e
    logger_trade.info("{}撤单完毕".format(code))
    async_log_util.info(logger_trade, "{}撤单完毕".format(code))


# 再次撤单，防止没有撤掉
@@ -557,7 +557,7 @@
    # 下单成功，加入固定代码库
    if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_THS:
        l2_data_manager.remove_from_l2_fixed_codes(code)
    logger_trade.info("{}撤单成功".format(code))
    async_log_util.info(logger_trade, "{}撤单成功".format(code))
    kp_client_msg_manager.add_msg(code, "撤单成功")