<?php

/* This file is part of Jeedom.
*
* Jeedom 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 3 of the License, or
* (at your option) any later version.
*
* Jeedom 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 Jeedom. If not, see <http://www.gnu.org/licenses/>.
*/
require_once dirname(__FILE__) . '/../../../../core/php/core.inc.php';

class dsc extends eqLogic {
  public static function deamon_start($_debug = false) {
    self::deamon_stop();
    $deamon_info = self::deamon_info();
    if ($deamon_info['launchable'] != 'ok') {
      throw new Exception(__('Veuillez vérifier la configuration', __FILE__));
    }
    log::add('dsc', 'info', 'Lancement du démon dsc');

    $password = config::byKey('password', 'dsc');
    $addr = config::byKey('addr', 'dsc');
    $port = config::byKey('port', 'dsc');
    $zone = config::byKey('zone', 'dsc');
    $partition = config::byKey('partition', 'dsc');
    log::add('dsc','debug','Récupération de la configuration : Host ' . $addr . ' Port ' . $port . ' Zones ' . $zone . ' Partitions ' . $partition);

    $url = network::getNetworkAccess('internal') . '/plugins/dsc/core/api/dsc.php?apikey=' . jeedom::getApiKey('dsc');

    $sensor_path = realpath(dirname(__FILE__) . '/../../resources');
    $cmd = 'nice -n 19 nodejs ' . $sensor_path . '/jeedomdsc.js ' . $url . ' ' . $password . ' ' . $addr . ' ' . $port . ' ' . $zone . ' ' . $partition;

    //log::add('dsc', 'debug', 'Lancement démon dsc : ' . $cmd);
    $result = exec('nohup ' . $cmd . ' >> ' . log::getPathToLog('dsc_node') . ' 2>&1 &');
    if (strpos(strtolower($result), 'error') !== false || strpos(strtolower($result), 'traceback') !== false) {
      log::add('dsc', 'error', $result);
      return false;
    }
    $i = 0;
    while ($i < 30) {
      $deamon_info = self::deamon_info();
      if ($deamon_info['state'] == 'ok') {
        break;
      }
      sleep(1);
      $i++;
    }
    if ($i >= 30) {
      log::add('dsc', 'error', 'Impossible de lancer un démon dsc, vérifiez le port', 'unableStartDeamon');
      return false;
    }
    message::removeAll('dsc', 'unableStartDeamon');
    log::add('dsc', 'info', 'Démons dsc lancé');
    return true;
  }

  public static function deamon_info() {
    $return = array();
    $return['log'] = 'dsc_node';
    $return['launchable'] = 'ok';
    $pid = trim( shell_exec ('ps ax | grep "dsc/resources/jeedomdsc.js" | grep -v "grep" | wc -l') );
    if ($pid != '' && $pid != '0') {
      $return['state'] = 'ok';
    } else {
      $return['state'] = 'nok';
    }
    if (config::byKey('password', 'dsc') == '' || config::byKey('addr', 'dsc') == '' || config::byKey('port', 'dsc') == '' || config::byKey('zone', 'dsc') == '' || config::byKey('zone', 'dsc') == '') {
      $return['launchable'] = 'nok';
    }
    return $return;
  }

public static function deamon_stop() {
   $pid_file = jeedom::getTmpFolder(__CLASS__) . '/deamon.pid'; //seulement si le démon a bien écrit son PID dans ce fichier au démarrage (ce qui est une convention)
   if (file_exists($pid_file)) {
      $pid = intval(trim(file_get_contents($pid_file)));
      system::kill($pid); // car du coup ca permet de kill le bon process directement
   }
   system::kill('jeedomdsc.js'); //sinon c'est cette ligne qui fera la magie
   system::fuserk(config::byKey('socketport', __CLASS__)); // en dernier recours un kill via le port du socket ouvert mais de nouveau ceci est à adapter en fonction de ce que ce plugin fait (sauve-t-il le port du socket dans une config ou pas?)
}

