version 1.5, 2011/08/30 08:30:42 |
version 1.8, 2012/04/01 06:52:10 |
|
|
our $SPOOL_ZAYAVKI = "/mnt/archive/archive/wp/zayavki"; |
our $SPOOL_ZAYAVKI = "/mnt/archive/archive/wp/zayavki"; |
our $SPOOL_PROBAS = "/mnt/archive/archive/wp/proba"; |
our $SPOOL_PROBAS = "/mnt/archive/archive/wp/proba"; |
our $SPOOL_TT = "/mnt/archive/archive/wp/tt"; |
our $SPOOL_TT = "/mnt/archive/archive/wp/tt"; |
|
our $SPOOL_ZJPEG = "/mnt/archive/archive/wp/zjpeg"; |
|
our $SPOOL_PJPEG = "/mnt/archive/archive/wp/pjpeg"; |
our $SPOOL_TMPDIR = "/mnt/archive/archive/temp"; |
our $SPOOL_TMPDIR = "/mnt/archive/archive/temp"; |
|
|
# temp variables for map table lookup |
# temp variables for map table lookup |
|
|
$remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/; |
$remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/; |
} |
} |
|
|
if(-e $remotepaths[$i] || -e $remotepaths[$i] . '.rar') |
# if(-e $remotepaths[$i] || -e $remotepaths[$i] . '.rar') |
{ |
# { |
log::error("Remote file $remotepaths[$i] or $remotepaths[$i].rar already exists"); |
# log::error("Remote file $remotepaths[$i] or $remotepaths[$i].rar already exists"); |
db::change_status($dbids[$i], 1); |
# db::change_status($dbids[$i], 1); |
} |
# } |
else |
# else |
{ |
# { |
# In this place we must be sure that local file is ok |
# In this place we must be sure that local file is ok |
if( -e $localpaths[$i] ) |
if( -e $localpaths[$i] ) |
{ |
{ |
|
|
log::zayavki("Can not open local file $localpaths[$i]"); |
log::zayavki("Can not open local file $localpaths[$i]"); |
|
|
} |
} |
} |
# } |
|
|
# next iteration of 'while' and increment of $i |
# next iteration of 'while' and increment of $i |
$i++; |
$i++; |
|
|
log::main("Saved $okay tt on remote host"); |
log::main("Saved $okay tt on remote host"); |
log::tt("<< End transfer process >>"); |
log::tt("<< End transfer process >>"); |
} |
} |
|
|
|
|
|
sub zjpeg() |
|
{ |
|
my @dbids; |
|
my @localpaths; |
|
my @remotepaths; |
|
my $dbids_ref; |
|
my $localpaths_ref; |
|
my $i = 0; |
|
my $okay = 0; |
|
|
|
my $size_orig; |
|
|
|
($dbids_ref, $localpaths_ref) = fetch::zjpeg_list(); |
|
|
|
@dbids = @$dbids_ref; |
|
@localpaths = @$localpaths_ref; |
|
log::main("Fetched " . scalar(@localpaths) . " zjpeg from database"); |
|
log::zjpeg("<< Starting transfer process >>"); |
|
|
|
@remotepaths = @localpaths; # clone |
|
|
|
while($localpaths[$i]) |
|
{ |
|
# lookup in table first |
|
chomp( $tmpf = `basename $remotepaths[$i]` ); |
|
chomp( $_ = `dirname $remotepaths[$i]` ); |
|
$tmpd = hash::lookup($_); |
|
if ( $tmpd ne '' ) |
|
{ |
|
$remotepaths[$i] = $tmpd. "/". $tmpf; |
|
} |
|
else |
|
{ |
|
# hardcoded |
|
$remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/; |
|
} |
|
|
|
if(-e $remotepaths[$i]) |
|
{ |
|
log::error("Remote file $remotefile[$i] already exists"); |
|
db::change_status($dbids[$i], 1); |
|
} |
|
else |
|
{ |
|
if( -e $localpaths[$i] ) |
|
{ |
|
fileops::checkdir($remotepaths[$i]); |
|
# set $size_orig |
|
$size_orig = -s "$localpaths[$i]"; |
|
|
|
log::zjpeg("transferring $localpaths[$i] -> $remotepaths[$i]"); |
|
if( system("cp '$localpaths[$i]' '$remotepaths[$i]'") == 0 ) |
|
{ |
|
log::zjpeg("saved $localpaths[$i] -> $remotepaths[$i] [size_orig=$size_orig]"); |
|
# update database |
|
db::change_status($dbids[$i], 1); |
|
db::write_size_orig($dbids[$i], $size_orig); |
|
|
|
|
|
$okay++; |
|
|
|
} |
|
else |
|
{ |
|
# error in the copy process |
|
log::zjpeg("error in copy process (see error log)"); |
|
log::error("error in copy process: $?"); |
|
} |
|
} |
|
else |
|
{ |
|
# error, local file doesn't exists |
|
log::error("Can not open local file $localpaths[$i]"); |
|
log::zjpeg("Can not open local file $localpaths[$i]"); |
|
} |
|
} |
|
|
|
# next iteration of 'while' and increment of $i |
|
$i++; |
|
} |
|
|
|
log::main("Saved $okay zjpeg on remote host"); |
|
log::zjpeg("<< End transfer process >>"); |
|
} |
|
|
|
sub pjpeg() |
|
{ |
|
my @dbids; |
|
my @localpaths; |
|
my @remotepaths; |
|
my $dbids_ref; |
|
my $localpaths_ref; |
|
my $i = 0; |
|
my $okay = 0; |
|
|
|
my $size_orig; |
|
|
|
($dbids_ref, $localpaths_ref) = fetch::pjpeg_list(); |
|
|
|
@dbids = @$dbids_ref; |
|
@localpaths = @$localpaths_ref; |
|
log::main("Fetched " . scalar(@localpaths) . " pjpeg from database"); |
|
log::pjpeg("<< Starting transfer process >>"); |
|
|
|
@remotepaths = @localpaths; # clone |
|
|
|
while($localpaths[$i]) |
|
{ |
|
# lookup in table first |
|
chomp( $tmpf = `basename $remotepaths[$i]` ); |
|
chomp( $_ = `dirname $remotepaths[$i]` ); |
|
$tmpd = hash::lookup($_); |
|
if ( $tmpd ne '' ) |
|
{ |
|
$remotepaths[$i] = $tmpd. "/". $tmpf; |
|
} |
|
else |
|
{ |
|
# hardcoded |
|
$remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/; |
|
} |
|
|
|
if(-e $remotepaths[$i]) |
|
{ |
|
log::error("Remote file $remotefile[$i] already exists"); |
|
db::change_status($dbids[$i], 1); |
|
} |
|
else |
|
{ |
|
if( -e $localpaths[$i] ) |
|
{ |
|
fileops::checkdir($remotepaths[$i]); |
|
# set $size_orig |
|
$size_orig = -s "$localpaths[$i]"; |
|
|
|
log::pjpeg("transferring $localpaths[$i] -> $remotepaths[$i]"); |
|
if( system("cp '$localpaths[$i]' '$remotepaths[$i]'") == 0 ) |
|
{ |
|
log::pjpeg("saved $localpaths[$i] -> $remotepaths[$i] [size_orig=$size_orig]"); |
|
# update database |
|
db::change_status($dbids[$i], 1); |
|
db::write_size_orig($dbids[$i], $size_orig); |
|
|
|
|
|
$okay++; |
|
|
|
} |
|
else |
|
{ |
|
# error in the copy process |
|
log::pjpeg("error in copy process (see error log)"); |
|
log::error("error in copy process: $?"); |
|
} |
|
} |
|
else |
|
{ |
|
# error, local file doesn't exists |
|
log::error("Can not open local file $localpaths[$i]"); |
|
log::pjpeg("Can not open local file $localpaths[$i]"); |
|
} |
|
} |
|
|
|
# next iteration of 'while' and increment of $i |
|
$i++; |
|
} |
|
|
|
log::main("Saved $okay pjpeg on remote host"); |
|
log::pjpeg("<< End transfer process >>"); |
|
} |
|
|
return(1); |
return(1); |