se/SE/se-lib/Schema/UserTestStatsStorageAcl.php

<?php

Lib::loadClass('Core_AclSimpleSchemaBase');
Lib::loadClass('Schema_UserProcessStorageAcl');
Lib::loadClass('ParseOgcFilter');
Lib::loadClass('ProcesTestyHelper');

class Schema_UserTestStatsStorageAcl extends Core_AclSimpleSchemaBase {

	public $_simpleSchema = [
		'root' => [
			'@namespace' => 'default_objects/UserTestStats',
			'ID' => [ '@type' => 'xsd:integer' ],
			'PARENT_ID' => [ '@type' => 'xsd:integer' ],
			'nazwa' => [ '@type' => 'xsd:string', '@alias' => 'DESC' ],
			'opis' => [ '@type' => 'xsd:string', '@alias' => 'OPIS' ],
			'link_uruchom_filtr_procesu' => [ '@type' => 'p5:www_link' ],
			'link_uruchom_test_teoretyczny' => [ '@type' => 'p5:www_link', '@label' => "Wykonaj test teoretyczny"],
			'wynik_teoretyczny' => [ '@type' => 'xsd:string', '@label' => "Wynik teoretyczny" ],
			'wynik_teoretyczny_value' => [ '@type' => 'xsd:string', '@label' => "Wynik teoretyczny" ],
			'wynik_praktyczny' => [ '@type' => 'xsd:string', '@label' => "Wynik praktyczny" ],
			'wynik_unactual' => [ '@type' => 'xsd:string', '@label' => "Test nieaktualny?" ],
			'wynik_unactual_id' => [ '@type' => 'xsd:integer', '@label' => "Nr nieaktualnego testu" ],
			'link_popraw_test' => [ '@type' => 'xsd:integer', '@label' => "Popraw test" ],
			'last_update_date' => [ '@type' => 'xsd:date' , '@label' => 'Ostatnia zmiana w procesie' ],
			// 'autor' => [ '@type' => 'xsd:string' , '@alias' => 'A_RECORD_CREATE_AUTHOR' ],
			// 'utworzono' => [ '@type' => 'xsd:date' , '@alias' => 'A_RECORD_CREATE_DATE' ],
			// 'zaktualizował' => [ '@type' => 'xsd:string' , '@alias' => 'A_RECORD_UPDATE_AUTHOR' ],
			// 'zaktualizowano' => [ '@type' => 'xsd:date', '@alias' => 'A_RECORD_UPDATE_DATE' ]
		]
	];
	public $_rootTableName = 'CRM_PROCES';
	public $idUser = null;
	public $_userProcessAcl = null;// Schema_UserProcessStorageAcl

	public function __construct($simpleSchema = null) {
		parent::__construct($simpleSchema);
		$this->idUser = User::getID();// default - current user
		$this->_userProcessAcl = new Schema_UserProcessStorageAcl();// Core_AclHelper::getAclByNamespace('default_objects/UserProcess')
		$this->_userProcessAcl->setIdUser($this->idUser);
	}

	public function setIdUser($idUser) { $this->idUser = intval($idUser); $this->_userProcessAcl->setIdUser($this->idUser); }
	public function getIdUser() { return $this->idUser; }

	public function getTotal($params = []) { return $this->_userProcessAcl->getTotal(); }

	public function _parseSqlWhere($params = []) { return $this->_userProcessAcl->_parseSqlWhere($params); }

