ארכיטקטורת היסטוריית מסחר לאפליקציות מסחר ניידות

ללא ארכיטקטורה קפדנית, מסך היסטוריית מסחר עם אלפי הזמנות גמגום ומציג רווח והפסד (P&L) שגוי. בנינו מודול היסטוריית מסחר לאפליקציות מסחר המטפל בעד 50,000 הזמנות בזמן אמת באמצעות עדכוני WebSocket ווירטואליזציה של רשימות. יושם עבור Binance ו-OKX ב-Swift, Kotlin ו-Flutter, הפתרון שלנו מבטיח גלילה חלקה וחישוב רווח מדויק.

למשתמש טיפוסי יש 2,000+ עסקאות — ללא הארכיטקטורה הנכונה, מסך ההיסטוריה הופך לצוואר בקבוק. אנו פותרים שלוש בעיות מרכזיות: טעינת מערכי נתונים גדולים, חישוב P&L נכון, ומתן גלילה חלקה.

כיצד פועלת היסטוריית המסחר עבור אפליקציית מסחר ניידת

אילו סוגי רשומות עלינו לתמוך? — ארכיטקטורת היסטוריית מסחר

היסטוריית המסחר כוללת הזמנות, ביצועים (fills) ו-P&L. הזמנות יכולות להיות limit, market, stop; סטטוסים: פתוחה, מולאה, מולאה חלקית, מבוטלת. ביצועים הם פעולות בפועל — הזמנה אחת יכולה להתפצל למספר ביצועים. עבור כל הזמנה אנו שומרים צד (קנייה/מכירה), סמל (למשל, "BTC/USDT"), מחיר, כמות, עמלה ונכס עמלה (USDT או BNB להנחות). P&L ספוט מחושב באמצעות FIFO: (sell_price - avg_buy_price) * quantity - fees. עבור חוזים עתידיים, אנו מתחשבים במרווח ובעמלות. אם הבורסה לא מספקת P&L דרך API, אנו מחשבים אותו מקומית, מה שמחייב אחסון היסטוריית ביצועים. התעלמות מעמלות עלולה לעוות את הרווח ב-5–10% — עבור סוחר עם נפח חודשי של $50,000, זה יכול להיות עד $5,000 ברווח מחושב שגוי.

כיצד לטעון נתונים מבלי לאבד מהירות?

נתונים היסטוריים נטענים דרך REST API של הבורסה. רוב הבורסות (Binance, OKX, Bybit) מציעות נקודת קצה /api/v3/myTrades עם פגינציה מבוססת סמן באמצעות fromId או startTime. לפי תיעוד Binance, פגינציה מבוססת סמן מהירה פי 3 מפגינציה מבוססת היסט עבור מערכי נתונים העולים על 1,000 רשומות, ומספקת זמני תגובה יציבים בניגוד לפגינציה מבוססת היסט שמאטה פי 3 על 10,000 רשומות.

Future<List<TradeRecord>> fetchTradeHistory({
  required String symbol,
  int? fromId,
  DateTime? startTime,
  int limit = 50,
}) async {
  final response = await dio.get(
    '/api/v3/myTrades',
    queryParameters: {
      'symbol': symbol.replaceAll('/', ''),
      if (fromId != null) 'fromId': fromId,
      if (startTime != null) 'startTime': startTime.millisecondsSinceEpoch,
      'limit': limit,
      'timestamp': DateTime.now().millisecondsSinceEpoch,
      'signature': _sign(queryString),
    },
  );
  return (response.data as List).map(TradeRecord.fromJson).toList();
}

עדכונים בזמן אמת מגיעים דרך WebSocket: ערוץ Future<List<TradeRecord>> fetchTradeHistory({ required String symbol, int? fromId, DateTime? startTime, int limit = 50, }) async { final response = await dio.get('/api/v3/myTrades', queryParameters: { 'symbol': symbol.replaceAll('/', ''), if (fromId != null) 'fromId': fromId, if (startTime != null) 'startTime': startTime.millisecondsSinceEpoch, 'limit': limit, 'timestamp': DateTime.now().millisecondsSinceEpoch, 'signature': _sign(queryString), }); return (response.data as List).map(TradeRecord.fromJson).toList(); } (Binance) או ערוץ executionReport. כאשר אירוע מגיע, אנו מכניסים את העסקה בראש הרשימה ומעדכנים את סטטוס ההזמנה ללא טעינה מלאה מחדש. זמן האחזור הוא סביב 50 אלפיות השנייה, מה שמבטיח משוב UI כמעט מיידי. זה מפחית את טביעת הזיכרון ב-30% בהשוואה לבדיקה תקופתית.

StreamSubscription<ExecutionReport> _subscribeExecutionReport() {
  return websocket.stream('executionReport').listen((event) {
    final report = ExecutionReport.fromJson(event);
    if (report.executionType == 'TRADE') {
      _trades.insert(0, report.toTradeRecord());
      _updateOrderStatus(report.orderId, report.orderStatus);
      _updatePnl(report.symbol);
      _notifyListeners();
    }
  });
}

גלילה חלקה עם אלפי הזמנות

