<?php

namespace App\Models\Collect;

use App\Models\Base;

class CollectTask extends Base
{
    //设置关联表名
    protected $table = 'gl_collect_task';

    //连接数据库
    protected $connection = 'custom_mysql';

    const STATUS_UN = 0;
    const STATUS_ING = 1;
    const STATUS_COM= 2;

    public static function _insert($url, $project_id, $source, $source_id)
    {
        if(!$url){
            return;
        }

        $url_arr = parse_url($url);

        $data = [
            'project_id' => $project_id,
            'source' => $source,
            'source_id' => $source_id,
            'domain' => $url_arr['host'],
            'route' => $url_arr['path']
        ];

        $task = self::where($data)->first();
        if(!$task){
            $data['created_at'] = $data['updated_at'] = date('Y-m-d H:i:s');
            self::insert($data);
        }
    }
}