  public static function populate() {
    $zone = config::byKey('zone', 'dsc');
    $partition = config::byKey('partition', 'dsc');
    if ($zone != '' || $partition != '') {
      $izone = 1;
      $ipart = 1;
      while ($izone <= $zone) {
        $logical = 'zone' . $izone;
        $dsc = self::byLogicalId($logical, 'dsc');
        if (!is_object($dsc)) {
          log::add('dsc', 'info', 'Equipement n existe pas, création ' . $logical);
          $dsc = new dsc();
          $dsc->setEqType_name('dsc');
          $dsc->setLogicalId($logical);
          $dsc->setName('Zone ' . $izone);
          $dsc->setIsEnable(true);
          $dsc->save();
        }
        $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'alarm');
        if (!is_object($dscCmd)) {
          $dscCmd = new dscCmd();
          $dscCmd->setEqLogic_id($dsc->getId());
          $dscCmd->setEqType('dsc');
          $dscCmd->setIsHistorized(0);
          $dscCmd->setName( 'Alarme' );
          $dscCmd->setType('info');
          $dscCmd->setLogicalId('alarm');
          $dscCmd->setSubType('binary');
          $dscCmd->setIsVisible(0);
          $dscCmd->setConfiguration('value', '0' );
          $dscCmd->setTemplate("dashboard",'alert' );
          $dscCmd->setTemplate("mobile",'alert' );
          $dscCmd->setDisplay('generic_type','SABOTAGE');
          $dscCmd->save();
        }

        $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'tamper');
        if (!is_object($dscCmd)) {
          $dscCmd = new dscCmd();
          $dscCmd->setEqLogic_id($dsc->getId());
          $dscCmd->setEqType('dsc');
          $dscCmd->setIsHistorized(0);
          $dscCmd->setName( 'Sabotage' );
          $dscCmd->setIsVisible(0);
          $dscCmd->setSubType('binary');
          $dscCmd->setLogicalId('tamper');
          $dscCmd->setType('info');
          $dscCmd->setConfiguration('value', '0' );
          $dscCmd->setTemplate("dashboard",'lock' );
          $dscCmd->setTemplate("mobile",'lock' );
          $dscCmd->setDisplay('generic_type','LOCK_STATE');
          $dscCmd->save();
        }

        $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'fault');
        if (!is_object($dscCmd)) {
          $dscCmd = new dscCmd();
          $dscCmd->setEqLogic_id($dsc->getId());
          $dscCmd->setEqType('dsc');
          $dscCmd->setIsHistorized(0);
          $dscCmd->setName( 'Erreur' );
          $dscCmd->setIsVisible(0);
          $dscCmd->setSubType('binary');
          $dscCmd->setLogicalId('fault');
          $dscCmd->setType('info');
          $dscCmd->setConfiguration('value', '0' );
          $dscCmd->setTemplate("dashboard",'bell' );
          $dscCmd->setTemplate("mobile",'bell' );
          $dscCmd->setDisplay('generic_type','SABOTAGE');
          $dscCmd->save();
        }

        $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'activity');
        if (!is_object($dscCmd)) {
          $dscCmd = new dscCmd();
          $dscCmd->setEqLogic_id($dsc->getId());
          $dscCmd->setEqType('dsc');
          $dscCmd->setName( 'Activité' );
          $dscCmd->setIsHistorized(0);
          $dscCmd->setIsVisible(1);
          $dscCmd->setSubType('binary');
          $dscCmd->setLogicalId('activity');
          $dscCmd->setType('info');
          $dscCmd->setConfiguration('value', '0' );
          $dscCmd->setTemplate("dashboard",'bell' );
          $dscCmd->setTemplate("mobile",'bell' );
          $dscCmd->setDisplay('generic_type','OPENING');
          $dscCmd->save();
        }

        //incrémentation
        $izone++;
      }
      while ($ipart <= $partition) {
        $logical = 'partition' . $ipart;
        $dsc = self::byLogicalId($logical, 'dsc');
        if (!is_object($dsc)) {
          log::add('dsc', 'info', 'Equipement n existe pas, création ' . $logical);
          $dsc = new dsc();
          $dsc->setEqType_name('dsc');
          $dsc->setLogicalId($logical);
          $dsc->setName('Partition ' . $ipart);
          $dsc->setIsEnable(true);
          $dsc->save();
        }
        $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'status');
        if (!is_object($dscCmd)) {
          $dscCmd = new dscCmd();
          $dscCmd->setEqLogic_id($dsc->getId());
          $dscCmd->setEqType('dsc');
          $dscCmd->setName( 'Statut Alarme' );
          $dscCmd->setIsVisible(0);
          $dscCmd->setIsHistorized(0);
          $dscCmd->setSubType('numeric');
          $dscCmd->setLogicalId('status');
          $dscCmd->setType('info');
          $dscCmd->save();
        }

        /*$dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'state');
        if (!is_object($dscCmd)) {
        $dscCmd = new dscCmd();
        $dscCmd->setEqLogic_id($dsc->getId());
        $dscCmd->setEqType('dsc');
        $dscCmd->setName( 'Etat Activation' );
        $dscCmd->setIsVisible(1);
        $dscCmd->setIsHistorized(0);
        $dscCmd->setSubType('numeric');
        $dscCmd->setLogicalId('state');
        $dscCmd->setType('info');
        $dscCmd->save();
      }*/

      $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'alarmoff');
      if (!is_object($dscCmd)) {
        $dscCmd = new dscCmd();
        $dscCmd->setEqLogic_id($dsc->getId());
        $dscCmd->setEqType('dsc');
        $dscCmd->setLogicalId('alarmoff');
        $dscCmd->setName( 'Désactivation Alarme' );
        $dscCmd->setConfiguration('request', '040'.$ipart);
        $dscCmd->setType('action');
        $dscCmd->setSubType('other');
        $dscCmd->save();
      }

      $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'alarmon');
      if (is_object($dscCmd)) {
        $dscCmd->remove();
      }

      $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'alarmstay');
      if (!is_object($dscCmd)) {
        $dscCmd = new dscCmd();
        $dscCmd->setEqLogic_id($dsc->getId());
        $dscCmd->setEqType('dsc');
        $dscCmd->setLogicalId('alarmstay');
        $dscCmd->setName( 'Activation Stay' );
        $dscCmd->setConfiguration('request', '031'.$ipart);
        $dscCmd->setType('action');
        $dscCmd->setSubType('other');
        $dscCmd->save();
      }

      $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'alarmzero');
      if (!is_object($dscCmd)) {
        $dscCmd = new dscCmd();
        $dscCmd->setEqLogic_id($dsc->getId());
        $dscCmd->setEqType('dsc');
        $dscCmd->setLogicalId('alarmzero');
        $dscCmd->setName( 'Activation Zero Entry' );
        $dscCmd->setConfiguration('request', '032'.$ipart);
        $dscCmd->setType('action');
        $dscCmd->setSubType('other');
        $dscCmd->save();
      }

      //incrémentation
      $ipart++;
    }

  }
  return true;
}

