<?php

namespace App\Domains\Real\Commands\Sync;

use Carbon\Carbon;
use App\Models\Real\Company;
use Illuminate\Support\Facades\DB;
use App\Domains\Real\Repositories\CompanyRepository;

class CompanySync extends Command
{
    protected $name = 'sync:company';

    protected $description = '同步RD企业数据';

    public function handle()
    {
        $datetime = $this->getDateTime();

        $sql = "SELECT c.custom_no AS id,c.name,c.create_time AS created_at FROM jxc_user a 
            INNER JOIN jxc_user_custom_relation b ON a.id=b.uid 
            INNER JOIN jxc_custom c ON b.custom_no=c.custom_no AND c.del=0 
            WHERE a.parent_user IN (SELECT id FROM jxc_user WHERE parent_user=3 AND role_tag='normal')";

        $data = DB::connection('real')->select($sql);
        
        foreach ($data as &$item) {
            $item = (array)$item;
            $item['created_at'] = Carbon::parse($item['created_at']);
            $item['updated_at'] = date('Y-m-d H:i:s');
        }
        
        Company::replace($data);

        app(CompanyRepository::class)->forgetCached();
    }
}