mirror of
https://github.com/fhem/fhem-mirror.git
synced 2025-03-03 16:56:54 +00:00
73_NUKIBridge: 74_NUKIDevice - new modul structure and rewrite code, add support for new smartlock 3.0 and 3.0 pro, version 2.0 pre-release
git-svn-id: https://svn.fhem.de/fhem/trunk@25300 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
LeonGaultier
parent
d0337483e4
commit
d22a7142f5
@ -1,5 +1,8 @@
|
|||||||
# Add changes at the top of the list. Keep it in ASCII, and 80-char wide.
|
# Add changes at the top of the list. Keep it in ASCII, and 80-char wide.
|
||||||
# Do not insert empty lines here, update check depends on it.
|
# Do not insert empty lines here, update check depends on it.
|
||||||
|
- feature: 73_NUKIBridge 74_NUKIDevice: new modul structure and rewrite code,
|
||||||
|
add support for new smartlock 3.0 and 3.0 pro,
|
||||||
|
version 2.0 pre-release
|
||||||
- feature: 93_DbRep: diffValue - recognize if diff is 0 or no value available
|
- feature: 93_DbRep: diffValue - recognize if diff is 0 or no value available
|
||||||
- change: 72_FB_CALLLIST: reading "count-missed-calls" only counts incoming
|
- change: 72_FB_CALLLIST: reading "count-missed-calls" only counts incoming
|
||||||
missed calls
|
missed calls
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@ -24,604 +24,39 @@
|
|||||||
# $Id$
|
# $Id$
|
||||||
#
|
#
|
||||||
###############################################################################
|
###############################################################################
|
||||||
|
|
||||||
package main;
|
|
||||||
|
|
||||||
use strict;
|
|
||||||
use warnings;
|
|
||||||
|
|
||||||
package FHEM::NUKIDevice;
|
package FHEM::NUKIDevice;
|
||||||
|
|
||||||
use strict;
|
use strict;
|
||||||
use warnings;
|
use warnings;
|
||||||
|
|
||||||
use FHEM::Meta;
|
use FHEM::Meta;
|
||||||
use GPUtils qw(GP_Import GP_Export);
|
require FHEM::Devices::Nuki::Device;
|
||||||
|
|
||||||
main::LoadModule('NUKIBridge');
|
main::LoadModule('NUKIBridge');
|
||||||
|
|
||||||
# try to use JSON::MaybeXS wrapper
|
sub ::NUKIDevice_Initialize { goto &Initialize }
|
||||||
# for chance of better performance + open code
|
|
||||||
eval {
|
|
||||||
require JSON::MaybeXS;
|
|
||||||
import JSON::MaybeXS qw( decode_json encode_json );
|
|
||||||
1;
|
|
||||||
};
|
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# try to use JSON wrapper
|
|
||||||
# for chance of better performance
|
|
||||||
eval {
|
|
||||||
|
|
||||||
# JSON preference order
|
|
||||||
local $ENV{PERL_JSON_BACKEND} =
|
|
||||||
'Cpanel::JSON::XS,JSON::XS,JSON::PP,JSON::backportPP'
|
|
||||||
unless ( defined( $ENV{PERL_JSON_BACKEND} ) );
|
|
||||||
|
|
||||||
require JSON;
|
|
||||||
import JSON qw( decode_json encode_json );
|
|
||||||
1;
|
|
||||||
};
|
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# In rare cases, Cpanel::JSON::XS may
|
|
||||||
# be installed but JSON|JSON::MaybeXS not ...
|
|
||||||
eval {
|
|
||||||
require Cpanel::JSON::XS;
|
|
||||||
import Cpanel::JSON::XS qw(decode_json encode_json);
|
|
||||||
1;
|
|
||||||
};
|
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# In rare cases, JSON::XS may
|
|
||||||
# be installed but JSON not ...
|
|
||||||
eval {
|
|
||||||
require JSON::XS;
|
|
||||||
import JSON::XS qw(decode_json encode_json);
|
|
||||||
1;
|
|
||||||
};
|
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# Fallback to built-in JSON which SHOULD
|
|
||||||
# be available since 5.014 ...
|
|
||||||
eval {
|
|
||||||
require JSON::PP;
|
|
||||||
import JSON::PP qw(decode_json encode_json);
|
|
||||||
1;
|
|
||||||
};
|
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# Fallback to JSON::backportPP in really rare cases
|
|
||||||
require JSON::backportPP;
|
|
||||||
import JSON::backportPP qw(decode_json encode_json);
|
|
||||||
1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
## Import der FHEM Funktionen
|
|
||||||
#-- Run before package compilation
|
|
||||||
BEGIN {
|
|
||||||
|
|
||||||
# Import from main context
|
|
||||||
GP_Import(
|
|
||||||
qw(
|
|
||||||
readingsSingleUpdate
|
|
||||||
readingsBulkUpdate
|
|
||||||
readingsBeginUpdate
|
|
||||||
readingsEndUpdate
|
|
||||||
readingFnAttributes
|
|
||||||
makeDeviceName
|
|
||||||
defs
|
|
||||||
modules
|
|
||||||
Log3
|
|
||||||
CommandAttr
|
|
||||||
AttrVal
|
|
||||||
IsDisabled
|
|
||||||
deviceEvents
|
|
||||||
init_done
|
|
||||||
InternalVal
|
|
||||||
ReadingsVal
|
|
||||||
AssignIoPort
|
|
||||||
IOWrite
|
|
||||||
data)
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
#-- Export to main context with different name
|
|
||||||
GP_Export(
|
|
||||||
qw(
|
|
||||||
Initialize
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
my %deviceTypes = (
|
|
||||||
0 => 'smartlock',
|
|
||||||
2 => 'opener',
|
|
||||||
4 => 'smartlockNG'
|
|
||||||
);
|
|
||||||
|
|
||||||
my %modes = (
|
|
||||||
2 => {
|
|
||||||
0 => 'door mode',
|
|
||||||
2 => 'door mode'
|
|
||||||
},
|
|
||||||
3 => {
|
|
||||||
0 => '-',
|
|
||||||
2 => ' continuous mode'
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
my %lockStates = (
|
|
||||||
0 => {
|
|
||||||
0 => 'uncalibrated',
|
|
||||||
2 => 'untrained',
|
|
||||||
4 => 'uncalibrated'
|
|
||||||
},
|
|
||||||
1 => {
|
|
||||||
0 => 'locked',
|
|
||||||
2 => 'online',
|
|
||||||
4 => 'locked'
|
|
||||||
},
|
|
||||||
2 => {
|
|
||||||
0 => 'unlocking',
|
|
||||||
2 => '-',
|
|
||||||
4 => 'unlocking'
|
|
||||||
},
|
|
||||||
3 => {
|
|
||||||
0 => 'unlocked',
|
|
||||||
2 => 'rto active',
|
|
||||||
4 => 'unlocked'
|
|
||||||
},
|
|
||||||
4 => {
|
|
||||||
0 => 'locking',
|
|
||||||
2 => '-',
|
|
||||||
4 => 'locking'
|
|
||||||
},
|
|
||||||
5 => {
|
|
||||||
0 => 'unlatched',
|
|
||||||
2 => 'open',
|
|
||||||
4 => 'unlatched'
|
|
||||||
},
|
|
||||||
6 => {
|
|
||||||
0 => 'unlocked (lock ‘n’ go)',
|
|
||||||
2 => '-',
|
|
||||||
4 => 'unlocked (lock ‘n’ go)'
|
|
||||||
},
|
|
||||||
7 => {
|
|
||||||
0 => 'unlatching',
|
|
||||||
2 => 'opening',
|
|
||||||
4 => 'unlatching'
|
|
||||||
},
|
|
||||||
253 => {
|
|
||||||
0 => '-',
|
|
||||||
2 => 'boot run',
|
|
||||||
4 => '-'
|
|
||||||
},
|
|
||||||
254 => {
|
|
||||||
0 => 'motor blocked',
|
|
||||||
2 => '-',
|
|
||||||
4 => 'motor blocked'
|
|
||||||
},
|
|
||||||
255 => {
|
|
||||||
0 => 'undefined',
|
|
||||||
2 => 'undefined',
|
|
||||||
4 => 'undefined'
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
my %deviceTypeIds = reverse(%deviceTypes);
|
|
||||||
|
|
||||||
sub Initialize($) {
|
sub Initialize($) {
|
||||||
my ($hash) = @_;
|
my ($hash) = @_;
|
||||||
|
|
||||||
$hash->{Match} = '^{.*}$';
|
$hash->{Match} = '^{.*}$';
|
||||||
|
|
||||||
$hash->{SetFn} = 'FHEM::NUKIDevice::Set';
|
$hash->{SetFn} = \&FHEM::Devices::Nuki::Device::Set;
|
||||||
$hash->{DefFn} = 'FHEM::NUKIDevice::Define';
|
$hash->{DefFn} = \&FHEM::Devices::Nuki::Device::Define;
|
||||||
$hash->{UndefFn} = 'FHEM::NUKIDevice::Undef';
|
$hash->{UndefFn} = \&FHEM::Devices::Nuki::Device::Undef;
|
||||||
$hash->{NotifyFn} = 'FHEM::NUKIDevice::Notify';
|
$hash->{NotifyFn} = \&FHEM::Devices::Nuki::Device::Notify;
|
||||||
$hash->{AttrFn} = 'FHEM::NUKIDevice::Attr';
|
$hash->{AttrFn} = \&FHEM::Devices::Nuki::Device::Attr;
|
||||||
$hash->{ParseFn} = 'FHEM::NUKIDevice::Parse';
|
$hash->{ParseFn} = \&FHEM::Devices::Nuki::Device::Parse;
|
||||||
|
|
||||||
$hash->{AttrList} =
|
$hash->{AttrList} =
|
||||||
'IODev '
|
'IODev '
|
||||||
. 'model:opener,smartlock '
|
. 'model:smartlock,opener,smartdoor,smartlock3 '
|
||||||
. 'disable:1 '
|
. 'disable:1 '
|
||||||
. $readingFnAttributes;
|
. $::readingFnAttributes;
|
||||||
|
|
||||||
return FHEM::Meta::InitMod( __FILE__, $hash );
|
return FHEM::Meta::InitMod( __FILE__, $hash );
|
||||||
}
|
}
|
||||||
|
|
||||||
sub Define($$) {
|
|
||||||
my ( $hash, $def ) = @_;
|
|
||||||
my @a = split( '[ \t][ \t]*', $def );
|
|
||||||
|
|
||||||
return $@ unless ( FHEM::Meta::SetInternals($hash) );
|
|
||||||
use version 0.60; our $VERSION = FHEM::Meta::Get( $hash, 'version' );
|
|
||||||
|
|
||||||
return 'too few parameters: define <name> NUKIDevice <nukiId> <deviceType>'
|
|
||||||
if ( @a != 4 );
|
|
||||||
|
|
||||||
my $name = $a[0];
|
|
||||||
my $nukiId = $a[2];
|
|
||||||
my $deviceType = ( defined $a[3] ) ? $a[3] : 0;
|
|
||||||
|
|
||||||
$hash->{NUKIID} = $nukiId;
|
|
||||||
$hash->{DEVICETYPE} = ( defined $deviceType ) ? $deviceType : 0;
|
|
||||||
$hash->{VERSION} = version->parse($VERSION)->normal;
|
|
||||||
$hash->{STATE} = 'Initialized';
|
|
||||||
$hash->{NOTIFYDEV} = 'global,autocreate,' . $name;
|
|
||||||
|
|
||||||
my $iodev = AttrVal( $name, 'IODev', 'none' );
|
|
||||||
|
|
||||||
AssignIoPort( $hash, $iodev ) if ( !$hash->{IODev} );
|
|
||||||
|
|
||||||
if ( defined( $hash->{IODev}->{NAME} ) ) {
|
|
||||||
Log3( $name, 3,
|
|
||||||
"NUKIDevice ($name) - I/O device is " . $hash->{IODev}->{NAME} );
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
Log3( $name, 1, "NUKIDevice ($name) - no I/O device" );
|
|
||||||
}
|
|
||||||
|
|
||||||
$iodev = $hash->{IODev}->{NAME};
|
|
||||||
|
|
||||||
$hash->{BRIDGEAPI} = $defs{$iodev}->{BRIDGEAPI};
|
|
||||||
|
|
||||||
my $d = $modules{NUKIDevice}{defptr}{$nukiId};
|
|
||||||
|
|
||||||
return
|
|
||||||
'NUKIDevice device '
|
|
||||||
. $name
|
|
||||||
. ' on NUKIBridge '
|
|
||||||
. $iodev
|
|
||||||
. ' already defined.'
|
|
||||||
if ( defined($d)
|
|
||||||
and $d->{IODev} == $hash->{IODev}
|
|
||||||
and $d->{NAME} ne $name );
|
|
||||||
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - defined with NukiId: $nukiId" );
|
|
||||||
|
|
||||||
CommandAttr( undef, $name . ' room NUKI' )
|
|
||||||
if ( AttrVal( $name, 'room', 'none' ) eq 'none' );
|
|
||||||
CommandAttr( undef, $name . ' model ' . $deviceTypes{$deviceType} )
|
|
||||||
if ( AttrVal( $name, 'model', 'none' ) eq 'none' );
|
|
||||||
|
|
||||||
$modules{NUKIDevice}{defptr}{$nukiId} = $hash;
|
|
||||||
|
|
||||||
GetUpdate($hash)
|
|
||||||
if ( ReadingsVal( $name, 'success', 'none' ) eq 'none'
|
|
||||||
and $init_done );
|
|
||||||
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub Undef($$) {
|
|
||||||
my ( $hash, $arg ) = @_;
|
|
||||||
|
|
||||||
my $nukiId = $hash->{NUKIID};
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - undefined with NukiId: $nukiId" );
|
|
||||||
delete( $modules{NUKIDevice}{defptr}{$nukiId} );
|
|
||||||
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub Attr(@) {
|
|
||||||
my ( $cmd, $name, $attrName, $attrVal ) = @_;
|
|
||||||
|
|
||||||
my $hash = $defs{$name};
|
|
||||||
my $token = $hash->{IODev}->{TOKEN};
|
|
||||||
|
|
||||||
if ( $attrName eq 'disable' ) {
|
|
||||||
if ( $cmd eq 'set' and $attrVal == 1 ) {
|
|
||||||
readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - disabled" );
|
|
||||||
}
|
|
||||||
|
|
||||||
elsif ( $cmd eq 'del' ) {
|
|
||||||
readingsSingleUpdate( $hash, 'state', 'active', 1 );
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - enabled" );
|
|
||||||
}
|
|
||||||
}
|
|
||||||
elsif ( $attrName eq 'disabledForIntervals' ) {
|
|
||||||
if ( $cmd eq 'set' ) {
|
|
||||||
Log3( $name, 3,
|
|
||||||
"NUKIDevice ($name) - enable disabledForIntervals" );
|
|
||||||
readingsSingleUpdate( $hash, 'state', 'Unknown', 1 );
|
|
||||||
}
|
|
||||||
|
|
||||||
elsif ( $cmd eq 'del' ) {
|
|
||||||
readingsSingleUpdate( $hash, 'state', 'active', 1 );
|
|
||||||
Log3( $name, 3,
|
|
||||||
"NUKIDevice ($name) - delete disabledForIntervals" );
|
|
||||||
}
|
|
||||||
}
|
|
||||||
elsif ( $attrName eq 'model' ) {
|
|
||||||
if ( $cmd eq 'set' ) {
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - change model" );
|
|
||||||
$hash->{DEVICETYPE} = $deviceTypeIds{$attrVal};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub Notify($$) {
|
|
||||||
|
|
||||||
my ( $hash, $dev ) = @_;
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
return if ( IsDisabled($name) );
|
|
||||||
|
|
||||||
my $devname = $dev->{NAME};
|
|
||||||
my $devtype = $dev->{TYPE};
|
|
||||||
my $events = deviceEvents( $dev, 1 );
|
|
||||||
return if ( !$events );
|
|
||||||
|
|
||||||
GetUpdate($hash)
|
|
||||||
if (
|
|
||||||
(
|
|
||||||
grep /^INITIALIZED$/,
|
|
||||||
@{$events}
|
|
||||||
or grep /^REREADCFG$/,
|
|
||||||
@{$events}
|
|
||||||
or grep /^MODIFIED.$name$/,
|
|
||||||
@{$events}
|
|
||||||
or grep /^DEFINED.$name$/,
|
|
||||||
@{$events}
|
|
||||||
)
|
|
||||||
and $devname eq 'global'
|
|
||||||
and $init_done
|
|
||||||
);
|
|
||||||
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub Set($$@) {
|
|
||||||
my ( $hash, $name, @aa ) = @_;
|
|
||||||
|
|
||||||
my ( $cmd, @args ) = @aa;
|
|
||||||
my $lockAction;
|
|
||||||
|
|
||||||
if ( lc($cmd) eq 'statusrequest' ) {
|
|
||||||
return ('usage: statusRequest') if ( @args != 0 );
|
|
||||||
|
|
||||||
GetUpdate($hash);
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
elsif ($cmd eq 'lock'
|
|
||||||
or lc($cmd) eq 'deactivaterto'
|
|
||||||
or $cmd eq 'unlock'
|
|
||||||
or lc($cmd) eq 'activaterto'
|
|
||||||
or $cmd eq 'unlatch'
|
|
||||||
or lc($cmd) eq 'electricstrikeactuation'
|
|
||||||
or lc($cmd) eq 'lockngo'
|
|
||||||
or lc($cmd) eq 'activatecontinuousmode'
|
|
||||||
or lc($cmd) eq 'lockngowithunlatch'
|
|
||||||
or lc($cmd) eq 'deactivatecontinuousmode'
|
|
||||||
or $cmd eq 'unpair' )
|
|
||||||
{
|
|
||||||
return ( 'usage: ' . $cmd )
|
|
||||||
if ( @args != 0 );
|
|
||||||
$lockAction = $cmd;
|
|
||||||
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
my $list = '';
|
|
||||||
$list =
|
|
||||||
'statusRequest:noArg unlock:noArg lock:noArg unlatch:noArg locknGo:noArg locknGoWithUnlatch:noArg unpair:noArg'
|
|
||||||
if ( $hash->{DEVICETYPE} == 0
|
|
||||||
|| $hash->{DEVICETYPE} == 4 );
|
|
||||||
$list =
|
|
||||||
'statusRequest:noArg activateRto:noArg deactivateRto:noArg electricStrikeActuation:noArg activateContinuousMode:noArg deactivateContinuousMode:noArg unpair:noArg'
|
|
||||||
if ( $hash->{DEVICETYPE} == 2 );
|
|
||||||
|
|
||||||
return ( 'Unknown argument ' . $cmd . ', choose one of ' . $list );
|
|
||||||
}
|
|
||||||
|
|
||||||
$hash->{helper}{lockAction} = $lockAction;
|
|
||||||
|
|
||||||
# IOWrite( $hash, 'lockAction', $lockAction, $hash->{NUKIID},
|
|
||||||
# $hash->{DEVICETYPE} );
|
|
||||||
|
|
||||||
IOWrite( $hash, 'lockAction', '{"param":"' . $lockAction
|
|
||||||
. '","nukiId":' . $hash->{NUKIID} . ',"deviceType":' . $hash->{DEVICETYPE} . '}' );
|
|
||||||
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub GetUpdate($) {
|
|
||||||
my $hash = shift;
|
|
||||||
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
|
|
||||||
if ( !IsDisabled($name) ) {
|
|
||||||
# IOWrite( $hash, 'lockState', undef, $hash->{NUKIID},
|
|
||||||
# $hash->{DEVICETYPE} );
|
|
||||||
|
|
||||||
IOWrite( $hash, 'lockState', '{"nukiId":' . $hash->{NUKIID}
|
|
||||||
. ',"deviceType":' . $hash->{DEVICETYPE} . '}' );
|
|
||||||
|
|
||||||
Log3( $name, 2, "NUKIDevice ($name) - GetUpdate Call IOWrite" );
|
|
||||||
}
|
|
||||||
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
sub Parse($$) {
|
|
||||||
my ( $hash, $json ) = @_;
|
|
||||||
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
|
|
||||||
Log3( $name, 5, "NUKIDevice ($name) - Parse with result: $json" );
|
|
||||||
#########################################
|
|
||||||
####### Errorhandling #############
|
|
||||||
|
|
||||||
if ( $json !~ m/^[\[{].*[}\]]$/ ) {
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - invalid json detected: $json" );
|
|
||||||
return "NUKIDevice ($name) - invalid json detected: $json";
|
|
||||||
}
|
|
||||||
|
|
||||||
#########################################
|
|
||||||
#### verarbeiten des JSON Strings #######
|
|
||||||
my $decode_json = eval { decode_json($json) };
|
|
||||||
if ($@) {
|
|
||||||
Log3( $name, 3, "NUKIDevice ($name) - JSON error while request: $@" );
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if ( ref($decode_json) ne 'HASH' ) {
|
|
||||||
Log3( $name, 2,
|
|
||||||
"NUKIDevice ($name) - got wrong status message for $name: $decode_json"
|
|
||||||
);
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
my $nukiId = $decode_json->{nukiId};
|
|
||||||
|
|
||||||
if ( my $hash = $modules{NUKIDevice}{defptr}{$nukiId} ) {
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
|
|
||||||
WriteReadings( $hash, $decode_json );
|
|
||||||
Log3( $name, 4,
|
|
||||||
"NUKIDevice ($name) - find logical device: $hash->{NAME}" );
|
|
||||||
|
|
||||||
##################
|
|
||||||
## Zwischenlösung so für die Umstellung, kann später gelöscht werden
|
|
||||||
if ( AttrVal( $name, 'model', '' ) eq '' ) {
|
|
||||||
CommandDefMod( undef,
|
|
||||||
$name
|
|
||||||
. ' NUKIDevice '
|
|
||||||
. $hash->{NUKIID} . ' '
|
|
||||||
. $decode_json->{deviceType} );
|
|
||||||
CommandAttr( undef,
|
|
||||||
$name
|
|
||||||
. ' model '
|
|
||||||
. $deviceTypes{ $decode_json->{deviceType} } );
|
|
||||||
Log3( $name, 2, "NUKIDevice ($name) - redefined Defmod" );
|
|
||||||
}
|
|
||||||
|
|
||||||
return $hash->{NAME};
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
Log3( $name, 4,
|
|
||||||
"NUKIDevice ($name) - autocreate new device "
|
|
||||||
. makeDeviceName( $decode_json->{name} )
|
|
||||||
. " with nukiId $decode_json->{nukiId}, model $decode_json->{deviceType}"
|
|
||||||
);
|
|
||||||
return
|
|
||||||
'UNDEFINED '
|
|
||||||
. makeDeviceName( $decode_json->{name} )
|
|
||||||
. " NUKIDevice $decode_json->{nukiId} $decode_json->{deviceType}";
|
|
||||||
}
|
|
||||||
|
|
||||||
Log3( $name, 5, "NUKIDevice ($name) - parse status message for $name" );
|
|
||||||
|
|
||||||
WriteReadings( $hash, $decode_json );
|
|
||||||
}
|
|
||||||
|
|
||||||
sub WriteReadings($$) {
|
|
||||||
my ( $hash, $decode_json ) = @_;
|
|
||||||
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
|
|
||||||
############################
|
|
||||||
#### Status des Smartlock
|
|
||||||
|
|
||||||
if ( defined( $hash->{helper}{lockAction} ) ) {
|
|
||||||
my $state;
|
|
||||||
|
|
||||||
if (
|
|
||||||
defined( $decode_json->{success} )
|
|
||||||
and ( $decode_json->{success} eq 'true'
|
|
||||||
or $decode_json->{success} == 1 )
|
|
||||||
)
|
|
||||||
{
|
|
||||||
$state = $hash->{helper}{lockAction};
|
|
||||||
# IOWrite( $hash, 'lockState', undef, $hash->{NUKIID} )
|
|
||||||
|
|
||||||
IOWrite( $hash, 'lockState', '{"nukiId":' . $hash->{NUKIID}
|
|
||||||
. ',"deviceType":' . $hash->{DEVICETYPE} . '}' )
|
|
||||||
if (
|
|
||||||
ReadingsVal( $hash->{IODev}->{NAME}, 'bridgeType', 'Software' )
|
|
||||||
eq 'Software' );
|
|
||||||
|
|
||||||
}
|
|
||||||
elsif (
|
|
||||||
defined( $decode_json->{success} )
|
|
||||||
and ( $decode_json->{success} eq 'false'
|
|
||||||
or $decode_json->{success} == 0 )
|
|
||||||
)
|
|
||||||
{
|
|
||||||
|
|
||||||
$state = $deviceTypes{ $hash->{DEVICETYPE} } . ' response error';
|
|
||||||
# IOWrite( $hash, 'lockState', undef, $hash->{NUKIID},
|
|
||||||
# $hash->{DEVICETYPE} );
|
|
||||||
IOWrite( $hash, 'lockState', '{"nukiId":' . $hash->{NUKIID}
|
|
||||||
. ',"deviceType":' . $hash->{DEVICETYPE} . '}' );
|
|
||||||
}
|
|
||||||
|
|
||||||
$decode_json->{'state'} = $state;
|
|
||||||
delete $hash->{helper}{lockAction};
|
|
||||||
}
|
|
||||||
|
|
||||||
readingsBeginUpdate($hash);
|
|
||||||
|
|
||||||
my $t;
|
|
||||||
my $v;
|
|
||||||
|
|
||||||
if ( defined( $decode_json->{lastKnownState} )
|
|
||||||
and ref( $decode_json->{lastKnownState} ) eq 'HASH' )
|
|
||||||
{
|
|
||||||
while ( ( $t, $v ) = each %{ $decode_json->{lastKnownState} } ) {
|
|
||||||
$decode_json->{$t} = $v;
|
|
||||||
}
|
|
||||||
|
|
||||||
delete $decode_json->{lastKnownState};
|
|
||||||
}
|
|
||||||
|
|
||||||
while ( ( $t, $v ) = each %{$decode_json} ) {
|
|
||||||
readingsBulkUpdate( $hash, $t, $v )
|
|
||||||
unless ( $t eq 'state'
|
|
||||||
or $t eq 'mode'
|
|
||||||
or $t eq 'deviceType'
|
|
||||||
or $t eq 'paired'
|
|
||||||
or $t eq 'batteryCritical'
|
|
||||||
or $t eq 'timestamp' );
|
|
||||||
readingsBulkUpdate( $hash, $t,
|
|
||||||
( $v =~ m/^[0-9]$/ ? $lockStates{$v}{ $hash->{DEVICETYPE} } : $v ) )
|
|
||||||
if ( $t eq 'state' );
|
|
||||||
readingsBulkUpdate( $hash, $t, $modes{$v}{ $hash->{DEVICETYPE} } )
|
|
||||||
if ( $t eq 'mode' );
|
|
||||||
readingsBulkUpdate( $hash, $t, $deviceTypes{$v} )
|
|
||||||
if ( $t eq 'deviceType' );
|
|
||||||
readingsBulkUpdate( $hash, $t, ( $v == 1 ? 'true' : 'false' ) )
|
|
||||||
if ( $t eq 'paired' );
|
|
||||||
readingsBulkUpdate( $hash, 'batteryState',
|
|
||||||
( ( $v eq 'true' or $v == 1 ) ? 'low' : 'ok' ) )
|
|
||||||
if ( $t eq 'batteryCritical' );
|
|
||||||
}
|
|
||||||
|
|
||||||
readingsEndUpdate( $hash, 1 );
|
|
||||||
|
|
||||||
Log3( $name, 5, "NUKIDevice ($name) - lockAction readings set for $name" );
|
|
||||||
|
|
||||||
return undef;
|
|
||||||
}
|
|
||||||
|
|
||||||
1;
|
1;
|
||||||
|
|
||||||
=pod
|
=pod
|
||||||
@ -769,7 +204,7 @@ sub WriteReadings($$) {
|
|||||||
],
|
],
|
||||||
"release_status": "stable",
|
"release_status": "stable",
|
||||||
"license": "GPL_2",
|
"license": "GPL_2",
|
||||||
"version": "v1.9.50",
|
"version": "v2.0.0",
|
||||||
"author": [
|
"author": [
|
||||||
"Marko Oldenburg <leongaultier@gmail.com>"
|
"Marko Oldenburg <leongaultier@gmail.com>"
|
||||||
],
|
],
|
||||||
|
|||||||
1438
fhem/lib/FHEM/Devices/Nuki/Bridge.pm
Normal file
1438
fhem/lib/FHEM/Devices/Nuki/Bridge.pm
Normal file
File diff suppressed because it is too large
Load Diff
598
fhem/lib/FHEM/Devices/Nuki/Device.pm
Normal file
598
fhem/lib/FHEM/Devices/Nuki/Device.pm
Normal file
@ -0,0 +1,598 @@
|
|||||||
|
###############################################################################
|
||||||
|
#
|
||||||
|
# Developed with Kate
|
||||||
|
#
|
||||||
|
# (c) 2016-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
|
||||||
|
# All rights reserved
|
||||||
|
#
|
||||||
|
# This script is free software; you can redistribute it and/or modify
|
||||||
|
# it under the terms of the GNU General Public License as published by
|
||||||
|
# the Free Software Foundation; either version 2 of the License, or
|
||||||
|
# any later version.
|
||||||
|
#
|
||||||
|
# The GNU General Public License can be found at
|
||||||
|
# http://www.gnu.org/copyleft/gpl.html.
|
||||||
|
# A copy is found in the textfile GPL.txt and important notices to the license
|
||||||
|
# from the author is found in LICENSE.txt distributed with these scripts.
|
||||||
|
#
|
||||||
|
# This script is distributed in the hope that it will be useful,
|
||||||
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
# GNU General Public License for more details.
|
||||||
|
#
|
||||||
|
#
|
||||||
|
# $Id$
|
||||||
|
#
|
||||||
|
###############################################################################
|
||||||
|
package FHEM::Devices::Nuki::Device;
|
||||||
|
|
||||||
|
use strict;
|
||||||
|
use warnings;
|
||||||
|
|
||||||
|
use FHEM::Meta;
|
||||||
|
|
||||||
|
# try to use JSON::MaybeXS wrapper
|
||||||
|
# for chance of better performance + open code
|
||||||
|
eval {
|
||||||
|
require JSON::MaybeXS;
|
||||||
|
import JSON::MaybeXS qw( decode_json encode_json );
|
||||||
|
1;
|
||||||
|
};
|
||||||
|
|
||||||
|
if ($@) {
|
||||||
|
$@ = undef;
|
||||||
|
|
||||||
|
# try to use JSON wrapper
|
||||||
|
# for chance of better performance
|
||||||
|
eval {
|
||||||
|
|
||||||
|
# JSON preference order
|
||||||
|
local $ENV{PERL_JSON_BACKEND} =
|
||||||
|
'Cpanel::JSON::XS,JSON::XS,JSON::PP,JSON::backportPP'
|
||||||
|
unless ( defined( $ENV{PERL_JSON_BACKEND} ) );
|
||||||
|
|
||||||
|
require JSON;
|
||||||
|
import JSON qw( decode_json encode_json );
|
||||||
|
1;
|
||||||
|
};
|
||||||
|
|
||||||
|
if ($@) {
|
||||||
|
$@ = undef;
|
||||||
|
|
||||||
|
# In rare cases, Cpanel::JSON::XS may
|
||||||
|
# be installed but JSON|JSON::MaybeXS not ...
|
||||||
|
eval {
|
||||||
|
require Cpanel::JSON::XS;
|
||||||
|
import Cpanel::JSON::XS qw(decode_json encode_json);
|
||||||
|
1;
|
||||||
|
};
|
||||||
|
|
||||||
|
if ($@) {
|
||||||
|
$@ = undef;
|
||||||
|
|
||||||
|
# In rare cases, JSON::XS may
|
||||||
|
# be installed but JSON not ...
|
||||||
|
eval {
|
||||||
|
require JSON::XS;
|
||||||
|
import JSON::XS qw(decode_json encode_json);
|
||||||
|
1;
|
||||||
|
};
|
||||||
|
|
||||||
|
if ($@) {
|
||||||
|
$@ = undef;
|
||||||
|
|
||||||
|
# Fallback to built-in JSON which SHOULD
|
||||||
|
# be available since 5.014 ...
|
||||||
|
eval {
|
||||||
|
require JSON::PP;
|
||||||
|
import JSON::PP qw(decode_json encode_json);
|
||||||
|
1;
|
||||||
|
};
|
||||||
|
|
||||||
|
if ($@) {
|
||||||
|
$@ = undef;
|
||||||
|
|
||||||
|
# Fallback to JSON::backportPP in really rare cases
|
||||||
|
require JSON::backportPP;
|
||||||
|
import JSON::backportPP qw(decode_json encode_json);
|
||||||
|
1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
######## Begin Device
|
||||||
|
|
||||||
|
my %deviceTypes = (
|
||||||
|
0 => 'smartlock',
|
||||||
|
2 => 'opener',
|
||||||
|
3 => 'smartdoor',
|
||||||
|
4 => 'smartlock3'
|
||||||
|
);
|
||||||
|
|
||||||
|
my %deviceTypeIds = reverse(%deviceTypes);
|
||||||
|
|
||||||
|
my %modes = (
|
||||||
|
2 => {
|
||||||
|
0 => 'door mode',
|
||||||
|
2 => 'door mode'
|
||||||
|
},
|
||||||
|
3 => {
|
||||||
|
0 => '-',
|
||||||
|
2 => ' continuous mode'
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
my %lockStates = (
|
||||||
|
0 => {
|
||||||
|
0 => 'uncalibrated',
|
||||||
|
2 => 'untrained',
|
||||||
|
4 => 'uncalibrated'
|
||||||
|
},
|
||||||
|
1 => {
|
||||||
|
0 => 'locked',
|
||||||
|
2 => 'online',
|
||||||
|
4 => 'locked'
|
||||||
|
},
|
||||||
|
2 => {
|
||||||
|
0 => 'unlocking',
|
||||||
|
2 => '-',
|
||||||
|
4 => 'unlocking'
|
||||||
|
},
|
||||||
|
3 => {
|
||||||
|
0 => 'unlocked',
|
||||||
|
2 => 'rto active',
|
||||||
|
4 => 'unlocked'
|
||||||
|
},
|
||||||
|
4 => {
|
||||||
|
0 => 'locking',
|
||||||
|
2 => '-',
|
||||||
|
4 => 'locking'
|
||||||
|
},
|
||||||
|
5 => {
|
||||||
|
0 => 'unlatched',
|
||||||
|
2 => 'open',
|
||||||
|
4 => 'unlatched'
|
||||||
|
},
|
||||||
|
6 => {
|
||||||
|
0 => 'unlocked (lock ‘n’ go)',
|
||||||
|
2 => '-',
|
||||||
|
4 => 'unlocked (lock ‘n’ go)'
|
||||||
|
},
|
||||||
|
7 => {
|
||||||
|
0 => 'unlatching',
|
||||||
|
2 => 'opening',
|
||||||
|
4 => 'unlatching'
|
||||||
|
},
|
||||||
|
253 => {
|
||||||
|
0 => '-',
|
||||||
|
2 => 'boot run',
|
||||||
|
4 => '-'
|
||||||
|
},
|
||||||
|
254 => {
|
||||||
|
0 => 'motor blocked',
|
||||||
|
2 => '-',
|
||||||
|
4 => 'motor blocked'
|
||||||
|
},
|
||||||
|
255 => {
|
||||||
|
0 => 'undefined',
|
||||||
|
2 => 'undefined',
|
||||||
|
4 => 'undefined'
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
my %doorsensorStates = (
|
||||||
|
1 => 'deactivated',
|
||||||
|
2 => 'door closed',
|
||||||
|
3 => 'door opened',
|
||||||
|
4 => 'door state unknown',
|
||||||
|
5 => 'calibrating'
|
||||||
|
);
|
||||||
|
|
||||||
|
sub Define {
|
||||||
|
my $hash = shift;
|
||||||
|
my $def = shift // return;
|
||||||
|
|
||||||
|
return $@ unless ( FHEM::Meta::SetInternals($hash) );
|
||||||
|
use version 0.60; our $VERSION = FHEM::Meta::Get( $hash, 'version' );
|
||||||
|
|
||||||
|
my ( $name, undef, $nukiId, $deviceType ) = split( m{\s+}xms, $def );
|
||||||
|
return 'too few parameters: define <name> NUKIDevice <nukiId> <deviceType>'
|
||||||
|
if ( !defined($nukiId)
|
||||||
|
|| !defined($name) );
|
||||||
|
|
||||||
|
$deviceType =
|
||||||
|
defined($deviceType)
|
||||||
|
? $deviceType
|
||||||
|
: 0;
|
||||||
|
|
||||||
|
$hash->{NUKIID} = $nukiId;
|
||||||
|
$hash->{DEVICETYPEID} = $deviceType;
|
||||||
|
$hash->{VERSION} = version->parse($VERSION)->normal;
|
||||||
|
$hash->{STATE} = 'Initialized';
|
||||||
|
$hash->{NOTIFYDEV} = 'global,autocreate,' . $name;
|
||||||
|
|
||||||
|
my $iodev = ::AttrVal( $name, 'IODev', 'none' );
|
||||||
|
|
||||||
|
::AssignIoPort( $hash, $iodev ) if ( !$hash->{IODev} );
|
||||||
|
|
||||||
|
if ( defined( $hash->{IODev}->{NAME} ) ) {
|
||||||
|
::Log3( $name, 3,
|
||||||
|
"NUKIDevice ($name) - I/O device is " . $hash->{IODev}->{NAME} );
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
::Log3( $name, 1, "NUKIDevice ($name) - no I/O device" );
|
||||||
|
}
|
||||||
|
|
||||||
|
$iodev = $hash->{IODev}->{NAME};
|
||||||
|
|
||||||
|
$hash->{BRIDGEAPI} = $::defs{$iodev}->{BRIDGEAPI}
|
||||||
|
if ( defined($iodev)
|
||||||
|
&& $iodev );
|
||||||
|
|
||||||
|
my $d = $::modules{NUKIDevice}{defptr}{$nukiId};
|
||||||
|
|
||||||
|
return
|
||||||
|
'NUKIDevice device '
|
||||||
|
. $name
|
||||||
|
. ' on NUKIBridge '
|
||||||
|
. $iodev
|
||||||
|
. ' already defined.'
|
||||||
|
if ( defined($d)
|
||||||
|
&& $d->{IODev} == $hash->{IODev}
|
||||||
|
&& $d->{NAME} ne $name );
|
||||||
|
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - defined with NukiId: $nukiId" );
|
||||||
|
|
||||||
|
::CommandAttr( undef, $name . ' room NUKI' )
|
||||||
|
if ( ::AttrVal( $name, 'room', 'none' ) eq 'none' );
|
||||||
|
::CommandAttr( undef, $name . ' model ' . $deviceTypes{$deviceType} )
|
||||||
|
if ( ::AttrVal( $name, 'model', 'none' ) eq 'none' );
|
||||||
|
|
||||||
|
$::modules{NUKIDevice}{defptr}{$nukiId} = $hash;
|
||||||
|
|
||||||
|
GetUpdate($hash)
|
||||||
|
if ( ::ReadingsVal( $name, 'success', 'none' ) eq 'none'
|
||||||
|
&& $::init_done );
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub Undef {
|
||||||
|
my $hash = shift;
|
||||||
|
|
||||||
|
my $nukiId = $hash->{NUKIID};
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - undefined with NukiId: $nukiId" );
|
||||||
|
delete( $::modules{NUKIDevice}{defptr}{$nukiId} );
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub Attr {
|
||||||
|
my $cmd = shift;
|
||||||
|
my $name = shift;
|
||||||
|
my $attrName = shift;
|
||||||
|
my $attrVal = shift;
|
||||||
|
|
||||||
|
my $hash = $::defs{$name};
|
||||||
|
my $token = $hash->{IODev}->{TOKEN};
|
||||||
|
|
||||||
|
if ( $attrName eq 'disable' ) {
|
||||||
|
if ( $cmd eq 'set' && $attrVal == 1 ) {
|
||||||
|
::readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - disabled" );
|
||||||
|
}
|
||||||
|
|
||||||
|
elsif ( $cmd eq 'del' ) {
|
||||||
|
::readingsSingleUpdate( $hash, 'state', 'active', 1 );
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - enabled" );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
elsif ( $attrName eq 'disabledForIntervals' ) {
|
||||||
|
if ( $cmd eq 'set' ) {
|
||||||
|
::Log3( $name, 3,
|
||||||
|
"NUKIDevice ($name) - enable disabledForIntervals" );
|
||||||
|
::readingsSingleUpdate( $hash, 'state', 'Unknown', 1 );
|
||||||
|
}
|
||||||
|
|
||||||
|
elsif ( $cmd eq 'del' ) {
|
||||||
|
::readingsSingleUpdate( $hash, 'state', 'active', 1 );
|
||||||
|
::Log3( $name, 3,
|
||||||
|
"NUKIDevice ($name) - delete disabledForIntervals" );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
elsif ( $attrName eq 'model' ) {
|
||||||
|
if ( $cmd eq 'set' ) {
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - change model" );
|
||||||
|
$hash->{DEVICETYPEID} = $deviceTypeIds{$attrVal};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub Notify {
|
||||||
|
my $hash = shift;
|
||||||
|
my $dev = shift // return;
|
||||||
|
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
return if ( ::IsDisabled($name) );
|
||||||
|
|
||||||
|
my $devname = $dev->{NAME};
|
||||||
|
my $devtype = $dev->{TYPE};
|
||||||
|
my $events = ::deviceEvents( $dev, 1 );
|
||||||
|
|
||||||
|
return if ( !$events );
|
||||||
|
|
||||||
|
GetUpdate($hash)
|
||||||
|
if (
|
||||||
|
(
|
||||||
|
grep /^INITIALIZED$/,
|
||||||
|
@{$events}
|
||||||
|
or grep /^REREADCFG$/,
|
||||||
|
@{$events}
|
||||||
|
or grep /^MODIFIED.$name$/,
|
||||||
|
@{$events}
|
||||||
|
or grep /^DEFINED.$name$/,
|
||||||
|
@{$events}
|
||||||
|
)
|
||||||
|
&& $devname eq 'global'
|
||||||
|
&& $::init_done
|
||||||
|
);
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub Set {
|
||||||
|
my $hash = shift;
|
||||||
|
my $name = shift;
|
||||||
|
my $cmd = shift // return "set $name needs at least one argument !";
|
||||||
|
|
||||||
|
my $lockAction;
|
||||||
|
|
||||||
|
if ( lc($cmd) eq 'statusrequest' ) {
|
||||||
|
|
||||||
|
GetUpdate($hash);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
elsif ($cmd eq 'lock'
|
||||||
|
|| lc($cmd) eq 'deactivaterto'
|
||||||
|
|| $cmd eq 'unlock'
|
||||||
|
|| lc($cmd) eq 'activaterto'
|
||||||
|
|| $cmd eq 'unlatch'
|
||||||
|
|| lc($cmd) eq 'electricstrikeactuation'
|
||||||
|
|| lc($cmd) eq 'lockngo'
|
||||||
|
|| lc($cmd) eq 'activatecontinuousmode'
|
||||||
|
|| lc($cmd) eq 'lockngowithunlatch'
|
||||||
|
|| lc($cmd) eq 'deactivatecontinuousmode'
|
||||||
|
|| $cmd eq 'unpair' )
|
||||||
|
{
|
||||||
|
$lockAction = $cmd;
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
my $list = '';
|
||||||
|
$list =
|
||||||
|
'statusRequest:noArg unlock:noArg lock:noArg unlatch:noArg locknGo:noArg locknGoWithUnlatch:noArg unpair:noArg'
|
||||||
|
if ( $hash->{DEVICETYPEID} == 0
|
||||||
|
|| $hash->{DEVICETYPEID} == 4 );
|
||||||
|
$list =
|
||||||
|
'statusRequest:noArg activateRto:noArg deactivateRto:noArg electricStrikeActuation:noArg activateContinuousMode:noArg deactivateContinuousMode:noArg unpair:noArg'
|
||||||
|
if ( $hash->{DEVICETYPEID} == 2 );
|
||||||
|
|
||||||
|
return ( 'Unknown argument ' . $cmd . ', choose one of ' . $list );
|
||||||
|
}
|
||||||
|
|
||||||
|
$hash->{helper}{lockAction} = $lockAction;
|
||||||
|
|
||||||
|
::IOWrite( $hash, 'lockAction',
|
||||||
|
'{"param":"'
|
||||||
|
. $lockAction
|
||||||
|
. '","nukiId":'
|
||||||
|
. $hash->{NUKIID}
|
||||||
|
. ',"deviceType":'
|
||||||
|
. $hash->{DEVICETYPEID}
|
||||||
|
. '}' );
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub GetUpdate {
|
||||||
|
my $hash = shift;
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
if ( !::IsDisabled($name) ) {
|
||||||
|
::IOWrite( $hash, 'lockState',
|
||||||
|
'{"nukiId":'
|
||||||
|
. $hash->{NUKIID}
|
||||||
|
. ',"deviceType":'
|
||||||
|
. $hash->{DEVICETYPEID}
|
||||||
|
. '}' );
|
||||||
|
|
||||||
|
::Log3( $name, 2, "NUKIDevice ($name) - GetUpdate Call IOWrite" );
|
||||||
|
}
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub Parse {
|
||||||
|
my $hash = shift;
|
||||||
|
my $json = shift // return;
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
::Log3( $name, 5, "NUKIDevice ($name) - Parse with result: $json" );
|
||||||
|
|
||||||
|
#########################################
|
||||||
|
####### Errorhandling #############
|
||||||
|
|
||||||
|
if ( $json !~ m/^[\[{].*[}\]]$/ ) {
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - invalid json detected: $json" );
|
||||||
|
return "NUKIDevice ($name) - invalid json detected: $json";
|
||||||
|
}
|
||||||
|
|
||||||
|
#########################################
|
||||||
|
#### verarbeiten des JSON Strings #######
|
||||||
|
my $decode_json = eval { decode_json($json) };
|
||||||
|
if ($@) {
|
||||||
|
::Log3( $name, 3, "NUKIDevice ($name) - JSON error while request: $@" );
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ( ref($decode_json) ne 'HASH' ) {
|
||||||
|
::Log3( $name, 2,
|
||||||
|
"NUKIDevice ($name) - got wrong status message for $name: $decode_json"
|
||||||
|
);
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
my $nukiId = $decode_json->{nukiId};
|
||||||
|
if ( my $hash = $::modules{NUKIDevice}{defptr}{$nukiId} ) {
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
WriteReadings( $hash, $decode_json );
|
||||||
|
::Log3( $name, 4,
|
||||||
|
"NUKIDevice ($name) - find logical device: $hash->{NAME}" );
|
||||||
|
|
||||||
|
return $hash->{NAME};
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
::Log3( $name, 4,
|
||||||
|
"NUKIDevice ($name) - autocreate new device "
|
||||||
|
. ::makeDeviceName( $decode_json->{name} )
|
||||||
|
. " with nukiId $decode_json->{nukiId}, model $decode_json->{deviceType}"
|
||||||
|
);
|
||||||
|
return
|
||||||
|
'UNDEFINED '
|
||||||
|
. ::makeDeviceName( $decode_json->{name} )
|
||||||
|
. " NUKIDevice $decode_json->{nukiId} $decode_json->{deviceType}";
|
||||||
|
}
|
||||||
|
|
||||||
|
::Log3( $name, 5, "NUKIDevice ($name) - parse status message for $name" );
|
||||||
|
|
||||||
|
WriteReadings( $hash, $decode_json );
|
||||||
|
}
|
||||||
|
|
||||||
|
sub WriteReadings {
|
||||||
|
my $hash = shift;
|
||||||
|
my $decode_json = shift;
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
############################
|
||||||
|
#### Status des Smartlock
|
||||||
|
|
||||||
|
if ( defined( $hash->{helper}{lockAction} ) ) {
|
||||||
|
my $state;
|
||||||
|
|
||||||
|
if (
|
||||||
|
defined( $decode_json->{success} )
|
||||||
|
&& ( $decode_json->{success} eq 'true'
|
||||||
|
|| $decode_json->{success} == 1 )
|
||||||
|
)
|
||||||
|
{
|
||||||
|
$state = $hash->{helper}{lockAction};
|
||||||
|
|
||||||
|
::IOWrite( $hash, 'lockState',
|
||||||
|
'{"nukiId":'
|
||||||
|
. $hash->{NUKIID}
|
||||||
|
. ',"deviceType":'
|
||||||
|
. $hash->{DEVICETYPEID}
|
||||||
|
. '}' )
|
||||||
|
if (
|
||||||
|
::ReadingsVal( $hash->{IODev}->{NAME},
|
||||||
|
'bridgeType', 'Software' ) eq 'Software'
|
||||||
|
);
|
||||||
|
|
||||||
|
}
|
||||||
|
elsif (
|
||||||
|
defined( $decode_json->{success} )
|
||||||
|
&& ( $decode_json->{success} eq 'false'
|
||||||
|
|| $decode_json->{success} == 0 )
|
||||||
|
)
|
||||||
|
{
|
||||||
|
|
||||||
|
$state = $deviceTypes{ $hash->{DEVICETYPEID} } . ' response error';
|
||||||
|
|
||||||
|
::IOWrite( $hash, 'lockState',
|
||||||
|
'{"nukiId":'
|
||||||
|
. $hash->{NUKIID}
|
||||||
|
. ',"deviceType":'
|
||||||
|
. $hash->{DEVICETYPEID}
|
||||||
|
. '}' );
|
||||||
|
}
|
||||||
|
|
||||||
|
$decode_json->{'state'} = $state;
|
||||||
|
delete $hash->{helper}{lockAction};
|
||||||
|
}
|
||||||
|
|
||||||
|
::readingsBeginUpdate($hash);
|
||||||
|
|
||||||
|
my $t;
|
||||||
|
my $v;
|
||||||
|
|
||||||
|
if ( defined( $decode_json->{lastKnownState} )
|
||||||
|
&& ref( $decode_json->{lastKnownState} ) eq 'HASH' )
|
||||||
|
{
|
||||||
|
while ( ( $t, $v ) = each %{ $decode_json->{lastKnownState} } ) {
|
||||||
|
$decode_json->{$t} = $v;
|
||||||
|
}
|
||||||
|
|
||||||
|
delete $decode_json->{lastKnownState};
|
||||||
|
}
|
||||||
|
|
||||||
|
while ( ( $t, $v ) = each %{$decode_json} ) {
|
||||||
|
::readingsBulkUpdate( $hash, $t, $v )
|
||||||
|
if ( $t ne 'state'
|
||||||
|
&& $t ne 'mode'
|
||||||
|
&& $t ne 'deviceType'
|
||||||
|
&& $t ne 'paired'
|
||||||
|
&& $t ne 'batteryCritical'
|
||||||
|
&& $t ne 'batteryChargeState'
|
||||||
|
&& $t ne 'batteryCharging'
|
||||||
|
&& $t ne 'timestamp'
|
||||||
|
&& $t ne 'doorsensorState'
|
||||||
|
&& $t ne 'doorsensorStateName' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate(
|
||||||
|
$hash, $t,
|
||||||
|
(
|
||||||
|
$v =~ m/^[0-9]$/
|
||||||
|
? $lockStates{$v}{ $hash->{DEVICETYPEID} }
|
||||||
|
: $v
|
||||||
|
)
|
||||||
|
) if ( $t eq 'state' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, $t, $modes{$v}{ $hash->{DEVICETYPEID} } )
|
||||||
|
if ( $t eq 'mode' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, $t, $deviceTypes{$v} )
|
||||||
|
if ( $t eq 'deviceType' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, $t, $doorsensorStates{$v} )
|
||||||
|
if ( $t eq 'doorsensorState' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, $t, ( $v == 1 ? 'true' : 'false' ) )
|
||||||
|
if ( $t eq 'paired' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, $t, ( $v == 1 ? 'true' : 'false' ) )
|
||||||
|
if ( $t eq 'batteryCharging' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, 'batteryState',
|
||||||
|
( $v == 1 ? 'low' : 'ok' ) )
|
||||||
|
if ( $t eq 'batteryCritical' );
|
||||||
|
|
||||||
|
::readingsBulkUpdate( $hash, 'batteryPercent', $v )
|
||||||
|
if ( $t eq 'batteryChargeState' );
|
||||||
|
}
|
||||||
|
|
||||||
|
::readingsEndUpdate( $hash, 1 );
|
||||||
|
|
||||||
|
::Log3( $name, 5,
|
||||||
|
"NUKIDevice ($name) - lockAction readings set for $name" );
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
1;
|
||||||
Loading…
x
Reference in New Issue
Block a user