1: <?php
2: /**
3: * Magento
4: *
5: * NOTICE OF LICENSE
6: *
7: * This source file is subject to the Open Software License (OSL 3.0)
8: * that is bundled with this package in the file LICENSE.txt.
9: * It is also available through the world-wide-web at this URL:
10: * http://opensource.org/licenses/osl-3.0.php
11: * If you did not receive a copy of the license and are unable to
12: * obtain it through the world-wide-web, please send an email
13: * to license@magentocommerce.com so we can send you a copy immediately.
14: *
15: * DISCLAIMER
16: *
17: * Do not edit or add to this file if you wish to upgrade Magento to newer
18: * versions in the future. If you wish to customize Magento for your
19: * needs please refer to http://www.magentocommerce.com for more information.
20: *
21: * @category Mage
22: * @package Mage_Newsletter
23: * @copyright Copyright (c) 2012 Magento Inc. (http://www.magentocommerce.com)
24: * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
25: */
26:
27: /**
28: * Newsletter module observer
29: *
30: * @author Magento Core Team <core@magentocommerce.com>
31: */
32: class Mage_Newsletter_Model_Observer
33: {
34: public function subscribeCustomer($observer)
35: {
36: $customer = $observer->getEvent()->getCustomer();
37: if (($customer instanceof Mage_Customer_Model_Customer)) {
38: Mage::getModel('newsletter/subscriber')->subscribeCustomer($customer);
39: }
40: return $this;
41: }
42:
43: /**
44: * Customer delete handler
45: *
46: * @param Varien_Object $observer
47: * @return Mage_Newsletter_Model_Observer
48: */
49: public function customerDeleted($observer)
50: {
51: $subscriber = Mage::getModel('newsletter/subscriber')
52: ->loadByEmail($observer->getEvent()->getCustomer()->getEmail());
53: if($subscriber->getId()) {
54: $subscriber->delete();
55: }
56: return $this;
57: }
58:
59: public function scheduledSend($schedule)
60: {
61: $countOfQueue = 3;
62: $countOfSubscritions = 20;
63:
64: $collection = Mage::getModel('newsletter/queue')->getCollection()
65: ->setPageSize($countOfQueue)
66: ->setCurPage(1)
67: ->addOnlyForSendingFilter()
68: ->load();
69:
70: $collection->walk('sendPerSubscriber', array($countOfSubscritions));
71: }
72: }
73: