43 lines
1.2 KiB
PHP
43 lines
1.2 KiB
PHP
<?php
|
|
|
|
namespace App\Domains\Virtual\Commands\Sync;
|
|
|
|
use Carbon\Carbon;
|
|
use App\Models\Virtual\Company;
|
|
use Illuminate\Support\Facades\DB;
|
|
use App\Domains\Virtual\Services\CommonService;
|
|
use App\Domains\Virtual\Repositories\CompanyRepository;
|
|
|
|
class CompanySync extends Command
|
|
{
|
|
protected $name = 'virtual:sync-company';
|
|
|
|
protected $description = '同步VD企业数据';
|
|
|
|
public function handle()
|
|
{
|
|
$datetime = $this->getDateTime();
|
|
|
|
$data = DB::connection('vd_old')->table('ckb_company')->select([
|
|
'id',
|
|
'unicom_name as name',
|
|
'create_time as created_at',
|
|
'update_time as updated_at',
|
|
'del'
|
|
])->get()->toArray();
|
|
|
|
foreach ($data as &$item) {
|
|
$item = (array)$item;
|
|
$item['sn'] = CommonService::stringifyCompanyId($item['id']);
|
|
$item['created_at'] = date('Y-m-d H:i:s', $item['created_at']);
|
|
$item['updated_at'] = date('Y-m-d H:i:s', $item['updated_at']);
|
|
$item['deleted_at'] = $item['del'] ? $item['updated_at'] : null;
|
|
unset($item['del']);
|
|
}
|
|
|
|
Company::upsert($data, 'id');
|
|
|
|
app(CompanyRepository::class)->forgetCached();
|
|
}
|
|
}
|