<?php

namespace App\Jobs;

use App\Models\File\ErrorFile;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class SyncImageFileJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    public $tries = 3; // 可配置任务重试次数

    protected $param;

    /**
     * Create a new job instance.
     *
     * @param  CopyImageFile  $event
     * @return void
     */
    public function __construct($data)
    {
        $this->param = $data;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $file_path = $this->getUrl($this->param['path'].'/'.$this->param['name'], 0,$this->param['location']);
        $cmd = 'curl -F "file_path='.$file_path.'" -F "save_path=/www/wwwroot/cos'.$this->param['path'].'" https://v6-file.globalso.com/upload.php';
        echo date('Y-m-d H:i:s') . ' | ' . $cmd . PHP_EOL;
        $code = shell_exec($cmd);
        if(200 != (int)$code){
            $errorFileModel = new ErrorFile();
            $errorFileModel->add(['path'=>$this->param['path'].'/'.$this->param['name']]);
        }
        return true;
    }

    /**
     * @remark :获取图片文件链接
     * @name   :getUrl
     * @author :lyh
     * @method :post
     * @time   :2024/5/22 11:53
     */
    public function getUrl($path,$storage_type,$location){
        if(is_array($path)){
            $url =[];
            foreach ($path as $v){
                $url[] = $this->getUrl($v,$storage_type,$location);
            }
        }else{
            if(empty($path)){
                return '';
            }
            if((strpos($path,'https://')!== false) || (strpos($path,'http://') !== false)){
                return  $path;
            }
            if(substr($path,0,2) == '//'){
                return 'https:'.$path;
            }
            if($location == 0){
                $cos = config('filesystems.disks.cos');
                $cosCdn = ($storage_type == 0) ? $cos['cdn'] : $cos['cdn1'];
                $url = $cosCdn.$path;
            }else{
                $s3 = config('filesystems.disks.s3');
                $cdn = $s3['cdn'];
                $url = $cdn.$path;
            }
        }
        return $url;
    }
}