eliminata la funzione ftp
This commit is contained in:
136
LoadCSVData.pl
136
LoadCSVData.pl
@@ -170,142 +170,6 @@ sub trxelab {
|
|||||||
exec('/usr/bin/sg', 'mysql', "$ftpcmd");
|
exec('/usr/bin/sg', 'mysql', "$ftpcmd");
|
||||||
}
|
}
|
||||||
|
|
||||||
sub trxelab_old {
|
|
||||||
my $dbh =
|
|
||||||
DBI->connect( "DBI:mysql:$db_lar;host=$server", $username, $password )
|
|
||||||
or die getTimeStamp("log")
|
|
||||||
. " - pid $$ >> Could not connect to database: $DBI::errstr";
|
|
||||||
|
|
||||||
my $sth = $dbh->prepare(
|
|
||||||
'select ftp_addrs, ftp_user, ftp_passwd, ftp_parm, ftp_filename, ftp_target, duedate from units
|
|
||||||
where id = ' . $unit_id . ';'
|
|
||||||
) or die getTimeStamp("log") . " - pid $$ >> $DBI::errstr";
|
|
||||||
|
|
||||||
$sth->execute();
|
|
||||||
if ( $sth->rows eq 0 ) {
|
|
||||||
die getTimeStamp("log") . " - pid $$ >> No unit ftp params selected.\n";
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
while ( my $results = $sth->fetchrow_hashref ) {
|
|
||||||
$ftp_addrs = $results->{'ftp_addrs'};
|
|
||||||
$ftp_user = $results->{'ftp_user'};
|
|
||||||
$ftp_passwd = $results->{'ftp_passwd'};
|
|
||||||
$ftp_parm = $results->{'ftp_parm'};
|
|
||||||
$ftp_filename = $results->{'ftp_filename'};
|
|
||||||
$ftp_target = $results->{'ftp_target'};
|
|
||||||
$duedate = $results->{'duedate'};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
$sth->finish;
|
|
||||||
|
|
||||||
# Disconnect
|
|
||||||
|
|
||||||
my $fileelab;
|
|
||||||
|
|
||||||
if ( $ftp_filename eq "" ) {
|
|
||||||
$fileelab =
|
|
||||||
'/var/lib/mysql-files/'
|
|
||||||
. $tool . '_'
|
|
||||||
. getTimeStamp()
|
|
||||||
. '.csv'; #mettere quello che si prende da query *** aggiungere $unit
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
$ftp_filename =~ s/(\$\w+)/$1/eeg;
|
|
||||||
$ftp_filename =~ s/\s/_/g;
|
|
||||||
$fileelab =
|
|
||||||
'/var/lib/mysql-files/'
|
|
||||||
. $ftp_filename . '_'
|
|
||||||
. getTimeStamp() . '.csv';
|
|
||||||
}
|
|
||||||
|
|
||||||
my $sthdo = $dbh->do(
|
|
||||||
qq{
|
|
||||||
select * from (
|
|
||||||
select 'ToolNameID', 'EventDate', 'EventTime', 'NodeNum', 'NodeType', 'NodeDepth',
|
|
||||||
'XShift', 'YShift', 'ZShift' , 'X', 'Y', 'Z', 'HShift', 'HShiftDir', 'HShift_local',
|
|
||||||
'speed', 'speed_local', 'acceleration', 'acceleration_local', 'T_node', 'water_level', 'pressure', 'load_value', 'AlfaX', 'AlfaY', 'CalcErr'
|
|
||||||
union all
|
|
||||||
select ToolNameID, EventDate, EventTime, NodeNum, NodeType, NodeDepth,
|
|
||||||
XShift, YShift, ZShift , X, Y, Z, HShift, HShiftDir, HShift_local,
|
|
||||||
speed, speed_local, acceleration, acceleration_local, T_node, water_level, pressure, load_value, AlfaX, AlfaY, calcerr
|
|
||||||
from elabdataview
|
|
||||||
where UnitName = '$unit' and ToolNameID = '$tool' and updated_at > '$matlab_timestamp'
|
|
||||||
order by ToolNameID DESC, EventDate, EventTime, convert(`NodeNum`, UNSIGNED INTEGER) DESC
|
|
||||||
) resulting_set
|
|
||||||
into outfile '$fileelab'
|
|
||||||
fields terminated by ',' optionally enclosed by '"' lines terminated by '\n'}
|
|
||||||
) or die getTimeStamp("log") . " - pid $$ >> $DBI::errstr";
|
|
||||||
|
|
||||||
$dbh->disconnect;
|
|
||||||
|
|
||||||
$ftp_parm //= "";
|
|
||||||
$ftp_parm =~ s/\s//g;
|
|
||||||
|
|
||||||
my %ftp_parms = ( 'Host' => $ftp_addrs, );
|
|
||||||
$ftp_parms{'Debug'} = 0;
|
|
||||||
$ftp_parms{'Passive'} = 1;
|
|
||||||
|
|
||||||
foreach my $parm ( split( /,/, $ftp_parm ) ) {
|
|
||||||
my ( $key, $val ) = split( /=>/, $parm );
|
|
||||||
$ftp_parms{$key} = $val;
|
|
||||||
}
|
|
||||||
my $name = POSIX::cuserid();
|
|
||||||
print getTimeStamp("log")
|
|
||||||
. " - pid $$ >> Current user id: $name\n";
|
|
||||||
print getTimeStamp("log")
|
|
||||||
. " - pid $$ >> $unit - $tool ftp parm:\n"
|
|
||||||
. Dumper(%ftp_parms);
|
|
||||||
|
|
||||||
if ( !defined $duedate
|
|
||||||
or ( $duedate eq '0000-00-00 00:00:00' )
|
|
||||||
or ( $duedate eq '' )
|
|
||||||
or ( $duedate gt getTimeStamp("db_ts") ) )
|
|
||||||
{
|
|
||||||
my $ftp = Net::FTP->new(%ftp_parms)
|
|
||||||
or die getTimeStamp("log")
|
|
||||||
. " - pid $$ >> Cannot connect to $ftp_addrs: $@ \n";
|
|
||||||
|
|
||||||
$ftp->starttls() if exists $ftp_parms{'SSL_version'};
|
|
||||||
|
|
||||||
$ftp->login( $ftp_user, $ftp_passwd )
|
|
||||||
or die getTimeStamp("log")
|
|
||||||
. " - pid $$ >> Cannot login "
|
|
||||||
. $ftp->message . "\n";
|
|
||||||
|
|
||||||
$ftp_target //= "";
|
|
||||||
if ( $ftp_target ne "" ) {
|
|
||||||
$ftp->cwd($ftp_target)
|
|
||||||
or die getTimeStamp("log")
|
|
||||||
. " - pid $$ >> Change remote dir failed "
|
|
||||||
. $ftp->message . "\n";
|
|
||||||
}
|
|
||||||
|
|
||||||
print getTimeStamp("log")
|
|
||||||
. " - pid $$ >> ftp target: "
|
|
||||||
. $ftp->pwd() . ".\n";
|
|
||||||
|
|
||||||
$ftp->put($fileelab)
|
|
||||||
or die getTimeStamp("log")
|
|
||||||
. " - pid $$ >> Put failed: "
|
|
||||||
. $ftp->message . "\n";
|
|
||||||
|
|
||||||
print getTimeStamp("log")
|
|
||||||
. " - pid $$ >> ftp target lists "
|
|
||||||
. scalar @{ $ftp->ls() }
|
|
||||||
. " elements.\n";
|
|
||||||
|
|
||||||
$ftp->quit;
|
|
||||||
print getTimeStamp("log")
|
|
||||||
. " - pid $$ >> $unit - $tool: $fileelab ftp put executed.\n";
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
print getTimeStamp("log")
|
|
||||||
. " - pid $$ >> $unit - $tool: $fileelab ftp put didn't executed because due date reached.\n";
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub getNodesType {
|
sub getNodesType {
|
||||||
my $dbh =
|
my $dbh =
|
||||||
DBI->connect( "DBI:mysql:$db_lar;host=$server", $username, $password )
|
DBI->connect( "DBI:mysql:$db_lar;host=$server", $username, $password )
|
||||||
|
|||||||
Reference in New Issue
Block a user