123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289 |
- <?php
- /*
- @nom: Story
- @auteur: Idleman (idleman@idleman.fr)
- @description: Représente un scénario avec ses causes de déclenchement et ses effets associés
- */
- class Story extends SQLiteEntity{
- public $id,$date,$user,$label,$state,$log;
- protected $TABLE_NAME = 'plugin_story';
- protected $CLASS_NAME = 'Story';
- protected $object_fields =
- array(
- 'id'=>'key',
- 'date'=>'string',
- 'user'=>'int',
- 'label'=>'string',
- 'state'=>'int',
- 'log'=>'longstring'
- );
- function __construct(){
- parent::__construct();
- }
-
- public static function keywords(){
- global $myUser,$conf;
-
- $sunrise_time = $conf->get('YANA_LATITUDE') !=''? date_sunrise(time(), SUNFUNCS_RET_TIMESTAMP, $conf->get('YANA_LATITUDE'),$conf->get('YANA_LONGITUDE'), 90, 1):0;
- $sunset_time = $conf->get('YANA_LATITUDE') !='' ? date_sunset(time(), SUNFUNCS_RET_TIMESTAMP, $conf->get('YANA_LATITUDE'),$conf->get('YANA_LONGITUDE'), 90, 1):0;
-
-
- return array(
- '{DATE}'=>date('d-m-Y'),
- '{YEAR}'=>date('Y'),
- '{MONTH}'=>date('m'),
- '{DAY}'=>date('d'),
- '{HOUR}'=>date('H'),
- '{MINUT}'=>date('i'),
- '{TIME}'=>time(),
- '{USER.LOGIN}'=>$myUser->getLogin(),
- '{USER.ID}'=>$myUser->getId(),
- '{USER.MAIL}'=>$myUser->getMail(),
- '{YANA.URL}'=>YANA_URL,
- '{SUNRISE.TIMESTAMP}'=>$sunrise_time,
- '{SUNRISE.HOUR}'=>date('H',$sunrise_time),
- '{SUNRISE.MINUT}'=>date('i',$sunrise_time),
- '{SUNSET.TIMESTAMP}'=>$sunset_time,
- '{SUNSET.HOUR}'=>date('H',$sunset_time),
- '{SUNSET.MINUT}'=>date('i',$sunset_time)
- );
- }
-
- public static function check($event=array()){
- require_once(dirname(__FILE__).'/Cause.class.php');
-
- global $conf;
-
-
- self::out('Vérification des scénarios');
-
- $causeManager = new Cause('r');
- $storyCauses = $causeManager->loadAll(array());
-
- self::out('Vérification des '.count($storyCauses).' causes');
-
-
- //$sentence = $conf->get('last_sentence','var');
- list($i,$h,$d,$m,$y) = explode('-',date('i-H-d-m-Y'));
- $validCauses = array();
-
- if(isset($event['type']))
- self::out('Argument d entrée :'.$event['type']);
-
- //self::out('Dernière phrase énoncée : "'.$sentence.'"');
- self::out('Date actuelle '.$d.'/'.$m.'/'.$y.' '.$h.':'.$i);
-
- foreach($storyCauses as $storyCause){
- self::out("Vérification cause ID : $storyCause->id type : $storyCause->type");
- $values = $storyCause->getValues();
- switch ($storyCause->type){
- case 'listen':
- if(!isset($event['type']) || $event['type'] !='sentence') continue;
- if($values->value == $event['sentence']){
- $validCauses[$storyCause->story][] = $storyCause;
- self::out("Phrase correspondante, ajout $storyCause->id aux causes valides");
- }else{
- self::out("Phrase non correspondante");
- }
- break;
- case 'pin':
- if(!isset($event['type']) || $event['type'] !='gpio') continue;
- if($values->pin == $event['pin'] && $values->value == $event['state']){
- $validCauses[$storyCause->story][] = $storyCause;
- self::out("Pin et etat correspondant, ajout $storyCause->id aux causes valides");
- }else{
- self::out("Pin non correspondant");
- }
- break;
- case 'time':
-
-
- if ($storyCause->value != $i.'-'.$h.'-'.$d.'-'.$m.'-'.$y) $validate = false;
- if ((
- ($i == $values->minut || $values->minut == '*') &&
- ($h == $values->hour || $values->hour == '*') &&
- ($d == $values->day || $values->day == '*') &&
- ($m == $values->month || $values->month == '*') &&
- ($y == $values->year || $values->year == '*')
- )){
- self::out("Date correspondante, ajout $storyCause->id aux causes valides");
- $validCauses[$storyCause->story][] = $storyCause;
- }else{
- self::out("Date non correspondante");
- }
- break;
- case 'readvar':
- self::out($values->var.' ('.self::parse($values->var).') égale à '.self::parse($values->value).' ?');
- if (self::parse($values->var) == self::parse($values->value)) {
- $validCauses[$storyCause->story][] = $storyCause;
- self::out("Variable correspondante, ajout $storyCause->id aux causes valides");
- }else{
- self::out("Variable non correspondante");
- }
- break;
- }
- }
-
- self::out("Vérification de la somme des causes pour chaques scénario (".count($validCauses)." valides)");
-
- foreach($validCauses as $story=>$causes){
- self::out("Scénario ID : $story, ".count($causes)." causes valides.");
- if(count($causes) == $causeManager->rowCount(array('story'=>$story))){
- self::out("Execution des effets du Scénario ID : $story");
- self::execute($story);
- }else{
- self::out("Non execution des effets du Scénario ID : $story, nombre de causes insuffisantes");
- }
- }
- //$conf->put('last_sentence','','var');
- }
-
-
- public static function parse($value){
- global $conf;
-
- $keywords = self::keywords();
- $value = str_replace(array_keys($keywords),array_values($keywords),$value);
-
-
- preg_match_all("/(\{)(.*?)(\})/", $value, $matches, PREG_SET_ORDER);
- foreach($matches as $match){
- $value = str_replace($match[0],$conf->get($match[2],'var'),$value);
- }
-
-
- return $value;
- }
- public static function execute($storyId){
- global $conf;
- $story = new self();
- $story = $story->getById($storyId);
- $log = '====== Execution '.date('d/m/Y H:i').'======'.PHP_EOL;
- try{
-
- $cli = new Client();
- $cli->connect();
-
-
- require_once(dirname(__FILE__).'/Effect.class.php');
- $effectManager = new Effect('r');
-
- $effects = $effectManager->loadAll(array('story'=>$story->id),'sort');
-
- $log .= count($effects).' effets à executer'.PHP_EOL;
- foreach($effects as $effect){
- $data = $effect->getValues();
-
- $log .= '> Execution de l\'effet "'.$effect->type.'"'.PHP_EOL;
- try{
- switch ($effect->type) {
- case 'command':
- if($data->target=='server'){
-
- $log .= "\tcommande server lancée : ".self::parse($data->value).PHP_EOL;
- $return = System::commandSilent(self::parse($data->value));
- $conf->put('cmd_result',$return,'var');
- }else{
- $log .= "\tcommande client lancée : ".self::parse($data->value).PHP_EOL;
-
-
- $cli->execute(self::parse($data->value));
-
- }
- break;
- case 'image':
- $log .= "\tImage affichée : ".self::parse($data->value).PHP_EOL;
-
- $cli->image(self::parse($data->value));
-
- break;
- case 'var':
- $log .= "\tVariable ".$data->var.' définie à : "'.self::parse($data->value).'"'.PHP_EOL;
- $conf->put($data->var,self::parse($data->value),'var');
- break;
- case 'url':
- $log .= "\tExecution url ".$data->var.' définie à : "'.self::parse($data->value).'"'.PHP_EOL;
- $return = @file_get_contents(html_entity_decode(self::parse($data->value)));
- $conf->put('url_result',$return,'var');
- break;
- case 'gpio':
- $log .= "\tChangement GPIO $data->gpio définie à ".self::parse($data->value).PHP_EOL;
- $pins = explode(',',$data->gpio);
- foreach($pins as $pin)
- Gpio::write($pin,self::parse($data->value),true);
-
- break;
- case 'sleep':
- if(!is_numeric($data->value)) throw new Exception('Pause non numerique, pause annulée');
- $log .= "\tPause de ".self::parse($data->value)." secondes".PHP_EOL;
- sleep(self::parse($data->value));
-
-
- break;
- case 'talk':
- $log .= "\tParole : ".self::parse($data->value).PHP_EOL;
-
-
- $cli->talk(self::parse($data->value));
-
- break;
- case 'emotion':
- $log .= "\tEmotion : ".self::parse($data->value).PHP_EOL;
-
- $cli->emotion(self::parse($data->value));
-
- break;
- case 'sound':
- $log .= "\tSon client : ".self::parse($data->value).PHP_EOL;
-
- $cli->sound(self::parse($data->value));
-
- break;
- case 'image':
- $log .= "\tImage client : ".self::parse($data->value).PHP_EOL;
-
- $cli->image(self::parse($data->value));
-
- break;
- case 'story':
- if(!is_numeric($data->value)) throw new Exception('ID scénario non numerique, lancement scénario annulé');
- $log .= 'Execution : '.self::parse($data->value).PHP_EOL;
- self::execute(self::parse($data->value));
- break;
- default:
- $log .= "\tType effet inconnu : ".PHP_EOL;
- break;
- }
- }catch(Exception $e){
- $log .= "\tERREUR : ".$e->getMessage().PHP_EOL;
- }
- }
- $cli->disconnect();
-
- }catch(Exception $e){
- self::out('ERREUR : '.$e->getMessage());
- $log .= 'ERREUR : '.$e->getMessage().PHP_EOL;
- }
- $story->log = $log;
- $story->save();
- }
-
- public static function out($msg){
- global $_;
-
- if(!isset($_['mode']) || $_['mode'] != 'verbose') return;
- Functions::log($msg);
- echo '<pre>'.date('d/m/Y H:i:s').' | '.$msg.PHP_EOL;
- }
-
- }
- ?>
|