alex/ase_perl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cambio modulo x email

Browse Source
This commit is contained in:
Alessandro Battilani
2020-12-24 23:14:14 +01:00
parent 5988453a5a
commit b5724a63f6
2 changed files with 65 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
LoadCSVData.pl Normal file → Executable file
View File

@@ -8,7 +8,7 @@ use File::Basename qw( fileparse );
use List::Util qw( max );
use Data::Dumper qw(Dumper);
use Cwd;
use Mail::Sender;
use MIME::Lite;
$|++; # Autoflush
@@ -21,9 +21,10 @@ my $server = 'localhost';
my $db_name = "ase_lar";
my $table = "RAWDATACOR";
my ( @CSVData, @sql );
my $outcount = 0;
my $outfilenum = 0;
my $maxsqllines = 10000;
my $outcount = 0;
my $outfilenum = 0;
my $maxsqllines = 10000;
my $csv_x_ftp_dir = '/home/asega/.csv_x_ftp';
my (
$tool, $toolbatt, $tooltemp, $tooltype, @channels,
@NewData, @ain, @din, @nodetype, $GDEventDate
@@ -47,6 +48,7 @@ my $matlab_error = '';
my $matlab_timeout = '1800';
my $email_addr =
'andrea.carri@aseltd.eu,edoardo.cavalca@aseltd.eu,alessandro.battilani@gmail.com,alessandro.valletta@aseltd.eu';
my $from = 'ASE Alert System<alert@aseltd.eu>';
my ( $email_msg, $email_obj );
my $G201_fcheck = 0;
my $D2W_fcheck = 0;
@@ -190,6 +192,7 @@ sub trxelab {
# Disconnect
my $fileelab;
if ( $ftp_filename eq "" ) {
$fileelab =
'/var/lib/mysql-files/'
@@ -225,6 +228,7 @@ sub trxelab {
) or die getTimeStamp("log") . " - pid $$ >> $DBI::errstr";
$dbh->disconnect;
$ftp_parm //= "";
$ftp_parm =~ s/\s//g;
@@ -236,7 +240,9 @@ sub trxelab {
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);
@@ -442,29 +448,30 @@ END_MSG
sub emailSend {
$email_obj = 'Matlab error on unit ' . $unit . ' - tool ' . $tool;
my $msg = MIME::Lite->new(
From => $from,
To => $email_addr,
Subject => $email_obj,
Data => $email_msg
);
my $sender = new Mail::Sender {
auth => 'PLAIN',
authid => 'ase.mums.alert@gmail.com',
authpwd => 'ASE@mums2013F!',
smtp => 'smtp.gmail.com',
port => 587,
from => 'ASE Alert System',
to => $email_addr,
subject => $email_obj,
msg => $email_msg,
ctype => "text/html",
encoding => "7bit"
};
my $mail_res = $sender->MailMsg( { msg => $sender->{msg}, } );
if ( ref($mail_res) ne "Mail::Sender" ) {
print getTimeStamp("log")
. " - pid $$ >> $mail_res: $sender->{error_msg} \n";
$msg->attr( "content-type" => "text/html" );
if (
$msg->send(
'smtp', "smtps.aruba.it",
AuthUser => "alert\@aseltd.eu",
AuthPass => "Ase#2013!20\@bat",
Port => 465,
SSL => 1,
Debug => 0
)
)
{
print getLoggingTime() . " - $email_obj\n";
print getLoggingTime() . " - Mail sent to: $email_addr.\n";
}
else {
print getTimeStamp("log") . " - pid $$ >> $email_obj\n";
print getTimeStamp("log") . " - pid $$ >> Mail sent to: $email_addr.\n";
print getLoggingTime() . " - Error in sending mail to: $email_addr.\n";
}
}
@@ -562,14 +569,14 @@ while ( my $line = <FILE> ) {
#$NodeData =~ s/Dis\./N\/A/g;
@NewData = grep /\S/, split( /\||;/, $NodeData );
if ( scalar (@NewData) != 0 ) {
my $idx = 0;
if ( scalar(@NewData) != 0 ) {
my $idx = 0;
$CSVData[ $idx++ ] = join( ';', splice( @NewData, 0, 2 ) );
foreach my $ch (@channels) {
$CSVData[ $idx++ ] =
join( ';', splice( @NewData, 0, $ch ) );
}
$CSVData[ $idx++ ] = join( ';', splice( @NewData, 0, 2 ) );
foreach my $ch (@channels) {
$CSVData[ $idx++ ] =
join( ';', splice( @NewData, 0, $ch ) );
}
}
}
elsif ( $tooltype eq "MUSA" ) {