<?php
namespace app\api\job;

use think\queue\Job;
use sftp\Sftp;

class mysftp {
    
    public function push(Job $job, $data){
        $job->delete();
        //链接sftp服务器（凭证走 dbpush 配置，历史值兜底）
        $cred = config('dbpush.credentials.portico');
        $config['host'] = isset($cred['host']) ? $cred['host'] : 'ftp.portico.org';
        $config['port'] = isset($cred['port']) ? $cred['port'] : 22;
        $config['username'] = isset($cred['user']) ? $cred['user'] : "TMR";
        $config['password'] = isset($cred['pass']) ? $cred['pass'] : "h6EHD8";
        $sftp_obj = new Sftp($config);
        $sftp_obj->upftp($data['local'],$data['remote']);
    }

}