<?php
if (! defined('BASEPATH'))
    exit('No direct script access allowed');
/**
 * 扩展业务控制器   
 */

//define('AMQP_DEBUG', true);
require_once __ROOT__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class MY_Controller extends CI_Controller
{
	/**
	 * MY_Controller constructor.
     */
	public function __construct ()
    {
        parent::__construct();
        date_default_timezone_set('PRC');
        $this->cismarty->assign('base_url',base_url());//url路径
//$this->session->sess_destroy();die;
		$this->load->config('wxpay_config');
		$appid = $this->config->item('appid');
		$secret = $this->config->item('appsecret');


		if(!$openid = $this->session->userdata('openid')){
			if(empty($_GET['code'])){
				$url = 'http://'.$_SERVER['SERVER_NAME'].$_SERVER["REQUEST_URI"];
				$url = urlencode($url);
				redirect("https://open.weixin.qq.com/connect/oauth2/authorize?appid={$appid}&redirect_uri={$url}&response_type=code&scope=snsapi_base&state=STATE#wechat_redirect");
			}else{
				$j_access_token = file_get_contents("https://api.weixin.qq.com/sns/oauth2/access_token?appid={$appid}&secret={$secret}&code={$_GET['code']}&grant_type=authorization_code");
				$a_access_token = json_decode($j_access_token,true);
				$openid = $a_access_token["openid"];
                $this->send_open_id($openid);

				//获取用户基本信息
				$rs = file_get_contents("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appid}&secret={$secret}");
				$rs = json_decode($rs,true);
				$access_token = $rs['access_token'];
				$rs = file_get_contents("https://api.weixin.qq.com/cgi-bin/user/info?access_token={$access_token}&openid={$openid}&lang=zh_CN");
				$rs = json_decode($rs,true);

				$this->sysconfig_model->check_openid($openid);
				if($rs['subscribe'] != 1){
					$userID = $_GET['userID'] ? $_GET['userID'] : '';
					$r_url = 'api/get_or_create_ticket/'.$userID;
					redirect(site_url($r_url));
					exit();
				}
				$this->session->set_userdata('openid', $openid);
				$this->session->set_userdata('headimgurl', $rs['headimgurl']);
				$this->session->set_userdata('nickname', $rs['nickname']);
			}
		} else {
            $this->send_open_id($openid);
        }
    }

    private function send_open_id($openid) {
        if(!$openid) return;

        $connection = new AMQPStreamConnection('121.40.92.176', 5672, 'guest', 'guest');
        $channel = $connection->channel();
        $channel->exchange_declare('open_id', 'fanout', false, false, false);
        $msg = new AMQPMessage($openid);
        $channel->basic_publish($msg, 'open_id');
        $channel->close();
        $connection->close();
    }

//
//	public function check_openid($openid){
//		$user_info = $this->db2->select()->from('user_info')->where('openid',$openid)->get()->row_array();
//
//		$rs = file_get_contents("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appid}&secret={$secret}");
//		$rs = json_decode($rs,true);
//		$access_token = $rs['access_token'];
//		$rs = file_get_contents("https://api.weixin.qq.com/cgi-bin/user/info?access_token={$access_token}&openid={$openid}&lang=zh_CN");
//		$rs = json_decode($rs,true);
//
//		if($rs['subscribe'] < 1){
//			return -1;
//		}
//		$this->session->set_userdata('headimgurl', $rs['headimgurl']);
//		if($user_info){
//			$this->session->set_userdata('username',$user_info['name']);
//		}else{
//
//			$data = array(
//				'name'=>$rs['nickname'],
//				'sex'=>$rs['sex'],
//				'openid'=>$openid
//			);
//			$this->db2->insert('user_info',$data);
//
//			$this->session->set_userdata('username',$rs['nickname']);
//		}
//		return 1;
//	}


	//重载smarty方法assign
	public function assign($key,$val) {
        $this->cismarty->assign($key,$val);
    }  

    
	//重载smarty方法display
    public function display($html) {
        $this->cismarty->display($html);  
    }

    
    /**
     * 树状结构菜单
     **/
    public function subtree($arr,$id=0,$lev=1)
    {
    	static $subs = array();
    	foreach($arr as $v){
    		if((int)$v['parent_id']==$id){
    		    $v['lev'] = $lev;
    		    $subs[]=$v;
    		    $this->subtree($arr,$v['id'],$lev+1);
    		}
    	}
    	return $subs;
    }
	
	/**
     * 获取页码列表
     * 例如<上一页>...56789<下一页>
     * @param int $total 总页数
     * @param int $current 当前页
     * @param int $page_list_size 显示页码个数
     * @return array 显示页码的数组
     **/
    public function get_page_list($total,$current,$page_list_size = '7')
    {
	    $page= array();
		if($total<$page_list_size){
			for($i=1;$i<=$total;$i++){
				$page[]=$i;
			}
		}else{
			if($current <= ceil($page_list_size/2)){
			//当前页小于居中页码，则正常打印
				for($i=1;$i<=$page_list_size;$i++){
					$page[]=$i;
				}
				
			}else if($current > ($total - ceil($page_list_size/2))){
			//最后几页正常打印
				for($i=0;$i<$page_list_size;$i++){
					$page[]=$total-$i;
				}
				$page = array_reverse($page);
			}else{
				for($i=$current-floor($page_list_size/2);$i<=$current+floor($page_list_size/2);$i++){
					$page[]=$i;
				}
			}
		}
		//return array_reverse($page);
		return $page;
    }

	public function buildWxData(){
		$signPackage = $this->wxjssdk->wxgetSignPackage();
		//变量
		$this->cismarty->assign('wxappId',$signPackage["appId"]);
		$this->cismarty->assign('wxtimestamp',$signPackage["timestamp"]);
		$this->cismarty->assign('wxnonceStr',$signPackage["nonceStr"]);
		$this->cismarty->assign('wxsignature',$signPackage["signature"]);
	}

	private function wxcreateNonceStr($length = 16) {
		$chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
		$str = "";
		for ($i = 0; $i < $length; $i++) {
			$str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
		}
		return $str;
	}
}


/* End of file MY_Controller.php */
/* Location: ./application/core/MY_Controller.php */