* @link http://www.oxidmodule.com */ namespace D3\Ordermanager\Application\Model; use D3\ModCfg\Application\Model\Configuration\d3_cfg_mod; use D3\ModCfg\Application\Model\Configuration\d3modprofilelist; use D3\ModCfg\Application\Model\d3utils; use D3\ModCfg\Application\Model\Exception\d3_cfg_mod_exception; use D3\ModCfg\Application\Model\Exception\d3ShopCompatibilityAdapterException; use Doctrine\DBAL\DBALException; use Doctrine\DBAL\ParameterType; use Doctrine\DBAL\Query\QueryBuilder; use Exception; use OxidEsales\Eshop\Core\Exception\DatabaseConnectionException; use OxidEsales\Eshop\Core\Exception\DatabaseErrorException; use OxidEsales\Eshop\Core\Exception\StandardException; use OxidEsales\EshopCommunity\Internal\Container\ContainerFactory; use OxidEsales\EshopCommunity\Internal\Framework\Database\QueryBuilderFactoryInterface; use Psr\Container\ContainerInterface; class d3ordermanagerlist extends d3modprofilelist { /** * List Object class name * * @var string */ protected $_sObjectsInListName = d3ordermanager::class; /** * @param $sFolderId * @return d3ordermanagerlist * @throws DBALException * @throws DatabaseConnectionException * @throws DatabaseErrorException * @throws StandardException * @throws d3ShopCompatibilityAdapterException * @throws d3_cfg_mod_exception * @throws Exception */ public function d3GetManuallyManagerJobsByFolder($sFolderId) { /** @var d3ordermanager $oListObject */ $oListObject = $this->getBaseObject(); $fieldList = array_map('trim', explode(',', $oListObject->getSelectFields())); /** @var QueryBuilder $queryBuilder */ $queryBuilder = $this->getDIContainer()->get(QueryBuilderFactoryInterface::class)->create(); $queryBuilder->select($fieldList) ->from($oListObject->getViewName()) ->orderBy($oListObject->getViewName().".oxsort", "ASC") ->addOrderBy($oListObject->getViewName().".oxfolder", "ASC"); $queryBuilder = $this->d3AddActiveSnippet($oListObject, $queryBuilder, true, false); $queryBuilder = $this->d3AddFolderSelection($sFolderId, $oListObject, $queryBuilder); $this->selectString($queryBuilder->getSQL(), $queryBuilder->getParameters()); /** @var $oManager d3ordermanager */ foreach ($this->getArray() as $sKey => $oManager) { if (false == $this->canExecutedManually($oManager)) { $this->offsetUnset($sKey); } } return $this; } /** * @return d3ordermanagerlist * @throws DBALException * @throws DatabaseConnectionException * @throws DatabaseErrorException * @throws StandardException * @throws d3ShopCompatibilityAdapterException * @throws d3_cfg_mod_exception * @throws Exception */ public function d3GetOrderSaveTriggeredManagerTasks() { if ($this->d3GetSet()->isDemo() || in_array( true, array_map(array($this->d3GetSet(),'getLicenseConfigData'),array(d3ordermanager_conf::SERIAL_BIT_STANDARD_EDITION)) ) ) { /** @var d3ordermanager $oListObject */ $oListObject = $this->getBaseObject(); $fieldList = array_map('trim', explode(',', $oListObject->getSelectFields())); /** @var QueryBuilder $queryBuilder */ $queryBuilder = $this->getDIContainer()->get(QueryBuilderFactoryInterface::class)->create(); $queryBuilder->select($fieldList) ->from($oListObject->getViewName()) ->where( $queryBuilder->expr()->eq( $oListObject->getViewName() . '.D3_OM_ORDERSAVETRIGGERED', $queryBuilder->createNamedParameter(1) ) ) ->orderBy($oListObject->getViewName() . ".oxsort", 'ASC') ->addOrderBy($oListObject->getViewName() . ".oxfolder", "ASC"); $queryBuilder = $this->d3AddActiveSnippet($oListObject, $queryBuilder, true, false); $this->selectString($queryBuilder->getSQL(), $queryBuilder->getParameters()); /** @var $oManager d3ordermanager */ foreach ($this->getArray() as $sKey => $oManager) { if (false == $oManager->getLicenseActive()) { $this->offsetUnset($sKey); } } } return $this; } /** * @return $this * @throws DBALException * @throws DatabaseConnectionException * @throws DatabaseErrorException * @throws StandardException * @throws d3ShopCompatibilityAdapterException * @throws d3_cfg_mod_exception * @throws Exception */ public function d3GetOrderFinishTriggeredManagerTasks() { if ($this->d3GetSet()->isDemo() || in_array( true, array_map(array($this->d3GetSet(),'getLicenseConfigData'),array(d3ordermanager_conf::SERIAL_BIT_STANDARD_EDITION)) ) ) { /** @var d3ordermanager $oListObject */ $oListObject = $this->getBaseObject(); $fieldList = array_map('trim', explode(',', $oListObject->getSelectFields())); /** @var QueryBuilder $queryBuilder */ $queryBuilder = $this->getDIContainer()->get(QueryBuilderFactoryInterface::class)->create(); $queryBuilder->select($fieldList) ->from($oListObject->getViewName()) ->where( $queryBuilder->expr()->eq( $oListObject->getViewName() . '.D3_OM_ORDERFINISHTRIGGERED', $queryBuilder->createNamedParameter(1) ) ) ->orderBy($oListObject->getViewName() . ".oxsort", 'ASC') ->addOrderBy($oListObject->getViewName() . ".oxfolder", 'ASC'); $queryBuilder = $this->d3AddActiveSnippet($oListObject, $queryBuilder, true, false); $this->selectString($queryBuilder->getSQL(), $queryBuilder->getParameters()); /** @var $oManager d3ordermanager */ foreach ($this->getArray() as $sKey => $oManager) { if (false == $oManager->getLicenseActive()) { $this->offsetUnset($sKey); } } } return $this; } /** * @param d3ordermanager $oManager * * @return bool * @throws DatabaseConnectionException * @throws d3ShopCompatibilityAdapterException * @throws d3_cfg_mod_exception * @throws DBALException * @throws DatabaseErrorException * @throws StandardException */ public function canExecutedManually(d3ordermanager $oManager) { return $oManager->getFieldData('D3_OM_EXECMANUALLY') && $oManager->getLicenseActive(); } /** * @param d3ordermanager $oListObject * @param QueryBuilder $queryBuilder * @param bool $blManually * @param bool $blUseCommonActiveCheck * * @return QueryBuilder * @throws DatabaseConnectionException * @throws Exception */ public function d3AddActiveSnippet(d3ordermanager $oListObject, QueryBuilder $queryBuilder, $blManually = false, $blUseCommonActiveCheck = true) { $sActiveSnippet = $oListObject->getSqlActiveSnippet(); /** @var d3utils $d3Utils */ $d3Utils = d3GetModCfgDIC()->get(d3utils::class); if ($blUseCommonActiveCheck && $sActiveSnippet) { $queryBuilder->andWhere($sActiveSnippet); } if ($blManually) { $sFieldName = $d3Utils->getMultiLangFieldName( 'D3_OM_EXECMANUALLY', '', $oListObject ); } else { $sFieldName = $d3Utils->getMultiLangFieldName( 'oxactive', '', $oListObject ); } $queryBuilder->andWhere( $queryBuilder->expr()->eq( $oListObject->getViewName() . "." . $sFieldName, $queryBuilder->createNamedParameter(1, ParameterType::INTEGER) ) ); return $queryBuilder; } /** * @param $sFolderId * @param d3ordermanager $oListObject * @param QueryBuilder $queryBuilder * * @return QueryBuilder */ public function d3AddFolderSelection($sFolderId, d3ordermanager $oListObject, QueryBuilder $queryBuilder) { if ($sFolderId && $sFolderId != '-1') { $queryBuilder->andWhere( $queryBuilder->expr()->eq( $oListObject->getViewName() . ".oxfolder", $queryBuilder->createNamedParameter($sFolderId) ) ); } return $queryBuilder; } /** * @param bool|string $iCronJobId */ public function setCronJobId($iCronJobId) { /** @var d3ordermanager $oBaseObject */ $oBaseObject = $this->getBaseObject(); $oBaseObject->setCronJobIdFilter($iCronJobId); } /** * @return d3_cfg_mod * @throws Exception */ public function d3GetSet() { return d3GetModCfgDIC()->get('d3.ordermanager.modcfg'); } /** * @return ContainerInterface */ public function getDIContainer() { return ContainerFactory::getInstance()->getContainer(); } }