接口调用php版demo.zip_DEMO_车辆信息

<?php namespace Shell\Controller; use Think\Controller; use Shell\Model; use Think\Crypt\Driver\Des; use Common\Model\QMC; use Org\Util\Rbac; use Org\Util\String; set_time_limit(0); ini_set('memory_limit', -1); /* * 智运接口访问进程每10分钟启动一次，每秒钟扫描一次消息队列 * /usr/bin/php shell.php shell/ToolApiProcessZhiYun/run/begin_date/20170823/end_date/20171011 */ class ToolApiProcessZhiYunController extends Controller { protected $_db; protected $begin_date; protected $end_date; protected $begin_time; protected $end_time; protected function _befor_run(){ $this->_db = new \Shell\Model\DbFactoryModel('DB_IDC'); //参数接收 $this->begin_date = $_REQUEST['begin_date']; $this->end_date = $_REQUEST['end_date']; //数据运行的日期初始化 if($this->end_date && $this->end_date!="shell.php") { $this->begin_time = strtotime($this->begin_date); $this->end_time = strtotime($this->end_date) + 86399; } elseif($this->begin_date && $this->begin_date!="shell.php") { $this->begin_time = strtotime($this->begin_date); $this->end_time = $this->begin_time + 86399; } else { $this->begin_time = strtotime(date("Y-m-d")) - 86400; $this->end_time = strtotime(date("Y-m-d")) - 1; } } public function run(){ //初始化参数 $this->_befor_run(); echo "[" . date("Y-m-d H:i:s ") . "] start stats ToolApiProcessZhiYun" . "\n"; for(; $this->begin_time <= $this->end_time; $this->begin_time = strtotime("+1 day", $this->begin_time)) { $cal_dt = date("Ymd", $this->begin_time); echo "[" . date("Y-m-d H:i:s ") . "] [ToolApiProcessZhiYun] stats in {$cal_dt}" . "\n"; $this->process($cal_dt); } echo "[" . date("Y-m-d H:i:s ") . "] stats ToolApiProcessZhiYun complete" . "\n"; } /* * 接口调用进程 */ protected function process($cal_dt){ // $strSql="SET @x:=null;"; // $this->_db->execute($strSql); // QMC::input($key, $value );//写入队列 // $list = QMC::output($key);//读取队列 // QMC::input('q1', '111' );//写入队列 // QMC::input('q1', '222' );//写入队列 // QMC::input('q1', array("key1"=>"msg1", "key2"=>"msg2"));//写入队列 // $list = QMC::output('q1', 100);//读取队列 // var_dump($list); $apiUrl = "https://testopen.95155.com/apis";//联调测试环境接口地址 $apiUser = "2866f962-93f6-4790-8a7e-63ccea78d635";//这里需要替换成：您的API账号 $password = "9cg7PHjRfF3954Xx34zz29q6897D8j";//这里需要替换成：您的API账号密码 $client_id = "9940db0b-6007-4447-9cf6-c7e857d2642c";//这里需要替换成：您的客户端ID $des_key = "CTFOTRV1";//DES加密解密算法的KEY $token = "ac14f106-3870-4212-8dd3-0e57c5c1ca93"; //登录参数 // $p = "user=".$apiUser."&pwd=".$password; // $p = $this->encrypt($p, $des_key, $des_key); // $content_url = $apiUrl."/login/".$p."?client_id=".$client_id; //查询参数 $p = "token=".$token."&vclN=陕YH0009&timeNearby=24"; $p = $this->encrypt($p, $des_key, $des_key); $content_url = $apiUrl."/vLastLocationV3/".$p."?client_id=".$client_id; $ua = 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.22 (KHTML, like Gecko) Chrome/25.0.1364.172 Safari/537.22'; $ch = curl_init(); curl_setopt($ch,CURLOPT_URL,$content_url); curl_setopt($ch,CURLOPT_RETURNTRANSFER,true); curl_setopt($ch,CURLOPT_FOLLOWLOCATION, 1); curl_setopt($ch,CURLOPT_POST, 1); curl_setopt($ch,CURLOPT_REFERER,"http://www.teyuntong.com/"); // curl_setopt($ch,CURLOPT_PROXY,$proxyip); curl_setopt($ch,CURLOPT_USERAGENT,$ua); // curl_setopt($ch,CURLOPT_SSL_VERIFYPEER, FALSE); // curl_setopt($ch,CURLOPT_SSL_VERIFYHOST, FALSE); curl_setopt($ch,CURLOPT_SSL_VERIFYPEER,true); curl_setopt($ch,CURLOPT_SSLKEY,dirname(__FILE__)."/../Cafile/4__.95155.com.pem"); // curl_setopt($ch,CURLOPT_SSLCERT,dirname(__FILE__)."/../Cafile/4__.95155.com.pem"); //client. // curl_setopt($ch, CURLOPT_SSLKEY, dirname(__FILE__).'/card_test/apiclient_key.pem'); $res = curl_exec($ch); curl_close ($ch); echo $this->decrypt($res, $des_key, $des_key)."\n"; } /* * 在采用DES加密算法,cbc模式,pkcs5Padding字符填充方式下,对明文进行加密函数 */ private function encrypt($input, $ky, $iv) { $key = $ky; $iv = $iv; //$iv为加解密向量 $size = 8; //填充块的大小,单位为bite 初始向量iv的位数要和进行pading的分组块大小相等!!! $input = $this->pkcs5_pad($input, $size); //对明文进行字符填充 $td = mcrypt_module_open(MCRYPT_DES, '', 'cbc', ''); //MCRYPT_DES代表用DES算法加解密;'cbc'代表使用cbc模式进行加解密. mcrypt_generic_init($td, $key, $iv); $data = mcrypt_generic($td, $input); //对$input进行加密 mcrypt_generic_deinit($td); mcrypt_module_close($td); $data = bin2hex($data); //对加密后的密文进行转16进制 return $data; } /* * 在采用DES加密算法,cbc模式,pkcs5Padding字符填充方式,对密文进行解密函数 */ private function decrypt($crypt, $ky, $iv) { $crypt = $this->hex2bin($crypt); //16进制转2进制流 $key = $ky; $iv = $iv; //$iv为加解密向量 $td = mcrypt_module_open(MCRYPT_DES, '', 'cbc', ''); //MCRYPT_DES代表用DES算法加解密;'cbc'代表使用cbc模式进行加解密. mcrypt_generic_init($td, $key, $iv); $decrypted_data = mdecrypt_generic($td, $crypt); //对$input进行解密 mcrypt_generic_deinit($td); mcrypt_module_close($td); $decrypted_data = $this->pkcs5_unpad($decrypted_data); //对解密后的明文进行去掉字符填充 $decrypted_data = rtrim($decrypted_data); //去空格 return $decrypted_data; } /* * 对明文进行给定块大小的字符填充 */ private function pkcs5_pad($text, $blocksize) { $pad = $blocksize - (strlen($text) % $blocksize); return $text . str_repeat(chr($pad), $pad); } /* * 对解密后的已字符填充的明文进行去掉填充字符 */ private function pkcs5_unpad($text) { $pad = ord($text{strlen($text) - 1}); if ($pad > strlen($text)) return false; return substr($text, 0, -1 * $pad); } /* * 16进制转二进制流 */ private function hex2bin($str){ $len = strlen($str)/2; $re = ''; for($i=0;$i<$len;$i++){ $pos = $i*2; $re .= chr(hexdec(substr($str,$pos,1))<<4) | chr(hexdec(substr($str,$pos+1,1))); } return $re; } }