FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-02-01 01:09:47 +00:00
Code Issues Releases Wiki Activity

73_PRESENCE.pm: Version 02.00

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@28744 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
jowiemann 2024-04-03 12:56:46 +00:00
parent 558a03abc4
commit 08e43eab08
1 changed files with 48 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
fhem/FHEM/73_PRESENCE.pm
View File

@ -1,4 +1,4 @@
# $Id$ # $Id$
############################################################################## ##############################################################################
# #
# 73_PRESENCE.pm # 73_PRESENCE.pm
@ -33,8 +33,18 @@ use Blocking;
use Time::HiRes qw(gettimeofday usleep sleep); use Time::HiRes qw(gettimeofday usleep sleep);
use DevIo; use DevIo;
sub my $ModulVersion = "02.00";
PRESENCE_Initialize($) my %LOG_Text = (
0 => "SERVER:",
1 => "ERROR:",
2 => "SIGNIFICANT:",
3 => "BASIC:",
4 => "EXPANDED:",
5 => "DEBUG:"
);
#######################################################################
sub PRESENCE_Initialize($)
{ {
my ($hash) = @_; my ($hash) = @_;
@ -69,7 +79,7 @@ PRESENCE_Initialize($)
} }
##################################### #######################################################################
sub sub
PRESENCE_Define($$) PRESENCE_Define($$)
{ {
@ -248,7 +258,7 @@ PRESENCE_Define($$)
return undef; return undef;
} }
##################################### #######################################################################
sub sub
PRESENCE_Undef($$) PRESENCE_Undef($$)
{ {
@ -265,7 +275,7 @@ PRESENCE_Undef($$)
return undef; return undef;
} }
##################################### #######################################################################
sub sub
PRESENCE_State($$$$) PRESENCE_State($$$$)
{ {
@ -279,7 +289,7 @@ PRESENCE_State($$$$)
return undef; return undef;
} }
##################################### #######################################################################
sub sub
PRESENCE_Notify($$) PRESENCE_Notify($$)
{ {
@ -343,7 +353,7 @@ PRESENCE_Notify($$)
} }
} }
##################################### #######################################################################
sub sub
PRESENCE_Set($@) PRESENCE_Set($@)
{ {
@ -585,7 +595,7 @@ PRESENCE_Attr(@)
} }
##################################### #######################################################################
# Receives an event and creates several readings for event triggering # Receives an event and creates several readings for event triggering
sub sub
PRESENCE_Read($) PRESENCE_Read($)
@ -683,7 +693,7 @@ PRESENCE_Read($)
readingsEndUpdate($hash, 1); readingsEndUpdate($hash, 1);
} }
##################################### #######################################################################
sub sub
PRESENCE_Ready($) PRESENCE_Ready($)
{ {
@ -693,13 +703,13 @@ PRESENCE_Ready($)
} }
########################################################################################################################## ################################################################################################################################################################################################################################
# #
# Functions for local testing with Blocking.pm to ensure a smooth FHEM processing # Functions for local testing with Blocking.pm to ensure a smooth FHEM processing
# #
########################################################################################################################## ################################################################################################################################################################################################################################
##################################### #######################################################################
sub PRESENCE_StartLocalScan($;$) sub PRESENCE_StartLocalScan($;$)
{ {
my ($hash, $local) = @_; my ($hash, $local) = @_;
@ -727,26 +737,31 @@ sub PRESENCE_StartLocalScan($;$)
{ {
Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode local-bluetooth"; Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode local-bluetooth";
$hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalBluetoothScan", $name."|".$hash->{ADDRESS}."|".$local."|".AttrVal($name, "bluetoothHciDevice", ""), "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash); $hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalBluetoothScan", $name."|".$hash->{ADDRESS}."|".$local."|".AttrVal($name, "bluetoothHciDevice", ""), "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash);
$hash->{helper}{RUNNING_PID}->{loglevel} = GetVerbose($name);
} }
elsif($mode eq "lan-ping") elsif($mode eq "lan-ping")
{ {
Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode lan-ping"; Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode lan-ping";
$hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalPingScan", $name."|".$hash->{ADDRESS}."|".$local."|".AttrVal($name, "pingCount", "4"), "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash); $hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalPingScan", $name."|".$hash->{ADDRESS}."|".$local."|".AttrVal($name, "pingCount", "4"), "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash);
$hash->{helper}{RUNNING_PID}->{loglevel} = GetVerbose($name);
} }
elsif($mode eq "fritzbox") elsif($mode eq "fritzbox")
{ {
Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode fritzbox"; Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode fritzbox";
$hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalFritzBoxScan", $name."|".$hash->{ADDRESS}."|".$local."|".AttrVal($name, "fritzboxCheckSpeed", "0"), "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash); $hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalFritzBoxScan", $name."|".$hash->{ADDRESS}."|".$local."|".AttrVal($name, "fritzboxCheckSpeed", "0"), "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash);
$hash->{helper}{RUNNING_PID}->{loglevel} = GetVerbose($name);
} }
elsif($mode eq "shellscript") elsif($mode eq "shellscript")
{ {
Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode shellscript"; Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode shellscript";
$hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalShellScriptScan", $name."|".$hash->{helper}{call}."|".$local, "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash); $hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalShellScriptScan", $name."|".$hash->{helper}{call}."|".$local, "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash);
$hash->{helper}{RUNNING_PID}->{loglevel} = GetVerbose($name);
} }
elsif($mode eq "function") elsif($mode eq "function")
{ {
Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode function"; Log3 $name, 5, "PRESENCE ($name) - starting blocking call for mode function";
$hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalFunctionScan", $name."|".$hash->{helper}{call}."|".$local, "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash); $hash->{helper}{RUNNING_PID} = BlockingCall("PRESENCE_DoLocalFunctionScan", $name."|".$hash->{helper}{call}."|".$local, "PRESENCE_ProcessLocalScan", 60, "PRESENCE_ProcessAbortedScan", $hash);
$hash->{helper}{RUNNING_PID}->{loglevel} = GetVerbose($name);
} }
if(!$hash->{helper}{RUNNING_PID} and $mode =~ /^local-bluetooth|lan-ping|fritzbox|shellscript|function$/) if(!$hash->{helper}{RUNNING_PID} and $mode =~ /^local-bluetooth|lan-ping|fritzbox|shellscript|function$/)
@ -781,7 +796,7 @@ sub PRESENCE_StartLocalScan($;$)
} }
} }
##################################### #######################################################################
sub PRESENCE_DoLocalPingScan($) sub PRESENCE_DoLocalPingScan($)
{ {
@ -846,7 +861,7 @@ sub PRESENCE_DoLocalPingScan($)
return $return; return $return;
} }
##################################### #######################################################################
sub PRESENCE_ExecuteFritzBoxCMD($$) sub PRESENCE_ExecuteFritzBoxCMD($$)
{ {
@ -874,7 +889,7 @@ sub PRESENCE_ExecuteFritzBoxCMD($$)
return $status; return $status;
} }
##################################### #######################################################################
sub PRESENCE_DoLocalFritzBoxScan($) sub PRESENCE_DoLocalFritzBoxScan($)
{ {
my ($string) = @_; my ($string) = @_;
@ -980,7 +995,7 @@ sub PRESENCE_DoLocalFritzBoxScan($)
return ($status == 0 ? "$name|$local|absent" : "$name|$local|present").($number <= $max ? "|$number" : "|").($speedcheck == 1 and defined($speed) ? "|$speed" : ""); return ($status == 0 ? "$name|$local|absent" : "$name|$local|present").($number <= $max ? "|$number" : "|").($speedcheck == 1 and defined($speed) ? "|$speed" : "");
} }
##################################### #######################################################################
sub PRESENCE_DoLocalBluetoothScan($) sub PRESENCE_DoLocalBluetoothScan($)
{ {
my ($string) = @_; my ($string) = @_;
@ -1054,7 +1069,7 @@ sub PRESENCE_DoLocalBluetoothScan($)
return $return; return $return;
} }
##################################### #######################################################################
sub PRESENCE_DoLocalShellScriptScan($) sub PRESENCE_DoLocalShellScriptScan($)
{ {
@ -1098,7 +1113,7 @@ sub PRESENCE_DoLocalShellScriptScan($)
return $return; return $return;
} }
##################################### #######################################################################
sub PRESENCE_DoLocalFunctionScan($) sub PRESENCE_DoLocalFunctionScan($)
{ {
@ -1140,7 +1155,7 @@ sub PRESENCE_DoLocalFunctionScan($)
return $return; return $return;
} }
##################################### #######################################################################
sub PRESENCE_ProcessLocalScan($) sub PRESENCE_ProcessLocalScan($)
{ {
my ($string) = @_; my ($string) = @_;
@ -1165,7 +1180,7 @@ sub PRESENCE_ProcessLocalScan($)
if(defined($hash->{helper}{RETRY_COUNT})) if(defined($hash->{helper}{RETRY_COUNT}))
{ {
Log3 $hash->{NAME}, 2, "PRESENCE ($name) - check returned a valid result after ".$hash->{helper}{RETRY_COUNT}." unsuccesful ".($hash->{helper}{RETRY_COUNT} > 1 ? "retries" : "retry"); Log3 $hash->{NAME}, 3, "PRESENCE ($name) - check returned a valid result after ".$hash->{helper}{RETRY_COUNT}." unsuccesful ".($hash->{helper}{RETRY_COUNT} > 1 ? "retries" : "retry");
delete($hash->{helper}{RETRY_COUNT}); delete($hash->{helper}{RETRY_COUNT});
} }
@ -1215,7 +1230,7 @@ sub PRESENCE_ProcessLocalScan($)
} }
} }
##################################### #######################################################################
sub PRESENCE_ProcessAbortedScan($) sub PRESENCE_ProcessAbortedScan($)
{ {
my ($hash, $msg) = @_; my ($hash, $msg) = @_;
@ -1229,13 +1244,13 @@ sub PRESENCE_ProcessAbortedScan($)
{ {
if($hash->{helper}{RETRY_COUNT} >= AttrVal($name, "retryCount", 3)) if($hash->{helper}{RETRY_COUNT} >= AttrVal($name, "retryCount", 3))
{ {
Log3 $hash->{NAME}, 2, "PRESENCE ($name) - device could not be checked after ".$hash->{helper}{RETRY_COUNT}." ".($hash->{helper}{RETRY_COUNT} > 1 ? "retries" : "retry"). " (resuming normal operation): $msg" if($hash->{helper}{RETRY_COUNT} == 3); Log3 $hash->{NAME}, 3, "PRESENCE ($name) - device could not be checked after ".$hash->{helper}{RETRY_COUNT}." ".($hash->{helper}{RETRY_COUNT} > 1 ? "retries" : "retry"). " (resuming normal operation): $msg" if($hash->{helper}{RETRY_COUNT} == 3);
InternalTimer(gettimeofday()+$hash->{INTERVAL_NORMAL}, "PRESENCE_StartLocalScan", $hash, 0) unless($hash->{helper}{DISABLED}); InternalTimer(gettimeofday()+$hash->{INTERVAL_NORMAL}, "PRESENCE_StartLocalScan", $hash, 0) unless($hash->{helper}{DISABLED});
$hash->{helper}{RETRY_COUNT}++; $hash->{helper}{RETRY_COUNT}++;
} }
else else
{ {
Log3 $hash->{NAME}, 2, "PRESENCE ($name) - device could not be checked after ".$hash->{helper}{RETRY_COUNT}." ".($hash->{helper}{RETRY_COUNT} > 1 ? "retries" : "retry")." (retrying in $retry_interval seconds): $msg"; Log3 $hash->{NAME}, 3, "PRESENCE ($name) - device could not be checked after ".$hash->{helper}{RETRY_COUNT}." ".($hash->{helper}{RETRY_COUNT} > 1 ? "retries" : "retry")." (retrying in $retry_interval seconds): $msg";
InternalTimer(gettimeofday()+$retry_interval, "PRESENCE_StartLocalScan", $hash, 0) unless($hash->{helper}{DISABLED}); InternalTimer(gettimeofday()+$retry_interval, "PRESENCE_StartLocalScan", $hash, 0) unless($hash->{helper}{DISABLED});
$hash->{helper}{RETRY_COUNT}++; $hash->{helper}{RETRY_COUNT}++;
} }
@ -1244,20 +1259,20 @@ sub PRESENCE_ProcessAbortedScan($)
{ {
$hash->{helper}{RETRY_COUNT} = 1; $hash->{helper}{RETRY_COUNT} = 1;
InternalTimer(gettimeofday()+$retry_interval, "PRESENCE_StartLocalScan", $hash, 0) unless($hash->{helper}{DISABLED}); InternalTimer(gettimeofday()+$retry_interval, "PRESENCE_StartLocalScan", $hash, 0) unless($hash->{helper}{DISABLED});
Log3 $hash->{NAME}, 2, "PRESENCE ($name) - device could not be checked (retrying in $retry_interval seconds): $msg" Log3 $hash->{NAME}, 3, "PRESENCE ($name) - device could not be checked (retrying in $retry_interval seconds): $msg"
} }
readingsSingleUpdate($hash, "state", "timeout",1); readingsSingleUpdate($hash, "state", "timeout",1);
} }
########################################################################################################################## ################################################################################################################################################################################################################################
# #
# Helper Functions # Helper Functions
# #
########################################################################################################################## ################################################################################################################################################################################################################################
##################################### #######################################################################
sub PRESENCE_DoInit($) sub PRESENCE_DoInit($)
{ {
my ($hash) = @_; my ($hash) = @_;
@ -1276,7 +1291,7 @@ sub PRESENCE_DoInit($)
return undef; return undef;
} }
##################################### #######################################################################
sub PRESENCE_calculateThreshold($) sub PRESENCE_calculateThreshold($)
{ {
my ($value) = @_; my ($value) = @_;
@ -1304,7 +1319,7 @@ sub PRESENCE_calculateThreshold($)
return $value; return $value;
} }
##################################### #######################################################################
sub PRESENCE_ThresholdTrigger($) sub PRESENCE_ThresholdTrigger($)
{ {
my ($hash) = @_; my ($hash) = @_;
@ -1328,7 +1343,7 @@ sub PRESENCE_ThresholdTrigger($)
} }
} }
##################################### #######################################################################
sub PRESENCE_ProcessState($$) sub PRESENCE_ProcessState($$)
{ {
my ($hash, $state) = @_; my ($hash, $state) = @_;
@ -1446,7 +1461,7 @@ sub PRESENCE_ProcessState($$)
} }
} }
##################################### #######################################################################
sub PRESENCE_ProcessAddonData($$) sub PRESENCE_ProcessAddonData($$)
{ {
my ($hash, $data) = @_; my ($hash, $data) = @_;
@ -1461,7 +1476,7 @@ sub PRESENCE_ProcessAddonData($$)
return undef; return undef;
} }
##################################### #######################################################################
sub PRESENCE_setNotfiyDev($) sub PRESENCE_setNotfiyDev($)
{ {
my ($hash) = @_; my ($hash) = @_;