<?php

class DB extends Worker
{
    private static $db;
    private $dsn;
    private $root;
    private $pwd;

    public function __construct($dsn, $root, $pwd)
    {
        $this->dsn = $dsn;
        $this->root = $root;
        $this->pwd = $pwd;
    }

    public function run()
    {
        //建立連線物件
        self::$db = new PDO($this->dsn, $this->root, $this->pwd);

        //把require放到worker執行緒中，不要放到主執行緒中，不然會報錯找不到類
        require './vendor/autoload.php';
    }

    //返回一個連線資源
    public function getConn()
    {
        return self::$db;
    }
}

class Sina extends Thread
{
    private $name;
    private $url;

    public function __construct($name, $url)
    {
        $this->name = $name;
        $this->url = $url;
    }

    public function run()
    {
        $db = $this->worker->getConn();

        if (empty($db) || empty($this->url)) {
            return false;
        }

        $content = file_get_contents($this->url);
        if (!empty($content)) {
            //獲取標題，地址，時間
            $data = QL\QueryList::Query($content, [
                'tit' => ['.c_tit > a', 'text'],
                'url' => ['.c_tit > a', 'href'],
                'time' => ['.c_time', 'text'],
            ], '', 'UTF-8', 'GB2312')->getData();

            //把獲取的資料插入資料庫
            if (!empty($data)) {
                $sql = 'INSERT INTO tb_sina(`url`, `title`, `time`) VALUES';
                foreach ($data as $row) {
                    //修改下時間，新浪的時間格式是這樣的04-23 15:30
                    $time = date('Y') . '-' . $row['time'] . ':00';
                    $sql .= "('{$row['url']}', '{$row['tit']}', '{$time}'),";
                }
                $sql = rtrim($sql, ',');
                $ret = $db->exec($sql);

                if ($ret !== false) {
                    echo "執行緒{$this->name}成功插入{$ret}條資料\n";
                } else {
                    var_dump($db->errorInfo());
                }
            }
        }
    }
}

//抓取頁面地址
$url = 'http://roll.news.sina.com.cn/s/channel.php?ch=01#col=89&spec=&type=&ch=01&k=&offset_page=0&offset_num=0&num=60&asc=&page=';
//建立pool池
$pool = new Pool(5, 'DB', ['mysql:dbname=test;host=192.168.33.226', 'root', '']);

//獲取100個分頁資料
for ($ix = 1; $ix <= 100; $ix++) {
    $pool->submit(new Sina($ix, $url . $ix));
}

//迴圈收集垃圾，阻塞主執行緒，等待子執行緒結束
while ($pool->collect()) ;
$pool->shutdown();