	public function getItems($params = []) {
		$bupLimit = V::get('limit', 0, $params);
		$params['limit'] = 0;
		$items = $this->_userProcessAcl->getItems($params);
		if (empty($items)) return $items;

		$params['limit'] = $bupLimit;

		$sqlWhereAnd[] = "t.ID_PROCES_INIT in (" . implode(",", array_keys($items)) . ")";
		// if ($max_age > 0) {
		//	 $sqlWhereAnd[] = "COALESCE(UNIX_TIMESTAMP(t.`TEST_END`), 0) > (UNIX_TIMESTAMP(NOW()) - {$max_age})";
		// }
		$sqlWhereAnd = (!empty($sqlWhereAnd)) ? "and " . implode("\n and ", $sqlWhereAnd) : '';
		$idUser = $this->idUser;
		$wynikiTeoret = DB::getPDO()->fetchAllByKey("
			select test.ID
				,	test.ID_PROCES_INIT
				,	test.OCENA
				,	test.A_STATUS
				,	test.TEST_TYPE
				,	test.TEST_END
			from CRM_TESTY test
			where test.ID in(
				select MAX(t.ID) as ID
				from CRM_TESTY t
				where t.`ID_TESTER`='{$idUser}'
					and t.TEST_TYPE = 'TEORETYCZNY'
					{$sqlWhereAnd}
				group by t.ID_PROCES_INIT
			)
		", 'ID_PROCES_INIT');
		DBG::log($wynikiTeoret, 'array', "\$wynikiTeoret");
		$wynikiPraktyczne = DB::getPDO()->fetchAllByKey("
			select test.ID
				,	test.ID_PROCES_INIT
				,	test.OCENA
				,	test.A_STATUS
				,	test.TEST_TYPE
				,	test.TEST_END
			from CRM_TESTY test
			where test.ID in(
				select MAX(t.ID) as ID
				from CRM_TESTY t
				where t.`ID_TESTER`='{$idUser}'
					and t.TEST_TYPE = 'PRAKTYCZNY'
					{$sqlWhereAnd}
				group by t.ID_PROCES_INIT
			)
		", 'ID_PROCES_INIT');
		DBG::log($wynikiPraktyczne, 'array', "\$wynikiPraktyczne");

		$limit = V::get('limit', 0, $params);
		$limit = ($limit < 0) ? 0 : $limit;
		$offset = V::get('limitstart', 0, $params);
		$offset = ($offset < 0) ? 0 : $offset;
		$items = array_slice($items, $offset, ($limit > 0) ? $limit : null, $preserve_keys = true);
		if (empty($items)) return $items;

		$testyLastUpdate = DB::getPDO()->fetchAllByKey("
			select i.idx_PROCES_INIT_ID as ID, max(p.`A_RECORD_UPDATE_DATE`) as max_update_date
			from CRM_PROCES p
				join CRM_PROCES_idx i on(i.ID_PROCES = p.ID)
			where i.idx_PROCES_INIT_ID in (" . implode(",", array_keys($items)) . ")
			group by i.idx_PROCES_INIT_ID
		", 'ID');
		DBG::log($testyLastUpdate, 'array', "\$testyLastUpdate");
		DBG::log($items, 'array', "\$items...");

		array_walk($items, function(&$item, $key) use ($wynikiTeoret, $wynikiPraktyczne, $testyLastUpdate) {
			$item['link_uruchom_test_teoretyczny'] = Request::getPathUri() . "procesy5.php?task=CRM_TESTY__ADD_TEST&test_type=TEORETYCZNY&proces_id={$item['ID']}";

			$item['wynik_teoretyczny_value'] = (array_key_exists($item['ID'], $wynikiTeoret)) ? $wynikiTeoret[ $item['ID'] ][ 'OCENA' ] : 0;
			$item['wynik_teoretyczny'] = ProcesTestyHelper::getOcenaLabel($item['wynik_teoretyczny_value']);
			$wynik_praktyczny_value = (array_key_exists($item['ID'], $wynikiPraktyczne)) ? $wynikiPraktyczne[ $item['ID'] ][ 'OCENA' ] : 0;
			$item['wynik_praktyczny'] = ProcesTestyHelper::getOcenaLabel($wynik_praktyczny_value);
			$item['wynik_unactual'] = '';
			$item['wynik_unactual_id'] = '';
			$item['link_popraw_test'] = '';
			$item['last_test_end'] = '';
			$item['last_update_date'] = (array_key_exists($item['ID'], $testyLastUpdate)) ? $testyLastUpdate[ $item['ID'] ][ 'max_update_date' ] : null;
			if (array_key_exists($item['ID'], $wynikiTeoret)) {
				$test = $wynikiTeoret[ $item['ID'] ];
				$item['last_test_end'] = $test['TEST_END'];

				$max_update_date = DB::getPDO()->fetchValue("
					select max(p.`A_RECORD_UPDATE_DATE`) as max_update_date
					from `CRM_PROCES` as p
					where p.`ID` in(
						select i.`ID_PROCES`
							from `CRM_PROCES_idx` i
							where i.`idx_PROCES_INIT_ID`='{$item['ID']}'
					)
				");
				if ($item['last_update_date']) {
					$max_update_date = substr($item['last_update_date'], 0, 10);
					$test_end = substr($item['last_test_end'], 0, 10);
					if ($max_update_date > $test_end) {
						$item['wynik_unactual'] = $max_update_date;
						$item['wynik_unactual_id'] = $test['ID'];
						$item['link_popraw_test'] = "procesy5.php?task=CRM_TESTY__ADD_TEST&function_init=fun_CRM_TESTY__ADD_FIX&test_id={$test['ID']}";
					}
				}
			}
		});

		return $items;
	}

}