give / src / Campaigns / Actions / CacheCampaignData.php

CacheCampaignData.php in GiveWP – Donation Plugin and Fundraising Platform 4.16.8.1, at src/Campaigns/Actions/CacheCampaignData.php

181 lines 5.5 KB

Raw Download Zip

1	<?php
2
3	namespace Give\Campaigns\Actions;
4
5	use Give\Campaigns\CampaignsDataQuery;
6	use Give\Campaigns\Models\Campaign;
7	use Give\Donations\Models\Donation;
8
9	/**
10	* @since 4.8.0
11	*
12	* @uses give_insert_payment hook
13	* @uses give_update_payment_status hook
14	* @uses give_recurring_add_subscription_payment hook
15	* @uses givewp_campaigns_merged hook
16	*
17	* Action used to update campaign's stats data
18	*
19	*/
20	class CacheCampaignData
21	{
22	/**
23	* @since 4.13.1 added dispatch method
24	* @since 4.8.0
25	*/
26	public function __invoke(int $donationId): void
27	{
28	$donation = Donation::find($donationId);
29
30	if (!$donation) {
31	return;
32	}
33
34	if ($donation->status->isComplete() \|\| $donation->status->isRenewal()) {
35	$this->dispatch($donation->campaignId);
36	}
37	}
38
39	/**
40	* Dispatch the cache campaign data action
41	* @since 4.13.1
42	*/
43	public function dispatch(int $campaignId): void
44	{
45	as_enqueue_async_action('givewp_cache_campaign_data', [$campaignId], 'givewp_campaigns_cache');
46	}
47
48	/**
49	* Handle campaign cache
50	* @since 4.8.0
51	*/
52	public function handleCache(int $campaignId): void
53	{
54	$campaign = Campaign::find($campaignId);
55
56	if (!$campaign) {
57	return;
58	}
59
60	$campaignsData = get_option('give_campaigns_data', []);
61	$campaignsSubscriptionData = get_option('give_campaigns_subscription_data', []);
62
63	// Prefill cache structure to ensure keys exist
64	$campaignsData = array_merge([
65	'amounts' => [],
66	'donationsCount' => [],
67	'donorsCount' => []
68	], $campaignsData);
69
70	$campaignsSubscriptionData = array_merge([
71	'amounts' => [],
72	'donationsCount' => [],
73	'donorsCount' => []
74	], $campaignsSubscriptionData);
75
76	$donations = CampaignsDataQuery::donations([$campaign->id]);
77
78	$isCached = $isSubscriptionCached = false;
79
80	// Update cache only if it exists for this campaign
81	foreach ($campaignsData['amounts'] as $i => $data) {
82	if ($data['campaign_id'] == $campaign->id) {
83	$isCached = true;
84
85	$campaignsData['amounts'][$i] = $donations->collectIntendedAmounts()[0];
86	break;
87	}
88	}
89
90	foreach ($campaignsData['donationsCount'] as $i => $data) {
91	if ($data['campaign_id'] == $campaign->id) {
92	$campaignsData['donationsCount'][$i] = $donations->collectDonations()[0];
93	break;
94	}
95	}
96
97	foreach ($campaignsData['donorsCount'] as $i => $data) {
98	if ($data['campaign_id'] == $campaign->id) {
99	$campaignsData['donorsCount'][$i] = $donations->collectDonors()[0];
100	break;
101	}
102	}
103
104
105	// Update campaign subscriptions data
106	if (defined('GIVE_RECURRING_VERSION')) {
107
108	$subscriptions = CampaignsDataQuery::subscriptions([$campaign->id]);
109
110	foreach ($campaignsSubscriptionData['amounts'] as $i => $data) {
111	if ($data['campaign_id'] == $campaign->id) {
112	$isSubscriptionCached = true;
113
114	$campaignsSubscriptionData['amounts'][$i] = $subscriptions->collectInitialAmounts()[0];
115	break;
116	}
117	}
118
119	foreach ($campaignsSubscriptionData['donationsCount'] as $i => $data) {
120	if ($data['campaign_id'] == $campaign->id) {
121	$campaignsSubscriptionData['donationsCount'][$i] = $subscriptions->collectDonations()[0];
122	break;
123	}
124	}
125
126	foreach ($campaignsSubscriptionData['donorsCount'] as $i => $data) {
127	if ($data['campaign_id'] == $campaign->id) {
128	$campaignsSubscriptionData['donorsCount'][$i] = $subscriptions->collectDonors()[0];
129	break;
130	}
131	}
132	}
133
134
135	// Save updated cache
136	if ($isCached) {
137	update_option('give_campaigns_data', $campaignsData);
138	}
139
140	if ($isSubscriptionCached) {
141	update_option('give_campaigns_subscriptions_data', $campaignsSubscriptionData);
142	}
143
144	if ($isCached \|\| $isSubscriptionCached) {
145	return;
146	}
147
148	update_option('give_campaigns_data', [
149	'amounts' => array_merge(
150	$campaignsData['amounts'] ?? [],
151	$donations->collectIntendedAmounts()
152	),
153	'donationsCount' => array_merge(
154	$campaignsData['donationsCount'] ?? [],
155	$donations->collectDonations()
156	),
157	'donorsCount' => array_merge(
158	$campaignsData['donorsCount'] ?? [],
159	$donations->collectDonors()
160	),
161	]);
162
163	if (defined('GIVE_RECURRING_VERSION')) {
164	update_option('give_campaigns_subscriptions_data', [
165	'amounts' => array_merge(
166	$campaignsSubscriptionData['amounts'] ?? [],
167	$subscriptions->collectIntendedAmounts()
168	),
169	'donationsCount' => array_merge(
170	$campaignsSubscriptionData['donationsCount'] ?? [],
171	$subscriptions->collectDonations()
172	),
173	'donorsCount' => array_merge(
174	$campaignsSubscriptionData['donorsCount'] ?? [],
175	$subscriptions->collectDonors()
176	),
177	]);
178	}
179	}
180	}
181