se/SE/se-lib/Schema/DefaultDb/zaliczka_pozycja/ZaliczkaPozycjaStorageAcl.php

<?php

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

class Schema_DefaultDb_zaliczka_pozycja_ZaliczkaPozycjaStorageAcl extends Core_AclSimpleSchemaBase {

  public $_simpleSchema = [
    'root' => [
      '@namespace' => 'default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja',// Api_WfsNs::getBaseWfsUri() . '/default_db/Zaliczka'
      '@primaryKey' => 'id',
      'id' => [ '@type' => 'xsd:integer', '@alias' => 'ID' ],
      'nr_faktury' => [ '@type' => "xsd:string" ],
      'kwota' => [ '@type' => 'xsd:decimal', '@totalDigits' => 16, '@fractionDigits' => 2 ],
      'vat' => [ '@type' => "xsd:integer", '@default' => 23 ],
      'kwota_netto' => [ '@type' => 'xsd:decimal', '@totalDigits' => 16, '@fractionDigits' => 2 ],
      'kategoria_kosztu' => [ '@type' => 'p5:enum', '@aliasFieldValues' => [
        'namespace' => 'default_db/IN7_DZIENNIK_KORESP',
        'childName' => 'KATEGORIA_KOSZTU'
      ] ],// default_db__x3A__ZALICZKA_POZYCJA:kategoria_kosztuType, default_db__x3A__IN7_DZIENNIK_KORESP:kategoria_kosztuType
      // 'korespondencja' => [ '@ref' => 'default_db/IN7_DZIENNIK_KORESP/ZaliczkaKoresp' ],
      // 'projekt' => [ '@ref' => 'default_db/IN7_MK_BAZA_DYSTRYBUCJI/ZaliczkaProjekt' ]
    ],
    // 'kategoria_kosztuType' => [// TODO: enumeration or config for remote data fetch - Typespecial
      // <xsd:simpleType name="A_STATUSType">
      //   <xsd:restriction base="xsd:string">
      //     <xsd:enumeration value="DELETED"/>
      //     <xsd:enumeration value="MONITOR"/>
      //     <xsd:enumeration value="NORMAL"/>
      //     <xsd:enumeration value="OFF_HARD"/>
      //     <xsd:enumeration value="OFF_SOFT"/>
      //     <xsd:enumeration value="WAITING"/>
      //     <xsd:enumeration value="WARNING"/>
      //   </xsd:restriction>
      // </xsd:simpleType>
    // ]
  ];

  public function addItem($itemTodo) {
    DBG::log(['msg'=> 'addItem', $itemTodo]);
    $sqlItem = array();
    if (!empty($itemTodo['nr_faktury'])) {
      $sqlItem[ $this->getSqlFieldName('nr_faktury') ] = $itemTodo['nr_faktury'];
    }
    if (!empty($itemTodo['kwota'])) {
      $kwota = V::get('kwota', 0, $itemTodo, 'price');
      if ($kwota > 0) $sqlItem[ $this->getSqlFieldName('kwota') ] = $kwota;
    }
    if (!empty($itemTodo['vat'])) {
      $vat = (int)$itemTodo['vat'];
      if ($vat > 0) $sqlItem[ $this->getSqlFieldName('vat') ] = $vat;
    }
    if (!empty($itemTodo['kategoria_kosztu'])) {
      $sqlItem[ $this->getSqlFieldName('kategoria_kosztu') ] = $itemTodo['kategoria_kosztu'];
    }

    $sqlItem[ $this->getSqlFieldName('kwota_netto') ] = ($kwota > 0 && $vat > 0)
      ? $kwota / (1 + $vat / 100)
      : 0;

    if (empty($sqlItem)) throw new Exception("Empty record");
    return DB::getPDO()->insert($this->getRootTableName(), $sqlItem);
  }

