require_once \'apiAccess_token.php\';
//require_once \'apiOpenid.php\';
require_once \'../../includes/config.inc.php\';
header(\'Content-Type: text/html; charset=utf-8\');
error_reporting(0);
if(!empty($access_token)){
$sql = "select openid from `weiuser` ";
$openid = $mysqli->get($sql) ;
echo "<pre>";
$num =ceil(count($openid));
$sql = "insert into `weijilu`(\'worker\',\'opercode\',\'openid\',\'time\',\'text\')";
for($i=0;$i<$num;$i++){
$openid1 = $openid[$i][\'openid\'];
$url="https://api.weixin.qq.com/cgi-bin/customservice/getrecord?access_token=$access_token";
$arr=array(
"starttime" =>123456789,
"endtime" => 987654321,
"openid" => "$openid1",
"pagesize" => 10,
"pageindex" => 1,
);
$json = json_encode($arr);
p($url);
p($arr);
p($json);
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, $json);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
$output = curl_exec($ch);
curl_close($ch);
$jsoninfo = json_decode($output, true);
$worker = $jsoninfo[\'recordlist\'][\'worker\'];
$opercode = $jsoninfo[\'recordlist\'][\'opercode\'];
$time = $jsoninfo[\'recordlist\'][\'time\'];
$text = $jsoninfo[\'recordlist\'][\'text\'];
p($output);
if(!empty($worker) && !empty($opercode) && !empty($time) && !empty($text)){
echo 111;
$sql.="value(\'".$worker."\',\'".$opercode."\',\'".$openid1."\',\'".$time."\',\'".$text."\')";
}else{
echo "暂时没有聊天记录";
return false;
}
}
$mysqli -> execute($sql);
}