$page = $this->get('page', '1');
$pageSize = 100;
$doPage = ($page - 1) * $pageSize;
### 查数据库
$user = Yii::$app->db->createCommand("
SELECT * FROM (
SELECT user_id FROM `bz_user_goods` GROUP BY user_id
) as uc LEFT JOIN `bz_user` ON uc.user_id = bz_user.id WHERE `man_dian_id` IS NULL AND `realname` IS NOT NULL AND `realname` != '' LIMIT {$pageSize} OFFSET {$doPage}
")->queryAll();
if (!$user){
exit('执行完毕');
}
$url = 'http://test.pdshucang.com:86/userImport.api';
$error = [];
foreach ($user as $key => $value) {
$service = RequestService::loadModel([
'method' => RequestService::getMethodPost(),
'paramsPos' => RequestService::getParamsPosJson(),
'header' => ['appid' => '57nN2ks3_1','appsercret' => '943deb4049f7cd7cdaf434ec784a7034'],
'params' => [
'mobile' => $user[$key]['phone'],
'name' => $user[$key]['realname'],
'number' =>$user[$key]['identity_number']
],
'url' => $url
]);
if (!$service->doRequest()) {
$errors = ToolsService::getModelError($service->getErrors());
$error[$value['id']]['msg'] = $errors['msg'];
break;
}
$result = $service->getResult();
if ($result['no'] != 200) {
$error[$value['id']]['msg'] = $result['msg'];
}
if(!empty($result['data'])){
$resultId = $result['data'];// $result['data']['id'];
$oldId = $user[$key]['id'];
$result = Yii::$app->db->createCommand("
UPDATE `bz_user` SET `man_dian_id` = '{$resultId}' WHERE `id` = '{$oldId}'
")->execute();
}
}
$infos = json_encode($error);
$url = Url::toRoute(['/site/test-user', 'page' => $page + 1]);
exit("
执行完毕 , 日志: {$infos} 第几{$page}页, 正在跳转下一页.
");