nbfd_tp3/Home/Lib/Action/CronftpAction.class.php

<?php



class CronftpAction extends Action {
			


 
	public  function searchFile2Ftp(  ){
		$dir = C('FTP_LOCAL_DIR');
		$targetDir = C('FTP_SERVER_DIR');
		// $config = C('FTP_CONFIG');
		while (true) {
			$res = scanTargetFile($dir, 'md5');
			$files = explode(';', $res);
			array_pop($files);
			if (empty($files)) {
				sleep(1);
			}
			foreach ($files as $v) {
				$path_parts = pathinfo($v);
				//$start = time();
				//判断是否需要压缩，之前压缩过但没上传成功，需要重新上传
				$zip_file = $path_parts['dirname'] . '/' . $path_parts['filename'] . '.zip';
				if (file_exists($zip_file)) {
					$zip = $zip_file;
				} else {
					$zip = $this->zip($path_parts['filename'], $path_parts['dirname']);
				}
				if ($zip) { //压缩完成
					if (filesize($zip) <= 0) {
						@unlink($zip);
						continue;
					}
					//echo '压缩用时：'.(time()-$start).PHP_EOL;
					$tagetDat = $targetDir . '/' . $path_parts['filename'] . '.zip';
					//echo $tagetDat . PHP_EOL;
		
					// $datRes = Zmcoding\FtpFile::getInstance($config)->up_file($zip, $tagetDat);
					// echo "datRes:".$datRes.PHP_EOL;
					// if ($datRes) {
					// 	$md5Res = Zmcoding\FtpFile::getInstance($config)->up_file($v,  $targetDir . '/' . $path_parts['basename']); //md5文件
					// 	if ($md5Res) {
					// 		debug_log('upload_info', json_encode($targetDir . '/' . $path_parts['basename'], JSON_UNESCAPED_UNICODE));
					// 	}
					// 	debug_log('upload_info', json_encode($tagetDat, JSON_UNESCAPED_UNICODE));
					// }
					if (rename($zip, $tagetDat)) {
						echo $zip . "文件移动成功！" . PHP_EOL;
						//删除本地dat文件
						@unlink($path_parts['dirname'] . '/' . $path_parts['filename'] . '.dat');
						@unlink($path_parts['dirname'] . '/' . $path_parts['filename'] . '.md5');
					} else {
						echo $zip . "文件移动失败！" . $tagetDat . PHP_EOL;
					}
				}
			}
			// sleep(3);
		}
	}
	
 
	public  function zip( $name, $path ){
		//压缩
		if (!file_exists($path)) {
			return false;
		}
		$current_dir = opendir($path);
		$needzip = '';//需要压缩的文件
		while (($file = readdir($current_dir)) !== false) {
			$sub_dir = $path . DIRECTORY_SEPARATOR . $file;
			if ($file == '.' || $file == '..') {
				continue;
			}
			if (is_file($sub_dir)) {    //如果是.dat文件，进行赋值
				$pathinfo = pathinfo($file);
				// var_dump($pathinfo);
				if ($pathinfo['extension'] == 'dat' && $pathinfo['filename'] == $name) {
					$needzip = $file;
				}
			}
		}
		if ($needzip == '') {
			return false;
		}
		// var_dump($files);exit;
		$zip_filename = $path . '/' . $name . '.zip';
		@unlink($zip_filename);
		if (!file_exists($zip_filename)) {
			touch($zip_filename);
			$zip = new \ZipArchive();
			$ret = $zip->open($zip_filename, \ZipArchive::OVERWRITE);
			if ($ret !== true) {
				return false;
			} else {
				// if (!empty($files)) {
				// foreach ($files as $file) {
				$zip->addFile($path . '/' . $needzip, $needzip);
				// @unlink($path . '/' . $name . '.dat');
				// }
				// }
				$zip->close();
			}
		}
		return $zip_filename;
	}
	

}