大于200亿的流出不算作净流出

Administrator

2024-12-30 dad46b192e8fc3dcc657877b7189a8d0fe5f4aa7

大于200亿的流出不算作净流出

 l2_test.py

@@ -10,6 +10,7 @@
import psutil
import requests

from code_attribute import global_data_loader
from huaxin_client import l2_client_test, l1_subscript_codes_manager
from log_module.log import logger_local_huaxin_l2_transaction_big_order, logger_system
from third_data.custom_block_in_money_manager import CodeInMoneyManager, BlockInMoneyRankManager
@@ -148,6 +149,8 @@


if __name__ == "__main__":
    # 载入自由流通量
    global_data_loader.load_zyltgb_volume_from_db()
    threading.Thread(target=__compute_and_upload, daemon=True).start()
    # 启动内部接口服务
    threading.Thread(target=__run_server, args=("0.0.0.0", 9005,), daemon=True).start()

 third_data/custom_block_in_money_manager.py

@@ -10,7 +10,7 @@
from huaxin_client import l1_subscript_codes_manager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager
from third_data.third_blocks_manager import BlockMapManager
from utils import tool
from utils import tool, global_util


@tool.singleton
@@ -20,6 +20,7 @@
        self.__code_money_dict = {}
        # 净流入大单金额
        self.__code_big_buy_mmoney_list_dict = {}
        self.__latest_price = {}
        self.__load_data()

    def __load_data(self):
@@ -50,6 +51,7 @@
                self.__code_big_buy_mmoney_list_dict[code].append((item[2][2], item[2][4], item[2][0]))
        else:
            self.__code_money_dict[code] -= item[2][2]
        self.__latest_price[code] = item[2][4]

    def get_code_money_dict(self):
        return self.__code_money_dict
@@ -69,6 +71,9 @@
        @return:[(金额, 价格, 订单号)]
        """
        return self.__code_big_buy_mmoney_list_dict.get(code)

    def get_latest_price(self, code):
        return self.__latest_price.get(code)


@tool.singleton
@@ -172,6 +177,13 @@
            money = CodeInMoneyManager().get_money(code)
            if money is None:
                continue
            # 大自由流通市值的流出不算
            if money < 0:
                price = CodeInMoneyManager().get_latest_price(code)
                zylt_volume = global_util.zylt_volume_map.get(code)
                if price and zylt_volume and zylt_volume * price > 200e8:
                    continue

            before_fblocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(code)
            if not before_fblocks:
                before_fblocks = set()