trunk/obj/task.class.php

<?php
//$Id$
//gen openMairie le 14/04/2020 14:11

require_once "../gen/obj/task.class.php";

class task extends task_gen {

    const STATUS_DRAFT = 'draft';
    const STATUS_NEW = 'new';
    const STATUS_PENDING = 'pending';
    const STATUS_DONE = 'done';
    const STATUS_ERROR = 'error';
    const STATUS_DEBUG = 'debug';
    const STATUS_ARCHIVED = 'archived';
    const STATUS_CANCELED = 'canceled';

    /**
     * Liste des types de tâche concernant les services instructeurs
     */
    const TASK_TYPE_SI = array(
        'creation_DA',
        'creation_DI',
        'depot_DI',
        'modification_DI',
        'qualification_DI',
        'decision_DI',
        'incompletude_DI',
        'completude_DI',
        'ajout_piece',
        'add_piece',
        'creation_consultation',
        'modification_DA',
        'create_DI',
        'envoi_CL',
        'notification_recepisse',
        'notification_instruction',
        'notification_decision',
    );

    /**
     * Liste des types de tâche concernant les services consultés
     */
    const TASK_TYPE_SC = array(
        'create_DI_for_consultation',
        'avis_consultation',
        'pec_metier_consultation',
        'create_message',
        'notification_recepisse',
        'notification_instruction',
        'notification_decision',
        'prescription',
    );

    /**
     * Catégorie de la tâche
     */
    var $category = 'platau';

    /**
     * Définition des actions disponibles sur la classe.
     *
     * @return void
     */
    public function init_class_actions() {
        parent::init_class_actions();
        //
        $this->class_actions[998] = array(
            "identifier" => "json_data",
            "view" => "view_json_data",
            "permission_suffix" => "consulter",
        );
        $this->class_actions[997] = array(
            "identifier" => "json_data",
            "view" => "post_update_task",
            "permission_suffix" => "modifier",
        );
        $this->class_actions[996] = array(
            "identifier" => "json_data",
            "view" => "post_add_task",
            "permission_suffix" => "ajouter",
        );
    }

    public function setvalF($val = array()) {

        // // les guillets doubles sont remplacés automatiquement par des simples
        // // dans core/om_formulaire.clasS.php::recupererPostvar()
        // // voir le ticket https://dev.atreal.fr/projets/openmairie/tracker/209
        // // ceci est un hack sale temporaire en attendant résolution du ticket
        // foreach(array('json_payload', 'timestamp_log') as $key) {
        //     if (isset($val[$key]) && ! empty($val[$key]) &&
        //             isset($_POST[$key]) && ! empty($_POST[$key])) {
        //         $submited_payload = $_POST[$key];
        //         if (! empty($submited_payload)) {
        //             $new_payload = str_replace("'", '"', $val[$key]);
        //             if ($new_payload == $submited_payload ||
        //                     strpos($submited_payload, '"') === false) {
        //                 $val[$key] = $new_payload;
        //             }
        //             else {
        //                 $error_msg = sprintf(
        //                     __("La convertion des guillemets de la payload JSON '%s' ".
        //                         "n'est pas idempotente (courante: %s, postée: %s, convertie: %s)"),
        //                     $key, var_export($val[$key], true), var_export($submited_payload, true),
        //                     var_export($new_payload, true));
        //                 $this->correct = false;
        //                 $this->addToMessage($error_msg);
        //                 $this->addToLog(__METHOD__."() erreur : $error_msg", DEBUG_MODE);
        //                 return false;
        //             }
        //         }
        //     }
        // }

        parent::setvalF($val);

        // XXX Ancien code : permet de ne pas avoir d'erreru lors de la modification d'une task
        if (array_key_exists('timestamp_log', $val) === true) {
            $this->valF['timestamp_log'] = str_replace("'", '"', $val['timestamp_log']);
        }

        // récupération de l'ID de l'objet existant
        $id = property_exists($this, 'id') ? $this->id : null;
        if(isset($val[$this->clePrimaire])) {
            $id = $val[$this->clePrimaire];
        } elseif(isset($this->valF[$this->clePrimaire])) {
            $id = $this->valF[$this->clePrimaire];
        }

        // MODE MODIFIER
        if (! empty($id)) {

            // si aucune payload n'est fourni (devrait toujours être le cas)
            if (! isset($val['json_payload']) || empty($val['json_payload'])) {

                // récupère l'objet existant
                $existing = $this->f->findObjectById('task', $id);
                if (! empty($existing)) {

                    // récupère la payload de l'objet
                    $val['json_payload'] = $existing->getVal('json_payload');
                    $this->valF['json_payload'] = $existing->getVal('json_payload');
                    $this->f->addToLog(__METHOD__."() récupère la payload de la tâche existante ".
                        "'$id': ".$existing->getVal('json_payload'), EXTRA_VERBOSE_MODE);
                }
            }
        }

        if (array_key_exists('category', $val) === false
            || $this->valF['category'] === ''
            || $this->valF['category'] === null) {
            //
            $this->valF['category'] = $this->category;
        }
    }

    /**
     *
     * @return array
     */
    function get_var_sql_forminc__champs() {
        return array(
            "task",
            "type",
            "state",
            "object_id",
            "dossier",
            "stream",
            "json_payload",
            "timestamp_log",
            "category",
        );
    }

    function setType(&$form, $maj) {
        parent::setType($form, $maj);

        // Récupération du mode de l'action
        $crud = $this->get_action_crud($maj);

        // ALL
        $form->setType("category", "hidden");

        // MODE CREER
        if ($maj == 0 || $crud == 'create') {
            $form->setType("state", "select");
            $form->setType("stream", "select");
            $form->setType("json_payload", "textarea");
        }
        // MDOE MODIFIER
        if ($maj == 1 || $crud == 'update') {
            $form->setType("state", "select");
            $form->setType("stream", "select");
            $form->setType("json_payload", "jsonprettyprint");
        }
        // MODE CONSULTER
        if ($maj == 3 || $crud == 'read') {
            $form->setType('dossier', 'link');
            $form->setType('json_payload', 'jsonprettyprint');
        }

    }

    /**
     *
     */
    function setSelect(&$form, $maj, &$dnu1 = null, $dnu2 = null) {
        if($maj < 2) {

            $contenu = array();
            foreach(array('DRAFT', 'NEW', 'PENDING', 'DONE', 'ERROR', 'DEBUG', 'ARCHIVED', 'CANCELED') as $key) {
                $const_name = 'STATUS_'.$key;
                $const_value = constant("self::$const_name");
                $contenu[0][] = $const_value;
                $contenu[1][] = $const_value;
            }

            $form->setSelect("state", $contenu);

            $contenu_stream =array();
            $contenu_stream[0][0]="input";
            $contenu_stream[1][0]=_('input');
            $contenu_stream[0][1]="output";
            $contenu_stream[1][1]=_('output');
            $form->setSelect("stream", $contenu_stream);

        }

        if ($maj == 3) {
            if ($this->getVal('stream') == 'output') {
                $inst_dossier = $this->f->get_inst__om_dbform(array(
                    "obj" => "dossier",
                    "idx" => $form->val['dossier'],
                ));

                if($form->val['type'] == "creation_DA"
                    || $form->val['type'] == "modification_DA"){
                    //
                    $obj_link = 'dossier_autorisation';
                } else {
                    $obj_link = 'dossier_instruction';
                }

                $params = array();
                $params['obj'] = $obj_link;
                $params['libelle'] = $inst_dossier->getVal('dossier');
                $params['title'] = "Consulter le dossier";
                $params['idx'] = $form->val['dossier'];
                $form->setSelect("dossier", $params);
            }
        }
    }

    /**
     * SETTER_FORM - setVal (setVal).
     *
     * @return void
     */
    function setVal(&$form, $maj, $validation, &$dnu1 = null, $dnu2 = null) {
        // parent::setVal($form, $maj, $validation);
        //
        if ($this->getVal('stream') == "output") {
            $form->setVal('json_payload', $this->view_form_json(true));
        } else {
            $form->setVal('json_payload', htmlentities($this->getVal('json_payload')));
        }
    }

    function setLib(&$form, $maj) {
        parent::setLib($form, $maj);

        // Récupération du mode de l'action
        $crud = $this->get_action_crud($maj);

        // MODE different de CREER
        if ($maj != 0 || $crud != 'create') {
            $form->setLib('json_payload', '');
        }
    }

