Administrator
2023-08-02 818e5fec4c646ddc54bbb8337fe3a5fb1dac30ed
redis缓存加入内存缓存
1个文件已修改
24 ■■■■ 已修改文件
l2/l2_data_manager_new.py 24 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
l2/l2_data_manager_new.py
@@ -573,16 +573,7 @@
        if not is_first_code:
            can, need_clear_data, reason = cls.__can_buy(code)
        else:
            # can, need_clear_data, reason = cls.__can_buy_first(code)
            lp = LineProfiler()
            lp.enable()
            lp_wrap = lp(cls.__can_buy_first)
            can, need_clear_data, reason = lp_wrap(code)
            output = io.StringIO()
            lp.print_stats(stream=output)
            lp.disable()
            with open(f"/home/logs/profile/{code}_can_buy_first.txt", 'w') as f:
                f.write(output.getvalue())
            can, need_clear_data, reason = cls.__can_buy_first(code)
        __start_time = l2_data_log.l2_time(code, tool.get_now_timestamp() - __start_time, "最后判断是否能下单", force=True)
        # 删除虚拟下单
@@ -879,7 +870,18 @@
            score_index = cls.__l2PlaceOrderParamsManagerDict[code].score_index
            score = cls.__l2PlaceOrderParamsManagerDict[code].score
            score_info = cls.__l2PlaceOrderParamsManagerDict[code].score_info
            return cls.can_buy_first(code, limit_up_price, score_index, score, score_info, cls.volume_rate_info[code])
            lp = LineProfiler()
            lp.enable()
            lp_wrap = lp(cls.can_buy_first)
            results = lp_wrap(code, limit_up_price, score_index, score, score_info, cls.volume_rate_info[code])
            output = io.StringIO()
            lp.print_stats(stream=output)
            lp.disable()
            with open(f"{constant.get_path_prefix()}/logs/profile/{code}_can_buy_first.txt", 'w') as f:
                f.write(output.getvalue())
            # return cls.can_buy_first(code, limit_up_price, score_index, score, score_info, cls.volume_rate_info[code])
            return results
        else:
            return True, False, "在想买名单中"