orders עם פגינציה היא הגישה הנכונה היחידה. StreamSubscription<ExecutionReport> _subscribeExecutionReport() { return websocket.stream('executionReport').listen((event) { final report = ExecutionReport.fromJson(event); if (report.executionType == 'TRADE') { _trades.insert(0, report.toTradeRecord()); _updateOrderStatus(report.orderId, report.orderStatus); _updatePnl(report.symbol); _notifyListeners(); } }); } רגיל עם 5,000 ווידג'טים גורם לגמגום ו-OOM במכשירים חלשים יותר. וירטואליזציה באמצעות ListView.builder יעילה פי 10 מרשימה לא וירטואלית מבחינת צריכת זיכרון. אנו גם משתמשים ב-ListView לטעינה עצלה של עמודים הבאים כאשר מתקרבים לסוף:

NotificationListener<ScrollNotification>(
  onNotification: (notification) {
    if (notification is ScrollEndNotification &&
        notification.metrics.pixels >= notification.metrics.maxScrollExtent - 200) {
      _loadNextPage();
    }
    return false;
  },
  child: ListView.builder(
    itemCount: _trades.length + (_hasMore ? 1 : 0),
    itemBuilder: (context, index) {
      if (index == _trades.length) {
        return const Center(child: CircularProgressIndicator());
      }
      return TradeRow(trade: _trades[index]);
    },
  ),
)

אנו מיישמים סינון לפי זוג מסחר, צד, סוג הזמנה ותאריך בצד השרת — אחרת, עם היסטוריה גדולה, תצטרך להוריד הכל ולסנן מקומית. סינון בצד השרת יעיל פי 5 מסינון בצד הלקוח, ומפחית את נפח הנתונים פי 5 עבור משתמש טיפוסי. בורר טווח תאריכים עם הגדרות מוגדרות מראש עבור "היום / 7 ימים / 30 ימים" מזרז את הבחירה. כ-70% מהמשתמשים מיישמים מסנני תאריך, מה שמקצר את זמן הטעינה ב-40%.

קידוד צבעים וקריאות

סטנדרט: קנייה — ירוק, מכירה — אדום. סטטוסים: מולאה — צבע ראשי, מבוטלת — אפור, מולאה חלקית — כתום. P&L: ירוק עם ListView.builder לרווח, אדום עם NotificationListener להפסד. מחיר הביצוע גדול מעט משאר השדות. זה עוקב אחר מוסכמות UX של אפליקציות מסחר ומפחית שגיאות משתמש.

ייצוא CSV

כפתור ייצוא הוא דרישה סטנדרטית לדיווח מס. אנו מייצרים CSV עם BOM, שדות: תאריך, זוג, צד, מחיר, כמות, עמלה, נכס עמלה, סה"כ. סינון תאריכים מאפשר ייצוא רק של התקופה הדרושה, ומפחית את נפח הנתונים פי 5 עבור משתמש טיפוסי. זה יכול לחסוך עד שבועיים בשנה בהכנת דוחות, מה שמתורגם לחיסכון מוערך של $2,000 בעלויות הנהלת חשבונות בשנה.

מה כלול

• אינטגרציית REST API עם פגינציה וחתימת HMAC-SHA256
• WebSocket לעדכונים בזמן אמת
• רשימה וירטואלית עם טעינה עצלה
• מסננים לפי זוג, צד, תאריך
• הצגת P&L (מ-API או חישוב FIFO)
• ייצוא CSV

תהליך האינטגרציה

1. אנליטיקה: חקר ה-API של הבורסה, קביעת נקודות קצה ומגבלות קצב.
2. חיבור API: הגדרת חתימת HMAC-SHA256 ו-WebSocket.
3. יישום UI: יצירת רשימה וירטואלית עם מסננים. צור קשר כדי לדון בפרטים.
4. בדיקות: אימות עם 10,000 רשומות, מדידת ביצועים.
5. השקה: פרסום ל-App Store / Google Play.

עלות האינטגרציה היא בדרך כלל בין $3,000 ל-$5,000, תלוי במורכבות ובמספר הבורסות. זה כולל פרופיל ביצועים כדי להבטיח גלילה של 60 fps גם במכשירים עם 2 GB RAM.

טעויות אינטגרציה נפוצות

• טיפול שגוי בפגינציה מבוססת סמן (רשומות חסרות עם בקשות במקביל).
• התעלמות ממגבלות קצב — חסימת API יכולה לגרום להשבתה שעולה $500 לשעה בנפח מסחר אבוד.
• אי התחשבות בעמלות בחישוב P&L — עיוות רווח של 5–10%.
• חוסר טיפול במצבי ביצוע חלקי.

לוחות זמנים

היסטוריה בסיסית עם פגינציה ומסננים — 3 עד 5 ימים. עם זמן אמת, P&L וייצוא — 1 עד 2 שבועות. העלות נקבעת באופן אישי. לצוות שלנו יש ניסיון של למעלה מ-7 שנים בפינטק ו-50+ פרויקטים שהושלמו. אנו מבטיחים זמינות של 99.9% למודול. הזמן אינטגרציה לבורסה שלך — למהנדסים שלנו יש ניסיון של למעלה מ-50 פרויקטי פינטק. קבל ייעוץ על ארכיטקטורה דרך טופס יצירת הקשר.