<?php
namespace Org\XiguSDK;
use Think\Exception;
use Think\JSMS;

use AliyunMNS\Client;
use AliyunMNS\Topic;
use AliyunMNS\Constants;
use AliyunMNS\Model\MailAttributes;
use AliyunMNS\Model\SmsAttributes;
use AliyunMNS\Model\BatchSmsAttributes;
use AliyunMNS\Model\MessageAttributes;
use AliyunMNS\Exception\MnsException;
use AliyunMNS\Requests\PublishMessageRequest;

class Xigu  {

    /**
     * API请求地址
     */
    const BaseUrl = "http://yun.vlcms.com/index.php";
    /**
     * 
     * 用户账号ID。由32个英文字母和阿拉伯数字组成的开发者账号唯一标识符。
     */
    private $accountid;

    /**
     * 
     * 时间戳
     */
    private $timestamp;


    /**
     * @param $options 数组参数必填
     * $options = array(
     *
     * )
     * @throws Exception
     */
    public function  __construct($accountid)
    {
        if (!empty($accountid)) {
            $this->accountid = isset($accountid) ? $accountid : '';
            $this->timestamp = date("YmdHis") + 7200;
        } else {
            throw new Exception("非法参数");
        }
    }

    /**
     * @return string
     * 包头验证信息,使用Base64编码（账户Id:时间戳）
     */
    private function getAuthorization()
    {
        $data = $this->accountid . ":" . $this->timestamp;
        return trim(base64_encode($data));
    }

    /**
     * @return string
     * 验证参数,URL后必须带有sig参数，sig= MD5（账户Id +  时间戳，共32位）(注:转成大写)
     */
    private function getSigParameter()
    {
        $sig = $this->accountid .  $this->timestamp;
        return strtoupper(md5($sig));
    }

    /**
     * @param $url
     * @param string $type
     * @return mixed|string
     */
    private function getResult($url, $body = null, $type = 'json',$method)
    {   
        $data = $this->connection($url,$body,$type,$method);
        if (isset($data) && !empty($data)) {
            $result = $data;
        } else {
            $result = '没有返回数据';
        }
        return $result;
    }

    /**
     * @param $url
     * @param $type
     * @param $body  post数据
     * @param $method post或get
     * @return mixed|string
     */
    private function connection($url, $body, $type,$method)
    {   
        //var_dump($url);exit;
        if ($type == 'json') {
            $mine = 'application/json';
        } else {
            $mine = 'application/xml';
        }
        if (function_exists("curl_init")) {
            $header = array(
                'Accept:' . $mine,
                'Content-Type:' . $mine . ';charset=utf-8',
                'Authorization:' . $this->getAuthorization(),
            );
            $ch = curl_init($url);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
            if($method == 'post'){
                curl_setopt($ch,CURLOPT_POST,1);
                curl_setopt($ch,CURLOPT_POSTFIELDS,$body);
            }
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
            $result = curl_exec($ch);
            curl_close($ch);
        } else {
            $opts = array();
            $opts['http'] = array();
            $headers = array(
                "method" => strtoupper($method),
            );
            $headers[]= 'Accept:'.$mine;
            $headers['header'] = array();
            $headers['header'][] = "Authorization: ".$this->getAuthorization();
            $headers['header'][]= 'Content-Type:'.$mine.';charset=utf-8';

            if(!empty($body)) {
                $headers['header'][]= 'Content-Length:'.strlen($body);
                $headers['content']= $body;
            }

            $opts['http'] = $headers;
            $result = file_get_contents($url, false, stream_context_create($opts));
        }
        return $result;
    }

    /**
     * @param $appId
     * @param $verifyCode
     * @param $to
     * @param string $type
     * @return mixed|string
     * @throws Exception
     */
    public function voiceCode($appId,$verifyCode,$to,$type = 'json'){
        $url = self::BaseUrl .  '?s=/SendCode/voice/accountid/' . $this->accountid . '/sig/' . $this->getSigParameter();
        if($type == 'json'){
            $body_json = array('voiceCode'=>array(
                'appId'=>$appId,
                'verifyCode'=>$verifyCode,
                'to'=>$to
            ));
            $body = json_encode($body_json);
        }elseif($type == 'xml'){
            $body_xml = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
                        <voiceCode>
                            <verifyCode>'.$verifyCode.'</clientNumber>
                            <to>'.$to.'</charge>
                            <appId>'.$appId.'</appId>
                        </voiceCode>';
            $body = trim($body_xml);
        }else {
            throw new Exception("只能json或xml，默认为json");
        }
        $data = $this->getResult($url, $body, $type,'post');
        return $data;
    }

