se/SE/se-lib/Route/Storage/AclReinstall.php

<?php

Lib::loadClass('RouteBase');
Lib::loadClass('Router');
Lib::loadClass('Response');
Lib::loadClass('UI');
Lib::loadClass('SchemaFactory');
Lib::loadClass('RefConfig');
Lib::loadClass('Type_Field');

class Route_Storage_AclReinstall extends RouteBase {

	public function handleAuth() {
		if (!User::logged()) {
			User::authByRequest();
		}
	}

	public function defaultAction() {
		UI::gora();
		UI::startContainer();
		try {
			$namespace = V::get('namespace', '', $_GET);
			if (empty($namespace)) throw new Exception("Missing param namespace");
			echo UI::h('h3', [], $namespace);
			echo UI::h('p', [], [
				UI::h('a', [
					'href' => Router::getRoute('Storage_AclStruct')->getLink('', [ 'namespace' => $namespace ]),
					'class' => "btn btn-md btn-link",
				], "<i class=\"glyphicon glyphicon-arrow-left\"></i> Wróć do struktury"),
				" | ",
				UI::h('a', [
					'href' => $this->getLink('viewXsdSource', [ 'namespace' => $namespace ]),
					'class' => "btn btn-md btn-link",
					'target' => "_blank",
				], "Otwórz plik xsd (źródłowy)"),
			]);

			if ('reinstall' == V::get('_postTask', '', $_POST)) {
				$this->reinstallAcl($namespace);
				return;
			}

			echo UI::hButtonPost("Reinstall", [
				'data' => [
					'_postTask' => 'reinstall'
				],
				'class' => 'btn btn-md btn-danger',
				'title' => "Reinstall structure"
			]);
			echo '<hr>';
			try {
				$this->printReinstallPreview($namespace);
			} catch (Exception $e) {
				DBG::log($e);
				UI::alert('danger', $e->getMessage());
			}
		} catch (Exception $e) {
			UI::alert('danger', "Error #" . $e->getCode() .  "|" . $e->getLine() .  ": " . $e->getMessage());
			DBG::log($e);
		}
		UI::endContainer();
		UI::dol();
	}

