input163HistoryDayK.class.php 3.5 KB

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