se/SE/se-lib/Schema/DefaultDb/zaliczka/ZaliczkaStorageAcl.php

<?php

Lib::loadClass('Core_AclSimpleSchemaBase');// extends Core_AclBase
Lib::loadClass('Core_AclHelper');
Lib::loadClass('DBG');

class Schema_DefaultDb_zaliczka_ZaliczkaStorageAcl extends Core_AclSimpleSchemaBase {

  public $_simpleSchema = [
    'root' => [
      '@namespace' => 'default_db/ZALICZKA/Zaliczka',// Api_WfsNs::getBaseWfsUri() . '/default_db/Zaliczka'
      '@primaryKey' => 'id',
      'id' => [ '@type' => 'xsd:integer', '@alias' => 'ID' ],
      'created' => [ '@type' => 'xsd:date', '@alias' => 'A_RECORD_CREATE_DATE' ],
      'worker' => [ '@ref' => 'default_objects/AccessOwner' ],// 'alias_ref:default_objects:AccessOwner'
      'kwota' => [ '@type' => 'xsd:decimal', '@totalDigits' => 16, '@fractionDigits' => 2, '@alias' => 'KWOTA' ],
      'nierozliczona_kwota' => [ '@type' => 'xsd:decimal', '@totalDigits' => 16, '@fractionDigits' => 2, '@alias' => 'NIEROZLICZONA_KWOTA' ],
      'korespondencja' => [ '@ref' => 'default_db/IN7_DZIENNIK_KORESP/ZaliczkaKoresp' ],
      'pozycja' => [ '@ref' => 'default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja', '@maxOccurs' => 'unbounded' ],
      'A_STATUS' => [ '@type' => 'xsd:string' ],
      'L_APPOITMENT_USER' => [ '@type' => 'xsd:string' ],
    ],
  ];

