UserAcl.php 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605
  1. <?php
  2. Lib::loadClass('DB');
  3. Lib::loadClass('UsersHelper');
  4. Lib::loadClass('ProcesHelper');
  5. Lib::loadClass('TableAcl');
  6. Lib::loadClass('SchemaReader');
  7. Lib::loadClass('SchemaFactory');
  8. Lib::loadClass('DBG');
  9. class UserAcl {
  10. public $_user_id;
  11. public $_use_cache = false;
  12. public $_session_id = false;
  13. /**
  14. * User groups (cached)
  15. */
  16. public $_groups = array();
  17. public $_proces_ids = array();
  18. public $_proces_tree_flat = array();
  19. public $_proces_used_ids = array();
  20. public $_proces_used_map = array();
  21. public $_proces_init_used_ids = array();
  22. function __construct($user_id, $use_cache = false, $session_id = null) {
  23. $this->_user_id = $user_id;
  24. $this->_use_cache = $use_cache;
  25. $this->_session_id = (null !== $session_id) ? $session_id : session_id();
  26. DBG::simpleLog('auth', "UserAcl::__construct {{$user_id}, {$this->_session_id}}");
  27. // try {
  28. // throw new Exception("Error Processing Request");
  29. // } catch (Exception $e) {
  30. // DBG::simpleLog('auth', "UserAcl::__construct {{$user_id}, {$this->_session_id}} trace:" . "\n" . $e->getTraceAsString());
  31. // }
  32. $this->_cache_init();
  33. }
  34. function fetchGroups() {
  35. if ($this->_user_id < 0) return false;
  36. if (!empty($this->_groups)) {
  37. return $this->_groups;
  38. }
  39. $this->_groups = $this->_cache_read('_groups');
  40. if ($this->_groups != null) {
  41. return $this->_groups;
  42. }
  43. $this->_groups = array();
  44. $this->_groups = UsersHelper::get_group_by_user($this->_user_id);
  45. $this->_cache_save('_groups', $this->_groups);
  46. return $this->_groups;
  47. }
  48. function getProcesIds() {
  49. if (!empty($this->_proces_ids)) return $this->_proces_ids;
  50. $groups = $this->fetchGroups();
  51. if (empty($groups)) {
  52. return false;
  53. }
  54. $this->_proces_ids = DB::getPDO()->fetchValuesList("
  55. select p.`ID`
  56. from `CRM_PROCES` as p
  57. left join `CRM_WSKAZNIK` as w on ( p.`ID` = w.`ID_PROCES` )
  58. where
  59. w.`ID_ZASOB` in ( " . implode(",", array_keys($groups)) . " )
  60. and w.`A_STATUS` in ( 'NORMAL', 'WAITING' )
  61. and p.`A_STATUS` in ( 'NORMAL', 'WAITING' )
  62. ");
  63. return $this->_proces_ids;
  64. }
  65. function getProcesTree() {
  66. if (!empty($this->_proces_tree_flat)) return $this->_proces_tree_flat;
  67. $listItems = DB::getPDO()->fetchAll("
  68. select p.`ID`, p.`PARENT_ID`
  69. from `CRM_PROCES` as p
  70. where p.`A_STATUS` in ( 'WAITING', 'NORMAL' )
  71. union
  72. select p.`IF_TRUE_GOTO` as ID, p.`ID` as PARENT_ID
  73. from `CRM_PROCES` as p
  74. where p.`A_STATUS` in ( 'WAITING', 'NORMAL' )
  75. and p.IF_TRUE_GOTO > 0
  76. and p.IF_TRUE_GOTO_FLAG = 'GOTO_AND_RETURN'
  77. ");
  78. // union select '83','122' union select p.`ID` as ID, p.`IF_TRUE_GOTO` as PARENT_ID from `CRM_PROCES` as p where p.`A_STATUS` in('WAITING','NORMAL') and p.IF_TRUE_GOTO>0
  79. //union select '83','122'
  80. //union select '83','2025'
  81. $this->_proces_tree_flat = [];
  82. foreach ($listItems as $item) {
  83. $this->_proces_tree_flat[$item['PARENT_ID']][] = $item['ID'];
  84. }
  85. return $this->_proces_tree_flat;
  86. }
  87. function _cache_init() {
  88. if (!$this->_use_cache) return;
  89. if (!isset($_SESSION['UserAcl_cache'])) {
  90. $_SESSION['UserAcl_cache'] = array();
  91. }
  92. else {
  93. $user_id = V::get('_user_id', 0, $_SESSION['UserAcl_cache'], 'int');
  94. if ($user_id > 0) {
  95. if ($user_id != $this->_user_id) {
  96. // clean cache if another user
  97. $_SESSION['UserAcl_cache'] = array();
  98. }
  99. }
  100. }
  101. }
  102. function _cache_clear() {
  103. if (!$this->_use_cache) return;
  104. $_SESSION['UserAcl_cache'] = array();
  105. }
  106. /**
  107. * Read data from cache.
  108. */
  109. function _cache_read($key) {
  110. if (!$this->_use_cache) return null;
  111. if (array_key_exists($key, $_SESSION['UserAcl_cache'])) {
  112. return $_SESSION['UserAcl_cache'][$key];
  113. }
  114. return null;
  115. }
  116. /**
  117. * Save data in cache.
  118. */
  119. function _cache_save($key, $value) {
  120. if (!$this->_use_cache) return;
  121. if ($key == 'foundTables') {
  122. $tblIds = array();
  123. foreach ($value as $idTable => $tableConfig) {
  124. $tblIds[] = $idTable;
  125. TableAcl::buildInstance($idTable, $tableConfig);
  126. }
  127. $value = $tblIds;
  128. }
  129. $_SESSION['UserAcl_cache'][$key] = $value;
  130. }
  131. public function getUrls() {// @require _fetchPerms
  132. static $_userUrls = null;
  133. if (null !== $_userUrls) return $_userUrls;
  134. $_userUrls = [];
  135. $filterIdProces = $this->getFilterIdProces();
  136. $userUrlAction = SchemaFactory::loadDefaultObject('UserUrlAction');
  137. $userUrlAction->setIdUser($this->_user_id);
  138. $userUrlAction->setIdProcesFilter($filterIdProces);
  139. foreach ($userUrlAction->getItems() as $url) {
  140. $_userUrls[ $url['ID_URL'] ] = $url['opis'];
  141. }
  142. return $_userUrls;
  143. }
  144. public function getObjectAcl($sourceName, $objName) {// TODO: rename $sourceName to $prefix (xml namespace - @see Core_AclHelper)
  145. if (empty($objName)) throw new Exception("Missing object name", 400);
  146. if ('default_db' == $sourceName) {
  147. $zasobTblInfo = ProcesHelper::getZasobTableInfoByUri("{$sourceName}/{$objName}");
  148. if (!$zasobTblInfo) throw new HttpException("Object not Found '{$objName}'", 404);
  149. if (!$this->hasTableAcl($zasobTblInfo->ID)) throw new HttpException("Access Denied for '{$sourceName}/{$objName}'", 403);
  150. return $this->getTableAcl($zasobTblInfo->ID);
  151. } else if ('objects' == $sourceName) {
  152. return SchemaFactory::loadDefaultObject($objName);
  153. } else if ('default_objects' == $sourceName) {
  154. return SchemaFactory::loadDefaultObject($objName);
  155. } else if ('default_db__x3A__' == substr($sourceName, 0, 17)) {
  156. $rootTableName = strtolower(substr($sourceName, 17));
  157. return SchemaFactory::loadTableObject($rootTableName, $objName);
  158. }
  159. throw new HttpException("Not Implemented", 501);
  160. }
  161. public function getTablesAcl() {// TODO: read from `CRM_PROCES_idx_TABLE_TO_USER_VIEW`
  162. $tbls = array();
  163. $tblIds = $this->_cache_read('foundTables');
  164. foreach ($tblIds as $vTableID) {
  165. $tbls[$vTableID] = TableAcl::getInstance($vTableID);
  166. }
  167. return $tbls;
  168. }
  169. public function hasTableAcl($tableID) {// TODO: read from `CRM_PROCES_idx_TABLE_TO_USER_VIEW`
  170. $tbls = $this->_cache_read('foundTables');
  171. return (is_array($tbls) && in_array($tableID, $tbls));
  172. }
  173. public function getTableAcl($tableID) {
  174. $tblAcl = TableAcl::getInstance($tableID);
  175. if (!$tblAcl) throw new Exception("Brak obiektu nr [{$tableID}]!");
  176. $tblAcl->init();
  177. return $tblAcl;
  178. }
  179. /**
  180. * Check if perms are only for one proces.
  181. * @returns int or false
  182. */
  183. public function getPermsFiltrProcesId() {// TODO: RMME mved to getFilterIdProces
  184. return $this->getFilterIdProces();
  185. }
  186. public function getFilterIdProces() {
  187. $procesID = $this->_cache_read('permsByProcesID');
  188. return ($procesID > 0)? $procesID : false;
  189. }
  190. public function fetchAllPerms($force = false) {
  191. $this->_fetchPerms('All', $force);
  192. }
  193. public function fetchProcesPerms($procesID, $force = false) {
  194. $this->_fetchPerms($procesID, $force);
  195. }
  196. /**
  197. * @param $type - 'All', $procesID
  198. */
  199. private function _fetchPerms($type, $force = false) {
  200. $procesID = 0;// if 0 - All, alse perms by procesID
  201. $foundTbls = array();
  202. if ($force) {
  203. $this->_cache_clear();
  204. }
  205. $schemaReader = new SchemaReader();
  206. if ($type == 'All') {
  207. $procesID = 0;// if 0 - All, alse perms by procesID
  208. $schemaReader->getAll();
  209. } else if (is_numeric($type) && $type > 0) {
  210. $procesID = (int)$type;
  211. }
  212. {// fetch from schema files in SE/schema/process/*.ini.php
  213. if ($schemaReader->hasProcessConfigs()) {
  214. foreach ($schemaReader->getProcessConfigs() as $process) {
  215. DBG::_('DBG_SCH', '1', "process", $process, __CLASS__, __FUNCTION__, __LINE__ );
  216. if ($process->hasAccess()) {
  217. $tables = $process->getTables();
  218. DBG::_('DBG_SCH', '1', "tables", $tables, __CLASS__, __FUNCTION__, __LINE__ );
  219. foreach ($tables as $vTable) {
  220. $tblUri = $vTable->getUri();
  221. $zasobTblInfo = ProcesHelper::getZasobTableInfoByUri($tblUri);
  222. DBG::_('DBG_SCH', '1', "table(" . $vTable->getLabel() . ")", $zasobTblInfo, __CLASS__, __FUNCTION__, __LINE__ );
  223. if ($zasobTblInfo) {
  224. $idTable = $zasobTblInfo->ID;
  225. if (!array_key_exists($idTable, $foundTbls)) {
  226. $tableConfig = array();
  227. $tableConfig['ID_TABLE'] = $idTable;
  228. $tableConfig['db'] = $zasobTblInfo->P__ID;
  229. $tableConfig['name'] = $zasobTblInfo->DESC;
  230. $tableConfig['label'] = $zasobTblInfo->DESC_PL;
  231. $tableConfig['opis'] = $zasobTblInfo->OPIS;
  232. $foundTbls[$idTable] = $tableConfig;
  233. }
  234. $tableAcl = TableAcl::buildInstance($idTable, $foundTbls[$idTable]);
  235. $fieldsConfig = array();
  236. $fldsInfo = ProcesHelper::getZasobTableFieldsInfo($idTable);
  237. foreach ($vTable->getFields() as $field) {
  238. $fldInfo = V::get($field->getName(), null, $fldsInfo);
  239. if ($fldInfo) {
  240. if (!array_key_exists($fldInfo->ID, $fieldsConfig)) {
  241. $fieldsConfig[$fldInfo->ID] = array();
  242. $fieldsConfig[$fldInfo->ID]['ID_CELL'] = $fldInfo->ID;
  243. $fieldsConfig[$fldInfo->ID]['CELL_NAME'] = $fldInfo->DESC;
  244. $fieldsConfig[$fldInfo->ID]['CELL_DESC'] = $fldInfo->OPIS;
  245. $fieldsConfig[$fldInfo->ID]['SORT_PRIO'] = $fldInfo->SORT_PRIO;
  246. $fieldsConfig[$fldInfo->ID]['CELL_LABEL'] = $fldInfo->DESC_PL;
  247. $fieldsConfig[$fldInfo->ID]['FORM_TREAT'] = '';
  248. //$tableAcl->addField($fldInfo->ID, $fldInfo->DESC, $fldInfo->OPIS, $fldInfo->SORT_PRIO, $fldInfo->DESC_PL);
  249. }
  250. // TODO: $field->getPerms() -> PERM_R, PERM_W, ... etc.?
  251. $fieldsConfig[$fldInfo->ID]['FORM_TREAT'] .= $field->getPerms();//$tableAcl->setFieldPerms($fldInfo->ID, $field->getPerms());
  252. }
  253. }
  254. $tableAcl->initFieldsFromConfig($fieldsConfig);
  255. DBG::_('DBG_SCH', '1', "fieldsConfig({$idTable})", $fieldsConfig, __CLASS__, __FUNCTION__, __LINE__);
  256. $tableAcl->save();
  257. DBG::_('DBG_SCH', '1', "tableAcl({$idTable})", $tableAcl, __CLASS__, __FUNCTION__, __LINE__);
  258. }
  259. }
  260. }
  261. }
  262. } else {
  263. DBG::_('DBG_SCH', '1', "NO \$schemaReader->hasProcessConfigs()", null, __CLASS__, __FUNCTION__, __LINE__);
  264. }
  265. DBG::_('DBG_SCH', '1', "foundTbls", $foundTbls, __CLASS__, __FUNCTION__, __LINE__);
  266. }// fetch from schema files
  267. $this->setFilterIdProces($procesID);//$this->_cache_save('permsByProcesID', $procesID);
  268. $filterIdProces = $this->getFilterIdProces();
  269. $userConfigStorage = SchemaFactory::loadDefaultObject('UserConfig');// TODO:? UserSession
  270. $userConfigStorage->setIdUser($this->_user_id);
  271. $userConfigStorage->setIdProcesFilter($filterIdProces);
  272. $userConf = $userConfigStorage->getItem(1);// TODO:? session_id() or 'api'
  273. DBG::simpleLog('auth', "UserAcl::fetchPerms UserConf: " . str_replace('"', '', json_encode($userConf)));
  274. // 'lastLogin' => [ '@type' => 'xsd:dateTime', '@confKey' => 'auth_user_{ID_USER}' ],// TODO: store last login time
  275. // 'lastAuthCacheUpdate' => [ '@type' => 'xsd:dateTime', '@confKey' => 'acl_user_{ID_USER}_cache_update' ],
  276. $userObject = SchemaFactory::loadDefaultObject('UserObject');
  277. $userObject->setIdUser($this->_user_id);
  278. $userObject->setIdProcesFilter($filterIdProces);
  279. $userUrlAction = SchemaFactory::loadDefaultObject('UserUrlAction');
  280. $userUrlAction->setIdUser($this->_user_id);
  281. $userUrlAction->setIdProcesFilter($filterIdProces);
  282. // DB cache
  283. // TODO: session garbage collector. CRM_CONFIG: last_proces_update, user_last_req_date, last_user_acl_cache_update
  284. $lastProcesIndexer = DB::getPDO()->fetchValue(" select CONF_VAL from CRM_CONFIG where CONF_KEY = 'tbl_indexer_CRM_PROCES_last_exec_end' ");
  285. DBG::simpleLog('auth', "UserAcl::fetchPerms lastProcesIndexer: '{$lastProcesIndexer}'");
  286. if ($userConf['lastAuthCacheUpdate'] > $lastProcesIndexer) {
  287. DBG::simpleLog('auth', "UserAcl::fetchPerms skip update cache");
  288. } else {
  289. DBG::simpleLog('auth', "UserAcl::fetchPerms update cache");
  290. $userObject->updateCacheFeatures();
  291. $userUrlAction->updateCacheFeatures();
  292. $userConfigStorage->updateItem([
  293. 'ID_USER' => $this->_user_id,
  294. 'ID_PROCES' => $filterIdProces,
  295. 'lastAuthCacheUpdate' => 'NOW()'
  296. ]);
  297. }
  298. $userAccessForTables = array_map(function ($tableConfig) {
  299. $sourceNs = substr($tableConfig['namespace'], 0, strpos($tableConfig['namespace'], '/'));
  300. return array_merge($tableConfig, [
  301. '_sourceNamespace' => $sourceNs,
  302. ]);
  303. }, $userObject->getItems());
  304. DBG::simpleLog('auth', "UserAcl::fetchPerms fetched " . count($userAccessForTables) . " tables");
  305. DBG::_('DBG_SCH', '1', "userAccessForTables", $userAccessForTables, __CLASS__, __FUNCTION__, __LINE__ );
  306. foreach ($userAccessForTables as $tableConfig) {
  307. unset($tableConfig['ID']);
  308. $idTable = $tableConfig['ID_TABLE'];
  309. if (!array_key_exists($idTable, $foundTbls)) {
  310. $foundTbls[$idTable] = $tableConfig;
  311. }
  312. }
  313. $this->_cache_save('foundTables', $foundTbls);
  314. // use cache for UserUrlAction turned OFF @see getUrls()
  315. // $userAccessForUrls = $userUrlAction->getItems();
  316. // DBG::logAuth($userAccessForUrls, "_fetchPerms \$userAccessForUrls");
  317. // DBG::_('DBG_SCH', '2', "userAccessForUrls", $userAccessForUrls, __CLASS__, __FUNCTION__, __LINE__ );
  318. // $foundUrls = array();
  319. // foreach ($userAccessForUrls as $vUrlConfig) {
  320. // $foundUrls[$vUrlConfig['ID_URL']] = $vUrlConfig['opis'];
  321. // }
  322. // $this->_cache_save('foundUrls', $foundUrls);
  323. }
  324. public function setFilterIdProces($procesID) {
  325. $this->_cache_save('permsByProcesID', $procesID);
  326. }
  327. public function getPermsForTable($idTable) { // @returns [ permInfo group by ID_CELL ]; permInfo = [ ID_CELL, CELL_NAME, SORT_PRIO, PERM_R, PERM_W, PERM_... ]
  328. $sqlIdProcesListSql = $this->getUsedUserProcesIdsSql();
  329. if (!$sqlIdProcesListSql) return [];
  330. $tableCellToProcesSql = "
  331. select z.`ID` as `ID_CELL`
  332. , z.`DESC` as `CELL_NAME`
  333. , z.`DESC_PL` as `CELL_LABEL`
  334. , z.`OPIS` as `CELL_DESC`
  335. , z.`SORT_PRIO` as `SORT_PRIO`
  336. , zp.`ID` as `ID_TABLE`
  337. -- , zp.`DESC` as `TABLE_NAME`
  338. -- , wsk.`ID_PROCES` as `ID_PROCES`
  339. , sum(IF(przyp.`FORM_TREAT` & 2, 1, 0)) as PERM_R
  340. , sum(IF(przyp.`FORM_TREAT` & 4, 1, 0)) as PERM_W
  341. , sum(IF(przyp.`FORM_TREAT` & 8, 1, 0)) as PERM_X
  342. , sum(IF(przyp.`FORM_TREAT` & 16, 1, 0)) as PERM_C
  343. , sum(IF(przyp.`FORM_TREAT` & 32, 1, 0)) as PERM_S
  344. , sum(IF(przyp.`FORM_TREAT` & 64, 1, 0)) as PERM_O
  345. , sum(IF(przyp.`FORM_TREAT` & 128, 1, 0)) as PERM_V
  346. , sum(IF(przyp.`FORM_TREAT` & 256, 1, 0)) as PERM_E
  347. from `CRM_LISTA_ZASOBOW` z
  348. join `CRM_LISTA_ZASOBOW` zp on(zp.`ID`=z.`PARENT_ID` and zp.`TYPE`='TABELA' and zp.`A_STATUS` in('WAITING','NORMAL'))
  349. join `CRM_WSKAZNIK` wsk on(wsk.`ID_ZASOB`=z.`ID` and wsk.`A_STATUS` in('WAITING','NORMAL'))
  350. join `CRM_PROCES` p on(p.`ID`=wsk.`ID_PROCES` and p.`A_STATUS` in('WAITING','NORMAL'))
  351. join `CRM_PRZYPADEK` as przyp on (przyp.`ID`=wsk.`ID_PRZYPADEK`)
  352. where z.`TYPE`='KOMORKA'
  353. and z.`A_STATUS` in('WAITING','NORMAL')
  354. and zp.`ID`='{$idTable}'
  355. and wsk.`ID_PROCES` in({$sqlIdProcesListSql})
  356. -- group by z.`ID`, wsk.`ID_PROCES`
  357. group by z.`ID`
  358. order by z.`SORT_PRIO`
  359. ";
  360. $userPermsForTable = array();
  361. foreach (DB::getPDO()->fetchAll($tableCellToProcesSql) as $h) {
  362. $idCell = $h['ID_CELL'];
  363. $userPermsForTable[$idCell] = $h;
  364. }
  365. return $userPermsForTable;
  366. }
  367. public function getUsedUserGroupIds() {
  368. $idUserGroupList = User::getGroupsIds();// TODO:? $this->_user_id
  369. // TODO: acl filtr by group ids
  370. return $idUserGroupList;
  371. }
  372. public function getUsedUserProcesIdsSql() {
  373. $filterIdProces = $this->getFilterIdProces();
  374. if ($filterIdProces > 0) {
  375. return "
  376. select i.`ID_PROCES`
  377. from `CRM_PROCES_idx` i
  378. where i.`idx_MAIN_PROCES_INIT_ID`='{$filterIdProces}'
  379. ";
  380. }
  381. $idUserGroupList = $this->getUsedUserGroupIds();
  382. if (empty($idUserGroupList)) return null;
  383. $sqlIdUserGroupList = implode(",", $idUserGroupList);
  384. return "
  385. select gi.`ID_PROCES`
  386. from `CRM_PROCES_idx_GROUP_to_PROCES` gi
  387. where gi.`ID_GROUP` in({$sqlIdUserGroupList})
  388. ";
  389. }
  390. public function getProcesMaxUpdateDate($idProcesInit) {
  391. return DB::getPDO()->fetchValue("
  392. select max(p.`A_RECORD_UPDATE_DATE`) as max_update_date
  393. from `CRM_PROCES` as p
  394. where p.`ID` in(
  395. select i.`ID_PROCES`
  396. from `CRM_PROCES_idx` i
  397. where i.`idx_PROCES_INIT_ID`='{$idProcesInit}'
  398. )
  399. ");
  400. }
  401. /**
  402. * Ids List of Proces Init for user (skip filters)
  403. */
  404. public function getUserProcesInitIds() {
  405. $procesInitList = $this->getUserProcesInitList();
  406. return array_keys($procesInitList);
  407. }
  408. /**
  409. * List of Proces Init for user (skip filters)
  410. */
  411. public function getUserProcesInitList() {// TODO: read from CRM_PROCES_idx_GROUP_to_INIT_VIEW?
  412. $idUserGroupList = $this->fetchGroups();
  413. if (empty($idUserGroupList)) return [];
  414. $sqlIdUserGroupList = implode(",", array_keys($idUserGroupList));
  415. $sqlIdProcesListSql = "
  416. select gi.`ID_PROCES`
  417. from `CRM_PROCES_idx_GROUP_to_PROCES` gi
  418. where gi.`ID_GROUP` in({$sqlIdUserGroupList})
  419. ";
  420. $sqlFetchUserProcesInitList = "
  421. select p.`ID`, p.`DESC`
  422. from `CRM_PROCES_idx` i
  423. join `CRM_PROCES` p on(p.`ID`=i.`idx_PROCES_INIT_ID`)
  424. where i.`ID_PROCES` in({$sqlIdProcesListSql})
  425. group by p.`ID`
  426. order by p.`SORT_PRIO`
  427. ";
  428. return array_map(function ($row) {
  429. return $row['DESC'];
  430. }, DB::getPDO()->fetchAllByKey($sqlFetchUserProcesInitList, 'ID'));
  431. }
  432. /**
  433. * Ids List of Proces Init for user (use filters)
  434. */
  435. function getUsedUserProcesInitIds() {
  436. $usedProcesInitList = $this->getUsedUserProcesInitList();
  437. return array_keys($usedProcesInitList);
  438. }
  439. /**
  440. * List of Proces Init for user (use filters)
  441. */
  442. function getUsedUserProcesInitList() {
  443. $filterIdProces = $this->getFilterIdProces();
  444. if ($filterIdProces > 0) return $filterIdProces;
  445. $sqlIdProcesListSql = $this->getUsedUserProcesIdsSql();
  446. if (!$sqlIdProcesListSql) return [];
  447. $listItems = DB::getPDO()->fetchAll("
  448. select p.`ID`, p.`DESC`
  449. from `CRM_PROCES` p
  450. where p.`ID` in ( {$sqlIdProcesListSql} )
  451. and p.`TYPE` = 'PROCES_INIT'
  452. order by p.`SORT_PRIO`
  453. ");
  454. $usedProcesInitList = array();
  455. foreach ($listItems as $item) {
  456. $usedProcesInitList[$item['ID']] = $item['DESC'];
  457. }
  458. return $usedProcesInitList;
  459. }
  460. /**
  461. * Ids List of Proces Init for given tabel (skip filters)
  462. */
  463. public function getTableProcesInitIds($idTable) {
  464. $procesInitList = $this->getTableProcesInitList($idTable);
  465. return array_keys($procesInitList);
  466. }
  467. /**
  468. * List of Proces Init for given table (skip filters)
  469. */
  470. public function getTableProcesInitList($idTable) {
  471. $tableProcesInitList = ACL::getTableProcesInitList($idTable);
  472. if (!empty($tableProcesInitList)) {
  473. $filteredTableProcesInitList = array();
  474. $procesIds = array_keys($tableProcesInitList);
  475. if (empty($procesIds)) {
  476. DBG::log("BUG empty \$procesIds for table {$idTable}");
  477. return [];
  478. }
  479. $sqlProcesIds = implode(",", $procesIds);
  480. $userLogin = User::getLogin();
  481. $groupIds = User::getGroupsIds();
  482. if (empty($procesIds)) {
  483. DBG::log("BUG empty User Group Ids");
  484. return [];
  485. }
  486. $sqlGroupIds = implode(",", $groupIds);
  487. // $sql = " -- slow
  488. // select uiv.`ID_PROCES_INIT`, uiv.`DESC`
  489. // from `CRM_PROCES_idx_USER_to_INIT_VIEW` uiv
  490. // where uiv.`ADM_ACCOUNT`='{$userLogin}'
  491. // and uiv.`ID_PROCES_INIT` in({$sqlProcesIds})
  492. // group by uiv.`ID_PROCES_INIT`
  493. // ";
  494. $sql = "
  495. select ugiv.`ID_PROCES_INIT`, ugiv.`DESC`
  496. from `CRM_PROCES_idx_GROUP_to_INIT_VIEW` ugiv
  497. where ugiv.`ID_GROUP` in({$sqlGroupIds})
  498. and ugiv.`ID_PROCES_INIT` in({$sqlProcesIds})
  499. ";
  500. foreach (DB::getPDO()->fetchAll($sql) as $row) {
  501. $filteredTableProcesInitList[$row['ID_PROCES_INIT']] = $row['DESC'];
  502. }
  503. $tableProcesInitList = $filteredTableProcesInitList;
  504. DBG::log($filteredTableProcesInitList, 'array', "tableProcesInitList({$idTable}):filteredTableProcesInitList");
  505. }
  506. return $tableProcesInitList;
  507. }
  508. function canExecuteProcesInit($idProcesInit) {
  509. $isAllowed = false;
  510. $idProcesInit = (int)$idProcesInit;
  511. if (!$idProcesInit) return false;
  512. $idUserGroupList = $this->fetchGroups();
  513. $sqlIdUserGroupList = implode(",", array_keys($idUserGroupList));
  514. $isAlowed = DB::getPDO()->fetchValue("
  515. select count(*) as cnt
  516. from `CRM_PROCES_idx_GROUP_to_PROCES` gi
  517. join `CRM_PROCES` p on ( p.`ID` = gi.`ID_PROCES` and p.`TYPE` = 'PROCES_INIT' )
  518. where gi.`ID_GROUP` in ( {$sqlIdUserGroupList} )
  519. and gi.`ID_PROCES` = :id_proces_init
  520. ", [
  521. ':id_proces_init' => $idProcesInit,
  522. ]);
  523. return ($isAlowed > 0);
  524. }
  525. function canViewProces($idProcesInit) {
  526. $isAllowed = false;
  527. $idProcesInit = (int)$idProcesInit;
  528. if (!$idProcesInit) return false;
  529. $idUserGroupList = $this->fetchGroups();
  530. $sqlIdUserGroupList = implode(",", array_keys($idUserGroupList));
  531. $isAllowed = DB::getPDO()->fetchValue("
  532. select count(*) as cnt
  533. from `CRM_PROCES_idx_GROUP_to_PROCES_PERM` gi
  534. join `CRM_PROCES` p on ( p.`ID` = gi.`ID_PROCES` )
  535. where gi.`ID_GROUP` in ( {$sqlIdUserGroupList} )
  536. and gi.`ID_PROCES` = :id_proces_init
  537. ", [
  538. ':id_proces_init' => $idProcesInit,
  539. ]);
  540. // -- and gi.`HAS_PERM_R` = 1 -- TODO allow only with defined perm 'R'
  541. return ($isAllowed > 0);
  542. }
  543. }