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

<?php

if(isset($_SERVER['REMOTE_ADDR'])) die();
include_once(dirname(__FILE__).'/../../../Common/Global.php');
include_once(dirname(__FILE__).'/../Routerboard.php');
include_once('Common.php');
$Path = array('tool', 'netwatch');
$Period = 60; // every 60 seconds

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

  // 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)
    {
      if($Properties['status'] == 'up')
      {
        $DbResult = $System->Database->update('NetworkInterface', '`LocalIP` = "'.$Properties['host'].'"', 
          array('Online' => $Online, 'LastOnline' => TimeToMysqlDateTime($StartTime)));
      } 
    }
  } 
  $DbResult = $System->Database->update('NetworkInterface', '`LastOnline` < "'.TimeToMysqlDateTime($StartTime).'"', array('Online' => 0));

  // 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)));
  }
  $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);
}