<?php
// +----------------------------------------------------------------------
// | 第三方平台微信推送  消息
// +----------------------------------------------------------------------
//[1.1.69]
namespace WxApi\Controller;
use Think\Controller;
class WxController extends Controller{
    public static $_set; //缓存全局配置
    public static $appid; //缓存全局配置
    public static $_wx; //缓存微信对象
    public static $_token;
    public static $_location; //用户地理信息
    public static $_merchantid; //用户地理信息
    //信息接收相关
    public static $_revtype; //微信发来的信息类型
    public static $_revdata; //微信发来的信息内容
    //信息推送相关
    public static $_url;
    public static $_wecha_id;
    public static $_actopen;
    public static $WAP;//CMS全局静态变量
    // 自动计算模型
    public static $_demployee;
    public function __construct($options)
    {
        $appid = I('get.Appid');
        file_put_contents("./appid.txt",$appid);
        if(!empty($appid)){
            $map['authorizer_appid'] = $appid;
        }else{
            $this->error('参数出错，请检查');
        }
        if(I('get.merchantid')==1){
            exit;
        }
        self::$_url = $_SERVER['SERVER_NAME'];
        self::$_set = M('wxconfig')->where($map)->find();

        $auther = M('appweixin')->find();
        //缓存微信API模型类
        $options['token'] = $auther['token'];
        $options['appid'] = $auther['appid'];

        $options['encodingaeskey'] = $auther['encodingaeskey'];
        $re = self::$_wx = new \Util\Wx\Wechat($options);
        //判断验证模式
        if (IS_GET) {
            self::$_wx->valid();
        } else {
            $is = self::$_wx->valid(true);
            if (!$is) {
                die('no access!!!');
            }

            //读取微信平台推送来的信息类型存全局
            self::$_revtype = self::$_wx->getRev()->getRevType();
            //读取微型平台推送来的信息存全局
            self::$_revdata = self::$_wx->getRevData();

            self::$_wecha_id = self::$_wx->getRevFrom();
            //读取用户地理信息
            //self::$_location=self::$_wx->getRevData();
            $str = "";
            foreach (self::$_revdata as $k => $v) {
                $str = $str . $k . "=>" . $v . '  ';
            }

        }
    }
    /*
     * appid 授权入口
     */
    public function auth(){
        //这里微信要做处理
        $this->go();
    }
    public function go()
    {

        switch (self::$_revtype) {

            case \Util\Wx\Wechat::MSGTYPE_TEXT:
                $this->checkKeyword(self::$_revdata['Content']);
                //self::$_wx->text(self::$_revdata['Content'])->reply();
                break;
            case \Util\Wx\Wechat::MSGTYPE_EVENT:
                $this->checkEvent(self::$_revdata['Event']);
                break;
            case \Util\Wx\Wechat::MSGTYPE_IMAGE:
                //$this -> checkImg();
                self::$_wx->text('本系统暂不支持图片信息！')->reply();
                break;
            default:
                self::$_wx->text("本系统暂时无法识别您的指令！")->reply();
        }

    }
    public function toApp($type)
    {

        $title = "App管理员模式：\n命令：" . $type . "\n结果：\n";

        switch ($type) {
            case 'dkf':
                $str = "人工客服接入！";
                self::$_wx->dkf($str)->reply();
                break;
            case 'openid':
                self::$_wx->text($title . self::$_revdata['FromUserName'])->reply();
                break;
            default:
                self::$_wx->text("App:未知命令")->reply();
        }

    }

