From 10e175f0b00ba76fc84e1478489bdce78f1a40ec Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 22 五月 2025 14:12:28 +0800
Subject: [PATCH] 下单sinfo修改/加想的票累计大单成交足够后加红
---
l2_data_parser.py | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/l2_data_parser.py b/l2_data_parser.py
index 2a54e59..abdbe66 100644
--- a/l2_data_parser.py
+++ b/l2_data_parser.py
@@ -5,6 +5,7 @@
import os
import sys
import time
+import pandas as pd
from db import mysql_data_delegate as mysql_data
from huaxin_client.l2_client_test import L2TransactionDataManager
@@ -47,6 +48,16 @@
target_codes = __get_target_codes(day)
base_path = f"/home/userzjj/ftp/{day}"
fdatas = []
+ df = pd.read_csv(f"{base_path}/Transaction.csv")
+ category_revenue = df.groupby('BuyNo')['TradeVolume'].sum()
+ total_count = 0
+ for chunk in chunks:
+ total_count += len(chunk)
+ for chunk in chunks:
+ total_count += len(chunk)
+
+
+
with open(f"{base_path}/Transaction.csv", 'r', encoding='utf-8') as file:
csv_reader = csv.reader(file)
total_lines = csv_reader.line_num
--
Gitblit v1.8.0