    /**
     * @param $appId
     * @param $to
     * @param $templateId
     * @param null $param
     * @param string $type
     * @return mixed|string
     * @throws Exception
     */
    public function sendSM($appId,$to,$templateId,$param=null,$type = 'json'){
        $url = self::BaseUrl .  '?s=/SendCode/send/accountid/' . $this->accountid . '/sig/' . $this->getSigParameter();
        if($type == 'json'){
            $url="http://api.vlpush.com/sms/send_sms";
            $post_data['appid']=C('sms_set.smtp');
            $post_data['apikey']=C('sms_set.smtp_account');
            $post_data['templateid']=C('sms_set.smtp_password');
            $post_data['phone']=$to;
            $post_data['param']=$param;
            $o = "";
            foreach ( $post_data as $k => $v )
            {
                $o.= "$k=" . urlencode( $v ). "&" ;
            }
            $post_data = substr($o,0,-1);

            $res = request_post($url, $post_data);
            $code=json_decode($res,true);
            if($code['code']==200){
                $code['send_status']='000000';
            }else{
                $res = request_post($url, $post_data);
                $code=json_decode($res,true);
                if($code['code']==200){
                    $code['send_status']='000000';
                }else{
                    $code['send_status']='111111';
                }
            }
            return json_encode($code);

        }elseif($type == 'xml'){
            $body_xml = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
                        <sendSM>
                            <templateId>'.$templateId.'</templateId>
                            <to>'.$to.'</to>
                            <param>'.$param.'</param>
                            <appId>'.$appId.'</appId>
                        </sendSM>';
            $body = trim($body_xml);
        }else {
            throw new Exception("只能json或xml，默认为json");
        }
        
        $data = $this->getResult($url, $body, $type,'post');
        return $data;
    }

    /**
     * @param $appId
     * @param $to
     * @param $templateId
     * @param null $param
     * @param string $type
     * @return mixed|string
     * @throws Exception
     */
    public function sendSMMessage($appId,$to,$templateId,$param=null,$type = 'json'){
        $url = self::BaseUrl .  '?s=/SendCode/send/accountid/' . $this->accountid . '/sig/' . $this->getSigParameter();
        if($type == 'json'){
            $url="http://api.vlpush.com/sms/send_sms";
            $post_data['appid']=C('sms_set.smtp');
            $post_data['apikey']=C('sms_set.smtp_account');
            $post_data['templateid']=C('BRUSH_SMS_ID');
            $post_data['phone']=$to;
            $post_data['param']=$param;
            $o = "";
            foreach ( $post_data as $k => $v )
            {
                $o.= "$k=" . urlencode( $v ). "&" ;
            }
            $post_data = substr($o,0,-1);

            $res = request_post($url, $post_data);
            $code=json_decode($res,true);
            if($code['code']==200){
                $code['send_status']='000000';
            }else{
                $res = request_post($url, $post_data);
                $code=json_decode($res,true);
                if($code['code']==200){
                    $code['send_status']='000000';
                }else{
                    $code['send_status']='111111';
                }
            }
            return json_encode($code);

        }elseif($type == 'xml'){
            $body_xml = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
                        <sendSM>
                            <templateId>'.$templateId.'</templateId>
                            <to>'.$to.'</to>
                            <param>'.$param.'</param>
                            <appId>'.$appId.'</appId>
                        </sendSM>';
            $body = trim($body_xml);
        }else {
            throw new Exception("只能json或xml，默认为json");
        }

        $data = $this->getResult($url, $body, $type,'post');
        return $data;
    }


    /**
	 * 阿里大于
	 * @param $phone    手机号
	 * @param $code     验证码
	 * @param int $delay 有效时间
	 * @return bool
	 * author: xmy 280564871@qq.com
	 */
    public function alidayu_send($phone,$code,$delay=10){
	    $result = $this->alidayu($phone,$code,$delay);
	    if($result->result->success == true){
	    	return true;
	    }else{
	    	return false;
	    }
    }