    //微信号的关键字设置
    public function checkKeyword($key)
    {
//        self::$_wx->text("未知的关键字信息，请联系客服")->reply();
        /*if (substr($key, 0, 5) == 'App-') {
            $this->toApp(substr($key, 5));
        }
        $mapkey['keyword'] = $key;
        $mapkey['storeid'] = self::$_storeid;
        //用户自定义关键词
        $keyword = M('wxkeyword');
        $ruser = $keyword->where($mapkey)->find();
        if ($ruser) {
            //进入用户自定义关键词回复
            $this->toKeyUser($ruser);
        }else{
            //自定义推送消息
            $this->checkedKey($key);
        }*/
        // $this->toKeyUnknow();

    }
    public function checkedKey($key){
        $this->toKeyUnknow($key);

    }
    /*自定义关键词模式 by App
    $ruser=关键词记录
     */
    public function getPic($id)
    {
        $m = M('Upload_img');
        $map['id'] = $id;
        $list = $m->where($map)->find();
        $list['imgurl'] = self::$_url . "/Upload/" . $list['savepath'] . $list['savename'];
        return $list ? $list : false;
    }
    public function toKeyUser($ruser)
    {
        $type = $ruser['type'];
        switch ($type) {
            //文本
            case "1":
                self::$_wx->text($ruser['summary'])->reply();
                break;
            //单图文
            case "2":
                $news[0]['Title'] = $ruser['name'];
                $news[0]['Description'] = $ruser['summary'];
                $news[0]['PicUrl'] = "http://".self::$_url .$ruser['pic'];
                $news[0]['Url'] = $ruser['url'];
                self::$_wx->news($news)->reply();
                break;
            //多图文
            case "3":
                $pagelist = M('Wx_keyword_img')->where(array('kid' => $ruser['id']))->order('sorts desc')->select();
                $news = array();
                foreach ($pagelist as $k => $v) {
                    $news[$k]['Title'] = $v['name'];
                    $news[$k]['Description'] = $v['summary'];
                    $img = $this->getPic($v['pic']);
                    $news[$k]['PicUrl'] = $img['imgurl'];
                    $news[$k]['Url'] = $v['url'];
                }
                self::$_wx->news($news)->reply();
                break;
            default:
                self::$_wx->text("未知类型的关键词，请联系客服！")->reply();
                break;
        }
    }
    //未知关键字匹配
    public function toKeyUnknow()
    {
       // self::$_wx->text("未知的关键字信息，请联系客服")->reply();
    }
    public function add_vipLog($type){
        $data = self::$_revdata;
        $item['storeid'] = self::$_storeid;
        $item['openid'] = $data['FromUserName'];
        $item['addtime'] = time();
        $item['type'] = $type;
        D('Sublog')->addLog($item);
    }
    /*
     *这里是  服务器配置接受微信推送事件
     */
    public function checkEvent($event)
    {
        $wxconfig = self::$_set;
        $data = self::$_revdata;
        $datas = json_encode($data);
        switch ($event) {
            case 'subscribe':

                //获取一个token
                break;
            case 'unsubscribe':
                //关注取消事件
                $this->add_vipLog(2);
            case 'CLICK':
                $key = self::$_revdata['EventKey'];
                switch ($key) {
                    case '#sy':
                        break;
                }
                $this->checkKeyword($key);
                break;
            case 'user_get_card':
                $this->setCard();
                A('Card')->updateCard($data);
                //根据会员卡id 获取 用户的门店信息
                $cardid = $data['CardId'];
                $getstore['card_id'] = $cardid;
                //获取门店
                $store = M('wx_membercard')->where($getstore)->getField('storeid');
                //获取门店id  通过id 获取门店的微信配置
                $map['storeid'] = $store;
                //推送消息  推送一条用户领取会员卡的消息
                $openid = $data['FromUserName'];
                //$this->addcard($store,$openid);
                //激活的话修改vip中的字段  同时会员卡的数量减一
                $vip['openid'] = $openid;
                //$vip['card_id'] = $cardid;
                $vip['primaryid'] = $store;
                //$vip['openid'] = "owUCP1KMgjtVXBgJbgVie8o_ff-c";
                //会员入驻
                $this->sendCard();
                //获取会员信息
                $mobile_phone = M('retail_vip')->where($vip)->getField('mobile_phone');
                M('retail_vip')->where($vip)->save(array('card_id'=>$cardid,'iswxcode'=>1,'cardnum'=>$mobile_phone,'cardnum_old'=>$data['UserCardCode']));
                break;
            case 'user_pay_from_pay_cell':
                break;
            case 'user_view_card':
                $cardid = $data['CardId'];
                $getstore['card_id'] = $cardid;
                $merchantid = M('wx_membercard')->where($getstore)->getField('merchantid');
                //获取门店id  通过id 获取门店的微信配置
                $map['merchantid'] = $merchantid;
                //推送消息  推送一条用户领取会员卡的消息
                $openid = $data['FromUserName'];
                $vip['openid'] = $openid;
                //$vip['card_id'] = $cardid;
                $vip['merchantid'] = $merchantid;
                $mobile_phone = M('retail_vip')->where($vip)->getField('mobile_phone');

                M('retail_vip')->where($vip)->save(array('card_id'=>$cardid,'iswxcode'=>1,'cardnum'=>$mobile_phone,'cardnum_old'=>$data['UserCardCode']));
                $this->sendCard();
                break;


        }
    }
    /*
     * 实现会员卡领卡的时候  库存减一
     */
    public function setCard(){
        $data = self::$_revdata;
        file_put_contents('./vipcard.txt',json_encode($data));
        $set['card_id'] = $data['CardId'];
        // 判断用户的信息
        $card = M('wx_membercard')->where($set)->find();
        if(!empty($card)&&$card['quantity']>0){
            M('wx_membercard')->where($set)->setDec('quantity');
            M('wx_membercard')->where($set)->setInc('closure');
            //确定可以使用的时候的 发送请求
        }
    }
    /*
     * 推送服务器 获取token的 方法
     */
    public function getToKen()
    {

        $tokens = get_authorizer_access_token(self::$_set["merchantid"]);
        return $tokens;

    }
    /*
     * 获取post 参数 ，发送会员变动记录 积分和余额的同步
     */
    public function sendCard(){
        //获取token值

        $data = self::$_revdata;

        $token = $this->getToKen();
        $vip['openid'] = $data['FromUserName'];
        $userinfo = M('retail_vip')->where($vip)->find();
        $seturl = "https://api.weixin.qq.com/card/membercard/activate?access_token=".$token;
        $item['membership_number'] = $userinfo['mobile_phone'];
        $item['code'] = $data['UserCardCode'];
        $item['card_id'] = $data['CardId'];
        $item['init_bonus'] =  intval($userinfo['integral']+$userinfo['cash_integral']);
        $text = json_encode($item);
        $re =  $this->curl_post($seturl, $text);
        file_put_contents("./wx_card.txt",json_encode($re)."1212");
    }