    public function verifier($val = array(), &$dnu1 = null, $dnu2 = null) {
        $ret = parent::verifier($val, $dnu1, $dnu2);

        // une tâche entrante doit avoir un type et une payload non-vide
        if (isset($this->valF['stream']) === false || $this->valF['stream'] == 'input') {
            if (isset($this->valF['type']) === false) {
                $this->correct = false;
                $this->addToMessage(sprintf(
                    __("Le champ %s est obligatoire pour une tâche entrante."),
                    sprintf('<span class="bold">%s</span>', $this->getLibFromField('type'))
                ));
                $this->addToLog(__METHOD__.'(): erreur: '.$this->msg, DEBUG_MODE);
            }
            if (isset($this->valF['json_payload']) === false) {
                $this->correct = false;
                $this->addToMessage(sprintf(
                    __("Le champ %s est obligatoire pour une tâche entrante."),
                    sprintf('<span class="bold">%s</span>', $this->getLibFromField('json_payload'))
                ));
                $this->addToLog(__METHOD__.'(): erreur: '.$this->msg, DEBUG_MODE);
            }
        }

        // les JSONs doivent être décodables
        foreach(array('json_payload', 'timestamp_log') as $key) {
            if (isset($this->valF[$key]) && ! empty($this->valF[$key]) && (
                    is_array(json_decode($this->valF[$key], true)) === false
                    || json_last_error() !== JSON_ERROR_NONE)) {
                $this->correct = false;
                $champ_text = sprintf('<span class="bold">%s</span>', $this->getLibFromField($key));
                $this->addToMessage(sprintf(
                    __("Le champ %s doit être dans un format JSON valide (erreur: %s).".
                    "<p>%s valF:</br><pre>%s</pre></p>".
                    "<p>%s val:</br><pre>%s</pre></p>".
                    "<p>%s POST:</br><pre>%s</pre></p>".
                    "<p>%s submitted POST value:</br><pre>%s</pre></p>"),
                    $champ_text,
                    json_last_error() !== JSON_ERROR_NONE ? json_last_error_msg() : __('invalide'),
                    $champ_text,
                    $this->valF[$key],
                    $champ_text,
                    $val[$key],
                    $champ_text,
                    isset($_POST[$key]) ? $_POST[$key] : '',
                    $champ_text,
                    $this->f->get_submitted_post_value($key)
                ));
                $this->addToLog(__METHOD__.'(): erreur JSON: '.$this->msg, DEBUG_MODE);
            }
        }

        // une tâche entrante doit avoir une payload avec les clés requises
        if ($this->correct && (isset($this->valF['stream']) === false ||
                               $this->valF['stream'] == 'input')) {

            // décode la payload JSON
            $json_payload = json_decode($this->valF['json_payload'], true);

            // défini une liste de chemin de clés requises
            $paths = array();
            if ($this->valF['category'] === 'platau') {
                $paths = array(
                    'external_uids/dossier'
                );
            }

            // tâche de type création de DI/DA
            if (isset($this->valF['type']) !== false && $this->valF['type'] == 'create_DI_for_consultation') {

                $paths = array_merge($paths, array(
                    'dossier/dossier',
                    'dossier/dossier_autorisation_type_detaille_code',
                    'dossier/date_demande',
                    'dossier/depot_electronique',
                ));

                // si l'option commune est activée (mode MC)
                if ($this->f->is_option_dossier_commune_enabled()) {
                    $paths[] = 'dossier/insee';
                }

                // présence d'un moyen d'identifier la collectivité/le service
                if (! isset($json_payload['external_uids']['acteur']) &&
                        ! isset($json_payload['dossier']['om_collectivite'])) {
                    $this->correct = false;
                    $this->addToMessage(sprintf(
                        __("L'une des clés %s ou %s est obligatoire dans le contenu du champ %s pour une tâche entrante."),
                        sprintf('<span class="bold">%s</span>', 'external_uids/acteur'),
                        sprintf('<span class="bold">%s</span>', 'dossier/om_collectivite'),
                        sprintf('<span class="bold">%s</span>', $this->getLibFromField('json_payload'))
                    ));
                    $this->addToLog(__METHOD__.'(): erreur: '.$this->msg, DEBUG_MODE);
                }
            }

            // pas d'erreur déjà trouvée
            if($this->correct) {

                // pour chaque chemin
                foreach($paths as $path) {

                    // décompose le chemin
                    $tokens = explode('/', $path);
                    $cur_depth = $json_payload;

                    // descend au et à mesure dans l'arborescence du chemin
                    foreach($tokens as $token) {

                        // en vérifiant que chaque élément du chemin est défini et non-nul
                        if (isset($cur_depth[$token]) === false) {

                            // sinon on produit une erreur
                            $this->correct = false;
                            $this->addToMessage(sprintf(
                                __("La clé %s est obligatoire dans le contenu du champ %s pour une tâche entrante."),
                                sprintf('<span class="bold">%s</span>', $path),
                                sprintf('<span class="bold">%s</span>', $this->getLibFromField('json_payload'))
                            ));
                            $this->addToLog(__METHOD__.'(): erreur: '.$this->msg, DEBUG_MODE);
                            break 2;
                        }
                        $cur_depth = $cur_depth[$token];
                    }
                }
            }
        }

        return $ret && $this->correct;
    }

    /**
     * [task_exists description]
     * @param  string $type      [description]
     * @param  string $object_id [description]
     * @param  bool   $is_not_done   [description]
     * @return [type]            [description]
     */
    public function task_exists(string $type, string $object_id, string $dossier = null, bool $is_not_done = true) {
        $query = sprintf('
            SELECT task
            FROM %1$stask
            WHERE %2$s
            type = \'%3$s\'
            AND (object_id = \'%4$s\'
            %5$s)
            AND state != \'%6$s\'
            ',
            DB_PREFIXE,
            $is_not_done == true ? 'state != \''.self::STATUS_DONE.'\' AND' : '',
            $type,
            $object_id,
            $dossier !== null ? sprintf('OR dossier = \'%s\'', $dossier) : '',
            self::STATUS_CANCELED
        );
        $res = $this->f->get_one_result_from_db_query($query);
        if ($res['result'] !== null && $res['result'] !== '') {
            return $res['result'];
        }
        return false;
    }

    /**
     * Permet la recherche multi-critères des tasks.
     *
     * @param  array  $search_values Chaque entrée du tableau est une ligne dans le WHERE
     * @return mixed                 Retourne le résultat de la requête ou false
     */
    public function task_exists_multi_search(array $search_values) {
        $query = sprintf('
            SELECT task
            FROM %1$stask
            %2$s
            %3$s
            ',
            DB_PREFIXE,
            empty($search_values) === false ? ' WHERE ' : '',
            implode(' AND ', $search_values)
        );
        $res = $this->f->get_all_results_from_db_query($query);
        if (count($res['result']) > 0) {
            return $res['result'];
        }
        return false;
    }

    /**
     * TRIGGER - triggerajouter.
     *
     * @param string $id
     * @param null &$dnu1 @deprecated  Ne pas utiliser.
     * @param array $val Tableau des valeurs brutes.
     * @param null $dnu2 @deprecated  Ne pas utiliser.
     *
     * @return boolean
     */
    function triggerajouter($id, &$dnu1 = null, $val = array(), $dnu2 = null) {

        // tâche entrante
        if (isset($this->valF['stream']) === false || $this->valF['stream'] == 'input') {

            // décode la paylod JSON pour extraire les données métiers à ajouter
            // en tant que métadonnées de la tâche
            $json_payload = json_decode($this->valF['json_payload'], true);

            // si la tâche possède déjà une clé dossier
            if (isset($json_payload['dossier']['dossier']) &&
                    ! empty($json_payload['dossier']['dossier'])) {
                $this->valF["dossier"] = $json_payload['dossier']['dossier'];
            }
        }

        // gestion d'une tache de type notification et de category mail
        if (isset($val['type'])
            && (//$val['type'] === 'notification_recepisse'
                $val['type'] === 'notification_instruction'
                || $val['type'] === 'notification_decision')
            && isset($val['category'])
            && $val['category'] === 'mail') {
            // Récupère la payload de la tache
            $data = array();
            $data['instruction_notification'] = $this->get_instruction_notification_data(
                $this->valF['category'],
                'with-id',
                array('with-id' => $this->valF['object_id'])
            );
            $data['dossier'] = $this->get_dossier_data($this->valF['dossier']);

            // Récupère l'instance de la notification
            $inst_notif = $this->f->get_inst__om_dbform(array(
                "obj" => "instruction_notification",
                "idx" => $val['object_id'],
            ));
            // Envoi le mail et met à jour le suivi
            $envoiMail = $inst_notif->send_mail_notification_demandeur($data);
            // Passage de la tache à done si elle a réussi et à error
            // si l'envoi a échoué
            $this->valF['state'] = 'done';
            if ($envoiMail === false) {
                $this->valF['state'] = 'error';
            }
        }
    }

