3 +--------------------------------------------------------------------+
4 | Copyright CiviCRM LLC. All rights reserved. |
6 | This work is published under the GNU AGPLv3 license with some |
7 | permitted exceptions and without any warranty. For full license |
8 | and copyright information, see https://civicrm.org/licensing |
9 +--------------------------------------------------------------------+
15 * @copyright CiviCRM LLC https://civicrm.org/licensing
17 class CRM_Mailing_BAO_Recipients
extends CRM_Mailing_DAO_Recipients
{
22 public function __construct() {
23 parent
::__construct();
27 * @param int $mailingID
31 public static function mailingSize($mailingID) {
33 SELECT count(*) as count
34 FROM civicrm_mailing_recipients
37 $params = [1 => [$mailingID, 'Integer']];
38 return CRM_Core_DAO
::singleValueQuery($sql, $params);
42 * @param int $mailingID
48 public static function mailingQuery(
50 $offset = NULL, $limit = NULL
53 if ($limit && $offset !== NULL) {
54 $offset = CRM_Utils_Type
::escape($offset, 'Int');
55 $limit = CRM_Utils_Type
::escape($limit, 'Int');
57 $limitString = "LIMIT $offset, $limit";
60 $isSMSMode = CRM_Core_DAO
::getFieldValue('CRM_Mailing_BAO_Mailing', $mailingID, 'sms_provider_id', 'id');
61 $additionalJoin = $isSMSMode ?
'' : " INNER JOIN civicrm_email e ON (r.email_id = e.id AND e.on_hold = 0)";
64 SELECT r.contact_id, r.email_id, r.phone_id
65 FROM civicrm_mailing_recipients r
66 INNER JOIN civicrm_contact c on
70 AND c.do_not_" . ($isSMSMode ?
'sms' : 'email') . " = 0
74 WHERE r.mailing_id = %1
77 $params = [1 => [$mailingID, 'Integer']];
79 return CRM_Core_DAO
::executeQuery($sql, $params);
83 * Moves a number of randomly-chosen recipients of one Mailing to another Mailing.
85 * @param int $sourceMailingId
87 * @param int $newMailingID
88 * Destination mailing ID
89 * @param int $totalLimit
90 * Number of recipients to move
92 public static function updateRandomRecipients($sourceMailingId, $newMailingID, $totalLimit = NULL) {
95 $limitString = "LIMIT 0, $totalLimit";
97 $temporaryTable = CRM_Utils_SQL_TempTable
::build()
98 ->setCategory('sr' . $sourceMailingId)
100 ->createWithColumns("mailing_recipient_id int unsigned, id int PRIMARY KEY AUTO_INCREMENT, INDEX(mailing_recipient_id)");
101 $temporaryTableName = $temporaryTable->getName();
103 INSERT INTO {$temporaryTableName} (mailing_recipient_id)
105 FROM civicrm_mailing_recipients mr
106 WHERE mr.mailing_id = $sourceMailingId
110 CRM_Core_DAO
::executeQuery($sql);
112 UPDATE civicrm_mailing_recipients mr
113 INNER JOIN {$temporaryTableName} temp_mr ON temp_mr.mailing_recipient_id = mr.id
114 SET mr.mailing_id = $newMailingID
116 CRM_Core_DAO
::executeQuery($sql);
117 $temporaryTable->drop();
121 * Redistribute recipients from $sourceMailingId to a series of other mailings.
123 * @param int $sourceMailingId
125 * (int $targetMailingId => int $count).
127 public static function reassign($sourceMailingId, $to) {
128 foreach ($to as $targetMailingId => $count) {
130 CRM_Mailing_BAO_Recipients
::updateRandomRecipients($sourceMailingId, $targetMailingId, $count);