From ae42e70c2a3950a2ed79204a8f0e4c1f8047f431 Mon Sep 17 00:00:00 2001 From: Alessandro Battilani Date: Fri, 25 Dec 2020 19:15:14 +0100 Subject: [PATCH] eliminata la funzione ftp --- LoadCSVData.pl | 136 ------------------------------------------------- 1 file changed, 136 deletions(-) diff --git a/LoadCSVData.pl b/LoadCSVData.pl index fb34013..e819de6 100755 --- a/LoadCSVData.pl +++ b/LoadCSVData.pl @@ -170,142 +170,6 @@ sub trxelab { 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 { my $dbh = DBI->connect( "DBI:mysql:$db_lar;host=$server", $username, $password )