$fetchTableProcesInitListSql('.$idTable.') ';print_r($fetchTableProcesInitListSql);echo''; $tableProcesInitList = array(); $db = DB::getDB(); $res = $db->query($fetchTableProcesInitListSql); while ($r = $db->fetch($res)) { $tableProcesInitList[$r->ID] = $r->DESC; } return $tableProcesInitList; } public static function getProcesInitMapTreeOnlyIds($ids) { $mapTree = array(); $map = self::getProcesInitMapOnlyIds($ids); foreach ($map as $r) { if ('PROCES_INIT' == $r->TYPE) { $mapTree[$r->ID_PROCES] = array(); } } foreach ($map as $r) { if ('GOTO_AND_RETURN' == $r->TYPE) { $mapTree[$r->idx_MAIN_PROCES_INIT_ID][$r->ID_PROCES] = array(); } } foreach ($map as $r) { if ('GOTO_AND_RETURN_LVL2' == $r->TYPE) { $mapTree[$r->idx_MAIN_PROCES_INIT_ID][$r->idx_GOTO_LVL2_INIT_ID][$r->ID_PROCES] = true; } } return $mapTree; } public static function getProcesInitMapOnlyIds($ids) { $map = array(); $sqlIds = V::filter($ids, array('V', 'filterPositiveInteger')); $sqlIds = implode(',', $sqlIds); if (empty($sqlIds)) return $map; $sql = <<query($sql); while ($r = $db->fetch($res)) { $map[] = $r; } //DBG::table("MAP", $map, __CLASS__, __FUNCTION__, __LINE__); return $map; } public static function canGroupViewProces($idGroup, $idProcesInit) { $isAllowed = false; $idProcesInit = (int)$idProcesInit; if (!$idProcesInit) return false; $checkProcesAccessSql = <<query($checkProcesAccessSql); if ($r = $db->fetch($res)) { if ($r->cnt > 0) { $isAllowed = true; } } return $isAllowed; } public static function getAclByNamespace($namespace, $forceTblAclInit = false) { return Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit); } public static function parseNamespaceUrl($namespace) {// returns assoc array: [ 'name', 'url', 'prefix', 'sourceName' ] return Core_AclHelper::parseNamespaceUrl($namespace); } public static function getRefTable($rootObjectNamespace, $childName) { static $cacheRefTables = array(); $cacheKey = "{$rootObjectNamespace}/{$childName}"; if (array_key_exists($cacheKey, $cacheRefTables)) return $cacheRefTables[$cacheKey]; $rootAcl = self::getAclByNamespace($rootObjectNamespace); $childXsdType = $rootAcl->getXsdFieldType($childName); if ('ref_uri:' !== substr($childXsdType, 0, 8)) throw new Exception("Expected ref type for field '{$childName}' in object '{$rootObjectNamespace}'"); $childNamespace = substr($childXsdType, 8); $childAcl = self::getAclByNamespace($childNamespace); $refInfo = [];// define $refInfo = [ ID, A_STATUS, VERSION ] try {// check that ref config table exists $sqlRootTableNs = DB::getPDO()->quote($rootObjectNamespace, PDO::PARAM_STR); $sqlChildName = DB::getPDO()->quote($childName, PDO::PARAM_STR); $sqlChildNamespace = DB::getPDO()->quote($childNamespace, PDO::PARAM_STR); $refInfo = DB::getPDO()->fetchFirst(" select c.ID, c.A_STATUS, c.VERSION from `CRM_REF_CONFIG` c where c.ROOT_OBJECT_NS = {$sqlRootTableNs} and c.CHILD_NAME = {$sqlChildName} and c.CHILD_NS = {$sqlChildNamespace} "); } catch (Exception $e) { DB::getPDO()->exec(" CREATE TABLE `CRM_REF_CONFIG` ( `ID` INT NOT NULL AUTO_INCREMENT , `ROOT_OBJECT_NS` VARCHAR(255) NOT NULL , `CHILD_NAME` VARCHAR(255) NOT NULL , `CHILD_NS` VARCHAR(255) NOT NULL , `A_STATUS` enum('WAITING', 'NORMAL', 'DELETED') NOT NULL DEFAULT 'WAITING' , `VERSION` int(11) NOT NULL DEFAULT 0 , `A_LAST_ACTION_DATE` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP , PRIMARY KEY (`ID`) ) ENGINE = MyISAM DEFAULT CHARSET=latin2; "); } if (empty($refInfo)) { $refInfo = [ 'ID' => 0, 'A_STATUS' => 'WAITING', 'VERSION' => 0 ]; $refInfo['ID'] = DB::getPDO()->insert("CRM_REF_CONFIG", [ 'ROOT_OBJECT_NS' => $rootObjectNamespace, 'CHILD_NAME' => $childName, 'CHILD_NS' => $childNamespace ]); } if (!$refInfo['ID']) throw new Exception("Ref table not found in ref config table for field '{$childName}' in object '{$rootObjectNamespace}'"); $refTableName = "CRM__#REF_TABLE__{$refInfo['ID']}"; if ('WAITING' == $refInfo['A_STATUS']) { DB::getPDO()->exec(" CREATE TABLE IF NOT EXISTS `{$refTableName}` ( `PRIMARY_KEY` int(11) NOT NULL , `REMOTE_PRIMARY_KEY` int(11) NOT NULL , `REMOTE_TYPENAME` varchar(255) NOT NULL DEFAULT '' , `A_STATUS` enum('WAITING', 'NORMAL', 'DELETED') NOT NULL DEFAULT 'WAITING' , `TRANACTION_ID` int(11) NOT NULL , `A_LAST_ACTION_DATE` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP , KEY `PRIMARY_KEY` (`PRIMARY_KEY`) , KEY `REMOTE_PRIMARY_KEY` (`REMOTE_PRIMARY_KEY`) ) ENGINE=MyISAM DEFAULT CHARSET=latin2 COMMENT='{$rootObjectNamespace} #REF $childName ({$childNamespace})'; "); $refInfo['A_STATUS'] = "NORMAL"; $refInfo['VERSION'] = self::$REF_TABLE_VERSION; $affected = DB::getPDO()->update("CRM_REF_CONFIG", 'ID', $refInfo['ID'], [ 'A_STATUS' => $refInfo['A_STATUS'], 'VERSION' => $refInfo['VERSION'] ]); } if ($refInfo['VERSION'] < self::$REF_TABLE_VERSION) throw new Exception("TODO: ref table {$refInfo['ID']} require upgrade - field '{$childName}' in object '{$rootObjectNamespace}'"); $cacheRefTables[$cacheKey] = $refTableName; return $refTableName; } }