source: trunk/Modules/NetworkConfigRouterOS/Generators/NetwatchImport.php@ 667

<?php

if(isset($_SERVER['REMOTE_ADDR'])) die();
include_once(dirname(__FILE__).'/../../../Application/System.php');
$System = new System();
$System->ShowPage = false;
$System->Run();

$Path = array('tool', 'netwatch');
$Period = 60; // every 60 seconds


while(1)
{
  $StartTime = time();

  // Load all interfaces to memory
  $Interfaces = array();
  $DbResult = $System->Database->select('NetworkInterface', '`Id`, `LocalIP` AS `IP`, `Online`, 0 AS `NewOnline`');
  while($DbRow = $DbResult->fetch_assoc())
    $Interfaces[$DbRow['IP']] = $DbRow;

  // Load netwatch status from all DHCP routers
  $DbResult3 = $System->Database->query('SELECT `DHCP`, `AddressRange`, `Mask` FROM `NetworkSubnet` '.
                'WHERE (`Configure` = 1) AND (`Member` IS NULL) GROUP BY DHCP');
  while($Subnet = $DbResult3->fetch_assoc())
  {
    echo($Subnet['AddressRange'].'/'.$Subnet['Mask'].' on router '.$Subnet['DHCP']."\n");
    $Routerboard = new Routerboard();
    $Routerboard->UserName = $Config['MainRouter']['UserName'];
    $Routerboard->Timeout = $Config['MainRouter']['ConnectTimeout'];
    $Routerboard->HostName = $Subnet['DHCP'];
    $List = $Routerboard->ListGetPrint($Path, array('host', 'status'));
    foreach($List as $Properties)
    {
      $IP = $Properties['host'];
      if($Properties['status'] == 'up') $Online = 1;
        else $Online = 0;

      if($Online)
      {
        if(array_key_exists($IP, $Interfaces))
          $Interfaces[$IP]['NewOnline'] = 1;
          else echo('IP '.$IP.' not found.'."\n");
      }
    }
  }

  foreach($Interfaces as $Index => $Interface)
  {
    // Update last online time if still online
    if($Interface['NewOnline'])
      $DbResult = $System->Database->update('NetworkInterface', '`Id` = "'.$Interface['Id'].'"',
        array('LastOnline' => TimeToMysqlDateTime($StartTime)));

        if($Interface['Online'] != $Interface['NewOnline'])
    {
        // Online state changed
      $System->Database->insert('NetworkInterfaceUpDown', array(
        'Interface' => $Interface['Id'], 'State' => $Interface['NewOnline'],
           'Time' => TimeToMysqlDateTime($StartTime)));
      $System->Database->update('NetworkInterface', '`Id` = "'.$Interface['Id'].'"',
        array('Online' => $Interface['NewOnline']));
    }
  }

  // Set offline all interfaces which were not updated as online
  $DbResult = $System->Database->select('NetworkInterface', '*', '(`Online` = 1) AND '.
    '(`LastOnline` < "'.TimeToMysqlDateTime($StartTime).'")');
  while($DbRow = $DbResult->fetch_assoc())
  {
        echo('IP '.$DbRow['LocalIP'].' online but time not updated.'."\n");
  }
  $DbResult = $System->Database->select('NetworkInterface', '*', '(`Online` = 0) AND '.
    '(`LastOnline` >= "'.TimeToMysqlDateTime($StartTime).'")');
  while($DbRow = $DbResult->fetch_assoc())
  {
    echo('IP '.$DbRow['LocalIP'].' not online but time updated.'."\n");
  }

  // Update device online state
  $DbResult = $System->Database->select('NetworkInterface', '`Device`, SUM(`Online`) AS `SumOnline`', '`Online` = 1 GROUP BY `Device`');
  while($Device = $DbResult->fetch_assoc())
  {
    if($Device['SumOnline'] > 0)
      $System->Database->update('NetworkDevice', 'Id='.$Device['Device'], array('LastOnline' => TimeToMysqlDateTime($StartTime), 'Online' => 1));
  }
  $DbResult = $System->Database->update('NetworkDevice', '`LastOnline` < "'.TimeToMysqlDateTime($StartTime).'"', array('Online' => 0));

  // Update interface online statistics
  $DbResult = $System->Database->select('NetworkInterface', 'Id', '`Online` = 1');
  while($Interface = $DbResult->fetch_assoc())
  {
    $DbResult2 = $System->Database->select('NetworkInterfaceStat', '*', '(`NetworkInterface`="'.$Interface['Id'].'") AND (`Time` = DATE_FORMAT(NOW(), "%Y-%m-%d %H:00:00"))');
    if($DbResult2->num_rows == 0) $System->Database->query('REPLACE INTO `NetworkInterfaceStat` (`NetworkInterface`, `Time`, `PingCount`) VALUES ("'.$Interface['Id'].'", DATE_FORMAT(NOW(), "%Y-%m-%d %H:00:00"), 1)');
      else $System->Database->query('UPDATE `NetworkInterfaceStat` SET `PingCount` = `PingCount` + 1 WHERE (`NetworkInterface`="'.$Interface['Id'].'") AND (`Time` = DATE_FORMAT(NOW(), "%Y-%m-%d %H:00:00"))');
  }

  $EndTime = time();
  $Delay = $Period - ($EndTime - $StartTime);
  if($Delay < 0) $Delay = 0;

  echo('Waiting '.$Delay.' seconds...'."\n");
  sleep($Delay);
}