Ftp.class.php
4.83 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006-2014 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 麦当苗儿 <zuojiazi@vip.qq.com> <http://www.zjzit.cn>
// +----------------------------------------------------------------------
namespace Think\Upload\Driver;
class Ftp
{
/**
* 上传文件根目录
*
* @var string
*/
private $rootPath;
/**
* 本地上传错误信息
*
* @var string
*/
private $error = ''; // 上传错误信息
/**
* FTP连接
*
* @var resource
*/
private $link;
private $config = array(
'host' => '', // 服务器
'port' => 21, // 端口
'timeout' => 90, // 超时时间
'username' => '', // 用户名
'password' => ''
); // 密码
/**
* 构造函数，用于设置上传根路径
*
* @param array $config
* FTP配置
*/
public function __construct($config)
{
// 默认FTP配置
$this->config = array_merge($this->config, $config);
// 登录FTP服务器
if (! $this->login()) {
E($this->error);
}
}
/**
* 检测上传根目录
*
* @param string $rootpath
* 根目录
* @return boolean true-检测通过，false-检测失败
*/
public function checkRootPath($rootpath)
{
// 设置根目录
$this->rootPath = ftp_pwd($this->link) . '/' . ltrim($rootpath, '/');
if (! @ftp_chdir($this->link, $this->rootPath)) {
$this->error = '上传根目录不存在！';
return false;
}
return true;
}
/**
* 检测上传目录
*
* @param string $savepath
* 上传目录
* @return boolean 检测结果，true-通过，false-失败
*/
public function checkSavePath($savepath)
{
// 检测并创建目录
if (! $this->mkdir($savepath)) {
return false;
} else {
// TODO:检测目录是否可写
return true;
}
}
/**
* 保存指定文件
*
* @param array $file
* 保存的文件信息
* @param boolean $replace
* 同名文件是否覆盖
* @return boolean 保存状态，true-成功，false-失败
*/
public function save($file, $replace = true)
{
$filename = $this->rootPath . $file['savepath'] . $file['savename'];
// 不覆盖同名文件
// if (!$replace && is_file($filename)) {
// $this->error = '存在同名文件' . $file['savename'];
// return false;
// }
// 移动文件
if (! ftp_put($this->link, $filename, $file['tmp_name'], FTP_BINARY)) {
$this->error = '文件上传保存错误！';
return false;
}
return true;
}
/**
* 创建目录
*
* @param string $savepath
* 要创建的穆里
* @return boolean 创建状态，true-成功，false-失败
*/
public function mkdir($savepath)
{
$dir = $this->rootPath . $savepath;
if (ftp_chdir($this->link, $dir)) {
return true;
}
if (ftp_mkdir($this->link, $dir)) {
return true;
} elseif ($this->mkdir(dirname($savepath)) && ftp_mkdir($this->link, $dir)) {
return true;
} else {
$this->error = "目录 {$savepath} 创建失败！";
return false;
}
}
/**
* 获取最后一次上传错误信息
*
* @return string 错误信息
*/
public function getError()
{
return $this->error;
}
/**
* 登录到FTP服务器
*
* @return boolean true-登录成功，false-登录失败
*/
private function login()
{
extract($this->config);
$this->link = ftp_connect($host, $port, $timeout);
if ($this->link) {
if (ftp_login($this->link, $username, $password)) {
return true;
} else {
$this->error = "无法登录到FTP服务器：username - {$username}";
}
} else {
$this->error = "无法连接到FTP服务器：{$host}";
}
return false;
}
/**
* 析构方法，用于断开当前FTP连接
*/
public function __destruct()
{
ftp_close($this->link);
}
}