@@ -1,6 +1,6 @@

 #!/usr/bin/perl

 # parser pentru mesajele MQTT

-# Version: 1.0.8

+# Version: 1.1.0

 use strict;

 use warnings;

@@ -32,6 +32,8 @@ my $dbpass;

 my $dbhost;

 my $mqttuser;

 my $mqttpass;

+my $startime = strftime("%s", localtime(time));

+

 my $row=1;

 while( my $line = <$CFG>){

   my @credentials = split /=/, $line;

@@ -58,15 +60,20 @@ while (my $mqttMessage = <$SUB> ) {

       (my $root, my $topic, my $queue) = split /\//, $channel;

       # aleg canalele de unde salvez date in DB:

       if ($queue eq "LWT"){

-        # stergem consumul pentru azi si ieri cand este offline priza

-        if ($nonjson eq 'Offline') {

-          delDB($topic);

+        my $curtime = strftime("%s", localtime(time));

+        my $uptime = $curtime-$startime;

+        # nu procesez retained LWT cand pornesc mqttparser 

+        if ($uptime>60){ 

+          # stergem consumul pentru azi si ieri cand este offline priza

+          if ($nonjson eq 'Offline') {

+            delDB($topic);

+          }

+          # salvam ultima stare a releului

+          my $script="php /admin/scripts/mqttparser/last_state.php $topic $nonjson\n";

+          runSCRIPT ($script);

+          # salvam in DB statusul online/offline

+          addDB ($topic, "LWT", $nonjson);

         }

-        # salvam ultima stare a releului

-        my $script="php /admin/scripts/mqttparser/last_state.php $topic $nonjson\n";

-        runSCRIPT ($script);

-        # salvam in DB statusul online/offline

-        addDB ($topic, "LWT", $nonjson);

       }

       else {

         #print "nu ma intereseaza alte canale fara json";