se/SE/se-lib/Schema/UserProcessStorageAcl.php

<?php

Lib::loadClass('Core_AclSimpleSchemaBase');
Lib::loadClass('ParseOgcFilter');

class Schema_UserProcessStorageAcl extends Core_AclSimpleSchemaBase {

  public $_simpleSchema = [
    'root' => [
      '@namespace' => 'default_objects/UserProcess',
      'ID' => [ '@type' => 'xsd:integer' ],
      'PARENT_ID' => [ '@type' => 'xsd:integer' ],
      'nazwa' => [ '@type' => 'xsd:string', '@alias' => 'DESC' ],
      'opis' => [ '@type' => 'xsd:string', '@alias' => 'OPIS' ],
      'link_uruchom_filtr_procesu' => [ '@type' => 'p5:www_link' ],
      'autor' => [ '@type' => 'xsd:string' , '@alias' => 'A_RECORD_CREATE_AUTHOR' ],
      'utworzono' => [ '@type' => 'xsd:date' , '@alias' => 'A_RECORD_CREATE_DATE' ],
      'zaktualizował' => [ '@type' => 'xsd:string' , '@alias' => 'A_RECORD_UPDATE_AUTHOR' ],
      'zaktualizowano' => [ '@type' => 'xsd:date', '@alias' => 'A_RECORD_UPDATE_DATE' ]
    ]
  ];
  public $_rootTableName = 'CRM_PROCES';
  public $idUser = null;

  public function __construct($simpleSchema = null) {
    parent::__construct($simpleSchema);
    $this->idUser = User::getID();// default - current user
  }

  public function setIdUser($idUser) { $this->idUser = intval($idUser); }
  public function getIdUser() { return $this->idUser; }

  public function getTotal($params = []) {
    $sqlWhereAnd = $this->_parseSqlWhere($params);

    $idGroupList = $this->_getUserIdGroupList();
    if (empty($idGroupList)) throw new Exception("Brak przyipsanych grup do użytwkonika");
    $sqlIdGroupCsv = implode(",", $idGroupList);

    return DB::getPDO()->fetchValue("
      select count(1) as total
      from `CRM_PROCES` p
      where p.`TYPE` = 'PROCES_INIT'
        and p.`A_STATUS` not in('DELETED', 'OFF_HARD', 'OFF_SOFT')
        and p.ID in (
          select gi.ID_PROCES_INIT
          from `CRM_PROCES_idx_GROUP_to_INIT_VIEW` as gi
          where gi.ID_GROUP in({$sqlIdGroupCsv})
        )
        {$sqlWhereAnd}
    ");
  }

  public function _parseSqlWhere($params = []) {
    $sqlWhereAnd = "";
    // TODO: parse where/ogc, etc.
    return $sqlWhereAnd;
  }

  public function getItems($params = []) {
    $sqlOrderBy = "";
    $sqlLimitOffset = "";
    $sqlWhereAnd = $this->_parseSqlWhere($params);

    $currSortCol = V::get('order_by', 'ID', $params);
    $currSortFlip = strtolower(V::get('order_dir', 'desc', $params));
    // TODO: validate $currSortCol is in field list
    // TODO: validate $currSortFlip ('asc' or 'desc')

    $aliasMap = array();
    foreach ($this->_simpleSchema['root'] as $key => $field) {
      if ('@' === substr($key, 0, 1)) continue;
      $aliasMap[ $key ] = (!empty($field['@alias'])) ? $field['@alias'] : $key;
    }
    // TODO: if (!array_key_exists($currSortCol, $aliasMap)) throw new Exception("field name not allowed to sort");
    $currSortCol = (array_key_exists($currSortCol, $aliasMap)) ? $aliasMap[$currSortCol] : null;

    if (!empty($currSortCol) && ('asc' == $currSortFlip || 'desc' == $currSortFlip)) {
      $sqlOrderBy = "order by p.`{$currSortCol}` {$currSortFlip}";
    }

    $limit = V::get('limit', 0, $params);
    $limit = ($limit < 0) ? 0 : $limit;
    $offset = V::get('limitstart', 0, $params);
    $offset = ($offset < 0) ? 0 : $offset;
    if ($limit > 0) $sqlLimitOffset = "limit {$limit} offset {$offset}";

    $idGroupList = $this->_getUserIdGroupList();
    if (empty($idGroupList)) throw new Exception("Brak przyipsanych grup do użytwkonika");
    $sqlIdGroupCsv = implode(",", $idGroupList);

    $items = DB::getPDO()->fetchAllByKey("
      select p.ID
        , p.PARENT_ID
        , p.`DESC` as nazwa
        , p.`OPIS` as opis
        , p.A_RECORD_CREATE_AUTHOR as `autor`
        , p.A_RECORD_CREATE_DATE as `utworzono`
        , p.A_RECORD_UPDATE_AUTHOR as `zaktualizował`
        , p.A_RECORD_UPDATE_DATE as `zaktualizowano`
      from `CRM_PROCES` p
      where p.`TYPE` = 'PROCES_INIT'
        and p.`A_STATUS` not in('DELETED', 'OFF_HARD', 'OFF_SOFT')
        and p.ID in (
          select gi.ID_PROCES_INIT
          from `CRM_PROCES_idx_GROUP_to_INIT_VIEW` as gi
          where gi.ID_GROUP in({$sqlIdGroupCsv})
        )
        {$sqlWhereAnd}
      group by p.ID
      {$sqlOrderBy}
      {$sqlLimitOffset}
    ", 'ID');
    array_walk($items, function (&$item, $key) {
      $item['link_uruchom_filtr_procesu'] = Request::getPathUri() . "index.php?FUNCTION_INIT=MENU_SELECT_PROCES&_action=setPermsByProces&id_proces={$item['ID']}";
    });
    return $items;
  }

  public function _getUserIdGroupList() {
    return array_map(
      function ($row) {
        return $row['ID'];
      }
      , DB::getPDO()->fetchAll("
        select z.ID
        from `CRM_AUTH_PROFILE` as up
          left join `CRM_LISTA_ZASOBOW` as z on(z.`ID`=up.`ID_ZASOB`)
        where
          up.`REMOTE_ID`='{$this->idUser}'
          and up.`A_STATUS` in('WAITING', 'NORMAL')
          and up.`REMOTE_TABLE`='ADMIN_USERS'
          and z.`ID` is not null
          and z.`TYPE` in('STANOWISKO','PODMIOT','DZIAL')
      ")
    );
  }

}