dimosha13

// new device

$tm=registeredEventTime('btcall'); 
if ((time()-$tm)>60 || $tm<0) {
 registerEvent('btcall'); 
}


if ($params['new']) {
 //say('Обнаружено новое блютуз устройство');
}
if ($params['user']!='') {
 //say($params['user'].' где-то рядом');
}

// device lost

$command=$params['command'];

$short_command='';
$dt=recognizeTime($command,$short_command);

if (preg_match('/скажи сколько время/is',$command)) {
 if ($dt>0) {
  addScheduledJob("command".$dt,"processCommand('".$short_command."');",$dt);
  say('Задача принята');
  return;
 }
 global $voicemode;
 $voicemode='on';
 say('Сейчас '.timeNow());
} elseif (preg_match('/сколько время/is',$command)) {
 if ($dt>0) {
  addScheduledJob("command".$dt,"processCommand('".$short_command."');",$dt);
  say('Задача принята');
  echo $short_command;
  return;
 }
 say('Сейчас '.timeNow());
} elseif (preg_match('/повтори (.+)/is',$command,$m) || preg_match('/скажи (.+)/is',$command,$m)) {
 if ($dt>0) {
  addScheduledJob("command".$dt,"processCommand('".$short_command."');",$dt);
  say('Задача принята');
  return;
 }
 global $voicemode;
 $voicemode='on';
 say($m[1]);
} else {
 say('Неизвестная команда...');
}

say("Отключено питание");

 sg($This + ".status",1);

 sg($This + ".status",0);

echo("<BR>Start");
if (isset($params['prm'])){
$prm=$params['prm'];
}

$s=$params['s'];
$prm=$params['prm'];
$idd=$params['id'];
$idp=$params['idp'];
echo("<BR>"."ID=".$idd." Status=".$s);	

//-----------------------------------------------------------------
$objects=getObjectsByClass("RF_Device");
echo("<br>");
foreach($objects as $obj) {
$ob=getObject($obj['TITLE']);
$ID=$ob->getProperty("ID"); 
echo($obj['TITLE']." Class -".get_class($ob)." ID= ".$ID." Status= ".$s);
if ($ID==$idd){
	echo("     Поступила команда   <BR>");
	$ob->callmethod("SetStatus",array("s"=>hexdec($s),"prm"=>hexdec($prm),"idp"=>hexdec($idp),"prm"=>hexdec($prm)));
	//if (isset($params['prm'])){
	//$ob->callmethod("SetStatus",array("prm"=>hexdec($prm)));
	//}
}
echo("<BR>");
}
//-----------------------------------------------------------------

echo("<BR>Adress request");

$ADDR=$params['prm'];
echo($ADDR);
$CMD=$params['s'];
//-------------------------------------------------------------------------------------------------------------------
//  Обработка запроса от RF-модуля на выделение нового адреса.
//  Адрес определяется как очередной из уже существующих. Адрес ControlCentre - зарезервирован и в выборе не участвует
//-------------------------------------------------------------------------------------------------------------------

