PHP-sftp文件上传
PHP的sftp文件上传；在框架thinkphp5中使用；主要用到的sftp函数如下；ssh2_connect(host,port) 链接信息ssh2_auth_password($con,username,password)登录验证copy();//服务器之间的文件复制；要求如下需要的文件字段信息见附件内容，注意最后一列带年月日时分秒格式；上传前，需要先判断相应目录下是否有上一天日期文件夹，若无，则创建，若有，则直接上传至相应文件夹下，如附件所示thinkphp5中提供了一个非composer安装的第三方类库目录extend在extend目录下创建一个sftp目录创建sftp.php的类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
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 = ssh2_connect($this->config['host'], $this->config['port']);
if( ssh2_auth_password($this->conn, $this->config['username'], $this->config['password']))
{
$this->ressftp = ssh2_sftp($this->conn);
}else{
echo "用户名或密码错误";
}
}
// 下载文件
public function downftp($remote, $local)
{
return copy("ssh2.sftp://{$ressftp}".$remote, $local);
}
// 文件上传
public function upftp( $local,$remote, $file_mode = 0777)
{
return copy($local,"ssh2.sftp://{$this->ressftp}".$remote);
}
//创建目录
public function ssh2_sftp_mchkdir($path)//使用创建目录循环
{
ssh2_sftp_mkdir($this->ressftp, $path,0777);
}
//判段目录是否存在
public function ssh2_dir_exits($dir){
return file_exists("ssh2.sftp://{$this->ressftp}".$dir);
}
}
下面在控制器里面调用
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
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->ssh2_dir_exits("/test/$time");
if($re){//如果目录存在直接上传
$sftp->upftp("$name.csv",'/test/'.$time.'/'.$name.'.csv');
}else{
$sftp->ssh2_sftp_mchkdir('/test/'.$time);
$sftp->upftp("$name.csv",'/test/'.$time.'/'.$name.'.csv');
}
}
}
页:
[1]