正在显示
1 个修改的文件
包含
30 行增加
和
20 行删除
| @@ -9,6 +9,7 @@ | @@ -9,6 +9,7 @@ | ||
| 9 | 9 | ||
| 10 | namespace App\Console\Commands\Sync; | 10 | namespace App\Console\Commands\Sync; |
| 11 | 11 | ||
| 12 | +use App\Models\Manage\Mobile; | ||
| 12 | use App\Models\User\User; | 13 | use App\Models\User\User; |
| 13 | use Illuminate\Console\Command; | 14 | use Illuminate\Console\Command; |
| 14 | use Illuminate\Support\Facades\DB; | 15 | use Illuminate\Support\Facades\DB; |
| @@ -40,31 +41,40 @@ class SyncMobile extends Command | @@ -40,31 +41,40 @@ class SyncMobile extends Command | ||
| 40 | $url = 'https://www.quanqiusou.cn/extend_api/saas/get_phone.php'; | 41 | $url = 'https://www.quanqiusou.cn/extend_api/saas/get_phone.php'; |
| 41 | // $data = curlGet($url);//TODO::获取号码库 | 42 | // $data = curlGet($url);//TODO::获取号码库 |
| 42 | $client = new \GuzzleHttp\Client(); | 43 | $client = new \GuzzleHttp\Client(); |
| 43 | - $data = $client->request('GET', $url, [ | ||
| 44 | - 'proxy' => env('CURL_PROXY'), // 代理服务器地址和端口号 | ||
| 45 | - ])->getBody()->getContents(); | ||
| 46 | - dd($data); | 44 | + try { |
| 45 | + $data = $client->request('GET', $url, [ | ||
| 46 | + 'proxy' => env('CURL_PROXY'), // 代理服务器地址和端口号 | ||
| 47 | + ])->getBody()->getContents(); | ||
| 48 | + }catch (\Exception $e){ | ||
| 49 | + echo date('Y-m-d H:i:s').':未拉起到数据'.PHP_EOL; | ||
| 50 | + } | ||
| 47 | if(!empty($data)){ | 51 | if(!empty($data)){ |
| 52 | + $mobile = new Mobile(); | ||
| 53 | + $mobile->truncate(); | ||
| 48 | $data = json_decode($data, true); | 54 | $data = json_decode($data, true); |
| 49 | - DB::table('gl_mobile')->delete(); | ||
| 50 | - $create_time = date('Y-m-d H:i:s'); | ||
| 51 | - foreach ($data as $v){ | 55 | + $userModel = new User(); |
| 56 | + foreach ($data as $mobile){ | ||
| 52 | $param = [ | 57 | $param = [ |
| 53 | - 'mobile'=>$v, | ||
| 54 | - 'created_at'=>$create_time | 58 | + 'mobile'=>$mobile, |
| 59 | + 'created_at'=>date('Y-m-d H:i:s') | ||
| 55 | ]; | 60 | ]; |
| 56 | - DB::table('gl_mobile')->insert($param); | ||
| 57 | - } | ||
| 58 | - $userModel = new User(); | ||
| 59 | - try { | ||
| 60 | - $data[] = '13083988828'; | ||
| 61 | - $data[] = '6591559603'; | ||
| 62 | - $userModel->edit(['status'=>1],['project_id'=>1,'mobile'=>['not in',$data]]); | ||
| 63 | - $userModel->edit(['status'=>0],['project_id'=>1,'mobile'=>['in',$data]]); | ||
| 64 | - }catch (\Exception $e){ | ||
| 65 | - echo date('Y-m-d H:i:s') . 'error' . PHP_EOL; | 61 | + $mobile->insert($param); |
| 62 | + //查看当前用户是否存在 | ||
| 63 | + $info = $userModel->read(['mobile'=>$mobile,'project_id'=>1]); | ||
| 64 | + if($info === false){ | ||
| 65 | + $data = [ | ||
| 66 | + 'mobile'=>$mobile, | ||
| 67 | + 'password'=>base64_encode(md5('123456')), | ||
| 68 | + 'project_id'=>1, | ||
| 69 | + 'name'=>$mobile, | ||
| 70 | + 'type'=>$userModel::TYPE_ONE | ||
| 71 | + ]; | ||
| 72 | + $userModel->add($data); | ||
| 73 | + } | ||
| 66 | } | 74 | } |
| 75 | + $data[] = '13083988828'; | ||
| 76 | + $userModel->edit(['status'=>1],['project_id'=>1,'mobile'=>['not in',$data]]); | ||
| 77 | + $userModel->edit(['status'=>0],['project_id'=>1,'mobile'=>['in',$data]]); | ||
| 67 | } | 78 | } |
| 68 | } | 79 | } |
| 69 | - | ||
| 70 | } | 80 | } |
-
请 注册 或 登录 后发表评论