|
17 | 17 |
|
18 | 18 |
|
19 | 19 | #reseting the order_status
|
20 |
| - $query = "UPDATE stocklistbackup SET `order_status`='0' "; |
| 20 | + $query = "UPDATE stocklistbackupbackup SET `order_status`='0' "; |
21 | 21 | $result = mysqli_query($GLOBALS['mysqlConnect'],$query);
|
22 | 22 |
|
23 |
| - $delete_query = "DELETE FROM stockvaluesbackup WHERE `createdDate` = '$date'"; |
| 23 | + $delete_query = "DELETE FROM stockvaluesbackupbackup WHERE `createdDate` = '$date'"; |
24 | 24 | $delete_result = mysqli_query($GLOBALS['mysqlConnect'],$delete_query);
|
25 | 25 |
|
26 | 26 |
|
| 27 | + $ranges = array("0,501", "500,1001", "1000,1501","1500,2001","2000,2500"); |
27 | 28 |
|
28 |
| - //Getting all stocks |
| 29 | +//$ranges = array("0,5", "6,10", "11,17","18,29","45,57"); |
29 | 30 |
|
30 |
| - $query = "Select cSymbol from stocklistbackup"; |
31 |
| - $result = mysqli_query($GLOBALS['mysqlConnect'],$query); |
32 |
| - $row = mysqli_fetch_all($result); |
33 |
| - $i = 1; |
34 |
| - |
35 |
| - //Concating all stocks at onces |
36 |
| - foreach ($row as $record) { |
37 | 31 |
|
38 |
| - $api_symbol = $record[0]; |
| 32 | +//Getting all stocks |
39 | 33 |
|
40 |
| - if (str_contains($api_symbol, "&")) { |
41 |
| - $api_symbol = str_replace("&", "%26", $api_symbol); |
42 |
| - } |
| 34 | + foreach ($ranges as $range) { |
43 | 35 |
|
| 36 | + $all_stocks = []; |
44 | 37 |
|
45 |
| - $all_stocks[] = "i=NSE:" . $api_symbol; |
| 38 | + $two_range = explode(",", $range); |
46 | 39 |
|
47 |
| - } |
| 40 | + $query = "Select cSymbol from stocklistbackupbackup where id > $two_range[0] and id < $two_range[1]"; |
| 41 | + $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
| 42 | + $row = mysqli_fetch_all($result); |
48 | 43 |
|
| 44 | + //Concating all stocks at onces |
| 45 | + foreach ($row as $record) { |
49 | 46 |
|
50 |
| - //Got all data from kite instruments |
51 |
| - $all_stocks = implode("&",$all_stocks); |
52 |
| - $end_point = "https://api.kite.trade/quote?$all_stocks"; |
53 |
| - $res = $client->request('GET', $end_point); |
54 |
| - $response = $res->getBody()->getContents(); |
55 |
| - $response = (json_decode($response, true)); |
| 47 | + $api_symbol = $record[0]; |
56 | 48 |
|
| 49 | + if (str_contains($api_symbol, "&")) { |
| 50 | + $api_symbol = str_replace("&", "%26", $api_symbol); |
| 51 | + } |
57 | 52 |
|
58 |
| -//Updating in Database |
59 |
| -foreach ($row as $record) { |
60 | 53 |
|
61 |
| - $api_symbol = $record[0]; |
| 54 | + $all_stocks[] = "i=NSE:" . $api_symbol; |
62 | 55 |
|
63 |
| - if(str_contains($api_symbol,"%26")) { |
64 |
| - $api_symbol = str_replace("%26", "&", $api_symbol); |
65 |
| - } |
| 56 | + } |
66 | 57 |
|
67 |
| - $fetch = $response['data']["NSE:$api_symbol"]["ohlc"]; |
| 58 | + //Got all data from kite instruments |
| 59 | + $all_stock = implode("&", $all_stocks); |
| 60 | + $end_point = "https://api.kite.trade/quote?$all_stock"; |
| 61 | + $res = $client->request('GET', $end_point); |
| 62 | + $response = $res->getBody()->getContents(); |
| 63 | + $response = (json_decode($response, true)); |
68 | 64 |
|
69 |
| - $open = $fetch['open']; |
70 |
| - $open = str_replace(",", "", $open); |
| 65 | + //Updating in Database |
| 66 | + foreach ($row as $record) { |
71 | 67 |
|
72 |
| - $low = $fetch['low']; |
73 |
| - $low = str_replace(",", "", $low); |
| 68 | + $api_symbol = $record[0]; |
74 | 69 |
|
75 |
| - $high = $fetch['high']; |
76 |
| - $high = str_replace(",", "", $high); |
| 70 | + if (str_contains($api_symbol, "%26")) { |
| 71 | + $api_symbol = str_replace("%26", "&", $api_symbol); |
| 72 | + } |
77 | 73 |
|
78 |
| - $close = $response['data']["NSE:$api_symbol"]['last_price']; |
79 |
| - $close = str_replace(",", "", $close); |
| 74 | + $fetch = $response['data']["NSE:$api_symbol"]["ohlc"]; |
80 | 75 |
|
81 |
| - $prev_close = $fetch['close']; |
82 |
| - $prev_close = str_replace(",", "", $prev_close); |
| 76 | + $open = $fetch['open']; |
| 77 | + $open = str_replace(",", "", $open); |
83 | 78 |
|
| 79 | + $low = $fetch['low']; |
| 80 | + $low = str_replace(",", "", $low); |
84 | 81 |
|
85 |
| - $volume = $response['data']["NSE:$api_symbol"]['volume']; |
86 |
| - $alllow = 0; |
87 |
| - $allhigh = 0; |
88 |
| - $value = 0; |
89 |
| - $chng_percentage = 0; |
| 82 | + $high = $fetch['high']; |
| 83 | + $high = str_replace(",", "", $high); |
90 | 84 |
|
91 |
| - $chng = $close - $prev_close; |
92 |
| - $chng = number_format($chng, 1); |
| 85 | + $close = $response['data']["NSE:$api_symbol"]['last_price']; |
| 86 | + $close = str_replace(",", "", $close); |
93 | 87 |
|
| 88 | + $prev_close = $fetch['close']; |
| 89 | + $prev_close = str_replace(",", "", $prev_close); |
94 | 90 |
|
95 | 91 |
|
96 |
| - $query = "Select id from stocklistbackup where cSymbol = '$api_symbol' "; |
97 |
| - $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
98 |
| - $id = $result->fetch_all(MYSQLI_ASSOC); |
99 |
| - $sid = $id[0]['id']; |
| 92 | + $volume = $response['data']["NSE:$api_symbol"]['volume']; |
| 93 | + $alllow = 0; |
| 94 | + $allhigh = 0; |
| 95 | + $value = 0; |
| 96 | + $chng_percentage = 0; |
100 | 97 |
|
101 |
| - $query = "INSERT INTO stockvaluesbackup(sid, open, high, allHigh, low, allLow, close, schange, schangePercent, volume, stockValues, addClear, createdDate) |
102 |
| -VALUES ('$sid','$open','$high','$allhigh','$low','$alllow','$close','$chng','$chng_percentage','$volume','$value',1,'$date')"; |
103 |
| - $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
| 98 | + $chng = $close - $prev_close; |
| 99 | + $chng = number_format($chng, 1); |
104 | 100 |
|
105 |
| - $query = "UPDATE stocklistbackup SET dailyEntry='yes',current_volume='$volume',qbuy='$chng' WHERE id = '$sid'"; |
106 |
| - $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
107 | 101 |
|
| 102 | + $query = "Select id from stocklistbackupbackup where cSymbol = '$api_symbol' "; |
| 103 | + $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
| 104 | + $id = $result->fetch_all(MYSQLI_ASSOC); |
| 105 | + $sid = $id[0]['id']; |
108 | 106 |
|
| 107 | + $query = "INSERT INTO stockvaluesbackupbackup(sid, open, high, allHigh, low, allLow, close, schange, schangePercent, volume, stockvaluesbackup, addClear, createdDate) |
| 108 | + VALUES ('$sid','$open','$high','$allhigh','$low','$alllow','$close','$chng','$chng_percentage','$volume','$value',1,'$date')"; |
| 109 | + $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
109 | 110 |
|
110 |
| - echo "$api_symbol Completed - $chng"; |
111 |
| - echo "\n"; |
| 111 | + $query = "UPDATE stocklistbackupbackup SET dailyEntry='yes',current_volume='$volume',qbuy='$chng' WHERE id = '$sid'"; |
| 112 | + $result = mysqli_query($GLOBALS['mysqlConnect'], $query); |
112 | 113 |
|
113 |
| - $i++; |
114 | 114 |
|
| 115 | + echo "$api_symbol Completed - $chng"; |
| 116 | + echo "\n"; |
115 | 117 |
|
116 |
| -} |
117 | 118 |
|
118 | 119 |
|
| 120 | + } |
119 | 121 |
|
120 | 122 |
|
| 123 | + sleep(2); |
| 124 | + } |
121 | 125 |
|
122 | 126 |
|
123 | 127 |
|
|
0 commit comments