if ($CMD==9) {
echo("Incoming address request");
// ---------------------- Формирование нового номера модуля --------------------------------------------------------- 
// Для определения очередного номера делаем запрос в базу объектов с фильтром по PROPERTY_ID объекта - 86  (поле с номером модуля)
$result = mysql_query("SELECT * FROM `pvalues` WHERE `PROPERTY_ID`=86");
if (!$result) {
    echo mysql_error();
}

if (!$result) {
    $message  = 'Неверный запрос: ' . mysql_error() . "\n";
    //$message .= 'Запрос целиком: ' . $query;
    die($message);
}
//------------------------------------------------------------------------------------------------------------------
$NEW_ModuleID=0;

while ($row = mysql_fetch_object($result)) {
    echo ("ID:".$row->ID);
    echo (" OBJECT:".$row->OBJECT_ID);
    echo (" PROPERTY_ID:".$row->PROPERTY_ID);
    echo (" VALUE:".$row->VALUE);
    echo ("<BR>");
    // ------------------------ если наткнулись на объект ControlCenter (т.е. на себя ) то пропускаем (Обычно у него номер идет не по-порядку) -------------
    if  ( $row->VALUE == $this->getProperty("ID")) {
    echo("It's Control center - continue...<BR>");
    continue;
    }
    //------------------------- здесь находим самый большой(последний) номер --------------------------------------------------
    if ($row->VALUE>$NEW_ModuleID) {
    	$NEW_ModuleID=$row->VALUE;
    //--------------------------------------------------------------------------------------------------------------
    }
}
mysql_free_result($result);  			// Удаление объекта с результатом запроса. 
//---------------------------- здесь создаем новый номер кратный 0x10 ------------------------------------------------
echo "MAX_ModuleID:".$NEW_ModuleID."<BR>";

//----------- В базе хранятся номера модулей в HEX виде, но этот вид не помечен ни "0х" ни "\х". Поэтому следующий блок приводит номер к НЕХ виду
//----------- и вычисляет следующий по порядку номер для модуля кратный 0х10 
$NEW_ModuleID=hexdec("0x".$NEW_ModuleID);
//echo "NEW_ModuleID(HEX):". sprintf("%04X",$NEW_ModuleID)."<BR>";
$NEW_ModuleID=floor($NEW_ModuleID/0x10)*0x10+0x10;

// ------- Если новый адрес совпадает с адресом СontrolCenter то берем следующий адрес -----------------------------
   $aa=substr_replace($this->getProperty("ID"), '0', -1);  // Из адреса элемента формируем RF адрес модуля, последней цифрой ставя ноль
   if  ( $NEW_ModuleID == $aa ) {
      $NEW_ModuleID=hexdec("0x".$NEW_ModuleID);
      $NEW_ModuleID=floor($NEW_ModuleID/0x10)*0x10+0x10;
   }
// ------------------------------------------------------------------------------------------------------------------

//echo "NEW_ModuleID(HEX):". sprintf("%04X",$NEW_ModuleID)."<BR>";
//echo sprintf("%02X%02X",$NEW_ModuleID&0x00FF,$NEW_ModuleID>>8);
//-----------------  Отсылаем новый номер устройству ---------------------------------------------------------------- 
$ID="E7E7E7".$ADDR;

echo("<BR>".$ADDR);
//echo("<BR>".sprintf("%02X%02X",$ADDR&0x00FF,$ADDR>>8));

$ADDR=hexdec("0x".$ADDR);
$IDS=sprintf("%02X%02X",$ADDR&0x00FF,$ADDR>>8); //
$CMD='08'."00"."00000000".sprintf("%02X%02X",$NEW_ModuleID&0x00FF,$NEW_ModuleID>>8)."3131";  // сложная конструкция с побитовыми операциями - это смена местами старшего и младшего байта, для передачи
safe_exec('"C:/_majordomo/apps/arduino_gw/arduino_gw.exe" '.$ID.$IDS.$CMD);
echo("<BR>".'"C:/_majordomo/apps/arduino_gw/arduino_gw.exe" '.$ID.$IDS.$CMD);
}

if ($CMD==7) {
echo("Incoming address confirmation");
$NEW_ModuleID=$ADDR;
// ---------------------- Создаем новый RF объект в базе ------------------------------------------------------------
$TITLE="New RF device";
$CLASS_ID=29;
$DESCRIPTION="New RF device ModuleID: ".sprintf("%04s",$NEW_ModuleID); //  в описание сразу добавляем номер модуля для удобства
$LOCATION_ID=4;

$query_o = "INSERT INTO `objects` (`TITLE`, `CLASS_ID`, `DESCRIPTION`,`LOCATION_ID`) VALUE (\"$TITLE\", \"$CLASS_ID\",
        \"$DESCRIPTION\", \"$LOCATION_ID\")";

echo("<BR>"."Create new object".$query_o."<BR>");        
        
mysql_query ($query_o) or die (mysql_error());
//-------- Сохраняем ИД нового объекта для дальнейшего создания записи со свойствами для этого объекта -----------
$NEW_OBJECT_ID=mysql_insert_id();
echo("<BR>Last inserted record has id ".$NEW_OBJECT_ID." <BR>");
// ---------------------- Присваиваем номер модулю -----------------------------------------------------------------
$PROPERTY_ID=86; 				// 86 - свойство с номером модуля
$OBJECT_ID=$NEW_OBJECT_ID;			// ИД только что созданого объекта
$VALUE=sprintf("%04s",$NEW_ModuleID);		// номер модуля

echo "NEW_ModuleID(HEX):".$VALUE."<BR>";
$query_pv = "INSERT INTO `pvalues` (`PROPERTY_ID`, `OBJECT_ID`, `VALUE`) VALUE (\"$PROPERTY_ID\", \"$OBJECT_ID\",\"$VALUE\")";

echo("<BR>".$query_pv); 

mysql_query ($query_pv) or die (mysql_error());

$this->setProperty("LastCommand",$CMD); // сохраняем полседнюю команду, Типа мини-лог.

}

