CampaignPageRepository.php
1 year ago
CampaignRepository.php
1 year ago
CampaignsDataRepository.php
1 year ago
CampaignPageRepository.php
230 lines
| 1 | <?php |
| 2 | |
| 3 | namespace Give\Campaigns\Repositories; |
| 4 | |
| 5 | use Give\Campaigns\Actions\CreateDefaultLayoutForCampaignPage; |
| 6 | use Give\Campaigns\Models\CampaignPage; |
| 7 | use Give\Campaigns\ValueObjects\CampaignPageMetaKeys; |
| 8 | use Give\Campaigns\ValueObjects\CampaignPageStatus; |
| 9 | use Give\Framework\Database\DB; |
| 10 | use Give\Framework\Exceptions\Primitives\Exception; |
| 11 | use Give\Framework\Exceptions\Primitives\InvalidArgumentException; |
| 12 | use Give\Framework\Models\ModelQueryBuilder; |
| 13 | use Give\Framework\Support\Facades\DateTime\Temporal; |
| 14 | use Give\Helpers\Hooks; |
| 15 | use Give\Log\Log; |
| 16 | |
| 17 | /** |
| 18 | * @since 4.0.0 |
| 19 | */ |
| 20 | class CampaignPageRepository |
| 21 | { |
| 22 | /** |
| 23 | * @since 4.0.0 |
| 24 | */ |
| 25 | protected $requiredProperties = [ |
| 26 | 'campaignId', |
| 27 | ]; |
| 28 | |
| 29 | /** |
| 30 | * @since 4.0.0 |
| 31 | */ |
| 32 | public function getById(int $id): ?CampaignPage |
| 33 | { |
| 34 | return $this->prepareQuery() |
| 35 | ->where('id', $id) |
| 36 | ->get(); |
| 37 | } |
| 38 | |
| 39 | /** |
| 40 | * @since 4.0.0 |
| 41 | */ |
| 42 | public function queryByCampaignId(int $campaignId): ModelQueryBuilder |
| 43 | { |
| 44 | return $this->prepareQuery() |
| 45 | ->where('postmeta_attach_meta_campaignId.meta_value', $campaignId); |
| 46 | } |
| 47 | |
| 48 | /** |
| 49 | * @since 4.0.0 |
| 50 | */ |
| 51 | public function findByCampaignId(int $campaignId): ?CampaignPage |
| 52 | { |
| 53 | return $this->queryByCampaignId($campaignId)->get(); |
| 54 | } |
| 55 | |
| 56 | /** |
| 57 | * @since 4.0.0 |
| 58 | * @throws Exception |
| 59 | */ |
| 60 | public function insert(CampaignPage $campaignPage): void |
| 61 | { |
| 62 | $this->validate($campaignPage); |
| 63 | |
| 64 | Hooks::doAction('givewp_campaign_page_creating', $campaignPage); |
| 65 | |
| 66 | $dateCreated = Temporal::withoutMicroseconds($campaignPage->createdAt ?: Temporal::getCurrentDateTime()); |
| 67 | $dateCreatedFormatted = Temporal::getFormattedDateTime($dateCreated); |
| 68 | $dateUpdated = $campaignPage->updatedAt ?? $dateCreated; |
| 69 | $dateUpdatedFormatted = Temporal::getFormattedDateTime($dateUpdated); |
| 70 | $status = $campaignPage->status ?? CampaignPageStatus::DRAFT(); |
| 71 | $campaign = $campaignPage->campaign(); |
| 72 | |
| 73 | if (!$campaign) { |
| 74 | throw new Exception('Campaign not found'); |
| 75 | } |
| 76 | |
| 77 | DB::query('START TRANSACTION'); |
| 78 | |
| 79 | try { |
| 80 | $campaignPage->id = wp_insert_post([ |
| 81 | 'post_title' => $campaign->title, |
| 82 | 'post_name' => sanitize_title($campaign->title), |
| 83 | 'post_date' => $dateCreatedFormatted, |
| 84 | 'post_modified' => $dateUpdatedFormatted, |
| 85 | 'post_status' => $status->getValue(), |
| 86 | 'post_type' => 'page', |
| 87 | 'post_content' => give(CreateDefaultLayoutForCampaignPage::class)( |
| 88 | $campaign->id, |
| 89 | $campaign->shortDescription |
| 90 | ), |
| 91 | ]); |
| 92 | |
| 93 | if (!$campaignPage->id) { |
| 94 | throw new Exception('Failed creating a campaign page'); |
| 95 | } |
| 96 | |
| 97 | $campaignPage->createdAt = $dateCreated; |
| 98 | $campaignPage->updatedAt = $dateUpdated; |
| 99 | $campaignPage->status = $status; |
| 100 | |
| 101 | update_post_meta($campaignPage->id, CampaignPageMetaKeys::CAMPAIGN_ID, $campaignPage->campaignId); |
| 102 | |
| 103 | if ($campaign->image && $imageId = attachment_url_to_postid($campaign->image)) { |
| 104 | set_post_thumbnail($campaignPage->id, $imageId); |
| 105 | } |
| 106 | } catch (Exception $exception) { |
| 107 | DB::query('ROLLBACK'); |
| 108 | |
| 109 | Log::error('Failed creating a campaign page', [$campaignPage]); |
| 110 | |
| 111 | throw new $exception('Failed creating a campaign page'); |
| 112 | } |
| 113 | |
| 114 | DB::query('COMMIT'); |
| 115 | |
| 116 | Hooks::doAction('givewp_campaign_page_created', $campaignPage); |
| 117 | } |
| 118 | |
| 119 | /** |
| 120 | * @since 4.0.0 |
| 121 | * @throws Exception |
| 122 | */ |
| 123 | public function update(CampaignPage $campaignPage): void |
| 124 | { |
| 125 | $this->validate($campaignPage); |
| 126 | |
| 127 | Hooks::doAction('givewp_campaign_page_updating', $campaignPage); |
| 128 | |
| 129 | $now = Temporal::withoutMicroseconds(Temporal::getCurrentDateTime()); |
| 130 | $nowFormatted = Temporal::getFormattedDateTime($now); |
| 131 | $status = $campaignPage->status ?? CampaignPageStatus::PUBLISH(); |
| 132 | |
| 133 | DB::query('START TRANSACTION'); |
| 134 | |
| 135 | try { |
| 136 | DB::table('posts') |
| 137 | ->where('ID', $campaignPage->id) |
| 138 | ->update([ |
| 139 | 'post_modified' => $nowFormatted, |
| 140 | 'post_modified_gmt' => get_gmt_from_date($nowFormatted), |
| 141 | 'post_status' => $status->getValue(), |
| 142 | ]); |
| 143 | |
| 144 | $campaignPage->updatedAt = $now; |
| 145 | $campaignPage->status = $status; |
| 146 | |
| 147 | update_post_meta($campaignPage->id, CampaignPageMetaKeys::CAMPAIGN_ID, $campaignPage->campaignId); |
| 148 | } catch (Exception $exception) { |
| 149 | DB::query('ROLLBACK'); |
| 150 | |
| 151 | Log::error('Failed updating a campaign page', [$campaignPage]); |
| 152 | |
| 153 | throw new $exception('Failed updating a campaign page'); |
| 154 | } |
| 155 | |
| 156 | DB::query('COMMIT'); |
| 157 | |
| 158 | Hooks::doAction('givewp_campaign_page_updated', $campaignPage); |
| 159 | } |
| 160 | |
| 161 | /** |
| 162 | * @since 4.0.0 |
| 163 | * @throws Exception |
| 164 | */ |
| 165 | public function delete(CampaignPage $campaignPage): bool |
| 166 | { |
| 167 | DB::query('START TRANSACTION'); |
| 168 | |
| 169 | Hooks::doAction('givewp_campaign_page_deleting', $campaignPage); |
| 170 | |
| 171 | try { |
| 172 | DB::table('posts') |
| 173 | ->where('id', $campaignPage->id) |
| 174 | ->delete(); |
| 175 | |
| 176 | DB::table('postmeta') |
| 177 | ->where('post_id', $campaignPage->id) |
| 178 | ->delete(); |
| 179 | } catch (Exception $exception) { |
| 180 | DB::query('ROLLBACK'); |
| 181 | |
| 182 | Log::error('Failed deleting a campaign page', [$campaignPage]); |
| 183 | |
| 184 | throw new $exception('Failed deleting a campaign page'); |
| 185 | } |
| 186 | |
| 187 | DB::query('COMMIT'); |
| 188 | |
| 189 | Hooks::doAction('givewp_campaign_page_deleted', $campaignPage); |
| 190 | |
| 191 | return true; |
| 192 | } |
| 193 | |
| 194 | /** |
| 195 | * @since 4.0.0 |
| 196 | * |
| 197 | * @return ModelQueryBuilder<CampaignPage> |
| 198 | */ |
| 199 | public function prepareQuery(): ModelQueryBuilder |
| 200 | { |
| 201 | $builder = new ModelQueryBuilder(CampaignPage::class); |
| 202 | |
| 203 | return $builder->from('posts') |
| 204 | ->select( |
| 205 | ['ID', 'id'], |
| 206 | ['post_date', 'createdAt'], |
| 207 | ['post_modified', 'updatedAt'], |
| 208 | ['post_status', 'status'] |
| 209 | ) |
| 210 | ->attachMeta( |
| 211 | 'postmeta', |
| 212 | 'ID', |
| 213 | 'post_id', |
| 214 | ...CampaignPageMetaKeys::getColumnsForAttachMetaQuery() |
| 215 | ); |
| 216 | } |
| 217 | |
| 218 | /** |
| 219 | * @since 4.0.0 |
| 220 | */ |
| 221 | public function validate(CampaignPage $campaignPage) |
| 222 | { |
| 223 | foreach ($this->requiredProperties as $key) { |
| 224 | if (!isset($campaignPage->$key)) { |
| 225 | throw new InvalidArgumentException("'$key' is required."); |
| 226 | } |
| 227 | } |
| 228 | } |
| 229 | } |
| 230 |