PHP-sftp文件上傳

個人博客地址https://xgs888.top/post/view?id=57

PHP的sftp文件上傳；在框架thinkphp5中使用；

主要用到的sftp函數如下；

ssh3_connect(host,port) 鏈接信息

ssh3_auth_password($con,username,password)登錄驗證

copy();//服務器之間的文件復制；

要求如下

需要的文件字段信息見附件內容，注意最后一列帶年月日時分秒格式；

上傳前，需要先判斷相應目錄下是否有上一天日期文件夾，若無，則創建，若有，則直接上傳至相應文件夾下，如附件所示

thinkphp5中提供了一個非composer安裝的第三方類庫目錄extend

在extend目錄下創建一個sftp目錄創建sftp.php的類

namespace sftp;
class Sftp
{
  
	 // 初始配置為NULL
	 private $config = NULL;
	 // 連接為NULL
	 private $conn = NULL;
	 //sftp resource 
	 private $ressftp = NULL;
	 // 初始化
	 public function __construct($config)
	 {
		 $this->config = $config;
		 $this->connect();
	 }
	  
	 
	 public function connect()
	 {
	  
		 $this->conn = ssh3_connect($this->config['host'], $this->config['port']);
		 if( ssh3_auth_password($this->conn, $this->config['username'], $this->config['password']))
		 {
		 	$this->ressftp = ssh3_sftp($this->conn);
		   
		 }else{ 
		  	echo "用戶名或密碼錯誤";
		 }
	  
	 }
	  
	 // 下載文件
	 public function downftp($remote, $local)
	 { 
		 return copy("ssh3.sftp://{$ressftp}".$remote, $local);
	 }
	  
	 // 文件上傳
	 public function upftp( $local,$remote, $file_mode = 0777)
	 { 
	 	return copy($local,"ssh3.sftp://{$this->ressftp}".$remote); 
	  
	 }
	 //創建目錄
	 public function ssh3_sftp_mchkdir($path)  //使用創建目錄循環
	{
		ssh3_sftp_mkdir($this->ressftp, $path,0777);
	}
	//判段目錄是否存在
	public function ssh3_dir_exits($dir){
		return file_exists("ssh3.sftp://{$this->ressftp}".$dir);
	}
  
}

下面在控制器里面調用

namespace app\index\controller;

use think\Controller;
use \sftp\sftp;
class Index extends Controller
{
    public function index()
    {
    	ini_set('max_execution_time','0');//設置永不超時
    	$time = date('ymd',time()-24*3600);//上一天的日期

    	$name = "mac".$time;
         $data = db('table')->where("add_date='2017-10-09'")->select();//查詢數據
         $fp = fopen("$name.csv","a"); //打開csv文件，如果不存在則創建
		 $datastr = 'id,sitecode,devmac,stamac,add_date,up_time'."\r\n";
		 foreach ($data as $key => $value) {
		 	# code...
		 	$datastr = $datastr.$value['id'].$value['sitecode'].','.$value['devmac'].
		 	','.$value['stamac'].','.$value['add_date'].','.$value['up_time']."\r\n";
		 }
		 //iconv('GB2312','UTF-8//IGNORE',$datastr)
		 fwrite($fp,$datastr); //寫入數據講gbk轉成utf8
		 fclose($fp); //關閉文件句柄
		 echo "生成成功";

		$config = array(
			'host'=>'127.0.0.1',
			'username'=>'root',
			'password'=>'root',
			'port'=>'22'
		);
		$sftp = new sftp($config);
		
		$re = $sftp->ssh3_dir_exits("/test/$time");
		if($re){//如果目錄存在直接上傳
			$sftp->upftp("$name.csv",'/test/'.$time.'/'.$name.'.csv');
		}else{
			$sftp->ssh3_sftp_mchkdir('/test/'.$time);
			$sftp->upftp("$name.csv",'/test/'.$time.'/'.$name.'.csv');
		}

    }

  

}