echo("Exit DHCP");

$aa=(round(intval($this->getProperty("ID"))/10, 0)*10);
$aa=str_pad($aa, 4, "0", STR_PAD_LEFT);

echo("<BR>".$aa);
$IDS="E0E1";//intval($this->getProperty("ID"));
$ID=("E7E7E7".$IDS);//$aa;
$CMD='06';

$objects=getObjectsByClass("RF_Device");
echo("<br>");
foreach($objects as $obj) 
{
	$ob=getObject($obj['TITLE']);
	//$ob=$this;
	
	if ($ob->object_title!=$this->object_title){
	$ob->callmethod("SetNames");
	}
	
//	$IDdev=hexdec("0x".$ob->getProperty("ID")); 
//	$IDdev=sprintf("%02X%02X",$IDdev&0x00FF,$IDdev>>8);
//	$name=$ob->object_title;

echo("<BR>".$name." ");
/*
for ($aa=0;$aa<16;$aa++) {
  $IDp=sprintf("%02X",$aa);
  $Param=sprintf("%02X",ord($name{$aa})).'00';
  if ($Param=="0000"){
     break;
  }
 

//  safe_exec('"C:/_majordomo/apps/arduino_gw/arduino_gw.exe" '.$ID.$IDdev.$CMD.$IDp."00000000".$Param."3131");


}
*/


//usleep(1000000);
}
//safe_exec('"echo>>C:/_majordomo/apps/arduino_gw/arduino_gw.log "'.date("H:i",time())." : ".$ID.$IDS."00".'03'."00"."00000000"."0000"."3131");

$aa="";
$ID="";
$IDS="";

$aa=(round(intval($this->getProperty("ID"))/10, 0)*10);
$aa=str_pad($aa, 4, "0", STR_PAD_LEFT);

echo("<BR>".$aa);
$IDS="E0E1";//intval($this->getProperty("ID"));
$ID=("E7E7E7".$IDS);//$aa;
$CMD='0A';

$objects=getObjectsByClass("TextMessages");
echo("<br>");
foreach($objects as $obj) 
{
	$ob=getObject($obj['TITLE']);
	$IDtext=$ob->getProperty("Text");
	$IDdev=hexdec("0x".$ob->getProperty("ID")); 
	$IDdev=sprintf("%02X%02X",$IDdev&0x00FF,$IDdev>>8);	

echo("<BR>".$IDtext." ");


for ($aa=0;$aa<16;$aa++) {

  $IDp=sprintf("%02X",$aa);
  $Param=sprintf("%02X",ord($IDtext{$aa})).'00';
  if ($Param=="0000"){
     break;
  }

echo("<BR>".$ID.$IDdev.$CMD.$IDp."00000000".$Param."3131"."<BR>");
 
 safe_exec('"C:/_majordomo/apps/arduino_gw/arduino_gw.exe" '.$ID.$IDdev.$CMD.$IDp."00000000".$Param."3131");


}
}

$aa=(round(intval($this->getProperty("ID"))/10, 0)*10);
$aa=str_pad($aa, 4, "0", STR_PAD_LEFT);

echo("<BR>".$aa);
$IDS="E0E1";//intval($this->getProperty("ID"));
$ID=("E7E7E7".$IDS);//$aa;
$CMD='0B';

$objects=getObjectsByClass("TextMessages");
echo("<br>");
//foreach($objects as $obj) 
//{
	//$ob=getObject($obj['TITLE']);
	//$IDtext=$ob->getProperty("ID");
	$IDdev=hexdec("0x"."0001"); 
	$IDdev=sprintf("%02X%02X",$IDdev&0x00FF,$IDdev>>8);	

