UserAcl.php 19 KB

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