    /**
     * TRIGGER - triggermodifierapres.
     *
     * @param string $id
     * @param null &$dnu1 @deprecated  Ne pas utiliser.
     * @param array $val Tableau des valeurs brutes.
     * @param null $dnu2 @deprecated  Ne pas utiliser.
     *
     * @return boolean
     */
    public function triggermodifierapres($id, &$dnu1 = null, $val = array(), $dnu2 = null) {
        parent::triggermodifierapres($id, $dnu1, $val, $dnu2);

        // Suivi des notificiations
        // En cas de changement de l'état de la tâche de notification, alors
        // le suivi des dates de la notification et de l'instruction, est effectué
        if (isset($val['category']) === true
            && $val['category'] === 'portal'
            && isset($val['type']) === true
            && ($val['type'] === 'notification_recepisse'
                || $val['type'] === 'notification_instruction'
                || $val['type'] === 'notification_decision')) {
            //
            if (isset($this->valF['state']) === true
                && $this->valF['state'] !== $this->getVal('state')
                && $this->valF['state'] !== self::STATUS_CANCELED) {
                //
                $inst_in = $this->f->get_inst__om_dbform(array(
                    "obj" => "instruction_notification",
                    "idx" => $val['object_id'],
                ));
                $valF_in = array();
                foreach ($inst_in->champs as $champ) {
                    $valF_in[$champ] = $inst_in->getVal($champ);
                }
                // Par défaut la date d'envoi et la date de premier accès sur
                // la notification ne sont pas renseignées
                $valF_in['date_envoi'] = null;
                $valF_in['date_premier_acces'] = null;
                // Lorsque la tâche est correctement traitée
                if ($this->valF['state'] === self::STATUS_DONE) {
                    //
                    $valF_in['statut'] = __("envoyé");
                    $valF_in['commentaire'] = __("Notification traitée");
                    $valF_in['date_envoi'] = date('d/m/Y H:i:s');
                    // Si l'instruction possède un document lié, alors ses dates
                    // de suivi sont mises à jour
                    $inst_instruction = $this->f->get_inst__om_dbform(array(
                        "obj" => "instruction",
                        "idx" => $inst_in->getVal('instruction'),
                    ));
                    if ($inst_instruction->has_an_edition() === true) {
                        $valF_instruction = array();
                        foreach ($inst_instruction->champs as $champ) {
                            $valF_instruction[$champ] = $inst_instruction->getVal($champ);
                        }
                        $valF_instruction['date_envoi_rar'] = date('d/m/Y');
                        $valF_instruction['date_retour_rar'] = date('d/m/Y', strtotime('now + 1 day'));
                        $inst_instruction->setParameter('maj', 1);
                        $update_instruction = $inst_instruction->modifier($valF_instruction);
                        if ($update_instruction === false) {
                            $this->addToLog(__METHOD__."(): ".$inst_instruction->msg, DEBUG_MODE);
                            return false;
                        }
                    }
                }
                // En cas d'erreur lors du traitement de la task
                if ($this->valF['state'] === self::STATUS_ERROR) {
                    $valF_in['statut'] = __("échec");
                    $valF_in['commentaire'] = __("Le traitement de la notification a échoué");
                }
                // Met à jour la notification
                $inst_in->setParameter('maj', 1);
                $update_in = $inst_in->modifier($valF_in);
                if ($update_in === false) {
                    $this->addToLog(__METHOD__."(): ".$inst_in->msg, DEBUG_MODE);
                    return false;
                }
            }
        }

        // Envoi au contrôle de légalité
        // En cas de changement de l'état de la tâche envoi_CL, alors le suivi
        // des dates de l'instruction est effectué
        if ($val['type'] === 'envoi_CL'
            && isset($this->valF['state']) === true
            && $this->valF['state'] === self::STATUS_DONE) {
            //
            $inst_instruction = $this->f->get_inst__om_dbform(array(
                "obj" => "instruction",
                "idx" => $this->getVal('object_id'),
            ));
            if ($inst_instruction->has_an_edition() === true) {
                $valF_instruction = array();
                foreach ($inst_instruction->champs as $champ) {
                    $valF_instruction[$champ] = $inst_instruction->getVal($champ);
                }
            }
            $valF_instruction['date_envoi_controle_legalite'] = date("Y-m-d");
            $inst_instruction->setParameter('maj', 1);
            $update_instruction = $inst_instruction->modifier($valF_instruction);
            if ($update_instruction === false) {
                $this->addToLog(__METHOD__."(): ".$inst_instruction->msg, DEBUG_MODE);
                return false;
            }
        }

        //
        return true;
    }

