updateSelectedPostTask();
case 'forceUpdateSelected': return $this->forceUpdateSelectedPostTask();
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 {$totalSelected} 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 {$totalToUpdateClients}"),
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 forceUpdateSelectedPostTask() {
$sqlSelected = FeatureAttrSelected::getAllSelectedAsSqlSubQuery($typeName = "default_db/USERS2_WINDYKACJA_STATUS");
DB::getPDO()->execSql("
update USERS2_WINDYKACJA_STATUS t
set t.A_STATUS_UPDATE_DATE = :yesterday
where t.ID in ( {$sqlSelected} )
", [
':yesterday' => date("Y-m-d", mktime(0,0,0, date("m"), date("d") - 1, date("Y")))
]);
UI::layout([ $this, 'updateSelectedPostTaskView' ]);
}
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"),
'ALLOW_FORCE_UPDATE' => User::isAdmin(),
'FORCE_UPDATE_POST_DATA' => User::isAdmin() ? [ '_postTask' => 'forceUpdateSelected' ] : null,
]);
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 {$totalToUpdateClients}"),
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);
DBG::log([ '$toUpdateClientID' => $toUpdateClientID, 'user' => $user ], 'array', "DBG:updateOneFromSelectedAjaxTask");
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,
],
];
}
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,
],
];
}
}