  public function updateItem($itemPatch) {
    DBG::log(['msg'=> 'updateItem: $itemPatch', $itemPatch]);
    // 'id' => '1',
    //   'nr_faktury' => '100.',
    //   'kwota' => '123.46',
    //   'vat' => '23',
    //   'kwota_netto' => '100.37',
    //   'kategoria_kosztu' => 'BUDOWA: Wynagrodzenia osobowe + ZUS',
    $pkField = $this->getPrimaryKeyField();
    $pk = V::get($pkField, null, $itemPatch);
    if (null === $pk) throw new Exception("BUG missing primary key field for {$this->_namespace}");
    $oldItem = $this->getItem($pk);// TODO: only cols: ['id', 'nr_faktury', 'kwota', 'vat', 'kategoria_kosztu']
    DBG::log(['msg'=> 'updateItem: $oldItem', $oldItem]);
    if (!$oldItem) throw new Exception("BUG item '{$pk}' not found ({$this->_namespace})");
    $sqlPatch = array();
    if (array_key_exists('nr_faktury', $itemPatch) && $oldItem['nr_faktury'] != $itemPatch['nr_faktury']) {
      $sqlPatch[ $this->getSqlFieldName('nr_faktury') ] = $itemPatch['nr_faktury'];
    }
    $nettoToUpdate = false;
    $kwota = V::get('kwota', 0, $oldItem, 'price');
    if (array_key_exists('kwota', $itemPatch) && $oldItem['kwota'] != $itemPatch['kwota']) {
      $nettoToUpdate = true;
      $kwota = V::get('kwota', 0, $itemPatch, 'price');
      $sqlPatch[ $this->getSqlFieldName('kwota') ] = $kwota;
    }
    $vat = V::get('vat', 0, $oldItem, 'int');
    if (array_key_exists('vat', $itemPatch) && $oldItem['vat'] != $itemPatch['vat']) {
      $nettoToUpdate = true;
      $vat = V::get('vat', 0, $itemPatch, 'int');
      $sqlPatch[ $this->getSqlFieldName('vat') ] = $vat;
    }
    if ($nettoToUpdate) {
      $sqlPatch[ $this->getSqlFieldName('kwota_netto') ] = ($kwota > 0 && $vat > 0)
        ? $kwota / (1 + $vat / 100)
        : 0;
    }
    if (array_key_exists('kategoria_kosztu', $itemPatch) && $oldItem['kategoria_kosztu'] != $itemPatch['kategoria_kosztu']) {
      $sqlPatch[ $this->getSqlFieldName('kategoria_kosztu') ] = $itemPatch['kategoria_kosztu'];
    }
    DBG::log(['msg'=> 'updateItem: $sqlPatch', $sqlPatch]);
    if (empty($sqlPatch)) return 0;
    return DB::getPDO()->update(
      $this->getRootTableName(),
      $this->getSqlPrimaryKeyField(),
      $pk,
      $sqlPatch
    );
  }

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

  public function getItems($params = array()) {
    DBG::log(['msg'=> 'getItems', $params]);
    // $idUser = V::get('primaryKey', 0, $params['#refFrom'], 'int');
    $sqlWhereAnd = array();
    if (empty($params)) {
    } else if (!empty($params['@primaryKey'])) {// [@primaryKey] => Array ([0] => 59599)
      if (is_array($params['@primaryKey'])) {
        $sqlWhereAnd[] = "z.ID in(" . implode(", ", $params['@primaryKey']) . ")";
      }
    // } else if (!empty($params['f_title'])) {
    //   DBG::log("return filter by K_ZAWARTOS, K_OD_KOGO like '%{$params['f_title']}%' order by last created rows by user or another users");
    //   $sqlParamTitle = DB::getPDO()->quote("%{$params['f_title']}%", PDO::PARAM_STR);
    //   $sqlWhereAnd[] = " (
    //     k.ID like {$sqlParamTitle}
    //     or k.K_ZAWARTOS like {$sqlParamTitle}
    //     or k.K_OD_KOGO like {$sqlParamTitle}
    //   ) ";
    }
    $sqlWhere = (!empty($sqlWhereAnd)) ? implode(" and ", $sqlWhereAnd) : "1=1";
    return array_map(
      function ($row) use ($params) {
        return $this->buildFromSqlRow($row, $params);
      },
      DB::getPDO()->fetchAll("
        select z.*
        from ZALICZKA_POZYCJA z
        where {$sqlWhere}
        order by z.ID ASC
      ")
    );
  }

}