input163Index.class.php 3.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. <?php
  2. /**
  3. * @author:王刚涛
  4. * 用于获取当天各种指数
  5. * http://hq.sinajs.cn/list=s_sz000002
  6. */
  7. class Input163index
  8. {
  9. /****
  10. * @param $code
  11. * @return string
  12. * 返回股票指数所属的板块,在股票代码前拼接0或者1
  13. */
  14. static public function stock_block($code)
  15. {
  16. $f = substr($code, 0, 1);
  17. if ($f == "6") {
  18. $stock_code = "1" . $code;
  19. } else {
  20. $stock_code = "0" . $code;
  21. }
  22. return $stock_code;
  23. }
  24. /****
  25. * @param $url
  26. * @return array|bool|string
  27. * 对curl_setopt进行封装,消除代码冗余
  28. */
  29. static private function curl_get_data($url){
  30. $curlHandle = curl_init();
  31. curl_setopt($curlHandle, CURLOPT_URL, $url);
  32. curl_setopt($curlHandle, CURLOPT_RETURNTRANSFER, 1);
  33. curl_setopt($curlHandle, CURLOPT_SSL_VERIFYPEER, false);
  34. curl_setopt($curlHandle, CURLOPT_SSL_VERIFYHOST, false);
  35. curl_setopt($curlHandle, CURLOPT_TIMEOUT, 10);
  36. $content = curl_exec($curlHandle);
  37. curl_close($curlHandle);
  38. $content1 = explode("\n", $content);//以换行符进行分割字符串
  39. return $content1;
  40. }
  41. static public function get_history_index($stock_code,$start_date,$end_date)
  42. {
  43. $code = self::stock_block($stock_code);
  44. $url = "http://quotes.money.163.com/service/chddata.html?code=" . $code . "&start=" . $start_date . "&end=" . $end_date . "&fields=TOPEN;HIGH;LOW;TCLOSE;VATURNOVER;VOTURNOVER;CHG;PCHG";
  45. //构建所要发送的url
  46. $content1=self::curl_get_data($url);
  47. if (!empty($content1[1])) {
  48. for ($i = count($content1) - 1; $i >0; $i--) {//排除日期,代码等标题栏
  49. if (!empty($content1[$i])) {
  50. $content3 = explode(",", iconv("gbk", "utf-8", $content1[$i]));
  51. }
  52. else{
  53. continue;
  54. }
  55. // 解析返回的历史数据
  56. $data['date'] = strtotime($content3[0]);//用于创建表
  57. $data['code'] = explode("'",$content3[1])[1];
  58. $data['name'] = $content3[2];
  59. $data['open_price'] = floatval($content3[3]);
  60. $data['hightest_price'] = floatval($content3[4]);
  61. $data['lowest_price'] = floatval($content3[5]);
  62. $data['close_price'] = floatval($content3[6]);
  63. $data['value'] = floatval($content3[7]);
  64. $data['amount'] = floatval($content3[8]);
  65. $data['increase_price'] = floatval($content3[9]);
  66. $data['increase_ratio'] = floatval($content3[10]);
  67. //将所要存储的数据放入一个数组中
  68. $stock_name = $content3[1];
  69. if ($data['close_price'] == 0) {//当收盘价为0的时候,表示此时的基于9-3点,所以不存储
  70. continue;
  71. }
  72. if (!empty($data)) {
  73. $msg= Index_day_k::insert($data);//将这支股票的历史数据存入数据库
  74. }
  75. }
  76. }
  77. return $msg;
  78. }
  79. }
  80. ?>