FTP自动上传文件的perl脚本以及配置文件

xiyou

　　#!/usr/bin/perl -w
　　##--------------------------------
　　#
　　# 工程项目： FTP自动上传两类文件
　　#
　　# 模块名称： FTPAutoUpload
　　#
　　# 模块任务： 按照指定的文件夹目录，自动将该文件夹下的所有文件上传到指定ftp站点的指定目录下
　　#
　　# 程序名称:     Upload.pl
　　#
　　##-------------------------------
　　##---------------------------#
　　## 引用的库声明 2
　　#use strict;
　　use File::Copy;
　　use File::stat;
　　use File::Find;
　　use Net::FTP;
　　use Date::Pcalc qw(Delta_DHMS);
　　use Date::Parse;
　　use Win32::OLE;
　　use Win32::OLE::Variant;
　　##---------------------------#
　　##---------------------------#
　　## 引用的库声明 1
　　#- 读取ini配置文件的库
　　use Config::IniFiles;
　　my $cfg = Config::IniFiles->new( -file => "Upload.config" );
　　##---------------------------#
　　##---------------------------#
　　## 从配置文件读取外部参数 ##
　　##
　　## FTP服务器的IP地址 ##
　　$ftp_server    = $cfg->val('FTPServer', 'ftp_server') || '';
　　## 指定的FTP上传目录路径 ##
　　#! 切记：文件夹最后不要加"/"符号 !#
　　$ftp_dir    = $cfg->val('FTPServer', 'ftp_dir') || '';
　　## FTP的登陆用户名 ##
　　$ftp_uid   = $cfg->val('FTPServer', 'ftp_uid') || '';
　　## FTP的登陆密码 ##
　　$ftp_pw     = $cfg->val('FTPServer', 'ftp_pw') || '';
　　## 指定文件夹“语音文件”，放置所有要上传的语音文件 ##
　　#! 切记：文件夹最后不要加"\\"符号 !#
　　@src_dir_WAVFiles = $cfg->val('SrcDirectory', 'src_dir_WAVFiles');
　　## 指定文件夹“命名对照列表文件TXT”，放置命名对照列表文件 ##
　　#! 切记：文件夹最后不要加"\\"符号 !#
　　@src_dir_NamesListFile = $cfg->val('SrcDirectory', 'src_dir_NamesListFile');
　　## 一个字符串集合，表明哪些类型的文件/文件夹将不被上传到服务器 ##
　　@wc_exclude   = ("_vti",".mdb","\\bak","\\data","server.inc");
　　##---------------------------#
　　##---------------------------#
　　## 记录全部过程的日志文件准备
　　$logfilename = 'upload.log';
　　$log_cnt = 0;
　　LOG("");
　　LOG("自动上传FTP文件 Version 0.1");
　　LOG("");
　　LOG("用法： Perl Upload.pl");
　　LOG("");
　　##---------------------------#
　　##---------------------------#
　　##=== 程序执行的第一步：尝试登陆ftp站点 ==========================##
　　##  $total_files是上传文件的数目
　　$total_files = 0;
　　##  $processed_files是已上传文件的数目
　　$processed_files = 0;
　　##  $skipped_files是跳过文件的数目
　　$skipped_files = 0;
　　##  $start_date计算出当前开始的时间
　　$start_date = timeString(time);
　　## $g_nUploadSuccess代表是否已经完全上传,-1为不是，1为是：
　　my $g_nUploadSuccess = 1;
　　## $g_nIsAllWAVsFile_UploadSuccess代表是否已经完全将A类文件上传,-1为不是，1为是：
　　my $g_nIsAllWAVsFile_UploadSuccess = 1;
　　## $g_strLastError代表上次错误原因：
　　my $g_strLastError = "";
　　LOG("正在链接至指定FTP服务器($ftp_server)...");
　　$ftp = Net::FTP->new($ftp_server);
　　if($@)
　　{
　　$g_strLastError = "不能连接到FTP服务器,错误原因:".$@;
　　LOG("$g_strLastError@\n");
　　$g_nUploadSuccess = -1;
　　}
　　else
　　{
　　$ftp->login($ftp_uid, $ftp_pw);
　　if($@)
　　{
　　$g_strLastError = "不能登陆FTP服务器,错误原因:".$@;
　　LOG("$g_strLastError\n");
　　$g_nUploadSuccess = -1;
　　}
　　else
　　{
　　$ftp->binary;
　　LOG("链接FTP服务器成功!");
　　##---------------------------#
　　##---------------------------#
　　##=== 程序执行的第二步，将指定A类文件夹下所有A类文件上传到FTP站点指定目录下 ===##
　　my %lookup;
　　LOG("准备上传“A类文件”目录(@src_dir_WAVFiles)下的所有文件!");
　　find(\&processFiles, @src_dir_WAVFiles);
　　LOG("目录(@src_dir_WAVFiles)已经处理完毕，结果是：");
　　##---------------------------#
　　##=== 程序执行的第三步，将指定B类文件夹下B类文件上传到FTP站点指定目录下 ===##
　　if($g_nIsAllWAVsFile_UploadSuccess > 0)
　　{
　　LOG("+===============================+");
　　LOG("准备上传B类目录(@src_dir_NamesListFile)下的所有文件!");
　　find(\&processFiles, @src_dir_NamesListFile);
　　LOG("目录(@src_dir_NamesListFile)已经处理完毕，结果是：");
　　LOG("-===============================-");
　　}
　　else
　　{
　　LOG("-===============================-");
　　LOG("由于A类文件目录并没有完全上传，所以本B类文件不上传!");
　　LOG("-===============================-");
　　}
　　##---------------------------#
　　##---------------------------#
　　# 日志文件的最后是一个统计报告
　　$span = calcDeltaSeconds($start_date,timeString(time));
　　LOG("上传结果：成功。\n花费:$span 秒, 总共处理了 $total_files 个文件, 其中 $processed_files 上传成功, 跳过了 $skipped_files 个文件。");
　　$ftp->quit()         or warn "unable to quit: $@\n";
　　}
　　closeLogfile();
　　}
　　##---------------------------#
　　##---------------------------#
　　##=== 程序执行的第四步，写成功日志 ===============================##
　　if($g_nIsAllWAVsFile_UploadSuccess > 0 && $g_nUploadSuccess > 0)
　　{
　　$logfilename = 'Upload_Succ_'.shortTimeString(time).'.log';
　　$log_cnt = 0;
　　LOG("");
　　LOG("FTP自动上传文件 Version 0.1");
　　LOG("");
　　LOG("上传结果：成功。\n花费:$span 秒, 总共处理了 $total_files 个文件, 其中 $processed_files 上传成功, 跳过了 $skipped_files 个文件。");
　　LOG("");
　　closeLogfile();
　　}
　　##---------------------------#
　　##---------------------------#
　　##=== 程序执行的第四步，写失败日志 ===============================##
　　if($g_nIsAllWAVsFile_UploadSuccess < 0 || $g_nUploadSuccess < 0)
　　{
　　$logfilename = 'Upload_Fail_'.shortTimeString(time).'.log';
　　$log_cnt = 0;
　　LOG("");
　　LOG("FTP自动上传文件 Version 0.1");
　　LOG("");
　　LOG("上传结果：失败。失败原因:$g_strLastError。\n花费:$span 秒, 总共处理了 $total_files 个文件, 其中 $processed_files 上传成功, 跳过了 $skipped_files 个文件。");
　　LOG("");
　　closeLogfile();
　　}
　　##---------------------------#
　　## 以下是子函数体的定义
　　##----------------------------##
　　##
　　## 函数名称：processFiles
　　## 功能：
　　##           得到指定文件夹下的所有文件以及子文件夹，然后依次处理它们。
　　##
　　## 程序员：  Uwe Keim
　　##
　　## 历史记录：
　　## 编号     日期       作者    备注
　　## 1        2000       Uwe Keim
　　##
　　##----------------------##
　　sub processFiles
　　{
　　my $srcdir = fsToBs($File::Find::dir);
　　my $srcpath = fsToBs($File::Find::name);
　　my $base = fsToBs($File::Find::topdir);
　　foreach my $exclude (@wc_exclude) {
　　if ( index($srcpath, $exclude)>-1 ) {
　　$File::Find::prune = 1 if -d $srcpath;
　　return;
　　}
　　}
　　# no DIRECT processing of directories.
　　if ( -d $srcpath ) {
　　return;
　　}
　　my $dstdir = $srcdir;
　　my $dstpath = $srcpath;
　　$dstdir =~ s{\Q$base\E}{$ftp_dir}is;
　　$dstpath =~ s{\Q$base\E}{$ftp_dir}is;
　　$dstdir = bsToFs($dstdir);
　　$dstpath = bsToFs($dstpath);
　　processFile($srcpath,$dstpath,$dstdir);
　　}
　　sub processFile
　　{
　　my ($src,$dst,$dstdir) = @_;
　　$total_files++;
　　LOG("正在处理文件 $total_files \"$src\"...");
　　# --------------------
　　# check time.
　　my $need_upload = 0;
　　# create time.
　　my $t1 = $lookup{$src};
　　my $t2 = timeString(stat($src)->mtime);
　　if ( not defined $t1 ) {
　　$lookup{$src} = $t2;
　　$need_upload = 1;
　　} else {
　　my $delta_sec = calcDeltaSeconds($t1,$t2);
　　$need_upload = 1 if $delta_sec>5;     # 5 seconds as tolerance.
　　}
　　# --------------------
　　if ( $need_upload>0 ) {
　　$processed_files++;
　　LOG("正在上传文件：从源 \"$src\" 到目标 \"$dst\"...");
　　$ftp->mkdir($dstdir,1);
　　$ftp->put($src, $dst) or  $g_nIsAllWAVsFile_UploadSuccess=-1;
　　if($g_nIsAllWAVsFile_UploadSuccess < 0)
　　{
　　LOG("不能上传文件：从源 \"$src\" 到目标 \"$dst\" (dst-dir: \"$dstdir\")。\n");
　　if($@)
　　{
　　LOG("错误原因是:$@\n");
　　}
　　}
　　} else {
　　$skipped_files++;
　　}
　　}
　　sub bsToFs {
　　my ($s) = @_;
　　$s =~ s/\\/\//gis;
　　return $s;
　　}
　　sub fsToBs {
　　my ($s) = @_;
　　$s =~ s/\//\\/gis;
　　return $s;
　　}
　　sub timeString {
　　my ($tm) = @_;
　　my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($tm);
　　return sprintf("%04d-%02d-%02d %02d:%02d:%02d", $year+1900, $mon+1, $mday, $hour, $min, $sec);
　　}
　　sub shortTimeString {
　　my ($tm) = @_;
　　my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($tm);
　　return sprintf("%04d_%02d_%02d_%02d_%02d", $year+1900, $mon+1, $mday, $hour, $min);
　　}
　　# input dates as string "YYYY-MM-DD HH:MM:SS".
　　# earlier as first parameter, later as second.
　　sub calcDeltaSeconds {
　　my ($t1,$t2) = @_;
　　my ($year1,$month1,$day1,$hh1,$mm1,$ss1) = scanDate($t1);
　　my ($year2,$month2,$day2,$hh2,$mm2,$ss2) = scanDate($t2);
　　my ($days, $hours, $minutes, $seconds) = Delta_DHMS(
　　$year1, $month1, $day1, $hh1, $mm1, $ss1,     # earlier.
　　$year2, $month2, $day2, $hh2, $mm2, $ss2);    # later.
　　return $seconds + $minutes*60 + $hours*60*60 + $days*60*60*24.
　　}
　　sub removeFilename {
　　my ($s) = @_;
　　my $pos = rindex($s,'\\');
　　return substr($s, 0, $pos);
　　}
　　# format: "2000-09-29 09:09:51".
　　sub scanDate {
　　my ($date) = @_;
　　my ($year, $month, $day, $hour, $minute, $seconds);
　　$year   = substr($date, 0, 4);
　　$month  = substr($date, 5, 2);
　　$day   = substr($date, 8, 2);
　　$hour   = substr($date, 11, 2);
　　$minute  = substr($date, 14, 2);
　　$seconds = substr($date, 17, 2);
　　return ($year, $month, $day, $hour, $minute, $seconds);
　　}
　　sub LOG {
　　my ($text) = @_;
　　my $time = timeString time;
　　# log to stdout.
　　print "[$time] $text\n";
　　# log to logfile.
　　my $LOG_STEP = 10;
　　flushLogfile() if ($log_cnt % $LOG_STEP)==0 or $log_cnt==0;
　　$log_cnt++;
　　print HLOG "[$time] $text\n";
　　}
　　sub openLogfile {
　　closeLogfile();
　　open(HLOG,">>$logfilename") or die("打开日志文件出错：文件名为 $logfilename ；错误原因为: $!");
　　};
　　sub closeLogfile {
　　close HLOG if defined HLOG;
　　}
　　sub flushLogfile {
　　closeLogfile();
　　openLogfile();
　　}
　　附录：
　　Upoad.config内容：
　　## 配置的外部参数 ##
　　##
　　[FTPServer]
　　#- FTP服务器的IP地址 -#
　　ftp_server   =
　　#- 指定的FTP上传目录路径 -#
　　#! 切记：文件夹最后不要加"/"符号 !#
　　ftp_dir       =
　　#- FTP的登陆用户名 -#
　　ftp_uid    =
　　#- FTP的登陆密码 -#
　　ftp_pw    =
　　## 配置的外部参数 ##
　　##
　　[SrcDirectory]
　　#- 指定文件夹“语音文件”，放置所有要上传的语音文件 -#
　　#! 切记：文件夹最后不要加"\"符号 !#
　　src_dir_WAVFiles  =
　　#- 指定文件夹“命名对照列表文件TXT”，放置命名对照列表文件 -#
　　#! 切记：文件夹最后不要加"\"符号 !#
　　src_dir_NamesListFile =