//echo("<BR>".$IDtext." ");

echo("<BR>".$ID.$IDdev.$CMD.$IDp."00000000".$Param."3131"."<BR>");

safe_exec('"C:/_majordomo/apps/arduino_gw/arduino_gw.exe" '."E7E7E7E0E102000B010000000061003131"); 

// safe_exec('"C:/_majordomo/apps/arduino_gw/arduino_gw.exe" '.$ID.$IDdev.$CMD."00"."00000000".$Param."3131");


//}
//}

echo "status received: ".$params['status'];

 global $voicemode;
 $voicemode='off';
 processCommand($params['message']);

$details=array();
$red_state=0;
$yellow_state=0;

if ($red_state) {
 $state='red';
 $state_title='Red'; 
} elseif ($yellow_state) {
 $state='yellow';
 $state_title='Yellow';  
} else {
 $state='green';
 $state_title='Green';   
}

$new_details=implode(". ",$details);
if ($this->getProperty("stateDetails")!=$new_details) {
 $this->setProperty('stateDetails',$new_details);
}

if ($this->getProperty('stateColor')!=$state) {
 $this->setProperty('stateColor',$state);
 $this->setProperty('stateTitle',$state_title);
 if ($state!='green') {
  say("System state changed to ".$state_title.".");
  say(implode(". ",$details));
 } else {
  say("System state restored to ".$state_title);
 }
 $this->callMethod('stateChanged');
}

$details=array();
$red_state=0;
$yellow_state=0;

$cycles=array('states'=>'states cycle','main'=>'main cycle','execs'=>'exec cycle','scheduler'=>'scheduler cycle');
foreach($cycles as $k=>$v) {
 $tm=getGlobal('ThisComputer.cycle_'.$k.'Run');
 if (time()-$tm>5*60) {
  $red_state=1;
  $details[]=$v." stopped.";
 }
}

$cycles=array('ping'=>'ping cycle','webvars'=>'webvars cycle','watchfolders'=>'watch folders cycle','rss'=>'RSS cycle');
foreach($cycles as $k=>$v) {
 $tm=getGlobal('ThisComputer.cycle_'.$k.'Run');
 if (time()-$tm>10*60) {
  $yellow_state=1;
  $details[]=$v." stopped.";
 }
}

if ($red_state) {
 $state='red';
 $state_title='Red'; 
} elseif ($yellow_state) {
 $state='yellow';
 $state_title='Yellow';  
} else {
 $state='green';
 $state_title='Green';   
}

$new_details=implode(". ",$details);
if ($this->getProperty("stateDetails")!=$new_details) {
 $this->setProperty('stateDetails',$new_details);
}

if ($this->getProperty('stateColor')!=$state) {
 $this->setProperty('stateColor',$state);
 $this->setProperty('stateTitle',$state_title);
 if ($state!='green') {
  say("System state changed to ".$state_title.".");
  say(implode(". ",$details));
 } else {
  say("System state restored to ".$state_title);
 }
 $this->callMethod('stateChanged');
}

$details=array();
$red_state=0;
$yellow_state=0;

if ($red_state) {
 $state='red';
 $state_title='Red'; 
} elseif ($yellow_state) {
 $state='yellow';
 $state_title='Yellow';  
} else {
 $state='green';
 $state_title='Green';   
}

$new_details=implode(". ",$details);
if ($this->getProperty("stateDetails")!=$new_details) {
 $this->setProperty('stateDetails',$new_details);
}

if ($this->getProperty('stateColor')!=$state) {
 $this->setProperty('stateColor',$state);
 $this->setProperty('stateTitle',$state_title);
 if ($state!='green') {
  say("System state changed to ".$state_title.".");
  say(implode(". ",$details));
 } else {
  say("System state restored to ".$state_title);
 }
 $this->callMethod('stateChanged');
}