public static function eventZone($id,$value) {
  $logical = 'zone' . $id;
  switch ($value) {
    case '601':
    $cmd='alarm';
    $code='1';
    break;

    case '602':
    $cmd='alarm';
    $code='0';
    break;

    case '603':
    $cmd='tamper';
    $code='1';
    break;

    case '604':
    $cmd='tamper';
    $code='0';
    break;

    case '605':
    $cmd='fault';
    $code='1';
    break;

    case '606':
    $cmd='fault';
    $code='0';
    break;

    case '609':
    $cmd='activity';
    $code='1';
    break;

    case '610':
    $cmd='activity';
    $code='0';
    break;

  }
  log::add('dsc', 'info', 'Evènement sur zone : ' . $logical . ' commande : ' . $cmd . ' code : ' . $code . ' (' . $value . ')');
  dsc::switchStatus($logical,$cmd,$code);
}

public static function eventPartition($id,$value) {
  $logical = 'partition' . $id;
  log::add('dsc', 'info', 'Evènement sur partition ' . $logical . ' de type ' . $value);
  dsc::switchStatus($logical,'status',$value);
  /*switch ($value) {
  case '650':
  $state='prête';
  break;
}
$dsc = self::byLogicalId($logical, 'dsc');
$dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),'state');
$dscCmd->setConfiguration('value', $state );
$dscCmd->save();
$dscCmd->event($state);*/
}

public static function switchStatus($id,$cmd,$value) {
  $dsc = self::byLogicalId($id, 'dsc');
  $dscCmd = dscCmd::byEqLogicIdAndLogicalId($dsc->getId(),$cmd);
  $dscCmd->setConfiguration('value', $value );
  $dscCmd->save();
  $dscCmd->event($value);
  log::add('dsc', 'info', 'Changement de valeur de  ' . $id . ' pour ' . $value);
}

public static function sendCommand($id,$value) {

  log::add('dsc', 'info', 'Envoi commande ' . $value . ' pour ' . $id);

  $password = config::byKey('password', 'dsc');
  $port = config::byKey('port', 'dsc');
  $zone = config::byKey('zone', 'dsc');
  $partition = config::byKey('partition', 'dsc');
  log::add('dsc','debug','Récupération de la configuration : Host ' . $addr . ' Port ' . $port . ' Zones ' . $zone . ' Partitions ' . $partition);

  $sensor_path = realpath(dirname(__FILE__) . '/../../resources');
  $cmd = 'nice -n 19 nodejs ' . $sensor_path . '/jeedomcmd.js ' . $password . ' ' . $port . ' ' . $zone . ' ' . $partition . ' ' . $value;

  log::add('dsc', 'debug', 'Lancement commande : ' . $cmd);

  $result = exec($cmd . ' >> ' . log::getPathToLog('dsc_command') . ' 2>&1 &');

}

}

class dscCmd extends cmd {
  public function execute($_options = null) {
    switch ($this->getType()) {
      case 'info' :
      return $this->getConfiguration('value');
      break;

      case 'action' :
      $eqLogic = $this->getEqLogic();
      dsc::sendCommand($eqLogic->getLogicalId(),$this->getConfiguration('request'));
      return true;
    }

  }

}

?>