    /**
     * TREATMENT - add_task
     * Ajoute un enregistrement.
     *
     * @param  array $params Tableau des paramètres
     * @return boolean
     */
    public function add_task($params = array()) {
        $this->begin_treatment(__METHOD__);

        // Vérifie si la task doit être ajoutée en fonction du mode de l'application,
        // seulement pour les tasks output
        $task_types_si = self::TASK_TYPE_SI;
        $task_types_sc = self::TASK_TYPE_SC;
        $stream = isset($params['val']['stream']) === true ? $params['val']['stream'] : 'output';
        if ($stream === 'output'
            && isset($params['val']['type']) === true
            && $this->f->is_option_mode_service_consulte_enabled() === true
            && in_array($params['val']['type'], $task_types_sc) === false) {
            //
            return $this->end_treatment(__METHOD__, true);
        }
        if ($stream === 'output'
            && isset($params['val']['type']) === true
            && $this->f->is_option_mode_service_consulte_enabled() === false
            && in_array($params['val']['type'], $task_types_si) === false) {
            //
            return $this->end_treatment(__METHOD__, true);
        }

        //
        $timestamp_log = json_encode(array(
            'creation_date' => date('Y-m-d H:i:s'),
        ));

        //
        $category = isset($params['val']['category']) === true ? $params['val']['category'] : $this->category;

        // Si la tâche est de type ajout_piece et de stream input alors on ajoute le fichier
        // et on ajoute l'uid dans le champ json_payload avant l'ajout de la tâche
        if (isset($params['val']['type'])
            && ($params['val']['type'] == "add_piece" || $params['val']['type'] == "avis_consultation")
            && isset($params['val']['stream'])
            && $params['val']['stream'] == "input" ) {
            //
            $json_payload = json_decode($params['val']['json_payload'], true);
            if (json_last_error() !== JSON_ERROR_NONE) {
                $this->addToMessage(__("Le contenu JSON de la tâche n'est pas valide."));
                return $this->end_treatment(__METHOD__, false);
            }
            if (isset($json_payload['document_numerise']) === true
                && empty($json_payload['document_numerise']) === false) {
                //
                $document_numerise = $json_payload['document_numerise'];
                $file_content = base64_decode($document_numerise["file_content"]);
                if ($file_content === false){
                    $this->addToMessage(__("Le contenu du fichier lié à la tâche n'a pas pu etre recupere."));
                    return $this->end_treatment(__METHOD__, false);
                }
                $metadata = array(
                    "filename" => $document_numerise['nom_fichier'],
                    "size" => strlen($file_content),
                    "mimetype" => $document_numerise['file_content_type'],
                    "date_creation" => isset($document_numerise['date_creation']) === true ? $document_numerise['date_creation'] : date("Y-m-d"),
                );
                $uid_fichier = $this->f->storage->create($file_content, $metadata, "from_content", "task.uid_fichier");
                if ($uid_fichier === OP_FAILURE) {
                    $this->addToMessage(__("Erreur lors de la creation du fichier lié à la tâche."));
                    return $this->end_treatment(__METHOD__, false);
                }
                $json_payload["document_numerise"]["uid"] = $uid_fichier;
                // Le fichier a été ajouté nous n'avons plus besoin du champ file_content dans la payload
                unset($json_payload["document_numerise"]["file_content"]);
                $params['val']['json_payload'] = json_encode($json_payload, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
            }
        }

        // Mise à jour du DI
        $valF = array(
            'task' => '',
            'type' => $params['val']['type'],
            'timestamp_log' => $timestamp_log,
            'state' => isset($params['val']['state']) === true ? $params['val']['state'] : self::STATUS_NEW,
            'object_id' => isset($params['val']['object_id']) ? $params['val']['object_id'] : '',
            'dossier' => isset($params['val']['dossier']) ? $params['val']['dossier'] : '',
            'stream' => $stream,
            'json_payload' => isset($params['val']['json_payload']) === true ? $params['val']['json_payload'] : '{}',
            'category' => $category,
        );

        // tâche sortante
        if ($valF["stream"] == "output"
            && $valF['type'] !== 'notification_recepisse'
            && $valF['type'] !== 'notification_instruction'
            && $valF['type'] !== 'notification_decision') {

            // TODO expliquer ce code
            $task_exists = $this->task_exists($valF['type'], $valF['object_id'], $valF['dossier']);
            if ($valF['type'] === 'modification_DI' && $task_exists === false) {
                $task_exists = $this->task_exists('creation_DI', $valF['object_id']);
            }
            if ($valF['type'] === 'modification_DA' && $task_exists === false) {
                $task_exists = $this->task_exists('creation_DA', $valF['object_id']);
            }
            if ($valF['type'] === 'ajout_piece') {
                $task_exists = $this->task_exists('ajout_piece', $valF['object_id']);
            }
            if ($valF['type'] === 'creation_consultation') {
                $task_exists = $this->task_exists('creation_consultation', $valF['object_id']);
            }
            if ($task_exists !== false) {
                $inst_task = $this->f->get_inst__om_dbform(array(
                    "obj" => "task",
                    "idx" => $task_exists,
                ));
                $update_state = $inst_task->getVal('state');
                if (isset($params['update_val']['state']) === true) {
                    $update_state = $params['update_val']['state'];
                }
                $update_params = array(
                    'val' => array(
                        'state' => $update_state,
                    ),
                    'object_id' => $valF['object_id'],
                );
                return $inst_task->update_task($update_params);
            }
        }
        $add = $this->ajouter($valF);
        $this->addToLog(__METHOD__."(): retour de l'ajout de tâche: ".var_export($add, true), VERBOSE_MODE);
        if ($add === false) {
            $this->addToLog(__METHOD__."(): ".$this->msg, DEBUG_MODE);
            return $this->end_treatment(__METHOD__, false);
        }
        return $this->end_treatment(__METHOD__, true);
    }

    /**
     * TREATMENT - update_task
     * Met à jour l'enregistrement instancié.
     *
     * @param  array  $params Tableau des paramètres
     * @return boolean
     */
    public function update_task($params = array()) {
        $this->begin_treatment(__METHOD__);
        $timestamp_log = $this->get_timestamp_log();
        if ($timestamp_log === false) {
            $this->addToLog(__METHOD__."(): erreur timestamp log", DEBUG_MODE);
            return $this->end_treatment(__METHOD__, false);
        }
        // Vérification des object_id précédent en cas de tentative d'appliquer
        // l'état CANCELED sur la tâche
        if (isset($params['val']['state']) === true
            && $params['val']['state'] === self::STATUS_CANCELED) {
            // Récupération du journal d'activité de la tâche sous forme de tableau
            // trié par ordre décroissant
            $log = $timestamp_log;
            unset($log['creation_date']);
            krsort($log);
            // Pour chaque entrée dans le journal d'activité de la tâche :
            // - vérification de la présence de l'object_id précédent
            // - vérification que l'object_id précédent existe toujours dans la base de données
            // - l'object_id est mise à jour avec la valeur de l'object_id précédent
            // - le state n'est pas modifié
            // - sortie du traitement dès que le premier object_id précédent existant est trouvé
            // - si aucun object_id précédent existant n'est trouvé alors ni le state, ni l'object_id n'est modifiés
            foreach ($log as $key => $value) {
                //
                if (isset($value['prev_object_id']) === true
                    && $this->getVal('object_id') !== $value['prev_object_id']) {
                    // Récupère la liste des tables potentielles pour un type de tâche
                    $tables = $this->get_tables_by_task_type($this->getVal('type'), $this->getVal('stream'));
                    foreach ($tables as $table) {
                        // Vérifie s'il y a un ou aucun résultat
                        $query = sprintf('
                            SELECT COUNT(%2$s)
                            FROM %1$s%2$s
                            WHERE %2$s = \'%3$s\'
                            ',
                            DB_PREFIXE,
                            $table,
                            $value['prev_object_id']
                        );
                        $res = $this->f->get_one_result_from_db_query($query, true);
                        if ($res['code'] === 'KO') {
                            return $this->end_treatment(__METHOD__, false);
                        }
                        // Affectation des valeurs et sortie de la boucle
                        if ($res['result'] == '1') {
                            $params['object_id'] = $value['prev_object_id'];
                            $params['val']['state'] = $this->getVal('state');
                            break;
                        }
                    }
                    // Sortie de la boucle si les valeurs sont affectées
                    if (isset($params['object_id']) === true
                        && $params['object_id'] === $value['prev_object_id']) {
                        //
                        break;
                    }
                }
            }
        }
        // Mise à jour du journal d'activité de la tâche
        array_push($timestamp_log, array(
            'modification_date' => date('Y-m-d H:i:s'),
            'state' => $params['val']['state'],
            'prev_state' => $this->getVal('state'),
            'object_id' => isset($params['object_id']) == true ? $params['object_id'] : $this->getVal('object_id'),
            'prev_object_id' => $this->getVal('object_id'),
        ));
        $timestamp_log = json_encode($timestamp_log);
        // Mise à jour de la tâche
        $valF = array(
            'task' => $this->getVal($this->clePrimaire),
            'type' => $this->getVal('type'),
            'timestamp_log' => $timestamp_log,
            'state' => $params['val']['state'],
            'object_id' => isset($params['object_id']) == true ? $params['object_id'] : $this->getVal('object_id'),
            'stream' => $this->getVal('stream'),
            'dossier' => $this->getVal('dossier'),
            'json_payload' => $this->getVal('json_payload'),
            'category' => $this->getVal('category'),
        );
        $update = $this->modifier($valF);
        if ($update === false) {
            $this->addToLog($this->msg, DEBUG_MODE);
            return $this->end_treatment(__METHOD__, false);
        }
        return $this->end_treatment(__METHOD__, true);
    }

    /**
     * Récupère le journal d'horodatage dans le champ timestamp_log de
     * l'enregistrement instancié.
     *
     * @param  array  $params Tableau des paramètres
     * @return array sinon false en cas d'erreur
     */
    protected function get_timestamp_log($params = array()) {
        $val = $this->getVal('timestamp_log');
        if ($val === '') {
            $val = json_encode(array());
        }
        if($this->isJson($val) === false) {
            return false;
        }
        return json_decode($val, true);
    }

    /**
     * VIEW - view_json_data
     * Affiche l'enregistrement dans le format JSON.
     *
     * @return void
     */
    public function view_json_data() {
        $this->checkAccessibility();
        $this->f->disableLog();
        if ($this->getParameter('idx') !== ']'
            && $this->getParameter('idx') !== '0') {
            //
            $this->view_form_json();
        }
        else {
            $this->view_tab_json();
        }
    }

    protected function view_tab_json() {
        $where = '';
        if ($this->f->get_submitted_get_value('state') !== null
            && $this->f->get_submitted_get_value('state') !== '') {
            //
            $where_or_and = 'WHERE';
            if ($where !== '') {
                $where_or_and = 'AND';
            }
            $where .= sprintf(' %s state = \'%s\' ', $where_or_and, $this->f->get_submitted_get_value('state'));
        }
        if ($this->f->get_submitted_get_value('category') !== null
            && $this->f->get_submitted_get_value('category') !== '') {
            //
            $where_or_and = 'WHERE';
            if ($where !== '') {
                $where_or_and = 'AND';
            }
            $where .= sprintf(' %s category = \'%s\' ', $where_or_and, $this->f->get_submitted_get_value('category'));
        }
        $query = sprintf('
            SELECT
                *
            FROM %1$stask
            %2$s
            ORDER BY task ASC
            ',
            DB_PREFIXE,
            $where
        );
        $res = $this->f->get_all_results_from_db_query($query, true);
        if ($res['code'] === 'KO') {
            return false;
        }
        $list_tasks = array();
        foreach ($res['result'] as $task) {
            $task['timestamp_log'] = json_decode($task['timestamp_log'], true);
            $task['dossier'] = $task['dossier'];
            if ($task['type'] === 'ajout_piece') {
                $val_dn = $this->get_document_numerise_data($task['object_id']);
            }
            if ($task['stream'] === 'output') {
                $task['external_uids'] = $this->get_all_external_uids($task['dossier']);
            }
            $list_tasks[$task['task']] = $task;
        }
        printf(json_encode($list_tasks));
    }

    protected function get_dossier_data(string $dossier) {
        $val_di = array();
        $inst_di = $this->f->get_inst__om_dbform(array(
            "obj" => "dossier",
            "idx" => $dossier,
        ));
        if (empty($inst_di->val) === true) {
            return $val_di;
        }
        $val_di = $inst_di->get_json_data();
        if ($val_di['dossier_instruction_type_code'] === 'T') {
            $val_di['date_decision_transfert'] = $val_di['date_decision'];
        }
        unset($val_di['initial_dt']);
        unset($val_di['log_instructions']);
        return $val_di;
    }

    protected function get_dossier_autorisation_data(string $da) {
        $val_da = array();
        $inst_da = $this->f->get_inst__om_dbform(array(
            "obj" => "dossier_autorisation",
            "idx" => $da,
        ));
        $val_da = $inst_da->get_json_data();
        return $val_da;
    }

    protected function get_donnees_techniques_data(string $fk_idx, string $fk_field) {
        $val_dt = array();
        $inst_dt = $this->f->get_inst__by_other_idx(array(
            "obj" => "donnees_techniques",
            "fk_field" => $fk_field,
            "fk_idx" => $fk_idx,
        ));
        $val_dt = array(
            'donnees_techniques' => $inst_dt->getVal($inst_dt->clePrimaire),
            'cerfa' => $inst_dt->getVal('cerfa'),
        );
        $val_dt = array_merge($val_dt, $inst_dt->get_donnees_techniques_applicables());
        if (isset($val_dt['am_exist_date']) === true) {
            $val_dt['am_exist_date_num'] = '';
            if (is_numeric($val_dt['am_exist_date']) === true) {
                $val_dt['am_exist_date_num'] = $val_dt['am_exist_date'];
            }
        }
        // Correspond à la nomenclature de Plat'AU STATUT_INFO
        $val_dt['tax_statut_info'] = 'Déclaré';
        //
        if ($inst_dt->is_tab_surf_ssdest_enabled() === true) {
            $fields_tab_surf_dest = $inst_dt->get_fields_tab_surf_dest();
            foreach ($fields_tab_surf_dest as $field) {
                if (isset($val_dt[$field]) === true) {
                    unset($val_dt[$field]);
                }
            }
        } else {
            $fields_tab_surf_ssdest = $inst_dt->get_fields_tab_surf_ssdest();
            foreach ($fields_tab_surf_ssdest as $field) {
                if (isset($val_dt[$field]) === true) {
                    unset($val_dt[$field]);
                }
            }
        }
        // Correspond à la nouvelle ligne CERFA v7 dans le DENSI imposition 1.2.3
        if (isset($val_dt['tax_su_non_habit_surf2']) === true
            && isset($val_dt['tax_su_non_habit_surf3']) === true
            && (($val_dt['tax_su_non_habit_surf2'] !== null
                    && $val_dt['tax_su_non_habit_surf2'] !== '')
                || ($val_dt['tax_su_non_habit_surf3'] !== null
                    && $val_dt['tax_su_non_habit_surf3'] !== ''))) {
            //
            $val_dt['tax_su_non_habit_surf8'] = intval($val_dt['tax_su_non_habit_surf2']) + intval($val_dt['tax_su_non_habit_surf3']);
        }
        if (isset($val_dt['tax_su_non_habit_surf_stat2']) === true
            && isset($val_dt['tax_su_non_habit_surf_stat3']) === true
            && (($val_dt['tax_su_non_habit_surf_stat2'] !== null
                    && $val_dt['tax_su_non_habit_surf_stat2'] !== '')
                || ($val_dt['tax_su_non_habit_surf_stat3'] !== null
                    && $val_dt['tax_su_non_habit_surf_stat3'] !== ''))) {
            //
            $val_dt['tax_su_non_habit_surf_stat8'] = intval($val_dt['tax_su_non_habit_surf_stat2']) + intval($val_dt['tax_su_non_habit_surf_stat3']);
        }
        // Cas particulier d'un projet réduit à l'extension d'une habitation existante
        $particular_case = false;
        $fields_tab_crea_loc_hab = $inst_dt->get_fields_tab_crea_loc_hab();
        foreach ($fields_tab_crea_loc_hab as $field) {
            if (isset($val_dt[$field]) === false
                || (isset($val_dt[$field]) === true
                    && ($val_dt[$field] === null
                        || $val_dt[$field] === ''))) {
                //
                $particular_case = true;
            }
        }
        if ($particular_case === true) {
            if (isset($val_dt['tax_ext_pret']) === true
                && $val_dt['tax_ext_pret'] === 'f') {
                //
                $val_dt['tax_su_princ_surf1'] = $val_dt['tax_surf_tot_cstr'];
                $val_dt['tax_su_princ_surf_stat1'] = $val_dt['tax_surf_loc_stat'];
            }
            if (isset($val_dt['tax_ext_pret']) === true
                && $val_dt['tax_ext_pret'] === 't') {
                //
                if (isset($val_dt['tax_ext_desc']) === true) {
                    if (preg_match('/[pP].*[lL].*[aA].*[iI]/', $val_dt['tax_ext_desc']) === 1
                        || preg_match('/[lL].*[lL].*[tT].*[sS]/', $val_dt['tax_ext_desc']) === 1) {
                        //
                        $val_dt['tax_su_princ_surf2'] = $val_dt['tax_surf_tot_cstr'];
                        $val_dt['tax_su_princ_surf_stat2'] = $val_dt['tax_surf_loc_stat'];
                    }
                    // if (preg_match('/[pP].*[tT].*[zZ]/', $val_dt['tax_ext_desc']) === 1) {
                    //     $val_dt['tax_su_princ_surf4'] = $val_dt['tax_surf_tot_cstr'];
                    //     $val_dt['tax_su_princ_surf_stat4'] = $val_dt['tax_surf_loc_stat'];
                    // }
                    // if (preg_match('/[pP].*[lL].*[uU].*[sS]/', $val_dt['tax_ext_desc']) === 1
                    //     || preg_match('/[lL].*[eE].*[sS]/', $val_dt['tax_ext_desc']) === 1
                    //     || preg_match('/[pP].*[sS].*[lL].*[aA]/', $val_dt['tax_ext_desc']) === 1
                    //     || preg_match('/[pP].*[lL].*[sS]/', $val_dt['tax_ext_desc']) === 1
                    //     || preg_match('/[lL].*[lL].*[sS]/', $val_dt['tax_ext_desc']) === 1) {
                    //     //
                    //     $val_dt['tax_su_princ_surf3'] = $val_dt['tax_surf_tot_cstr'];
                    //     $val_dt['tax_su_princ_surf_stat3'] = $val_dt['tax_surf_loc_stat'];
                    // }
                }
            }
        }
        // Cas particulier de la surface taxable démolie
        if (isset($val_dt['tax_surf_tot_demo']) === true
            && isset($val_dt['tax_surf_tax_demo']) === true
            && ($val_dt['tax_surf_tot_demo'] === null
                || $val_dt['tax_surf_tot_demo'] === '')) {
            //
            $val_dt['tax_surf_tot_demo'] = $val_dt['tax_surf_tax_demo'];
        }
        return $val_dt;
    }

    /**
     * Récupère la liste des objets distincts existants dans la table des liens
     * entre identifiants internes et identifiants externes.
     *
     * @return array
     */
    protected function get_list_distinct_objects_external_link() {
        $query = sprintf('
            SELECT
                DISTINCT(object)
            FROM %1$slien_id_interne_uid_externe
            ORDER BY object ASC
            ',
            DB_PREFIXE
        );
        $res = $this->f->get_all_results_from_db_query($query, true);
        if ($res['code'] === 'KO') {
            return array();
        }
        $result = array();
        foreach ($res['result'] as $object) {
            $result[] = $object['object'];
        }
        return $result;
    }

    protected function get_external_uid($fk_idx, string $fk_idx_2) {
        $inst_external_uid = $this->f->get_inst__by_other_idx(array(
            "obj" => "lien_id_interne_uid_externe",
            "fk_field" => 'object_id',
            "fk_idx" => $fk_idx,
            "fk_field_2" => 'object',
            "fk_idx_2" => $fk_idx_2,
        ));
        return $inst_external_uid->getVal('external_uid');
    }

    protected function get_all_external_uids($fk_idx, $link_objects = array()) {
        if (count($link_objects) == 0) {
            $link_objects = $this->get_list_distinct_objects_external_link();
        }
        $val_external_uid = array();
        foreach ($link_objects as $link_object) {
            $external_uid = $this->get_external_uid($fk_idx, $link_object);
            if ($external_uid !== '' && $external_uid !== null) {
                $val_external_uid[$link_object] = $external_uid;
            }
        }
        return $val_external_uid;
    }

    protected function get_demandeurs_data($dossier) {
        $val_demandeur = array();
        if ($dossier === null) {
            return $val_demandeur;
        }
        $inst_di = $this->f->get_inst__om_dbform(array(
            "obj" => "dossier",
            "idx" => $dossier,
        ));
        $list_demandeurs = $inst_di->get_demandeurs();
        foreach ($list_demandeurs as $demandeur) {
            $inst_demandeur = $this->f->get_inst__om_dbform(array(
                "obj" => "demandeur",
                "idx" => $demandeur['demandeur'],
            ));
            $val_demandeur[$demandeur['demandeur']] = $inst_demandeur->get_json_data();
            $val_demandeur[$demandeur['demandeur']]['petitionnaire_principal'] = $demandeur['petitionnaire_principal'];
        }
        return $val_demandeur;
    }

    protected function get_architecte_data($architecte = null) {
        $val_architecte = null;
        if ($architecte !== null
            && $architecte !== '') {
            //
            $inst_architecte = $this->f->get_inst__om_dbform(array(
                "obj" => "architecte",
                "idx" => $architecte,
            ));
            $val_architecte = $inst_architecte->get_json_data();
        }
        return $val_architecte;
    }

    protected function get_instruction_data($dossier, $type = 'decision', $extra_params = array()) {
        $val_instruction = null;
        if ($dossier === null) {
            return $val_instruction;
        }
        $instruction_with_doc = null;
        $inst_di = $this->f->get_inst__om_dbform(array(
            "obj" => "dossier",
            "idx" => $dossier,
        ));
        $idx = null;
        if ($type === 'decision') {
            $idx = $inst_di->get_last_instruction_decision();
        }
        if ($type === 'incompletude') {
            $idx = $inst_di->get_last_instruction_incompletude();
        }
        // XXX Permet de récupérer l'instruction par son identifiant
        if ($type === 'with-id') {
            $idx = $extra_params['with-id'];
        }
        $inst_instruction = $this->f->get_inst__om_dbform(array(
            "obj" => "instruction",
            "idx" => $idx,
        ));
        if (count($inst_instruction->val) > 0) {
            $val_instruction = array();
            $instruction_data = $inst_instruction->get_json_data();
            $val_instruction = $this->sort_instruction_data($instruction_data, $val_instruction);
            if ($instruction_data['om_fichier_instruction'] !== null
                && $instruction_data['om_fichier_instruction'] !== '') {
                //
                $instruction_with_doc = $inst_instruction->getVal($inst_instruction->clePrimaire);
            }
            $inst_ev = $this->f->get_inst__om_dbform(array(
                "obj" => "evenement",
                "idx" => $inst_instruction->getVal('evenement'),
            ));
            if ($inst_ev->getVal('retour') === 't') {
                $instructions_related = $inst_instruction->get_related_instructions();
                foreach ($instructions_related as $instruction) {
                    if ($instruction !== null && $instruction !== '') {
                        $inst_related_instruction = $this->f->get_inst__om_dbform(array(
                            "obj" => "instruction",
                            "idx" => $instruction,
                        ));
                        $instruction_data = $inst_related_instruction->get_json_data();
                        $val_instruction = $this->sort_instruction_data($instruction_data, $val_instruction);
                        if ($instruction_data['om_fichier_instruction'] !== null
                            && $instruction_data['om_fichier_instruction'] !== '') {
                            //
                            $instruction_with_doc = $inst_related_instruction->getVal($inst_related_instruction->clePrimaire);
                        }
                    }
                }
            }
            if ($instruction_with_doc !== null) {
                //
                $val_instruction['path'] = sprintf('%s&snippet=%s&obj=%s&champ=%s&id=%s', 'app/index.php?module=form', 'file', 'instruction', 'om_fichier_instruction', $instruction_with_doc);
            }
        }
        return $val_instruction;
    }

    /**
     * Récupère les informations 
    */
    protected function get_instruction_notification_data($category, $type = '', $extra_params = array()) {
        $val_in = null;

        $idx = null;
        if ($type === 'with-id') {
            $idx = $extra_params['with-id'];
        }

        // récupére les données à intégrer à la payload
        $inst_in = $this->f->get_inst__om_dbform(array(
            "obj" => "instruction_notification",
            "idx" => $idx,
        ));
        if (count($inst_in->val) > 0) {
            $val_in = $inst_in->get_json_data();

            $val_in['parametre_courriel_type_titre'] = '';
            $val_in['parametre_courriel_type_message'] = '';
            // Récupération du message et du titre
            if ($category === 'mail') {
                $inst_instruction = $this->f->get_inst__om_dbform(array(
                    "obj" => "instruction",
                    "idx" => $inst_in->getVal('instruction'),
                ));
                $collectivite_id = $inst_instruction->get_dossier_instruction_om_collectivite($inst_instruction->getVal('dossier'));
                $phrase_type_notification = array();
                $phrase_type_notification = $this->f->get_notification_parametre_courriel_type($collectivite_id);
                $val_in['parametre_courriel_type_titre'] = $phrase_type_notification['parametre_courriel_type_titre'];
                $val_in['parametre_courriel_type_message'] = $phrase_type_notification['parametre_courriel_type_message'];
            }

            // Récupération des liens vers les documents et de l'id de l'instruction
            // de l'annexe
            $infoDocNotif = $inst_in->getInfosDocumentsNotif($inst_in->getVal($inst_in->clePrimaire));
            $val_in['lien_telechargement_document'] = $infoDocNotif['document']['lien'];
            $val_in['lien_telechargement_annexe'] = $infoDocNotif['annexe']['lien'];
            $val_in['instruction_annexe'] = $infoDocNotif['annexe']['id_instruction'];
        }

        return $val_in;
    }

    protected function sort_instruction_data(array $values, array $res) {
        $fields = array(
            "date_evenement",
            "date_envoi_signature",
            "date_retour_signature",
            "date_envoi_rar",
            "date_retour_rar",
            "date_envoi_controle_legalite",
            "date_retour_controle_legalite",
            "signataire_arrete",
            "om_fichier_instruction",
            "tacite",
            "lettretype",
            "commentaire",
            "complement_om_html",
        );
        foreach ($values as $key => $value) {
            if (in_array($key, $fields) === true) {
                if (array_key_exists($key, $res) === false
                    && $value !== null
                    && $value !== '') {
                    //
                    $res[$key] = $value;
                } elseif ($key === 'tacite'
                    && $value === 't') {
                    //
                    $res[$key] = $value;
                }
            }
        }
        return $res;
    }

    /**
     * Permet de définir si l'instruction passée en paramètre est une instruction
     * récépissé d'une demande et si la demande en question a générée un dossier d'instruction.
     *
     * @param  integer  $instruction Identifiant de l'instruction
     * @return boolean
     */
    protected function is_demande_instruction_recepisse_without_dossier($instruction) {
        if ($instruction === null) {
            return false;
        }
        $query = sprintf('
            SELECT demande_type.dossier_instruction_type
            FROM %1$sdemande
                INNER JOIN %1$sdemande_type ON demande.demande_type = demande_type.demande_type
            WHERE demande.instruction_recepisse = %2$s
            ',
            DB_PREFIXE,
            $instruction
        );
        $res = $this->f->get_one_result_from_db_query(
            $query,
            true
        );
        if ($res['code'] === 'KO') {
            return null;
        }
        if ($res['result'] === '') {
            return true;
        }
        return false;
    }

    protected function get_document_numerise_data(string $dn) {
        $val_dn = array();
        $inst_dn = $this->f->get_inst__om_dbform(array(
            "obj" => "document_numerise",
            "idx" => $dn,
        ));
        $val_dn = $inst_dn->get_json_data();
        $val_dn['path'] = sprintf('%s&snippet=%s&obj=%s&champ=%s&id=%s', 'app/index.php?module=form', 'file', 'document_numerise', 'uid', $this->getVal('object_id'));
        // Correspond à la nomenclature Plat'AU NATURE_PIECE
        $val_dn['nature'] = $val_dn['document_numerise_nature_libelle'];
        return $val_dn;
    }

    protected function get_parcelles_data(string $object, string $idx) {
        $val_dp = array();
        $inst_di = $this->f->get_inst__om_dbform(array(
            "obj" => $object,
            "idx" => $idx,
        ));
        $list_parcelles = $inst_di->get_parcelles();
        $no_ordre = 1;
        foreach ($list_parcelles as $parcelle) {
            $val_dp[$parcelle[$object.'_parcelle']] = array(
                $object.'_parcelle' => $parcelle[$object.'_parcelle'],
                'libelle' => $parcelle['libelle'],
                'no_ordre' => $no_ordre,
            );
            $no_ordre++;
        }
        return $val_dp;
    }

    protected function get_avis_decision_data(string $dossier) {
        $inst_di = $this->f->get_inst__om_dbform(array(
            "obj" => "dossier",
            "idx" => $dossier,
        ));
        $ad = $inst_di->getVal('avis_decision');
        $val_ad = array();
        if ($ad !== null) {
            $inst_ad = $this->f->get_inst__om_dbform(array(
                "obj" => "avis_decision",
                "idx" => $ad,
            ));
            $val_ad = $inst_ad->get_json_data();
            $val_ad['txAvis'] = "Voir document joint";
            if (isset($val_ad['tacite']) ===  true
                && $val_ad['tacite'] === 't') {
                //
                $val_ad['txAvis'] = "Sans objet";
            }
        }
        return $val_ad;
    }

    protected function get_signataire_arrete_data(string $sa) {
        $inst_sa = $this->f->get_inst__om_dbform(array(
            "obj" => "signataire_arrete",
            "idx" => $sa,
        ));
        $val_sa = array_combine($inst_sa->champs, $inst_sa->val);
        foreach ($val_sa as $key => $value) {
            $val_sa[$key] = strip_tags($value);
        }
        return $val_sa;
    }

    // XXX WIP
    protected function get_consultation_data(string $consultation) {
        $val_consultation = array();
        $inst_consultation = $this->f->get_inst__om_dbform(array(
            "obj" => "consultation",
            "idx" => $consultation,
        ));
        $val_consultation = $inst_consultation->get_json_data();
        if (isset($val_consultation['fichier']) === true
            && $val_consultation['fichier'] !== '') {
            //
            $val_consultation['path_fichier'] = sprintf('%s&snippet=%s&obj=%s&champ=%s&id=%s', 'app/index.php?module=form', 'file', 'consultation', 'fichier', $this->getVal('object_id'));
        }
        if (isset($val_consultation['om_fichier_consultation']) === true
            && $val_consultation['om_fichier_consultation'] !== '') {
            //
            $val_consultation['path_om_fichier_consultation'] = sprintf('%s&snippet=%s&obj=%s&champ=%s&id=%s', 'app/index.php?module=form', 'file', 'consultation', 'om_fichier_consultation', $this->getVal('object_id'));
        }
        return $val_consultation;
    }

    // XXX WIP
    protected function get_service_data(string $service) {
        $val_service = array();
        $inst_service = $this->f->get_inst__om_dbform(array(
            "obj" => "service",
            "idx" => $service,
        ));
        $val_service = $inst_service->get_json_data();
        return $val_service;
    }

    protected function view_form_json($in_field = false) {
        //
        if ($this->f->get_submitted_post_value('valid') === null
            && $this->getVal('state') !== self::STATUS_CANCELED) {
            // Liste des valeurs à afficher
            $val = array();
            //
            $val_task = array_combine($this->champs, $this->val);
            foreach ($val_task as $key => $value) {
                $val_task[$key] = strip_tags($value);
            }
            $val_task['timestamp_log'] = json_decode($val_task['timestamp_log'], true);
            $val['task'] = $val_task;
            //
            if ($this->getVal('type') === 'creation_DA'
                || $this->getVal('type') === 'modification_DA') {
                //
                $val['dossier_autorisation'] = $this->get_dossier_autorisation_data($this->getVal('object_id'));
                $val['donnees_techniques'] = $this->get_donnees_techniques_data($this->getVal('object_id'), 'dossier_autorisation');
                $val['dossier_autorisation_parcelle'] = $this->get_parcelles_data('dossier_autorisation', $val['dossier_autorisation']['dossier_autorisation']);
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier_autorisation']['dossier_autorisation'], 'dossier_autorisation');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'creation_DI'
                || $this->getVal('type') === 'modification_DI'
                || $this->getVal('type') === 'depot_DI') {
                //
                $val['dossier'] = $this->get_dossier_data($this->getVal('object_id'));
                $val['donnees_techniques'] = $this->get_donnees_techniques_data($this->getVal('object_id'), 'dossier_instruction');
                $val['demandeur'] = $this->get_demandeurs_data($val['dossier']['dossier']);
                $architecte = isset($val['donnees_techniques']['architecte']) === true ? $val['donnees_techniques']['architecte'] : null;
                $val['architecte'] = $this->get_architecte_data($architecte);
                $val['dossier_parcelle'] = $this->get_parcelles_data('dossier', $val['dossier']['dossier']);
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'qualification_DI') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'ajout_piece') {
                $val['document_numerise'] = $this->get_document_numerise_data($this->getVal('object_id'));
                $val['dossier'] = $this->get_dossier_data($val['document_numerise']['dossier']);
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val_external_uid['document_numerise'] = $this->get_external_uid($val['document_numerise']['document_numerise'], 'document_numerise');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'decision_DI') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($val['dossier']['dossier'], 'with-id', array('with-id' => $this->getVal('object_id')));
                $val['instruction']['final'] = 't';
                if (isset($val['instruction']['signataire_arrete']) === true) {
                    $val['signataire_arrete'] = $this->get_signataire_arrete_data($val['instruction']['signataire_arrete']);
                }
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'incompletude_DI') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($val['dossier']['dossier'], 'with-id', array('with-id' => $this->getVal('object_id')));
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'completude_DI') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($val['dossier']['dossier'], 'with-id', array('with-id' => $this->getVal('object_id')));
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'pec_metier_consultation') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($this->getVal('dossier'), 'with-id', array('with-id' => $this->getVal('object_id')));
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val_external_uid['dossier_consultation'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier_consultation');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'avis_consultation') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($this->getVal('dossier'), 'with-id', array('with-id' => $this->getVal('object_id')));
                $val['avis_decision'] = $this->get_avis_decision_data($this->getVal('dossier'));
                if (isset($val['instruction']['signataire_arrete']) === true) {
                    $val['signataire_arrete'] = $this->get_signataire_arrete_data($val['instruction']['signataire_arrete']);
                }
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val_external_uid['dossier_consultation'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier_consultation');
                $val['external_uids'] = $val_external_uid;
            }
            // XXX WIP
            if ($this->getVal('type') === 'creation_consultation') {
                //
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['consultation'] = $this->get_consultation_data($this->getVal('object_id'));
                $val['service'] = $this->get_service_data($val['consultation']['service']);
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'envoi_CL') {
                //
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($this->getVal('dossier'), 'with-id', array('with-id' => $this->getVal('object_id')));
                $val['dossier_autorisation'] = $this->get_dossier_autorisation_data($val['dossier']['dossier_autorisation']);
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($this->getVal('dossier'), 'dossier');
                $val_external_uid['decision'] = $this->get_external_uid($this->getVal('object_id'), 'instruction');
                if ($val_external_uid['decision'] === null) {
                    $inst_instruction = $this->f->get_inst__om_dbform(array(
                        "obj" => "instruction",
                        "idx" => $this->getVal('object_id'),
                    ));
                    $val_external_uid['decision'] = $this->get_external_uid($inst_instruction->get_related_instructions_next('retour_signature'), 'instruction');
                }
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'notification_instruction'
                || $this->getVal('type') === 'notification_recepisse'
                || $this->getVal('type') === 'notification_decision') {
                //
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $dossier_id = isset($val['dossier']['dossier']) === true ? $val['dossier']['dossier'] : null;
                $val['demandeur'] = $this->get_demandeurs_data($dossier_id);
                $val['instruction_notification'] = $this->get_instruction_notification_data($this->getVal('category'), 'with-id', array('with-id' => $this->getVal('object_id')));
                $instruction_id = isset($val['instruction_notification']['instruction']) === true ? $val['instruction_notification']['instruction'] : null;
                $instruction_annexe = isset($val['instruction_notification']['instruction_annexe']) === true ? $val['instruction_notification']['instruction_annexe'] : null;
                $val['instruction'] = $this->get_instruction_data($dossier_id, 'with-id', array('with-id' => $instruction_id));
                // Précise qu'il s'agit d'une instruction final si l'instruction est liée à une
                // demande dont le type ne génère pas de dossier
                if ($this->is_demande_instruction_recepisse_without_dossier($instruction_id) === true) {
                    $val['instruction']['final'] = 't';
                }
                //
                if ($instruction_annexe != '') {
                    $val['instruction_annexe'] = $this->get_instruction_data($dossier_id, 'with-id', array('with-id' => $instruction_annexe));
                }
                $val_external_uid = array();
                // Affiche l'identifiant externe lié à l'instruction si cette combinaison existe, sinon celui lié au dossier
                $val_external_uid['demande'] = $this->get_external_uid($instruction_id, 'demande') !== '' ? $this->get_external_uid($instruction_id, 'demande') : $this->get_external_uid($dossier_id, 'demande');
                $val['external_uids'] = $val_external_uid;
            }
            //
            if ($this->getVal('type') === 'prescription') {
                $val['dossier'] = $this->get_dossier_data($this->getVal('dossier'));
                $val['instruction'] = $this->get_instruction_data($this->getVal('dossier'), 'with-id', array('with-id' => $this->getVal('object_id')));
                $val['avis_decision'] = $this->get_avis_decision_data($this->getVal('dossier'));
                if (isset($val['instruction']['signataire_arrete']) === true) {
                    $val['signataire_arrete'] = $this->get_signataire_arrete_data($val['instruction']['signataire_arrete']);
                }
                $val_external_uid = array();
                $val_external_uid['dossier_autorisation'] = $this->get_external_uid($val['dossier']['dossier_autorisation'], 'dossier_autorisation');
                $val_external_uid['dossier'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier');
                $val_external_uid['dossier_consultation'] = $this->get_external_uid($val['dossier']['dossier'], 'dossier_consultation');
                $val['external_uids'] = $val_external_uid;
            }

            if ($in_field === true) {
                return json_encode($val, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
            } else {
                // Liste des valeurs affichée en JSON
                echo(json_encode($val, JSON_UNESCAPED_SLASHES));
            }
        }
    }

    function post_update_task() {
        // Mise à jour des valeurs

        // Modification de l'état de la tâche
        if ($this->f->get_submitted_post_value('state') !== null) {
            $params = array(
                'val' => array(
                    'state' => $this->f->get_submitted_post_value('state')
                ),
            );
            $update = $this->update_task($params);
            $message_class = "valid";
            $message = $this->msg;
            if ($update === false) {
                $this->addToLog($this->msg, DEBUG_MODE);
                $message_class = "error";
                $message = sprintf(
                    '%s %s',
                    __('Impossible de mettre à jour la tâche.'),
                    __('Veuillez contacter votre administrateur.')
                );
            }
            $this->f->displayMessage($message_class, $message);
        }

        // Sauvegarde de l'uid externe retourné
        if ($this->f->get_submitted_post_value('external_uid') !== null) {
            //
            $objects = $this->get_objects_by_task_type($this->getVal('type'), $this->getVal('stream'));
            foreach ($objects as $object) {
                $inst_lien = $this->f->get_inst__om_dbform(array(
                    "obj" => "lien_id_interne_uid_externe",
                    "idx" => ']',
                ));
                $object_id = $this->getVal('object_id');
                // Dans le cas spécifique de la mise à jour d'une notification
                // et de la création d'une liaison d'identifiant pour l'objet demande,
                // l'identifiant de l'objet n'est plus celui de la notification
                // d'instruction mais celui du dossier d'instruction
                if ($object === 'demande'
                    && ($this->getVal('type') === 'notification_recepisse'
                        || $this->getVal('type') === 'notification_instruction'
                        || $this->getVal('type') === 'notification_decision')) {
                    //
                    $object_id = $this->getVal('dossier');
                }
                if ($inst_lien->is_exists($object, $object_id, $this->f->get_submitted_post_value('external_uid'), $this->getVal('dossier')) === false) {
                    $valF = array(
                        'lien_id_interne_uid_externe' => '',
                        'object' => $object,
                        'object_id' => $object_id,
                        'external_uid' => $this->f->get_submitted_post_value('external_uid'),
                        'dossier' => $this->getVal('dossier'),
                        'category' => $this->getVal('category'),
                    );
                    $add = $inst_lien->ajouter($valF);
                    $message_class = "valid";
                    $message = $inst_lien->msg;
                    if ($add === false) {
                        $this->addToLog($inst_lien->msg, DEBUG_MODE);
                        $message_class = "error";
                        $message = sprintf(
                            '%s %s',
                            __("Impossible de mettre à jour le lien entre l'identifiant interne et l'identifiant de l'application externe."),
                            __('Veuillez contacter votre administrateur.')
                        );
                    }
                    $this->f->displayMessage($message_class, $message);
                }
            }
        }
    }

    function post_add_task() {
        // TODO Tester de remplacer la ligne de json_payload par un $_POST
        $result = $this->add_task(array(
            'val' => array(
                'stream' => 'input',
                'json_payload' => html_entity_decode($this->f->get_submitted_post_value('json_payload')),
                'type' => $this->f->get_submitted_post_value('type'),
                'category' => $this->f->get_submitted_post_value('category'),
            )
        ));
        $message = sprintf(
            __("Tâche %s ajoutée avec succès"),
            $this->getVal($this->clePrimaire)).
            '<br/><br/>'.
            $this->msg;
        $message_class = "valid";
        if ($result === false){
            $this->addToLog($this->msg, DEBUG_MODE);
            $message_class = "error";
            $message = sprintf(
                '%s %s',
                __('Impossible d\'ajouter la tâche.'),
                __('Veuillez contacter votre administrateur.')
            );
        }
        $this->f->displayMessage($message_class, $message);
    }

    function setLayout(&$form, $maj) {

        // Récupération du mode de l'action
        $crud = $this->get_action_crud($maj);

        // MODE different de CREER
        if ($maj != 0 || $crud != 'create') {
            $form->setBloc('json_payload', 'D', '', 'col_6');
                $form->setFieldset('json_payload', 'DF', __("json_payload"), "collapsible, startClosed");
            $form->setBloc('json_payload', 'F');
        }
        $form->setBloc('timestamp_log', 'DF', '', 'col_9');
    }

    /**
     * [get_objects_by_task_type description]
     * @param  [type] $type [description]
     * @return [type]       [description]
     */
    function get_objects_by_task_type($type, $stream = 'all') {
        $objects = array();
        if (in_array($type, array('creation_DA', 'modification_DA', )) === true) {
            $objects = array('dossier_autorisation', );
        }
        if (in_array($type, array('creation_DI', 'depot_DI', 'notification_DI', 'qualification_DI', )) === true) {
            $objects = array('dossier', );
        }
        if (in_array($type, array('create_DI_for_consultation', )) === true) {
            $objects = array('dossier', 'dossier_consultation', );
        }
        if (in_array($type, array('create_DI', )) === true
            && $stream === 'input') {
            $objects = array('dossier', 'dossier_autorisation', 'demande', );
        }
        if (in_array($type, array('decision_DI', 'incompletude_DI', 'completude_DI', 'envoi_CL', )) === true) {
            $objects = array('instruction', );
        }
        if (in_array($type, array('pec_metier_consultation', )) === true
            && $stream === 'output') {
            $objects = array('pec_dossier_consultation', );
        }
        if (in_array($type, array('avis_consultation', )) === true
            && $stream === 'output') {
            $objects = array('avis_dossier_consultation', );
        }
        if (in_array($type, array('prescription', )) === true
            && $stream === 'output') {
            $objects = array('prescription', );
        }
        if (in_array($type, array('ajout_piece', 'add_piece', )) === true) {
            $objects = array('piece', );
        }
        if (in_array($type, array('creation_consultation', )) === true) {
            $objects = array('consultation', );
        }
        if (in_array($type, array('pec_metier_consultation', )) === true
            && $stream === 'input') {
            $objects = array('pec_metier_consultation', );
        }
        if (in_array($type, array('avis_consultation', )) === true
            && $stream === 'input') {
            $objects = array('avis_consultation', );
        }
        if (in_array($type, array('create_message', )) === true
            && $stream === 'input') {
            $objects = array('dossier_message', );
        }
        if (in_array($type, array('notification_recepisse', 'notification_instruction', 'notification_decision' )) === true) {
            $objects = array('instruction_notification', 'demande', );
        }
        return $objects;
    }

    /**
     * Récupère les tables auxquelles pourrait être rattaché l'objet lié à la tâche,
     * par rapport à son type.
     *
     * @param  string $type   Type de la tâche
     * @param  string $stream input ou output
     * @return array
     */
    function get_tables_by_task_type($type, $stream = 'all') {
        $tables = array();
        if (in_array($type, array('creation_DA', 'modification_DA', )) === true) {
            $tables = array('dossier_autorisation', );
        }
        if (in_array($type, array('creation_DI', 'depot_DI', )) === true) {
            $tables = array('dossier', );
        }
        if (in_array($type, array('qualification_DI', )) === true) {
            $tables = array('instruction', );
        }
        if (in_array($type, array('create_DI_for_consultation', )) === true) {
            $tables = array('dossier', );
        }
        if (in_array($type, array('create_DI', )) === true
            && $stream === 'input') {
            $tables = array('dossier', 'dossier_autorisation', 'demande', );
        }
        if (in_array($type, array('decision_DI', 'incompletude_DI', 'completude_DI', )) === true) {
            $tables = array('instruction', );
        }
        if (in_array($type, array('pec_metier_consultation', )) === true
            && $stream === 'output') {
            $tables = array('instruction', );
        }
        if (in_array($type, array('avis_consultation', )) === true
            && $stream === 'output') {
            $tables = array('instruction', );
        }
        if (in_array($type, array('prescription', )) === true
            && $stream === 'output') {
            $tables = array('instruction', );
        }
        if (in_array($type, array('ajout_piece', 'add_piece', )) === true) {
            $tables = array('document_numerise', );
        }
        if (in_array($type, array('creation_consultation', )) === true) {
            $tables = array('consultation', );
        }
        if (in_array($type, array('pec_metier_consultation', )) === true
            && $stream === 'input') {
            $tables = array('consultation', );
        }
        if (in_array($type, array('avis_consultation', )) === true
            && $stream === 'input') {
            $tables = array('consultation', );
        }
        if (in_array($type, array('create_message', )) === true
            && $stream === 'input') {
            $tables = array('dossier_message', );
        }
        if (in_array($type, array('notification_recepisse', 'notification_instruction', 'notification_decision' )) === true) {
            $tables = array('instruction_notification', );
        }
        return $tables;
    }

}