'; print_r($result);exit; $_PDO=DB_PDO::getInstance( conf::$DB_CONF ); $total_num = 0; $ins_num = 0; $already = 0; foreach($result['data']['data'] as $k=>$v){ $total_num++; if(!if_exists($ks_id)){ $sql = format_sql($v, 'ks_users'); }else{ $already++; continue; } $stmt = $_PDO->prepare($sql); $stmt->execute(); $res = $_PDO->lastinsertid(); if($res){ $ins_num++; } } echo "\n总共".$total_num."条数据"; echo "\n成功插入".$ins_num."条数据"; echo "\n已存在".$already."条数据"; function curl_get($url){ $header = array( 'Origin: https://www.caasdata.com', 'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/69.0.3497.100 Safari/537.36', 'Authorization: Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwczovL2FwaS5kYXRhLmNhYXNkYXRhLmNvbS91c2VycyIsImlhdCI6MTU1NjQzNjU2NywiZXhwIjoxNTU5MDI4NTY3LCJuYmYiOjE1NTY0MzY1NjcsImp0aSI6Ik45ekZrRFBadEVwT2pKSFgiLCJzdWIiOiI2OTY2NyIsIkxvZ2luVG9rZW4iOiJJakZlejFUV3lCRkJ3In0.DkA2GnIZKm-dSoi0mHGOnZ-F2-0d1XuS3E6Gr2HGXNw', ); $ch = curl_init();//初始化curl curl_setopt($ch, CURLOPT_URL,$url); curl_setopt($ch, CURLOPT_HEADER, 0);// curl_setopt($ch, CURLOPT_HTTPHEADER, $header); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);//要求结果为字符串且输出到屏幕上 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);//绕过ssl验证 curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); //curl_setopt($ch, CURLOPT_POST, 1);//post提交方式 //curl_setopt($ch, CURLOPT_POSTFIELDS, $param); $data = curl_exec($ch);//运行curl curl_close($ch); return json_decode($data,true); } function curl_post($url, $param){ $auth_token = isset($param['auth_token'])? $param['auth_token'] : ''; unset($param['auth_token']); $header = array('Content-Type:application/x-www-form-urlencoded;charset=utf-8','auth_token:'.$auth_token); $ch = curl_init();//初始化curl curl_setopt($ch, CURLOPT_URL,$url); curl_setopt($ch, CURLOPT_HEADER, 0);// curl_setopt($ch, CURLOPT_HTTPHEADER, $header); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);//要求结果为字符串且输出到屏幕上 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);//绕过ssl验证 curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); curl_setopt($ch, CURLOPT_POST, 1);//post提交方式 curl_setopt($ch, CURLOPT_POSTFIELDS, $param); $data = curl_exec($ch);//运行curl curl_close($ch); return json_decode($data,true); } function if_exists($ks_id){ $sql = "select id from ks_users where ks_id = {$ks_id} limit 1"; $stmt = $_PDO->prepare($sql); $stmt->execute(); $res = $stmt->fetch(PDO::FETCH_ASSOC); if($res){ return true; } return false; } function format_sql($data, $table){ if(empty($data)) return false; $columns = ''; $values = ''; foreach($data as $key=>$val){ if($key == 'id'){ $key = 'ks_id'; } $columns .= '`'.$key.'`,'; if(is_array($val)){ $val = json_encode($val); } $values .= "'".$val."',"; } $columns = trim($columns, ','); $values = trim($values,','); $sql = 'insert into '.$table.' ('.$columns.') values('.$values.')'; return $sql; }