//------------------------------------------------------------------------------------
// Конвертирует количество секунд в читабельное время : 5w 4d 6h 58m 50s
function time_elapsed_A($secs){
    $bit = array(
        'y' => $secs / 31556926 % 12,
        'w' => $secs / 604800 % 52,
        'd' => $secs / 86400 % 7,
        'h' => $secs / 3600 % 24,
        'm' => $secs / 60 % 60,
        's' => $secs % 60
        );
        
    foreach($bit as $k => $v)
        if($v > 0)
           $ret[] = $v . $k ;
        else 
           $ret[] =  "" ;
        
    return join(" ", $ret);
    }
//-------------------------------------------------------------------------------------

$h=(int)date('G',time());
$m=date('i',time());


if (isWeekDay()) {

}

//------------------ Опрос всех датчиков температуры --------------------------------------------------
$nowtime = time();			       // Текущее время
$objects=getObjectsByClass("TempSensors");     // Выбираем все датчики температуры
echo("<BR>----------------------------------");
echo("<BR>   Датчики температуры");
echo("<BR>----------------------------------");
foreach($objects as $obj) {
   $ob=getObject($obj['TITLE']);

   $updated=$ob->getProperty("updated");       //  Получаем время последнего успешного опроса
   $temp=$ob->getProperty("RequestPeriod");    //  Получаем период опроса из свойств датчика

   if ( $temp == "" ) {			       //  Если период не установлен принимаем за 10 мин
     $temp=10;
   }
   $interval= ($nowtime-$updated)/60;		// вычисляем время прошедшее с последнего успешного опроса в минутах ( /60 ) 
 
   echo("<br>".$ob->object_title." Elapsed time: ".$interval." => ".$temp);
 
   if ( $interval > $temp ){
      echo(" отправка запроса...");
      $ob->callmethod("TempRequest");		// Если время истекло, посылаем запрос на датчик
      }
   else {
      echo(" ждем ...");
      }
}

//-------------------------------------------------------------------------------
//    Проверка доступности датчиков по времени последнего контакта Свойство LastConnect.
$nowtime = time();
$devices=getObjectsByClass("RF_Device");     					//  перебираем все удаленные устройства
//------------------------------------------------------------------------------------------------------------------------
echo("<BR>----------------------------------");
echo("<BR>   Проверка доступности модулей");
echo("<BR>----------------------------------");
		foreach($devices as $dev) {
		$device=getObject($dev['TITLE']);
		$updated=$device->getProperty("updated");			
		$AliveTimeOut=$device->getProperty("AliveTimeOut");
		echo("<BR>Device: ".$dev['TITLE']." Time: ".date('Y-m-d h:s', $updated));
		echo "time_elapsed: ".time_elapsed_A($nowtime-$updated)."\n";
		//----------------------------------------------
		if ($AliveTimeOut == "" ) {					// если время допустимой неактивности не указано 
		  $AliveTimeOut=60*15 ; // 15 min				// берем 15 минут
		}
		//----------------------------------------------
		if ( $nowtime-$updated > $AliveTimeOut ){			// помечаем датчик активным/неактивным
		$device->setProperty("Active",0);				// в зависимости от прошедшего времени с последнего отклика
		echo("NoActive 0");
		//----------------------------------------------		// запрос имени класса объекта 
		$SQL_R=SQLSelectOne("SELECT * FROM classes WHERE ID='".(int)$device->class_id."'"); 
		$class=$SQL_R['TITLE'];
		//----------------------------------------------
		echo("<br>->".$class."<-<br>");		
		if ($class=="MovementSensors") {
	//		$device->callMethod("MovementOFF");			// Для датчика движения сбрасываем состояние в неактивное
		   }
		//----------------------------------------------
		   }
		else {
		    $device->setProperty("Active",1);
		    echo("Active 1");
		   }
		//----------------------------------------------
		}
//------------------------------------------------------------------------------------------------------------------------
// Поддержание температурного режима.
// Выбираем все комнаты и проверяем температуру в каждой
echo("<BR>----------------------------------");
echo("<BR>   Проверка комнат");

$objects=getObjectsByClass("Rooms");

