默认交易模式变更/真实下单位置计算位置修改

Administrator

5 小时以前 2f2516749615da866e96d8d24e499b7ecbb63a3e

 output/code_info_output.py

@@ -15,6 +15,8 @@
from l2.l2_data_manager import OrderBeginPosInfo
from l2.l2_data_util import L2DataUtil
from third_data.code_plate_key_manager import KPLCodeJXBlockManager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager
from trade.buy_radical.block_special_codes_manager import BlockSpecialCodesManager
from utils import global_util, tool
from log_module import log, log_export
from l2 import l2_data_manager, l2_data_util, transaction_progress, l2_data_manager_new, code_price_manager
@@ -79,7 +81,6 @@
        code_extra_infos.append("暂不买")
    params["code"] = code
    params["code_name"] = f"{gpcode_manager.get_code_name(code)} {code}  （{','.join(code_extra_infos)}）"

    total_datas = l2_data_util.local_today_datas.get(code)
    if total_datas is None:
        total_datas = []
@@ -114,7 +115,8 @@

        # 获取量参考日期
        try:
            volume_refer_date, volume_refer_date_distance = code_volumn_manager.CodeVolumeManager().get_volume_refer_date(code)
            volume_refer_date, volume_refer_date_distance = code_volumn_manager.CodeVolumeManager().get_volume_refer_date(
                code)
            params["trade_data"]["volume_refer_date"] = volume_refer_date
        except:
            pass
@@ -300,6 +302,13 @@
    if code_records:
        code_records = [(format_plate_output(k[0]), k[1], [format_plate_output(k1) for k1 in k[2].split("、")]) for k in
                        code_records]
    # 修改历史
    # code_records = LimitUpCodesBlockRecordManager().get_radical_buy_blocks_origin_data(code)
    # if code_records:
    #     code_records = [(f"{x[0]}x{x[1]}", x[2], '') for x in code_records]
    # else:
    #     code_records = []

    params["kpl_code_info"]["code_records"] = code_records

    if not KPLLimitUpDataRecordManager.total_datas:
@@ -485,6 +494,8 @@
                elif type == trade_record_log_util.TYPE_CANCEL:
                    load_cancel_watch_index(latest_cancel_watch_index_dict)
                    records_new_data.append((time_, "撤单", f"原因：{data['msg']}", []))
                elif type == trade_record_log_util.TYPE_ACTION:
                    records_new_data.append((time_, data['type'], f"{data['msg']}", []))
            load_cancel_watch_index(latest_cancel_watch_index_dict)
            records_new_data.sort(key=lambda x: x[0])
            if records_new_data:
@@ -495,10 +506,6 @@
    records_new.reverse()
    records_new_data.reverse()
    return break_time, records_new, records_new_data






# 返回内容[（类型,buy_single_index,indexes）]