give / src / Log / Migrations / MigrateExistingLogs.php

MigrateExistingLogs.php in GiveWP – Donation Plugin and Fundraising Platform 4.16.9, at src/Log/Migrations/MigrateExistingLogs.php

161 lines 3.9 KB

Raw Download Zip

1	<?php
2
3	namespace Give\Log\Migrations;
4
5	use Give\Framework\Database\DB;
6	use Give\Framework\Migrations\Contracts\Migration;
7	use Give\Log\Helpers\LegacyLogsTable;
8	use Give\Log\Helpers\LogTypeHelper;
9	use Give\Log\LogFactory;
10	use Give_Updates;
11
12	class MigrateExistingLogs extends Migration
13	{
14
15	/**
16	* @var LogTypeHelper
17	*/
18	private $logTypeHelper;
19
20	/**
21	* @var LegacyLogsTable
22	*/
23	private $legacyLogsTable;
24
25	/**
26	* MigrateExistingLogs constructor.
27	*
28	* @param LogTypeHelper $logTypeHelper
29	* @param LegacyLogsTable $legacyLogsTable
30	*/
31	public function __construct(
32	LogTypeHelper $logTypeHelper,
33	LegacyLogsTable $legacyLogsTable
34	) {
35	$this->logTypeHelper = $logTypeHelper;
36	$this->legacyLogsTable = $legacyLogsTable;
37	}
38
39	/**
40	* Register background update.
41	*
42	* @since 2.10.0
43	*
44	* @param Give_Updates $give_updates
45	*
46	*/
47	public function register($give_updates)
48	{
49	$give_updates->register(
50	[
51	'id' => self::id(),
52	'version' => '2.10.0',
53	'callback' => [$this, 'run'],
54	]
55	);
56	}
57
58	/**
59	* @return string
60	*/
61	public static function id()
62	{
63	return 'migrate_existing_logs';
64	}
65
66	/**
67	* @return string
68	*/
69	public static function title()
70	{
71	return esc_html__('Migrate existing logs to give_log table', 'give');
72	}
73
74	/**
75	* @return int
76	*/
77	public static function timestamp()
78	{
79	return strtotime('2021-01-28 13:00');
80	}
81
82	/**
83	* @inheritDoc
84	*
85	* @since 2.21.2 Migration should complete when log table does not exist.
86	*/
87	public function run()
88	{
89	global $wpdb;
90
91	// Check if legacy table exist
92	if ( ! $this->legacyLogsTable->exist()) {
93	give_set_upgrade_complete(self::id());
94	return;
95	}
96
97	$logs_table = "{$wpdb->prefix}give_logs";
98	$logmeta_table = "{$wpdb->prefix}give_logmeta";
99
100	$give_updates = Give_Updates::get_instance();
101
102	$perBatch = 500;
103
104	$offset = ($give_updates->step - 1) * $perBatch;
105
106	$result = DB::get_results(
107	DB::prepare(
108	"SELECT * FROM {$logs_table} LIMIT %d OFFSET %d",
109	$perBatch,
110	$offset
111	)
112	);
113
114	$totalLogs = DB::get_var("SELECT COUNT(id) FROM {$logs_table}");
115
116	if ($result) {
117	$give_updates->set_percentage(
118	$totalLogs,
119	$give_updates->step * $perBatch
120	);
121
122	foreach ($result as $log) {
123	$context = [];
124
125	// Add old data as a context
126	$context['log_date'] = $log->log_date;
127	$context['log_content'] = $log->log_content;
128
129	// Get old log meta
130	$logsMeta = DB::get_results(
131	DB::prepare("SELECT * FROM {$logmeta_table} WHERE log_id = %d", $log->ID)
132	);
133
134	if ($logsMeta) {
135	foreach ($logsMeta as $logMeta) {
136	$context[$logMeta->meta_key] = $logMeta->meta_value;
137	}
138	}
139
140	// Get new type and category
141	$data = $this->logTypeHelper->getDataFromType($log->log_type);
142
143	try {
144	LogFactory::make(
145	$data['type'],
146	$log->log_title,
147	$data['category'],
148	'Log Migration',
149	$context
150	)->save();
151	} catch (\Exception $exception) {
152	$give_updates->pause_db_update(true);
153	update_option('give_upgrade_error', 1, false);
154	}
155	}
156	} else {
157	give_set_upgrade_complete(self::id());
158	}
159	}
160	}
161