WispX
130 lines
2.7 KiB
PHP
130 lines
2.7 KiB
PHP
<?php
|
||
/**
|
||
* Created by WispX.
|
||
* User: WispX <1591788658@qq.com>
|
||
* Date: 2019/10/31
|
||
* Time: 9:39 上午
|
||
* Link: https://github.com/wisp-x
|
||
*/
|
||
|
||
namespace strategy\driver;
|
||
|
||
use FtpClient\FtpException;
|
||
use strategy\Driver;
|
||
|
||
class Remote implements Driver
|
||
{
|
||
private $ftp;
|
||
|
||
private $error;
|
||
|
||
public function __construct($options = [])
|
||
{
|
||
try {
|
||
$this->ftp = new \FtpClient\FtpClient();
|
||
$this->ftp->connect($options['remote_host']);
|
||
$this->ftp = $this->ftp->login($options['remote_name'], $options['remote_password']);
|
||
} catch (FtpException $e) {
|
||
$this->error = $e->getMessage();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 创建文件
|
||
*
|
||
* @param $pathname
|
||
* @param $file
|
||
*
|
||
* @return mixed
|
||
*/
|
||
public function create($pathname, $file)
|
||
{
|
||
if (!$this->check()) return false;
|
||
|
||
try {
|
||
$dirname = dirname($pathname);
|
||
if (!$this->ftp->isDir($dirname)) {
|
||
if (!$this->ftp->mkdir($dirname, true)) {
|
||
throw new FtpException('文件夹创建失败!');
|
||
}
|
||
}
|
||
if (!$this->ftp->put($pathname, $file, FTP_BINARY)) {
|
||
throw new FtpException('上传失败');
|
||
}
|
||
} catch (FtpException $e) {
|
||
$this->error = $e->getMessage();
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 删除单个文件
|
||
*
|
||
* @param $pathname
|
||
*
|
||
* @return mixed
|
||
*/
|
||
public function delete($pathname)
|
||
{
|
||
if (!$this->check()) return false;
|
||
|
||
try {
|
||
if (!$this->ftp->remove($pathname, true)) {
|
||
throw new FtpException('删除失败');
|
||
}
|
||
} catch (FtpException $e) {
|
||
$this->error = $e->getMessage();
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 删除多个文件
|
||
*
|
||
* @param array $list 一维数组
|
||
*
|
||
* @return mixed
|
||
*/
|
||
public function deletes(array $list)
|
||
{
|
||
if (!$this->check()) return false;
|
||
|
||
try {
|
||
foreach ($list as $item) {
|
||
if (!$this->ftp->remove($item, true)) {
|
||
throw new FtpException('删除失败');
|
||
}
|
||
}
|
||
} catch (FtpException $e) {
|
||
$this->error = $e->getMessage();
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 获取出错信息
|
||
*
|
||
* @return mixed
|
||
*/
|
||
public function getError()
|
||
{
|
||
return 'Remote：' . $this->error;
|
||
}
|
||
|
||
private function check()
|
||
{
|
||
if (!extension_loaded('ftp')) {
|
||
$this->error = 'php_ftp 拓展未开启';
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
}
|