shopware / SwagConnect

    /**

     * @return array

     */

    public function fetchConnectStreamIds()

    {

        $builder = $this->manager->getConnection()->createQueryBuilder();

        $results = $builder->select('sa.streamID')

            ->from('s_product_streams_attributes', 'sa')

            ->where('sa.connect_is_remote = 1')

            ->execute()

            ->fetchAll();

        return array_map(function ($item) {

            return $item['streamID'];

        }, $results);

    }

    /**

     * @param int|array $streamId

     * @param array $orderNumbers

     * @return array

     */

    public function getArticleIdsByNumber(array $orderNumbers)

    {

        $builder = $this->manager->getConnection()->createQueryBuilder();

        $rows = $builder->select('d.articleID as articleId')

            ->from('s_articles_details', 'd')

            ->where('d.ordernumber IN (:orderNumbers)')

            ->setParameter('orderNumbers', $orderNumbers, \Doctrine\DBAL\Connection::PARAM_STR_ARRAY)

            ->execute()

            ->fetchAll();

        return array_map(function ($row) {

            return $row['articleId'];

        }, $rows);

    }

    /**

     * Returns article detail model by

    /**

     * @return array

     */

    public function getAllNonConnectArticleIds()

    {

        $builder = $this->manager->getConnection()->createQueryBuilder();

        $builder->select('DISTINCT spci.article_id');

        $builder->from('s_plugin_connect_items', 'spci');

        $builder->where('spci.shop_id IS NULL');

        $result = $builder->execute()->fetchAll();

        return array_map(function ($row) {

            return $row['article_id'];

        }, $result);

    }

}