|
|
@@ -0,0 +1,206 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+Lib::loadClass('Core_AclSimpleSchemaBase');
|
|
|
+Lib::loadClass('ParseOgcFilter');
|
|
|
+
|
|
|
+class Schema_UserMsgsStorageAcl extends Core_AclSimpleSchemaBase {
|
|
|
+
|
|
|
+ // select m.*
|
|
|
+ // `ID` int(11) NOT NULL AUTO_INCREMENT,
|
|
|
+ // `idReplyTo` int(11) NOT NULL DEFAULT '0',
|
|
|
+ // `idThread` int(11) NOT NULL DEFAULT '0',
|
|
|
+ // `app_className` varchar(255) DEFAULT NULL,
|
|
|
+ // `msg` varchar(1000) NOT NULL,
|
|
|
+ // `msgType` enum('info','danger','warning','success') NOT NULL DEFAULT 'info',
|
|
|
+ // `uiTargetType` enum('default_db_table','default_db_table_record','after_login','everywhere') NOT NULL,
|
|
|
+ // `uiTargetName` varchar(255) NOT NULL DEFAULT '',
|
|
|
+ // `userTargetType` enum('none','everyone','admin','user','group') NOT NULL DEFAULT 'none',
|
|
|
+ // `userTargetName` varchar(255) NOT NULL DEFAULT '',
|
|
|
+ // `actionExecutedTime` datetime DEFAULT NULL,
|
|
|
+ // `actionNotes` varchar(255) NOT NULL DEFAULT '',
|
|
|
+ // `A_STATUS` enum('WAITING','NORMAL','OFF_HARD','DELETED') NOT NULL DEFAULT 'WAITING',
|
|
|
+ // `A_RECORD_CREATE_DATE` datetime DEFAULT NULL,
|
|
|
+ // `A_RECORD_CREATE_AUTHOR` varchar(40) NOT NULL DEFAULT '',
|
|
|
+ // `A_RECORD_UPDATE_DATE` datetime DEFAULT NULL,
|
|
|
+ // `A_RECORD_UPDATE_AUTHOR` varchar(40) NOT NULL DEFAULT '',
|
|
|
+ // `A_RECORD_DELETE_DATE` datetime DEFAULT NULL,
|
|
|
+ // `A_RECORD_DELETE_AUTHOR` varchar(40) NOT NULL DEFAULT '',
|
|
|
+ // PRIMARY KEY (`ID`),
|
|
|
+ // KEY `app_className` (`app_className`),
|
|
|
+ // KEY `A_STATUS` (`A_STATUS`),
|
|
|
+ // KEY `A_RECORD_UPDATE_DATE` (`A_RECORD_UPDATE_DATE`)
|
|
|
+ // from `CRM_UI_MSGS` m
|
|
|
+ // where m.`uiTargetType`='default_db_table_record'
|
|
|
+ // -- and m.`uiTargetName`='.'
|
|
|
+ // and (
|
|
|
+ // m.`userTargetType` in('everyone')
|
|
|
+ // or (m.`userTargetType`='user' and m.`userTargetName`='plabudda')
|
|
|
+ // or (m.`userTargetType`='group' and m.`userTargetName` in(94,4495,1767,2948,2975,13069,21168,12887,22017,20046,11875,20906,79,22720,26118,26522,26498,26519,26623,26532,26119,26529,26497,27324,289,288,270,13,20540))
|
|
|
+ // )
|
|
|
+ // and m.`A_STATUS` in('WAITING', 'NORMAL')
|
|
|
+ // order by m.`ID` DESC
|
|
|
+ // limit 21
|
|
|
+
|
|
|
+ public $_simpleSchema = [
|
|
|
+ 'root' => [
|
|
|
+ '@namespace' => 'default_objects/UserMsgs',
|
|
|
+ 'ID' => [ '@type' => 'xsd:integer' ],
|
|
|
+ 'idReplyTo' => [ '@type' => 'xsd:integer' ],
|
|
|
+ 'idThread' => [ '@type' => 'xsd:integer' ],
|
|
|
+ 'app_className' => [ '@type' => 'xsd:string' ],
|
|
|
+ 'msg' => [ '@type' => 'xsd:string' ],
|
|
|
+ 'msgType' => [ '@type' => 'xsd:string' ], // enum('info','danger','warning','success') NOT NULL DEFAULT 'info',
|
|
|
+ 'uiTargetType' => [ '@type' => 'xsd:string' ], // enum('default_db_table','default_db_table_record','after_login','everywhere') NOT NULL,
|
|
|
+ 'uiTargetName' => [ '@type' => 'xsd:string' ],
|
|
|
+ 'userTargetType' => [ '@type' => 'xsd:string' ], // enum('none','everyone','admin','user','group') NOT NULL DEFAULT 'none',
|
|
|
+ 'userTargetName' => [ '@type' => 'xsd:string' ],
|
|
|
+ 'actionExecutedTime' => [ '@type' => 'xsd:date' ],
|
|
|
+ 'actionNotes' => [ '@type' => 'xsd:string' ],
|
|
|
+ 'A_STATUS' => [ '@type' => 'xsd:string' ], // enum('WAITING','NORMAL','OFF_HARD','DELETED') NOT NULL DEFAULT 'WAITING',
|
|
|
+ 'actionNotes' => [ '@type' => 'xsd:string' ],
|
|
|
+ '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' ],
|
|
|
+ 'usunął' => [ '@type' => 'xsd:string', '@alias' => 'A_RECORD_DELETE_AUTHOR' ],
|
|
|
+ 'usunięto' => [ '@type' => 'xsd:date', '@alias' => 'A_RECORD_DELETE_DATE' ],
|
|
|
+ // 'custom_field_name' => [ '@type' => 'p5:www_link' ],
|
|
|
+ ]
|
|
|
+ ];
|
|
|
+ public $_rootTableName = 'CRM_UI_MSGS';
|
|
|
+ public $idUser = null;
|
|
|
+ public $login = null;
|
|
|
+
|
|
|
+ public function __construct($simpleSchema = null) {
|
|
|
+ parent::__construct($simpleSchema);
|
|
|
+ $this->idUser = User::getID(); // default - current user
|
|
|
+ $this->login = User::getLogin();
|
|
|
+ }
|
|
|
+
|
|
|
+ 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 przypisanych grup do użytkownika");
|
|
|
+ $sqlIdGroupsCsv = implode(",", $idGroupList);
|
|
|
+
|
|
|
+ return DB::getPDO()->fetchValue("
|
|
|
+ select count(1) as total
|
|
|
+ from `CRM_UI_MSGS` m
|
|
|
+ where m.`uiTargetType` = 'default_db_table_record'
|
|
|
+ -- and m.`uiTargetName` = '.'
|
|
|
+ and (
|
|
|
+ m.`userTargetType` in('everyone')
|
|
|
+ or ( m.`userTargetType`='user' and m.`userTargetName` = :login )
|
|
|
+ or ( m.`userTargetType`='group' and m.`userTargetName` in( {$sqlIdGroupsCsv} ) )
|
|
|
+ )
|
|
|
+ and m.`A_STATUS` in('WAITING', 'NORMAL')
|
|
|
+ {$sqlWhereAnd}
|
|
|
+ ", [
|
|
|
+ ':login' => $this->login,
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+
|
|
|
+ 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 m.`{$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 przypisanych grup do użytkownika");
|
|
|
+ $sqlIdGroupsCsv = implode(",", $idGroupList);
|
|
|
+
|
|
|
+ $items = DB::getPDO()->fetchAllByKey("
|
|
|
+ select m.ID
|
|
|
+ , m.idReplyTo
|
|
|
+ , m.idThread
|
|
|
+ , m.app_className
|
|
|
+ , m.msg
|
|
|
+ , m.msgType
|
|
|
+ , m.uiTargetType
|
|
|
+ , m.uiTargetName
|
|
|
+ , m.userTargetType
|
|
|
+ , m.userTargetName
|
|
|
+ , m.actionExecutedTime
|
|
|
+ , m.actionNotes
|
|
|
+ , m.A_STATUS
|
|
|
+ , m.actionNotes
|
|
|
+ , m.A_RECORD_CREATE_AUTHOR as `autor`
|
|
|
+ , m.A_RECORD_CREATE_DATE as `utworzono`
|
|
|
+ , m.A_RECORD_UPDATE_AUTHOR as `zaktualizował`
|
|
|
+ , m.A_RECORD_UPDATE_DATE as `zaktualizowano`
|
|
|
+ , m.A_RECORD_DELETE_AUTHOR as `usunął`
|
|
|
+ , m.A_RECORD_DELETE_DATE as `usunięto`
|
|
|
+ from `CRM_UI_MSGS` m
|
|
|
+ where m.`uiTargetType` = 'default_db_table_record'
|
|
|
+ -- and m.`uiTargetName` = '.'
|
|
|
+ and (
|
|
|
+ m.`userTargetType` in('everyone')
|
|
|
+ or ( m.`userTargetType`='user' and m.`userTargetName` = :login )
|
|
|
+ or ( m.`userTargetType`='group' and m.`userTargetName` in( {$sqlIdGroupsCsv} ) )
|
|
|
+ )
|
|
|
+ and m.`A_STATUS` in('WAITING', 'NORMAL')
|
|
|
+ {$sqlWhereAnd}
|
|
|
+ {$sqlOrderBy}
|
|
|
+ {$sqlLimitOffset}
|
|
|
+ ", 'ID', [
|
|
|
+ ':login' => $this->login,
|
|
|
+ ]);
|
|
|
+ // 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')
|
|
|
+ ")
|
|
|
+ );
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
