‘功能完善

Administrator

5 天以前 09f84c4ecae2a71e07f6dd64e6066563599a62b6

 strategy/low_suction_strategy.py

@@ -5,6 +5,7 @@
import os

import constant
from db.mysql_data_delegate import Mysqldb
from strategy import strategy_variable


@@ -170,7 +171,7 @@
            return eval(line)
        return None

    def export_big_order_deal(self):
    def export_big_order_deal(self, min_money=299e4):
        """
        大单成交
        @return: {"代码":[(买单号, 量, 金额, 时间, 最终成交价)]}
@@ -184,12 +185,33 @@
                data = eval(line)
                if data[1] != 0:
                    continue
                if data[2][2] < min_money:
                    continue
                if data[0] not in fdatas:
                    fdatas[data[0]] = []
                fdatas[data[0]].append(data[2])
        return fdatas

    def export_big_sell_order_deal(self):
    def export_all_big_order_deal(self, min_money=299e4):
        """
        所有大单成交，包含买，卖
        @return: {"代码":[代码,卖/买, (买单号, 量, 金额, 时间, 最终成交价)]}
        """

        fdatas = {}
        lines = self.__export_logs(f"logs/huaxin_local/l2/transaction_accurate_big_order.{self.day}.log")
        if lines:
            for line in lines:
                line = line[line.find(" - ") + 3:].strip()
                data = eval(line)
                if data[2][2] < min_money:
                    continue
                if data[0] not in fdatas:
                    fdatas[data[0]] = []
                fdatas[data[0]].append(data)
        return fdatas

    def export_big_sell_order_deal(self, min_money=299e4):
        """
        大单成交
        @return: {"代码":[(买单号, 量, 金额, 时间, 最终成交价)]}
@@ -201,12 +223,14 @@
            data = eval(line)
            if data[1] != 1:
                continue
            if data[2][2] < min_money:
                continue
            if data[0] not in fdatas:
                fdatas[data[0]] = []
            fdatas[data[0]].append(data[2])
        return fdatas

    def export_big_order_deal_by(self):
    def export_big_order_deal_by(self, min_money=299e4):
        """
        大单成交
        @return: {"代码":[(买单号, 量, 金额, 时间, 最终成交价)]}
@@ -220,7 +244,7 @@
                data = eval(line)
                if data[1] != 0:
                    continue
                if data[2][2] < 299e4:
                if data[2][2] < min_money:
                    continue
                if data[2][0] in buy_order_nos:
                    continue
@@ -229,7 +253,7 @@
                fdatas[data[0]].append(data[2])
        return fdatas

    def export_big_sell_order_deal_by(self):
    def export_big_sell_order_deal_by(self, min_money=299e4):
        """
        大单成交
        @return: {"代码":[(买单号, 量, 金额, 时间, 最终成交价)]}
@@ -242,7 +266,7 @@
            data = eval(line)
            if data[1] != 1:
                continue
            if data[2][2] < 299e4:
            if data[2][2] < min_money:
                continue
            if data[2][0] in buy_order_nos:
                continue
@@ -262,6 +286,15 @@
                line = line[line.find(" - ") + 3:].strip()
                data = eval(line)
        return data

    def export_current_limit_up_records(self):
        """
        导出当日历史涨停
        @return: [(代码, 代码名称, 涨停原因, 涨停时间, 高度信息, 自由流通市值，是否炸板)]
        """
        results = Mysqldb().select_all(
            f"select r.`_code`, r.`_code_name`, r.`_hot_block_name`, r.`_limit_up_time`, r.`_limit_up_high_info`, r.`_zylt_val`, r.`_open`  from kpl_limit_up_record r where r._day = '{self.day}'")
        return results


class LowSuctionDataManager:
@@ -341,8 +374,9 @@


if __name__ == "__main__":
    fdatas = LowSuctionOriginDataExportManager("2025-04-30").export_code_plates()
    print(fdatas)
    fdatas = LowSuctionOriginDataExportManager("2025-06-09").export_big_order_deal_by()
    fdatas = fdatas.get("000795")
    print(sum([x[2] for x in fdatas]))
    result = eval("1>2")
    print(type(result))
    print(eval(strategy_variable.大单表达式))