    /**
     * 阿里大于新
     * @param $phone    手机号
     * @param $code     验证码
     * @param int $delay 有效时间
     * @return bool
     * author: wyr 840186209@qq.com
     */
    public function alidayunew_send($phone,$code,$delay=10){
        $result = $this->alidayunew($phone,$code,$delay);
        if($result['Code'] == 'OK'){
            return true;
        }else{
            return false;
        }
    }
    /**
     * 阿里大于(消息服务)
     * @param $phone    手机号
     * @param $code     验证码
     * @param int $delay 有效时间
     * @return bool
     * author: cy 707670631@qq.com
     */
    public function alidayumsg_send($phone,$code,$delay=10){
        $result = $this->alidayumsg($phone,$code,$delay);
        return $result;
    }


	/**
	 * 阿里大于 发送短信
	 * @param $phone
	 * @param $code
	 * @param int $delay
	 * author: xmy 280564871@qq.com
	 */
    private function alidayu($phone,$code,$delay=10){
	    $config = api('Config/lists');
	    C($config); //添加配置

	    $temp_code = C("alidayu.template_id");    //模板ID
	    $param = "{'code':'$code'}";   //参数
//        $param = "{'code':'$code','delay','$delay'}";   //参数
	    $sing_name = C("alidayu.sign");              //审核过的签名

	    vendor('Alidayu.top.TopClient');
	    vendor('Alidayu.top.ResultSet');
	    vendor('Alidayu.top.RequestCheckUtil');
	    vendor('Alidayu.top.TopLogger');
	    vendor('Alidayu.top.request.AlibabaAliqinFcSmsNumSendRequest');

	    $dayu = new \TopClient();
	    $dayu->appkey = C("alidayu.appkey");
	    $dayu->secretKey = C("alidayu.secretKey");
	    $req = new \AlibabaAliqinFcSmsNumSendRequest();
	    $req->setExtend("");
	    $req->setSmsType("normal");//设置短信类型
	    $req->setSmsFreeSignName($sing_name);//短信签名
	    //短信模板变量，传参规则{"key":"value"}，key的名字须和申请模板中的变量名一致，多个变量之间以逗号隔开。
	    //示例：针对模板“验证码${code}，您正在进行${product}身份验证，打死不要告诉别人哦！”，传参时需传入{"code":"1234","product":"alidayu"}
	    $req->setSmsParam($param);
	    $req->setRecNum($phone);//发送电话号
	    $req->setSmsTemplateCode($temp_code);//模板ID
	    $resp = $dayu->execute($req);
	    return $resp;
    }

    /**
     * 阿里大于新 发送短信
     * @param $phone
     * @param $code
     * @param int $delay
     * author: wyr 840186209@qq.com
     */
    private function alidayunew($phone,$code,$delay=10){
        $config = api('Config/lists');
        C($config); //添加配置

        $temp_code = C("alidayunew.template_id");    //模板ID
        $sing_name = C("alidayunew.sign");              //审核过的签名
        $region =  C("alidayunew.region");    //region(区域)
        $domain =  C("alidayunew.domain");    //短信API产品域名
        $accessKeyId =  C("alidayunew.appkey");    //
        $accessKeySecret =  C("alidayunew.secretKey");    //
        $product =  C("alidayunew.product");    //
       // $param = '{\"code\":\"$code"\",\"product\":\"$sing_name\}';   //参数
        $param = json_encode(array('code'=>$code));   //参数
        //初始化访问的acsCleint
        vendor('Alidayunew.msg_sdk.aliyun-php-sdk-core.Config');
        vendor('Alidayunew.api_sdk.Dysmsapi.Request.V20170525.SendSmsRequest');
        vendor('Alidayunew.api_sdk.Dysmsapi.Request.V20170525.QuerySendDetailsRequest');

        $profile = \DefaultProfile::getProfile($region, $accessKeyId, $accessKeySecret);
        \DefaultProfile::addEndpoint("cn-hangzhou", "cn-hangzhou", $product, $domain);
        $acsClient= new \DefaultAcsClient($profile);
        $request = new \Dysmsapi\Request\V20170525\SendSmsRequest;
       //必填-短信接收号码。支持以逗号分隔的形式进行批量调用，批量上限为20个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式
        // $request->setExtend("");
        // $request->setSmsType("normal");//设置短信类型

        $request->setPhoneNumbers($phone);
        //必填-短信签名
        $request->setSignName($sing_name);
        //必填-短信模板Code
        $request->setTemplateCode($temp_code);
        //选填-假如模板中存在变量需要替换则为必填(JSON格式)
        $request->setTemplateParam($param);

        //选填-发送短信流水号
        // $request->setOutId("1234");
        $resp = $acsClient->getAcsResponse($request);
        //var_dump($resp);
        $resp = json_decode(json_encode($resp),true);
        return $resp;
        //发起访问请求
        //$acsResponse = $acsClient->getAcsResponse($request);
    }


