51 $this->
_init(
'newsletter_queue',
'queue_id');
64 if (count($subscriberIds) == 0) {
65 throw new \Magento\Framework\Exception\LocalizedException(
__(
'There are no subscribers selected.'));
69 throw new \Magento\Framework\Exception\LocalizedException(
__(
'You selected an invalid queue.'));
76 $this->
getTable(
'newsletter_queue_link'),
82 'subscriber_id in (?)',
87 $subscriberIds = array_flip($subscriberIds);
88 $newIds = array_diff_key($subscriberIds, $usedIds);
92 foreach (array_keys($newIds) as $subscriberId) {
95 $data[
'subscriber_id'] = $subscriberId;
99 }
catch (\Exception $e) {
117 $this->
getTable(
'newsletter_queue_link'),
118 [
'queue_id = ?' => $queue->getId(),
'letter_sent_at IS NULL']
122 }
catch (\Exception $e) {
137 $connection->delete($this->
getTable(
'newsletter_queue_store_link'), [
'queue_id = ?' => $queue->getId()]);
156 $subscribers = $this->_subscriberCollection->addFieldToFilter(
159 )->useOnlySubscribed()->load();
167 if (count($subscriberIds) > 0) {
184 $this->
getTable(
'newsletter_queue_store_link'),
187 'queue_id = :queue_id' 205 if (
$queue->getSaveStoresFlag()) {
__construct(\Magento\Framework\Model\ResourceModel\Db\Context $context, \Magento\Newsletter\Model\ResourceModel\Subscriber\Collection $subscriberCollection, $connectionName=null)
getStores(ModelQueue $queue)
setStores(ModelQueue $queue)
_afterSave(AbstractModel $queue)
addSubscribersToQueue(ModelQueue $queue, array $subscriberIds)
_init($mainTable, $idFieldName)
removeSubscribersFromQueue(ModelQueue $queue)