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
{
20 * @param int $mailingID
24 public static function mailingSize($mailingID) {
26 SELECT count(*) as count
27 FROM civicrm_mailing_recipients
30 $params = [1 => [$mailingID, 'Integer']];
31 return CRM_Core_DAO
::singleValueQuery($sql, $params);
35 * @param int $mailingID
41 public static function mailingQuery(
43 $offset = NULL, $limit = NULL
46 if ($limit && $offset !== NULL) {
47 $offset = CRM_Utils_Type
::escape($offset, 'Int');
48 $limit = CRM_Utils_Type
::escape($limit, 'Int');
50 $limitString = "LIMIT $offset, $limit";
53 $isSMSMode = CRM_Core_DAO
::getFieldValue('CRM_Mailing_BAO_Mailing', $mailingID, 'sms_provider_id', 'id');
54 $additionalJoin = $isSMSMode ?
'' : " INNER JOIN civicrm_email e ON (r.email_id = e.id AND e.on_hold = 0)";
57 SELECT r.contact_id, r.email_id, r.phone_id
58 FROM civicrm_mailing_recipients r
59 INNER JOIN civicrm_contact c on
63 AND c.do_not_" . ($isSMSMode ?
'sms' : 'email') . " = 0
67 WHERE r.mailing_id = %1
70 $params = [1 => [$mailingID, 'Integer']];
72 return CRM_Core_DAO
::executeQuery($sql, $params);
76 * Moves a number of randomly-chosen recipients of one Mailing to another Mailing.
78 * @param int $sourceMailingId
80 * @param int $newMailingID
81 * Destination mailing ID
82 * @param int $totalLimit
83 * Number of recipients to move
85 public static function updateRandomRecipients($sourceMailingId, $newMailingID, $totalLimit = NULL) {
88 $limitString = "LIMIT 0, $totalLimit";
90 $temporaryTable = CRM_Utils_SQL_TempTable
::build()
91 ->setCategory('sr' . $sourceMailingId)
93 ->createWithColumns("mailing_recipient_id int unsigned, id int PRIMARY KEY AUTO_INCREMENT, INDEX(mailing_recipient_id)");
94 $temporaryTableName = $temporaryTable->getName();
96 INSERT INTO {$temporaryTableName} (mailing_recipient_id)
98 FROM civicrm_mailing_recipients mr
99 WHERE mr.mailing_id = $sourceMailingId
103 CRM_Core_DAO
::executeQuery($sql);
105 UPDATE civicrm_mailing_recipients mr
106 INNER JOIN {$temporaryTableName} temp_mr ON temp_mr.mailing_recipient_id = mr.id
107 SET mr.mailing_id = $newMailingID
109 CRM_Core_DAO
::executeQuery($sql);
110 $temporaryTable->drop();
114 * Redistribute recipients from $sourceMailingId to a series of other mailings.
116 * @param int $sourceMailingId
118 * (int $targetMailingId => int $count).
120 public static function reassign($sourceMailingId, $to) {
121 foreach ($to as $targetMailingId => $count) {
123 CRM_Mailing_BAO_Recipients
::updateRandomRecipients($sourceMailingId, $targetMailingId, $count);