	public function printReinstallPreview($namespace) {
		$objectItem = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => "*,field" ]);
		DBG::log($objectItem, 'array', '$objectItem preview');

		switch ($objectItem['_type']) {
			case 'AntAcl': $this->printReinstallAntAclPreview($objectItem); break;
			case 'TableAcl': $this->printReinstallTableAclPreview($objectItem); break;
			case 'StorageAcl': $this->printReinstallStorageAclPreview($objectItem); break;
			default: throw new Exception("TODO: Not Implemented type '{$objectItem['_type']}'");
		}
	}
	public function printReinstallAntAclPreview($item) {
		Lib::loadClass('Schema_SystemObjectFieldStorageAcl');
		$antAclPath = Schema_SystemObjectFieldStorageAcl::getAntAclXsdBasePath($item['typeName']);
		if (!file_exists("{$antAclPath}/build.xml")) throw new Exception("Ant build file not exists " . str_replace(APP_PATH_ROOT, 'SE', $antAclPath));

		Lib::loadClass('XML');
		$xsdType = XML::getXsdTypeFromXsdSchema("{$antAclPath}/{$item['name']}.xsd", $namespace = $item['namespace'], $name = $item['name']);
		DBG::nicePrint($item, '$item');
		$sortPrio = 0;
		foreach ($xsdType['struct'] as $fieldName => $fieldItem) {
			$xsdType['struct'][$fieldName]['sortPrio'] = $sortPrio++;
		}
		DBG::nicePrint($xsdType, '$xsdType');
		// TODO: fix sortPrio for all fields if not set = 0

		echo '<hr>';
		echo UI::h('h3', [], "Lista zmian:");

		echo ($item['primaryKey'] != $xsdType['primaryKey'])
		?	UI::h('p', [ 'style' => "" ], "@primaryKey - zmiana z '{$item['primaryKey']}' na '{$xsdType['primaryKey']}'")
		:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "@primaryKey - bez zmian");

		if (empty($xsdType['struct'])) throw new Exception("Field list not found for '{$item['namespace']}'");
		foreach ($xsdType['struct'] as $fieldName => $x) {
			$listEnum = [];
			if (!empty($x['restrictions']['enumeration'])) {
				$listEnum = $x['restrictions']['enumeration'];
				unset($x['restrictions']['enumeration']);
			}
			if (!empty($listEnum)) {
				DBG::log($listEnum, 'array', "\$listEnum for field '{$fieldName}'");
			}
		}

		$old = [
			'fields' => array_map(function ($field) { return $field['fieldNamespace']; }, $item['field']),
		];
		$new = [
			'fields' => array_keys($xsdType['struct']),
		];

		sort($old['fields']);
		sort($new['fields']);
		$diffFieldsToCreate = array_diff($new['fields'], $old['fields']);
		$diffFieldsToRemove = array_diff($old['fields'], $new['fields']);
		$sameFields = array_intersect($new['fields'], $old['fields']);
		echo (!empty($diffFieldsToCreate))
		?	UI::h('details', [ 'open' => "open" ], [
				UI::h('summary', [], "Pola do dodania (".count($diffFieldsToCreate)."):"),
				UI::h('ul', [], array_map(function ($fieldName) {
					return UI::h('li', [], $fieldName);
				}, $diffFieldsToCreate)),
			])
		:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "Brak pól do dodania");
		echo (!empty($diffFieldsToRemove))
		?	UI::h('details', [ 'open' => "open", 'style' => "margin:4px 0; color:#8a6d3b; background-color:#fcf8e3; border:1px solid #faebcc;" ], [
				UI::h('summary', [ 'style' => "padding:4px; outline:none; cursor:pointer" ], "Pola do usunięcia (".count($diffFieldsToRemove)."):"),
				UI::h('ul', [], array_map(function ($fieldName) {
					return UI::h('li', [], $fieldName);
				}, $diffFieldsToRemove)),
			])
		:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "Brak pól do usunięcia");
		foreach ($sameFields as $fieldName) {
			// UI::alert('warning', "TODO: is field changed? '{$fieldName}'");
			$oldField = array_filter($item['field'], function ($field) use ($fieldName) { return ( $fieldName === $field['fieldNamespace'] ); });
			$oldField = ($oldField) ? reset($oldField) : null;
			// DBG::nicePrint($oldField, "\$oldField '$fieldName'");
			$newField = $xsdType['struct'][$fieldName];
			// DBG::nicePrint($newField, "\$newField '$fieldName'");
			$fieldDiff = [];
			if ($newField['type'] !== $oldField['xsdType']) $fieldDiff[] = 'xsdType';
			if ($newField['minOccurs'] != $oldField['minOccurs']) $fieldDiff[] = 'minOccurs';
			if ($newField['maxOccurs'] != $oldField['maxOccurs']) $fieldDiff[] = 'maxOccurs';
			if (json_encode($newField['restrictions']) !== $oldField['xsdRestrictions']) $fieldDiff[] = 'xsdRestrictions';
			if (json_encode($newField['appInfo']) !== $oldField['appInfo']) $fieldDiff[] = 'appInfo';
			if (RefConfig::isRefField($item['namespace'], $fieldName)) {
				$typeNewField = Type_Field::build($newField);
				$typeOldField = Type_Field::build($oldField);
				if (RefConfig::needUpdate($item['namespace'], $oldField['fieldNamespace'], $typeNewField, $typeOldField)) {
					$fieldDiff[] = 'RefConfig';
				}
			}
			echo (!empty($fieldDiff))
			?	UI::h('p', [ 'style' => "" ], "Pole '{$fieldName}' - zmiany: " . implode(", ", $fieldDiff))
			:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "Pole '{$fieldName}' - bez zmian");
		}
	}
	public function printReinstallTableAclPreview($item) {
		throw new Exception("TODO: Podgląd zmian dla tabeli {$item['namespace']} ...");
	}
	public function printReinstallStorageAclPreview($item) {
		DBG::nicePrint($item, '$item');
		$acl = SchemaFactory::loadDefaultObject($item['name']);
		DBG::nicePrint($acl, '$acl');
		$xsdType = [
			'primaryKey' => $acl->getPrimaryKeyField(),
			'struct' => $acl->getFieldsWithXsdTypes()
		];
		DBG::nicePrint($xsdType, '$xsdType');

		echo '<hr>';
		echo UI::h('h3', [], "Lista zmian:");

		echo ($item['primaryKey'] != $xsdType['primaryKey'])
		?	UI::h('p', [ 'style' => "" ], "@primaryKey - zmiana z '{$item['primaryKey']}' na '{$xsdType['primaryKey']}'")
		:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "@primaryKey - bez zmian");

		if (empty($xsdType['struct'])) throw new Exception("Field list not found for '{$item['namespace']}'");
		foreach ($xsdType['struct'] as $fieldName => $x) {
			$listEnum = [];
			if (!empty($x['restrictions']['enumeration'])) {
				$listEnum = $x['restrictions']['enumeration'];
				unset($x['restrictions']['enumeration']);
			}
			if (!empty($listEnum)) {
				DBG::log($listEnum, 'array', "\$listEnum for field '{$fieldName}'");
			}
		}

		$old = [
			'fields' => array_map(function ($field) { return $field['fieldNamespace']; }, $item['field']),
		];
		$new = [
			'fields' => array_keys($xsdType['struct']),
		];

		sort($old['fields']);
		sort($new['fields']);
		$diffFieldsToCreate = array_diff($new['fields'], $old['fields']);
		$diffFieldsToRemove = array_diff($old['fields'], $new['fields']);
		$sameFields = array_intersect($new['fields'], $old['fields']);
		echo (!empty($diffFieldsToCreate))
		?	UI::h('details', [ 'open' => "open" ], [
				UI::h('summary', [], "Pola do dodania (".count($diffFieldsToCreate)."):"),
				UI::h('ul', [], array_map(function ($fieldName) {
					return UI::h('li', [], $fieldName);
				}, $diffFieldsToCreate)),
			])
		:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "Brak pól do dodania");
		echo (!empty($diffFieldsToRemove))
		?	UI::h('details', [ 'open' => "open", 'style' => "margin:4px 0; color:#8a6d3b; background-color:#fcf8e3; border:1px solid #faebcc;" ], [
				UI::h('summary', [ 'style' => "padding:4px; outline:none; cursor:pointer" ], "Pola do usunięcia (".count($diffFieldsToRemove)."):"),
				UI::h('ul', [], array_map(function ($fieldName) {
					return UI::h('li', [], $fieldName);
				}, $diffFieldsToRemove)),
			])
		:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "Brak pól do usunięcia");
		foreach ($sameFields as $fieldName) {
			// UI::alert('warning', "TODO: is field changed? '{$fieldName}'");
			$oldField = array_filter($item['field'], function ($field) use ($fieldName) { return ( $fieldName === $field['fieldNamespace'] ); });
			$oldField = ($oldField) ? reset($oldField) : null;
			// DBG::nicePrint($oldField, "\$oldField '$fieldName'");
			$newField = $xsdType['struct'][$fieldName];
			// DBG::nicePrint($newField, "\$newField '$fieldName'");
			$fieldDiff = [];
			if ($newField['type'] !== $oldField['xsdType']) $fieldDiff[] = 'xsdType';
			if ($newField['minOccurs'] != $oldField['minOccurs']) $fieldDiff[] = 'minOccurs';
			if ($newField['maxOccurs'] != $oldField['maxOccurs']) $fieldDiff[] = 'maxOccurs';
			if (json_encode($newField['restrictions']) !== $oldField['xsdRestrictions']) $fieldDiff[] = 'xsdRestrictions';
			if (json_encode($newField['appInfo']) !== $oldField['appInfo']) $fieldDiff[] = 'appInfo';
			echo (!empty($fieldDiff))
			?	UI::h('p', [ 'style' => "" ], "Pole '{$fieldName}' - zmiany: " . implode(", ", $fieldDiff))
			:	UI::h('p', [ 'style' => "font-style:italic; color:silver" ], "Pole '{$fieldName}' - bez zmian");
		}
	}

	public function viewXsdSourceAction() {
		try {
			$namespace = V::get('namespace', '', $_GET);
			if (empty($namespace)) throw new Exception("Missing param namespace");
			$objectItem = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => "*,field" ]);
			switch ($objectItem['_type']) {
				case 'AntAcl': $this->viewXsdSource($objectItem); break;
				// case 'TableAcl': $this->viewXsdSource($objectItem); break;
				default: throw new Exception("TODO: Not Implemented type '{$objectItem['_type']}'");
			}
		} catch (Exception $e) {
			DBG::log($e);
			echo "Error #" . $e->getCode() .  "|" . $e->getLine() .  ": " . $e->getMessage();
		}
	}
	function viewXsdSource($objectItem) {
		if (empty($objectItem)) throw new Exception("Missing objectItem in viewXsdSource");
		DBG::log($objectItem, "viewXsdSource \$objectItem");

		Lib::loadClass('Schema_SystemObjectFieldStorageAcl');
		$antAclPath = Schema_SystemObjectFieldStorageAcl::getAntAclXsdBasePath($objectItem['typeName']);
		if (!file_exists("{$antAclPath}/build.xml")) throw new Exception("Ant build file not exists");
		DBG::log(str_replace(APP_PATH_ROOT, '~', $antAclPath), "viewXsdSource \$antAclPath");

		$xsdFile = "{$antAclPath}/{$objectItem['name']}.xsd";
		if (!file_exists($xsdFile)) throw new Exception("Xsd file not exists");
		DBG::log(str_replace(APP_PATH_ROOT, '~', $xsdFile), "viewXsdSource \$xsdFile");

		header('Content-Type: application/xml; charset=utf-8');
		$fd = fopen($xsdFile, 'r');
		fpassthru($fd);
		exit;
	}

	function reinstallAcl($namespace) {
		try {
			$this->_createOrUpdateTableStructure($namespace);
		} catch (Exception $e) {
			DBG::log($e);
			UI::alert('danger', $e->getMessage());
		}

		Lib::loadClass('Schema_SystemObjectFieldStorageAcl');
		$objFieldAcl = new Schema_SystemObjectFieldStorageAcl();
		$objFieldAcl->updateCache($namespace);

		try {
			$dbgInfo = [
				'idInstance' => ACL::getInstanceId($namespace),
				// 'rootInstance' => InstanceConfig::getRootNamespace($namespace),
				// 'conf' => InstanceConfig::fetchInstanceConfig($namespace),
			];
			DBG::nicePrint($dbgInfo, "dbg");
		} catch (Exception $e) {
			DBG::log($e);
			UI::alert('warning', $e->getMessage());
		}

		$childRefList = RefConfig::getChildRefFullList($namespace);
		DBG::nicePrint($childRefList, '$childRefList');
		DBG::nicePrint($item, '$item');
		$activeFields = array_filter($item['field'], function ($field) {
			return ($field['isActive'] > 0);
		});
		$fieldNsList = array_map(function ($field) {
			return $field['fieldNamespace'];
		}, $activeFields);
		DBG::nicePrint($fieldNsList, '$fieldNsList');

		if ('AntAcl' === $item['_type']) { // fix ref config status (turn on/off)
			foreach ($childRefList as $refConfig) { // [ namespace, A_STATUS ]
				if ($refConfig->status !== 'DELETED' && !in_array($refConfig->childName, $fieldNsList)) {
					UI::alert('danger', "remove ref config for '{$refConfig->childName}' ...");
					if (!$refConfig->id) throw new Exception("Missing ref config ID");
					RefConfig::remove($refConfig);
				}
				else if ($refConfig->status !== 'DELETED' && in_array($refConfig->childName, $fieldNsList)) {
					UI::alert('info', "ref config for '{$refConfig->childName}' active - OK");
				}
				else if ($refConfig->status === 'DELETED' && in_array($refConfig->childName, $fieldNsList)) {
					UI::alert('warning', "activate ref config for '{$refConfig->childName}' ...");
					if (!$refConfig->id) throw new Exception("Missing ref config ID");
					RefConfig::reactivate($refConfig);
				}
				else if ($refConfig->status === 'DELETED' && !in_array($refConfig->childName, $fieldNsList)) {
					UI::alert('info', "ref config for '{$refConfig->childName}' removed - OK");
				}
				else {
					UI::alert('danger', "Not implemented action for '{$refConfig->childName}'");
				}
			}
			// TODO: create missing refConfig - field is not in $childRefList
		}

		if ('AntAcl' === $item['_type']) { // fix ref tables by appInfo
			$activeRefFields = array_filter($item['field'], function ($field) {
				return ($field['isActive'] && 'ref:' === substr($field['xsdType'], 0, 4));
			});
			DBG::log($activeRefFields, 'array', "DBG \$activeRefFields");
			foreach ($activeRefFields as $field) {
				$typeNewField = Type_Field::build($field);
				// if (RefConfig::needUpdate($item['namespace'], $oldField['fieldNamespace'], $typeNewField, $typeOldField))
				try {
					RefConfig::update($item['namespace'], $field['fieldNamespace'], $typeNewField);
				} catch (Exception $e) {
					// TODO: deactivate RefConfig if error
					DBG::log($e);
					UI::alert('danger', $e->getMessage());
				}
			}
		}

		{ // TODO: RMME? function is too slow for join query
			if ('AntAcl' === $item['_type']) {
				$idInstance = ACL::getInstanceId($namespace);
				$dbName = DB::getPDO()->getDatabaseName();
				DB::getPDO()->execSql(" DROP FUNCTION IF EXISTS `{$dbName}`.`isInstance_{$idInstance}` ");
			}
		}
		{ // TODO: mv to updateCache
			if ('AntAcl' === $item['_type']) {
				$instConf = InstanceConfig::getInstanceConfig($namespace);
				InstanceConfig::createInstanceTable($instConf, $item); // force create instance table event if A_STATUS is NORMAL
			}
		}
	}

	function _createOrUpdateTableStructure($namespace) {
		$item = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => '*,field' ]);
		DBG::nicePrint($item, 'DBG:_createOrUpdateTableStructure:$item');
		$storagePdo = DB::getStorage($item['idDatabase']);
		$tblStruct = [];
		try {
			$tblStruct = $storagePdo->getTableStruct($item['_rootTableName']);
		} catch (Exception $e) {
		}
		DBG::nicePrint($tblStruct, 'DBG:_createOrUpdateTableStructure:$tblStruct');

		if (DB::getPDO()->getZasobId() != $item['idDatabase']) throw new Exception("Not imeplemented Create/Update table structure in non default database");

		if (empty($tblStruct)) $this->_createTableStructure($item);
		else $this->_updateTableStructure($item, $tblStruct);
	}
	// $item['idDatabase'] => int idDatabase
	// $item['_rootTableName'] => string tableName
	// $item['primaryKey'] => string primaryKey fieldName
	// $item['field'] => []
	// $item['field']['fieldNamespace'] => fieldName,
	// $item['field']['xsdRestrictions'] => [] // TODO: handle restrictions like maxLength, etc.
	// $item['field']['xsdType'] `select distinct xsdType from `CRM_#CACHE_ACL_OBJECT_FIELD` where xsdType not like 'ref:%'`: [
		// default_db__x3A__BADANIA_W_TERENIE:A_STATUS_Type
		// default_db__x3A__CRM_PROCES:TYPE_Simple
		// gml:AbstractFeatureType
		// gml:PolygonPropertyType
		// p5:enum
		// p5:price
		// p5:www_link
		// p5Type:date
		// p5Type:dateTime
		// p5Type:decimal
		// p5Type:integer
		// p5Type:lineString
		// p5Type:point
		// p5Type:polygon
		// p5Type:string
		// p5Type:text
		// xsd:date
		// xsd:dateTime
		// xsd:decimal
		// xsd:double
		// xsd:float
		// xsd:gYear
		// xsd:hexBinary
		// xsd:int
		// xsd:integer
		// xsd:long
		// xsd:positiveInteger
		// xsd:short
		// xsd:string
		// xsd:time
		// xsd:token
	// ]
	function _createTableStructure($item) {
		$tryConvertFields = array_map(function ($fieldInfo) {
			if ('ref:' === substr($fieldInfo['xsdType'], 0, 4)) return "Skipped create ref field '{$fieldInfo['xsdType']}'";
			switch ($fieldInfo['xsdType']) {
				case 'xsd:integer':
				case 'p5Type:integer':
				case 'xsd:positiveInteger':
				case 'xsd:int': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "int(11)" ];
				case 'xsd:float': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "float" ];
				case 'xsd:double': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "double" ];
				case 'xsd:date': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "date" ];
				case 'xsd:datetime': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "datetime" ];
				case 'xsd:string':
				case 'p5Type:string': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "varchar(255)" ];
				// TODO: implement more xsd types:
				// case 'p5Type:decimal':
				// case 'xsd:decimal': return [ 'name' => $fieldInfo['fieldNamespace'], 'raw_storage_type' => "decimal" ];
				// default_db__x3A__BADANIA_W_TERENIE:A_STATUS_Type
				// default_db__x3A__CRM_PROCES:TYPE_Simple
				// gml:AbstractFeatureType
				// gml:PolygonPropertyType
				// p5:enum
				// p5:price
				// p5:www_link
				// p5Type:date
				// p5Type:dateTime
				// p5Type:decimal
				// p5Type:lineString
				// p5Type:point
				// p5Type:polygon
				// p5Type:text
				// xsd:decimal
				// xsd:gYear
				// xsd:hexBinary
				// xsd:long
				// xsd:short
				// xsd:time
				// xsd:token
				default: return "Not implemented type '{$fieldInfo['xsdType']}'";
			}
		}, $item['field']);
		DBG::nicePrint($tryConvertFields, "DBG:create table struct:\$tryConvertFields");
		$toCreateFields = array_filter($tryConvertFields, function ($fieldInfo) { return is_array($fieldInfo); });
		DBG::nicePrint($toCreateFields, "DBG:create table struct:\$toCreateFields");

		$tblStruct = array_combine(
			array_map(V::makePick('name'), $toCreateFields),
			array_values($toCreateFields)
		);
		DBG::nicePrint($tblStruct, "DBG:create table struct:\$tblStruct");
		if (!array_key_exists($item['primaryKey'], $tblStruct)) throw new Exception("BUG: primaryKey field definition not exists");
		$tblStruct[$item['primaryKey']]['extra'] = "auto_increment";

		DB::getStorage($item['idDatabase'])->createTableStructure([
			'tableName' => $item['_rootTableName'],
			'fields' => $tblStruct,
			'primaryKey' => $item['primaryKey'],
			'keys' => [],
		]);
	}
	function _updateTableStructure($item, $tblStruct) {
		throw new Exception("Not imeplemented Update table structure in non default database");
	}

}