免签约支付宝及时到账接口

/**
 * 支付宝免签约及时到账接口
 * @author Roope <[email protected]>
 * @version 1.0.3 [修复一些错误。]
 */
class Alipay {

    /**
     * 需要定时刷新的URL
     * @var string
     */
    private $url;

    /**
     * 通知地址
     * @var string
     */
    private $notify;

    /**
     * 支付宝Cookie，用document.cookie获取
     * @var string
     */
    private $cookie;

    /**
     * 通讯密钥
     * @var string
     */
    private $token;

    /**
     * 构造函数
     * @param array $config
     */
    public function __construct(array $config) {

        require_once dirname(__FILE__) . '/SQLite.php';
        $this->db = new SQLite('db.db');
        $this->cookie = isset($config['cookie']) ? $config['cookie'] : exit('Cookie 错误。');
        $this->notify = isset($config['notify']) ? $config['notify'] : exit('通知地址错误。');
        $this->token = isset($config['token']) ? $config['token'] : exit('通讯密钥错误。');
        $days = time() - 86400;
        $this->url = 'https://consumeprod.alipay.com/record/advanced.htm?beginDate='.date('Y.m.d',$days).'&beginTime=00%3A00&endDate='.date('Y.m.d').'&endTime=24%3A00&dateRange=customDate&status=all&keyword=bizOutNo&keyValue=&dateType=createDate&minAmount=&maxAmount=&fundFlow=in&tradeType=ALL&categoryId=&_input_charset=utf-8';
    }


    /**
     * 请求支付宝
     * @return string 抓取回来的信息
     */
    public function requestURL() {

        $ch = curl_init($this->url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_HEADER, array(
            'Host: consumeprod.alipay.com',
            'User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:40.0) Gecko/20100101 Firefox/40.0',
            'Accept: */*',
            'Accept-Language: zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3',
            'Accept-Encoding: gzip, deflate',
            'DNT: 1',
            'Referer: https://authgtj.alipay.com/login/index.htm',
            'Connection: keep-alive'
        ));
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_COOKIE, $this->cookie);
        $response = curl_exec($ch);
        if(curl_errno($ch)) $response = curl_error($ch);
        curl_close($ch);
        return $response;
    }

    /**
     * 解析下返回来的信息
     * @return string 解析成功后的信息
     */
    public function parse() {

        require_once dirname(__FILE__) . '/simple_html_dom.php';

        $data = $this->requestURL();
        if(empty($data))  return $data;  //如过抓取到的内容是空的说明cookie失效了。

        $html = new simple_html_dom();
        $html->load($data);
        $ymd = $html->find('.time-d');
        $his = $html->find('.time-h');
        $title = $html->find('.consume-title a');
        $trade = $html->find('td.tradeNo p');
        $name = $html->find('p.name');
        $amount = $html->find('td.amount span');

        if(!$trade) return 'no_order';
        $info = array();
        foreach ($ymd as $key => $value) {
            //只要订单数字部分
            preg_match('/\d+/',$trade[$key]->innertext,$tradeNo);
            //这里可以添加一些逻辑判断语句，例如存到数据库里面遍历查询这个订单是否已经通知成功
            $info[] = array(
                'time' => trim($ymd[$key]->innertext) . ' ' . trim($his[$key]->innertext),
                'title' => trim($title[$key]->innertext),
                'trade' => trim($tradeNo[0]),
                'name' => trim($name[$key]->innertext),
                'amount' => trim(str_replace('+', '', $amount[$key]->innertext))
            );
        }
        $html->clear();

        return $info;
    }

    /**
     * 通知接口
     * @param array $order 订单信息
     * @return void
     */
    public function notify(array $order) {

        $exists = $this->db->select('trade','id','trade','has_notify','AND' => 'trade' => $order'trade');

        if(!$exists) {
            $this->db->insert('trade',[
                'time','title','trade','name','amount','has_notify'
            ],[
                $order['time'],$order['title'],$order['trade'],$order['name'],$order['amount'],0
            ]);

        } else {
            if($exists[0]['has_notify'] == 1) return '已经通知成功，无需再次通知。';
        }

        //MD5加密下当作签名传过去好校验是不是自己的
        $order['sig'] = strtoupper(md5($this->token));

        $ch = curl_init($this->notify);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($order));
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        $response = curl_exec($ch);
        //print_r($response);
	if(curl_errno($ch)) return curl_error($ch);
        if($response == 'success') {
            $this->db->update('trade',['has_notify' => 1],['AND' => [['trade' => $order['trade']]]]);
            return 'success';
        } else {
            return '服务器未返回正确的参数。';
        }
    }

    /**
     * 运行程序
     * @return boolean
     */
    public function run() {

        $orderArr = $this->parse();
        if(empty($orderArr)) {
            echo "Cookie失效，请重新填写Cookie。\n";
            return false;
        } else if($orderArr == 'no_order') {
            echo "暂无订单。 \n";
            return false;
        }

        foreach($orderArr as $key => $order) {
            $notify = $this->notify($order);
	    if($notify == 'success') echo '订单: ' . $order['trade'] . " 通知成功。\n";
            else echo '订单: ' . $order['trade'] . " 通知失败。错误信息：$notify \n";
        }
    }
}