Administrator
2023-11-14 da3c8d719889ca9024c4a7835e5fa2e4b387a55c
处理时间日志
2个文件已修改
18 ■■■■■ 已修改文件
l2/l2_data_manager_new.py 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
utils/ths_industry_util.py 15 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
l2/l2_data_manager_new.py
@@ -597,9 +597,10 @@
                l2_log.debug(code, "执行买入成功")
                ################下单成功处理################
                trade_result_manager.real_buy_success(code, cls.__TradePointManager)
                l2_log.debug(code, "处理买入成功1")
                cancel_buy_strategy.set_real_place_position(code, local_today_datas.get(code)[-1]["index"],
                                                            order_begin_pos.buy_single_index)
                l2_log.debug(code, "处理买入成功")
                l2_log.debug(code, "处理买入成功2")
                params_desc = cls.__l2PlaceOrderParamsManagerDict[code].get_buy_rank_desc()
                l2_log.debug(code, params_desc)
                ############记录下单时的数据############
utils/ths_industry_util.py
@@ -17,13 +17,14 @@
    __industry_map = {}
    mysqldb = mysql_data.Mysqldb()
    results = mysqldb.select_all("select _id,second_industry from ths_industry_codes")
    for r in results:
        code = r[0]
        industry = r[1]
        __code_map[code] = industry
        if __industry_map.get(industry) is None:
            __industry_map[industry] = set()
        __industry_map[industry].add(code)
    if results:
        for r in results:
            code = r[0]
            industry = r[1]
            __code_map[code] = industry
            if __industry_map.get(industry) is None:
                __industry_map[industry] = set()
            __industry_map[industry].add(code)
    return __code_map, __industry_map