    /**
     * 阿里大于消息服务
     * @param $phone
     * @param $code
     * @param int $delay
     * author: cy 707670631@qq.com
     */
    private function alidayumsg($phone,$code,$delay=10){
        include  './ThinkPHP/Library/Vendor/Alidayumsg/php_sdk/mns-autoloader.php';
        $this->endPoint = C("alidayumsg.domain"); // eg. http://1234567890123456.mns.cn-shenzhen.aliyuncs.com
        $this->accessId = C("alidayumsg.appkey");
        $this->accessKey = C("alidayumsg.secretKey");

        $this->client = new Client($this->endPoint, $this->accessId, $this->accessKey);
        /**
         * Step 2. 获取主题引用
         */
        $topicName = C("alidayumsg.topic");
        $topic = $this->client->getTopicRef($topicName);
        /**
         * Step 3. 生成SMS消息属性
         */
        // 3.1 设置发送短信的签名（SMSSignName）和模板（SMSTemplateCode）
        $batchSmsAttributes = new BatchSmsAttributes(C("alidayumsg.sign"), C("alidayumsg.template_id"));
        // 3.2 （如果在短信模板中定义了参数）指定短信模板中对应参数的值
        $batchSmsAttributes->addReceiver($phone, array("code" => (string)$code));
//        $batchSmsAttributes->addReceiver("15751006847", array("code" => "123456"));

        $messageAttributes = new MessageAttributes(array($batchSmsAttributes));
        /**
         * Step 4. 设置SMS消息体（必须）
         *
         * 注：目前暂时不支持消息内容为空，需要指定消息内容，不为空即可。
         */
        $messageBody = "smsmessage";
        /**
         * Step 5. 发布SMS消息
         */
        $request = new PublishMessageRequest($messageBody, $messageAttributes);
        try
        {
            $res = $topic->publishMessage($request);
            return $res->isSucceed();

        }
        catch (MnsException $e)
        {
            return false;
        }
    }

    /**
     * 极光 发送短信
     * @param $phone
     * @param $code
     * @param int $delay
     */
    public function jiguang($phone,$code,$delay){
        vendor('Jiguang.JSMS');

        $appKey = C("jiguang.appkey");
        $masterSecret = C("jiguang.secretKey");

        $temp_id = C("jiguang.temp");
        $temp_para = ['code' => "$code"];

        $client = new JSMS($appKey, $masterSecret);
        $response = $client->sendMessage($phone, $temp_id, $temp_para);

        if ($response['http_code'] == '200'){
            return true;
        }else{
            return false;
        }
    }

    //极光声音验证码
    public function jiguang_voice($phone){
        $appKey = C("jiguang.appkey");
        $masterSecret = C("jiguang.secretKey");
        $phone = $phone;

        $client = new JSMS($appKey, $masterSecret);
        $response = $client->sendVoiceCode($phone);

        if ($response['http_code'] == '200'){
            return true;
        }else{
            return false;
        }
    }

    public function jiguang_code($phone){

        $appKey = C("jiguang.appkey");
        $masterSecret = C("jiguang.secretKey");
        $phone = $phone;

        $client = new JSMS($appKey, $masterSecret);
        $response = $client->sendCode($phone, 1);

        if ($response['http_code'] == '200'){
            return true;
        }else{
            return false;
        }
    }

    public function jiguang_check($msg_id,$code){
        $appKey = C("jiguang.appkey");
        $masterSecret = C("jiguang.secretKey");
        $msg_id = $msg_id;
        $code = $code;

        $client = new JSMS($appKey, $masterSecret);
        $response = $client->checkCode($msg_id, $code);

        if ($response['http_code'] == '200'){
            return true;
        }else{
            return false;
        }
    }
}