boniu/lib/input162DayKQfq.class.php

<?php

/**
 * @author:王刚涛
 * 用于获取当天各种指数
 * http://hq.sinajs.cn/list=s_sz000002
 */
class Input162DayKQfq
{

    /****
     * @param $code
     * @return string
     * 返回股票指数所属的板块，在股票代码前拼接0或者1
     */
    static public function stock_block($code)
    {
        $f = substr($code, 0, 1);
        if ($f == "6") {
            $stock_code = "0" . $code;
        } else {
            $stock_code = "1" . $code;
        }
        return $stock_code;
    }

    /****
     * @param $url
     * @return array|bool|string
     * 对curl_setopt进行封装，消除代码冗余
     */
    static private function curl_get_data($url)
    {
        //构建所要发送的url
        $curlHandle = curl_init();
        curl_setopt($curlHandle, CURLOPT_ENCODING, "");//这个接口的数据被压缩，所以要解压
        curl_setopt( $curlHandle , CURLOPT_URL, $url );
        curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 );
        curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 );
        $content2 = curl_exec($curlHandle);
        curl_close( $curlHandle );
        $content3 = json_decode($content2);
        $content4 =$content3->data;
        return $content4;
    }

    static public function get_day_k_qfq($code, $year)
    {
        $msg = array();
        $stock_code = self::stock_block($code);
        $url = "http://img1.money.126.net/data/hs/klinederc/day/history/" . $year . "/" . $stock_code . ".json";
        //构建所要发送的url
        $data = self::curl_get_data($url);
        $stock_info=Stock::getInfoByCode($code);

        for ($i = 0; $i < count($data); $i++) {
            $d = $data[$i];
            $time = strtotime($d[0]);
            $a['timestamp'] = $time;
            $a['date'] = (int)$d[0];
            $a['code'] = $code;
            $a['name'] = $stock_info["name"];
            $a['open_price'] = floatval($d[1]);
            $a['close_price'] = floatval($d[2]);
            $a['highest_price'] = floatval($d[3]);
            $a['lowest_price'] = floatval($d[4]);
            $a['amount'] = (int)$d[5];
//            $a['turnover'] =floatval($d[6]);
            $a['turnover'] =empty(floatval($d[6]))?"0.00":floatval($d[6]);
            Day_k_qfq::addOrUpdateByCode($a);
        }
        return $msg;
    }
}

?>