query($sql);
$rowset = $result->fetchAll(PDO::FETCH_ASSOC);
foreach ($rowset as $key => $value) {
$token =getAccesstoken();
$result = http_request('https://api.weixin.qq.com/cgi-bin/user/info?access_token='.$token.'&openid='.$value['OPENID'].'&lang=zh_CN');
$res = (array)json_decode($result);
if(isset($res['subscribe']) && $res['subscribe']==1){
$sql = "update wechat_user set CITY ='".$res['city']."', is_register =1,NICKNAME ='".$res['nickname']."',SEX =".$res['sex'].",COUNTRY ='".$res['country']."',PROVINCE ='".$res['province']."' where id =".$value['ID'];
$result = $pdo->query($sql);
}elseif($value['IS_REGISTER']==1){
$sql = "update wechat_user set is_register =2 where id =".$value['ID'];
$result = $pdo->query($sql);
}
}
die;