|
|
@@ -1807,14 +1807,13 @@ SQL;
|
|
|
try {
|
|
|
$query = "select count(*) from `BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA` where `FILE_STATUS` = 'IN_PROGRESS' and `BI_analiza_reloadCache` = 'Part' and ID != ${ID}";
|
|
|
$sqlArr = [
|
|
|
- 'ID' => $ID,
|
|
|
'BI_analiza_reloadCache' => 'Part',
|
|
|
'FILE_STATUS_info' => 'Odświeżam częściowo cache',
|
|
|
];
|
|
|
do {
|
|
|
DB::getPDO()->query("lock tables `BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA` write");
|
|
|
$activeReloadingCache = DB::getPDO()->fetchValue($query);
|
|
|
- if (!$activeReloadingCache) DB::getDB()->UPDATE_OBJ('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', $sqlArr);
|
|
|
+ if (!$activeReloadingCache) DB::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
DB::getPDO()->query("unlock tables");
|
|
|
if ($activeReloadingCache) {
|
|
|
BiAuditPowiazania::saveToLog("Czekam na zakończenie częściowego odświeżania cache przez inne zadanie");
|
|
|
@@ -1826,9 +1825,11 @@ SQL;
|
|
|
self::doReloadCache();
|
|
|
BiAuditPowiazania::saveToLog("Odświeżono częściowo cache");
|
|
|
|
|
|
- $sqlArr['BI_analiza_reloadCache'] = 'No';
|
|
|
- $sqlArr['FILE_STATUS_info'] = 'Zakończono odświeżanie cache i wyzwolono funkcję szukania powiązań';
|
|
|
- DB::getDB()->UPDATE_OBJ('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', $sqlArr);
|
|
|
+ $sqlArr = [
|
|
|
+ 'BI_analiza_reloadCache' => 'No',
|
|
|
+ 'FILE_STATUS_info' => 'Zakończono odświeżanie cache i wyzwolono funkcję szukania powiązań',
|
|
|
+ ];
|
|
|
+ DB::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
|
$BiAuditPowiazania = new BiAuditPowiazania($ID, $tasksDirLocation);
|
|
|
if (!$BiAuditPowiazania->powiazaniaFound()) throw new Exception("Nie znaleziono żadnych powiązań");
|