/*
* title:php实现curl递归调用分页api数据，并生成到sql写入语句
*
* author:范二狗(笔名)
* QQ:1149523905
*
@api_url 接口地址
@args 接口所需参数
*/
function ec_getToken($api_url,$args ){ // 模拟提交数据函数
$curl = curl_init(); // 启动一个CURL会话
curl_setopt($curl, CURLOPT_URL, $api_url); // 要访问的地址
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE); // 对认证证书来源的检查
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE); // 从证书中检查SSL加密算法是否存在
curl_setopt($curl, CURLOPT_POST, 1); // 发送一个常规的Post请求
curl_setopt($curl, CURLOPT_POSTFIELDS, $args); // Post提交的数据包
curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
curl_setopt($curl, CURLOPT_HEADER, 0); // 显示返回的Header区域内容
curl_setopt($curl, CURLOPT_RETURNTRANSFER,1); //相当关键，这句话是让curl_exec($ch)返回的结果可以进行赋值给其他的变量进行，json的数据操作，如果没有这句话，则curl返回的数据不可以进行人为的去操作（如json_decode等格式操作）
$tmpInfo = curl_exec($curl); // 执行操作
if (curl_errno($curl)) {
echo 'Errno'.curl_error($curl);//捕抓异常
}
curl_close($curl); // 关闭CURL会话
return $tmpInfo; // 返回数据
}
$r1= ec_getToken("https://open.xxx.com/auth/accesstoken",'{"appId":"123456789","appSecret":"wwwwaaaacccc"}');//获取token
$json_string = json_decode($r1,true);//解析token的json数据格式为数组
$ec_token=$json_string['data']['accessToken'];//获取数组中包含token的字段值
/*
ec_getData()函数实现获取服务器api单页数据
@api_url 接口地址
@args 接口所需参数
@$token_companyId 服务端客户标识
*/
function ec_getData($api_url,$args,$token_companyId){
$curl = curl_init(); // 启动一个CURL会话
curl_setopt($curl, CURLOPT_URL, $api_url); // 要访问的地址
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE); // 对认证证书来源的检查
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE); // 从证书中检查SSL加密算法是否存在
curl_setopt($curl, CURLOPT_POST, 1); // 发送一个常规的Post请求
curl_setopt($curl, CURLOPT_POSTFIELDS, $args); // Post提交的数据包
curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
curl_setopt($curl, CURLOPT_HEADER, 0); // 显示返回的Header区域内容
curl_setopt($curl, CURLOPT_HTTPHEADER,$token_companyId );//这里设置token验证权限
curl_setopt($curl, CURLOPT_RETURNTRANSFER,1); //相当关键，这句话是让curl_exec($ch)返回的结果可以进行赋值给其他的变量进行，json的数据操作，如果没有这句话，则curl返回的数据不可以进行人为的去操作（如json_decode等格式操作）
$tmpInfo = curl_exec($curl); // 执行操作
if (curl_errno($curl)) {
echo 'Errno'.curl_error($curl);//捕抓异常
}
curl_close($curl); // 关闭CURL会话
return $tmpInfo; // 返回数据
}
//定义一个递归调用函数
function getData($crmId,$token){
if($crmId==""){
return false;
}
$crm_details_json= ec_getData("https://open.xxx.com/customer/rangeQueryCustomer",'{"createTime": "2018-02-01;2018-02-02","lastCrmId":'.$crmId.'
}'
,array ('Authorization:'.$token,'CORP_ID:xxxx'));
$employee = json_decode($crm_details_json,true);
$data=$employee['data']['crmDetails'];//获取数组中某个子数组
$data_info=end($data); //获取最后一个数组
foreach ($data as $key => $value) {
/***生成一个sql插入语句***/////
echo "insert into crminfo(crmId,moblie,name) values('".$value['crmId']."','".$value['mobile']."','".$value['name']."'),";
}
return getData($data_info['crmId'],$token);//获取最后一个数组crmid
}
getData("0",$ec_token);//调用递归
网友评论