UserAcl.php 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599
  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) {
  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 && 'File' == $objName) {
  143. Lib::loadClass('FileStorageAcl');
  144. return new FileStorageAcl();
  145. } else if ('objects' == $sourceName && 'TestPerms' == $objName) {
  146. // TODO: ObjectAcl::getAcl($objName);
  147. Lib::loadClass('TestPermsStorageAcl');
  148. return new TestPermsStorageAcl();
  149. } else if ('objects' == $sourceName && 'Korespondencja' == $objName) {
  150. // TODO: ObjectAcl::getAcl($objName);
  151. Lib::loadClass('KorespondencjaStorageAcl');
  152. return new KorespondencjaStorageAcl();
  153. } else throw new HttpException("Not Implemented", 501);
  154. return false;
  155. }
  156. public function getTablesAcl() {// TODO: read from `CRM_PROCES_idx_TABLE_TO_USER_VIEW`
  157. $tbls = array();
  158. $tblIds = $this->_cache_read('foundTables');
  159. foreach ($tblIds as $vTableID) {
  160. $tbls[$vTableID] = TableAcl::getInstance($vTableID);
  161. }
  162. return $tbls;
  163. }
  164. public function hasTableAcl($tableID) {// TODO: read from `CRM_PROCES_idx_TABLE_TO_USER_VIEW`
  165. $tbls = $this->_cache_read('foundTables');
  166. return (is_array($tbls) && in_array($tableID, $tbls));
  167. }
  168. public function getTableAcl($tableID) {
  169. $tblAcl = TableAcl::getInstance($tableID);
  170. if (!$tblAcl) throw new Exception("Brak tabeli nr [{$tableID}]!");
  171. $tblAcl->init();
  172. return $tblAcl;
  173. }
  174. /**
  175. * Check if perms are only for one proces.
  176. * @returns int or false
  177. */
  178. public function getPermsFiltrProcesId() {// TODO: RMME mved to getFilterIdProces
  179. return $this->getFilterIdProces();
  180. }
  181. public function getFilterIdProces() {
  182. $procesID = $this->_cache_read('permsByProcesID');
  183. return ($procesID > 0)? $procesID : false;
  184. }
  185. public function fetchAllPerms($force = false) {
  186. $this->_fetchPerms('All', $force);
  187. }
  188. public function fetchProcesPerms($procesID, $force = false) {
  189. $this->_fetchPerms($procesID, $force);
  190. }
  191. /**
  192. * @param $type - 'All', $procesID
  193. */
  194. private function _fetchPerms($type, $force = false) {
  195. $db = DB::getDB();
  196. $procesID = 0;// if 0 - All, alse perms by procesID
  197. $foundUrls = array();
  198. $foundTbls = array();
  199. if ($force) {
  200. $this->_cache_clear();
  201. }
  202. $schemaReader = new SchemaReader();
  203. if ($type == 'All') {
  204. $schemaReader->getAll();
  205. } else if (is_numeric($type) && $type > 0) {
  206. $procesID = (int)$type;
  207. }
  208. {// fetch from schema files in SE/schema/process/*.ini.php
  209. if ($schemaReader->hasProcessConfigs()) {
  210. foreach ($schemaReader->getProcessConfigs() as $process) {
  211. DBG::_('DBG_SCH', '1', "process", $process, __CLASS__, __FUNCTION__, __LINE__ );
  212. if ($process->hasAccess()) {
  213. $tables = $process->getTables();
  214. DBG::_('DBG_SCH', '1', "tables", $tables, __CLASS__, __FUNCTION__, __LINE__ );
  215. foreach ($tables as $vTable) {
  216. $tblUri = $vTable->getUri();
  217. $zasobTblInfo = ProcesHelper::getZasobTableInfoByUri($tblUri);
  218. DBG::_('DBG_SCH', '1', "table(" . $vTable->getLabel() . ")", $zasobTblInfo, __CLASS__, __FUNCTION__, __LINE__ );
  219. if ($zasobTblInfo) {
  220. $idTable = $zasobTblInfo->ID;
  221. if (!array_key_exists($idTable, $foundTbls)) {
  222. $tableConfig = array();
  223. $tableConfig['ID_TABLE'] = $idTable;
  224. $tableConfig['db'] = $zasobTblInfo->P__ID;
  225. $tableConfig['name'] = $zasobTblInfo->DESC;
  226. $tableConfig['label'] = $zasobTblInfo->DESC_PL;
  227. $tableConfig['opis'] = $zasobTblInfo->OPIS;
  228. $foundTbls[$idTable] = $tableConfig;
  229. }
  230. $tableAcl = TableAcl::buildInstance($idTable, $foundTbls[$idTable]);
  231. $fieldsConfig = array();
  232. $fldsInfo = ProcesHelper::getZasobTableFieldsInfo($idTable);
  233. foreach ($vTable->getFields() as $field) {
  234. $fldInfo = V::get($field->getName(), null, $fldsInfo);
  235. if ($fldInfo) {
  236. if (!array_key_exists($fldInfo->ID, $fieldsConfig)) {//if (!$tableAcl->hasField($fldInfo->ID)) {
  237. $fieldsConfig[$fldInfo->ID] = array();
  238. $fieldsConfig[$fldInfo->ID]['ID_CELL'] = $fldInfo->ID;
  239. $fieldsConfig[$fldInfo->ID]['CELL_NAME'] = $fldInfo->DESC;
  240. $fieldsConfig[$fldInfo->ID]['CELL_DESC'] = $fldInfo->OPIS;
  241. $fieldsConfig[$fldInfo->ID]['SORT_PRIO'] = $fldInfo->SORT_PRIO;
  242. $fieldsConfig[$fldInfo->ID]['CELL_LABEL'] = $fldInfo->DESC_PL;
  243. $fieldsConfig[$fldInfo->ID]['FORM_TREAT'] = '';
  244. //$tableAcl->addField($fldInfo->ID, $fldInfo->DESC, $fldInfo->OPIS, $fldInfo->SORT_PRIO, $fldInfo->DESC_PL);
  245. }
  246. // TODO: $field->getPerms() -> PERM_R, PERM_W, ... etc.?
  247. $fieldsConfig[$fldInfo->ID]['FORM_TREAT'] .= $field->getPerms();//$tableAcl->setFieldPerms($fldInfo->ID, $field->getPerms());
  248. }
  249. }
  250. $tableAcl->initFieldsFromConfig($fieldsConfig);
  251. DBG::_('DBG_SCH', '1', "fieldsConfig({$idTable})", $fieldsConfig, __CLASS__, __FUNCTION__, __LINE__);
  252. $tableAcl->save();
  253. DBG::_('DBG_SCH', '1', "tableAcl({$idTable})", $tableAcl, __CLASS__, __FUNCTION__, __LINE__);
  254. }
  255. }
  256. }
  257. }
  258. } else {
  259. DBG::_('DBG_SCH', '1', "NO \$schemaReader->hasProcessConfigs()", null, __CLASS__, __FUNCTION__, __LINE__);
  260. }
  261. DBG::_('DBG_SCH', '1', "foundTbls", $foundTbls, __CLASS__, __FUNCTION__, __LINE__);
  262. }// fetch from schema files
  263. $this->setFilterIdProces($procesID);//$this->_cache_save('permsByProcesID', $procesID);
  264. $sqlIdProcesListSql = $this->getUsedUserProcesIdsSql();
  265. $userAccessForTables = array();
  266. $sql = <<<SQL
  267. select tpvg.`ID_TABLE`
  268. , tpvg.`ID_DATABASE` as `db`
  269. , tpvg.`TABLE_NAME` as `name`
  270. , tpvg.`TABLE_LABEL` as `label`
  271. , tpvg.`TABLE_DESCRIPTION` as `opis`
  272. from `CRM_PROCES_idx_TABLE_TO_PROCES_GROUPED_VIEW` as tpvg
  273. where tpvg.`ID_PROCES` in({$sqlIdProcesListSql})
  274. group by tpvg.`ID_TABLE`
  275. SQL;
  276. //echo'<pre>$userAccessForTables - $sql ';print_r($sql);echo'</pre>';
  277. $db = DB::getDB();
  278. $res = $db->query($sql);
  279. while ($h = $db->fetch_assoc($res)) {
  280. $userAccessForTables[$h['ID_TABLE']] = $h;
  281. }
  282. DBG::_('DBG_SCH', '1', "userAccessForTables", $userAccessForTables, __CLASS__, __FUNCTION__, __LINE__ );
  283. foreach ($userAccessForTables as $idTable => $tableConfig) {
  284. if (!array_key_exists($idTable, $foundTbls)) {
  285. $foundTbls[$idTable] = $tableConfig;
  286. }
  287. }
  288. $userAccessForUrls = array();
  289. $sql = <<<SQL
  290. select upvg.`ID_URL`
  291. , upvg.`URL_LINK` as `link`
  292. , upvg.`URL_LABEL` as `label`
  293. , upvg.`URL_DESC` as `opis`
  294. from `CRM_PROCES_idx_URL_TO_PROCES_VIEW` as upvg
  295. where upvg.`ID_PROCES` in({$sqlIdProcesListSql})
  296. group by upvg.`ID_URL`
  297. SQL;
  298. //echo'<pre>$userAccessForUrls - $sql ';print_r($sql);echo'</pre>';
  299. $db = DB::getDB();
  300. $res = $db->query($sql);
  301. while ($h = $db->fetch_assoc($res)) {
  302. $userAccessForUrls[$h['ID_URL']] = $h;
  303. }
  304. //echo'<pre>$userAccessForUrls ';print_r($userAccessForUrls);echo'</pre>';
  305. DBG::_('DBG_SCH', '2', "userAccessForUrls", $userAccessForUrls, __CLASS__, __FUNCTION__, __LINE__ );
  306. foreach ($userAccessForUrls as $idUrl => $vUrlConfig) {
  307. $foundUrls[$idUrl] = $vUrlConfig['opis'];
  308. }
  309. $this->_cache_save('foundUrls', $foundUrls);
  310. $this->_cache_save('foundTables', $foundTbls);
  311. }
  312. public function setFilterIdProces($procesID) {
  313. $this->_cache_save('permsByProcesID', $procesID);
  314. }
  315. public function getPermsForTable($idTable) {
  316. $sqlIdProcesListSql = $this->getUsedUserProcesIdsSql();
  317. $tableCellToProcesSql = <<<SQL
  318. select z.`ID` as `ID_CELL`
  319. , z.`DESC` as `CELL_NAME`
  320. , z.`DESC_PL` as `CELL_LABEL`
  321. , z.`OPIS` as `CELL_DESC`
  322. , z.`SORT_PRIO` as `SORT_PRIO`
  323. , zp.`ID` as `ID_TABLE`
  324. -- , zp.`DESC` as `TABLE_NAME`
  325. -- , wsk.`ID_PROCES` as `ID_PROCES`
  326. , sum(IF(przyp.`FORM_TREAT` & 2, 1, 0)) as PERM_R
  327. , sum(IF(przyp.`FORM_TREAT` & 4, 1, 0)) as PERM_W
  328. , sum(IF(przyp.`FORM_TREAT` & 8, 1, 0)) as PERM_X
  329. , sum(IF(przyp.`FORM_TREAT` & 16, 1, 0)) as PERM_C
  330. , sum(IF(przyp.`FORM_TREAT` & 32, 1, 0)) as PERM_S
  331. , sum(IF(przyp.`FORM_TREAT` & 64, 1, 0)) as PERM_O
  332. , sum(IF(przyp.`FORM_TREAT` & 128, 1, 0)) as PERM_V
  333. , sum(IF(przyp.`FORM_TREAT` & 256, 1, 0)) as PERM_E
  334. from `CRM_LISTA_ZASOBOW` z
  335. join `CRM_LISTA_ZASOBOW` zp on(zp.`ID`=z.`PARENT_ID` and zp.`TYPE`='TABELA' and zp.`A_STATUS` in('WAITING','NORMAL'))
  336. join `CRM_WSKAZNIK` wsk on(wsk.`ID_ZASOB`=z.`ID` and wsk.`A_STATUS` in('WAITING','NORMAL'))
  337. join `CRM_PROCES` p on(p.`ID`=wsk.`ID_PROCES` and p.`A_STATUS` in('WAITING','NORMAL'))
  338. join `CRM_PRZYPADEK` as przyp on (przyp.`ID`=wsk.`ID_PRZYPADEK`)
  339. where z.`TYPE`='KOMORKA'
  340. and z.`A_STATUS` in('WAITING','NORMAL')
  341. and zp.`ID`='{$idTable}'
  342. and wsk.`ID_PROCES` in({$sqlIdProcesListSql})
  343. -- group by z.`ID`, wsk.`ID_PROCES`
  344. group by z.`ID`
  345. order by z.`SORT_PRIO`
  346. SQL;
  347. //echo'<pre>UserAcl::getPermsForTable('.$idTable.')::$tableCellToProcesSql ';print_r($tableCellToProcesSql);echo'</pre>';
  348. $userPermsForTable = array();
  349. $db = DB::getDB();
  350. $res = $db->query($tableCellToProcesSql);
  351. while ($h = $db->fetch_assoc($res)) {
  352. $idCell = $h['ID_CELL'];
  353. $userPermsForTable[$idCell] = $h;
  354. }
  355. return $userPermsForTable;
  356. }
  357. public function getUsedUserGroupIds() {
  358. $idUserGroupList = User::getGroupsIds();
  359. // TODO: acl filtr by group ids
  360. return $idUserGroupList;
  361. }
  362. public function getUsedUserProcesIdsSql() {
  363. $filterIdProces = $this->getFilterIdProces();
  364. if ($filterIdProces > 0) {
  365. return <<<SQL
  366. select i.`ID_PROCES`
  367. from `CRM_PROCES_idx` i
  368. where i.`idx_MAIN_PROCES_INIT_ID`='{$filterIdProces}'
  369. SQL;
  370. }
  371. $idUserGroupList = $this->getUsedUserGroupIds();
  372. $sqlIdUserGroupList = implode(",", $idUserGroupList);
  373. return <<<SQL
  374. select gi.`ID_PROCES`
  375. from `CRM_PROCES_idx_GROUP_to_PROCES` gi
  376. where gi.`ID_GROUP` in({$sqlIdUserGroupList})
  377. SQL;
  378. }
  379. public function getProcesMaxUpdateDate($idProcesInit) {
  380. $maxUpdateDate = null;
  381. $db = DB::getDB();
  382. $sql = <<<SQL
  383. select max(p.`A_RECORD_UPDATE_DATE`) as max_update_date
  384. from `CRM_PROCES` as p
  385. where p.`ID` in(
  386. select i.`ID_PROCES`
  387. from `CRM_PROCES_idx` i
  388. where i.`idx_PROCES_INIT_ID`='{$idProcesInit}'
  389. )
  390. SQL;
  391. $res = $db->query($sql);
  392. if ($r = $db->fetch($res)) {
  393. $maxUpdateDate = $r->max_update_date;
  394. }
  395. return $maxUpdateDate;
  396. }
  397. /**
  398. * Ids List of Proces Init for user (skip filters)
  399. */
  400. public function getUserProcesInitIds() {
  401. $procesInitList = $this->getUserProcesInitList();
  402. return array_keys($procesInitList);
  403. }
  404. /**
  405. * List of Proces Init for user (skip filters)
  406. */
  407. public function getUserProcesInitList() {
  408. $userProcesInitList = array();
  409. $idUserGroupList = $this->fetchGroups();
  410. $sqlIdUserGroupList = implode(",", array_keys($idUserGroupList));
  411. $sqlIdProcesListSql = <<<SQL
  412. select gi.`ID_PROCES`
  413. from `CRM_PROCES_idx_GROUP_to_PROCES` gi
  414. where gi.`ID_GROUP` in({$sqlIdUserGroupList})
  415. SQL;
  416. $fetchUserProcesInitListSql = <<<SQL
  417. select p.`ID`, p.`DESC`
  418. from `CRM_PROCES_idx` i
  419. join `CRM_PROCES` p on(p.`ID`=i.`idx_PROCES_INIT_ID`)
  420. where i.`ID_PROCES` in({$sqlIdProcesListSql})
  421. group by p.`ID`
  422. order by p.`SORT_PRIO`
  423. SQL;
  424. $db = DB::getDB();
  425. $res = $db->query($fetchUserProcesInitListSql);
  426. while ($r = $db->fetch($res)) {
  427. $userProcesInitList[$r->ID] = $r->DESC;
  428. }
  429. return $userProcesInitList;
  430. }
  431. /**
  432. * Ids List of Proces Init for user (use filters)
  433. */
  434. public function getUsedUserProcesInitIds() {
  435. $usedProcesInitList = $this->getUsedUserProcesInitList();
  436. return array_keys($usedProcesInitList);
  437. }
  438. /**
  439. * List of Proces Init for user (use filters)
  440. */
  441. public function getUsedUserProcesInitList() {
  442. $filterIdProces = $this->getFilterIdProces();
  443. if ($filterIdProces > 0) {
  444. return $filterIdProces;
  445. }
  446. $sqlIdProcesListSql = $this->getUsedUserProcesIdsSql();
  447. $fetchUsedProcesInitListSql = <<<SQL
  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. SQL;
  454. $usedProcesInitList = array();
  455. $db = DB::getDB();
  456. $res = $db->query($fetchUsedProcesInitListSql);
  457. while ($r = $db->fetch($res)) {
  458. $usedProcesInitList[$r->ID] = $r->DESC;
  459. }
  460. return $usedProcesInitList;
  461. }
  462. /**
  463. * Ids List of Proces Init for given tabel (skip filters)
  464. */
  465. public function getTableProcesInitIds($idTable) {
  466. $procesInitList = $this->getTableProcesInitList($idTable);
  467. return array_keys($procesInitList);
  468. }
  469. /**
  470. * List of Proces Init for given table (skip filters)
  471. */
  472. public function getTableProcesInitList($idTable) {
  473. $tableProcesInitList = ACL::getTableProcesInitList($idTable);
  474. if (!empty($tableProcesInitList)) {
  475. $filteredTableProcesInitList = array();
  476. DBG::_('DBG_MAP', '1', "tableProcesInitList({$idTable})", $tableProcesInitList, __CLASS__, __FUNCTION__, __LINE__);
  477. $procesIds = array_keys($tableProcesInitList);
  478. $sqlProcesIds = implode(",", $procesIds);
  479. $userLogin = User::getLogin();
  480. $sql = "select uiv.`ID_PROCES_INIT`, uiv.`DESC`
  481. from `CRM_PROCES_idx_USER_to_INIT_VIEW` uiv
  482. where uiv.`ADM_ACCOUNT`='{$userLogin}'
  483. and uiv.`ID_PROCES_INIT` in({$sqlProcesIds})
  484. group by uiv.`ID_PROCES_INIT`
  485. ";
  486. DBG::_('DBG_MAP', '1', "tableProcesInitList({$idTable}):sql", $sql, __CLASS__, __FUNCTION__, __LINE__);
  487. $db = DB::getDB();
  488. $res = $db->query($sql);
  489. while ($r = $db->fetch($res)) {
  490. $filteredTableProcesInitList[$r->ID_PROCES_INIT] = $r->DESC;
  491. }
  492. $tableProcesInitList = $filteredTableProcesInitList;
  493. DBG::_('DBG_MAP', '1', "tableProcesInitList({$idTable}):filteredTableProcesInitList", $filteredTableProcesInitList, __CLASS__, __FUNCTION__, __LINE__);
  494. }
  495. return $tableProcesInitList;
  496. }
  497. public function canExecuteProcesInit($idProcesInit) {
  498. $isAllowed = false;
  499. $idProcesInit = (int)$idProcesInit;
  500. if (!$idProcesInit) return false;
  501. $idUserGroupList = $this->fetchGroups();
  502. $sqlIdUserGroupList = implode(",", array_keys($idUserGroupList));
  503. $checkProcesAccessSql = <<<SQL
  504. select count(*) as cnt
  505. from `CRM_PROCES_idx_GROUP_to_PROCES` gi
  506. join `CRM_PROCES` p on(p.`ID`=gi.`ID_PROCES` and p.`TYPE`='PROCES_INIT')
  507. where gi.`ID_GROUP` in({$sqlIdUserGroupList})
  508. and gi.`ID_PROCES`='{$idProcesInit}'
  509. SQL;
  510. $db = DB::getDB();
  511. $res = $db->query($checkProcesAccessSql);
  512. if ($r = $db->fetch($res)) {
  513. if ($r->cnt > 0) {
  514. $isAllowed = true;
  515. }
  516. }
  517. return $isAllowed;
  518. }
  519. public function canViewProces($idProcesInit) {
  520. $isAllowed = false;
  521. $idProcesInit = (int)$idProcesInit;
  522. if (!$idProcesInit) return false;
  523. $idUserGroupList = $this->fetchGroups();
  524. $sqlIdUserGroupList = implode(",", array_keys($idUserGroupList));
  525. $checkProcesAccessSql = <<<SQL
  526. select count(*) as cnt
  527. from `CRM_PROCES_idx_GROUP_to_PROCES_PERM` gi
  528. join `CRM_PROCES` p on(p.`ID`=gi.`ID_PROCES`)
  529. where gi.`ID_GROUP` in({$sqlIdUserGroupList})
  530. and gi.`ID_PROCES`='{$idProcesInit}'
  531. -- and gi.`HAS_PERM_R`=1 -- TODO: allow only with defined perm 'R'
  532. SQL;
  533. $db = DB::getDB();
  534. $res = $db->query($checkProcesAccessSql);
  535. if ($r = $db->fetch($res)) {
  536. if ($r->cnt > 0) {
  537. $isAllowed = true;
  538. }
  539. }
  540. return $isAllowed;
  541. }
  542. }