DeployerGuide/Others/ObjectsTriggers: MRDDecreeDocumentsObserver.inc

<?php
require_once('./classes/Notifier/observers/AbsNotifierObserver.inc');
require_once('./classes/Log/LogFactory.inc');

/**
 * MRDDecreeDocumentsObserver
 *
 * @uses AbsNotifierObserver
 * @final
 * @author Tomasz Świenty
 * @version 0.1
 * @copyright Copyright (c) BetaSoft
 */
final class MRDDecreeDocumentsObserver extends AbsNotifierObserver {



    private static $log = FALSE;



    public function preapreReceiversList() {

        $this->receivers = array();

    }



    private static function log($message, $priority = Log::EVENT_INFO) {

        if (!self::$log) {
            self::$log = LogFactory::factory('DATA')->unregisterAllWriters()->registerWriter(Log::FILE_LOG_WRITER);
        }

        self::$log->setWriterConfig(Log::FILE_LOG_WRITER, array('fileName' => date('Y-m-d'), 'tranIdx' => SysContext::$usr_info['usr_id'], 'clsnam' => 'UMR_DDO'));
        self::$log->write($message, Log::getDayKey(), array(), NULL, $priority);

    }



    public function update() {

        if (!isset($this->data['target']) OR !$this->data['target']) {
            return FALSE;
        }

        if (isset($this->data['source']) AND ($this->data['source'] == $this->data['target'])) {
            return FALSE;
        }

        require_once(MOD_PATH.'/Employers/OrganizationUnits/OrganizationUnitBean.inc');
        $organizationUnit = new OrganizationUnitBean($this->data['target']);

        // !! Obserwator uruchamia się jeśli dokument jest przekazany na skrzynke innej organizacji !!
        if ($organizationUnit->get('ndetpe') != 'ENTITY') {
            return FALSE;
        }

        if (bs_empty_str($organizationUnit->get('orunsm'))) {
            self::log('Brak symbolu jednostki', Log::EVENT_ERR);
            return FALSE;
        }

        if (!isset($this->data['source']) OR !$this->data['source']) {
            self::log('Brak source', Log::EVENT_ERR);
            return FALSE;
        }

        if ($this->data['source'] <= 0) {
            self::log('Przekazanie ze stanowiska będącego usługą (source < 0)', Log::EVENT_ERR);
            return FALSE;
        }

        if (!isset($this->data['doc_id']) OR empty($this->data['doc_id'])) {
            self::log('Brak doc_id', Log::EVENT_ERR);
            return FALSE;
        }

        $db = PgManager::getInstance();

        require_once(MOD_PATH.'ADocuments/beans/Document.inc');
        $document = Document::getInstance($this->data['doc_id']);

        ErrorHandler::tryBegin();

        self::log(sprintf('Przekazuję dokument doc_id=%s na stanowisko orunid=%s (target z documents)', $this->data['doc_id'], $this->data['target']));
        self::log('Odpalam komendę UCExportDocToMRDCommand');

        try {
            require_once('./commands/UCExportDocToMRDCommand.inc');
            $command = new UCExportDocToMRDCommand();
            $command->execute($document, array('orunsm' => $organizationUnit->get('orunsm')));
        } catch (Exception $e) {
            $db->rollback();

            self::log('Błąd komendy');
            self::log($e->getMessage(), Log::EVENT_ERR);
            throw new CustomErrorException($e->getMessage());
        }

        self::log('Komenda UCExportDocToMRDCommand wykonana');
        ErrorHandler::tryEnd();

        self::log('Koniec obserwatora dekretacji do MRD');

        return TRUE;

    }

}

?>