input_163_history_day_k.class.php 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. <?php
  2. /**
  3. * @author:王刚涛
  4. * 用于获取历史数据各种指数
  5. * http://hq.sinajs.cn/list=s_sz000002
  6. */
  7. class Input_163_history_day_k
  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 = "0" . $code;
  19. } else {
  20. $stock_code = "1" . $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. /***
  42. * @param $stock_code
  43. * @param $start_date
  44. * @param $end_date
  45. * @return array
  46. * 历史数据日k
  47. */
  48. static public function HistoryDayK($stock_code,$start_date,$end_date)
  49. {
  50. $msg=array();
  51. $code = self::stock_block($stock_code);
  52. $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";
  53. //构建所要发送的url
  54. $content1=self::curl_get_data($url);
  55. if (!empty($content1[1])) {
  56. for ($i = count($content1) - 1; $i >0; $i--) {//排除日期,代码等标题栏
  57. if (!empty($content1[$i])) {
  58. $content3 = explode(",", iconv("gbk", "utf-8", $content1[$i]));
  59. }
  60. else{
  61. continue;
  62. }
  63. // 解析返回的历史数据
  64. $data['timestamp'] = (int)strtotime($content3[0]);//当日零点的时间戳
  65. $data['date'] = (int)date("Ymd",strtotime($content3[0]));//用于创建表
  66. $data['code'] = explode("'",$content3[1])[1];
  67. $data['name'] = $content3[2];
  68. $data['open_price'] = floatval($content3[3]);
  69. $data['highest_price'] = floatval($content3[4]);
  70. $data['lowest_price'] = floatval($content3[5]);
  71. $data['close_price'] = floatval($content3[6]);
  72. $data['value'] = floatval($content3[7]);
  73. $data['amount'] = floatval($content3[8]);
  74. $data['increase_price'] = floatval($content3[9]);
  75. $data['increase_ratio'] = floatval($content3[10]);
  76. //将所要存储的数据放入一个数组中
  77. $stock_name = $content3[1];
  78. if ($data['close_price'] == 0) {//当收盘价为0的时候,表示此时的基于9-3点,所以不存储
  79. continue;
  80. }
  81. if (!empty($data)) {
  82. $msg= Day_k::HistoryDayK($data);//将这支股票的历史数据存入数据库
  83. }
  84. }
  85. }
  86. return $msg;
  87. }
  88. }
  89. ?>