    /**
     * POST 请求
     * @param string $url
     * @param array $param
     * @param boolean $post_file 是否文件上传
     * @return string content
     */
    private function http_post($url, $param, $post_file = false)
    {
        $oCurl = curl_init();
        if (stripos($url, "https://") !== FALSE) {
            curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, FALSE);
            curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, false);
            curl_setopt($oCurl, CURLOPT_SSLVERSION, 1); //CURL_SSLVERSION_TLSv1
        }
        if (is_string($param) || $post_file) {
            $strPOST = $param;
        } else {
            $aPOST = array();
            foreach ($param as $key => $val) {
                $aPOST[] = $key . "=" . urlencode($val);
            }
            $strPOST = join("&", $aPOST);
        }
        curl_setopt($oCurl, CURLOPT_URL, $url);
        curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($oCurl, CURLOPT_POST, true);
        curl_setopt($oCurl, CURLOPT_POSTFIELDS, $strPOST);
        $sContent = curl_exec($oCurl);
        $aStatus = curl_getinfo($oCurl);
        curl_close($oCurl);
        if (intval($aStatus["http_code"]) == 200) {
            return $sContent;
        } else {
            return false;
        }
    }
    function curl_post($url, array $params = array(), $timeout)
    {
        $ch = curl_init();//初始化
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($ch, CURLOPT_URL, $url);//抓取指定网页
        curl_setopt($ch, CURLOPT_HEADER, 0);//设置header
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);//要求结果为字符串且输出到屏幕上
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
        curl_setopt($ch, CURLOPT_POST, 1);//post提交方式
        curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
        $data = curl_exec($ch);//运行curl
        curl_close($ch);
        return ($data);
    }
    /*
     * 实现会员领卡的时候
     * @parem $storeid  门店的id
     * @parem $openid   用户的唯一标识
     */
    public function addcard($storeid,$openid){
        //获取用户信息
        $userinfo = $this->getUserInfo();

        //获取模板信息
        $w['storeid'] = $storeid;
        $template = M('mark')->where($w)->find();
        //$w['storeid'] = $storeid;
        $store['id'] = $storeid;
        $storename = M('store')->where($store)->getField('storetag');
        $templateid = $template['vip_mark'];
        if ($templateid && $openid && $storeid) {
            //从这里发送微信模板消息  通知微信
            $vipname = $userinfo['name']?$userinfo['name']:'用户';
            $cardnum = self::$_revdata['UserCardCode'];
            $str = '亲爱的'.$vipname.',您的微信会员卡激活成功，请从微信卡包中查看';
            $data['touser'] = $openid;
            $data['template_id'] = $templateid;
            $data['topcolor'] = "#00FF00";
            $data['url'] = 'http://'.$_SERVER['HTTP_HOST'].'/index.php/' . '/Vip/Index/index?storeid='.$storeid;
            $data['data'] = array(
                'first'=>array('value' => $str),
                'keyword1' => array('value' => '微信会员卡'),
                'keyword2' => array('value' => $cardnum),
                'remark' => array('value' => $storename.'：感谢您的使用。')
            );
            $options['appid'] = self::$_set['appid'];
            $options['appsecret'] = self::$_set['appsercet'];
            $wx = new \Util\Wx\Wechat($options);
            $re = $wx->sendTemplateMessage($data);
            $msg = json_encode($data);

        }
    }
    /*
     * 通过openid  获取用户信息
     */
    public function getUserInfo(){
        //先根据用户openid 查找用户信息
        $openid = self::$_revdata['FromUserName'];
        if(!empty($openid)){
            $map['openid'] = $openid;
            $cache = M('retail_vip')->where($map)->find();
            if(!empty($cache)){

                return $cache;
            }else{
                $user = $this->apiClient(self::$_revdata['FromUserName']);
                return $user;
            }
        }else{
            exit;
        }

    }
    public function apiClient($openid)
    {
        $user = self::$_wx->getUserInfo($openid);
        return $user ? $user : FALSE;
    }

}