mirror of
https://github.com/OpenXE-org/OpenXE.git
synced 2024-12-25 06:00:28 +01:00
271 lines
9.5 KiB
PHP
271 lines
9.5 KiB
PHP
<?php
|
|
|
|
use Xentral\Components\Logger\Logger;
|
|
|
|
/** @var Logger $logger */
|
|
$logger = $app->Container->get('Logger');
|
|
|
|
if (file_exists(dirname(__DIR__) . '/www/lib/class.erpapi_custom.php') && !class_exists('erpAPICustom')) {
|
|
include_once dirname(__DIR__) . '/www/lib/class.erpapi_custom.php';
|
|
}
|
|
if (empty($app->Conf)) {
|
|
$conf = new Config();
|
|
$app->Conf = $conf;
|
|
}
|
|
if (empty($app->DB) || empty($app->DB->connection)) {
|
|
$app->DB = new DB($app->Conf->WFdbhost, $app->Conf->WFdbname, $app->Conf->WFdbuser, $app->Conf->WFdbpass, null, $app->Conf->WFdbport);
|
|
}
|
|
if (!isset($app->erp) || !$app->erp) {
|
|
if (class_exists('erpAPICustom')) {
|
|
$erp = new erpAPICustom($app);
|
|
} else {
|
|
$erp = new erpAPI($app);
|
|
}
|
|
$app->erp = $erp;
|
|
}
|
|
if (empty($app->remote)) {
|
|
if (is_file(dirname(__DIR__) . '/www/lib/class.remote_custom.php')) {
|
|
if (!class_exists('RemoteCustom')) {
|
|
require_once dirname(__DIR__) . '/www/lib/class.remote_custom.php';
|
|
}
|
|
$app->remote = new RemoteCustom($app);
|
|
} else {
|
|
$app->remote = new Remote($app);
|
|
}
|
|
}
|
|
|
|
$logger->debug(
|
|
'Start'
|
|
);
|
|
|
|
$app->DB->Update(
|
|
"UPDATE `prozessstarter`
|
|
SET `mutexcounter` = `mutexcounter` + 1
|
|
WHERE `mutex` = 1 AND (`parameter` = 'artikeluebertragen') AND `aktiv` = 1"
|
|
);
|
|
|
|
if ($app->DB->Select("SELECT `mutex` FROM `prozessstarter` WHERE (`parameter` = 'artikeluebertragen') LIMIT 1") == 1) {
|
|
$logger->debug(
|
|
'Läuft bereits'
|
|
);
|
|
return;
|
|
}
|
|
|
|
$articles = $app->DB->SelectArr(
|
|
'SELECT `id`,`shop`,`artikel` FROM `shopexport_artikeluebertragen_check` ORDER BY `id`'
|
|
);
|
|
if (!empty($articles)) {
|
|
/** @var Shopexport $objShopexport */
|
|
$objShopexport = $app->loadModule('shopexport');
|
|
if ($objShopexport !== null && method_exists($objShopexport, 'addChangedArticles')) {
|
|
$objShopexport->addChangedArticles();
|
|
}
|
|
}
|
|
|
|
$logger->debug(
|
|
'Prepare',
|
|
[
|
|
'articles' => $articles
|
|
]
|
|
);
|
|
|
|
$anzChecked = [];
|
|
$anzChanged = [];
|
|
$lastids = [];
|
|
while (!empty($articles)) {
|
|
foreach ($articles as $article) {
|
|
if (empty($anzChanged[$article['shop']])) {
|
|
$anzChanged[$article['shop']] = 0;
|
|
}
|
|
if (empty($anzChecked[$article['shop']])) {
|
|
$anzChecked[$article['shop']] = 0;
|
|
}
|
|
if (!isset($lastids[$article['shop']])) {
|
|
$lastids[$article['shop']] = (int) $app->erp->GetKonfiguration(
|
|
'shopexport_artikeluebertragen_check_lastid_' . $article['shop']
|
|
);
|
|
}
|
|
$changed = $objShopexport->hasArticleHashChanged($article['artikel'], $article['shop']);
|
|
if ($changed['changed']) {
|
|
$app->DB->Insert(
|
|
sprintf(
|
|
'INSERT INTO `shopexport_artikeluebertragen` (`artikel`, `shop`, `check_nr`) VALUES (%d, %d, %d)',
|
|
$article['artikel'], $article['shop'], $lastids[$article['shop']]
|
|
)
|
|
);
|
|
$anzChanged[$article['shop']]++;
|
|
}
|
|
$anzChecked[$article['shop']]++;
|
|
$app->DB->Delete(
|
|
sprintf(
|
|
'DELETE FROM `shopexport_artikeluebertragen_check` WHERE `id` = %d',
|
|
$article['id']
|
|
)
|
|
);
|
|
$app->DB->Update(
|
|
sprintf(
|
|
"UPDATE `shopexport` SET `autosendarticle_last` = NOW() WHERE `id` = %d",
|
|
$article['shop']
|
|
)
|
|
);
|
|
}
|
|
$app->erp->SetKonfigurationValue(
|
|
'shopexport_artikeluebertragen_check_changed_' . $article['shop'],
|
|
$anzChanged[$article['shop']]
|
|
);
|
|
$app->erp->SetKonfigurationValue(
|
|
'shopexport_artikeluebertragen_check_checked_' . $article['shop'],
|
|
$anzChecked[$article['shop']]
|
|
);
|
|
if (method_exists($app->erp, 'canRunCronjob') && !$app->erp->canRunCronjob(['artikeluebertragen'])) {
|
|
$logger->debug(
|
|
'!canRunCronjob'
|
|
);
|
|
return;
|
|
}
|
|
$articles = $app->DB->SelectArr(
|
|
'SELECT `id`,`shop`,`artikel` FROM `shopexport_artikeluebertragen_check` ORDER BY `id` LIMIT 10'
|
|
);
|
|
$app->DB->Update(
|
|
"UPDATE `prozessstarter`
|
|
SET `letzteausfuerhung`=NOW(), `mutex` = 1,`mutexcounter`=0
|
|
WHERE `parameter` = 'artikeluebertragen'"
|
|
);
|
|
}
|
|
|
|
$check = $app->DB->Select('SELECT COUNT(`id`) FROM `shopexport_artikeluebertragen`');
|
|
$app->DB->Update(
|
|
"UPDATE `prozessstarter`
|
|
SET `letzteausfuerhung`=NOW(), `mutex` = 1,`mutexcounter`=0
|
|
WHERE `parameter` = 'artikeluebertragen'"
|
|
);
|
|
|
|
/*
|
|
while ($check > 0) {
|
|
$shopartikel = $app->DB->Query(
|
|
"SELECT `id`,`shop`,`artikel`,`check_nr` FROM `shopexport_artikeluebertragen` ORDER BY `id` LIMIT 10"
|
|
);
|
|
if (!empty($shopartikel)) {
|
|
$anz = 0;
|
|
while ($row = $app->DB->Fetch_Assoc($shopartikel)) {
|
|
if (!isset($lastids[$row['shop']])) {
|
|
$lastids[$row['shop']] = (int) $app->erp->GetKonfiguration('shopexport_artikeluebertragen_check_lastid_' . $row['shop']);
|
|
}
|
|
|
|
$anz++;
|
|
try {
|
|
$app->remote->RemoteSendArticleList($row['shop'], array($row['artikel']));
|
|
$app->erp->LagerSync($row['artikel'], true);
|
|
} catch (Execption $exception) {
|
|
$app->erp->LogFile($app->DB->real_escape_string($exception->getMessage()));
|
|
}
|
|
$app->DB->Delete(
|
|
sprintf(
|
|
'DELETE FROM `shopexport_artikeluebertragen` WHERE `id`= %d LIMIT 1',
|
|
$row['id']
|
|
)
|
|
);
|
|
|
|
if (!empty($row['check_nr']) && $row['check_nr'] == $lastids[$row['shop']]) {
|
|
$transfered = 1 + (int) $app->erp->GetKonfiguration('shopexport_artikeluebertragen_check_transfered_' . $row['shop']);
|
|
$app->erp->SetKonfigurationValue('shopexport_artikeluebertragen_check_transfered_' . $row['shop'], $transfered);
|
|
}
|
|
|
|
$app->DB->Update(
|
|
"UPDATE `prozessstarter`
|
|
SET `letzteausfuerhung`=NOW(), `mutex` = 1,`mutexcounter`=0
|
|
WHERE `parameter` = 'artikeluebertragen'"
|
|
);
|
|
}
|
|
|
|
$app->DB->free($shopartikel);
|
|
}
|
|
|
|
if (method_exists($app->erp, 'canRunCronjob') && !$app->erp->canRunCronjob(['artikeluebertragen'])) {
|
|
return;
|
|
}
|
|
|
|
$check = $app->DB->Select('SELECT COUNT(`id`) FROM `shopexport_artikeluebertragen`');
|
|
}*/
|
|
|
|
|
|
$sql = "SELECT DISTINCT `shop`, shopexport.`bezeichnung` FROM `shopexport_artikeluebertragen` INNER JOIN shopexport ON shopexport.id = `shop`";
|
|
$shops_to_transmit = $app->DB->SelectArr($sql);
|
|
|
|
//$app->erp->LogFile('Cronjob artikeluebertragen '.(!empty($shops_to_transmit)?count($shops_to_transmit):0)." shops", print_r($shops_to_transmit, true));
|
|
$logger->debug(
|
|
'{count} Shops',
|
|
[
|
|
'count' => (!empty($shops_to_transmit)?count($shops_to_transmit):0),
|
|
'shops_to_transmit' => $shops_to_transmit
|
|
]
|
|
);
|
|
|
|
foreach ($shops_to_transmit as $shop_to_transmit) {
|
|
$sql = "SELECT `artikel` FROM `shopexport_artikeluebertragen` WHERE `shop` = '".$shop_to_transmit['shop']."'";
|
|
$articles_to_transmit = $app->DB->SelectArr($sql);
|
|
|
|
$logger->debug(
|
|
'{bezeichnung} (Shop {shop_to_transmit}) {count} Artikel',
|
|
[
|
|
'shop_to_transmit' => $shop_to_transmit['shop'],
|
|
'bezeichnung' => $shop_to_transmit['bezeichnung'],
|
|
'count' => (!empty($articles_to_transmit)?count($articles_to_transmit):0),
|
|
'articles_to_transmit' => $articles_to_transmit
|
|
]
|
|
);
|
|
|
|
if (!empty($articles_to_transmit)) {
|
|
|
|
$article_ids_to_transmit = array_column($articles_to_transmit, 'artikel');
|
|
|
|
try {
|
|
$result = $app->remote->RemoteSendArticleList($shop_to_transmit['shop'], $article_ids_to_transmit); // Expected result is array $articles_to_transmit, field status contains transmission status
|
|
} catch (Execption $exception) {
|
|
$logger->error(
|
|
'Fehler {bezeichnung} (Shop {shop_to_transmit}) {count} Artikel',
|
|
[
|
|
'shop_to_transmit' => $shop_to_transmit['shop'],
|
|
'bezeichnung' => $shop_to_transmit['bezeichnung'],
|
|
'count' => (!empty($articles_to_transmit)?count($articles_to_transmit):0),
|
|
'exception' => $exception
|
|
]
|
|
);
|
|
}
|
|
|
|
$logger->debug(
|
|
'Ende {bezeichnung} (Shop {shop_to_transmit}) {count} Artikel',
|
|
[
|
|
'shop_to_transmit' => $shop_to_transmit['shop'],
|
|
'bezeichnung' => $shop_to_transmit['bezeichnung'],
|
|
'count' => (!empty($articles_to_transmit)?count($articles_to_transmit):0),
|
|
'result' => $result
|
|
]
|
|
);
|
|
|
|
// See description of return format in function class.remote.php -> RemoteSendArticleList()
|
|
foreach ($result['articlelist'] as $article) {
|
|
$app->DB->Delete(
|
|
sprintf(
|
|
'DELETE FROM `shopexport_artikeluebertragen` WHERE `artikel`= %d AND `shop` = %d',
|
|
$article['artikel'],
|
|
$shop_to_transmit['shop']
|
|
)
|
|
);
|
|
$app->erp->LagerSync($article['artikel'], true);
|
|
}
|
|
} else {
|
|
|
|
}
|
|
}
|
|
|
|
$logger->debug(
|
|
'Ende'
|
|
);
|
|
|
|
$app->DB->Update(
|
|
"UPDATE `prozessstarter`
|
|
SET `letzteausfuerhung`= NOW(), `mutex` = 0,`mutexcounter`=0
|
|
WHERE `parameter` = 'artikeluebertragen'"
|
|
);
|