269 lines
7.7 KiB
Perl
Executable File
269 lines
7.7 KiB
Perl
Executable File
#!/usr/bin/perl -wT
|
|
#
|
|
# ==========================================================================
|
|
#
|
|
# ZoneMinder Experimental PTZ Tracking Script, $Date$, $Revision$
|
|
# Copyright (C) 2003, 2004, 2005 Philip Coombes
|
|
#
|
|
# This program 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 (at your option) any later version.
|
|
#
|
|
# This program 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.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
|
|
#
|
|
# ==========================================================================
|
|
#
|
|
# This script is used to trigger and cancel alarms from external sources
|
|
# using an arbitrary text based format
|
|
#
|
|
use strict;
|
|
use bytes;
|
|
|
|
# ==========================================================================
|
|
#
|
|
# User config
|
|
#
|
|
# ==========================================================================
|
|
|
|
use constant ZM_CONFIG => "/usr/local/etc/zm.conf"; # Path to the ZoneMinder config file, autogenerated do not change (from zmconfig)
|
|
use constant ZM_VERSION => "1.20.2"; # ZoneMinder version number, autogenerated do not change (from zmconfig)
|
|
use constant ZM_PATH_BIN => "/usr/local/bin"; # Path to the ZoneMinder executables, autogenerated do not change (from zmconfig)
|
|
|
|
# Load the config from the database into the symbol table
|
|
BEGIN
|
|
{
|
|
no strict 'refs';
|
|
|
|
open( CONFIG, "<".ZM_CONFIG ) or die( "Can't open config file: $!" );
|
|
foreach my $str ( <CONFIG> )
|
|
{
|
|
next if ( $str =~ /^\s*$/ );
|
|
next if ( $str =~ /^\s*#/ );
|
|
my ( $name, $value ) = $str =~ /^\s*([^=\s]+)\s*=\s*([^=\s]+)\s*$/;
|
|
$name =~ tr/a-z/A-Z/;
|
|
if (( $name eq 'ZM_DB_SERVER' ) ||
|
|
( $name eq 'ZM_DB_NAME' ) ||
|
|
( $name eq 'ZM_DB_USER' ) ||
|
|
( $name eq 'ZM_DB_PASS' ))
|
|
{
|
|
*{$name} = sub { $value };
|
|
}
|
|
}
|
|
close( CONFIG );
|
|
|
|
use DBI;
|
|
my $dbh = DBI->connect( "DBI:mysql:database=".&ZM_DB_NAME.";host=".&ZM_DB_SERVER, &ZM_DB_USER, &ZM_DB_PASS );
|
|
my $sql = "select * from Config";
|
|
my $sth = $dbh->prepare_cached( $sql ) or die( "Can't prepare '$sql': ".$dbh->errstr() );
|
|
my $res = $sth->execute() or die( "Can't execute '$sql': ".$sth->errstr() );
|
|
while( my $config = $sth->fetchrow_hashref() )
|
|
{
|
|
*{$config->{Name}} = sub { $config->{Value} };
|
|
}
|
|
$sth->finish();
|
|
$dbh->disconnect();
|
|
}
|
|
|
|
use constant LOG_FILE => ZM_PATH_LOGS.'/zmtrack-%s.log';
|
|
use constant SLEEP_TIME => 10000; # In microseconds
|
|
use constant VERBOSE => 1; # Whether to output more verbose debug
|
|
|
|
# ==========================================================================
|
|
#
|
|
# Don't change anything from here on down
|
|
#
|
|
# ==========================================================================
|
|
|
|
use DBI;
|
|
use POSIX;
|
|
use Data::Dumper;
|
|
use Getopt::Long;
|
|
use Time::HiRes qw( usleep );
|
|
|
|
$| = 1;
|
|
|
|
$ENV{PATH} = '/bin:/usr/bin';
|
|
$ENV{SHELL} = '/bin/sh' if exists $ENV{SHELL};
|
|
delete @ENV{qw(IFS CDPATH ENV BASH_ENV)};
|
|
|
|
my $mid = 0;
|
|
|
|
sub Usage
|
|
{
|
|
print( "
|
|
Usage: zmtrack.pl -m <monitor>,--monitor=<monitor>]
|
|
Parameters are :-
|
|
-m<monitor>, --monitor=<monitor> - Id of the monitor to track
|
|
");
|
|
exit( -1 );
|
|
}
|
|
|
|
if ( !GetOptions( 'monitor=s'=>\$mid ) )
|
|
{
|
|
Usage();
|
|
}
|
|
|
|
my ( $detaint_mid ) = $mid =~ /^(\d+)$/;
|
|
$mid = $detaint_mid;
|
|
|
|
my $log_file = sprintf( LOG_FILE, $mid );
|
|
open( LOG, ">>$log_file" ) or die( "Can't open log file: $!" );
|
|
open( STDOUT, ">&LOG" ) || die( "Can't dup stdout: $!" );
|
|
select( STDOUT ); $| = 1;
|
|
open( STDERR, ">&LOG" ) || die( "Can't dup stderr: $!" );
|
|
select( STDERR ); $| = 1;
|
|
select( LOG ); $| = 1;
|
|
|
|
print( "Tracker daemon $mid (experimental) starting at ".strftime( '%y/%m/%d %H:%M:%S', localtime() )."\n" );
|
|
|
|
my $dbh = DBI->connect( "DBI:mysql:database=".ZM_DB_NAME.";host=".ZM_DB_SERVER, ZM_DB_USER, ZM_DB_PASS );
|
|
|
|
my $sql = "select C.*,M.* from Monitors as M left join Controls as C on M.ControlId = C.Id where M.Id = ?";
|
|
my $sth = $dbh->prepare_cached( $sql ) or die( "Can't prepare '$sql': ".$dbh->errstr() );
|
|
|
|
my $res = $sth->execute( $mid ) or die( "Can't execute '$sql': ".$sth->errstr() );
|
|
my $monitor = $sth->fetchrow_hashref();
|
|
|
|
if ( !$monitor )
|
|
{
|
|
print( "Can't find monitor '$mid'\n" );
|
|
exit( -1 );
|
|
}
|
|
if ( !$monitor->{Controllable} )
|
|
{
|
|
print( "Monitor '$mid' is not controllable\n" );
|
|
exit( -1 );
|
|
}
|
|
if ( !$monitor->{TrackMotion} )
|
|
{
|
|
print( "Monitor '$mid' is not configured to track motion\n" );
|
|
exit( -1 );
|
|
}
|
|
|
|
if ( !$monitor->{CanMoveMap} )
|
|
{
|
|
print( "Monitor '$mid' cannot move in map mode" );
|
|
if ( $monitor->{CanMoveRel} )
|
|
{
|
|
print( ", falling back to pseudo map mode\n" );
|
|
}
|
|
else
|
|
{
|
|
print( "\n" );
|
|
exit( -1 );
|
|
}
|
|
}
|
|
|
|
print( "Found monitor for id '$monitor'\n" ) if ( VERBOSE );
|
|
my $size = 512; # We only need the first 512 bytes really for the alarm state and forced alarm
|
|
$monitor->{ShmKey} = hex(ZM_SHM_KEY)|$monitor->{Id};
|
|
$monitor->{ShmId} = shmget( $monitor->{ShmKey}, $size, 0 );
|
|
if ( !defined($monitor->{ShmId}) )
|
|
{
|
|
printf( "Can't get shared memory id '%x': $!\n", $monitor->{ShmKey}, $! );
|
|
exit( -1 );
|
|
}
|
|
|
|
sub Suspend
|
|
{
|
|
my $monitor = shift;
|
|
my $suspend_cmd = "/usr/local/bin/zmu -m ".$monitor->{Id}." -u -U admin -P pc00zm";
|
|
qx( $suspend_cmd );
|
|
}
|
|
|
|
sub Resume
|
|
{
|
|
my $monitor = shift;
|
|
sleep( $monitor->{TrackDelay} );
|
|
my $resume_cmd = "/usr/local/bin/zmu -m ".$monitor->{Id}." -r -U admin -P pc00zm";
|
|
qx( $resume_cmd );
|
|
}
|
|
|
|
sub Track
|
|
{
|
|
my $monitor = shift;
|
|
my ( $x, $y ) = @_;
|
|
my ( $detaint_x ) = $x =~ /^(\d+)$/; $x = $detaint_x;
|
|
my ( $detaint_y ) = $y =~ /^(\d+)$/; $y = $detaint_y;
|
|
my $move_cmd = $monitor->{Command};
|
|
$move_cmd .= " --device=".$monitor->{ControlDevice} if ( $monitor->{ControlDevice} );
|
|
$move_cmd .= " --address=".$monitor->{ControlAddress} if ( $monitor->{ControlAddress} );
|
|
$move_cmd .= " --command=".($monitor->{CanMoveMap}?"move_map":"move_pseudo_map")." --xcoord=$x --ycoord=$y --width=".$monitor->{Width}." --height=".$monitor->{Height};
|
|
qx( $move_cmd );
|
|
}
|
|
|
|
sub Return
|
|
{
|
|
my $monitor = shift;
|
|
my $move_cmd = $monitor->{Command};
|
|
$move_cmd .= " --device=".$monitor->{ControlDevice} if ( $monitor->{ControlDevice} );
|
|
$move_cmd .= " --address=".$monitor->{ControlAddress} if ( $monitor->{ControlAddress} );
|
|
$move_cmd .= " --command=".($monitor->{ReturnLocation}?"preset1":"preset_home");
|
|
qx( $move_cmd );
|
|
}
|
|
|
|
my $last_alarm = 0;
|
|
if ( ($monitor->{ReturnLocation} >= 0) )
|
|
{
|
|
Suspend( $monitor );
|
|
Return( $monitor );
|
|
Resume( $monitor );
|
|
}
|
|
|
|
my $alarmed = undef;
|
|
while( 1 )
|
|
{
|
|
my $state;
|
|
if ( !shmread( $monitor->{ShmId}, $state, 8, 4 ) )
|
|
{
|
|
print( "Can't read from shared memory: $!\n" );
|
|
exit( -1 );
|
|
}
|
|
$state = unpack( "l", $state );
|
|
|
|
if ( $state == 2 ) # Alarmed
|
|
{
|
|
my $alarm_pos;
|
|
if ( !shmread( $monitor->{ShmId}, $alarm_pos, 48, 8 ) )
|
|
{
|
|
print( "Can't read from shared memory '$monitor->{ShmKey}/$monitor->{ShmId}': $!\n" );
|
|
next;
|
|
}
|
|
my ( $alarm_x, $alarm_y ) = unpack( "ll", $alarm_pos );
|
|
if ( $alarm_x > 0 && $alarm_y > 0 )
|
|
{
|
|
print( "Got alarm at $alarm_x, $alarm_y\n" ) if ( VERBOSE );
|
|
Suspend( $monitor );
|
|
Track( $monitor, $alarm_x, $alarm_y );
|
|
Resume( $monitor );
|
|
$last_alarm = time();
|
|
$alarmed = !undef;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if ( VERBOSE && $alarmed )
|
|
{
|
|
print( "Left alarm state\n" );
|
|
$alarmed = undef;
|
|
}
|
|
if ( ($monitor->{ReturnLocation} >= 0) && ($last_alarm > 0) && ((time()-$last_alarm) > $monitor->{ReturnDelay}) )
|
|
{
|
|
print( "Returning to location ".$monitor->{ReturnLocation}."\n" ) if ( VERBOSE );
|
|
Suspend( $monitor );
|
|
Return( $monitor );
|
|
Resume( $monitor );
|
|
$last_alarm = 0;
|
|
}
|
|
}
|
|
usleep( SLEEP_TIME );
|
|
}
|