bug修复

Administrator

2024-02-26 5b406e155a8759285e7627df4c8f6fdd9c9cca3a

bug修复

 code_attribute/code_volumn_manager.py

@@ -91,7 +91,7 @@
    today = get_today_volumn(code)
    max60, yesterday = get_histry_volumn(code)
    if today is None or max60 is None or yesterday is None:
        raise Exception("获取量失败")
        raise Exception(f"获取量失败:{code}")
    rate = round((int(today) + total_sell_volume) / max(int(max60[0]), int(yesterday)), 2)
    if not with_info:
        return rate

 l2/l2_transaction_data_processor.py

@@ -133,10 +133,9 @@
                        if real_order_index and real_order_index >= buy_progress_index:
                            # 发送下单消息
                            try:
                                buy_order_msg_manager.almost_deal(code, real_order_index, buy_progress_index,
                                                                  total_datas)
                                buy_order_msg_manager.almost_deal(code, real_order_index, buy_progress_index)
                                buy_order_msg_manager.follow_not_enough(code, order_begin_pos.buy_exec_index,
                                                                        real_order_index, total_datas)
                                                                        real_order_index)
                            except Exception as e:
                                logger_debug.exception(e)
            else:

 third_data/data_server.py

@@ -344,7 +344,7 @@
                # 获取L2的数据
                ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
                code = ps_dict['code']
                datas = data_export_util.get_l2_datas(code)
                datas = data_export_util.get_l2_datas(code, l2_data_util.local_today_datas.get(code))
                code_name = gpcode_manager.get_code_name(code)
                response_data = json.dumps({"code": 0, "data": {"code": code, "code_name": code_name, "data": datas}})
            except Exception as e:

 utils/data_export_util.py

@@ -24,9 +24,11 @@


# 获取L2的数据
def get_l2_datas(code, date=None):
    local_today_datas = log_export.load_l2_from_log(date)
    datas = local_today_datas.get(code)
def get_l2_datas(code, today_datas=None, date=None):
    datas = today_datas
    if datas is None:
        local_today_datas = log_export.load_l2_from_log(date)
        datas = local_today_datas.get(code)
    if not datas:
        datas = []
    process_indexs = log_export.get_l2_process_position(code, date)