← All changes | src/Packetery/Module/Upgrade.php +212 -138 1.4.2 → 2.3.2 View file →

		@@ -11,8 +11,11 @@
11	11
12	12	use Packetery\Core;
13	13	use Packetery\Core\Log\ILogger;
14	14	use Packetery\Core\Log\Record;
	15	+use Packetery\Module\Carrier\EntityRepository;
	16	+use Packetery\Module\Options\OptionNames;
	17	+use Packetery\Module\Options\OptionsProvider;
15	18	use Packetery\Module\Upgrade\Version_1_4_2;
16	19
17	20	/**
18	21	* Class Upgrade.
		@@ -73,38 +76,53 @@
73	76	*/
74	77	private $carrierRepository;
75	78
76	79	/**
77		- * WPDB.
	80	+ * Customs declaration repository.
78	81	*
79		- * @var \wpdb
	82	+ * @var CustomsDeclaration\Repository
80	83	*/
81		- private $wpdb;
	84	+ private $customsDeclarationRepository;
82	85
83	86	/**
84		- * Constructor.
	87	+ * WpdbAdapter.
85	88	*
86		- * @param Order\Repository $orderRepository Order repository.
87		- * @param MessageManager $messageManager Message manager.
88		- * @param ILogger $logger Logger.
89		- * @param Log\Repository $logRepository Log repository.
90		- * @param \wpdb $wpdb WPDB.
91		- * @param Carrier\Repository $carrierRepository Carrier repository.
	89	+ * @var WpdbAdapter
92	90	*/
	91	+ private $wpdbAdapter;
	92	+
	93	+ /**
	94	+ * Options provider.
	95	+ *
	96	+ * @var OptionsProvider
	97	+ */
	98	+ private $optionsProvider;
	99	+
	100	+ /**
	101	+ * @var EntityRepository
	102	+ */
	103	+ private $carrierEntityRepository;
	104	+
