l2数据计算优化

Administrator

2022-09-23 21d753614ea7bbe936b8560cbf466c4e438821b2

 trade_manager.py

@@ -1,13 +1,15 @@
# 交易管理器
import datetime
import json
import time

import gpcode_manager
import l2_code_operate
import mongo_data
import tool
from trade_data_manager import TradeBuyDataManager
from trade_gui import THSGuiTrade, async_call
import time as t
from l2_code_operate import *
import l2_data_manager

from log import *
@@ -263,7 +265,13 @@
            continue
        if code is not None and int(data["type"]) == 0:
            forbidden_trade(code)
            state = get_trade_state(code)
            if state != TRADE_STATE_BUY_SUCCESS:
            set_trade_state(code, TRADE_STATE_BUY_SUCCESS)
                # 删除买撤记录的临时信息
                l2_data_manager.TradePointManager.delete_compute_info_for_cancel_buy(code)
                l2_data_manager.TradePointManager.delete_buy_cancel_point(code)
                l2_data_manager.TradePointManager.delete_buy_point(code)


# 处理委托成功数据
@@ -293,20 +301,21 @@
def __clear_data(code):
    redis_l2 = redis_manager.RedisManager(1).getRedis()

    redis_l2.delete("buy_compute_index-{}".format(code))
    redis_l2.delete("buy_compute_num-{}".format(code))
    keys = redis_l2.keys("l2-{}-*".format(code))
    keys = redis_l2.keys("*{}*".format(code))
    for k in keys:
        redis_l2.delete(k)

    redis_l2.delete("l2-data-latest-{}".format(code))
    redis_l2.delete("l2-maxindex-{}".format(code))
    redis_l2.delete("latest-l2-count-{}".format(code))
    redis_trade = redis_manager.RedisManager(2).getRedis()
    redis_trade.delete("trade-state-{}".format(code))

    redis_info = redis_manager.RedisManager(0).getRedis()
    keys = redis_info.keys("*{}*".format(code))
    for k in keys:
        if k.find("pre") is None or k.find("pre") < 0:
            redis_info.delete(k)


if __name__ == "__main__":
    # time_str = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    # print(time_str)
    __clear_data("000503")
    __clear_data("000068")