@@ -108,7 +108,9 @@ while (my $mqttMessage = <$SUB> ) {

       if ($queue eq "RESULT"){ # topic nou sonoff v6.2.1 sonoff bridge

         my $decoded = decode_json($json);

         if (exists $decoded->{'RfReceived'}{'Data'}){

-          addRF ($topic, $decoded->{'RfReceived'}{'Sync'}, $decoded->{'RfReceived'}{'Low'}, $decoded->{'RfReceived'}{'High'}, $decoded->{'RfReceived'}{'Data'}, "now()");

+          my ($sec,$min,$hour,$mday,$mon,$year)=localtime(time);

+          my $timestamp = sprintf ( "%04d-%02d-%02d %02d:%02d:%02d", $year+1900,$mon+1,$mday,$hour,$min,$sec);

+          addRF ($topic, $decoded->{'RfReceived'}{'Sync'}, $decoded->{'RfReceived'}{'Low'}, $decoded->{'RfReceived'}{'High'}, $decoded->{'RfReceived'}{'Data'}, $timestamp);

           my $script="php /admin/scripts/mqttparser/rf433.php $topic $decoded->{'RfReceived'}{'Data'}";

           runSCRIPT ($script);

         }

@@ -240,11 +242,11 @@ sub delDB {

 # adaug/updatez in tabela get433info din baza de date 

 sub addRF {

-  (my $topic, my $sync, my $low, my $high, my $data) = @_;

+  (my $topic, my $sync, my $low, my $high, my $data, my $timestamp) = @_;

   (my $user, my $devid) = split /\-/, $topic;

   my $query = "insert into get433info values (?, ?, ?, ?, ?, ?, ?) on duplicate key update log=?";

   my $sth = $dbh->prepare($query) or die "Can't prepare $query: $dbh->errstr\n";

-  $sth->execute("$user", "$devid", "$sync", "$low", "$high", "$data", "now()" ,"now()");

+  $sth->execute("$user", "$devid", "$sync", "$low", "$high", "$data", "$timestamp", "$timestamp");

   $sth->finish();

   return;

 }