93	105	public function __construct(
94	106	Order\Repository $orderRepository,
95	107	MessageManager $messageManager,
96	108	ILogger $logger,
97	109	Log\Repository $logRepository,
98		- \wpdb $wpdb,
99		- Carrier\Repository $carrierRepository
	110	+ WpdbAdapter $wpdbAdapter,
	111	+ Carrier\Repository $carrierRepository,
	112	+ CustomsDeclaration\Repository $customsDeclarationRepository,
	113	+ OptionsProvider $optionsProvider,
	114	+ EntityRepository $carrierEntityRepository
100	115	) {
101		- $this->orderRepository = $orderRepository;
102		- $this->messageManager = $messageManager;
103		- $this->logger = $logger;
104		- $this->logRepository = $logRepository;
105		- $this->wpdb = $wpdb;
106		- $this->carrierRepository = $carrierRepository;
	116	+ $this->orderRepository = $orderRepository;
	117	+ $this->messageManager = $messageManager;
	118	+ $this->logger = $logger;
	119	+ $this->logRepository = $logRepository;
	120	+ $this->wpdbAdapter = $wpdbAdapter;
	121	+ $this->carrierRepository = $carrierRepository;
	122	+ $this->customsDeclarationRepository = $customsDeclarationRepository;
	123	+ $this->optionsProvider = $optionsProvider;
	124	+ $this->carrierEntityRepository = $carrierEntityRepository;
107	125	}
108	126
109	127	/**
110	128	* Checks previous plugin version and runs upgrade if needed.
		@@ -112,93 +130,120 @@
112	130	*
113	131	* @return void
114	132	*/
115	133	public function check(): void {
116		- $oldVersion = get_option( 'packetery_version' );
117		- if ( Plugin::VERSION === $oldVersion ) {
	134	+ $oldVersion = get_option( OptionNames::VERSION );
	135	+ if ( $oldVersion === Plugin::VERSION ) {
118	136	return;
119	137	}
120	138
121		- $this->logRepository->createTable();
122		- $createResult = $this->carrierRepository->createTable();
123		- if ( false === $createResult ) {
124		- $lastError = $this->wpdb->last_error;
125		- $this->messageManager->flash_message( __( 'Database carrier table was not created, you can find more information in Packeta log.', 'packeta' ), MessageManager::TYPE_ERROR );
	139	+ $this->runCreateTables();
126	140
127		- $record = new Record();
128		- $record->action = Record::ACTION_CARRIER_TABLE_NOT_CREATED;
129		- $record->status = Record::STATUS_ERROR;
130		- $record->title = __( 'Database carrier table was not created.', 'packeta' );
131		- $record->params = [
132		- 'errorMessage' => $lastError,
133		- ];
134		- $this->logger->add( $record );
135		- }
	141	+ // If no previous version detected, no upgrade will be run.
	142	+ if ( $oldVersion !== null && $oldVersion !== false ) {
	143	+ if ( version_compare( $oldVersion, '1.2.0', '<' ) ) {
	144	+ $logEntries = get_posts(
	145	+ [
	146	+ 'post_type' => 'packetery_log',
	147	+ 'post_status' => 'any',
	148	+ 'nopaging' => true,
	149	+ 'fields' => 'ids',
	150	+ ]
	151	+ );
	152	+ foreach ( $logEntries as $logEntryId ) {
	153	+ wp_delete_post( $logEntryId, true );
	154	+ }
136	155
137		- $createResult = $this->orderRepository->createTable();
138		- if ( false === $createResult ) {
139		- $lastError = $this->wpdb->last_error;
140		- $this->messageManager->flash_message( __( 'Database order table was not created, you can find more information in Packeta log.', 'packeta' ), MessageManager::TYPE_ERROR );
	156	+ unregister_post_type( 'packetery_log' );
141	157
142		- $record = new Record();
143		- $record->action = Record::ACTION_ORDER_TABLE_NOT_CREATED;
144		- $record->status = Record::STATUS_ERROR;
145		- $record->title = __( 'Database order table was not created.', 'packeta' );
146		- $record->params = [
147		- 'errorMessage' => $lastError,
148		- ];
149		- $this->logger->add( $record );
150		- }
	158	+ $this->migrateWpOrderMetadata();
	159	+ $addressEntries = get_posts(
	160	+ [
	161	+ 'post_type' => self::POST_TYPE_VALIDATED_ADDRESS,
	162	+ 'post_status' => 'any',
	163	+ 'nopaging' => true,
	164	+ 'fields' => 'ids',
	165	+ ]
	166	+ );
	167	+ foreach ( $addressEntries as $addressEntryId ) {
	168	+ wp_delete_post( $addressEntryId, true );
	169	+ }
151	170
152		- // If no previous version detected, no upgrade will be run.
153		- if ( $oldVersion && version_compare( $oldVersion, '1.2.0', '<' ) ) {
154		- $logEntries = get_posts(
155		- [
156		- 'post_type' => 'packetery_log',
157		- 'post_status' => 'any',
158		- 'nopaging' => true,
159		- 'fields' => 'ids',
160		- ]
161		- );
162		- foreach ( $logEntries as $logEntryId ) {
163		- wp_delete_post( $logEntryId, true );
	171	+ unregister_post_type( self::POST_TYPE_VALIDATED_ADDRESS );
164	172	}
165	173
166		- unregister_post_type( 'packetery_log' );
	174	+ if ( version_compare( $oldVersion, '1.2.6', '<' ) ) {
	175	+ $this->orderRepository->deleteOrphans();
	176	+ }
167	177
168		- $this->migrateWpOrderMetadata();
169		- $addressEntries = get_posts(
170		- [
171		- 'post_type' => self::POST_TYPE_VALIDATED_ADDRESS,
172		- 'post_status' => 'any',
173		- 'nopaging' => true,
174		- 'fields' => 'ids',
175		- ]
176		- );
177		- foreach ( $addressEntries as $addressEntryId ) {
178		- wp_delete_post( $addressEntryId, true );
	178	+ if ( version_compare( $oldVersion, '1.4.2', '<' ) ) {
	179	+ $migration = new Version_1_4_2( $this->wpdbAdapter );
	180	+ $migration->run();
179	181	}
180	182
181		- unregister_post_type( self::POST_TYPE_VALIDATED_ADDRESS );
182		- }
	183	+ if ( version_compare( $oldVersion, '1.5', '<' ) ) {
	184	+ wp_clear_scheduled_hook( CronService::CRON_CARRIERS_HOOK );
	185	+ }
183	186
184		- if ( $oldVersion && version_compare( $oldVersion, '1.2.6', '<' ) ) {
185		- $this->orderRepository->deleteOrphans();
186		- }
	187	+ if ( version_compare( $oldVersion, '1.6.0', '<' ) ) {
	188	+ wp_clear_scheduled_hook( CronService::CRON_LOG_AUTO_DELETION_HOOK );
	189	+ wp_clear_scheduled_hook( CronService::CRON_PACKET_STATUS_SYNC_HOOK );
	190	+ }
187	191
188		- if ( $oldVersion && version_compare( $oldVersion, '1.4', '<' ) ) {
189		- $this->logRepository->addOrderIdColumn();
190		- $this->orderRepository->addAdultContentColumn();
191		- $this->orderRepository->addValueColumn();
192		- $this->orderRepository->addCodColumn();
	192	+ if ( version_compare( $oldVersion, '1.7.0', '<' ) ) {
	193	+ $orderStatusAutoChange = $this->optionsProvider->isOrderStatusAutoChangeEnabled();
	194	+ $autoOrderStatus = $this->optionsProvider->getAutoOrderStatus();
	195	+ $syncSettings = $this->optionsProvider->getOptionsByName( OptionNames::PACKETERY_SYNC );
	196	+ if ( $orderStatusAutoChange ) {
	197	+ $syncSettings['allow_order_status_change'] = true;
	198	+ }
	199	+ if ( $autoOrderStatus !== null ) {
	200	+ $syncSettings['order_status_change_packet_statuses'] = [
	201	+ Core\Entity\PacketStatus::RECEIVED_DATA => $autoOrderStatus,
	202	+ ];
	203	+ }
	204	+
	205	+ update_option( OptionNames::PACKETERY_SYNC, $syncSettings );
	206	+ }
	207	+
	208	+ if ( version_compare( $oldVersion, '1.7.1', '<' ) ) {
	209	+ $syncSettings = $this->optionsProvider->getOptionsByName( OptionNames::PACKETERY_SYNC );
	210	+ if (
	211	+ isset( $syncSettings['order_status_change_packet_statuses'][ Core\Entity\PacketStatus::RECEIVED_DATA ] ) &&
	212	+ $syncSettings['order_status_change_packet_statuses'][ Core\Entity\PacketStatus::RECEIVED_DATA ] === ''
	213	+ ) {
	214	+ unset( $syncSettings['order_status_change_packet_statuses'][ Core\Entity\PacketStatus::RECEIVED_DATA ] );
	215	+ update_option( OptionNames::PACKETERY_SYNC, $syncSettings );
	216	+ }
	217	+ }
	218	+
	219	+ if ( version_compare( $oldVersion, '1.8.0', '<' ) ) {
	220	+ $generalSettings = $this->optionsProvider->getOptionsByName( OptionNames::PACKETERY );
	221	+ if ( isset( $generalSettings['cod_payment_method'] ) ) {
	222	+ $generalSettings['cod_payment_methods'] = [ $generalSettings['cod_payment_method'] ];
	223	+ unset( $generalSettings['cod_payment_method'] );
	224	+ }
	225	+
	226	+ update_option( OptionNames::PACKETERY, $generalSettings );
	227	+ }
	228	+
	229	+ if ( version_compare( $oldVersion, '2.1.0', '<' ) ) {
	230	+ add_option( OptionNames::PACKETERY_TUTORIAL_ORDER_DETAIL_EDIT_PACKET, 0 );
	231	+ add_option( OptionNames::PACKETERY_TUTORIAL_ORDER_GRID_EDIT_PACKET, 0 );
	232	+ }
	233	+ } else {
	234	+ add_option( OptionNames::PACKETERY_TUTORIAL_ORDER_DETAIL_EDIT_PACKET, 1 );
	235	+ add_option( OptionNames::PACKETERY_TUTORIAL_ORDER_GRID_EDIT_PACKET, 1 );
193	236	}
194	237
195		- if ( $oldVersion && version_compare( $oldVersion, '1.4.2', '<' ) ) {
196		- $version_1_4_2 = new Version_1_4_2( $this->wpdb );
197		- $version_1_4_2->run();
198		- }
	238	+ update_option( OptionNames::VERSION, Plugin::VERSION );
	239	+ }
199	240
200		- update_option( 'packetery_version', Plugin::VERSION );
	241	+ public function runCreateTables(): void {
	242	+ $this->createLogTable();
	243	+ $this->createCarrierTable();
	244	+ $this->createOrderTable();
	245	+ $this->createCustomsDeclarationTables();
201	246	}
202	247
203	248	/**
204	249	* Migrates WP order metadata.
		@@ -205,30 +250,26 @@
205	250	*
206	251	* @return void
207	252	*/
208	253	private function migrateWpOrderMetadata(): void {
209		- global $wpdb;
	254	+ $this->createOrderTable();
210	255
211		- $createResult = $this->orderRepository->createTable();
212		- if ( false === $createResult ) {
213		- $lastError = $wpdb->last_error;
214		- $this->messageManager->flash_message( __( 'Database order table was not created, you can find more information in Packeta log.', 'packeta' ), MessageManager::TYPE_ERROR );
215		-
216		- $record = new Record();
217		- $record->action = Record::ACTION_ORDER_TABLE_NOT_CREATED;
218		- $record->status = Record::STATUS_ERROR;
219		- $record->title = __( 'Database order table was not created.', 'packeta' );
220		- $record->params = [
221		- 'errorMessage' => $lastError,
222		- ];
223		- $this->logger->add( $record );
224		- }
225		-
226	256	// Did not work when called from plugins_loaded hook.
227	257	$orders = wc_get_orders(
228	258	[
229		- 'packetery_all' => '1',
230		- 'nopaging' => true,
	259	+ 'nopaging' => true,
	260	+ // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_query
	261	+ 'meta_query' => [
	262	+ [
	263	+ 'key' => self::META_CARRIER_ID,
	264	+ 'compare' => 'EXISTS',
	265	+ ],
	266	+ [
	267	+ 'key' => self::META_CARRIER_ID,
	268	+ 'compare' => '!=',
	269	+ 'value' => '',
	270	+ ],
	271	+ ],
231	272	]
232	273	);
233	274
234	275	foreach ( $orders as $order ) {
		@@ -233,9 +274,9 @@
233	274
234	275	foreach ( $orders as $order ) {
235	276	$orderEntity = new Core\Entity\Order(
236	277	(string) $order->get_id(),
237		- $this->getMetaAsNullableString( $order, self::META_CARRIER_ID )
	278	+ $this->carrierEntityRepository->getAnyById( $this->getMetaAsNullableString( $order, self::META_CARRIER_ID ) )
238	279	);
239	280	$order->delete_meta_data( self::META_CARRIER_ID );
240	281
241	282	$orderEntity->setWeight( $this->getMetaAsNullableFloat( $order, self::META_WEIGHT ) );
		@@ -266,12 +307,13 @@
266	307	$order->delete_meta_data( self::META_LENGTH );
267	308	$order->delete_meta_data( self::META_WIDTH );
268	309	$order->delete_meta_data( self::META_HEIGHT );
269	310
270		- if ( null !== $this->getMetaAsNullableString( $order, self::META_POINT_ID ) ) {
	311	+ if ( $this->getMetaAsNullableString( $order, self::META_POINT_ID ) !== null ) {
271	312	$orderEntity->setPickupPoint(
272	313	new Core\Entity\PickupPoint(
273	314	$this->getMetaAsNullableString( $order, self::META_POINT_ID ),
	315	+ null,
274	316	$this->getMetaAsNullableString( $order, self::META_POINT_NAME ),
275	317	$this->getMetaAsNullableString( $order, self::META_POINT_CITY ),
276	318	$this->getMetaAsNullableString( $order, self::META_POINT_ZIP ),
277	319	$this->getMetaAsNullableString( $order, self::META_POINT_STREET ),
		@@ -286,9 +328,9 @@
286	328	$order->delete_meta_data( self::META_POINT_STREET );
287	329	$order->delete_meta_data( self::META_POINT_URL );
288	330
289	331	$validatedAddressId = $this->getValidatedAddressIdByOrderId( (int) $order->get_id() );
290		- if ( $validatedAddressId ) {
	332	+ if ( $validatedAddressId !== null ) {
291	333	$validatedAddress = $this->createAddressFromPostId( $validatedAddressId );
292	334	$orderEntity->setAddressValidated( true );
293	335	$orderEntity->setDeliveryAddress( $validatedAddress );
294	336	}
		@@ -293,8 +335,9 @@
293	335	$orderEntity->setDeliveryAddress( $validatedAddress );
294	336	}
295	337
296	338	$this->orderRepository->save( $orderEntity );
	339	+ // Ignore errors. Save the metadata even if the previous call fails.
297	340	$order->save_meta_data();
298	341	}
299	342	}
300	343
		@@ -337,9 +380,9 @@
337	380	'post_parent' => $orderId,
338	381	]
339	382	);
340	383
341		- if ( empty( $postIds ) ) {
	384	+ if ( count( $postIds ) === 0 ) {
342	385	return null;
343	386	}
344	387
345	388	return (int) array_shift( $postIds );
		@@ -354,9 +397,10 @@
354	397	* @return string|null
355	398	*/
356	399	private function getMetaAsNullableString( \WC_Order $order, string $key ): ?string {
357	400	$value = $order->get_meta( $key, true );
358		- return ( ( null !== $value && '' !== $value ) ? (string) $value : null );
	401	+
	402	+ return ( ( $value !== null && $value !== '' ) ? (string) $value : null );
359	403	}
360	404
361	405	/**
362	406	* Gets meta property of order as float.
		@@ -367,51 +411,81 @@
367	411	* @return float|null
368	412	*/
369	413	private function getMetaAsNullableFloat( \WC_Order $order, string $key ): ?float {
370	414	$value = $order->get_meta( $key, true );
371		- return ( ( null !== $value && '' !== $value ) ? (float) $value : null );
	415	+
	416	+ return ( ( $value !== null && $value !== '' ) ? (float) $value : null );
372	417	}
373	418
374	419	/**
375		- * Transforms custom query variable to meta query.
	420	+ * Creates log table.
376	421	*
377		- * @param array $queryVars Query vars.
378		- * @param array $get Input values.
	422	+ * @return void
	423	+ */
	424	+ private function createLogTable(): void {
	425	+ if ( $this->logRepository->createOrAlterTable() === false ) {
	426	+ $this->messageManager->flash_message(
	427	+ // translators: %s: Short table name.
	428	+ sprintf( __( 'Database %s table could not be created or altered, more information might be found in WooCommerce logs.', 'packeta' ), 'log' ),
	429	+ MessageManager::TYPE_ERROR
	430	+ );
	431	+ }
	432	+ }
	433	+
	434	+ /**
	435	+ * Creates carrier table.
379	436	*
380		- * @return array
	437	+ * @return void
381	438	*/
382		- public function handleCustomQueryVar( array $queryVars, array $get ): array {
383		- $metaQuery = $this->addQueryVars( ( $queryVars['meta_query'] ?? [] ), $get );
384		- if ( $metaQuery ) {
385		- // @codingStandardsIgnoreStart
386		- $queryVars['meta_query'] = $metaQuery;
387		- // @codingStandardsIgnoreEnd
	439	+ private function createCarrierTable(): void {
	440	+ if ( $this->carrierRepository->createOrAlterTable() === false ) {
	441	+ $this->flashAndLog( 'carrier', Record::ACTION_CARRIER_TABLE_NOT_CREATED );
388	442	}
	443	+ }
389	444
390		- return $queryVars;
	445	+ /**
	446	+ * Creates order table.
	447	+ *
	448	+ * @return void
	449	+ */
	450	+ private function createOrderTable(): void {
	451	+ if ( $this->orderRepository->createOrAlterTable() === false ) {
	452	+ $this->flashAndLog( 'order', Record::ACTION_ORDER_TABLE_NOT_CREATED );
	453	+ }
391	454	}
392	455
393	456	/**
394		- * Adds query vars to fetch order list.
	457	+ * Creates order table.
395	458	*
396		- * @param array $queryVars Query vars.
397		- * @param array $get Get parameters.
398		- *
399		- * @return array
	459	+ * @return void
400	460	*/
401		- private function addQueryVars( array $queryVars, array $get ): array {
402		- if ( ! empty( $get['packetery_all'] ) ) {
403		- $queryVars[] = [
404		- 'key' => self::META_CARRIER_ID,
405		- 'compare' => 'EXISTS',
406		- ];
407		- $queryVars[] = [
408		- 'key' => self::META_CARRIER_ID,
409		- 'value' => '',
410		- 'compare' => '!=',
411		- ];
	461	+ private function createCustomsDeclarationTables(): void {
	462	+ if ( $this->customsDeclarationRepository->createOrAlterTable() === false ) {
	463	+ $this->flashAndLog( 'customs_declaration', Record::ACTION_CUSTOMS_DECLARATION_TABLE_NOT_CREATED );
412	464	}
413	465
414		- return $queryVars;
	466	+ if ( $this->customsDeclarationRepository->createOrAlterItemTable() === false ) {
	467	+ $this->flashAndLog( 'customs_declaration_item', Record::ACTION_CUSTOMS_DECLARATION_ITEM_TABLE_NOT_CREATED );
	468	+ }
415	469	}
416	470
	471	+ /**
	472	+ * Flashes error and logs to Packeta log.
	473	+ *
	474	+ * @param string $table Short table name.
	475	+ * @param string $action Log action.
	476	+ *
	477	+ * @return void
	478	+ */
	479	+ private function flashAndLog( string $table, string $action ): void {
	480	+ // translators: %s: Short table name.
	481	+ $flashMessage = sprintf( __( 'Database %s table of Packeta plugin could not be created or altered, you can find more information in Packeta log.', 'packeta' ), $table );
	482	+ $this->messageManager->flash_message( $flashMessage, MessageManager::TYPE_ERROR );
	483	+
	484	+ $record = new Record();
	485	+ $record->action = $action;
	486	+ $record->status = Record::STATUS_ERROR;
	487	+ // translators: %s: Short table name.
	488	+ $record->title = sprintf( __( 'Database %s table could not be created or altered, more information might be found in WooCommerce logs.', 'packeta' ), $table );
	489	+ $this->logger->add( $record );
	490	+ }
417	491	}