fetch_price_backup.php

<?php
require_once './include/common.php';


$headers = [
    'Content-Type' => 'application/json',
    'X-Kite-Version' => '3',
    'Authorization' => 'token '.KEY.':'.TOKEN
];

$client = new GuzzleHttp\Client([
    'headers' => $headers
]);


$date = date('d-m-Y');


  #reseting the order_status
  $query = "UPDATE stocklistbackup SET `order_status`='0' ";
  $result = mysqli_query($GLOBALS['mysqlConnect'],$query);

  $delete_query = "DELETE FROM stockvaluesbackup WHERE `createdDate` = '$date'";
  $delete_result = mysqli_query($GLOBALS['mysqlConnect'],$delete_query);


  $ranges = array("0,501", "500,1001", "1000,1501","1500,2001","2000,2500");

//$ranges = array("0,5", "6,10", "11,17","18,29","45,57");


//Getting all stocks

 foreach ($ranges as $range) {

     $all_stocks = [];

     $two_range = explode(",", $range);

     $query = "Select cSymbol from stocklistbackup where id > $two_range[0] and id < $two_range[1]";
     $result = mysqli_query($GLOBALS['mysqlConnect'], $query);
     $row = mysqli_fetch_all($result);

     //Concating all stocks at onces
     foreach ($row as $record) {

         $api_symbol = $record[0];

         if (str_contains($api_symbol, "&")) {
             $api_symbol = str_replace("&", "%26", $api_symbol);
         }


         $all_stocks[] = "i=NSE:" . $api_symbol;

     }

     //Got all data from kite instruments
     $all_stock = implode("&", $all_stocks);
     $end_point = "https://api.kite.trade/quote?$all_stock";
     $res = $client->request('GET', $end_point);
     $response = $res->getBody()->getContents();
     $response = (json_decode($response, true));

     //Updating in Database
     foreach ($row as $record) {

         $api_symbol = $record[0];

         if (str_contains($api_symbol, "%26")) {
             $api_symbol = str_replace("%26", "&", $api_symbol);
         }

         $fetch = $response['data']["NSE:$api_symbol"]["ohlc"];

         $open = $fetch['open'];
         $open = str_replace(",", "", $open);

         $low = $fetch['low'];
         $low = str_replace(",", "", $low);

         $high = $fetch['high'];
         $high = str_replace(",", "", $high);

         $close = $response['data']["NSE:$api_symbol"]['last_price'];
         $close = str_replace(",", "", $close);

         $prev_close = $fetch['close'];
         $prev_close = str_replace(",", "", $prev_close);


         $volume = $response['data']["NSE:$api_symbol"]['volume'];
         $alllow = 0;
         $allhigh = 0;
         $value = 0;
         $chng_percentage = 0;

         $chng = $close - $prev_close;
         $chng = number_format($chng, 1);


         $query = "Select id from stocklistbackup where cSymbol = '$api_symbol' ";
         $result = mysqli_query($GLOBALS['mysqlConnect'], $query);
         $id = $result->fetch_all(MYSQLI_ASSOC);
         $sid = $id[0]['id'];

         $query = "INSERT INTO stockvaluesbackup(sid, open, high, allHigh, low, allLow, close, schange, schangePercent, volume, stockValues, addClear, createdDate)
     VALUES ('$sid','$open','$high','$allhigh','$low','$alllow','$close','$chng','$chng_percentage','$volume','$value',1,'$date')";
         $result = mysqli_query($GLOBALS['mysqlConnect'], $query);

         $query = "UPDATE stocklistbackup SET dailyEntry='yes',current_volume='$volume',qbuy='$chng' WHERE id = '$sid'";
         $result = mysqli_query($GLOBALS['mysqlConnect'], $query);


         echo "$api_symbol  Completed - $chng";
         echo "\n";



     }


     sleep(2);
 }


//$delete_query = "DELETE FROM stockvaluesbackup WHERE `volume` = ''";
//$delete_result = mysqli_query($GLOBALS['mysqlConnect'],$delete_query);











?>