foreach($objects as $obj) {
$ob=getObject($obj['TITLE']);
echo("<BR><BR>---- ".$obj['TITLE']." -------<BR>");
echo ("Терморегуляция ");
if ( $ob->getProperty("AutoTemp")==1 ) {
echo ("включена.");

	$T=$ob->getProperty("Temperature");
	$ST=$ob->getProperty("SetTemperature");
	if (($T=="") | ($ST=="")) {
//	continue;
	}
	
	echo("<BR>".$obj['TITLE']." t= ".$T.", Required : ".$ST." .");
	
	if ( ($T) < ($ST-2) ) {  // Если температура ниже заданной более чем на два градуса - ищем комнатный обогреватель и включаем его
	echo(" Room ".$ob->object_title." must be heated. ");
	$ob->callMethod("HeatersON");
	}
	
	if ( ($T) > ($ST) ) {  // Если температура выше заданной ищем комнатный обогреватель и вЫключаем его
	echo("Room ".$ob->object_title." must be cooled. ");
	$ob->callMethod("HeatersOFF");
	}
$ob->callMethod("CheckState");	 // опрос состояния и систем комнаты
	
    }
  
else {
		
echo ("выключена.<br>");
}

$ob->callMethod("CheckState");	 // опрос состояния и систем комнаты

    	
 }
//---------------------------------------------------------------------------------------------------------
				// Отработка режима энергосбережения
				
$devices=getObjectsByClass("Rooms");     					//  перебираем объекты типа ROOM
//------------------------------------------------------------------------------------------------------------------------
	foreach($devices as $dev) {
	$device=getObject($dev['TITLE']);
	$updated=$device->getProperty("LatestActivity");		// вычисляем период времени до последней активности в комнате
	
	if ( ($device->getProperty("EconomMode")==1 ) & ( $nowtime-$updated > 15 ) )  {    //  > 15 минут и включен эконом режим 	
											  //  ищем связанный с комнатой выключатель света и гасим свет

	//$device-> callMethod("");

	}

}				
//---------------------------------------------------------------------------------------------------------
				//	Голосовые сообщения     //
		
if (($h>=8)) {			// Объявление каждого нового часа
 if ($m=="00") {
   say(timeNow());
 }
}

if (($h==9)) {			// Утренне приветствие
 if ($m=="00") {
   runScript("morningGreeting");
 }
}

if (($h==13)) {			// обеденное приветствие
 if ($m=="00") {
   runScript("LunchTime");
 }
}


if (($h==17)) {			// Обявление об окончании рабочего дня
 if ($m=="25") {
   say(timeNow());
   runScript("WorkTimeOut");
 }
}
//--------------------------------------------------------------------------------------------------------------

if ($params['serial']=='' && $params['devname']!='') {
 $params['serial']=$params['devname'];
}

$device=SQLSelectOne("SELECT * FROM usbdevices WHERE SERIAL LIKE '".$params['serial']."'");
if (!$device['ID']) {
 // new device connected
 //say("Подключено новое устройство",1);
 $device=array();
 $device['SERIAL']=$params['serial'];
 $device['TITLE']='устройство '.$params['devname'];
 $device['FIRST_FOUND']=date('Y-m-d H:i:s');
 $device['LAST_FOUND']=date('Y-m-d H:i:s');
 $device['LOG'].=$device['FIRST_FOUND'].' подключено (впервые)'."\n";
 $device['ID']=SQLInsert('usbdevices',$device);
} else {
 // device already in our database
 //say("Подключено ".$device['TITLE'],1);
 if ($device['USER_ID']) {
  $user=SQLSelectOne("SELECT * FROM users WHERE ID='".$device['USER_ID']."'");
  if ($user['ID']) {
    //$user['NAME']; // теперь мы знаем имя пользователя, связанного с этим устройством
  }
 }
 $device['LAST_FOUND']=date('Y-m-d H:i:s');
 $device['LOG']=$device['LAST_FOUND'].' подключено'."\n".$device['LOG'];
 SQLUpdate('usbdevices',$device);
 if ($device['SCRIPT_ID']!='') {
  runScript($device['SCRIPT_ID'],$params);
 } elseif ($device['SCRIPT']!='') {
  eval($device['SCRIPT']);
 }
}

$w=round(strip_tags(gg("TempSensor2.Temp"))); //Переводим погоду в переменную
if($w < "0"){ // Задаем условие - если погода минусовая то:
    $w=abs($w); // Выводим в плюс
    say(' На улице ' .$w.' градусов мороза'  ); 
   }
else
{
    say(' На улице ' .$w.' градусов тепла'  ); 
}