comment fixes
[civicrm-core.git] / api / v3 / Mailing.php
CommitLineData
6a488035 1<?php
6a488035
TO
2/*
3 +--------------------------------------------------------------------+
81621fee 4 | CiviCRM version 4.7 |
6a488035 5 +--------------------------------------------------------------------+
e7112fa7 6 | Copyright CiviCRM LLC (c) 2004-2015 |
6a488035
TO
7 +--------------------------------------------------------------------+
8 | This file is a part of CiviCRM. |
9 | |
10 | CiviCRM is free software; you can copy, modify, and distribute it |
11 | under the terms of the GNU Affero General Public License |
12 | Version 3, 19 November 2007 and the CiviCRM Licensing Exception. |
13 | |
14 | CiviCRM is distributed in the hope that it will be useful, but |
15 | WITHOUT ANY WARRANTY; without even the implied warranty of |
16 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. |
17 | See the GNU Affero General Public License for more details. |
18 | |
19 | You should have received a copy of the GNU Affero General Public |
20 | License and the CiviCRM Licensing Exception along |
21 | with this program; if not, contact CiviCRM LLC |
22 | at info[AT]civicrm[DOT]org. If you have questions about the |
23 | GNU Affero General Public License or the licensing of CiviCRM, |
24 | see the CiviCRM license FAQ at http://civicrm.org/licensing |
25 +--------------------------------------------------------------------+
d25dd0ee 26 */
6a488035
TO
27
28/**
29 *
30 * APIv3 functions for registering/processing mailing events.
31 *
32 * @package CiviCRM_APIv3
6a488035
TO
33 */
34
6a488035
TO
35/**
36 * Handle a create event.
37 *
38 * @param array $params
22242c87 39 *
1747ab99 40 * @return array
7c550ca0 41 * API Success Array
c23f45d3
EM
42 * @throws \API_Exception
43 * @throws \Civi\API\Exception\UnauthorizedException
6a488035 44 */
c23f45d3 45function civicrm_api3_mailing_create($params) {
6818346a 46 if (CRM_Mailing_Info::workflowEnabled()) {
360d6097
TO
47 // Note: 'schedule mailings' and 'approve mailings' can update certain fields, but can't create.
48
49 if (empty($params['id'])) {
50 if (!CRM_Core_Permission::check('access CiviMail') && !CRM_Core_Permission::check('create mailings')) {
51 throw new \Civi\API\Exception\UnauthorizedException("Cannot create new mailing. Required permission: 'access CiviMail' or 'create mailings'");
52 }
53 }
54
3efe22a0
TO
55 $safeParams = array();
56 $fieldPerms = CRM_Mailing_BAO_Mailing::getWorkflowFieldPerms();
57 foreach (array_keys($params) as $field) {
58 if (CRM_Core_Permission::check($fieldPerms[$field])) {
59 $safeParams[$field] = $params[$field];
60 }
6818346a
TO
61 }
62 }
3efe22a0
TO
63 else {
64 $safeParams = $params;
65 }
66 $safeParams['_evil_bao_validator_'] = 'CRM_Mailing_BAO_Mailing::checkSendable';
67 return _civicrm_api3_basic_create(_civicrm_api3_get_BAO(__FUNCTION__), $safeParams);
e81bac46 68
6a488035
TO
69}
70
c23f45d3 71/**
9950a1c9
CW
72 * Get tokens for one or more entity type
73 *
74 * Output will be formatted either as a flat list,
75 * or pass sequential=1 to retrieve as a hierarchy formatted for select2.
22242c87 76 *
c23f45d3 77 * @param array $params
9950a1c9 78 * Should contain an array of entities to retrieve tokens for.
22242c87 79 *
c23f45d3
EM
80 * @return array
81 * @throws \API_Exception
82 */
1d280e03
CW
83function civicrm_api3_mailing_gettokens($params) {
84 $tokens = array();
85 foreach ((array) $params['entity'] as $ent) {
9950a1c9 86 $func = lcfirst($ent) . 'Tokens';
1d280e03
CW
87 if (!method_exists('CRM_Core_SelectValues', $func)) {
88 throw new API_Exception('Unknown token entity: ' . $ent);
89 }
90 $tokens = array_merge(CRM_Core_SelectValues::$func(), $tokens);
7e6e8bd6 91 }
1d280e03
CW
92 if (!empty($params['sequential'])) {
93 $tokens = CRM_Utils_Token::formatTokensForDisplay($tokens);
7e6e8bd6 94 }
1d280e03
CW
95 return civicrm_api3_create_success($tokens, $params, 'Mailing', 'gettokens');
96}
a95acf21 97
1d280e03
CW
98/**
99 * Adjust Metadata for Create action.
100 *
101 * The metadata is used for setting defaults, documentation & validation.
102 *
103 * @param array $params
104 * Array of parameters determined by getfields.
105 */
106function _civicrm_api3_mailing_gettokens_spec(&$params) {
107 $params['entity'] = array(
108 'api.default' => array('contact'),
109 'api.required' => 1,
7b6c5043 110 'api.multiple' => 1,
1d280e03
CW
111 'title' => 'Entity',
112 'options' => array(),
113 );
9950a1c9 114 // Fetch a list of token functions and format to look like entity names
1d280e03
CW
115 foreach (get_class_methods('CRM_Core_SelectValues') as $func) {
116 if (strpos($func, 'Tokens')) {
9950a1c9 117 $ent = ucfirst(str_replace('Tokens', '', $func));
1d280e03
CW
118 $params['entity']['options'][$ent] = $ent;
119 }
120 }
7e6e8bd6 121}
2b5e4108 122
11e09c59 123/**
0aa0303c
EM
124 * Adjust Metadata for Create action.
125 *
126 * The metadata is used for setting defaults, documentation & validation.
11e09c59 127 *
cf470720 128 * @param array $params
b081365f 129 * Array of parameters determined by getfields.
11e09c59 130 */
6a488035 131function _civicrm_api3_mailing_create_spec(&$params) {
6a488035 132 $params['created_id']['api.required'] = 1;
fddd185d 133 $params['created_id']['api.default'] = 'user_contact_id';
b0a31714 134
1a574627 135 $params['override_verp']['api.default'] = !CRM_Core_BAO_Setting::getItem(CRM_Core_BAO_Setting::MAILING_PREFERENCES_NAME, 'track_civimail_replies');
b0a31714 136 $params['visibility']['api.default'] = 'Public Pages';
1a574627 137 $params['dedupe_email']['api.default'] = CRM_Core_BAO_Setting::getItem(CRM_Core_BAO_Setting::MAILING_PREFERENCES_NAME, 'dedupe_email_default');
b0a31714
TO
138
139 $params['forward_replies']['api.default'] = FALSE;
140 $params['auto_responder']['api.default'] = FALSE;
141 $params['open_tracking']['api.default'] = TRUE;
142 $params['url_tracking']['api.default'] = TRUE;
143
144 $params['header_id']['api.default'] = CRM_Mailing_PseudoConstant::defaultComponent('Header', '');
145 $params['footer_id']['api.default'] = CRM_Mailing_PseudoConstant::defaultComponent('Footer', '');
146 $params['optout_id']['api.default'] = CRM_Mailing_PseudoConstant::defaultComponent('OptOut', '');
147 $params['reply_id']['api.default'] = CRM_Mailing_PseudoConstant::defaultComponent('Reply', '');
148 $params['resubscribe_id']['api.default'] = CRM_Mailing_PseudoConstant::defaultComponent('Resubscribe', '');
149 $params['unsubscribe_id']['api.default'] = CRM_Mailing_PseudoConstant::defaultComponent('Unsubscribe', '');
f72b68c0 150 $params['mailing_type']['api.default'] = 'standalone';
b0a31714
TO
151 $defaultAddress = CRM_Core_OptionGroup::values('from_email_address', NULL, NULL, NULL, ' AND is_default = 1');
152 foreach ($defaultAddress as $id => $value) {
153 if (preg_match('/"(.*)" <(.*)>/', $value, $match)) {
154 $params['from_email']['api.default'] = $match[2];
155 $params['from_name']['api.default'] = $match[1];
156 }
157 }
6a488035
TO
158}
159
00dc999a
TO
160function _civicrm_api3_mailing_clone_spec(&$spec) {
161 $mailingFields = CRM_Mailing_DAO_Mailing::fields();
162 $spec['id'] = $mailingFields['id'];
163 $spec['id']['api.required'] = 1;
164}
165
166function civicrm_api3_mailing_clone($params) {
167 $BLACKLIST = array(
168 'id',
169 'is_completed',
170 'created_id',
171 'created_date',
172 'scheduled_id',
173 'scheduled_date',
174 'approver_id',
175 'approval_date',
176 'approval_status_id',
177 'approval_note',
178 'is_archived',
179 'hash',
180 );
181
182 $get = civicrm_api3('Mailing', 'getsingle', array('id' => $params['id']));
183
184 $newParams = array();
185 $newParams['debug'] = CRM_Utils_Array::value('debug', $params);
186 $newParams['groups']['include'] = array();
187 $newParams['groups']['exclude'] = array();
188 $newParams['mailings']['include'] = array();
189 $newParams['mailings']['exclude'] = array();
190 foreach ($get as $field => $value) {
191 if (!in_array($field, $BLACKLIST)) {
192 $newParams[$field] = $value;
193 }
194 }
195
196 $dao = new CRM_Mailing_DAO_MailingGroup();
197 $dao->mailing_id = $params['id'];
198 $dao->find();
199 while ($dao->fetch()) {
200 // CRM-11431; account for multi-lingual
201 $entity = (substr($dao->entity_table, 0, 15) == 'civicrm_mailing') ? 'mailings' : 'groups';
202 $newParams[$entity][strtolower($dao->group_type)][] = $dao->entity_id;
203 }
204
205 return civicrm_api3('Mailing', 'create', $newParams);
206}
207
e37b4b04 208/**
eb1823ac 209 * Handle a delete event.
e37b4b04 210 *
211 * @param array $params
77b97be7 212 *
a6c01b45 213 * @return array
72b3a70c 214 * API Success Array
e37b4b04 215 */
906e6120 216function civicrm_api3_mailing_delete($params) {
7e6e8bd6 217 return _civicrm_api3_basic_delete(_civicrm_api3_get_BAO(__FUNCTION__), $params);
e37b4b04 218}
219
6a488035
TO
220/**
221 * Handle a get event.
222 *
223 * @param array $params
d1b0d05e 224 *
6a488035
TO
225 * @return array
226 */
e37b4b04 227function civicrm_api3_mailing_get($params) {
7e6e8bd6 228 return _civicrm_api3_basic_get(_civicrm_api3_get_BAO(__FUNCTION__), $params);
6a488035
TO
229}
230
c23f45d3 231/**
22242c87
EM
232 * Adjust metadata for mailing submit api function.
233 *
c23f45d3
EM
234 * @param array $spec
235 */
6818346a
TO
236function _civicrm_api3_mailing_submit_spec(&$spec) {
237 $mailingFields = CRM_Mailing_DAO_Mailing::fields();
238 $spec['id'] = $mailingFields['id'];
239 $spec['scheduled_date'] = $mailingFields['scheduled_date'];
240 $spec['approval_date'] = $mailingFields['approval_date'];
2c1e4dc1
TO
241 $spec['approval_status_id'] = $mailingFields['approval_status_id'];
242 $spec['approval_note'] = $mailingFields['approval_note'];
768c558c 243 // _skip_evil_bao_auto_recipients_: bool
6818346a
TO
244}
245
246/**
22242c87
EM
247 * Mailing submit.
248 *
6818346a 249 * @param array $params
22242c87 250 *
768c558c
TO
251 * @return array
252 * @throws API_Exception
6818346a
TO
253 */
254function civicrm_api3_mailing_submit($params) {
255 civicrm_api3_verify_mandatory($params, 'CRM_Mailing_DAO_Mailing', array('id'));
256
257 if (!isset($params['scheduled_date']) && !isset($updateParams['approval_date'])) {
258 throw new API_Exception("Missing parameter scheduled_date and/or approval_date");
259 }
260 if (!is_numeric(CRM_Core_Session::getLoggedInContactID())) {
261 throw new API_Exception("Failed to determine current user");
262 }
263
264 $updateParams = array();
265 $updateParams['id'] = $params['id'];
266
dc64d047
EM
267 // Note: we'll pass along scheduling/approval fields, but they may get ignored
268 // if we don't have permission.
6818346a
TO
269 if (isset($params['scheduled_date'])) {
270 $updateParams['scheduled_date'] = $params['scheduled_date'];
271 $updateParams['scheduled_id'] = CRM_Core_Session::getLoggedInContactID();
272 }
768c558c 273 if (isset($params['approval_date'])) {
6818346a
TO
274 $updateParams['approval_date'] = $params['approval_date'];
275 $updateParams['approver_id'] = CRM_Core_Session::getLoggedInContactID();
276 $updateParams['approval_status_id'] = CRM_Utils_Array::value('approval_status_id', $updateParams, CRM_Core_OptionGroup::getDefaultValue('mail_approval_status'));
277 }
2c1e4dc1
TO
278 if (isset($params['approval_note'])) {
279 $updateParams['approval_note'] = $params['approval_note'];
280 }
768c558c
TO
281 if (isset($params['_skip_evil_bao_auto_recipients_'])) {
282 $updateParams['_skip_evil_bao_auto_recipients_'] = $params['_skip_evil_bao_auto_recipients_'];
283 }
6818346a
TO
284
285 $updateParams['options']['reload'] = 1;
286 return civicrm_api3('Mailing', 'create', $updateParams);
287}
288
6a488035
TO
289/**
290 * Process a bounce event by passing through to the BAOs.
291 *
292 * @param array $params
293 *
77b97be7 294 * @throws API_Exception
6a488035
TO
295 * @return array
296 */
297function civicrm_api3_mailing_event_bounce($params) {
7e6e8bd6
TO
298 $body = $params['body'];
299 unset($params['body']);
6a488035 300
7e6e8bd6 301 $params += CRM_Mailing_BAO_BouncePattern::match($body);
6a488035 302
7e6e8bd6
TO
303 if (CRM_Mailing_Event_BAO_Bounce::create($params)) {
304 return civicrm_api3_create_success($params);
305 }
306 else {
244bbdd8 307 throw new API_Exception(ts('Queue event could not be found'), 'no_queue_event');
7e6e8bd6 308 }
6a488035
TO
309}
310
11e09c59 311/**
22242c87 312 * Adjust Metadata for bounce_spec action.
11e09c59 313 *
0aa0303c
EM
314 * The metadata is used for setting defaults, documentation & validation.
315 *
cf470720 316 * @param array $params
b081365f 317 * Array of parameters determined by getfields.
11e09c59 318 */
6a488035
TO
319function _civicrm_api3_mailing_event_bounce_spec(&$params) {
320 $params['job_id']['api.required'] = 1;
4c41ecb2 321 $params['job_id']['title'] = 'Job ID';
6a488035 322 $params['event_queue_id']['api.required'] = 1;
4c41ecb2 323 $params['event_queue_id']['title'] = 'Event Queue ID';
6a488035 324 $params['hash']['api.required'] = 1;
4c41ecb2 325 $params['hash']['title'] = 'Hash';
6a488035 326 $params['body']['api.required'] = 1;
4c41ecb2 327 $params['body']['title'] = 'Body';
6a488035
TO
328}
329
330/**
22242c87
EM
331 * Handle a confirm event.
332 *
6a488035
TO
333 * @deprecated
334 *
335 * @param array $params
336 *
337 * @return array
338 */
339function civicrm_api3_mailing_event_confirm($params) {
244bbdd8 340 return civicrm_api('MailingEventConfirm', 'create', $params);
6a488035
TO
341}
342
a14e9d08 343/**
d1b0d05e
EM
344 * Declare deprecated functions.
345 *
a14e9d08 346 * @deprecated api notice
a6c01b45 347 * @return array
16b10e64 348 * Array of deprecated actions
a14e9d08
CW
349 */
350function _civicrm_api3_mailing_deprecation() {
351 return array('event_confirm' => 'Mailing api "event_confirm" action is deprecated. Use the mailing_event_confirm api instead.');
352}
353
6a488035 354/**
22242c87 355 * Handle a reply event.
6a488035
TO
356 *
357 * @param array $params
358 *
359 * @return array
360 */
361function civicrm_api3_mailing_event_reply($params) {
7e6e8bd6
TO
362 $job = $params['job_id'];
363 $queue = $params['event_queue_id'];
364 $hash = $params['hash'];
365 $replyto = $params['replyTo'];
366 $bodyTxt = CRM_Utils_Array::value('bodyTxt', $params);
367 $bodyHTML = CRM_Utils_Array::value('bodyHTML', $params);
368 $fullEmail = CRM_Utils_Array::value('fullEmail', $params);
369
370 $mailing = CRM_Mailing_Event_BAO_Reply::reply($job, $queue, $hash, $replyto);
371
372 if (empty($mailing)) {
373 return civicrm_api3_create_error('Queue event could not be found');
374 }
6a488035 375
7e6e8bd6 376 CRM_Mailing_Event_BAO_Reply::send($queue, $mailing, $bodyTxt, $replyto, $bodyHTML, $fullEmail);
6a488035 377
7e6e8bd6 378 return civicrm_api3_create_success($params);
6a488035
TO
379}
380
11e09c59 381/**
22242c87 382 * Adjust Metadata for event_reply action.
11e09c59 383 *
0aa0303c
EM
384 * The metadata is used for setting defaults, documentation & validation.
385 *
cf470720 386 * @param array $params
b081365f 387 * Array of parameters determined by getfields.
11e09c59 388 */
6a488035
TO
389function _civicrm_api3_mailing_event_reply_spec(&$params) {
390 $params['job_id']['api.required'] = 1;
4c41ecb2 391 $params['job_id']['title'] = 'Job ID';
6a488035 392 $params['event_queue_id']['api.required'] = 1;
4c41ecb2 393 $params['event_queue_id']['title'] = 'Event Queue ID';
6a488035 394 $params['hash']['api.required'] = 1;
4c41ecb2 395 $params['hash']['title'] = 'Hash';
fb18363b 396 $params['replyTo']['api.required'] = 0;
4c41ecb2 397 $params['replyTo']['title'] = 'Reply To';//doesn't really explain adequately
6a488035
TO
398}
399
400/**
22242c87 401 * Handle a forward event.
6a488035
TO
402 *
403 * @param array $params
404 *
405 * @return array
406 */
407function civicrm_api3_mailing_event_forward($params) {
7e6e8bd6
TO
408 $job = $params['job_id'];
409 $queue = $params['event_queue_id'];
410 $hash = $params['hash'];
411 $email = $params['email'];
412 $fromEmail = CRM_Utils_Array::value('fromEmail', $params);
413 $params = CRM_Utils_Array::value('params', $params);
6a488035 414
7e6e8bd6 415 $forward = CRM_Mailing_Event_BAO_Forward::forward($job, $queue, $hash, $email, $fromEmail, $params);
6a488035 416
7e6e8bd6
TO
417 if ($forward) {
418 return civicrm_api3_create_success($params);
419 }
6a488035 420
7e6e8bd6 421 return civicrm_api3_create_error('Queue event could not be found');
6a488035
TO
422}
423
11e09c59 424/**
22242c87 425 * Adjust Metadata for event_forward action.
11e09c59 426 *
0aa0303c
EM
427 * The metadata is used for setting defaults, documentation & validation.
428 *
cf470720 429 * @param array $params
b081365f 430 * Array of parameters determined by getfields.
11e09c59 431 */
6a488035
TO
432function _civicrm_api3_mailing_event_forward_spec(&$params) {
433 $params['job_id']['api.required'] = 1;
48280907 434 $params['job_id']['title'] = 'Job ID';
6a488035 435 $params['event_queue_id']['api.required'] = 1;
4c41ecb2 436 $params['event_queue_id']['title'] = 'Event Queue ID';
6a488035 437 $params['hash']['api.required'] = 1;
4c41ecb2 438 $params['hash']['title'] = 'Hash';
6a488035 439 $params['email']['api.required'] = 1;
4c41ecb2 440 $params['email']['title'] = 'Forwarded to Email';
6a488035
TO
441}
442
443/**
22242c87 444 * Handle a click event.
6a488035
TO
445 *
446 * @param array $params
447 *
448 * @return array
449 */
450function civicrm_api3_mailing_event_click($params) {
7e6e8bd6
TO
451 civicrm_api3_verify_mandatory($params,
452 'CRM_Mailing_Event_DAO_TrackableURLOpen',
453 array('event_queue_id', 'url_id'),
454 FALSE
455 );
6a488035 456
7e6e8bd6
TO
457 $url_id = $params['url_id'];
458 $queue = $params['event_queue_id'];
6a488035 459
7e6e8bd6 460 $url = CRM_Mailing_Event_BAO_TrackableURLOpen::track($queue, $url_id);
6a488035 461
7e6e8bd6
TO
462 $values = array();
463 $values['url'] = $url;
464 $values['is_error'] = 0;
6a488035 465
7e6e8bd6 466 return civicrm_api3_create_success($values);
6a488035
TO
467}
468
469/**
22242c87 470 * Handle an open event.
6a488035
TO
471 *
472 * @param array $params
473 *
474 * @return array
475 */
476function civicrm_api3_mailing_event_open($params) {
477
7e6e8bd6
TO
478 civicrm_api3_verify_mandatory($params,
479 'CRM_Mailing_Event_DAO_Opened',
480 array('event_queue_id'),
481 FALSE
482 );
6a488035 483
7e6e8bd6
TO
484 $queue = $params['event_queue_id'];
485 $success = CRM_Mailing_Event_BAO_Opened::open($queue);
6a488035 486
7e6e8bd6
TO
487 if (!$success) {
488 return civicrm_api3_create_error('mailing open event failed');
489 }
6a488035 490
7e6e8bd6 491 return civicrm_api3_create_success($params);
6a488035
TO
492}
493
c23f45d3 494/**
22242c87
EM
495 * Preview mailing.
496 *
c23f45d3 497 * @param array $params
22242c87
EM
498 * Array per getfields metadata.
499 *
c23f45d3
EM
500 * @return array
501 * @throws \API_Exception
502 */
7811a84b 503function civicrm_api3_mailing_preview($params) {
504 civicrm_api3_verify_mandatory($params,
505 'CRM_Mailing_DAO_Mailing',
506 array('id'),
507 FALSE
6a488035 508 );
7811a84b 509
510 $fromEmail = NULL;
511 if (!empty($params['from_email'])) {
512 $fromEmail = $params['from_email'];
513 }
514
515 $session = CRM_Core_Session::singleton();
516 $mailing = new CRM_Mailing_BAO_Mailing();
517 $mailing->id = $params['id'];
518 $mailing->find(TRUE);
519
520 CRM_Mailing_BAO_Mailing::tokenReplace($mailing);
521
522 // get and format attachments
523 $attachments = CRM_Core_BAO_File::getEntityFile('civicrm_mailing', $mailing->id);
524
525 $returnProperties = $mailing->getReturnProperties();
526 $contactID = CRM_Utils_Array::value('contact_id', $params);
527 if (!$contactID) {
528 $contactID = $session->get('userID');
529 }
530 $mailingParams = array('contact_id' => $contactID);
531
6bea4a47 532 $details = CRM_Utils_Token::getTokenDetails($mailingParams, $returnProperties, TRUE, TRUE, NULL, $mailing->getFlattenedTokens());
7811a84b 533
534 $mime = &$mailing->compose(NULL, NULL, NULL, $session->get('userID'), $fromEmail, $fromEmail,
535 TRUE, $details[0][$contactID], $attachments
536 );
537
bd6658bd
TO
538 return civicrm_api3_create_success(array(
539 'id' => $params['id'],
540 'contact_id' => $contactID,
541 'subject' => $mime->_headers['Subject'],
51ae62c4
TO
542 'body_html' => $mime->getHTMLBody(),
543 'body_text' => $mime->getTXTBody(),
bd6658bd 544 ));
6a488035
TO
545}
546
c23f45d3 547/**
22242c87
EM
548 * Adjust metadata for send test function.
549 *
c23f45d3
EM
550 * @param array $spec
551 */
7ada2376
TO
552function _civicrm_api3_mailing_send_test_spec(&$spec) {
553 $spec['test_group']['title'] = 'Test Group ID';
554 $spec['test_email']['title'] = 'Test Email Address';
555}
556
c23f45d3 557/**
22242c87
EM
558 * Send test mailing.
559 *
c23f45d3 560 * @param array $params
22242c87 561 *
c23f45d3
EM
562 * @return array
563 * @throws \API_Exception
564 * @throws \CiviCRM_API3_Exception
565 */
425723d9 566function civicrm_api3_mailing_send_test($params) {
567 if (!array_key_exists('test_group', $params) && !array_key_exists('test_email', $params)) {
481a74f4 568 throw new API_Exception("Mandatory key(s) missing from params array: test_group and/or test_email field are required");
425723d9 569 }
570 civicrm_api3_verify_mandatory($params,
571 'CRM_Mailing_DAO_MailingJob',
572 array('mailing_id'),
573 FALSE
574 );
7811a84b 575
425723d9 576 $testEmailParams = _civicrm_api3_generic_replace_base_params($params);
7811a84b 577 $testEmailParams['is_test'] = 1;
578 $job = civicrm_api3('MailingJob', 'create', $testEmailParams);
425723d9 579 $testEmailParams['job_id'] = $job['id'];
580 $testEmailParams['emails'] = explode(',', $testEmailParams['test_email']);
581 if (!empty($params['test_email'])) {
932c73e7
TO
582 $query = CRM_Utils_SQL_Select::from('civicrm_email e')
583 ->select(array('e.id', 'e.contact_id', 'e.email'))
584 ->join('c', 'INNER JOIN civicrm_contact c ON e.contact_id = c.id')
585 ->where('e.email IN (@emails)', array('@emails' => $testEmailParams['emails']))
586 ->where('e.on_hold = 0')
587 ->where('c.is_opt_out = 0')
588 ->where('c.do_not_email = 0')
589 ->where('c.is_deceased = 0')
196c4f47 590 ->where('c.is_deleted = 0')
932c73e7
TO
591 ->groupBy('e.id')
592 ->orderBy(array('e.is_bulkmail DESC', 'e.is_primary DESC'))
593 ->toSQL();
425723d9 594 $dao = CRM_Core_DAO::executeQuery($query);
595 $emailDetail = array();
596 // fetch contact_id and email id for all existing emails
597 while ($dao->fetch()) {
598 $emailDetail[$dao->email] = array(
599 'contact_id' => $dao->contact_id,
600 'email_id' => $dao->id,
601 );
602 }
603 $dao->free();
604 foreach ($testEmailParams['emails'] as $key => $email) {
605 $email = trim($email);
606 $contactId = $emailId = NULL;
607 if (array_key_exists($email, $emailDetail)) {
608 $emailId = $emailDetail[$email]['email_id'];
609 $contactId = $emailDetail[$email]['contact_id'];
610 }
611 if (!$contactId) {
612 //create new contact.
613 $contact = civicrm_api3('Contact', 'create',
6ea503d4
TO
614 array(
615 'contact_type' => 'Individual',
425723d9 616 'email' => $email,
21dfd5f5 617 'api.Email.get' => array('return' => 'id'),
425723d9 618 )
619 );
620 $contactId = $contact['id'];
621 $emailId = $contact['values'][$contactId]['api.Email.get']['id'];
622 }
623 civicrm_api3('MailingEventQueue', 'create',
6ea503d4
TO
624 array(
625 'job_id' => $job['id'],
425723d9 626 'email_id' => $emailId,
21dfd5f5 627 'contact_id' => $contactId,
425723d9 628 )
629 );
630 }
631 }
7811a84b 632
425723d9 633 $isComplete = FALSE;
97b7d4a0 634 $config = CRM_Core_Config::singleton();
dc00ac6d 635 $mailerJobSize = Civi::settings()->get('mailerJobSize');
425723d9 636 while (!$isComplete) {
97b7d4a0
TO
637 // Q: In CRM_Mailing_BAO_Mailing::processQueue(), the three runJobs*()
638 // functions are all called. Why does Mailing.send_test only call one?
639 // CRM_Mailing_BAO_MailingJob::runJobs_pre($mailerJobSize, NULL);
425723d9 640 $isComplete = CRM_Mailing_BAO_MailingJob::runJobs($testEmailParams);
97b7d4a0 641 // CRM_Mailing_BAO_MailingJob::runJobs_post(NULL);
425723d9 642 }
7811a84b 643
644 //return delivered mail info
645 $mailDelivered = CRM_Mailing_Event_BAO_Delivered::getRows($params['mailing_id'], $job['id'], TRUE, NULL, NULL, NULL, TRUE);
646
647 return civicrm_api3_create_success($mailDelivered);
425723d9 648}
649
7811a84b 650/**
22242c87 651 * Adjust Metadata for send_mail action.
7811a84b 652 *
0aa0303c
EM
653 * The metadata is used for setting defaults, documentation & validation.
654 *
cf470720 655 * @param array $params
b081365f 656 * Array of parameters determined by getfields.
7811a84b 657 */
658function _civicrm_api3_mailing_stats_spec(&$params) {
659 $params['date']['api.default'] = 'now';
bd6658bd 660 $params['date']['title'] = 'Date';
7811a84b 661}
6a488035 662
c23f45d3 663/**
22242c87
EM
664 * Function which needs to be explained.
665 *
c23f45d3 666 * @param array $params
22242c87 667 *
c23f45d3
EM
668 * @return array
669 * @throws \API_Exception
670 */
7811a84b 671function civicrm_api3_mailing_stats($params) {
672 civicrm_api3_verify_mandatory($params,
673 'CRM_Mailing_DAO_MailingJob',
674 array('mailing_id'),
675 FALSE
676 );
677
678 if ($params['date'] == 'now') {
679 $params['date'] = date('YmdHis');
680 }
681 else {
682 $params['date'] = CRM_Utils_Date::processDate($params['date'] . ' ' . $params['date_time']);
683 }
684
685 $stats[$params['mailing_id']] = array();
686 if (empty($params['job_id'])) {
687 $params['job_id'] = NULL;
688 }
689 foreach (array('Delivered', 'Bounces', 'Unsubscribers', 'Unique Clicks', 'Opened') as $detail) {
690 switch ($detail) {
691 case 'Delivered':
692 $stats[$params['mailing_id']] += array(
7c550ca0 693 $detail => CRM_Mailing_Event_BAO_Delivered::getTotalCount($params['mailing_id'], $params['job_id'], FALSE, $params['date']),
7811a84b 694 );
695 break;
ea100cb5 696
7811a84b 697 case 'Bounces':
698 $stats[$params['mailing_id']] += array(
7c550ca0 699 $detail => CRM_Mailing_Event_BAO_Bounce::getTotalCount($params['mailing_id'], $params['job_id'], FALSE, $params['date']),
7811a84b 700 );
701 break;
ea100cb5 702
7811a84b 703 case 'Unsubscribers':
704 $stats[$params['mailing_id']] += array(
7c550ca0 705 $detail => CRM_Mailing_Event_BAO_Unsubscribe::getTotalCount($params['mailing_id'], $params['job_id'], FALSE, NULL, $params['date']),
7811a84b 706 );
707 break;
ea100cb5 708
7811a84b 709 case 'Unique Clicks':
710 $stats[$params['mailing_id']] += array(
7c550ca0 711 $detail => CRM_Mailing_Event_BAO_TrackableURLOpen::getTotalCount($params['mailing_id'], $params['job_id'], FALSE, NULL, $params['date']),
7811a84b 712 );
713 break;
ea100cb5 714
7811a84b 715 case 'Opened':
716 $stats[$params['mailing_id']] += array(
7c550ca0 717 $detail => CRM_Mailing_Event_BAO_Opened::getTotalCount($params['mailing_id'], $params['job_id'], FALSE, $params['date']),
7811a84b 718 );
719 break;
720 }
721 }
722 return civicrm_api3_create_success($stats);
723}
724
6a488035 725/**
22242c87
EM
726 * Fix the reset dates on the email record based on when a mail was last delivered.
727 *
6a488035
TO
728 * We only consider mailings that were completed and finished in the last 3 to 7 days
729 * Both the min and max days can be set via the params
22242c87 730 *
d0997921 731 * @param array $params
22242c87 732 *
645ee340 733 * @return array
6a488035
TO
734 */
735function civicrm_api3_mailing_update_email_resetdate($params) {
7e6e8bd6
TO
736 CRM_Mailing_Event_BAO_Delivered::updateEmailResetDate(
737 CRM_Utils_Array::value('minDays', $params, 3),
738 CRM_Utils_Array::value('maxDays', $params, 3)
739 );
740 return civicrm_api3_create_success();
6a488035 741}