se/SE/se-lib/Route/UrlAction/WindykacjaUpdateStatus.php

<?php

Lib::loadClass('RouteBase');
Lib::loadClass('FeatureAttrSelected');
Lib::loadClass('Response');
Lib::loadClass('Windykacja_StatsModel');
Lib::loadClass('Windykacja_StatsHelper');

// Tool with Lock actions on primary key
class Route_UrlAction_WindykacjaUpdateStatus extends RouteBase {

	function defaultAction() {
		$postTask = V::get('_postTask', '', $_POST);
		switch ($postTask) { // PostTask outputs html; TODO: move to WPS functions
			case 'updateSelected': return $this->updateSelectedPostTask();
			case 'updateAll': return $this->updateAllPostTask();
		}

		UI::layout([ $this, 'defaultView' ]);
	}

	function viewTop() {
		echo UI::h('h3', [], "Aktualizacja statusu windykacji klientów");
	}

	function defaultView() {
		$totalSelected = FeatureAttrSelected::getTotalSelected($typeName = "default_db/USERS2_WINDYKACJA_STATUS");
		$totalClients = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
		");
		$totalToUpdateClients = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
			where t.A_STATUS_UPDATE_DATE < :today
		", [
			':today' => date("Y-m-d"),
		]);

		// UI::h('div', [ 'class' => "alert alert-success" ], "Wszystkie wybrane rekordy są aktualne");

		$this->viewTop();
		echo UI::h('div', [ 'style' => "font-size:14px" ], [
			($totalSelected)
			?	UI::h('div', [ 'style' => "margin: 32px 0" ], [
					UI::h('p', [], "Wybrano <b>{$totalSelected}</b> rekordów"),
					UI::hButtonPost("aktualizuj", [
						'class' => "btn-primary",
						'data' => [
							'_route' => "UrlAction_WindykacjaUpdateStatus",
							'_postTask' => "updateSelected",
						]
					]),
				])
			:	'',

			($totalToUpdateClients)
			?	UI::h('div', [ 'style' => "margin: 32px 0" ], [
					UI::h('p', [], "Rekordów wymagających aktualizacji jest <b>{$totalToUpdateClients}</b>"),
					UI::hButtonPost("aktualizuj wszystkie", [
						'class' => "btn-primary",
						'data' => [
							'_route' => "UrlAction_WindykacjaUpdateStatus",
							'_postTask' => "updateAll",
						]
					]),
				])
			:	'',
		]);

		// $selected = FeatureAttrSelected::getAllSelected($typeName = "default_db/USERS2_WINDYKACJA_STATUS");
		// DBG::nicePrint($selected, '$selected');

		if(0){ // text create tasks
			$taskUrl = $this->getLink('testSleep', [ 'sleep' => 10 ]);
			echo UI::h('script', [], "
				var DBG = 0;
				var DBG1 = 1;
				var xhr = new XMLHttpRequest();
	
				xhr.onreadystatechange = function () {
					if (xhr.readyState == 4) {
						DBG1 && console.log('ready state = 4');
					}
				};
	
				xhr.open('GET', '{$taskUrl}', true);
				// xhr.setRequestHeader('Content-type', 'application/json; charset=utf-8');
				xhr.timeout = 1000;
				xhr.ontimeout = function () {
					DBG1 && console.log('Timed out!!!');
				}
				xhr.send();
			");
		}
	}
	function testSleepAction() {
		$totalSleep = V::get('sleep', 2, $_REQUEST);
		while ($totalSleep-- > 0) {
			DBG::log("DBG:testSleep[{$totalSleep}]");
			sleep(1);
		}
		DBG::log("DBG:testSleep::END");
	}

	function updateSelectedPostTask() { UI::layout([ $this, 'updateSelectedPostTaskView' ]); }
	function updateSelectedPostTaskView() {
		$totalSelected = FeatureAttrSelected::getTotalSelected($typeName = "default_db/USERS2_WINDYKACJA_STATUS");

		// - `A_STATUS_UPDATE_DATE`: "Data ostatniej aktualizacji danych"
		// 	- synchronizacja (ręczna, codziennie)
		// 		- [ ] sync on client view (btn just reload): "?MENU_INIT=USERS2_WINDYKACJA_STATUS&q={$q}&_p={$p}&_f={$f}&_user_id={$idUser}"
		// 		- [ ] sync all (partial) ""?MENU_INIT=USERS2_WINDYKACJA_STATUS&task=stats_update"
		// - `LAST_PAY_DATE`: "data ostatniej wpłaty"
		// - `PAY_DATE`: "data wymagalności ostatniej faktury"
		// - `LAST_SMS_MSG_ID`, `LAST_SMS_STATUS`
		// - `LAST_MAIL_MSG_ID`, `LAST_MAIL_STATUS`
		$sqlSelected = FeatureAttrSelected::getAllSelectedAsSqlSubQuery($typeName = "default_db/USERS2_WINDYKACJA_STATUS");
		$totalToUpdateSelected = DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
			where t.ID in ( {$sqlSelected} )
				and t.A_STATUS_UPDATE_DATE < :today
		", [
			':today' => date("Y-m-d"),
		]);
		$totalToUpdateClients = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
			where t.A_STATUS_UPDATE_DATE < :today
		", [
			':today' => date("Y-m-d"),
		]);

		$this->viewTop();
		echo UI::h('div', [ 'class' => "alert alert-info" ], [
			"Zaznaczono {$totalSelected}",
			($totalToUpdateSelected == 0) ? " ale wszystkie są aktualne" : "",
			($totalToUpdateSelected > 0 && $totalToUpdateSelected < $totalSelected) ? " z czego do aktualizacji {$totalToUpdateSelected}." : "",
			($totalToUpdateSelected == $totalSelected) ? ", wszystkie do aktualizacji." : "",
		]);

		// $todoRows = DB::getPDO()->fetchAll("
		// 	select t.ID, t.ID_BILLING_USERS
		// 		, t.A_STATUS_UPDATE_DATE
		// 		, t.LAST_PAY_DATE
		// 		, t.PAY_DATE
		// 		, t.LAST_SMS_MSG_ID
		// 		, t.LAST_MAIL_MSG_ID
		// 	from USERS2_WINDYKACJA_STATUS t
		// 	where t.ID in ( {$sqlSelected} )
		// ");
		// UI::table([ 'caption' => "DBG: Wszystkie zaznaczone rekordy", 'rows' => $todoRows ]);

		echo UI::h('script', ['src'=>"static/vendor.js", 'type'=>"text/javascript"]);
		echo UI::h('div', [ 'id' => "p5-widget-windykacja-status-update" ]);
		UI::inlineJS(__FILE__ . '.view.js', [
			'HTML_ID' => "p5-widget-windykacja-status-update",
			'TOTAL' => $totalSelected,
			'EXECUTE_SINGLE_TASK_URL' => $this->getLink("updateOneFromSelectedAjaxTask"),
		]);

		echo UI::h('div', [ 'style' => "font-size:14px" ], [
			($totalToUpdateClients)
			?	UI::h('div', [ 'style' => "margin: 32px 0" ], [
					UI::h('p', [], "Rekordów wymagających aktualizacji jest <b>{$totalToUpdateClients}</b>"),
					UI::hButtonPost("aktualizuj wszystkie", [
						'class' => "btn-primary",
						'data' => [
							'_route' => "UrlAction_WindykacjaUpdateStatus",
							'_postTask' => "updateAll",
						]
					]),
				])
			:	'',
		]);
	}

	function updateAllPostTask() { UI::layout([ $this, 'updateAllPostTaskView' ]); }
	function updateAllPostTaskView() {
		$totalClients = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
		");

		$this->viewTop();
		echo UI::h('script', ['src'=>"static/vendor.js", 'type'=>"text/javascript"]);
		echo UI::h('div', [ 'id' => "p5-widget-windykacja-status-update" ]);
		UI::inlineJS(__FILE__ . '.view.js', [
			'HTML_ID' => "p5-widget-windykacja-status-update",
			'TOTAL' => $totalClients,
			'EXECUTE_SINGLE_TASK_URL' => $this->getLink("updateOneFromAllAjaxTask"),
		]);
	}

	function updateOneFromSelectedAjaxTaskAction() { Response::sendTryCatchJson([ $this, 'updateOneFromSelectedAjaxTask' ]); }
	function updateOneFromSelectedAjaxTask($args) {
		$total = (int)FeatureAttrSelected::getTotalSelected($typeName = "default_db/USERS2_WINDYKACJA_STATUS");
		$sqlSelected = FeatureAttrSelected::getAllSelectedAsSqlSubQuery($typeName = "default_db/USERS2_WINDYKACJA_STATUS");
		$totalToUpdate = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
			where t.ID in ( {$sqlSelected} )
				and t.A_STATUS_UPDATE_DATE < :today
		", [
			':today' => date("Y-m-d"),
		]);
		$totalDone = $total - $totalToUpdate;
		$percentDone = ($totalDone / $total) * 100;

		{
			$toUpdateClientID = (int)DB::getPDO()->fetchValue("
				select t.ID_BILLING_USERS
				from USERS2_WINDYKACJA_STATUS t
				where t.ID in ( {$sqlSelected} )
					and t.A_STATUS_UPDATE_DATE < :today
				order by ID DESC
				limit 1
			", [
				':today' => date("Y-m-d"),
			]);
			$user = Windykacja_StatsModel::get_user_by_id($toUpdateClientID);
			if ($user) {
				$billing_docs = Windykacja_StatsModel::getBillDocsByDate($user->ID);
				Windykacja_StatsHelper::update_stats($user, $billing_docs);
			}
		}

		return [
			'type' => "success",
			'msg' => "ok",
			'body' => [
				'total' => $total,
				'totalDone' => $totalDone,
				'totalToUpdate' => $totalToUpdate,
				'percentDone' => $percentDone,
			],
		];
	}
	function updateOneFromAllAjaxTaskAction() { Response::sendTryCatchJson([ $this, 'updateOneFromAllAjaxTask' ]); }
	function updateOneFromAllAjaxTask($args) {
		$total = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
		");
		$totalToUpdate = (int)DB::getPDO()->fetchValue("
			select count(*) as total
			from USERS2_WINDYKACJA_STATUS t
			where t.A_STATUS_UPDATE_DATE < :today
		", [
			':today' => date("Y-m-d"),
		]);
		$totalDone = $total - $totalToUpdate;
		$percentDone = ($totalDone / $total) * 100;

		{
			$toUpdateClientListIds = DB::getPDO()->fetchValuesList("
				select t.ID_BILLING_USERS
				from USERS2_WINDYKACJA_STATUS t
				where t.A_STATUS_UPDATE_DATE < :today
				order by ID DESC
				limit 10
			", [
				':today' => date("Y-m-d"),
			]);
			foreach ($toUpdateClientListIds as $toUpdateClientID) {
				$user = Windykacja_StatsModel::get_user_by_id($toUpdateClientID);
				if ($user) {
					$billing_docs = Windykacja_StatsModel::getBillDocsByDate($user->ID);
					Windykacja_StatsHelper::update_stats($user, $billing_docs);
				} else {
					DB::getPDO()->update('USERS2_WINDYKACJA_STATUS', 'ID_BILLING_USERS', $toUpdateClientID, [
						'A_STATUS_UPDATE_DATE' => date("Y-m-d"),
					]);
				}
			}
		}

		return [
			'type' => "success",
			'msg' => "ok",
			'body' => [
				'total' => $total,
				'totalDone' => $totalDone,
				'totalToUpdate' => $totalToUpdate,
				'percentDone' => $percentDone,
			],
		];
	}

}