1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
|
22 while(my $logs = <$logs_content>){
23 my @data = split m!@!,$logs;
24 my $date = &date_split($data[0]);
25 #print $cpt++." -> ";
26 #print $data[3]."\n";
27
28 if($data[3]=~ /\|/){
29 my @catId = split(/\|/,$data[3]);
30 #incrementation pour chaque ligne/lead
31 $hash{$date."#".$data[7]."#".$catId[1]}++;
32 #print $date."#".$data[7]."#".$catId[1]."\n";
33 }
34 else { $hash{$date."#".$data[7]."#".$data[3]}++;
35 #print $date."#".$data[7]."#".$data[3]."\n";
36 }
37 #print $date."#".$data[7]."#".$data[3]."\n";
38 }
39 foreach my $cle (keys %hash){
40 my @fields = split (/#/,$cle);
41
42 #on regarde si les donnees existent deja en base
43
44 my $sel = $dbconnect->prepare("SELECT * FROM salestoolsLeads WHERE hitDate='$fields[0]' AND country='$country' AND comid='$ fields[1]' AND catId='$fields[2]' "); 45 46 $sel->execute() || die "pb de selection: $DBI::errstr"; 47 if ($sel->rows() == 0){ 48 #insertion en base 49 $dbconnect->do("INSERT INTO salestoolsLeads SET hitDate='$fields[0]', country='$country',comid='$fields[1]' ,catId='$fields[2]', nbLeads='$hash{$cle}' "); 50 } 51 } |
Partager