Binance Fetch All Trades For All Traded Symbols

<?php

include './ccxt.php';

date_default_timezone_set('UTC');

$id = "\\ccxt\\binance";
$exchange = new $id(array(
   'apiKey' => 'YOUR_API_KEY',
   'secret' => 'YOUR_SECRET',
));

$exchange->load_markets();
$balance = $exchange->fetch_balance();

$total = $balance['total'];

$all_matching_symbols = array();

foreach ($total as $currency_code => $value) {

   echo "-------------------------------------------------------------------\n";
   echo "Currency code: ", $currency_code, " value: ", $value, "\n";

   if ($value > 0) {

       // get all related markets with
       //   either base currency === currency code from the balance structure
       //      or quote currency === currency code from the balance structure

       $matching_markets = array_filter(array_values($exchange->markets), function ($market) use ($currency_code) {
           return ($market['base'] === $currency_code) || ($market['quote'] === $currency_code);
       });

       $matching_symbols = $exchange->pluck($matching_markets, 'symbol');

       echo "Matching symbols:\n";
       print_r($matching_symbols);

       $all_matching_symbols = array_merge($all_matching_symbols, $matching_symbols);
   }
}

echo "========================================================================\n";
$unique_symbols = $exchange->unique($all_matching_symbols);
print_r($unique_symbols);

$all_trades_for_all_symbols = array();

// ----------------------------------------------------------------------------

function fetch_all_my_trades($exchange, $symbol) {

   $from_id = '0';
   $params = array('fromId' => $from_id);
   $previous_from_id = $from_id;

   $all_trades = array();

   while (true) {

       echo "------------------------------------------------------------------\n";
       echo "Fetching with params:\n";
       print_r($params);
       $trades = $exchange->fetch_my_trades($symbol, null, null, $params);
       echo "Fetched ", count($trades), ' ', $symbol, " trades\n";
       if (count($trades)) {
           $last_trade = $trades[count($trades) - 1];
           if ($last_trade['id'] == $previous_from_id) {
               break;
           } else {
               $params['fromId'] = $last_trade['id'];
               $previous_from_id = $last_trade['id'];
               $all_trades = array_merge ($all_trades, $trades);
           }
       } else {
           break;
       }
   }

   echo "Fetched ", count($all_trades), ' ', $symbol, " trades\n";
   for ($i = 0; $i < count($all_trades); $i++) {
       $trade = $all_trades[$i];
       echo $i, ' ', $trade['symbol'], ' ', $trade['id'], ' ', $trade['datetime'], ' ', $trade['amount'], "\n";
   }

   return $all_trades;
}

// ----------------------------------------------------------------------------

foreach ($unique_symbols as $symbol) {

   echo "=================================================================\n";
   echo "Fetching all ", $symbol, " trades\n";

   // fetch all trades for the $symbol, with pagination
   $trades = fetch_all_my_trades($exchange, $symbol);

   echo count($trades), ' ' , $symbol, " trades\n";

   $all_trades_for_all_symbols = array_merge($all_trades_for_all_symbols, $trades);

}

// do whatever you want with $all_trades_for_all_symbols

?>