ACL.php 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527
  1. <?php
  2. Lib::loadClass('Core_AclHelper');
  3. Lib::loadClass('AntAclBase');
  4. Lib::loadClass('RefConfig');
  5. Lib::loadClass('InstanceConfig');
  6. class ACL {
  7. /**
  8. * Ids List of Proces Init for given tabel (skip filters)
  9. */
  10. public static function getTableProcesInitIds($idTable) {
  11. $procesInitList = self::getTableProcesInitList($idTable);
  12. return array_keys($procesInitList);
  13. }
  14. /**
  15. * List of Proces Init for given table (skip filters)
  16. */
  17. public static function getTableProcesInitList($idTable) {
  18. $tableProcesInitList = array();
  19. $sqlIdProcesListSql = "
  20. select tpv.`ID_PROCES`
  21. from `CRM_PROCES_idx_TABLE_TO_PROCES_VIEW` tpv
  22. where tpv.`ID_TABLE`='{$idTable}'
  23. ";
  24. $fetchTableProcesInitListSql = "
  25. -- time ~0.07 -- no goto and return
  26. select p.`ID`, p.`DESC`
  27. from `CRM_PROCES` p
  28. where p.`ID` in(
  29. select i.`idx_PROCES_INIT_ID`
  30. from `CRM_PROCES_idx` i
  31. where i.`ID_PROCES` in({$sqlIdProcesListSql})
  32. )
  33. and p.`TYPE`='PROCES_INIT'
  34. order by p.`SORT_PRIO`
  35. ";
  36. /*
  37. SELECT p.`ID` , p.`DESC`
  38. FROM `CRM_PROCES` p
  39. WHERE p.`ID`
  40. IN (
  41. SELECT i.`idx_PROCES_INIT_ID`
  42. FROM `CRM_PROCES_idx` i
  43. WHERE i.`ID_PROCES`
  44. IN (
  45. SELECT tpv.`ID_PROCES`
  46. FROM `CRM_PROCES_idx_TABLE_TO_PROCES_VIEW` tpv
  47. WHERE tpv.`ID_TABLE` = '13051'
  48. )
  49. )
  50. AND p.`TYPE` = 'PROCES_INIT'
  51. order by p.`SORT_PRIO`
  52. */
  53. $fetchTableProcesInitListSql = "
  54. -- time ~0.15s
  55. select p.`ID`, p.`DESC`
  56. from `CRM_PROCES` p
  57. where p.`ID` in(
  58. select i.`idx_PROCES_INIT_ID`
  59. from `CRM_PROCES_idx` i
  60. where i.`ID_PROCES` in({$sqlIdProcesListSql})
  61. union
  62. select ig.`idx_PROCES_INIT_ID`
  63. from `CRM_PROCES_idx` i
  64. join `CRM_PROCES_idx` ig on(ig.`ID_PROCES`=i.`idx_PROCES_WITH_GROUPS_ID`)
  65. where i.`ID_PROCES` in({$sqlIdProcesListSql})
  66. )
  67. and p.`TYPE`='PROCES_INIT'
  68. order by p.`SORT_PRIO`
  69. ";
  70. $fetchTableProcesInitListSql = "
  71. -- time ~0.14
  72. select p.`ID`, p.`DESC`
  73. from `CRM_PROCES` p
  74. where p.`ID` in(
  75. select i.`idx_PROCES_INIT_ID`
  76. from `CRM_PROCES_idx` i
  77. where i.`ID_PROCES` in({$sqlIdProcesListSql})
  78. or i.`ID_PROCES` in(
  79. select ig.`idx_PROCES_WITH_GROUPS_ID`
  80. from `CRM_PROCES_idx` ig
  81. where ig.`ID_PROCES` in({$sqlIdProcesListSql})
  82. )
  83. )
  84. and p.`TYPE`='PROCES_INIT'
  85. order by p.`SORT_PRIO`
  86. ";
  87. return array_map(function ($row) {
  88. return $row['DESC'];
  89. }, DB::getPDO()->fetchAllByKey($fetchTableProcesInitListSql, 'ID'));
  90. }
  91. public static function getProcesInitMapTreeOnlyIds($ids) {
  92. $mapTree = array();
  93. $map = self::getProcesInitMapOnlyIds($ids);
  94. foreach ($map as $row) {
  95. if ('PROCES_INIT' == $row['TYPE']) {
  96. $mapTree[ $row['ID_PROCES'] ] = array();
  97. }
  98. }
  99. foreach ($map as $row) {
  100. if ('GOTO_AND_RETURN' == $row['TYPE']) {
  101. $mapTree[ $row['idx_MAIN_PROCES_INIT_ID'] ][ $row['ID_PROCES'] ] = array();
  102. }
  103. }
  104. foreach ($map as $row) {
  105. if ('GOTO_AND_RETURN_LVL2' == $row['TYPE']) {
  106. $mapTree[ $row['idx_MAIN_PROCES_INIT_ID'] ][ $row['idx_GOTO_LVL2_INIT_ID'] ][ $row['ID_PROCES'] ] = true;
  107. }
  108. }
  109. return $mapTree;
  110. }
  111. public static function getProcesInitMapOnlyIds($ids) {
  112. $map = array();
  113. $sqlIds = V::filter($ids, array('V', 'filterPositiveInteger'));
  114. $sqlIds = implode(',', $sqlIds);
  115. if (empty($sqlIds)) return $map;
  116. $sql = "
  117. select i.`ID_PROCES`
  118. , i.`PARENT_ID`
  119. , i.`TYPE`
  120. , i.`idx_PROCES_INIT_ID`
  121. , i.`idx_MAIN_PROCES_INIT_ID`
  122. , i.`idx_PROCES_WITH_GROUPS_ID`
  123. , IF(i.`TYPE`='GOTO_AND_RETURN_LVL2'
  124. , (select ig.`idx_PROCES_INIT_ID`
  125. from `CRM_PROCES_idx` ig
  126. where ig.`ID_PROCES`=i.`PARENT_ID`
  127. limit 1)
  128. , 0
  129. ) as idx_GOTO_LVL2_INIT_ID
  130. from `CRM_PROCES_idx` i
  131. where i.`ID_PROCES` in({$sqlIds})
  132. and i.`idx_MAIN_PROCES_INIT_ID` in({$sqlIds})
  133. ";
  134. return DB::getPDO()->fetchAll($sql);
  135. }
  136. public static function canGroupViewProces($idGroup, $idProcesInit) {
  137. $isAllowed = false;
  138. $idProcesInit = (int)$idProcesInit;
  139. if (!$idProcesInit) return false;
  140. $checkProcesAccessSql = "
  141. select count(*) as cnt
  142. from `CRM_PROCES_idx_GROUP_to_INIT_VIEW` giv
  143. where giv.`ID_GROUP` = '{$idGroup}'
  144. and giv.`ID_PROCES_INIT` = '{$idProcesInit}'
  145. ";
  146. return ( DB::getPDO()->fetchValue($checkProcesAccessSql) > 0 );
  147. }
  148. public static function getStorageByNamespace($namespace, $forceTblAclInit = false) {
  149. Lib::loadClass('Core_AclHelper');
  150. Lib::loadClass('SchemaFactory');
  151. $ns = Core_AclHelper::parseNamespaceUrl($namespace);
  152. DBG::log($ns, 'array', "parseNamespaceUrl({$namespace})");
  153. if ('default_db' == $ns['prefix']) {
  154. $acl = User::getAcl()->getObjectAcl($ns['prefix'], $ns['name']);
  155. } else if ('objects' == $ns['prefix']) {
  156. $acl = SchemaFactory::loadDefaultObject($ns['name']);
  157. } else if ('default_objects' == $ns['prefix']) {
  158. $acl = SchemaFactory::loadDefaultObject($ns['name']);
  159. } else if ('default_db__x3A__' == substr($ns['prefix'], 0, 17)) {
  160. $rootTableName = strtolower(substr($ns['prefix'], 17));
  161. $acl = SchemaFactory::loadTableObject($rootTableName, $ns['name']);
  162. } else {
  163. throw new HttpException("Not Implemented", 501);
  164. }
  165. $acl->init($forceTblAclInit);
  166. return $acl;
  167. }
  168. public static function getBaseNamespace($namespace) {
  169. // map SystemObjects__x3A__{parent}/{name} to default_objects/{name}
  170. if ('SystemObjects/' === substr($namespace, 0, strlen('SystemObjects/'))) {
  171. $exNs = explode('/', $namespace);
  172. if (3 === count($exNs)) {
  173. return "default_objects/{$exNs[2]}";
  174. }
  175. }
  176. return $namespace;
  177. }
  178. public static function getAclByNamespace($namespace, $forceTblAclInit = false) {
  179. $namespace = ACL::getBaseNamespace($namespace);
  180. return Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit);
  181. }
  182. public static function getAclByTypeName($typeName, $forceTblAclInit = false) {
  183. return Core_AclHelper::getAclByNamespace(str_replace(':', '/', $typeName), $forceTblAclInit);
  184. }
  185. public static function getNamespaceFromId($idZasob) {
  186. $sqlIdZasob = DB::getPDO()->quote($idZasob, PDO::PARAM_INT);
  187. $zasob = DB::getPDO()->fetchFirst("
  188. select z.ID, z.DESC, z.PARENT_ID
  189. from CRM_LISTA_ZASOBOW z
  190. where z.ID = {$sqlIdZasob}
  191. and z.`TYPE` = 'TABELA'
  192. and z.A_STATUS != 'DELETED'
  193. ");
  194. if (!$zasob) throw new Exception("Object not exists '{$idZasob}'");
  195. if ($zasob['PARENT_ID'] != DB::getPDO()->getZasobId()) {
  196. throw new Exception("TODO: getNamespaceFromId for remote database");
  197. }
  198. return ('default_db/' === substr($zasob['DESC'], 0, strlen('default_db/')))
  199. ? $zasob['DESC']
  200. : "default_db/{$zasob['DESC']}"
  201. ;
  202. }
  203. public static function parseNamespaceUrl($namespace) {// returns assoc array: [ 'name', 'url', 'prefix', 'sourceName' ]
  204. return Core_AclHelper::parseNamespaceUrl($namespace);
  205. }
  206. static function getRefConfig($rootObjectNamespace, $childName) { // @return Type_RefConfig or throws Exception
  207. return RefConfig::getRefConfig($rootObjectNamespace, $childName);
  208. }
  209. public static function getRefTable($rootObjectNamespace, $childName) { // TODO: RMME - use getRefConfig
  210. static $cacheRefTables = array();
  211. DBG::log("DBG get ref table ({$rootObjectNamespace}, {$childName}) ...");
  212. $rootObjectNamespace = ACL::getBaseNamespace($rootObjectNamespace);
  213. $cacheKey = "{$rootObjectNamespace}/{$childName}";
  214. if (array_key_exists($cacheKey, $cacheRefTables)) return $cacheRefTables[$cacheKey];
  215. $rootAcl = self::getAclByNamespace($rootObjectNamespace);
  216. // $item = SchemaFactory::loadDefaultObject('SystemObject')->getItem($rootObjectNamespace, [ 'propertyName' => '*,field' ]);
  217. if (!($rootAcl instanceof AntAclBase)) throw new Exception("Ref allowed only for AntAcl objects");
  218. $refConfig = RefConfig::getRefConfig($rootObjectNamespace, $childName);
  219. $cacheRefTables[$cacheKey] = $refConfig->tableName;
  220. return $cacheRefTables[$cacheKey];
  221. }
  222. public static function getRefSource($rootObjectNamespace, $childName) { // CRM_REF_CONFIG
  223. $rootObjectNamespace = ACL::getBaseNamespace($rootObjectNamespace);
  224. $refConfig = RefConfig::fetch($rootObjectNamespace, $childName);
  225. return $refConfig->source;
  226. }
  227. public static function addRef($ns, $typeName, $pk, $remotePk) {
  228. $refTable = ACL::getRefTable($ns, $typeName); // TODO: RefConfig::fetch($ns, $typeName);
  229. DB::getPDO()->insert($refTable, [ 'PRIMARY_KEY' => $pk, 'REMOTE_PRIMARY_KEY' => $remotePk ]);
  230. }
  231. public static function addListRef($ns, $typeName, $pk, $listRemotePk) {
  232. $refTable = ACL::getRefTable($ns, $typeName); // TODO: RefConfig::fetch($ns, $typeName);
  233. foreach ($listRemotePk as $remotePk) {
  234. DB::getPDO()->insert($refTable, [ 'PRIMARY_KEY' => $pk, 'REMOTE_PRIMARY_KEY' => $remotePk ]);
  235. }
  236. }
  237. public static function removeRef($ns, $typeName, $pk, $remotePk) {
  238. $refTable = ACL::getRefTable($ns, $typeName); // TODO: RefConfig::fetch($ns, $typeName);
  239. DB::getPDO()->execSql(" delete from `{$refTable}` where PRIMARY_KEY = :pk and REMOTE_PRIMARY_KEY = :remote_pk ", [
  240. ':pk' => $pk,
  241. ':remote_pk' => $remotePk
  242. ]);
  243. }
  244. public static function removeListRef($ns, $typeName, $pk, $listRemotePk) {
  245. $refTable = ACL::getRefTable($ns, $typeName); // TODO: RefConfig::fetch($ns, $typeName);
  246. foreach ($listRemotePk as $remotePk) {
  247. DB::getPDO()->execSql(" delete from `{$refTable}` where PRIMARY_KEY = :pk and REMOTE_PRIMARY_KEY = :remote_pk ", [
  248. ':pk' => $pk,
  249. ':remote_pk' => $remotePk
  250. ]);
  251. }
  252. }
  253. public static function decodeAppInfoJson($appInfoJsonString) {
  254. $appInfo = @json_decode($appInfoJsonString, $assoc = true);
  255. if (null == $appInfo && 0 !== json_last_error()) throw new Exception("Parsing Json failed: " . json_last_error());
  256. return $appInfo;
  257. }
  258. public static function generateRefSelectSqlByFlatRelationCache($rootObjectNamespace, $childName) { // CRM_REF_CONFIG
  259. $appInfo = DB::getPDO()->fetchValue("
  260. select f.appInfo
  261. from `CRM_#CACHE_ACL_OBJECT_FIELD` f
  262. where f.objectNamespace = :objectNamespace
  263. and f.fieldNamespace = :fieldNamespace
  264. ", [
  265. ':objectNamespace' => $rootObjectNamespace,
  266. ':fieldNamespace' => $childName,
  267. ]);
  268. if (!$appInfo) throw new Exception("Missing app:info for field '{$rootObjectNamespace}/{$childName}'");
  269. $appInfo = ACL::decodeAppInfoJson($appInfo);
  270. if (empty($appInfo)) throw new Exception("Empty app:info for field '{$rootObjectNamespace}/{$childName}'");
  271. DBG::log(['$appInfo'=>$appInfo, '$rootObjectNamespace'=>$rootObjectNamespace, '$childName'=>$childName], 'array', "\$appInfo");
  272. $rootAcl = self::getAclByNamespace($rootObjectNamespace);
  273. $childXsdType = $rootAcl->getXsdFieldType($childName);
  274. list($typePrefix, $childNamespace) = explode(':', $childXsdType, 2);
  275. switch ($typePrefix) {
  276. case 'ref_uri': $childAcl = self::getAclByNamespace($childNamespace); break;
  277. case 'ref': $childAcl = self::getAclByTypeName($childNamespace); break;
  278. default: throw new Exception("Expected ref type for field '{$childName}' in object '{$rootObjectNamespace}'");
  279. }
  280. $lastActionDateField = "NULL"; // , IF(l.A_RECORD_UPDATE_DATE > r.A_RECORD_UPDATE_DATE, l.A_RECORD_UPDATE_DATE, r.A_RECORD_UPDATE_DATE) as A_LAST_ACTION_DATE
  281. $rootPrimaryKeyField = $rootAcl->getPrimaryKeyField();
  282. $childPrimaryKeyField = $childAcl->getPrimaryKeyField();
  283. $rootTableName = $rootAcl->getRootTableName();
  284. $childTableName = $childAcl->getRootTableName();
  285. // '$appInfo' => [
  286. // 'flat_relation_cache' => [
  287. // 'source' => [
  288. // '@name' => 'ID',
  289. // '@xpath' => 'default_db__x3A__CRM_WSKAZNIK:CRM_WSKAZNIK/ID_PROCES',
  290. // ),
  291. // ),
  292. // ),
  293. // '$rootObjectNamespace' => 'default_db/CRM_PROCES/PROCES',
  294. // '$childName' => 'default_db__x3A__CRM_WSKAZNIK:CRM_WSKAZNIK',
  295. // '$appInfo' => [
  296. // 'flat_relation_cache' => [
  297. // 'source' => [
  298. // '@name' => 'ID',
  299. // '@xpath' => 'default_db__x3A__CRM_PROCES:PROCES/PARENT_ID',
  300. // ),
  301. // ),
  302. // ),
  303. // '$rootObjectNamespace' => 'default_db/CRM_PROCES/PROCES',
  304. // '$childName' => 'default_db__x3A__CRM_PROCES:PROCES',
  305. $appInfoRootFieldName = null;
  306. $appInfoChildFieldName = null;
  307. {
  308. if (empty($appInfo['flat_relation_cache']['source']['@name'])) throw new Exception("Missing flat_relation_cache/source/@name");
  309. if (empty($appInfo['flat_relation_cache']['source']['@xpath'])) throw new Exception("Missing flat_relation_cache/source/@xpath");
  310. $appInfoName = $appInfo['flat_relation_cache']['source']['@name'];
  311. $appInfoXpath = $appInfo['flat_relation_cache']['source']['@xpath'];
  312. // $rootNs = $rootAcl->getNamespace()
  313. if ("{$childName}/" === substr($appInfoXpath, 0, strlen("{$childName}/"))) {
  314. $appInfoRootFieldName = substr($appInfoXpath, strlen("{$childName}/"));
  315. $appInfoChildFieldName = $appInfoName;
  316. } else {
  317. throw new Exception("TODO parse flat_relation_cache");
  318. }
  319. }
  320. if (!$appInfoRootFieldName || !$appInfoChildFieldName) throw new Exception("Error Processing flat_relation_cache");
  321. $sqlWhereFromRestrictions = [];
  322. DBG::log(['root'=>$rootAcl->getFields(), 'child'=>$childAcl->getFields()], 'array', "rootAcl and childAcl fields - xsdRestrictions");
  323. if ($rootAcl instanceof AntAclBase && $childAcl instanceof AntAclBase) {
  324. $rootLocalFieldsWithRestrictions = array_filter($rootAcl->getFields(), function ($field) {
  325. if (!$field['isLocal']) return false;
  326. if (empty($field['xsdRestrictions'])) return false;
  327. if ('[]' == $field['xsdRestrictions']) return false;
  328. return true;
  329. });
  330. $childLocalFieldsWithRestrictions = array_filter($childAcl->getFields(), function ($field) {
  331. if (!$field['isLocal']) return false;
  332. if (empty($field['xsdRestrictions'])) return false;
  333. if ('[]' == $field['xsdRestrictions']) return false;
  334. return true;
  335. });
  336. DBG::log(['root'=>$rootLocalFieldsWithRestrictions, 'child'=>$childLocalFieldsWithRestrictions], 'array', "root and child fields with xsdRestrictions");
  337. if (!empty($rootLocalFieldsWithRestrictions)) {
  338. $sqlTablePrefix = 'root';
  339. $sqlWhereFromRestrictions = array_reduce(
  340. array_map(function ($field) use ($sqlTablePrefix) {
  341. $sqlRestrictions = [];
  342. // 'xsdRestrictions' => '{"enumeration":{"PROCES":"PROCES"}}',
  343. $restrictions = @json_decode($field['xsdRestrictions'], $assoc = true);
  344. if (!empty($restrictions)) {
  345. if (!empty($restrictions['enumeration'])) {
  346. $sqlRestrictions[] = "{$sqlTablePrefix}.`{$field['fieldNamespace']}` in (" . implode(",", array_map([DB::getPDO(), 'quote'], array_keys($restrictions['enumeration']))) . ")";
  347. }
  348. }
  349. return $sqlRestrictions;
  350. }, $rootLocalFieldsWithRestrictions),
  351. function ($ret, $cur) {
  352. return array_merge($ret, array_filter($cur, ['V', 'filterNotEmpty']));
  353. },
  354. $sqlWhereFromRestrictions
  355. );
  356. }
  357. if (!empty($childLocalFieldsWithRestrictions)) {
  358. $sqlTablePrefix = 'child';
  359. $sqlWhereFromRestrictions = array_reduce(
  360. array_map(function ($field) use ($sqlTablePrefix) {
  361. $sqlRestrictions = [];
  362. // 'xsdRestrictions' => '{"enumeration":{"PROCES":"PROCES"}}',
  363. $restrictions = @json_decode($field['xsdRestrictions'], $assoc = true);
  364. if (!empty($restrictions)) {
  365. if (!empty($restrictions['enumeration'])) {
  366. $sqlRestrictions[] = "{$sqlTablePrefix}.`{$field['fieldNamespace']}` in (" . implode(",", array_map([DB::getPDO(), 'quote'], array_keys($restrictions['enumeration']))) . ")";
  367. }
  368. }
  369. return $sqlRestrictions;
  370. }, $childLocalFieldsWithRestrictions),
  371. function ($ret, $cur) {
  372. return array_merge($ret, array_filter($cur, ['V', 'filterNotEmpty']));
  373. },
  374. $sqlWhereFromRestrictions
  375. );
  376. }
  377. }
  378. $sqlWhereFromRestrictions = (!empty($sqlWhereFromRestrictions)) ? implode(" and ", $sqlWhereFromRestrictions) : "1=1";
  379. $sqlChildFieldName = $childAcl->getSqlFieldName($appInfoRootFieldName);
  380. $sql = "
  381. select root.{$rootPrimaryKeyField} as PRIMARY_KEY
  382. , child.{$childPrimaryKeyField} as REMOTE_PRIMARY_KEY
  383. , '' as REMOTE_TYPENAME
  384. , 'WAITING' as A_STATUS
  385. , 0 as TRANSACTION_ID
  386. , {$lastActionDateField} as A_LAST_ACTION_DATE
  387. from `{$rootTableName}` root
  388. join `{$childTableName}` child on(child.{$sqlChildFieldName} = root.{$appInfoChildFieldName})
  389. where {$sqlWhereFromRestrictions}
  390. ";
  391. DBG::log($sql, 'sql', "generateRefSelectSqlByFlatRelationCache");
  392. return $sql;
  393. }
  394. public static function getBackRefList($namespace) {
  395. if (!$namespace) throw new Exception("Missing namespace");
  396. $nsParts = explode('/', $namespace);
  397. $typeName = array_pop($nsParts);
  398. $typeName = implode("__x3A__", $nsParts) . ":{$typeName}";
  399. return DB::getPDO()->fetchAll("
  400. select c.ROOT_OBJECT_NS as namespace
  401. , i.id as idInstance
  402. from CRM_REF_CONFIG c
  403. join CRM_INSTANCE_CONFIG i on ( i.namespace = c.ROOT_OBJECT_NS )
  404. where ( c.CHILD_NAME = :type_name or c.CHILD_NAME = :namespace )
  405. and c.A_STATUS = 'NORMAL'
  406. ", [
  407. ':type_name' => $typeName,
  408. ':namespace' => $namespace,
  409. ]);
  410. }
  411. public static function fetchRefs($namespace, $childNamespace, $primaryKey, $params = []) { // TODO: $params: limit, total
  412. if (!$namespace) throw new Exception("Missing namespace");
  413. if (!$childNamespace) throw new Exception("Missing child namespace");
  414. if (!$primaryKey) throw new Exception("Missing primary key");
  415. throw new Exception("TODO: fetch refs from '{$namespace}' where primaryKey = '{$primaryKey}'");
  416. }
  417. public static function fetchBackRefs($namespace, $primaryKey, $parentNamespace, $params = []) { // TODO: $params: limit, total
  418. if (!$namespace) throw new Exception("Missing namespace");
  419. if (!$parentNamespace) throw new Exception("Missing parent namespace");
  420. if (!$primaryKey) throw new Exception("Missing primary key");
  421. $typeName = Api_WfsNs::typeName($namespace);
  422. $refTable = ACL::getRefTable($parentNamespace, $typeName);
  423. if (V::get('total', false, $params)) {
  424. return DB::getPDO()->fetchValue(" select count(*) as cnt from `{$refTable}` where REMOTE_PRIMARY_KEY = :primary_key and A_STATUS not in ('DELETED') ", [ ':primary_key' => $primaryKey ]);
  425. }
  426. throw new Exception("TODO: fetch back refs from '{$namespace}' where primaryKey({$primaryKey}) by refTable({$refTable})");
  427. }
  428. static function generateSqlWhereFromFieldsWithRestrictions($fieldsRestrictions, $sqlTablePrefix = 't') {
  429. return InstanceConfig::generateSqlWhereFromFieldsWithRestrictions($fieldsRestrictions, $sqlTablePrefix);
  430. }
  431. static function generateSqlWhereFromFieldRestrictions($fields, $sqlTablePrefix = 't') {
  432. return InstanceConfig::generateSqlWhereFromFieldRestrictions($fields, $sqlTablePrefix);
  433. }
  434. static function getInstanceId($namespace) {
  435. return InstanceConfig::getInstanceId($namespace);
  436. }
  437. static function getInstanceConfig($namespace) { // @return Type_InstanceConfig
  438. return InstanceConfig::getInstanceConfig($namespace);
  439. }
  440. static function getInstanceTable($namespace) { // @return tableName with struct { pk, idInstance, _createdAt }
  441. return InstanceConfig::getInstanceTable($namespace);
  442. }
  443. static function getRootNamespace($namespace) { // TODO: works only for relative urls! - mv to Acl->getRootNamespace
  444. return InstanceConfig::getRootNamespace($namespace);
  445. }
  446. static function getNamespaceSiblings($namespace) {
  447. return InstanceConfig::getNamespaceSiblings($namespace);
  448. }
  449. static function getFeatureNamespaces($namespace, $pk) {
  450. return InstanceConfig::getFeatureNamespaces($namespace, $pk);
  451. }
  452. // @params $from - ( ACL | tableName | namespace | etc... - only ACL)
  453. public static function query($from, $prefix = 't') {
  454. Lib::loadClass('AclQueryBuilder');
  455. $query = new AclQueryBuilder();
  456. $query->from($from, $prefix);
  457. return $query;
  458. }
  459. /**
  460. * @param mixed $object - Core_AclBase or string - namespace
  461. * @return Core_AclFields
  462. */
  463. public static function getObjectFields($object) {
  464. // TODO: try to get structure from `CRM_#CACHE_ACL_OBJECT_FIELD`
  465. // if ($object is instance Core_AclBase) {
  466. // if ($object->isStructInstalled) then get structure from `CRM_#CACHE_ACL_OBJECT_FIELD` and put into Core_AclFields
  467. // else get from $object->getFields() and put into Core_AclFields
  468. }
  469. public static function canUserReadObject($idUser, $aclOrIdZasob) {
  470. throw new Exception("TODO: canUserReadObjec({$idUser}, {$aclOrIdZasob})");
  471. }
  472. public static function canUserCreateObject($idUser, $aclOrIdZasob) {
  473. throw new Exception("TODO: canUserCreateObjec({$idUser}, {$aclOrIdZasob})");
  474. }
  475. public static function canUserWriteObject($idUser, $aclOrIdZasob) {
  476. throw new Exception("TODO: canUserWriteObjec({$idUser}, {$aclOrIdZasob})");
  477. }
  478. public static function canUserReadObjectField($idUser, $aclOrIdZasob, $fieldNameOrXPath) {
  479. throw new Exception("TODO: canUserReadObjectFiel({$idUser}, {$aclOrIdZasob}, {$fieldNameOrXPath})");
  480. }
  481. public static function canUserCreateObjectField($idUser, $aclOrIdZasob, $fieldNameOrXPath) {
  482. throw new Exception("TODO: canUserCreateObjectFiel({$idUser}, {$aclOrIdZasob}, {$fieldNameOrXPath})");
  483. }
  484. public static function canUserWriteObjectField($idUser, $aclOrIdZasob, $fieldNameOrXPath) {
  485. throw new Exception("TODO: canUserWriteObjectFiel({$idUser}, {$aclOrIdZasob}, {$fieldNameOrXPath})");
  486. }
  487. // TODO: replace below:
  488. // AclBase->canCreateField
  489. // AclBase->canReadField
  490. // AclBase->canReadObjectField
  491. // AclBase->canWriteField
  492. // AclBase->canWriteObjectField
  493. // AclBase->canWriteRecord
  494. // AclBase->canReadRecord
  495. }