acymailing / back / dynamics / subscription / SubscriptionAutomationActions.php

SubscriptionAutomationActions.php in AcyMailing – An Ultimate Newsletter Plugin and Marketing Automation Solution for WordPress 11.1.0, at back/dynamics/subscription/SubscriptionAutomationActions.php

170 lines 7.2 KB

Raw Download Zip

1	<?php
2
3	use AcyMailing\Classes\FollowupClass;
4	use AcyMailing\Classes\ListClass;
5
6	trait SubscriptionAutomationActions
7	{
8	protected function initAutomationActions(): void
9	{
10	$this->automationActions = [
11	'acy_list' => acym_translation('ACYM_ACYMAILING_LIST'),
12	'subscribe_followup' => acym_translation('ACYM_SUBSCRIBE_FOLLOW_UP'),
13	'unsubscribe_followup' => acym_translation('ACYM_UNSUBSCRIBE_FOLLOW_UP'),
14	];
15	}
16
17	public function displayActionOptions_acy_list(): void
18	{
19	$listClass = new ListClass();
20
21	$listActions = [
22	'sub' => acym_translation('ACYM_SUBSCRIBE_USERS_TO'),
23	'remove' => acym_translation('ACYM_REMOVE_USERS_FROM'),
24	'unsub' => acym_translation('ACYM_UNSUBSCRIBE_USERS_TO'),
25	];
26	$lists = $listClass->getAllForSelect();
27
28	include acym_getPartial('actions', 'acy_list');
29	}
30
31	public function displayActionOptions_subscribe_followup(): void
32	{
33	$followupClass = new FollowupClass();
34	$allListFollowups = $followupClass->getAll();
35
36	include acym_getPartial('actions', 'subscribe_followup');
37	}
38
39	public function displayActionOptions_unsubscribe_followup(): void
40	{
41	$followupClass = new FollowupClass();
42	$allListFollowups = $followupClass->getAll();
43
44	include acym_getPartial('actions', 'unsubscribe_followup');
45	}
46
47	public function onAcymProcessAction_acy_list(&$query, $action)
48	{
49	if ($action['list_actions'] === 'sub') {
50	$queryToProcess = 'INSERT IGNORE #__acym_user_has_list (`user_id`, `list_id`, `status`, `subscription_date`) ('.$query->getQuery(
51	[
52	'user.id',
53	intval($action['list_id']),
54	'1',
55	acym_escapeDB(acym_date(time(), 'Y-m-d H:i:s')),
56	]
57	).') ON DUPLICATE KEY UPDATE status = 1';
58	} elseif ($action['list_actions'] === 'remove') {
59	$queryToProcess = 'DELETE FROM #__acym_user_has_list WHERE list_id = '.intval($action['list_id']).' AND user_id IN ('.$query->getQuery(['user.id']).')';
60	} elseif ($action['list_actions'] === 'unsub') {
61	$queryToProcess = 'UPDATE #__acym_user_has_list SET status = 0, `unsubscribe_date` = '.acym_escapeDB(gmdate('Y-m-d H:i:s', time())).' WHERE list_id = '.intval($action['list_id']).' AND user_id IN ('.$query->getQuery(['user.id']).')';
62	}
63
64	$nbAffected = acym_query($queryToProcess);
65
66	return acym_translationSprintf('ACYM_ACTION_LIST_'.strtoupper($action['list_actions']), $nbAffected);
67	}
68
69	public function onAcymProcessAction_subscribe_followup(&$query, &$action)
70	{
71	$followupClass = new FollowupClass();
72	$followup = $followupClass->getOneById($action['followup_id']);
73	if (empty($followup->active)) {
74	return '';
75	}
76
77	$queryToProcess = 'INSERT IGNORE #__acym_user_has_list (`user_id`, `list_id`, `status`, `subscription_date`) ('.$query->getQuery(
78	[
79	'user.id',
80	$followup->list_id,
81	'1',
82	acym_escapeDB(acym_date(time(), 'Y-m-d H:i:s')),
83	]
84	).') ON DUPLICATE KEY UPDATE status = 1';
85
86	$nbAffected = acym_query($queryToProcess);
87
88	$followups = $followupClass->getFollowupsWithMailsInfoByIds([$action['followup_id']]);
89	foreach ($followups as $mails) {
90	foreach ($mails as $mail) {
91	$sendDate = time() + (intval($mail->delay) * intval($mail->delay_unit));
92	$sendDate = acym_escapeDB(acym_date($sendDate, 'Y-m-d H:i:s', false));
93	$queryToProcess = 'INSERT IGNORE #__acym_queue (`mail_id`, `user_id`, `sending_date`, `priority`, `try`) ('.$query->getQuery(
94	[
95	$mail->mail_id,
96	'user.id',
97	$sendDate,
98	$this->config->get('priority_newsletter', 3),
99	0,
100	]
101	).')';
102
103	acym_query($queryToProcess);
104	}
105	}
106
107	return acym_translationSprintf('ACYM_ACTION_LIST_SUB', $nbAffected);
108	}
109
110	public function onAcymProcessAction_unsubscribe_followup(&$query, &$action)
111	{
112	$followupClass = new FollowupClass();
113	$followup = $followupClass->getOneById($action['followup_id']);
114	if (empty($followup)) {
115	return '';
116	}
117
118	$mailIds = $followupClass->getEmailsByIds([$action['followup_id']]);
119	if (!empty($mailIds)) {
120	acym_query(
121	'DELETE FROM #__acym_queue
122	WHERE user_id IN ('.$query->getQuery(['user.id']).')
123	AND mail_id IN ('.implode(',', $mailIds).')'
124	);
125	}
126
127	$unsubscribeDate = gmdate('Y-m-d H:i:s', time());
128	$nbAffected = acym_query(
129	'UPDATE #__acym_user_has_list
130	SET `status` = 0, `unsubscribe_date` = '.acym_escapeDB($unsubscribeDate).'
131	WHERE list_id = '.intval($followup->list_id).'
132	AND user_id IN ('.$query->getQuery(['user.id']).')'
133	);
134
135	return acym_translationSprintf('ACYM_ACTION_LIST_UNSUB', $nbAffected);
136	}
137
138	public function onAcymDeclareSummary_actions(&$automationAction)
139	{
140	if (!empty($automationAction['acy_list'])) {
141	$listClass = new ListClass();
142	$list = $listClass->getOneById($automationAction['acy_list']['list_id'] ? : 0);
143	if ($automationAction['acy_list']['list_actions'] == 'sub') $automationAction['acy_list']['list_actions'] = 'ACYM_SUBSCRIBED_TO';
144	if ($automationAction['acy_list']['list_actions'] == 'unsub') $automationAction['acy_list']['list_actions'] = 'ACYM_UNSUBSCRIBE_FROM';
145	if ($automationAction['acy_list']['list_actions'] == 'remove') $automationAction['acy_list']['list_actions'] = 'ACYM_REMOVE_FROM';
146	if (empty($list)) {
147	$automationAction = '<span class="acym__color__red">'.acym_translation('ACYM_SELECT_A_LIST').'</span>';
148	} else {
149	$automationAction = acym_translationSprintf('ACYM_ACTION_LIST_SUMMARY', acym_translation($automationAction['acy_list']['list_actions']), $list->name);
150	}
151	}
152
153	if (!empty($automationAction['subscribe_followup'])) {
154	$followupClass = new FollowupClass();
155	$followup = $followupClass->getOneById($automationAction['subscribe_followup']['followup_id']);
156	$automationAction = !empty($followup)
157	? acym_translationSprintf('ACYM_ACTION_SUBSCRIBE_FOLLOWUP_SUMMARY', $followup->name)
158	: acym_translation('ACYM_FOLLOWUP_NOT_FOUND');
159	}
160
161	if (!empty($automationAction['unsubscribe_followup'])) {
162	$followupClass = new FollowupClass();
163	$followup = $followupClass->getOneById($automationAction['unsubscribe_followup']['followup_id']);
164	$automationAction = !empty($followup)
165	? acym_translationSprintf('ACYM_ACTION_UNSUBSCRIBE_FOLLOWUP_SUMMARY', $followup->name)
166	: acym_translation('ACYM_FOLLOWUP_NOT_FOUND');
167	}
168	}
169	}
170