初始化延时

Administrator

2023-10-27 23ba2f4bb794be805381d34f2d12dc641ef1a63c

初始化延时

 code_attribute/code_nature_analyse.py

@@ -5,6 +5,8 @@
# 是否有涨停
import copy
import json
import random
import time

from code_attribute import gpcode_manager

@@ -79,6 +81,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(LatestMaxVolumeManager, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance


 code_attribute/gpcode_manager.py

@@ -2,6 +2,7 @@
股票代码管理器
"""
import json
import random
import time

import constant
@@ -355,6 +356,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(FirstGPCodesManager, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance


 l2/cancel_buy_strategy.py

@@ -7,6 +7,7 @@
# 计算范围到申报时间的那一秒
import json
import logging
import random
import time

import constant
@@ -48,6 +49,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(SecondCancelBigNumComputer, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance

@@ -390,6 +392,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(HourCancelBigNumComputer, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance

@@ -677,6 +680,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(DCancelBigNumComputer, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance

@@ -843,6 +847,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(LCancelBigNumComputer, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance

@@ -1318,6 +1323,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(FastCancelBigNumComputer, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance

@@ -1999,6 +2005,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(LatestCancelIndexManager, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance


 l2/code_price_manager.py

@@ -2,6 +2,8 @@
代码价格管理
"""
import json
import random
import time

from code_attribute import gpcode_manager
from db.redis_manager_delegate import RedisUtils
@@ -25,6 +27,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(Buy1PriceManager, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance


 l2/l2_data_manager_new.py

@@ -1,4 +1,5 @@
import logging
import random
import time as t

from code_attribute import big_money_num_manager, code_volumn_manager, code_data_util, industry_codes_sort, \
@@ -64,6 +65,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(L2BigNumForMProcessor, cls).__new__(cls, *args, **kwargs)
            t.sleep(random.randint(0,2000)/1000)
            cls.__load_datas()
        return cls.__instance

@@ -215,7 +217,6 @@
    __SecondCancelBigNumComputer = SecondCancelBigNumComputer()
    __HourCancelBigNumComputer = HourCancelBigNumComputer()
    __LCancelBigNumComputer = LCancelBigNumComputer()
    __DCancelBigNumComputer = DCancelBigNumComputer()
    __TradeStateManager = trade_manager.TradeStateManager()
    __CodesTradeStateManager = trade_manager.CodesTradeStateManager()
    __PauseBuyCodesManager = gpcode_manager.PauseBuyCodesManager()

 l2/l2_sell_manager.py

@@ -2,6 +2,8 @@
L2卖管理
"""
import json
import random
import time

from db import redis_manager
from db.redis_manager import RedisUtils
@@ -22,6 +24,7 @@
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(L2MarketSellManager, cls).__new__(cls, *args, **kwargs)
            time.sleep(random.randint(0, 2000) / 1000)
            cls.__load_datas()
        return cls.__instance


 trade/huaxin/huaxin_trade_server.py

@@ -704,7 +704,6 @@
            logger_debug.error(e)

    def OnSystemLog(self, client_id, request_id, data):
        logger_debug.debug(f"OnSystemLog")
        try:
            start_index = data["start_index"]
            count = data["count"]