|
@@ -3132,7 +3132,7 @@ SQL;
|
|
|
$resultFile = "{$tasksDirLocation}/generatePowiazania-{$ID}.result";
|
|
$resultFile = "{$tasksDirLocation}/generatePowiazania-{$ID}.result";
|
|
|
$xmlFile = "{$tasksDirLocation}/generatePowiazania-{$ID}.xml";
|
|
$xmlFile = "{$tasksDirLocation}/generatePowiazania-{$ID}.xml";
|
|
|
$pidFile = "{$tasksDirLocation}/generatePowiazania-{$ID}.pid";
|
|
$pidFile = "{$tasksDirLocation}/generatePowiazania-{$ID}.pid";
|
|
|
- file_put_contents($pidFile, getmypid());
|
|
|
|
|
|
|
+ if (!$debug) file_put_contents($pidFile, getmypid());
|
|
|
|
|
|
|
|
/* $tablesConf = [
|
|
/* $tablesConf = [
|
|
|
'BI_audit_CEIDG' => ['ID', 'imie', 'nazwisko', 'nip', 'regon', 'firma', 'miejscowosc'],
|
|
'BI_audit_CEIDG' => ['ID', 'imie', 'nazwisko', 'nip', 'regon', 'firma', 'miejscowosc'],
|
|
@@ -3150,44 +3150,48 @@ SQL;
|
|
|
try {
|
|
try {
|
|
|
$BiAuditPowiazania = new BiAuditPowiazania($ID, $tasksDirLocation);
|
|
$BiAuditPowiazania = new BiAuditPowiazania($ID, $tasksDirLocation);
|
|
|
|
|
|
|
|
- $query = "select count(*) from `BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA` where `FILE_STATUS` = 'IN_PROGRESS' and `BI_analiza_reloadCache` in ('Part', 'Full') and ID != ${ID}";
|
|
|
|
|
- $sqlArr = [
|
|
|
|
|
- '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::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
- DB::getPDO()->query("unlock tables");
|
|
|
|
|
- if ($activeReloadingCache) {
|
|
|
|
|
- BiAuditPowiazania::saveToLog("Czekam na zakończenie odświeżania cache przez inne zadanie");
|
|
|
|
|
- sleep(30);
|
|
|
|
|
- }
|
|
|
|
|
- } while ($activeReloadingCache);
|
|
|
|
|
-
|
|
|
|
|
- BiAuditPowiazania::saveToLog("Uruchamiam częściowe odświeżenie cache");
|
|
|
|
|
- if (!$debug) $this->doReloadCache(); //DUPA testowe wylaczanie
|
|
|
|
|
- BiAuditPowiazania::saveToLog("Odświeżono cache");
|
|
|
|
|
|
|
+ if (!$debug) {
|
|
|
|
|
+ $query = "select count(*) from `BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA` where `FILE_STATUS` = 'IN_PROGRESS' and `BI_analiza_reloadCache` in ('Part', 'Full') and ID != ${ID}";
|
|
|
|
|
+ $sqlArr = [
|
|
|
|
|
+ '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::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
+ DB::getPDO()->query("unlock tables");
|
|
|
|
|
+ if ($activeReloadingCache) {
|
|
|
|
|
+ BiAuditPowiazania::saveToLog("Czekam na zakończenie odświeżania cache przez inne zadanie");
|
|
|
|
|
+ sleep(30);
|
|
|
|
|
+ }
|
|
|
|
|
+ } while ($activeReloadingCache);
|
|
|
|
|
|
|
|
- $sqlArr = [
|
|
|
|
|
- 'BI_analiza_reloadCache' => 'No',
|
|
|
|
|
- 'FILE_STATUS_info' => 'Szukam powiązań',
|
|
|
|
|
- ];
|
|
|
|
|
- DB::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
|
|
+ BiAuditPowiazania::saveToLog("Uruchamiam częściowe odświeżenie cache");
|
|
|
|
|
+ $this->doReloadCache(); //DUPA testowe wylaczanie
|
|
|
|
|
+ BiAuditPowiazania::saveToLog("Odświeżono cache");
|
|
|
|
|
+
|
|
|
|
|
+ $sqlArr = [
|
|
|
|
|
+ 'BI_analiza_reloadCache' => 'No',
|
|
|
|
|
+ 'FILE_STATUS_info' => 'Szukam powiązań',
|
|
|
|
|
+ ];
|
|
|
|
|
+ DB::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
$BiAuditPowiazania->run($debug);
|
|
$BiAuditPowiazania->run($debug);
|
|
|
//if (!$BiAuditPowiazania->powiazaniaFound()) throw new Exception("Nie znaleziono żadnych powiązań");
|
|
//if (!$BiAuditPowiazania->powiazaniaFound()) throw new Exception("Nie znaleziono żadnych powiązań");
|
|
|
//file_put_contents($xmlFile, $BiAuditPowiazania->asXml());
|
|
//file_put_contents($xmlFile, $BiAuditPowiazania->asXml());
|
|
|
|
|
|
|
|
- $sqlArr = ['FILE_STATUS_info' => 'Generuję raporty PDF i HTML'];
|
|
|
|
|
- DB::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
|
|
+ if (!$debug) {
|
|
|
|
|
+ $sqlArr = ['FILE_STATUS_info' => 'Generuję raporty PDF i HTML'];
|
|
|
|
|
+ DB::getPDO()->update('BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA', "ID", $ID, $sqlArr);
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
//$BiAuditPowiazania->saveXml();
|
|
//$BiAuditPowiazania->saveXml();
|
|
|
$BiAuditPowiazania->generatePdfAndHtml();
|
|
$BiAuditPowiazania->generatePdfAndHtml();
|
|
|
- file_put_contents($resultFile, json_encode(['result' => 'ok', 'parts' => $BiAuditPowiazania->getPartsCount()]));
|
|
|
|
|
|
|
+ if (!$debug) file_put_contents($resultFile, json_encode(['result' => 'ok', 'parts' => $BiAuditPowiazania->getPartsCount()]));
|
|
|
} catch (Exception $e) {
|
|
} catch (Exception $e) {
|
|
|
- file_put_contents($resultFile, json_encode(['result' => 'error', 'message' => $e->getMessage()]));
|
|
|
|
|
|
|
+ if (!$debug) file_put_contents($resultFile, json_encode(['result' => 'error', 'message' => $e->getMessage()]));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|