From 521058f11b090d704268c9b7d09ea38e99aecc75 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 09 四月 2024 23:46:26 +0800
Subject: [PATCH] 当前总卖额统计卖1信息

---
 test/test_sell.py |   46 +++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 41 insertions(+), 5 deletions(-)

diff --git a/test/test_sell.py b/test/test_sell.py
index 076322f..f449f6d 100644
--- a/test/test_sell.py
+++ b/test/test_sell.py
@@ -1,16 +1,50 @@
+from l2.huaxin import l2_huaxin_util
 from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager
 from l2 import l2_data_util
 from log_module import log_export, async_log_util
 from utils import tool
 
 
+def statistic_buy_order():
+    code = "600768"
+    data_map = log_export.load_huaxin_transaction_map(date=tool.get_now_date_str())
+    datas = data_map.get(code)
+    __latest_buy_order_dict = {}
+    total_money = 0
+    for data in datas:
+        for d in data:
+            if code not in __latest_buy_order_dict:
+                # 鏍煎紡锛歔涔板崟鍙�,鎵嬫暟,鍗曚环]
+                __latest_buy_order_dict[code] = [d[6], d[2], d[1], (d[3], d[1]), (d[3], d[1])]
+            else:
+                if __latest_buy_order_dict[code][0] == d[6]:
+                    __latest_buy_order_dict[code][1] += d[2]
+                    __latest_buy_order_dict[code][2] = d[1]
+                    __latest_buy_order_dict[code][4] = (d[3], d[1])
+                else:
+                    info = __latest_buy_order_dict[code]
+
+                    # 涓婁釜鍗栧崟鎴愪氦瀹屾垚
+                    # 灏佸瓨鏁版嵁锛岃绠楁柊璧风偣
+                    # 澶т簬50w鐨勫崠鍗曟墠浼氫繚瀛�
+                    # 澶т簬50w鍔犲叆鍗栧崟
+                    money = info[1] * info[2]
+                    # if 101328000 > info[3] > 101324000:
+                    if tool.trade_time_sub(l2_huaxin_util.convert_time(info[3][0]), "10:08:30") >= 0 and info[2] >= 11.54:
+                        total_money += money
+                        print(int(total_money), round(money / 10000, 1), info)
+                    if money >= 500000:
+                        pass
+                    __latest_buy_order_dict[code] = [d[6], d[2], d[1], (d[3], d[1]), (d[3], d[1])]
+
+
 # 鍗栧崟缁熻
 def statistic_sell_order():
-    code = "000888"
+    code = "600768"
     data_map = log_export.load_huaxin_transaction_map(date=tool.get_now_date_str())
     datas = data_map.get(code)
     __latest_sell_order_dict = {}
-
+    total_money = 0
     for data in datas:
         for d in data:
             if code not in __latest_sell_order_dict:
@@ -28,8 +62,10 @@
                     # 澶т簬50w鐨勫崠鍗曟墠浼氫繚瀛�
                     # 澶т簬50w鍔犲叆鍗栧崟
                     money = info[1] * info[2]
-                    if 101328000 > info[3][0] > 101324000 and info[0] > 12265084:
-                        print(money, info)
+                    if tool.trade_time_sub(l2_huaxin_util.convert_time(info[3][0]), "10:08:30") >= 0:
+                        if info[2] >= 11.54:
+                            total_money += money
+                            print(money, round(total_money), info)
                     if money >= 500000:
                         pass
                     __latest_sell_order_dict[code] = [d[7], d[2], d[1], (d[3], d[6]), (d[3], d[6])]
@@ -65,4 +101,4 @@
 
 
 if __name__ == '__main__':
-    statistic_sell_order()
+    statistic_buy_order()

--
Gitblit v1.8.0