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

corr din/ain

Browse Source
This commit is contained in:
battilo
2018-11-19 23:21:01 +01:00
parent 38f60ce3cc
commit f0ab80f719
1 changed files with 57 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files

120
LoadCSVData.pl
View File

@@ -24,7 +24,7 @@ my ( @CSVData, @sql );
my $outcount = 0; my $outcount = 0;
my $outfilenum = 0; my $outfilenum = 0;
my $maxsqllines = 10000; my $maxsqllines = 10000;
my ($tool, $toolbatt, $tooltemp, $tooltype, @channels,@NewData, @din, @nodetype, $GDEventDate); my ($tool, $toolbatt, $tooltemp, $tooltype, @channels,@NewData, @ain, @din, @nodetype, $GDEventDate);
my $matlab_ip = "160.78.21.71"; my $matlab_ip = "160.78.21.71";
my $matlab_cmd = "matlab.cmd"; my $matlab_cmd = "matlab.cmd";
my $matlab_timestamp = ""; my $matlab_timestamp = "";
@@ -486,90 +486,84 @@ while ( my $line = <FILE> ) {
if ($used_din eq 0) { if ($used_din eq 0) {
$CSVData[$idx++] = $Din1; $CSVData[$idx++] = $Din1;
$used_din = 1; $used_din = 1;
} } else {
else {
$CSVData[$idx++] = $Din2; $CSVData[$idx++] = $Din2;
} }
} } elsif ($ain[i] eq 1) {
elsif ($ain[i] eq 1) {
if ($used_ain eq 0) { if ($used_ain eq 0) {
$CSVData[$idx++] = $Ain1; $CSVData[$idx++] = $Ain1;
$used_ain = 1; $used_ain = 1;
} } else {
else {
$CSVData[$idx++] = $Ain2; $CSVData[$idx++] = $Ain2;
} }
} } elsif ($din[i] eq 2) {
elsif ($din[i] eq 2) {
$CSVData[$idx++] = $Din1 . ";" . $Din2; $CSVData[$idx++] = $Din1 . ";" . $Din2;
} } elsif ($ain[i] eq 2) {
elsif ($ain[i] eq 2) {
$CSVData[$idx++] = $Ain1 . ";" . $Ain2; $CSVData[$idx++] = $Ain1 . ";" . $Ain2;
} }
} }
}
} }elsif ( $tooltype eq "GD" ) {
elsif ( $tooltype eq "GD" ) { my ( $div, $Vbat, $Tmod ) =
my ( $div, $Vbat, $Tmod ) = split( /;/, $NodeData );
split( /;/, $NodeData ); $CSVData[0] = $Vbat . ";" . $Tmod;
$CSVData[0] = $Vbat . ";" . $Tmod;
my ( $y, $m, $d, $t ) = split( /[\s\/]/, $first );
my ( $h, $min, $sec ) = split( /:/, $t );
$GDEventDate = $y . '-' . $m . '-' . $d;
$CSVData[1] = "DT". substr( $tool, 2, 4 ) . ';'. $h . ':'. ( $min - 1 ) . ';'. $h . ':'. ( $min + 1 );
}else {
@CSVData = split( /\|/, $NodeData );
}
my $nodenum = 0;
foreach (@CSVData) {
$sql[ ( $outcount % $maxsqllines ) ] = "";
my (@data) = grep { /\S/ } split( /\;/, $_ );
if ( $nodenum eq 0 ) {
$toolbatt = $data[0];
$tooltemp = $data[1];
}else {
my ( $y, $m, $d, $t ) = split( /[\s\/]/, $first ); my ( $y, $m, $d, $t ) = split( /[\s\/]/, $first );
if (length($y) != 4) { # G201 con la data invertita my ( $h, $min, $sec ) = split( /:/, $t );
my $w = $y; $GDEventDate = $y . '-' . $m . '-' . $d;
$y = $d; $CSVData[1] = "DT". substr( $tool, 2, 4 ) . ';'. $h . ':'. ( $min - 1 ) . ';'. $h . ':'. ( $min + 1 );
$m = sprintf('%02d',$m); }else {
$d = sprintf('%02d',$w); @CSVData = split( /\|/, $NodeData );
} }
foreach (@data) {
if ( $sql[ ( $outcount % $maxsqllines ) ] eq "" ) { my $nodenum = 0;
$sql[ ( $outcount % $maxsqllines ) ] = "('$unit','$tool','$nodenum','$y-$m-$d','$t','$toolbatt','$tooltemp'"; foreach (@CSVData) {
} $sql[ ( $outcount % $maxsqllines ) ] = "";
$sql[ ( $outcount % $maxsqllines ) ] .= ",'" . $_ . "'"; my (@data) = grep { /\S/ } split( /\;/, $_ );
} if ( $nodenum eq 0 ) {
my $InsCompl = ",NULL" x ( 15 - $#data ); $toolbatt = $data[0];
$sql[ ( $outcount % $maxsqllines ) ] .= $InsCompl . ")"; $tooltemp = $data[1];
if ( ++$outcount % $maxsqllines eq 0 ) { }else {
$sql[ ( $outcount % $maxsqllines ) - 1 ] .= ";\n"; my ( $y, $m, $d, $t ) = split( /[\s\/]/, $first );
writeOutSql($tool); if (length($y) != 4) { # G201 con la data invertita
}else { my $w = $y;
$sql[ ( $outcount % $maxsqllines ) - 1 ] .= ",\n"; $y = $d;
} $m = sprintf('%02d',$m);
$d = sprintf('%02d',$w);
}
foreach (@data) {
if ( $sql[ ( $outcount % $maxsqllines ) ] eq "" ) {
$sql[ ( $outcount % $maxsqllines ) ] = "('$unit','$tool','$nodenum','$y-$m-$d','$t','$toolbatt','$tooltemp'";
}
$sql[ ( $outcount % $maxsqllines ) ] .= ",'" . $_ . "'";
}
my $InsCompl = ",NULL" x ( 15 - $#data );
$sql[ ( $outcount % $maxsqllines ) ] .= $InsCompl . ")";
if ( ++$outcount % $maxsqllines eq 0 ) {
$sql[ ( $outcount % $maxsqllines ) - 1 ] .= ";\n";
writeOutSql($tool);
}else {
$sql[ ( $outcount % $maxsqllines ) - 1 ] .= ",\n";
}
}
$nodenum++;
} }
$nodenum++;
} }
} }
} }
}
close FILE; close FILE;
$sql[ ( $outcount % $maxsqllines ) - 1 ] =~ s/,$/;/g; $sql[ ( $outcount % $maxsqllines ) - 1 ] =~ s/,$/;/g;
writeOutSql($tool); writeOutSql($tool);
if ( $tooltype eq "GD" ) { if ( $tooltype eq "GD" ) {
print getTimeStamp("log") . " - pid $$ >> tool GD: nothing to do.\n"; print getTimeStamp("log") . " - pid $$ >> tool GD: nothing to do.\n";
}else { }else {
matlabCalc(); matlabCalc();
if ($ftp_send) { if ($ftp_send) {
if ( $tool eq 'DT0076' ) { if ( $tool eq 'DT0076' ) {
sleep(600); sleep(600);
} }
trxelab(); trxelab();
} }
} }
print getTimeStamp("log") . " - pid $$ >> Execution ended.\n"; print getTimeStamp("log") . " - pid $$ >> Execution ended.\n";