  public function getTotal($params = array()) {
    if (!isset($params['#refFrom'])) {
      throw new Exception("Missing param #refFrom/primaryKey (id user)");
    }
    $idUser = V::get('primaryKey', 0, $params['#refFrom'], 'int');
    return DB::getPDO()->fetchValue("
      select count(*) as cnt
      from ZALICZKA z
        join ADMIN_USERS u on(z.L_APPOITMENT_USER = u.ADM_ACCOUNT and u.ID = {$idUser})
    ");
  }

  public function getItems($params = array()) {
    // '#refFrom' => [
    //   'namespace' => 'default_db__x3A__ADMIN_USERS/Worker',
    //   'primaryKey' => $idUser
    // ]
    if (!isset($params['#refFrom'])) {
      throw new Exception("Missing param #refFrom/primaryKey (id user)");
    }
    $idUser = V::get('primaryKey', 0, $params['#refFrom'], 'int');

    return array_map(
      function ($row) use ($params) {
        return $this->buildFromSqlRow($row, $params);
      },
      DB::getPDO()->fetchAll("
        select z.*
        from ZALICZKA z
          join ADMIN_USERS u on(z.L_APPOITMENT_USER = u.ADM_ACCOUNT and u.ID = {$idUser})
        order by z.ID DESC
      ")
    );
  }

  public function addItem($itemTodo) {
    DBG::log(['msg' => '$itemTodo', 'log' => $itemTodo]);

    if (!is_array($itemTodo) || empty($itemTodo['worker'])) throw new Exception("Missing worker");
    if (empty($itemTodo['worker']['id'])) throw new Exception("Missing worker id");
    if (empty($itemTodo['kwota'])) throw new Exception("Nie podano kwoty");
    $itemTodo['kwota'] = floatval($itemTodo['kwota']);
    if ($itemTodo['kwota'] <= 0) throw new Exception("Podano błędną kwotę");

    $idUser = intval($itemTodo['worker']['id']);
    if ($idUser <= 0) throw new Exception("Wrong worker id");

    // TODO: use default_objects/AccessOwner -> getItem($idUser)
    $userLogin = DB::getPDO()->fetchValue("
      select u.ADM_ACCOUNT
      from `ADMIN_USERS` u
      where u.ID = {$idUser}
    ");
    if (empty($userLogin)) throw new Exception("User not exists ID={$idUser}");
    DBG::log(['msg' => '$userLogin', 'log' => $userLogin]);

    $idTransaction = Core_AclHelper::startTransaction('ZALICZKA', $idUser, $userLogin);

    $zaliczkaRefWorker = ACL::getRefTable('default_db/ZALICZKA/Zaliczka', 'worker');
    $idActiveZaliczka = DB::getPDO()->fetchValue("
      select MAX(t.ID)
      from `ZALICZKA` t
        -- join `ADMIN_USERS` u on(t.L_APPOITMENT_USER = u.ADM_ACCOUNT)
        left join `{$zaliczkaRefWorker}` ref on(ref.PRIMARY_KEY = t.ID and ref.A_STATUS != 'DELETED')
        left join `ADMIN_USERS` r on(r.ID = ref.REMOTE_PRIMARY_KEY)
      where r.ID = {$idUser}
        and t.A_STATUS in('WAITING', 'NORMAL') -- TODO cache use #INSTANCE table
    ");
    DBG::log(['msg' => '$idActiveZaliczka', 'log' => $idActiveZaliczka]);

    $userSaldo = 0;
    if ($idActiveZaliczka > 0) {
      $zaliczkaRefPozycja = ACL::getRefTable('default_db/ZALICZKA/Zaliczka', 'pozycja');
      $userSaldo = DB::getPDO()->fetchValue("
    		select t.KWOTA + t.NIEROZLICZONA_KWOTA - sum(COALESCE(r.KWOTA, 0))
    		from `ZALICZKA` t
    			left join `{$zaliczkaRefPozycja}` ref on(ref.PRIMARY_KEY = t.ID and ref.A_STATUS != 'DELETED')
    			left join `ZALICZKA_POZYCJA` r on(r.ID = ref.REMOTE_PRIMARY_KEY)
        where t.ID = {$idActiveZaliczka}
    	");
    }
    DBG::log(['msg' => '$userSaldo', 'log' => $userSaldo]);

    $usrLogin = User::getLogin();
    $execRet = DB::getPDO()->execSql("
      insert into `ZALICZKA` (A_RECORD_CREATE_AUTHOR, A_RECORD_CREATE_DATE
          , L_APPOITMENT_USER, NIEROZLICZONA_KWOTA, KWOTA)
        select '{$usrLogin}' as A_RECORD_CREATE_AUTHOR, NOW() as A_RECORD_CREATE_DATE
          , u.ADM_ACCOUNT, '{$userSaldo}', '{$itemTodo['kwota']}'
        from ADMIN_USERS u
        where u.ID = {$idUser}
    ");
    DBG::log(['msg' => '$execRet', 'log' => $execRet]);
    $id = DB::getPDO()->lastInsertId();
    DBG::log(['msg' => '$id', 'log' => $id]);
    if (!$id) throw new Exception("Wystąpiły błędy podczas dodawania Zaliczki do bazy danych");

    DB::getPDO()->execSql("
      insert into `ZALICZKA__#INSTANCE` (PRIMARY_KEY, INSTANCE_NAME)
        values({$id}, 'ZaliczkaAktywna')
      ON DUPLICATE KEY UPDATE INSTANCE_NAME = 'ZaliczkaAktywna'
    ");
    foreach (DB::getPDO()->fetchAll("
      select z.ID as ID_ZALICZKA, i.*
      from `ZALICZKA` z
        left join `ZALICZKA__#INSTANCE` i on(i.PRIMARY_KEY = z.ID)
      where z.ID != {$id}
        and z.L_APPOITMENT_USER = '{$userLogin}'
    ") as $instance) {
      DBG::log(['msg' => 'old $instance', 'log' => $instance]);

      // FIX Instance name
      foreach (DB::getPDO()->fetchAll("
        select z.ID as ID_ZALICZKA
  				, IF(i.PRIMARY_KEY IS NOT NULL, 1, 0) as has_instance
  				, i.*
        from `ZALICZKA` z
          left join `ZALICZKA__#INSTANCE` i on(i.PRIMARY_KEY = z.ID)
        where z.ID != {$id}
          and z.L_APPOITMENT_USER = '{$userLogin}'
      ") as $instance) {
        DBG::log(['msg' => 'fix instance name $instance', 'log' => $instance]);
  			if (!$instance['has_instance']) {
          DB::getPDO()->insert('ZALICZKA__#INSTANCE_HIST', [
            'PRIMARY_KEY' => $instance['ID_ZALICZKA'],
            'INSTANCE_NAME' => 'ZaliczkaArchiwalna'
    			]);
  				DB::getPDO()->insert('ZALICZKA__#INSTANCE', [
            'PRIMARY_KEY' => $instance['ID_ZALICZKA'],
            'INSTANCE_NAME' => 'ZaliczkaArchiwalna'
  				]);
  			} else if ('ZaliczkaAktywna' == $instance['INSTANCE_NAME']) {
          DB::getPDO()->insert('ZALICZKA__#INSTANCE_HIST', [
            'PRIMARY_KEY' => $instance['ID_ZALICZKA'],
            'INSTANCE_NAME' => 'ZaliczkaArchiwalna'
    			]);
  				DB::getPDO()->execSql("
  					update `ZALICZKA__#INSTANCE`
  					set INSTANCE_NAME = 'ZaliczkaArchiwalna'
  						, A_RECORD_UPDATE_DATE = NOW()
  					where PRIMARY_KEY = {$instance['ID_ZALICZKA']}
  				");
  			}
      }
    }

    $this->insertRef('worker', $id, $idUser);// TODO: add to hist table

    $childTableKwota = $this->getChildHistTable('kwota');
    DB::getPDO()->insert($childTableKwota, [
      'VALUE' => $itemTodo['kwota'],
      'A_TRANSACTION_ID' => $idTransaction
    ]);

    DB::getPDO()->execSql("
      update ZALICZKA
      set A_STATUS = 'OFF_HARD'
      where L_APPOITMENT_USER = '{$userLogin}'
        and ID < {$id}
    ");

    // TODO: legacy fill table ZALICZKA_HIST
    DB::getPDO()->execSql("
      insert into `ZALICZKA_HIST` (ID_USERS2, L_APPOITMENT_USER, NIEROZLICZONA_KWOTA, KWOTA)
        select z.ID as ID_USERS2, z.L_APPOITMENT_USER, z.NIEROZLICZONA_KWOTA, z.KWOTA
        from ZALICZKA z
        where z.ID = {$id}
    ");
    return $id;
  }

  public function updateItem($itemPatch) {
    DBG::log(['msg' => '$itemPatch', $itemPatch]);
    $pkField = $this->getPrimaryKeyField();
    if (!array_key_exists($pkField, $itemPatch)) throw new Exception("Missing primary key");
    $pk = (int)$itemPatch[$pkField];
    if ($pk <= 0) throw new Exception("Wrong primary key format");
    $oldItem = $this->getItem($pk, [
			'cols' => [
				'id',
				'kwota',
				// 'nierozliczona_kwota',
				'korespondencja',
				'pozycja',
				// 'worker',
			]
		]);
    DBG::log(['msg' => '$oldItem', $oldItem]);

    // pozycja
    $pozAcl = ACL::getAclByNamespace('default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja');
    $pozPkField = $pozAcl->getPrimaryKeyField();
    if (empty($oldItem['pozycja'])) {
      DBG::log("empty \$oldItem['pozycja']");
      if (!empty($itemPatch['pozycja'])) {
        foreach ($itemPatch['pozycja'] as $pozTodo) {
          if ($pozTodo[ $pozPkField ] !== -1) throw new Exception("BUG ZaliczkaPozycja id not equal -1");
          unset($pozTodo[ $pozPkField ]);
          $pkPoz = $pozAcl->addItem($pozTodo);
          DBG::log(['msg'=> '$pkPoz', $pkPoz]);
          $this->insertRef('pozycja', $pk, $pkPoz);
        }
      }
    } else {
      DBG::log("not empty \$oldItem['pozycja'] " . ((!empty($itemPatch['pozycja'])) ? "not empty" : "empty") . " patch pozycja");
      $pozToAdd = array();
      $pozToUpdate = array();
      $pozToRemove = array();
      if (!empty($itemPatch['pozycja'])) {
        foreach ($itemPatch['pozycja'] as $pozTodo) {
          if ($pozTodo[ $pozPkField ] == -1) {
            unset($pozTodo[ $pozPkField ]);
            $pozToAdd[] = $pozTodo;
          } else {
            $pozToUpdate[ $pozTodo[ $pozPkField ] ] = $pozTodo;
          }
        }
      }
      foreach ($oldItem['pozycja'] as $pozOld) {
        if ($pozOld[ $pozPkField ] > 0 && !array_key_exists($pozOld[ $pozPkField ], $pozToUpdate)) {
          $pozToRemove[] = $pozOld[ $pozPkField ];
        }
      }

      DBG::log(['msg'=> '$pozToAdd', $pozToAdd]);
      DBG::log(['msg'=> '$pozToUpdate', $pozToUpdate]);
      DBG::log(['msg'=> '$pozToRemove', $pozToRemove]);

      foreach ($pozToAdd as $pozTodo) {
        $pkPoz = $pozAcl->addItem($pozTodo);
        DBG::log(['msg'=> '$pkPoz', $pkPoz]);
        $this->insertRef('pozycja', $pk, $pkPoz);
      }
      foreach ($pozToRemove as $idPoz) {
        // $rmPozItem = [];
        // $rmPozItem[$pozPkField] = $idPoz;
        // $rmPozItem['A_STATUS'] = 'DELETED';
        // $pozAcl->updateItem($rmPozItem);// TODO: update instance and A_STATUS (cache)
        $this->removeRef('pozycja', $pk, $idPoz);
      }
      foreach ($pozToUpdate as $pozTodo) {
        $pozAcl->updateItem($pozTodo);
      }
    }

    // korespondencja
    if (empty($oldItem['korespondencja'])) {
      DBG::log("empty \$oldItem['korespondencja']");
      if (!empty($itemPatch['korespondencja'])) {
        if (empty($itemPatch['korespondencja'][0]['id'])) throw new Exception("BUG: Missing Koresp id");
        $pkKoresp = $itemPatch['korespondencja'][0]['id'];
        $this->insertRef('korespondencja', $pk, $pkKoresp);
      }
    } else {
      DBG::log("not empty \$oldItem['korespondencja'] " . ((!empty($itemPatch['korespondencja'])) ? "not empty" : "empty") . " patch koresp");
      // if (id != id) => update : clearRefs, insertRef
      if (empty($oldItem['korespondencja'][0]['id'])) throw new Exception("BUG: Missing Koresp id in current object");

      if (!empty($itemPatch['korespondencja'])) {
        if (empty($itemPatch['korespondencja'][0]['id'])) throw new Exception("BUG: Missing Koresp id");
        $pkOldKoresp = $oldItem['korespondencja'][0]['id'];
        $pkKoresp = $itemPatch['korespondencja'][0]['id'];
        DBG::log("\$pkOldKoresp({$pkOldKoresp}), \$pkKoresp({$pkKoresp})");
        if ($pkOldKoresp != $pkKoresp) {
          $this->cleanRefs('korespondencja', $pk);
          $this->insertRef('korespondencja', $pk, $pkKoresp);
        }
      } else {
        DBG::log("cleanRefs \$pk({$pk})");
        $this->cleanRefs('korespondencja', $pk);
      }
    }

/* { "updates": {
        "@instance": "ZaliczkaAktywna",
        "id": "8",
        "created": "2017-01-27 11:10:59",
        "worker": [{ "id": "1", "login": "magdalena.cichosz", "name": "Magdalena Cichosz" }],
        "kwota": "0.01",
        "nierozliczona_kwota": "300.02",
        "pozycja": [{
            "id": -1,
            "nr_faktury": "fv 2017/1/1",
            "kwota": 100,
            "vat": 23,
            "kwota_netto": 0,
            "kategoria_kosztu": "BUDOWA: Usługi obce"
        }],
        "korespondencja": {
            "id": "6013",
            "title": "faktura Vat (MULTI-TAB) [6013]",
            "kategoriaKosztu": "do uzgodnienia",
            "projekt": { "id": "64", "nrBudowy": "20/2016" }
        }
    }
} */

    $patch = [];
    // $itemPatch['kwota'] = str_replace(',', '.', $itemPatch['kwota']);
    // if ($itemPatch['kwota'] != $oldItem['kwota']) $patch['kwota'] = $itemPatch['kwota'];

    // TODO: diff $itemPatch['pozycja'] != $oldItem['pozycja']
    if (!empty($patch)) {
      // if (array_key_exists('kwota', $patch)) {
      //   DB::getPDO()->update('ZALICZKA', 'ID', $pk, [ 'kwota' => $patch['kwota'] ]);
      // }
    }
  }

  public function getItem($primaryKey, $params = []) {
    $zaliczkaRaw = DB::getPDO()->fetchAll("
      select t.*
      from `ZALICZKA` t
      where t.ID = {$primaryKey}
    ");
    $zaliczkaRaw = (!empty($zaliczkaRaw)) ? reset($zaliczkaRaw) : null;
    // DBG::nicePrint($zaliczkaRaw, '$zaliczkaRaw');
    if (!$zaliczkaRaw) return null;
    return $this->buildFromSqlRow($zaliczkaRaw, $params);
  }

  public function reinstall() {
    // TODO: mv to Core_AclSimpleSchemaBase and reainstall by _simpleSchema - read current data from `information_schema`
		DB::getPDO()->execSql("
			CREATE TABLE IF NOT EXISTS `ZALICZKA` (
				`ID` int(11) NOT NULL AUTO_INCREMENT,
				`A_RECORD_CREATE_DATE` datetime  DEFAULT NULL,
				`A_RECORD_CREATE_AUTHOR` varchar(20)  DEFAULT NULL,
				`A_RECORD_UPDATE_DATE` datetime  DEFAULT NULL,
				`A_RECORD_UPDATE_AUTHOR` varchar(20) NOT NULL DEFAULT '',
				`A_STATUS` enum('WAITING','NORMAL','MONITOR','WARNING','OFF_SOFT','OFF_HARD','DELETED') DEFAULT 'WAITING',
				`A_ADM_COMPANY` varchar(100) NOT NULL DEFAULT '',
				`A_CLASSIFIED` varchar(100) NOT NULL DEFAULT '',
				`L_APPOITMENT_USER` varchar(100) NOT NULL DEFAULT '',
				`KWOTA` decimal(16,2) NOT NULL DEFAULT 0,
				`NIEROZLICZONA_KWOTA` decimal(16,2) NOT NULL DEFAULT 0,
				PRIMARY KEY (`ID`)
			) ENGINE=MyISAM DEFAULT CHARSET=latin2;
		");
		DB::getPDO()->execSql("
			CREATE TABLE IF NOT EXISTS `ZALICZKA_HIST` (
				`ID` int(11) NOT NULL AUTO_INCREMENT,
				`ID_USERS2` int(11) NOT NULL,
				`A_RECORD_CREATE_DATE` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_RECORD_CREATE_AUTHOR` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_RECORD_UPDATE_DATE` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_RECORD_UPDATE_AUTHOR` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_STATUS` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_ADM_COMPANY` varchar(100) NOT NULL DEFAULT 'N/S;',
				`A_CLASSIFIED` varchar(100) NOT NULL DEFAULT 'N/S;',
				`L_APPOITMENT_USER` varchar(100) NOT NULL DEFAULT 'N/S;',
				`KWOTA` varchar(16) NOT NULL DEFAULT 'N/S;',
				`NIEROZLICZONA_KWOTA` varchar(16) NOT NULL DEFAULT 'N/S;',
				PRIMARY KEY (`ID`),
			  KEY `ID_USERS2` (`ID_USERS2`)
			) ENGINE=MyISAM  DEFAULT CHARSET=latin2;
		");
		DB::getPDO()->execSql("
			CREATE TABLE IF NOT EXISTS `ZALICZKA_POZYCJA` (
				`ID` int(11) NOT NULL AUTO_INCREMENT,
				`A_RECORD_CREATE_DATE` datetime  DEFAULT NULL,
				`A_RECORD_CREATE_AUTHOR` varchar(20)  DEFAULT NULL,
				`A_RECORD_UPDATE_DATE` datetime  DEFAULT NULL,
				`A_RECORD_UPDATE_AUTHOR` varchar(20) NOT NULL DEFAULT '',
				`A_STATUS` enum('WAITING','NORMAL','MONITOR','WARNING','OFF_SOFT','OFF_HARD','DELETED') DEFAULT NULL,
				`A_ADM_COMPANY` varchar(100) NOT NULL DEFAULT '',
				`A_CLASSIFIED` varchar(100) NOT NULL DEFAULT '',
				`L_APPOITMENT_USER` varchar(100) NOT NULL DEFAULT '',
        `nr_faktury` varchar(255) NOT NULL DEFAULT '',
				`kwota` decimal(16,2) NOT NULL DEFAULT 0,
				`vat` int(11) NOT NULL DEFAULT 23,
				`kwota_netto` decimal(16,2) NOT NULL DEFAULT 0,
        `kategoria_kosztu` varchar(255) NOT NULL DEFAULT '',
				PRIMARY KEY (`ID`)
			) ENGINE=MyISAM DEFAULT CHARSET=latin2;
		");
		DB::getPDO()->execSql("
			CREATE TABLE IF NOT EXISTS `ZALICZKA_POZYCJA_HIST` (
				`ID` int(11) NOT NULL AUTO_INCREMENT,
				`ID_USERS2` int(11) NOT NULL,
				`A_RECORD_CREATE_DATE` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_RECORD_CREATE_AUTHOR` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_RECORD_UPDATE_DATE` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_RECORD_UPDATE_AUTHOR` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_STATUS` varchar(20) NOT NULL DEFAULT 'N/S;',
				`A_ADM_COMPANY` varchar(100) NOT NULL DEFAULT 'N/S;',
				`A_CLASSIFIED` varchar(100) NOT NULL DEFAULT 'N/S;',
				`L_APPOITMENT_USER` varchar(100) NOT NULL DEFAULT 'N/S;',
				`nr_faktury` varchar(255) NOT NULL DEFAULT 'N/S;',
				`kwota` varchar(16) NOT NULL DEFAULT 'N/S;',
				`vat` varchar(5) NOT NULL DEFAULT 'N/S;',
				`kwota_netto` varchar(16) NOT NULL DEFAULT 'N/S;',
        `kategoria_kosztu` varchar(255) NOT NULL DEFAULT 'N/S;',
				PRIMARY KEY (`ID`),
			  KEY `ID_USERS2` (`ID_USERS2`)
			) ENGINE=MyISAM  DEFAULT CHARSET=latin2;
		");

    echo UI::h('div', [ 'class' => "container", 'style' => "background:#ffe5b6; margin-top:6px" ], "<p style=\"margin:0; padding:6px\">Upgrade schema</p>");
    UI::startContainer([ 'style' => "max-height:200px; overflow-y:scroll; border:1px solid #ffe5b6" ]);
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA` ADD `nr_faktury` varchar(255) NOT NULL DEFAULT '' ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA` ADD `vat` int(11) NOT NULL DEFAULT 23 ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA` ADD `kwota_netto` decimal(16,2) NOT NULL DEFAULT 0 ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA` ADD `kategoria_kosztu` varchar(255) NOT NULL DEFAULT '' ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA_HIST` ADD `nr_faktury` varchar(255) NOT NULL DEFAULT 'N/S;' ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA_HIST` ADD `vat` varchar(5) NOT NULL DEFAULT 'N/S;' ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA_HIST` ADD `kwota_netto` varchar(16) NOT NULL DEFAULT 'N/S;' ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    try {
      DB::getPDO()->execSql(" ALTER TABLE `ZALICZKA_POZYCJA_HIST` ADD `kategoria_kosztu` varchar(255) NOT NULL DEFAULT 'N/S;' ");
    } catch (Exception $e) { UI::alert('warning', $e->getMessage()); }
    UI::endContainer();

    ACL::getRefTable('default_db/ZALICZKA/Zaliczka', 'worker');
    ACL::getRefTable('default_db/ZALICZKA/Zaliczka', 'pozycja');
    ACL::getRefTable('default_db/ZALICZKA/Zaliczka', 'korespondencja');
    // ACL::getRefTable('default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja', 'projekt');
    // ACL::getRefTable('default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja', 'korespondencja');

    Core_AclHelper::getInstanceTable('ZALICZKA');// `ZALICZKA__#INSTANCE`
    // TODO: ZaliczkaOczekujaca   A_STATUS = WAITING  -- dodane przez pracownika
    // TODO: ZaliczkaAktywna      A_STATUS = NORMAL   -- zakceptowane / wyplacone przez ...
      // TODO: pole na dane wypłacającego zaliczkę
      // TODO: dopiero teraz wyliczyć saldo / nierozliczona_kwota? Saldo pokazywać zawsze, aktualizować po akceptacji (Oczekujaca --> Aktywna)
    // TODO: ZaliczkaArchiwalna   A_STATUS = OFF_HARD -- poprzednie zaliczki
    // TODO: ZaliczkaUsunieta     A_STATUS = DELETED  -- usunieta przez workera lub anulowana przez osobę uprawnioną

    Core_AclHelper::getTransactionTable('ZALICZKA');// `ZALICZKA__#TRANSACTION`
    Core_AclHelper::getTransactionTable('ZALICZKA_POZYCJA');// `ZALICZKA_POZYCJA__#TRANSACTION`

    echo UI::h('div', [ 'class' => "container", 'style' => "background:#ffe5b6; margin-top:6px" ], "<p style=\"margin:0; padding:6px\">create ChildHistTable</p>");
    UI::startContainer([ 'style' => "max-height:200px; overflow-y:scroll; border:1px solid #ffe5b6" ]);
    foreach ($this->_simpleSchema['root'] as $childName => $schema) {
      if ('@' == substr($childName, 0, 1)) continue;
      $this->getChildHistTable($childName);
      DBG::nicePrint($schema, '$childName('.$childName.')');// TODO: DBG
    }
    UI::endContainer();
	}

}