Completed
Branch master (148746)
by
unknown
08:25 queued 02:26
created
core/data_migration_scripts/EE_Data_Migration_Class_Base.core.php 2 patches
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -185,7 +185,7 @@  discard block
 block discarded – undo
185 185
      */
186 186
     public function add_error($error, $force = false)
187 187
     {
188
-        if (! defined('EE_DMS_ERROR_LIMIT')) {
188
+        if ( ! defined('EE_DMS_ERROR_LIMIT')) {
189 189
             $limit = 50;
190 190
         } else {
191 191
             $limit = EE_DMS_ERROR_LIMIT;
@@ -201,7 +201,7 @@  discard block
 block discarded – undo
201 201
                 $this->_errors[] = "Limit reached; removed first half of errors to save space";
202 202
                 $this->_errors[] = $error;
203 203
             } else {
204
-                $this->_errors[ $limit ] = 'More, but limit reached...';
204
+                $this->_errors[$limit] = 'More, but limit reached...';
205 205
             }
206 206
         } else {
207 207
             $this->_errors[] = $error;
@@ -345,7 +345,7 @@  discard block
 block discarded – undo
345 345
         $new_columns_and_values_for_string = array();
346 346
         $count = 0;
347 347
         foreach ($new_row_as_array as $column => $value) {
348
-            $new_columns_and_values_for_string[] = " $column => $value (" . $data_types[ $count++ ] . ")";
348
+            $new_columns_and_values_for_string[] = " $column => $value (".$data_types[$count++].")";
349 349
         }
350 350
         return sprintf(
351 351
             esc_html__(
@@ -376,7 +376,7 @@  discard block
 block discarded – undo
376 376
         foreach ($array_of_data as $name => $value) {
377 377
             $unserialized_data = @unserialize($value);
378 378
             if ($unserialized_data === false) {
379
-                $fields_to_include[ $name ] = $value;
379
+                $fields_to_include[$name] = $value;
380 380
             }
381 381
         }
382 382
         return wp_json_encode($fields_to_include);
Please login to merge, or discard this patch.
Indentation   +404 added lines, -404 removed lines patch added patch discarded remove patch
@@ -16,408 +16,408 @@
 block discarded – undo
16 16
  */
17 17
 abstract class EE_Data_Migration_Class_Base
18 18
 {
19
-    /**
20
-     * @var $records_to_migrate int count of all that have been migrated
21
-     */
22
-    protected $_records_to_migrate = 0;
23
-
24
-    /**
25
-     *
26
-     * @var $records_migrated int
27
-     */
28
-    protected $_records_migrated = 0;
29
-
30
-    /**
31
-     * Whether this migration script is done or not. This COULD be deduced by
32
-     * _records_to_migrate and _records_migrated, but that might nto be accurate
33
-     *
34
-     * @var string one of EE_Data_migration_Manager::status_* constants
35
-     */
36
-    protected $_status = null;
37
-
38
-    /**
39
-     * internationalized name of this class. Convention is to NOT restate that
40
-     * this class if a migration script or a migration script stage
41
-     *
42
-     * @var string (i18ned)
43
-     */
44
-    protected $_pretty_name = null;
45
-
46
-    /**
47
-     * @var array
48
-     */
49
-    protected $_errors = array();
50
-
51
-    /**
52
-     * @var \EventEspresso\core\services\database\TableManager $table_manager
53
-     */
54
-    protected $_table_manager;
55
-
56
-    /**
57
-     * @var \EventEspresso\core\services\database\TableAnalysis $table_analysis
58
-     */
59
-    protected $_table_analysis;
60
-
61
-
62
-    /**
63
-     * Just initializes the status of the migration
64
-     *
65
-     * @param TableManager  $table_manager
66
-     * @param TableAnalysis $table_analysis
67
-     */
68
-    public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null)
69
-    {
70
-        $this->_table_manager = $table_manager;
71
-        $this->_table_analysis = $table_analysis;
72
-        $this->set_status(EE_Data_Migration_Manager::status_continue);
73
-    }
74
-
75
-
76
-    /**
77
-     * Just gets the pretty name for this migration script or stage
78
-     *
79
-     * @throws EE_Error
80
-     * @return string
81
-     */
82
-    public function pretty_name()
83
-    {
84
-        if ($this->_pretty_name === null) {
85
-            throw new EE_Error(
86
-                sprintf(
87
-                    esc_html__(
88
-                        "Please give a pretty name to the migration script stage %s by assigning the property _pretty_name in the constructor",
89
-                        "event_espresso"
90
-                    ),
91
-                    get_class($this)
92
-                )
93
-            );
94
-        }
95
-        return $this->_pretty_name;
96
-    }
97
-
98
-    /**
99
-     *
100
-     * @return int
101
-     */
102
-    public function count_records_to_migrate()
103
-    {
104
-        if ($this->_records_to_migrate == null) {
105
-            $this->_records_to_migrate = $this->_count_records_to_migrate();
106
-        }
107
-        return $this->_records_to_migrate;
108
-    }
109
-
110
-    /**
111
-     * Counts records already migrated. This should only be implemented by EE_Data_Migration_Script_base and
112
-     * EE_Data_migration_Script_Stage
113
-     *
114
-     * @return int
115
-     */
116
-    abstract public function count_records_migrated();
117
-
118
-    /**
119
-     * Counts the records to migrate; the public version may cache it
120
-     *
121
-     * @return int
122
-     */
123
-    abstract protected function _count_records_to_migrate();
124
-
125
-    /**
126
-     * Returns a string indicating the migration script's status.
127
-     *
128
-     * @return string one of EE_Data_Migration_Manager::status_* constants
129
-     * @throws EE_Error
130
-     */
131
-    public function get_status()
132
-    {
133
-        if ($this->_status === null) {
134
-            throw new EE_Error(
135
-                sprintf(
136
-                    esc_html__(
137
-                        "Trying to get status of Migration class %s, but it has not been initialized yet. It should be set in the constructor.",
138
-                        "event_espresso"
139
-                    ),
140
-                    get_class($this)
141
-                )
142
-            );
143
-        }
144
-        return $this->_status;
145
-    }
146
-
147
-    /**
148
-     *
149
-     * @param string $status
150
-     * @return void
151
-     */
152
-    protected function set_status($status)
153
-    {
154
-        $this->_status = $status;
155
-    }
156
-
157
-    /**
158
-     * @return array of strings
159
-     */
160
-    abstract public function get_errors();
161
-
162
-    /**
163
-     * Returns the last error that occurred. If none occurred, returns null
164
-     *
165
-     * @return string
166
-     */
167
-    public function get_last_error()
168
-    {
169
-        $errors = $this->get_errors();
170
-        if ($errors) {
171
-            return end($errors);
172
-        } else {
173
-            return null;
174
-        }
175
-    }
176
-
177
-    /**
178
-     * Adds an error to the array of errors on this class.
179
-     *
180
-     * @param string  $error a string describing the error that will be useful for debugging. Consider including all
181
-     *                       the data that led to the error, and a stack trace etc.
182
-     * @param boolean $force force the error to be added (because otherwise we have a limit). If forcing and errors are
183
-     *                       already at their limit, we will purposefully forget the first half
184
-     */
185
-    public function add_error($error, $force = false)
186
-    {
187
-        if (! defined('EE_DMS_ERROR_LIMIT')) {
188
-            $limit = 50;
189
-        } else {
190
-            $limit = EE_DMS_ERROR_LIMIT;
191
-        }
192
-        // make sure errors is an array, see ticket #8261
193
-        if (is_string($this->_errors)) {
194
-            $this->_errors = array($this->_errors);
195
-        }
196
-        if (count($this->_errors) >= $limit) {
197
-            if ($force) {
198
-                // get rid of the first half of the errors and any above the limit
199
-                $this->_errors = array_slice($this->_errors, $limit / 2, $limit / 2);
200
-                $this->_errors[] = "Limit reached; removed first half of errors to save space";
201
-                $this->_errors[] = $error;
202
-            } else {
203
-                $this->_errors[ $limit ] = 'More, but limit reached...';
204
-            }
205
-        } else {
206
-            $this->_errors[] = $error;
207
-        }
208
-    }
209
-
210
-    /**
211
-     * Indicates there was a fatal error and the migration cannot possibly continue
212
-     *
213
-     * @return boolean
214
-     */
215
-    public function is_broken()
216
-    {
217
-        return $this->get_status() == EE_Data_Migration_Manager::status_fatal_error;
218
-    }
219
-
220
-    /**
221
-     * @deprecated since 4.6.12
222
-     */
223
-    public function is_borked()
224
-    {
225
-        EE_Error::doing_it_wrong(
226
-            'is_borked',
227
-            esc_html__(
228
-                'The cheeky "is_borked" method had been replaced with the more proper "is_broken"',
229
-                'event_espresso'
230
-            ),
231
-            '4.6.12'
232
-        );
233
-        return $this->is_broken();
234
-    }
235
-
236
-    /**
237
-     * Sets the status to as having a fatal error
238
-     */
239
-    public function set_broken()
240
-    {
241
-        $this->_status = EE_Data_Migration_Manager::status_fatal_error;
242
-    }
243
-
244
-    /**
245
-     *
246
-     * @deprecated since 4.6.12
247
-     */
248
-    public function set_borked()
249
-    {
250
-        EE_Error::doing_it_wrong(
251
-            'is_borked',
252
-            esc_html__(
253
-                'The cheeky "is_borked" method had been replaced with the more proper "is_broken"',
254
-                'event_espresso'
255
-            ),
256
-            '4.6.12'
257
-        );
258
-        return $this->set_broken();
259
-    }
260
-
261
-    /**
262
-     * Checks if this thing believes it is completed
263
-     *
264
-     * @return boolean
265
-     */
266
-    public function is_completed()
267
-    {
268
-        return $this->get_status() == EE_Data_Migration_Manager::status_completed;
269
-    }
270
-
271
-    /**
272
-     * Checks if the current script has more to do or not (ie, if it's status is CONTINUE)
273
-     *
274
-     * @return boolean
275
-     */
276
-    public function has_more_to_do()
277
-    {
278
-        return $this->get_status() == EE_Data_Migration_Manager::status_continue;
279
-    }
280
-
281
-    /**
282
-     * Marks that we believe this migration thing is completed
283
-     */
284
-    public function set_completed()
285
-    {
286
-        $this->_status = EE_Data_Migration_Manager::status_completed;
287
-    }
288
-
289
-    /**
290
-     * Marks that we think this migration class can continue to migrate
291
-     */
292
-    public function reattempt()
293
-    {
294
-        $this->_status = EE_Data_Migration_Manager::status_continue;
295
-        $this->add_error(esc_html__('Reattempt migration', 'event_espresso'), true);
296
-    }
297
-
298
-    /**
299
-     * A lot like "__sleep()" magic method in purpose, this is meant for persisting this class'
300
-     * properties to the DB. However, we don't want to use __sleep() because its quite
301
-     * possible that this class is defined when it goes to sleep, but NOT available when it
302
-     * awakes (eg, this class is part of an addon that is deactivated at some point).
303
-     */
304
-    public function properties_as_array()
305
-    {
306
-        $properties = get_object_vars($this);
307
-        $properties['class'] = get_class($this);
308
-        unset($properties['_migration_script']);
309
-        unset($properties['_table_manager']);
310
-        unset($properties['_table_analysis']);
311
-        return $properties;
312
-    }
313
-
314
-    /**
315
-     * Sets all of the properties of this script stage to match what's in the array, which is assumed
316
-     * to have been made from the properties_as_array() function.
317
-     *
318
-     * @param array $array_of_properties like what's produced from properties_as_array() method
319
-     */
320
-    abstract public function instantiate_from_array_of_properties($array_of_properties);
321
-
322
-    /**
323
-     * Convenience method for showing a database insertion error
324
-     *
325
-     * @param string $old_table
326
-     * @param array  $old_row_as_array
327
-     * @param string $new_table
328
-     * @param array  $new_row_as_array columns=>values like used in wpdb->insert
329
-     * @param array  $data_types       numerically indexed
330
-     * @return string
331
-     */
332
-    protected function _create_error_message_for_db_insertion(
333
-        $old_table,
334
-        $old_row_as_array,
335
-        $new_table,
336
-        $new_row_as_array,
337
-        $data_types
338
-    ) {
339
-        global $wpdb;
340
-        $old_columns_and_values_for_string = array();
341
-        foreach ($old_row_as_array as $column => $value) {
342
-            $old_columns_and_values_for_string[] = "$column => $value";
343
-        }
344
-        $new_columns_and_values_for_string = array();
345
-        $count = 0;
346
-        foreach ($new_row_as_array as $column => $value) {
347
-            $new_columns_and_values_for_string[] = " $column => $value (" . $data_types[ $count++ ] . ")";
348
-        }
349
-        return sprintf(
350
-            esc_html__(
351
-                'Received error "%6$s" inserting row %5$s %1$s %5$s into table %2$s.%5$s Data used was %5$s %3$s %5$s from table %4$s.',
352
-                'event_espresso'
353
-            ),
354
-            implode(", ", $new_columns_and_values_for_string),
355
-            $new_table,
356
-            implode(", ", $old_columns_and_values_for_string),
357
-            $old_table,
358
-            '<br/>',
359
-            $wpdb->last_error
360
-        );
361
-    }
362
-
363
-
364
-    /**
365
-     * Same as json_encode, just avoids putting
366
-     * serialized arrays into the http build query, as that would
367
-     *
368
-     * @param array $array_of_data
369
-     * @return string
370
-     */
371
-    protected function _json_encode($array_of_data)
372
-    {
373
-        // we'd rather NOT serialize the transaction details
374
-        $fields_to_include = array();
375
-        foreach ($array_of_data as $name => $value) {
376
-            $unserialized_data = @unserialize($value);
377
-            if ($unserialized_data === false) {
378
-                $fields_to_include[ $name ] = $value;
379
-            }
380
-        }
381
-        return wp_json_encode($fields_to_include);
382
-    }
383
-
384
-    /**
385
-     * Gets the table manager (or throws an exception if it cannot be retrieved)
386
-     *
387
-     * @return TableManager
388
-     * @throws EE_Error
389
-     */
390
-    protected function _get_table_manager()
391
-    {
392
-        if ($this->_table_manager instanceof TableManager) {
393
-            return $this->_table_manager;
394
-        } else {
395
-            throw new EE_Error(
396
-                sprintf(
397
-                    esc_html__('Table manager on migration class %1$s is not set properly.', 'event_espresso'),
398
-                    get_class($this)
399
-                )
400
-            );
401
-        }
402
-    }
403
-
404
-    /**
405
-     * Gets the injected table analyzer, or throws an exception
406
-     *
407
-     * @return TableAnalysis
408
-     * @throws EE_Error
409
-     */
410
-    protected function _get_table_analysis()
411
-    {
412
-        if ($this->_table_analysis instanceof TableAnalysis) {
413
-            return $this->_table_analysis;
414
-        } else {
415
-            throw new EE_Error(
416
-                sprintf(
417
-                    esc_html__('Table analysis class on migration class %1$s is not set properly.', 'event_espresso'),
418
-                    get_class($this)
419
-                )
420
-            );
421
-        }
422
-    }
19
+	/**
20
+	 * @var $records_to_migrate int count of all that have been migrated
21
+	 */
22
+	protected $_records_to_migrate = 0;
23
+
24
+	/**
25
+	 *
26
+	 * @var $records_migrated int
27
+	 */
28
+	protected $_records_migrated = 0;
29
+
30
+	/**
31
+	 * Whether this migration script is done or not. This COULD be deduced by
32
+	 * _records_to_migrate and _records_migrated, but that might nto be accurate
33
+	 *
34
+	 * @var string one of EE_Data_migration_Manager::status_* constants
35
+	 */
36
+	protected $_status = null;
37
+
38
+	/**
39
+	 * internationalized name of this class. Convention is to NOT restate that
40
+	 * this class if a migration script or a migration script stage
41
+	 *
42
+	 * @var string (i18ned)
43
+	 */
44
+	protected $_pretty_name = null;
45
+
46
+	/**
47
+	 * @var array
48
+	 */
49
+	protected $_errors = array();
50
+
51
+	/**
52
+	 * @var \EventEspresso\core\services\database\TableManager $table_manager
53
+	 */
54
+	protected $_table_manager;
55
+
56
+	/**
57
+	 * @var \EventEspresso\core\services\database\TableAnalysis $table_analysis
58
+	 */
59
+	protected $_table_analysis;
60
+
61
+
62
+	/**
63
+	 * Just initializes the status of the migration
64
+	 *
65
+	 * @param TableManager  $table_manager
66
+	 * @param TableAnalysis $table_analysis
67
+	 */
68
+	public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null)
69
+	{
70
+		$this->_table_manager = $table_manager;
71
+		$this->_table_analysis = $table_analysis;
72
+		$this->set_status(EE_Data_Migration_Manager::status_continue);
73
+	}
74
+
75
+
76
+	/**
77
+	 * Just gets the pretty name for this migration script or stage
78
+	 *
79
+	 * @throws EE_Error
80
+	 * @return string
81
+	 */
82
+	public function pretty_name()
83
+	{
84
+		if ($this->_pretty_name === null) {
85
+			throw new EE_Error(
86
+				sprintf(
87
+					esc_html__(
88
+						"Please give a pretty name to the migration script stage %s by assigning the property _pretty_name in the constructor",
89
+						"event_espresso"
90
+					),
91
+					get_class($this)
92
+				)
93
+			);
94
+		}
95
+		return $this->_pretty_name;
96
+	}
97
+
98
+	/**
99
+	 *
100
+	 * @return int
101
+	 */
102
+	public function count_records_to_migrate()
103
+	{
104
+		if ($this->_records_to_migrate == null) {
105
+			$this->_records_to_migrate = $this->_count_records_to_migrate();
106
+		}
107
+		return $this->_records_to_migrate;
108
+	}
109
+
110
+	/**
111
+	 * Counts records already migrated. This should only be implemented by EE_Data_Migration_Script_base and
112
+	 * EE_Data_migration_Script_Stage
113
+	 *
114
+	 * @return int
115
+	 */
116
+	abstract public function count_records_migrated();
117
+
118
+	/**
119
+	 * Counts the records to migrate; the public version may cache it
120
+	 *
121
+	 * @return int
122
+	 */
123
+	abstract protected function _count_records_to_migrate();
124
+
125
+	/**
126
+	 * Returns a string indicating the migration script's status.
127
+	 *
128
+	 * @return string one of EE_Data_Migration_Manager::status_* constants
129
+	 * @throws EE_Error
130
+	 */
131
+	public function get_status()
132
+	{
133
+		if ($this->_status === null) {
134
+			throw new EE_Error(
135
+				sprintf(
136
+					esc_html__(
137
+						"Trying to get status of Migration class %s, but it has not been initialized yet. It should be set in the constructor.",
138
+						"event_espresso"
139
+					),
140
+					get_class($this)
141
+				)
142
+			);
143
+		}
144
+		return $this->_status;
145
+	}
146
+
147
+	/**
148
+	 *
149
+	 * @param string $status
150
+	 * @return void
151
+	 */
152
+	protected function set_status($status)
153
+	{
154
+		$this->_status = $status;
155
+	}
156
+
157
+	/**
158
+	 * @return array of strings
159
+	 */
160
+	abstract public function get_errors();
161
+
162
+	/**
163
+	 * Returns the last error that occurred. If none occurred, returns null
164
+	 *
165
+	 * @return string
166
+	 */
167
+	public function get_last_error()
168
+	{
169
+		$errors = $this->get_errors();
170
+		if ($errors) {
171
+			return end($errors);
172
+		} else {
173
+			return null;
174
+		}
175
+	}
176
+
177
+	/**
178
+	 * Adds an error to the array of errors on this class.
179
+	 *
180
+	 * @param string  $error a string describing the error that will be useful for debugging. Consider including all
181
+	 *                       the data that led to the error, and a stack trace etc.
182
+	 * @param boolean $force force the error to be added (because otherwise we have a limit). If forcing and errors are
183
+	 *                       already at their limit, we will purposefully forget the first half
184
+	 */
185
+	public function add_error($error, $force = false)
186
+	{
187
+		if (! defined('EE_DMS_ERROR_LIMIT')) {
188
+			$limit = 50;
189
+		} else {
190
+			$limit = EE_DMS_ERROR_LIMIT;
191
+		}
192
+		// make sure errors is an array, see ticket #8261
193
+		if (is_string($this->_errors)) {
194
+			$this->_errors = array($this->_errors);
195
+		}
196
+		if (count($this->_errors) >= $limit) {
197
+			if ($force) {
198
+				// get rid of the first half of the errors and any above the limit
199
+				$this->_errors = array_slice($this->_errors, $limit / 2, $limit / 2);
200
+				$this->_errors[] = "Limit reached; removed first half of errors to save space";
201
+				$this->_errors[] = $error;
202
+			} else {
203
+				$this->_errors[ $limit ] = 'More, but limit reached...';
204
+			}
205
+		} else {
206
+			$this->_errors[] = $error;
207
+		}
208
+	}
209
+
210
+	/**
211
+	 * Indicates there was a fatal error and the migration cannot possibly continue
212
+	 *
213
+	 * @return boolean
214
+	 */
215
+	public function is_broken()
216
+	{
217
+		return $this->get_status() == EE_Data_Migration_Manager::status_fatal_error;
218
+	}
219
+
220
+	/**
221
+	 * @deprecated since 4.6.12
222
+	 */
223
+	public function is_borked()
224
+	{
225
+		EE_Error::doing_it_wrong(
226
+			'is_borked',
227
+			esc_html__(
228
+				'The cheeky "is_borked" method had been replaced with the more proper "is_broken"',
229
+				'event_espresso'
230
+			),
231
+			'4.6.12'
232
+		);
233
+		return $this->is_broken();
234
+	}
235
+
236
+	/**
237
+	 * Sets the status to as having a fatal error
238
+	 */
239
+	public function set_broken()
240
+	{
241
+		$this->_status = EE_Data_Migration_Manager::status_fatal_error;
242
+	}
243
+
244
+	/**
245
+	 *
246
+	 * @deprecated since 4.6.12
247
+	 */
248
+	public function set_borked()
249
+	{
250
+		EE_Error::doing_it_wrong(
251
+			'is_borked',
252
+			esc_html__(
253
+				'The cheeky "is_borked" method had been replaced with the more proper "is_broken"',
254
+				'event_espresso'
255
+			),
256
+			'4.6.12'
257
+		);
258
+		return $this->set_broken();
259
+	}
260
+
261
+	/**
262
+	 * Checks if this thing believes it is completed
263
+	 *
264
+	 * @return boolean
265
+	 */
266
+	public function is_completed()
267
+	{
268
+		return $this->get_status() == EE_Data_Migration_Manager::status_completed;
269
+	}
270
+
271
+	/**
272
+	 * Checks if the current script has more to do or not (ie, if it's status is CONTINUE)
273
+	 *
274
+	 * @return boolean
275
+	 */
276
+	public function has_more_to_do()
277
+	{
278
+		return $this->get_status() == EE_Data_Migration_Manager::status_continue;
279
+	}
280
+
281
+	/**
282
+	 * Marks that we believe this migration thing is completed
283
+	 */
284
+	public function set_completed()
285
+	{
286
+		$this->_status = EE_Data_Migration_Manager::status_completed;
287
+	}
288
+
289
+	/**
290
+	 * Marks that we think this migration class can continue to migrate
291
+	 */
292
+	public function reattempt()
293
+	{
294
+		$this->_status = EE_Data_Migration_Manager::status_continue;
295
+		$this->add_error(esc_html__('Reattempt migration', 'event_espresso'), true);
296
+	}
297
+
298
+	/**
299
+	 * A lot like "__sleep()" magic method in purpose, this is meant for persisting this class'
300
+	 * properties to the DB. However, we don't want to use __sleep() because its quite
301
+	 * possible that this class is defined when it goes to sleep, but NOT available when it
302
+	 * awakes (eg, this class is part of an addon that is deactivated at some point).
303
+	 */
304
+	public function properties_as_array()
305
+	{
306
+		$properties = get_object_vars($this);
307
+		$properties['class'] = get_class($this);
308
+		unset($properties['_migration_script']);
309
+		unset($properties['_table_manager']);
310
+		unset($properties['_table_analysis']);
311
+		return $properties;
312
+	}
313
+
314
+	/**
315
+	 * Sets all of the properties of this script stage to match what's in the array, which is assumed
316
+	 * to have been made from the properties_as_array() function.
317
+	 *
318
+	 * @param array $array_of_properties like what's produced from properties_as_array() method
319
+	 */
320
+	abstract public function instantiate_from_array_of_properties($array_of_properties);
321
+
322
+	/**
323
+	 * Convenience method for showing a database insertion error
324
+	 *
325
+	 * @param string $old_table
326
+	 * @param array  $old_row_as_array
327
+	 * @param string $new_table
328
+	 * @param array  $new_row_as_array columns=>values like used in wpdb->insert
329
+	 * @param array  $data_types       numerically indexed
330
+	 * @return string
331
+	 */
332
+	protected function _create_error_message_for_db_insertion(
333
+		$old_table,
334
+		$old_row_as_array,
335
+		$new_table,
336
+		$new_row_as_array,
337
+		$data_types
338
+	) {
339
+		global $wpdb;
340
+		$old_columns_and_values_for_string = array();
341
+		foreach ($old_row_as_array as $column => $value) {
342
+			$old_columns_and_values_for_string[] = "$column => $value";
343
+		}
344
+		$new_columns_and_values_for_string = array();
345
+		$count = 0;
346
+		foreach ($new_row_as_array as $column => $value) {
347
+			$new_columns_and_values_for_string[] = " $column => $value (" . $data_types[ $count++ ] . ")";
348
+		}
349
+		return sprintf(
350
+			esc_html__(
351
+				'Received error "%6$s" inserting row %5$s %1$s %5$s into table %2$s.%5$s Data used was %5$s %3$s %5$s from table %4$s.',
352
+				'event_espresso'
353
+			),
354
+			implode(", ", $new_columns_and_values_for_string),
355
+			$new_table,
356
+			implode(", ", $old_columns_and_values_for_string),
357
+			$old_table,
358
+			'<br/>',
359
+			$wpdb->last_error
360
+		);
361
+	}
362
+
363
+
364
+	/**
365
+	 * Same as json_encode, just avoids putting
366
+	 * serialized arrays into the http build query, as that would
367
+	 *
368
+	 * @param array $array_of_data
369
+	 * @return string
370
+	 */
371
+	protected function _json_encode($array_of_data)
372
+	{
373
+		// we'd rather NOT serialize the transaction details
374
+		$fields_to_include = array();
375
+		foreach ($array_of_data as $name => $value) {
376
+			$unserialized_data = @unserialize($value);
377
+			if ($unserialized_data === false) {
378
+				$fields_to_include[ $name ] = $value;
379
+			}
380
+		}
381
+		return wp_json_encode($fields_to_include);
382
+	}
383
+
384
+	/**
385
+	 * Gets the table manager (or throws an exception if it cannot be retrieved)
386
+	 *
387
+	 * @return TableManager
388
+	 * @throws EE_Error
389
+	 */
390
+	protected function _get_table_manager()
391
+	{
392
+		if ($this->_table_manager instanceof TableManager) {
393
+			return $this->_table_manager;
394
+		} else {
395
+			throw new EE_Error(
396
+				sprintf(
397
+					esc_html__('Table manager on migration class %1$s is not set properly.', 'event_espresso'),
398
+					get_class($this)
399
+				)
400
+			);
401
+		}
402
+	}
403
+
404
+	/**
405
+	 * Gets the injected table analyzer, or throws an exception
406
+	 *
407
+	 * @return TableAnalysis
408
+	 * @throws EE_Error
409
+	 */
410
+	protected function _get_table_analysis()
411
+	{
412
+		if ($this->_table_analysis instanceof TableAnalysis) {
413
+			return $this->_table_analysis;
414
+		} else {
415
+			throw new EE_Error(
416
+				sprintf(
417
+					esc_html__('Table analysis class on migration class %1$s is not set properly.', 'event_espresso'),
418
+					get_class($this)
419
+				)
420
+			);
421
+		}
422
+	}
423 423
 }
Please login to merge, or discard this patch.
core/data_migration_scripts/EE_DMS_Core_4_6_0.dms.php 2 patches
Spacing   +17 added lines, -17 removed lines patch added patch discarded remove patch
@@ -13,12 +13,12 @@  discard block
 block discarded – undo
13 13
 // unfortunately, this needs to be done upon INCLUSION of this file,
14 14
 // instead of construction, because it only gets constructed on first page load
15 15
 // (all other times it gets resurrected from a wordpress option)
16
-$stages = glob(EE_CORE . 'data_migration_scripts/4_6_0_stages/*');
16
+$stages = glob(EE_CORE.'data_migration_scripts/4_6_0_stages/*');
17 17
 $class_to_filepath = array();
18 18
 foreach ($stages as $filepath) {
19 19
     $matches = array();
20 20
     preg_match('~4_6_0_stages/(.*).dmsstage.php~', $filepath, $matches);
21
-    $class_to_filepath[ $matches[1] ] = $filepath;
21
+    $class_to_filepath[$matches[1]] = $filepath;
22 22
 }
23 23
 // give addons a chance to autoload their stages too
24 24
 $class_to_filepath = apply_filters('FHEE__EE_DMS_4_6_0__autoloaded_stages', $class_to_filepath);
@@ -72,10 +72,10 @@  discard block
 block discarded – undo
72 72
         if (version_compare($version_string, '4.6.0.decaf', '<') && version_compare($version_string, '4.5.0.decaf', '>=')) {
73 73
 //          echo "$version_string can be migrated from";
74 74
             return true;
75
-        } elseif (! $version_string) {
75
+        } elseif ( ! $version_string) {
76 76
 //          echo "no version string provided: $version_string";
77 77
             // no version string provided... this must be pre 4.3
78
-            return false;// changed mind. dont want people thinking they should migrate yet because they cant
78
+            return false; // changed mind. dont want people thinking they should migrate yet because they cant
79 79
         } else {
80 80
 //          echo "$version_string doesnt apply";
81 81
             return false;
@@ -90,7 +90,7 @@  discard block
 block discarded – undo
90 90
     public function schema_changes_before_migration()
91 91
     {
92 92
         // relies on 4.1's EEH_Activation::create_table
93
-        require_once(EE_HELPERS . 'EEH_Activation.helper.php');
93
+        require_once(EE_HELPERS.'EEH_Activation.helper.php');
94 94
         $table_name = 'esp_answer';
95 95
         $sql = "ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
96 96
 					REG_ID int(10) unsigned NOT NULL,
@@ -537,7 +537,7 @@  discard block
 block discarded – undo
537 537
     public function add_default_admin_only_payments()
538 538
     {
539 539
         global $wpdb;
540
-        $table_name = $wpdb->prefix . "esp_payment_method";
540
+        $table_name = $wpdb->prefix."esp_payment_method";
541 541
         $user_id = EEH_Activation::get_default_creator_id();
542 542
         if ($this->_get_table_analysis()->tableExists($table_name)) {
543 543
             $SQL = "SELECT COUNT( * ) FROM $table_name";
@@ -565,7 +565,7 @@  discard block
 block discarded – undo
565 565
                 $slug = sanitize_key($nicename);
566 566
                 // check that such a payment method exists
567 567
                 $exists = $wpdb->get_var($wpdb->prepare("SELECT count(*) FROM $table_name WHERE PMD_slug = %s", $slug));
568
-                if (! $exists) {
568
+                if ( ! $exists) {
569 569
                     $values = array(
570 570
                         'PMD_type'       => 'Admin_Only',
571 571
                         'PMD_name'       => $nicename,
@@ -579,16 +579,16 @@  discard block
 block discarded – undo
579 579
                         $table_name,
580 580
                         $values,
581 581
                         array(
582
-                            '%s',// PMD_type
583
-                            '%s',// PMD_name
584
-                            '%s',// PMD_admin_name
585
-                            '%s',// PMD_admin_desc
586
-                            '%s',// PMD_slug
587
-                            '%d',// PMD_wp_user
588
-                            '%s',// PMD_scope
582
+                            '%s', // PMD_type
583
+                            '%s', // PMD_name
584
+                            '%s', // PMD_admin_name
585
+                            '%s', // PMD_admin_desc
586
+                            '%s', // PMD_slug
587
+                            '%d', // PMD_wp_user
588
+                            '%s', // PMD_scope
589 589
                         )
590 590
                     );
591
-                    if (! $success) {
591
+                    if ( ! $success) {
592 592
                         $this->add_error(sprintf(esc_html__(
593 593
                             "Could not insert new admin-only payment method with values %s during migration",
594 594
                             "event_espresso"
@@ -610,11 +610,11 @@  discard block
 block discarded – undo
610 610
     public function insert_default_currencies()
611 611
     {
612 612
         global $wpdb;
613
-        $currency_table = $wpdb->prefix . "esp_currency";
613
+        $currency_table = $wpdb->prefix."esp_currency";
614 614
         if ($this->_get_table_analysis()->tableExists($currency_table)) {
615 615
             $SQL = "SELECT COUNT('CUR_code') FROM $currency_table";
616 616
             $countries = $wpdb->get_var($SQL);
617
-            if (! $countries) {
617
+            if ( ! $countries) {
618 618
                 $SQL = "INSERT INTO $currency_table
619 619
 				( CUR_code, CUR_single, CUR_plural, CUR_sign, CUR_dec_plc, CUR_active) VALUES
620 620
 				( 'EUR',  'Euro',  'Euros',  '€',  2,1),
Please login to merge, or discard this patch.
Indentation   +259 added lines, -259 removed lines patch added patch discarded remove patch
@@ -10,9 +10,9 @@  discard block
 block discarded – undo
10 10
 $stages = glob(EE_CORE . 'data_migration_scripts/4_6_0_stages/*');
11 11
 $class_to_filepath = array();
12 12
 foreach ($stages as $filepath) {
13
-    $matches = array();
14
-    preg_match('~4_6_0_stages/(.*).dmsstage.php~', $filepath, $matches);
15
-    $class_to_filepath[ $matches[1] ] = $filepath;
13
+	$matches = array();
14
+	preg_match('~4_6_0_stages/(.*).dmsstage.php~', $filepath, $matches);
15
+	$class_to_filepath[ $matches[1] ] = $filepath;
16 16
 }
17 17
 // give addons a chance to autoload their stages too
18 18
 $class_to_filepath = apply_filters('FHEE__EE_DMS_4_6_0__autoloaded_stages', $class_to_filepath);
@@ -33,69 +33,69 @@  discard block
 block discarded – undo
33 33
  */
34 34
 class EE_DMS_Core_4_6_0 extends EE_Data_Migration_Script_Base
35 35
 {
36
-    /**
37
-     * return EE_DMS_Core_4_6_0
38
-     *
39
-     * @param TableManager  $table_manager
40
-     * @param TableAnalysis $table_analysis
41
-     */
42
-    public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null)
43
-    {
44
-        $this->_pretty_name = esc_html__("Data Update to Event Espresso 4.6.0", "event_espresso");
45
-        $this->_priority = 10;
46
-        $this->_migration_stages = array(
47
-            new EE_DMS_4_6_0_gateways(),
48
-            new EE_DMS_4_6_0_question_types(),
49
-            new EE_DMS_4_6_0_country_system_question(),
50
-            new EE_DMS_4_6_0_state_system_question(),
51
-            new EE_DMS_4_6_0_billing_info(),
52
-            new EE_DMS_4_6_0_transactions(),
53
-            new EE_DMS_4_6_0_payments(),
54
-            new EE_DMS_4_6_0_invoice_settings(),
55
-        );
56
-        parent::__construct($table_manager, $table_analysis);
57
-    }
36
+	/**
37
+	 * return EE_DMS_Core_4_6_0
38
+	 *
39
+	 * @param TableManager  $table_manager
40
+	 * @param TableAnalysis $table_analysis
41
+	 */
42
+	public function __construct(TableManager $table_manager = null, TableAnalysis $table_analysis = null)
43
+	{
44
+		$this->_pretty_name = esc_html__("Data Update to Event Espresso 4.6.0", "event_espresso");
45
+		$this->_priority = 10;
46
+		$this->_migration_stages = array(
47
+			new EE_DMS_4_6_0_gateways(),
48
+			new EE_DMS_4_6_0_question_types(),
49
+			new EE_DMS_4_6_0_country_system_question(),
50
+			new EE_DMS_4_6_0_state_system_question(),
51
+			new EE_DMS_4_6_0_billing_info(),
52
+			new EE_DMS_4_6_0_transactions(),
53
+			new EE_DMS_4_6_0_payments(),
54
+			new EE_DMS_4_6_0_invoice_settings(),
55
+		);
56
+		parent::__construct($table_manager, $table_analysis);
57
+	}
58 58
 
59 59
 
60 60
 
61
-    /**
62
-     * @param array $version_array
63
-     * @return bool
64
-     */
65
-    public function can_migrate_from_version($version_array)
66
-    {
67
-        $version_string = $version_array['Core'];
68
-        if (version_compare($version_string, '4.6.0.decaf', '<') && version_compare($version_string, '4.5.0.decaf', '>=')) {
61
+	/**
62
+	 * @param array $version_array
63
+	 * @return bool
64
+	 */
65
+	public function can_migrate_from_version($version_array)
66
+	{
67
+		$version_string = $version_array['Core'];
68
+		if (version_compare($version_string, '4.6.0.decaf', '<') && version_compare($version_string, '4.5.0.decaf', '>=')) {
69 69
 //          echo "$version_string can be migrated from";
70
-            return true;
71
-        } elseif (! $version_string) {
70
+			return true;
71
+		} elseif (! $version_string) {
72 72
 //          echo "no version string provided: $version_string";
73
-            // no version string provided... this must be pre 4.3
74
-            return false;// changed mind. dont want people thinking they should migrate yet because they cant
75
-        } else {
73
+			// no version string provided... this must be pre 4.3
74
+			return false;// changed mind. dont want people thinking they should migrate yet because they cant
75
+		} else {
76 76
 //          echo "$version_string doesnt apply";
77
-            return false;
78
-        }
79
-    }
77
+			return false;
78
+		}
79
+	}
80 80
 
81 81
 
82 82
 
83
-    /**
84
-     * @return bool
85
-     */
86
-    public function schema_changes_before_migration()
87
-    {
88
-        // relies on 4.1's EEH_Activation::create_table
89
-        require_once(EE_HELPERS . 'EEH_Activation.helper.php');
90
-        $table_name = 'esp_answer';
91
-        $sql = "ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
83
+	/**
84
+	 * @return bool
85
+	 */
86
+	public function schema_changes_before_migration()
87
+	{
88
+		// relies on 4.1's EEH_Activation::create_table
89
+		require_once(EE_HELPERS . 'EEH_Activation.helper.php');
90
+		$table_name = 'esp_answer';
91
+		$sql = "ANS_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
92 92
 					REG_ID int(10) unsigned NOT NULL,
93 93
 					QST_ID int(10) unsigned NOT NULL,
94 94
 					ANS_value text NOT NULL,
95 95
 					PRIMARY KEY  (ANS_ID)";
96
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
97
-        $table_name = 'esp_attendee_meta';
98
-        $sql = "ATTM_ID int(10) unsigned NOT	NULL AUTO_INCREMENT,
96
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
97
+		$table_name = 'esp_attendee_meta';
98
+		$sql = "ATTM_ID int(10) unsigned NOT	NULL AUTO_INCREMENT,
99 99
 						ATT_ID bigint(20) unsigned NOT NULL,
100 100
 						ATT_fname varchar(45) NOT NULL,
101 101
 						ATT_lname varchar(45) NOT	NULL,
@@ -111,9 +111,9 @@  discard block
 block discarded – undo
111 111
 								KEY ATT_fname (ATT_fname),
112 112
 								KEY ATT_lname (ATT_lname),
113 113
 								KEY ATT_email (ATT_email(191))";
114
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
115
-        $table_name = 'esp_country';
116
-        $sql = "CNT_ISO varchar(2) COLLATE utf8_bin NOT NULL,
114
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
115
+		$table_name = 'esp_country';
116
+		$sql = "CNT_ISO varchar(2) COLLATE utf8_bin NOT NULL,
117 117
 					  CNT_ISO3 varchar(3) COLLATE utf8_bin NOT NULL,
118 118
 					  RGN_ID tinyint(3) unsigned DEFAULT NULL,
119 119
 					  CNT_name varchar(45) COLLATE utf8_bin NOT NULL,
@@ -129,24 +129,24 @@  discard block
 block discarded – undo
129 129
 					  CNT_is_EU tinyint(1) DEFAULT '0',
130 130
 					  CNT_active tinyint(1) DEFAULT '0',
131 131
 					  PRIMARY KEY  (CNT_ISO)";
132
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
133
-        $table_name = 'esp_currency';
134
-        $sql = "CUR_code varchar(6) COLLATE utf8_bin NOT NULL,
132
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
133
+		$table_name = 'esp_currency';
134
+		$sql = "CUR_code varchar(6) COLLATE utf8_bin NOT NULL,
135 135
 				CUR_single varchar(45) COLLATE utf8_bin DEFAULT 'dollar',
136 136
 				CUR_plural varchar(45) COLLATE utf8_bin DEFAULT 'dollars',
137 137
 				CUR_sign varchar(45) COLLATE utf8_bin DEFAULT '$',
138 138
 				CUR_dec_plc varchar(1) COLLATE utf8_bin NOT NULL DEFAULT '2',
139 139
 				CUR_active tinyint(1) DEFAULT '0',
140 140
 				PRIMARY KEY  (CUR_code)";
141
-        $this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB');
142
-        $table_name = 'esp_currency_payment_method';
143
-        $sql = "CPM_ID int(11) NOT NULL AUTO_INCREMENT,
141
+		$this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB');
142
+		$table_name = 'esp_currency_payment_method';
143
+		$sql = "CPM_ID int(11) NOT NULL AUTO_INCREMENT,
144 144
 				CUR_code varchar(6) COLLATE utf8_bin NOT NULL,
145 145
 				PMD_ID int(11) NOT NULL,
146 146
 				PRIMARY KEY  (CPM_ID)";
147
-        $this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB ');
148
-        $table_name = 'esp_datetime';
149
-        $sql = "DTT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
147
+		$this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB ');
148
+		$table_name = 'esp_datetime';
149
+		$sql = "DTT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
150 150
 				  EVT_ID bigint(20) unsigned NOT NULL,
151 151
 				  DTT_name varchar(255) NOT NULL DEFAULT '',
152 152
 				  DTT_description text NOT NULL,
@@ -161,9 +161,9 @@  discard block
 block discarded – undo
161 161
 						PRIMARY KEY  (DTT_ID),
162 162
 						KEY EVT_ID (EVT_ID),
163 163
 						KEY DTT_is_primary (DTT_is_primary)";
164
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
165
-        $table_name = 'esp_event_meta';
166
-        $sql = "
164
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
165
+		$table_name = 'esp_event_meta';
166
+		$sql = "
167 167
 			EVTM_ID int(10) NOT NULL AUTO_INCREMENT,
168 168
 			EVT_ID bigint(20) unsigned NOT NULL,
169 169
 			EVT_display_desc tinyint(1) unsigned NOT NULL DEFAULT 1,
@@ -178,31 +178,31 @@  discard block
 block discarded – undo
178 178
 			EVT_external_URL varchar(200) NULL,
179 179
 			EVT_donations tinyint(1) NULL,
180 180
 			PRIMARY KEY  (EVTM_ID)";
181
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
182
-        $table_name = 'esp_event_question_group';
183
-        $sql = "EQG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
181
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
182
+		$table_name = 'esp_event_question_group';
183
+		$sql = "EQG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
184 184
 					EVT_ID bigint(20) unsigned NOT NULL,
185 185
 					QSG_ID int(10) unsigned NOT NULL,
186 186
 					EQG_primary tinyint(1) unsigned NOT NULL DEFAULT 0,
187 187
 					PRIMARY KEY  (EQG_ID)";
188
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
189
-        $table_name = 'esp_event_venue';
190
-        $sql = "EVV_ID int(11) NOT NULL AUTO_INCREMENT,
188
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
189
+		$table_name = 'esp_event_venue';
190
+		$sql = "EVV_ID int(11) NOT NULL AUTO_INCREMENT,
191 191
 				EVT_ID bigint(20) unsigned NOT NULL,
192 192
 				VNU_ID bigint(20) unsigned NOT NULL,
193 193
 				EVV_primary tinyint(1) unsigned NOT NULL DEFAULT 0,
194 194
 				PRIMARY KEY  (EVV_ID)";
195
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
196
-        $table_name = 'esp_extra_meta';
197
-        $sql = "EXM_ID int(11) NOT NULL AUTO_INCREMENT,
195
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
196
+		$table_name = 'esp_extra_meta';
197
+		$sql = "EXM_ID int(11) NOT NULL AUTO_INCREMENT,
198 198
 				OBJ_ID int(11) DEFAULT NULL,
199 199
 				EXM_type varchar(45) DEFAULT NULL,
200 200
 				EXM_key varchar(45) DEFAULT NULL,
201 201
 				EXM_value text,
202 202
 				PRIMARY KEY  (EXM_ID)";
203
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
204
-        $table_name = 'esp_line_item';
205
-        $sql = "LIN_ID int(11) NOT NULL AUTO_INCREMENT,
203
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
204
+		$table_name = 'esp_line_item';
205
+		$sql = "LIN_ID int(11) NOT NULL AUTO_INCREMENT,
206 206
 				LIN_code varchar(245) NOT NULL DEFAULT '',
207 207
 				TXN_ID int(11) DEFAULT NULL,
208 208
 				LIN_name varchar(245) NOT NULL DEFAULT '',
@@ -218,9 +218,9 @@  discard block
 block discarded – undo
218 218
 				OBJ_ID int(11) DEFAULT NULL,
219 219
 				OBJ_type varchar(45)DEFAULT NULL,
220 220
 				PRIMARY KEY  (LIN_ID)";
221
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
222
-        $table_name = 'esp_log';
223
-        $sql = "LOG_ID int(11) NOT NULL AUTO_INCREMENT,
221
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
222
+		$table_name = 'esp_log';
223
+		$sql = "LOG_ID int(11) NOT NULL AUTO_INCREMENT,
224 224
 				LOG_time datetime DEFAULT NULL,
225 225
 				OBJ_ID varchar(45) DEFAULT NULL,
226 226
 				OBJ_type varchar(45) DEFAULT NULL,
@@ -228,19 +228,19 @@  discard block
 block discarded – undo
228 228
 				LOG_message text,
229 229
 				LOG_wp_user int(11) DEFAULT NULL,
230 230
 				PRIMARY KEY  (LOG_ID)";
231
-        $this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB');
232
-        $table_name = 'esp_message_template';
233
-        $sql = "MTP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
231
+		$this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB');
232
+		$table_name = 'esp_message_template';
233
+		$sql = "MTP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
234 234
 					GRP_ID int(10) unsigned NOT NULL,
235 235
 					MTP_context varchar(50) NOT NULL,
236 236
 					MTP_template_field varchar(30) NOT NULL,
237 237
 					MTP_content text NOT NULL,
238 238
 					PRIMARY KEY  (MTP_ID),
239 239
 					KEY GRP_ID (GRP_ID)";
240
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
241
-        $this->_get_table_manager()->dropIndex('esp_message_template_group', 'EVT_ID');
242
-        $table_name = 'esp_message_template_group';
243
-        $sql = "GRP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
240
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
241
+		$this->_get_table_manager()->dropIndex('esp_message_template_group', 'EVT_ID');
242
+		$table_name = 'esp_message_template_group';
243
+		$sql = "GRP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
244 244
 					MTP_user_id int(10) NOT NULL DEFAULT '1',
245 245
 					MTP_name varchar(245) NOT NULL DEFAULT '',
246 246
 					MTP_description varchar(245) NOT NULL DEFAULT '',
@@ -252,17 +252,17 @@  discard block
 block discarded – undo
252 252
 					MTP_is_active tinyint(1) NOT NULL DEFAULT '1',
253 253
 					PRIMARY KEY  (GRP_ID),
254 254
 					KEY MTP_user_id (MTP_user_id)";
255
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
256
-        $table_name = 'esp_event_message_template';
257
-        $sql = "EMT_ID bigint(20) unsigned NOT NULL AUTO_INCREMENT,
255
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
256
+		$table_name = 'esp_event_message_template';
257
+		$sql = "EMT_ID bigint(20) unsigned NOT NULL AUTO_INCREMENT,
258 258
 					EVT_ID bigint(20) unsigned NOT NULL DEFAULT 0,
259 259
 					GRP_ID int(10) unsigned NOT NULL DEFAULT 0,
260 260
 					PRIMARY KEY  (EMT_ID),
261 261
 					KEY EVT_ID (EVT_ID),
262 262
 					KEY GRP_ID (GRP_ID)";
263
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
264
-        $table_name = 'esp_payment';
265
-        $sql = "PAY_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
263
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
264
+		$table_name = 'esp_payment';
265
+		$sql = "PAY_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
266 266
 					TXN_ID int(10) unsigned DEFAULT NULL,
267 267
 					STS_ID varchar(3) COLLATE utf8_bin DEFAULT NULL,
268 268
 					PAY_timestamp datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
@@ -279,9 +279,9 @@  discard block
 block discarded – undo
279 279
 					PRIMARY KEY  (PAY_ID),
280 280
 					KEY TXN_ID (TXN_ID),
281 281
 					KEY PAY_timestamp (PAY_timestamp)";
282
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
283
-        $table_name = 'esp_payment_method';
284
-        $sql = "PMD_ID int(11) NOT NULL AUTO_INCREMENT,
282
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
283
+		$table_name = 'esp_payment_method';
284
+		$sql = "PMD_ID int(11) NOT NULL AUTO_INCREMENT,
285 285
 				PMD_type varchar(124) DEFAULT NULL,
286 286
 				PMD_name varchar(255) DEFAULT NULL,
287 287
 				PMD_desc text,
@@ -296,28 +296,28 @@  discard block
 block discarded – undo
296 296
 				PMD_scope varchar(255) NULL DEFAULT 'frontend',
297 297
 				PRIMARY KEY  (PMD_ID),
298 298
 				UNIQUE KEY PMD_slug_UNIQUE (PMD_slug)";
299
-        $this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB ');
300
-        $table_name = "esp_ticket_price";
301
-        $sql = "TKP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
299
+		$this->_table_is_new_in_this_version($table_name, $sql, 'ENGINE=InnoDB ');
300
+		$table_name = "esp_ticket_price";
301
+		$sql = "TKP_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
302 302
 					  TKT_ID int(10) unsigned NOT NULL,
303 303
 					  PRC_ID int(10) unsigned NOT NULL,
304 304
 					  PRIMARY KEY  (TKP_ID)";
305
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
306
-        $table_name = "esp_datetime_ticket";
307
-        $sql = "DTK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
305
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
306
+		$table_name = "esp_datetime_ticket";
307
+		$sql = "DTK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
308 308
 					  DTT_ID int(10) unsigned NOT NULL,
309 309
 					  TKT_ID int(10) unsigned NOT NULL,
310 310
 					  PRIMARY KEY  (DTK_ID)";
311
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
312
-        $table_name = "esp_ticket_template";
313
-        $sql = "TTM_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
311
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
312
+		$table_name = "esp_ticket_template";
313
+		$sql = "TTM_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
314 314
 					  TTM_name varchar(45) NOT NULL,
315 315
 					  TTM_description text,
316 316
 					  TTM_file varchar(45),
317 317
 					  PRIMARY KEY  (TTM_ID)";
318
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
319
-        $table_name = 'esp_question';
320
-        $sql = 'QST_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
318
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
319
+		$table_name = 'esp_question';
320
+		$sql = 'QST_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
321 321
 					QST_display_text text NOT NULL,
322 322
 					QST_admin_label varchar(255) NOT NULL,
323 323
 					QST_system varchar(25) DEFAULT NULL,
@@ -329,25 +329,25 @@  discard block
 block discarded – undo
329 329
 					QST_wp_user bigint(20) unsigned NULL,
330 330
 					QST_deleted tinyint(1) unsigned NOT NULL DEFAULT 0,
331 331
 					PRIMARY KEY  (QST_ID)';
332
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
333
-        $table_name = 'esp_question_group_question';
334
-        $sql = "QGQ_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
332
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
333
+		$table_name = 'esp_question_group_question';
334
+		$sql = "QGQ_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
335 335
 					QSG_ID int(10) unsigned NOT NULL,
336 336
 					QST_ID int(10) unsigned NOT NULL,
337 337
 					QGQ_order int(10) unsigned NOT NULL DEFAULT 0,
338 338
 					PRIMARY KEY  (QGQ_ID) ";
339
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
340
-        $table_name = 'esp_question_option';
341
-        $sql = "QSO_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
339
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
340
+		$table_name = 'esp_question_option';
341
+		$sql = "QSO_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
342 342
 					QSO_value varchar(255) NOT NULL,
343 343
 					QSO_desc text NOT NULL,
344 344
 					QST_ID int(10) unsigned NOT NULL,
345 345
 					QSO_order int(10) unsigned NOT NULL DEFAULT 0,
346 346
 					QSO_deleted tinyint(1) unsigned NOT NULL DEFAULT 0,
347 347
 					PRIMARY KEY  (QSO_ID)";
348
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
349
-        $table_name = 'esp_registration';
350
-        $sql = "REG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
348
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
349
+		$table_name = 'esp_registration';
350
+		$sql = "REG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
351 351
 					  EVT_ID bigint(20) unsigned NOT NULL,
352 352
 					  ATT_ID bigint(20) unsigned NOT NULL,
353 353
 					  TXN_ID int(10) unsigned NOT NULL,
@@ -370,25 +370,25 @@  discard block
 block discarded – undo
370 370
 					  KEY STS_ID (STS_ID),
371 371
 					  KEY REG_url_link (REG_url_link),
372 372
 					  KEY REG_code (REG_code)";
373
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
374
-        $table_name = 'esp_checkin';
375
-        $sql = "CHK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
373
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
374
+		$table_name = 'esp_checkin';
375
+		$sql = "CHK_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
376 376
 					REG_ID int(10) unsigned NOT NULL,
377 377
 					DTT_ID int(10) unsigned NOT NULL,
378 378
 					CHK_in tinyint(1) unsigned NOT NULL DEFAULT 1,
379 379
 					CHK_timestamp datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
380 380
 					PRIMARY KEY  (CHK_ID)";
381
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
382
-        $table_name = 'esp_state';
383
-        $sql = "STA_ID smallint(5) unsigned NOT NULL AUTO_INCREMENT,
381
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
382
+		$table_name = 'esp_state';
383
+		$sql = "STA_ID smallint(5) unsigned NOT NULL AUTO_INCREMENT,
384 384
 					  CNT_ISO varchar(2) COLLATE utf8_bin NOT NULL,
385 385
 					  STA_abbrev varchar(24) COLLATE utf8_bin NOT NULL,
386 386
 					  STA_name varchar(100) COLLATE utf8_bin NOT NULL,
387 387
 					  STA_active tinyint(1) DEFAULT '1',
388 388
 					  PRIMARY KEY  (STA_ID)";
389
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
390
-        $table_name = 'esp_status';
391
-        $sql = "STS_ID varchar(3) COLLATE utf8_bin NOT NULL,
389
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
390
+		$table_name = 'esp_status';
391
+		$sql = "STS_ID varchar(3) COLLATE utf8_bin NOT NULL,
392 392
 					  STS_code varchar(45) COLLATE utf8_bin NOT NULL,
393 393
 					  STS_type set('event','registration','transaction','payment','email') COLLATE utf8_bin NOT NULL,
394 394
 					  STS_can_edit tinyint(1) NOT NULL DEFAULT 0,
@@ -396,9 +396,9 @@  discard block
 block discarded – undo
396 396
 					  STS_open tinyint(1) NOT NULL DEFAULT 1,
397 397
 					  UNIQUE KEY STS_ID_UNIQUE (STS_ID),
398 398
 					  KEY STS_type (STS_type)";
399
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
400
-        $table_name = 'esp_transaction';
401
-        $sql = "TXN_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
399
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
400
+		$table_name = 'esp_transaction';
401
+		$sql = "TXN_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
402 402
 					  TXN_timestamp datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
403 403
 					  TXN_total decimal(10,3) DEFAULT '0.00',
404 404
 					  TXN_paid decimal(10,3) NOT NULL DEFAULT '0.00',
@@ -410,9 +410,9 @@  discard block
 block discarded – undo
410 410
 					  PRIMARY KEY  (TXN_ID),
411 411
 					  KEY TXN_timestamp (TXN_timestamp),
412 412
 					  KEY STS_ID (STS_ID)";
413
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
414
-        $table_name = 'esp_venue_meta';
415
-        $sql = "VNUM_ID int(11) NOT NULL AUTO_INCREMENT,
413
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
414
+		$table_name = 'esp_venue_meta';
415
+		$sql = "VNUM_ID int(11) NOT NULL AUTO_INCREMENT,
416 416
 			VNU_ID bigint(20) unsigned NOT NULL DEFAULT 0,
417 417
 			VNU_address varchar(255) DEFAULT NULL,
418 418
 			VNU_address2 varchar(255) DEFAULT NULL,
@@ -430,10 +430,10 @@  discard block
 block discarded – undo
430 430
 			PRIMARY KEY  (VNUM_ID),
431 431
 			KEY STA_ID (STA_ID),
432 432
 			KEY CNT_ISO (CNT_ISO)";
433
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
434
-        // modified tables
435
-        $table_name = "esp_price";
436
-        $sql = "PRC_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
433
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
434
+		// modified tables
435
+		$table_name = "esp_price";
436
+		$sql = "PRC_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
437 437
 					  PRT_ID tinyint(3) unsigned NOT NULL,
438 438
 					  PRC_amount decimal(10,3) NOT NULL DEFAULT '0.00',
439 439
 					  PRC_name varchar(245) NOT NULL,
@@ -445,9 +445,9 @@  discard block
 block discarded – undo
445 445
 					  PRC_wp_user bigint(20) unsigned NULL,
446 446
 					  PRC_parent int(10) unsigned DEFAULT 0,
447 447
 					  PRIMARY KEY  (PRC_ID)";
448
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
449
-        $table_name = "esp_price_type";
450
-        $sql = "PRT_ID tinyint(3) unsigned NOT NULL AUTO_INCREMENT,
448
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
449
+		$table_name = "esp_price_type";
450
+		$sql = "PRT_ID tinyint(3) unsigned NOT NULL AUTO_INCREMENT,
451 451
 				  PRT_name varchar(45) NOT NULL,
452 452
 				  PBT_ID tinyint(3) unsigned NOT NULL DEFAULT '1',
453 453
 				  PRT_is_percent tinyint(1) NOT NULL DEFAULT '0',
@@ -456,9 +456,9 @@  discard block
 block discarded – undo
456 456
 				  PRT_deleted tinyint(1) NOT NULL DEFAULT '0',
457 457
 				  UNIQUE KEY PRT_name_UNIQUE (PRT_name),
458 458
 				  PRIMARY KEY  (PRT_ID)";
459
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
460
-        $table_name = "esp_ticket";
461
-        $sql = "TKT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
459
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB ');
460
+		$table_name = "esp_ticket";
461
+		$sql = "TKT_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
462 462
 					  TTM_ID int(10) unsigned NOT NULL,
463 463
 					  TKT_name varchar(245) NOT NULL DEFAULT '',
464 464
 					  TKT_description text NOT NULL,
@@ -479,10 +479,10 @@  discard block
 block discarded – undo
479 479
 					  TKT_parent int(10) unsigned DEFAULT '0',
480 480
 					  TKT_deleted tinyint(1) NOT NULL DEFAULT '0',
481 481
 					  PRIMARY KEY  (TKT_ID)";
482
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
483
-        $this->_get_table_manager()->dropIndex('esp_question_group', 'QSG_identifier_UNIQUE');
484
-        $table_name = 'esp_question_group';
485
-        $sql = 'QSG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
482
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
483
+		$this->_get_table_manager()->dropIndex('esp_question_group', 'QSG_identifier_UNIQUE');
484
+		$table_name = 'esp_question_group';
485
+		$sql = 'QSG_ID int(10) unsigned NOT NULL AUTO_INCREMENT,
486 486
 					QSG_name varchar(255) NOT NULL,
487 487
 					QSG_identifier varchar(100) NOT NULL,
488 488
 					QSG_desc text NULL,
@@ -494,124 +494,124 @@  discard block
 block discarded – undo
494 494
 					QSG_wp_user bigint(20) unsigned NULL,
495 495
 					PRIMARY KEY  (QSG_ID),
496 496
 					UNIQUE KEY QSG_identifier_UNIQUE (QSG_identifier ASC)';
497
-        $this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
498
-        /** @var EE_DMS_Core_4_1_0 $script_4_1_defaults */
499
-        $script_4_1_defaults = EE_Registry::instance()->load_dms('Core_4_1_0');
500
-        // (because many need to convert old string states to foreign keys into the states table)
501
-        $script_4_1_defaults->insert_default_states();
502
-        $script_4_1_defaults->insert_default_countries();
503
-        /** @var EE_DMS_Core_4_5_0 $script_4_5_defaults */
504
-        $script_4_5_defaults = EE_Registry::instance()->load_dms('Core_4_5_0');
505
-        $script_4_5_defaults->insert_default_price_types();
506
-        $script_4_5_defaults->insert_default_prices();
507
-        $script_4_5_defaults->insert_default_tickets();
508
-        // setting up the config wp option pretty well counts as a 'schema change', or at least should happen here
509
-        EE_Config::instance()->update_espresso_config(false, true);
510
-        $this->add_default_admin_only_payments();
511
-        $this->insert_default_currencies();
512
-        return true;
513
-    }
497
+		$this->_table_should_exist_previously($table_name, $sql, 'ENGINE=InnoDB');
498
+		/** @var EE_DMS_Core_4_1_0 $script_4_1_defaults */
499
+		$script_4_1_defaults = EE_Registry::instance()->load_dms('Core_4_1_0');
500
+		// (because many need to convert old string states to foreign keys into the states table)
501
+		$script_4_1_defaults->insert_default_states();
502
+		$script_4_1_defaults->insert_default_countries();
503
+		/** @var EE_DMS_Core_4_5_0 $script_4_5_defaults */
504
+		$script_4_5_defaults = EE_Registry::instance()->load_dms('Core_4_5_0');
505
+		$script_4_5_defaults->insert_default_price_types();
506
+		$script_4_5_defaults->insert_default_prices();
507
+		$script_4_5_defaults->insert_default_tickets();
508
+		// setting up the config wp option pretty well counts as a 'schema change', or at least should happen here
509
+		EE_Config::instance()->update_espresso_config(false, true);
510
+		$this->add_default_admin_only_payments();
511
+		$this->insert_default_currencies();
512
+		return true;
513
+	}
514 514
 
515 515
 
516 516
 
517
-    /**
518
-     * @return boolean
519
-     */
520
-    public function schema_changes_after_migration()
521
-    {
522
-        return true;
523
-    }
517
+	/**
518
+	 * @return boolean
519
+	 */
520
+	public function schema_changes_after_migration()
521
+	{
522
+		return true;
523
+	}
524 524
 
525 525
 
526 526
 
527
-    public function migration_page_hooks()
528
-    {
529
-    }
527
+	public function migration_page_hooks()
528
+	{
529
+	}
530 530
 
531 531
 
532 532
 
533
-    public function add_default_admin_only_payments()
534
-    {
535
-        global $wpdb;
536
-        $table_name = $wpdb->prefix . "esp_payment_method";
537
-        $user_id = EEH_Activation::get_default_creator_id();
538
-        if ($this->_get_table_analysis()->tableExists($table_name)) {
539
-            $SQL = "SELECT COUNT( * ) FROM $table_name";
540
-            $existing_payment_methods = $wpdb->get_var($SQL);
541
-            $default_admin_only_payment_methods = apply_filters(
542
-                'FHEE__EEH_Activation__add_default_admin_only_payments__default_admin_only_payment_methods',
543
-                array(
544
-                    (string) esc_html__("Bank", 'event_espresso')        => esc_html__("Bank Draft", 'event_espresso'),
545
-                    (string) esc_html__("Cash", 'event_espresso')        => esc_html__("Cash Delivered Physically", 'event_espresso'),
546
-                    (string) esc_html__("Check", 'event_espresso')       => esc_html__("Paper Check", 'event_espresso'),
547
-                    (string) esc_html__("Credit Card", 'event_espresso') => esc_html__("Offline Credit Card Payment", 'event_espresso'),
548
-                    (string) esc_html__("Debit Card", 'event_espresso')  => esc_html__("Offline Debit Payment", 'event_espresso'),
549
-                    (string) esc_html__("Invoice", 'event_espresso')     => esc_html__(
550
-                        "Invoice received with monies included",
551
-                        'event_espresso'
552
-                    ),
553
-                    (string) esc_html__("Money Order", 'event_espresso') => '',
554
-                    (string) esc_html__("Paypal", 'event_espresso')      => esc_html__("Paypal eCheck, Invoice, etc", 'event_espresso'),
555
-                    (string) esc_html__('Other', 'event_espresso')       => esc_html__('Other method of payment', 'event_espresso'),
556
-                )
557
-            );
558
-            // make sure we hae payment method records for the following
559
-            // so admins can record payments for them from the admin page
560
-            foreach ($default_admin_only_payment_methods as $nicename => $description) {
561
-                $slug = sanitize_key($nicename);
562
-                // check that such a payment method exists
563
-                $exists = $wpdb->get_var($wpdb->prepare("SELECT count(*) FROM $table_name WHERE PMD_slug = %s", $slug));
564
-                if (! $exists) {
565
-                    $values = array(
566
-                        'PMD_type'       => 'Admin_Only',
567
-                        'PMD_name'       => $nicename,
568
-                        'PMD_admin_name' => $nicename,
569
-                        'PMD_admin_desc' => $description,
570
-                        'PMD_slug'       => $slug,
571
-                        'PMD_wp_user'    => $user_id,
572
-                        'PMD_scope'      => serialize(array('ADMIN')),
573
-                    );
574
-                    $success = $wpdb->insert(
575
-                        $table_name,
576
-                        $values,
577
-                        array(
578
-                            '%s',// PMD_type
579
-                            '%s',// PMD_name
580
-                            '%s',// PMD_admin_name
581
-                            '%s',// PMD_admin_desc
582
-                            '%s',// PMD_slug
583
-                            '%d',// PMD_wp_user
584
-                            '%s',// PMD_scope
585
-                        )
586
-                    );
587
-                    if (! $success) {
588
-                        $this->add_error(sprintf(esc_html__(
589
-                            "Could not insert new admin-only payment method with values %s during migration",
590
-                            "event_espresso"
591
-                        ), $this->_json_encode($values)));
592
-                    }
593
-                }
594
-            }
595
-        }
596
-    }
533
+	public function add_default_admin_only_payments()
534
+	{
535
+		global $wpdb;
536
+		$table_name = $wpdb->prefix . "esp_payment_method";
537
+		$user_id = EEH_Activation::get_default_creator_id();
538
+		if ($this->_get_table_analysis()->tableExists($table_name)) {
539
+			$SQL = "SELECT COUNT( * ) FROM $table_name";
540
+			$existing_payment_methods = $wpdb->get_var($SQL);
541
+			$default_admin_only_payment_methods = apply_filters(
542
+				'FHEE__EEH_Activation__add_default_admin_only_payments__default_admin_only_payment_methods',
543
+				array(
544
+					(string) esc_html__("Bank", 'event_espresso')        => esc_html__("Bank Draft", 'event_espresso'),
545
+					(string) esc_html__("Cash", 'event_espresso')        => esc_html__("Cash Delivered Physically", 'event_espresso'),
546
+					(string) esc_html__("Check", 'event_espresso')       => esc_html__("Paper Check", 'event_espresso'),
547
+					(string) esc_html__("Credit Card", 'event_espresso') => esc_html__("Offline Credit Card Payment", 'event_espresso'),
548
+					(string) esc_html__("Debit Card", 'event_espresso')  => esc_html__("Offline Debit Payment", 'event_espresso'),
549
+					(string) esc_html__("Invoice", 'event_espresso')     => esc_html__(
550
+						"Invoice received with monies included",
551
+						'event_espresso'
552
+					),
553
+					(string) esc_html__("Money Order", 'event_espresso') => '',
554
+					(string) esc_html__("Paypal", 'event_espresso')      => esc_html__("Paypal eCheck, Invoice, etc", 'event_espresso'),
555
+					(string) esc_html__('Other', 'event_espresso')       => esc_html__('Other method of payment', 'event_espresso'),
556
+				)
557
+			);
558
+			// make sure we hae payment method records for the following
559
+			// so admins can record payments for them from the admin page
560
+			foreach ($default_admin_only_payment_methods as $nicename => $description) {
561
+				$slug = sanitize_key($nicename);
562
+				// check that such a payment method exists
563
+				$exists = $wpdb->get_var($wpdb->prepare("SELECT count(*) FROM $table_name WHERE PMD_slug = %s", $slug));
564
+				if (! $exists) {
565
+					$values = array(
566
+						'PMD_type'       => 'Admin_Only',
567
+						'PMD_name'       => $nicename,
568
+						'PMD_admin_name' => $nicename,
569
+						'PMD_admin_desc' => $description,
570
+						'PMD_slug'       => $slug,
571
+						'PMD_wp_user'    => $user_id,
572
+						'PMD_scope'      => serialize(array('ADMIN')),
573
+					);
574
+					$success = $wpdb->insert(
575
+						$table_name,
576
+						$values,
577
+						array(
578
+							'%s',// PMD_type
579
+							'%s',// PMD_name
580
+							'%s',// PMD_admin_name
581
+							'%s',// PMD_admin_desc
582
+							'%s',// PMD_slug
583
+							'%d',// PMD_wp_user
584
+							'%s',// PMD_scope
585
+						)
586
+					);
587
+					if (! $success) {
588
+						$this->add_error(sprintf(esc_html__(
589
+							"Could not insert new admin-only payment method with values %s during migration",
590
+							"event_espresso"
591
+						), $this->_json_encode($values)));
592
+					}
593
+				}
594
+			}
595
+		}
596
+	}
597 597
 
598 598
 
599 599
 
600
-    /**
601
-     * insert_default_countries
602
-     *
603
-     * @static
604
-     * @return void
605
-     */
606
-    public function insert_default_currencies()
607
-    {
608
-        global $wpdb;
609
-        $currency_table = $wpdb->prefix . "esp_currency";
610
-        if ($this->_get_table_analysis()->tableExists($currency_table)) {
611
-            $SQL = "SELECT COUNT('CUR_code') FROM $currency_table";
612
-            $countries = $wpdb->get_var($SQL);
613
-            if (! $countries) {
614
-                $SQL = "INSERT INTO $currency_table
600
+	/**
601
+	 * insert_default_countries
602
+	 *
603
+	 * @static
604
+	 * @return void
605
+	 */
606
+	public function insert_default_currencies()
607
+	{
608
+		global $wpdb;
609
+		$currency_table = $wpdb->prefix . "esp_currency";
610
+		if ($this->_get_table_analysis()->tableExists($currency_table)) {
611
+			$SQL = "SELECT COUNT('CUR_code') FROM $currency_table";
612
+			$countries = $wpdb->get_var($SQL);
613
+			if (! $countries) {
614
+				$SQL = "INSERT INTO $currency_table
615 615
 				( CUR_code, CUR_single, CUR_plural, CUR_sign, CUR_dec_plc, CUR_active) VALUES
616 616
 				( 'EUR',  'Euro',  'Euros',  '€',  2,1),
617 617
 				( 'AED',  'Dirham',  'Dirhams', 'د.إ',2,1),
@@ -765,8 +765,8 @@  discard block
 block discarded – undo
765 765
 				( 'ZAR',  'Rand',  'Rands',  'R',  2,1),
766 766
 				( 'ZMK',  'Kwacha',  'Kwachas',  '',  2,1),
767 767
 				( 'ZWD', 'Dollar', 'Dollars', 'Z$', 2,1);";
768
-                $wpdb->query($SQL);
769
-            }
770
-        }
771
-    }
768
+				$wpdb->query($SQL);
769
+			}
770
+		}
771
+	}
772 772
 }
Please login to merge, or discard this patch.
4_3_0_stages/EE_DMS_4_3_0_event_message_templates.dmsstage.php 2 patches
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch
@@ -24,8 +24,8 @@  discard block
 block discarded – undo
24 24
     {
25 25
         global $wpdb;
26 26
         $this->_pretty_name = esc_html__('Event Message Templates', 'event_espresso');
27
-        $this->_old_table = $wpdb->prefix . "esp_message_template_group";
28
-        $this->_emt_table = $wpdb->prefix . "esp_event_message_template";
27
+        $this->_old_table = $wpdb->prefix."esp_message_template_group";
28
+        $this->_emt_table = $wpdb->prefix."esp_event_message_template";
29 29
         parent::__construct();
30 30
     }
31 31
 
@@ -37,7 +37,7 @@  discard block
 block discarded – undo
37 37
         global $wpdb;
38 38
         if ($old_row['EVT_ID'] > 0) {
39 39
                                     // let's get the EVT for this id so we can update the custom name on the old row.
40
-                                    $event_name = 'Custom Template for ' . $wpdb->get_var($wpdb->prepare("SELECT post_title from $wpdb->posts WHERE ID = %d", absint($old_row['EVT_ID'])));
40
+                                    $event_name = 'Custom Template for '.$wpdb->get_var($wpdb->prepare("SELECT post_title from $wpdb->posts WHERE ID = %d", absint($old_row['EVT_ID'])));
41 41
 
42 42
                                     // update name
43 43
                                     $updated = $wpdb->update(
@@ -45,9 +45,9 @@  discard block
 block discarded – undo
45 45
                                         array(
46 46
                                             'MTP_name' => $event_name
47 47
                                             ),
48
-                                        array( 'GRP_ID' => (int) $old_row['GRP_ID'] ),
49
-                                        array( '%s' ),
50
-                                        array( '%d' )
48
+                                        array('GRP_ID' => (int) $old_row['GRP_ID']),
49
+                                        array('%s'),
50
+                                        array('%d')
51 51
                                     );
52 52
 
53 53
             $inserted = $wpdb->insert(
@@ -56,7 +56,7 @@  discard block
 block discarded – undo
56 56
                     'EVT_ID' => (int) $old_row['EVT_ID'],
57 57
                     'GRP_ID' => (int) $old_row['GRP_ID'],
58 58
                     ),
59
-                array( '%d', '%d' )
59
+                array('%d', '%d')
60 60
             );
61 61
 
62 62
             if (false === $updated) {
Please login to merge, or discard this patch.
Indentation   +46 added lines, -46 removed lines patch added patch discarded remove patch
@@ -12,59 +12,59 @@
 block discarded – undo
12 12
  */
13 13
 class EE_DMS_4_3_0_event_message_templates extends EE_Data_Migration_Script_Stage_Table
14 14
 {
15
-    /**
16
-     * This property will hold the table name for event_message_templates
17
-     * @var string
18
-     */
19
-    private $_emt_table;
15
+	/**
16
+	 * This property will hold the table name for event_message_templates
17
+	 * @var string
18
+	 */
19
+	private $_emt_table;
20 20
 
21 21
 
22
-    public function __construct()
23
-    {
24
-        global $wpdb;
25
-        $this->_pretty_name = esc_html__('Event Message Templates', 'event_espresso');
26
-        $this->_old_table = $wpdb->prefix . "esp_message_template_group";
27
-        $this->_emt_table = $wpdb->prefix . "esp_event_message_template";
28
-        parent::__construct();
29
-    }
22
+	public function __construct()
23
+	{
24
+		global $wpdb;
25
+		$this->_pretty_name = esc_html__('Event Message Templates', 'event_espresso');
26
+		$this->_old_table = $wpdb->prefix . "esp_message_template_group";
27
+		$this->_emt_table = $wpdb->prefix . "esp_event_message_template";
28
+		parent::__construct();
29
+	}
30 30
 
31 31
 
32 32
 
33
-    protected function _migrate_old_row($old_row)
34
-    {
35
-        // foreach row that has an evt_id ..let's create an equivalent entry in the new event_messages_template table to link the message template to the event (since EVT_ID is no longer referenced in esp_message_template_groups )
36
-        global $wpdb;
37
-        if ($old_row['EVT_ID'] > 0) {
38
-                                    // let's get the EVT for this id so we can update the custom name on the old row.
39
-                                    $event_name = 'Custom Template for ' . $wpdb->get_var($wpdb->prepare("SELECT post_title from $wpdb->posts WHERE ID = %d", absint($old_row['EVT_ID'])));
33
+	protected function _migrate_old_row($old_row)
34
+	{
35
+		// foreach row that has an evt_id ..let's create an equivalent entry in the new event_messages_template table to link the message template to the event (since EVT_ID is no longer referenced in esp_message_template_groups )
36
+		global $wpdb;
37
+		if ($old_row['EVT_ID'] > 0) {
38
+									// let's get the EVT for this id so we can update the custom name on the old row.
39
+									$event_name = 'Custom Template for ' . $wpdb->get_var($wpdb->prepare("SELECT post_title from $wpdb->posts WHERE ID = %d", absint($old_row['EVT_ID'])));
40 40
 
41
-                                    // update name
42
-                                    $updated = $wpdb->update(
43
-                                        $this->_old_table,
44
-                                        array(
45
-                                            'MTP_name' => $event_name
46
-                                            ),
47
-                                        array( 'GRP_ID' => (int) $old_row['GRP_ID'] ),
48
-                                        array( '%s' ),
49
-                                        array( '%d' )
50
-                                    );
41
+									// update name
42
+									$updated = $wpdb->update(
43
+										$this->_old_table,
44
+										array(
45
+											'MTP_name' => $event_name
46
+											),
47
+										array( 'GRP_ID' => (int) $old_row['GRP_ID'] ),
48
+										array( '%s' ),
49
+										array( '%d' )
50
+									);
51 51
 
52
-            $inserted = $wpdb->insert(
53
-                $this->_emt_table,
54
-                array(
55
-                    'EVT_ID' => (int) $old_row['EVT_ID'],
56
-                    'GRP_ID' => (int) $old_row['GRP_ID'],
57
-                    ),
58
-                array( '%d', '%d' )
59
-            );
52
+			$inserted = $wpdb->insert(
53
+				$this->_emt_table,
54
+				array(
55
+					'EVT_ID' => (int) $old_row['EVT_ID'],
56
+					'GRP_ID' => (int) $old_row['GRP_ID'],
57
+					),
58
+				array( '%d', '%d' )
59
+			);
60 60
 
61
-            if (false === $updated) {
62
-                $this->add_error(sprintf(esc_html__("Error in updating the row in %s setting 'MTP_name = %s", 'event_espresso'), $this->_old_table, $event_name));
63
-            }
61
+			if (false === $updated) {
62
+				$this->add_error(sprintf(esc_html__("Error in updating the row in %s setting 'MTP_name = %s", 'event_espresso'), $this->_old_table, $event_name));
63
+			}
64 64
 
65
-            if (false === $inserted) {
66
-                $this->add_error(sprintf(esc_html__("Error in inserting a row into  setting EVT_ID = %d and GRP_ID = %d", "event_espresso"), $this->_emt_table, $old_row['EVT_ID'], $old_row['GRP_ID']));
67
-            }
68
-        }
69
-    }
65
+			if (false === $inserted) {
66
+				$this->add_error(sprintf(esc_html__("Error in inserting a row into  setting EVT_ID = %d and GRP_ID = %d", "event_espresso"), $this->_emt_table, $old_row['EVT_ID'], $old_row['GRP_ID']));
67
+			}
68
+		}
69
+	}
70 70
 }
Please login to merge, or discard this patch.
4_3_0_stages/EE_DMS_4_3_0_question_option_order.dmsstage.php 2 patches
Indentation   +35 added lines, -35 removed lines patch added patch discarded remove patch
@@ -7,39 +7,39 @@
 block discarded – undo
7 7
 
8 8
 class EE_DMS_4_3_0_question_option_order extends EE_Data_Migration_Script_Stage_Table
9 9
 {
10
-    public function __construct()
11
-    {
12
-        global $wpdb;
13
-        $this->_pretty_name = esc_html__("Question Options", "event_espresso");
14
-        $this->_old_table = $wpdb->prefix . "esp_question_option";
15
-        parent::__construct();
16
-    }
17
-    protected function _migrate_old_row($old_row)
18
-    {
19
-        // foreach question_group_question entry with this QST_ID, we want to set its
20
-        // QSG_order equal to this question's QST_order
21
-        global $wpdb;
22
-        $updated = $wpdb->update(
23
-            $this->_old_table,
24
-            array('QSO_order' => $old_row['QSO_ID']),
25
-            array('QSO_ID' => $old_row['QSO_ID']),
26
-            array('%d',// QSO_order
27
-                    ),
28
-            array('%d',// QSO_ID
29
-                    )
30
-        );
31
-        if (false === $updated) {
32
-            $this->add_error(
33
-                sprintf(
34
-                    esc_html__(
35
-                        "Error in updating table %s setting QSO_order = %d where QSO_ID = %d",
36
-                        'event_espresso'
37
-                    ),
38
-                    $this->_old_table,
39
-                    $old_row['QSO_ID'],
40
-                    $old_row['QSO_ID']
41
-                )
42
-            );
43
-        }
44
-    }
10
+	public function __construct()
11
+	{
12
+		global $wpdb;
13
+		$this->_pretty_name = esc_html__("Question Options", "event_espresso");
14
+		$this->_old_table = $wpdb->prefix . "esp_question_option";
15
+		parent::__construct();
16
+	}
17
+	protected function _migrate_old_row($old_row)
18
+	{
19
+		// foreach question_group_question entry with this QST_ID, we want to set its
20
+		// QSG_order equal to this question's QST_order
21
+		global $wpdb;
22
+		$updated = $wpdb->update(
23
+			$this->_old_table,
24
+			array('QSO_order' => $old_row['QSO_ID']),
25
+			array('QSO_ID' => $old_row['QSO_ID']),
26
+			array('%d',// QSO_order
27
+					),
28
+			array('%d',// QSO_ID
29
+					)
30
+		);
31
+		if (false === $updated) {
32
+			$this->add_error(
33
+				sprintf(
34
+					esc_html__(
35
+						"Error in updating table %s setting QSO_order = %d where QSO_ID = %d",
36
+						'event_espresso'
37
+					),
38
+					$this->_old_table,
39
+					$old_row['QSO_ID'],
40
+					$old_row['QSO_ID']
41
+				)
42
+			);
43
+		}
44
+	}
45 45
 }
Please login to merge, or discard this patch.
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -11,7 +11,7 @@  discard block
 block discarded – undo
11 11
     {
12 12
         global $wpdb;
13 13
         $this->_pretty_name = esc_html__("Question Options", "event_espresso");
14
-        $this->_old_table = $wpdb->prefix . "esp_question_option";
14
+        $this->_old_table = $wpdb->prefix."esp_question_option";
15 15
         parent::__construct();
16 16
     }
17 17
     protected function _migrate_old_row($old_row)
@@ -23,9 +23,9 @@  discard block
 block discarded – undo
23 23
             $this->_old_table,
24 24
             array('QSO_order' => $old_row['QSO_ID']),
25 25
             array('QSO_ID' => $old_row['QSO_ID']),
26
-            array('%d',// QSO_order
26
+            array('%d', // QSO_order
27 27
                     ),
28
-            array('%d',// QSO_ID
28
+            array('%d', // QSO_ID
29 29
                     )
30 30
         );
31 31
         if (false === $updated) {
Please login to merge, or discard this patch.
4_8_0_stages/EE_DMS_4_8_0_event_subtotals.dmsstage.php 2 patches
Indentation   +73 added lines, -73 removed lines patch added patch discarded remove patch
@@ -11,77 +11,77 @@
 block discarded – undo
11 11
  */
12 12
 class EE_DMS_4_8_0_event_subtotals extends EE_Data_Migration_Script_Stage_Table
13 13
 {
14
-    public function __construct()
15
-    {
16
-        global $wpdb;
17
-        $this->_old_table = $wpdb->prefix . 'esp_line_item';
18
-        $this->_extra_where_sql = ' WHERE LIN_type="sub-total" AND LIN_code="pre-tax-subtotal"';
19
-        $this->_pretty_name = esc_html__('Event Sub-total line items', 'event_espresso');
20
-        parent::__construct();
21
-    }
22
-    protected function _migrate_old_row($line_item_row)
23
-    {
24
-        global $wpdb;
25
-        // what event is this line item for? this can be found by looking at its transaction's registration's EVT_ID
26
-        $event_id = $wpdb->get_var($wpdb->prepare('SELECT EVT_ID FROM ' . $wpdb->prefix . 'esp_registration WHERE TXN_ID=%d LIMIT 1', $line_item_row['TXN_ID']));
27
-        $new_line_item_data = array(
28
-                    'LIN_code' => 'event-' . $event_id,
29
-                    'TXN_ID' => $line_item_row['TXN_ID'],
30
-                    'LIN_name' => esc_html__('Event', 'event_espresso'),
31
-                    'LIN_desc' => $line_item_row['LIN_desc'],
32
-                    'LIN_unit_price' => $line_item_row['LIN_unit_price'],
33
-                    'LIN_percent' => $line_item_row['LIN_percent'],
34
-                    'LIN_is_taxable' => $line_item_row['LIN_is_taxable'],
35
-                    'LIN_order' => $line_item_row['LIN_order'],
36
-                    'LIN_total' => $line_item_row['LIN_total'],
37
-                    'LIN_quantity' => $line_item_row['LIN_quantity'],
38
-                    'LIN_parent' => $line_item_row['LIN_ID'],
39
-                    'LIN_type' => 'sub-total',
40
-                    'OBJ_type' => 'Event',
41
-                    'OBJ_ID' => $event_id,
42
-                );
43
-        $new_line_item_datatypes = array(
44
-                    '%s',// LIN_code
45
-                    '%d',// TXN_ID
46
-                    '%s',// LIN_name
47
-                    '%s',// LIN_desc
48
-                    '%f',// LIN_unit_price
49
-                    '%f',// LIN_percent
50
-                    '%d',// LIN_is_taxable
51
-                    '%d',// LIN_order
52
-                    '%f',// LIN_total
53
-                    '%d',// LIN_quantity
54
-                    '%d',// LIN_parent
55
-                    '%s',// LIN_type
56
-                    '%s',// OBJ_type
57
-                    '%d',// OBJ_ID
58
-                );
59
-        // insert the new event subtotal line item, pointing to this line item
60
-        $success = $wpdb->insert($this->_old_table, $new_line_item_data, $new_line_item_datatypes);
61
-        if (! $success) {
62
-            $this->add_error($this->_create_error_message_for_db_insertion($this->_old_table, $line_item_row, $this->_old_table, $new_line_item_data, $new_line_item_datatypes));
63
-        }
64
-        $new_line_item_id = $wpdb->insert_id;
65
-        $this->get_migration_script()->set_mapping($this->_old_table, $line_item_row['LIN_ID'], $this->_old_table, $new_line_item_id);
66
-        $query = $wpdb->prepare(
67
-            "UPDATE {$this->_old_table} SET LIN_parent=%d WHERE LIN_parent = %d AND LIN_ID != %d LIMIT 100",
68
-            $new_line_item_id,
69
-            $line_item_row['LIN_ID'],
70
-            $new_line_item_id
71
-        );
72
-        $success = $wpdb->query($query);
73
-        if ($success === false) {
74
-            $this->add_error(
75
-                sprintf(
76
-                    esc_html__('Error updating rows to new event subtotal %1$s from %2$s. Error was: %3$s, while using query %4$s which had a result of %5$s', 'event_espresso'),
77
-                    $new_line_item_id,
78
-                    $line_item_row['LIN_ID'],
79
-                    $wpdb->last_error,
80
-                    $query,
81
-                    $success
82
-                )
83
-            );
84
-        }
85
-        return 1;
86
-    }
14
+	public function __construct()
15
+	{
16
+		global $wpdb;
17
+		$this->_old_table = $wpdb->prefix . 'esp_line_item';
18
+		$this->_extra_where_sql = ' WHERE LIN_type="sub-total" AND LIN_code="pre-tax-subtotal"';
19
+		$this->_pretty_name = esc_html__('Event Sub-total line items', 'event_espresso');
20
+		parent::__construct();
21
+	}
22
+	protected function _migrate_old_row($line_item_row)
23
+	{
24
+		global $wpdb;
25
+		// what event is this line item for? this can be found by looking at its transaction's registration's EVT_ID
26
+		$event_id = $wpdb->get_var($wpdb->prepare('SELECT EVT_ID FROM ' . $wpdb->prefix . 'esp_registration WHERE TXN_ID=%d LIMIT 1', $line_item_row['TXN_ID']));
27
+		$new_line_item_data = array(
28
+					'LIN_code' => 'event-' . $event_id,
29
+					'TXN_ID' => $line_item_row['TXN_ID'],
30
+					'LIN_name' => esc_html__('Event', 'event_espresso'),
31
+					'LIN_desc' => $line_item_row['LIN_desc'],
32
+					'LIN_unit_price' => $line_item_row['LIN_unit_price'],
33
+					'LIN_percent' => $line_item_row['LIN_percent'],
34
+					'LIN_is_taxable' => $line_item_row['LIN_is_taxable'],
35
+					'LIN_order' => $line_item_row['LIN_order'],
36
+					'LIN_total' => $line_item_row['LIN_total'],
37
+					'LIN_quantity' => $line_item_row['LIN_quantity'],
38
+					'LIN_parent' => $line_item_row['LIN_ID'],
39
+					'LIN_type' => 'sub-total',
40
+					'OBJ_type' => 'Event',
41
+					'OBJ_ID' => $event_id,
42
+				);
43
+		$new_line_item_datatypes = array(
44
+					'%s',// LIN_code
45
+					'%d',// TXN_ID
46
+					'%s',// LIN_name
47
+					'%s',// LIN_desc
48
+					'%f',// LIN_unit_price
49
+					'%f',// LIN_percent
50
+					'%d',// LIN_is_taxable
51
+					'%d',// LIN_order
52
+					'%f',// LIN_total
53
+					'%d',// LIN_quantity
54
+					'%d',// LIN_parent
55
+					'%s',// LIN_type
56
+					'%s',// OBJ_type
57
+					'%d',// OBJ_ID
58
+				);
59
+		// insert the new event subtotal line item, pointing to this line item
60
+		$success = $wpdb->insert($this->_old_table, $new_line_item_data, $new_line_item_datatypes);
61
+		if (! $success) {
62
+			$this->add_error($this->_create_error_message_for_db_insertion($this->_old_table, $line_item_row, $this->_old_table, $new_line_item_data, $new_line_item_datatypes));
63
+		}
64
+		$new_line_item_id = $wpdb->insert_id;
65
+		$this->get_migration_script()->set_mapping($this->_old_table, $line_item_row['LIN_ID'], $this->_old_table, $new_line_item_id);
66
+		$query = $wpdb->prepare(
67
+			"UPDATE {$this->_old_table} SET LIN_parent=%d WHERE LIN_parent = %d AND LIN_ID != %d LIMIT 100",
68
+			$new_line_item_id,
69
+			$line_item_row['LIN_ID'],
70
+			$new_line_item_id
71
+		);
72
+		$success = $wpdb->query($query);
73
+		if ($success === false) {
74
+			$this->add_error(
75
+				sprintf(
76
+					esc_html__('Error updating rows to new event subtotal %1$s from %2$s. Error was: %3$s, while using query %4$s which had a result of %5$s', 'event_espresso'),
77
+					$new_line_item_id,
78
+					$line_item_row['LIN_ID'],
79
+					$wpdb->last_error,
80
+					$query,
81
+					$success
82
+				)
83
+			);
84
+		}
85
+		return 1;
86
+	}
87 87
 }
Please login to merge, or discard this patch.
Spacing   +18 added lines, -18 removed lines patch added patch discarded remove patch
@@ -14,7 +14,7 @@  discard block
 block discarded – undo
14 14
     public function __construct()
15 15
     {
16 16
         global $wpdb;
17
-        $this->_old_table = $wpdb->prefix . 'esp_line_item';
17
+        $this->_old_table = $wpdb->prefix.'esp_line_item';
18 18
         $this->_extra_where_sql = ' WHERE LIN_type="sub-total" AND LIN_code="pre-tax-subtotal"';
19 19
         $this->_pretty_name = esc_html__('Event Sub-total line items', 'event_espresso');
20 20
         parent::__construct();
@@ -23,9 +23,9 @@  discard block
 block discarded – undo
23 23
     {
24 24
         global $wpdb;
25 25
         // what event is this line item for? this can be found by looking at its transaction's registration's EVT_ID
26
-        $event_id = $wpdb->get_var($wpdb->prepare('SELECT EVT_ID FROM ' . $wpdb->prefix . 'esp_registration WHERE TXN_ID=%d LIMIT 1', $line_item_row['TXN_ID']));
26
+        $event_id = $wpdb->get_var($wpdb->prepare('SELECT EVT_ID FROM '.$wpdb->prefix.'esp_registration WHERE TXN_ID=%d LIMIT 1', $line_item_row['TXN_ID']));
27 27
         $new_line_item_data = array(
28
-                    'LIN_code' => 'event-' . $event_id,
28
+                    'LIN_code' => 'event-'.$event_id,
29 29
                     'TXN_ID' => $line_item_row['TXN_ID'],
30 30
                     'LIN_name' => esc_html__('Event', 'event_espresso'),
31 31
                     'LIN_desc' => $line_item_row['LIN_desc'],
@@ -41,24 +41,24 @@  discard block
 block discarded – undo
41 41
                     'OBJ_ID' => $event_id,
42 42
                 );
43 43
         $new_line_item_datatypes = array(
44
-                    '%s',// LIN_code
45
-                    '%d',// TXN_ID
46
-                    '%s',// LIN_name
47
-                    '%s',// LIN_desc
48
-                    '%f',// LIN_unit_price
49
-                    '%f',// LIN_percent
50
-                    '%d',// LIN_is_taxable
51
-                    '%d',// LIN_order
52
-                    '%f',// LIN_total
53
-                    '%d',// LIN_quantity
54
-                    '%d',// LIN_parent
55
-                    '%s',// LIN_type
56
-                    '%s',// OBJ_type
57
-                    '%d',// OBJ_ID
44
+                    '%s', // LIN_code
45
+                    '%d', // TXN_ID
46
+                    '%s', // LIN_name
47
+                    '%s', // LIN_desc
48
+                    '%f', // LIN_unit_price
49
+                    '%f', // LIN_percent
50
+                    '%d', // LIN_is_taxable
51
+                    '%d', // LIN_order
52
+                    '%f', // LIN_total
53
+                    '%d', // LIN_quantity
54
+                    '%d', // LIN_parent
55
+                    '%s', // LIN_type
56
+                    '%s', // OBJ_type
57
+                    '%d', // OBJ_ID
58 58
                 );
59 59
         // insert the new event subtotal line item, pointing to this line item
60 60
         $success = $wpdb->insert($this->_old_table, $new_line_item_data, $new_line_item_datatypes);
61
-        if (! $success) {
61
+        if ( ! $success) {
62 62
             $this->add_error($this->_create_error_message_for_db_insertion($this->_old_table, $line_item_row, $this->_old_table, $new_line_item_data, $new_line_item_datatypes));
63 63
         }
64 64
         $new_line_item_id = $wpdb->insert_id;
Please login to merge, or discard this patch.
data_migration_scripts/4_8_0_stages/EE_DMS_4_8_0_pretax_totals.dmsstage.php 2 patches
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -22,7 +22,7 @@  discard block
 block discarded – undo
22 22
     public function __construct()
23 23
     {
24 24
         global $wpdb;
25
-        $this->_line_item_table_name = $wpdb->prefix . "esp_line_item";
25
+        $this->_line_item_table_name = $wpdb->prefix."esp_line_item";
26 26
         $this->_pretty_name = esc_html__('Pre-tax total line items', 'event_espresso');
27 27
         parent::__construct();
28 28
     }
@@ -54,10 +54,10 @@  discard block
 block discarded – undo
54 54
         global $wpdb;
55 55
         $rows_updated = $wpdb->update(
56 56
             $this->_line_item_table_name,
57
-            array( 'LIN_code' => 'pre-tax-subtotal' ),
58
-            array( 'LIN_code' => 'tickets' ),
59
-            array( '%s' ),
60
-            array( '%s' )
57
+            array('LIN_code' => 'pre-tax-subtotal'),
58
+            array('LIN_code' => 'tickets'),
59
+            array('%s'),
60
+            array('%s')
61 61
         );
62 62
         $this->set_completed();
63 63
         return 1;
Please login to merge, or discard this patch.
Indentation   +41 added lines, -41 removed lines patch added patch discarded remove patch
@@ -12,53 +12,53 @@
 block discarded – undo
12 12
  */
13 13
 class EE_DMS_4_8_0_pretax_totals extends EE_Data_Migration_Script_Stage
14 14
 {
15
-    protected $_line_item_table_name;
15
+	protected $_line_item_table_name;
16 16
 
17 17
 
18
-    /**
19
-     * Just initializes the status of the migration
20
-     */
21
-    public function __construct()
22
-    {
23
-        global $wpdb;
24
-        $this->_line_item_table_name = $wpdb->prefix . "esp_line_item";
25
-        $this->_pretty_name = esc_html__('Pre-tax total line items', 'event_espresso');
26
-        parent::__construct();
27
-    }
18
+	/**
19
+	 * Just initializes the status of the migration
20
+	 */
21
+	public function __construct()
22
+	{
23
+		global $wpdb;
24
+		$this->_line_item_table_name = $wpdb->prefix . "esp_line_item";
25
+		$this->_pretty_name = esc_html__('Pre-tax total line items', 'event_espresso');
26
+		parent::__construct();
27
+	}
28 28
 
29 29
 
30 30
 
31
-    /**
32
-     * Counts the records to migrate; the public version may cache it
33
-     * @return int
34
-     */
35
-    protected function _count_records_to_migrate()
36
-    {
37
-        return 1;
38
-    }
31
+	/**
32
+	 * Counts the records to migrate; the public version may cache it
33
+	 * @return int
34
+	 */
35
+	protected function _count_records_to_migrate()
36
+	{
37
+		return 1;
38
+	}
39 39
 
40 40
 
41 41
 
42
-    /**
43
-     * IMPORTANT: if an error is encountered, or everything is finished, this stage should update its status property accordingly.
44
-     * Note: it should not alter the count of items migrated. That is done in the public function that calls this.
45
-     * IMPORTANT: The count of items migrated should ONLY be less than $num_items_to_migrate when it's the last migration step, otherwise it
46
-     * should always return $num_items_to_migrate. (Eg, if we're migrating attendees rows from the database, and $num_items_to_migrate is set to 50,
47
-     * then we SHOULD actually migrate 50 rows,but at very least we MUST report/return 50 items migrated)
48
-     * @param int $num_items_to_migrate
49
-     * @return int number of items ACTUALLY migrated
50
-     */
51
-    protected function _migration_step($num_items_to_migrate = 50)
52
-    {
53
-        global $wpdb;
54
-        $rows_updated = $wpdb->update(
55
-            $this->_line_item_table_name,
56
-            array( 'LIN_code' => 'pre-tax-subtotal' ),
57
-            array( 'LIN_code' => 'tickets' ),
58
-            array( '%s' ),
59
-            array( '%s' )
60
-        );
61
-        $this->set_completed();
62
-        return 1;
63
-    }
42
+	/**
43
+	 * IMPORTANT: if an error is encountered, or everything is finished, this stage should update its status property accordingly.
44
+	 * Note: it should not alter the count of items migrated. That is done in the public function that calls this.
45
+	 * IMPORTANT: The count of items migrated should ONLY be less than $num_items_to_migrate when it's the last migration step, otherwise it
46
+	 * should always return $num_items_to_migrate. (Eg, if we're migrating attendees rows from the database, and $num_items_to_migrate is set to 50,
47
+	 * then we SHOULD actually migrate 50 rows,but at very least we MUST report/return 50 items migrated)
48
+	 * @param int $num_items_to_migrate
49
+	 * @return int number of items ACTUALLY migrated
50
+	 */
51
+	protected function _migration_step($num_items_to_migrate = 50)
52
+	{
53
+		global $wpdb;
54
+		$rows_updated = $wpdb->update(
55
+			$this->_line_item_table_name,
56
+			array( 'LIN_code' => 'pre-tax-subtotal' ),
57
+			array( 'LIN_code' => 'tickets' ),
58
+			array( '%s' ),
59
+			array( '%s' )
60
+		);
61
+		$this->set_completed();
62
+		return 1;
63
+	}
64 64
 }
Please login to merge, or discard this patch.
4_1_0_stages/EE_DMS_4_1_0_event_question_group.dmsstage.php 2 patches
Indentation   +104 added lines, -106 removed lines patch added patch discarded remove patch
@@ -16,15 +16,13 @@  discard block
 block discarded – undo
16 16
             'EQG_primary'=>new EE_Boolean_Field('EQG_primary', esc_html__('Flag indicating question is only for primary attendees','event_espresso'), false, false)
17 17
         )
18 18
     );
19
-
20
-
21 19
  *
22 20
  */
23 21
 class EE_DMS_4_1_0_event_question_group extends EE_Data_Migration_Script_Stage_Table
24 22
 {
25
-    private $_new_table;
26
-    public function _migrate_old_row($old_row)
27
-    {
23
+	private $_new_table;
24
+	public function _migrate_old_row($old_row)
25
+	{
28 26
 //      $txn_id = $this->get_migration_script()->get_mapping_new_pk($this->_old_table, $old_row['id'], $this->_new_transaction_table);
29 27
 //          if ( ! $txn_id ){
30 28
 //              $this->add_error(sprintf(esc_html__("Could not find the transaction for the 3.1 attendee %d from row %s", "event_espresso"),$old_row['id'],$this->_json_encode($old_row)));
@@ -34,8 +32,8 @@  discard block
 block discarded – undo
34 32
 //          $new_line_items = $this->_insert_new_line_items($txn,$old_row);
35 33
 //          $this->get_migration_script()->set_mapping($this->_old_table,$old_row['id'],$this->_new_line_table,$new_line_items);
36 34
 
37
-            $this->_insert_new_event_question_groups($old_row);
38
-    }
35
+			$this->_insert_new_event_question_groups($old_row);
36
+	}
39 37
 //  function _migration_step($num_items=50){
40 38
 //      global $wpdb;
41 39
 //      $start_at_record = $this->count_records_migrated();
@@ -55,109 +53,109 @@  discard block
 block discarded – undo
55 53
 //      $count = $wpdb->get_var("SELECT COUNT(id) FROM ".$this->_old_table);
56 54
 //      return $count;
57 55
 //  }
58
-    public function __construct()
59
-    {
60
-        global $wpdb;
61
-        $this->_old_table = $wpdb->prefix . "events_detail";
62
-        $this->_extra_where_sql = 'WHERE event_status!="D"';
63
-        $this->_new_table = $wpdb->prefix . "esp_event_question_group";
64
-        $this->_pretty_name = esc_html__("Question Groups in each Event", "event_espresso");
65
-        parent::__construct();
66
-    }
56
+	public function __construct()
57
+	{
58
+		global $wpdb;
59
+		$this->_old_table = $wpdb->prefix . "events_detail";
60
+		$this->_extra_where_sql = 'WHERE event_status!="D"';
61
+		$this->_new_table = $wpdb->prefix . "esp_event_question_group";
62
+		$this->_pretty_name = esc_html__("Question Groups in each Event", "event_espresso");
63
+		parent::__construct();
64
+	}
67 65
 
68
-    /**
69
-     * Attempts to insert a new question group inthe new format given an old one
70
-     * @global type $wpdb
71
-     * @param array $old_event
72
-     * @return void
73
-     */
74
-    private function _insert_new_event_question_groups($old_event)
75
-    {
76
-        $new_event_question_group_ids = array();
77
-        $question_groups_for_primary = maybe_unserialize($old_event['question_groups']);
78
-        if (is_array($question_groups_for_primary)) {
79
-            foreach ($question_groups_for_primary as $old_question_group_id) {
80
-                $new_id = $this->_insert_event_question_group($old_event, $old_question_group_id, true);
81
-                if ($new_id) {
82
-                    $new_event_question_group_ids[] = $new_id;
83
-                }
84
-            }
85
-        }
86
-        $event_meta = maybe_unserialize($old_event['event_meta']);
87
-        if (isset($event_meta['add_attendee_question_groups'])) {
88
-            if (is_array($event_meta['add_attendee_question_groups'])) {
89
-                foreach ($event_meta['add_attendee_question_groups'] as $old_question_group_id) {
90
-                    $new_id = $this->_insert_event_question_group($old_event, $old_question_group_id, false);
91
-                    if ($new_id) {
92
-                        $new_event_question_group_ids[] = $new_id;
93
-                    }
94
-                }
95
-            }
96
-        }
66
+	/**
67
+	 * Attempts to insert a new question group inthe new format given an old one
68
+	 * @global type $wpdb
69
+	 * @param array $old_event
70
+	 * @return void
71
+	 */
72
+	private function _insert_new_event_question_groups($old_event)
73
+	{
74
+		$new_event_question_group_ids = array();
75
+		$question_groups_for_primary = maybe_unserialize($old_event['question_groups']);
76
+		if (is_array($question_groups_for_primary)) {
77
+			foreach ($question_groups_for_primary as $old_question_group_id) {
78
+				$new_id = $this->_insert_event_question_group($old_event, $old_question_group_id, true);
79
+				if ($new_id) {
80
+					$new_event_question_group_ids[] = $new_id;
81
+				}
82
+			}
83
+		}
84
+		$event_meta = maybe_unserialize($old_event['event_meta']);
85
+		if (isset($event_meta['add_attendee_question_groups'])) {
86
+			if (is_array($event_meta['add_attendee_question_groups'])) {
87
+				foreach ($event_meta['add_attendee_question_groups'] as $old_question_group_id) {
88
+					$new_id = $this->_insert_event_question_group($old_event, $old_question_group_id, false);
89
+					if ($new_id) {
90
+						$new_event_question_group_ids[] = $new_id;
91
+					}
92
+				}
93
+			}
94
+		}
97 95
 
98 96
 
99
-        $this->get_migration_script()->set_mapping($this->_old_table, $old_event['id'], $this->_new_table, $new_event_question_group_ids);
100
-    }
97
+		$this->get_migration_script()->set_mapping($this->_old_table, $old_event['id'], $this->_new_table, $new_event_question_group_ids);
98
+	}
101 99
 
102
-    private function _insert_event_question_group($old_event, $old_question_group_id, $primary)
103
-    {
104
-        global $wpdb;
105
-        $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
106
-            $wpdb->prefix . "events_qst_group",
107
-            intval($old_question_group_id),
108
-            $wpdb->prefix . "esp_question_group"
109
-        );
100
+	private function _insert_event_question_group($old_event, $old_question_group_id, $primary)
101
+	{
102
+		global $wpdb;
103
+		$new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
104
+			$wpdb->prefix . "events_qst_group",
105
+			intval($old_question_group_id),
106
+			$wpdb->prefix . "esp_question_group"
107
+		);
110 108
 
111
-        if (! $new_question_group_id) {
112
-            $this->add_error(
113
-                sprintf(
114
-                    // translators: %s question ID, %s event ID
115
-                    esc_html__("Could not find 4.1 question ID for 3.1 question id #%s on event $%s", "event_espresso"),
116
-                    $old_question_group_id,
117
-                    $old_event['id']
118
-                )
119
-            );
120
-            return 0;
121
-        }
122
-        $new_event_id = $this->get_migration_script()->get_mapping_new_pk(
123
-            $wpdb->prefix . "events_detail",
124
-            intval($old_event['id']),
125
-            $wpdb->posts
126
-        );
127
-        if (! $new_question_group_id) {
128
-            $this->add_error(
129
-                sprintf(
130
-                    // translators: %s event ID
131
-                    esc_html__("Could not find 4.1 event 3.1 event id #%s", "event_espresso"),
132
-                    $old_event['id']
133
-                )
134
-            );
135
-            return 0;
136
-        }
137
-        $cols_n_values = array(
138
-            'EVT_ID' => $new_event_id,
139
-            'QSG_ID' => $new_question_group_id,
140
-            'EQG_primary' => $primary
141
-        );
109
+		if (! $new_question_group_id) {
110
+			$this->add_error(
111
+				sprintf(
112
+					// translators: %s question ID, %s event ID
113
+					esc_html__("Could not find 4.1 question ID for 3.1 question id #%s on event $%s", "event_espresso"),
114
+					$old_question_group_id,
115
+					$old_event['id']
116
+				)
117
+			);
118
+			return 0;
119
+		}
120
+		$new_event_id = $this->get_migration_script()->get_mapping_new_pk(
121
+			$wpdb->prefix . "events_detail",
122
+			intval($old_event['id']),
123
+			$wpdb->posts
124
+		);
125
+		if (! $new_question_group_id) {
126
+			$this->add_error(
127
+				sprintf(
128
+					// translators: %s event ID
129
+					esc_html__("Could not find 4.1 event 3.1 event id #%s", "event_espresso"),
130
+					$old_event['id']
131
+				)
132
+			);
133
+			return 0;
134
+		}
135
+		$cols_n_values = array(
136
+			'EVT_ID' => $new_event_id,
137
+			'QSG_ID' => $new_question_group_id,
138
+			'EQG_primary' => $primary
139
+		);
142 140
 
143
-        $datatypes = array(
144
-            '%d',// EVT_ID
145
-            '%d',// QSG_ID
146
-            '%d',// EQG_primary
147
-        );
148
-        $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
149
-        if (! $success) {
150
-            $this->add_error(
151
-                $this->get_migration_script()->_create_error_message_for_db_insertion(
152
-                    $this->_old_table,
153
-                    $old_event,
154
-                    $this->_new_table,
155
-                    $cols_n_values,
156
-                    $datatypes
157
-                )
158
-            );
159
-            return 0;
160
-        }
161
-        return $wpdb->insert_id;
162
-    }
141
+		$datatypes = array(
142
+			'%d',// EVT_ID
143
+			'%d',// QSG_ID
144
+			'%d',// EQG_primary
145
+		);
146
+		$success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
147
+		if (! $success) {
148
+			$this->add_error(
149
+				$this->get_migration_script()->_create_error_message_for_db_insertion(
150
+					$this->_old_table,
151
+					$old_event,
152
+					$this->_new_table,
153
+					$cols_n_values,
154
+					$datatypes
155
+				)
156
+			);
157
+			return 0;
158
+		}
159
+		return $wpdb->insert_id;
160
+	}
163 161
 }
Please login to merge, or discard this patch.
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -58,9 +58,9 @@  discard block
 block discarded – undo
58 58
     public function __construct()
59 59
     {
60 60
         global $wpdb;
61
-        $this->_old_table = $wpdb->prefix . "events_detail";
61
+        $this->_old_table = $wpdb->prefix."events_detail";
62 62
         $this->_extra_where_sql = 'WHERE event_status!="D"';
63
-        $this->_new_table = $wpdb->prefix . "esp_event_question_group";
63
+        $this->_new_table = $wpdb->prefix."esp_event_question_group";
64 64
         $this->_pretty_name = esc_html__("Question Groups in each Event", "event_espresso");
65 65
         parent::__construct();
66 66
     }
@@ -103,12 +103,12 @@  discard block
 block discarded – undo
103 103
     {
104 104
         global $wpdb;
105 105
         $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk(
106
-            $wpdb->prefix . "events_qst_group",
106
+            $wpdb->prefix."events_qst_group",
107 107
             intval($old_question_group_id),
108
-            $wpdb->prefix . "esp_question_group"
108
+            $wpdb->prefix."esp_question_group"
109 109
         );
110 110
 
111
-        if (! $new_question_group_id) {
111
+        if ( ! $new_question_group_id) {
112 112
             $this->add_error(
113 113
                 sprintf(
114 114
                     // translators: %s question ID, %s event ID
@@ -120,11 +120,11 @@  discard block
 block discarded – undo
120 120
             return 0;
121 121
         }
122 122
         $new_event_id = $this->get_migration_script()->get_mapping_new_pk(
123
-            $wpdb->prefix . "events_detail",
123
+            $wpdb->prefix."events_detail",
124 124
             intval($old_event['id']),
125 125
             $wpdb->posts
126 126
         );
127
-        if (! $new_question_group_id) {
127
+        if ( ! $new_question_group_id) {
128 128
             $this->add_error(
129 129
                 sprintf(
130 130
                     // translators: %s event ID
@@ -141,12 +141,12 @@  discard block
 block discarded – undo
141 141
         );
142 142
 
143 143
         $datatypes = array(
144
-            '%d',// EVT_ID
145
-            '%d',// QSG_ID
146
-            '%d',// EQG_primary
144
+            '%d', // EVT_ID
145
+            '%d', // QSG_ID
146
+            '%d', // EQG_primary
147 147
         );
148 148
         $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
149
-        if (! $success) {
149
+        if ( ! $success) {
150 150
             $this->add_error(
151 151
                 $this->get_migration_script()->_create_error_message_for_db_insertion(
152 152
                     $this->_old_table,
Please login to merge, or discard this patch.
data_migration_scripts/4_1_0_stages/EE_DMS_4_1_0_event_venue.dmsstage.php 2 patches
Indentation   +87 added lines, -90 removed lines patch added patch discarded remove patch
@@ -25,105 +25,102 @@
 block discarded – undo
25 25
 
26 26
             )
27 27
         );
28
-
29
-
30
-
31 28
  *
32 29
  */
33 30
 class EE_DMS_4_1_0_event_venue extends EE_Data_Migration_Script_Stage
34 31
 {
35
-    private $_old_table;
36
-    private $_new_table;
37
-    public function _migration_step($num_items = 50)
38
-    {
32
+	private $_old_table;
33
+	private $_new_table;
34
+	public function _migration_step($num_items = 50)
35
+	{
39 36
 
40
-        global $wpdb;
41
-        $start_at_record = $this->count_records_migrated();
42
-        $rows = $wpdb->get_results(
43
-            $wpdb->prepare(
44
-                "SELECT * FROM $this->_old_table AS ev 
37
+		global $wpdb;
38
+		$start_at_record = $this->count_records_migrated();
39
+		$rows = $wpdb->get_results(
40
+			$wpdb->prepare(
41
+				"SELECT * FROM $this->_old_table AS ev 
45 42
                     INNER JOIN " . $wpdb->prefix . "events_detail AS e ON ev.event_id=e.id
46 43
                     WHERE e.event_status!='D' LIMIT %d,%d",
47
-                $start_at_record,
48
-                $num_items
49
-            ),
50
-            ARRAY_A
51
-        );
52
-        $items_actually_migrated = 0;
53
-        foreach ($rows as $event_venue_rel) {
54
-            $this->_insert_new_event_to_venue_rel($event_venue_rel);
55
-            $items_actually_migrated++;
56
-        }
57
-        if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
58
-            $this->set_completed();
59
-        }
60
-        return $items_actually_migrated;
61
-    }
62
-    public function _count_records_to_migrate()
63
-    {
64
-        global $wpdb;
65
-        $count = $wpdb->get_var(
66
-            "SELECT COUNT(ev.id) FROM " . $this->_old_table . " AS ev 
44
+				$start_at_record,
45
+				$num_items
46
+			),
47
+			ARRAY_A
48
+		);
49
+		$items_actually_migrated = 0;
50
+		foreach ($rows as $event_venue_rel) {
51
+			$this->_insert_new_event_to_venue_rel($event_venue_rel);
52
+			$items_actually_migrated++;
53
+		}
54
+		if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
55
+			$this->set_completed();
56
+		}
57
+		return $items_actually_migrated;
58
+	}
59
+	public function _count_records_to_migrate()
60
+	{
61
+		global $wpdb;
62
+		$count = $wpdb->get_var(
63
+			"SELECT COUNT(ev.id) FROM " . $this->_old_table . " AS ev 
67 64
             INNER JOIN " . $wpdb->prefix . 'events_detail AS e ON ev.event_id=e.id
68 65
             WHERE e.event_status!="D"'
69
-        );
70
-        return $count;
71
-    }
72
-    public function __construct()
73
-    {
74
-        global $wpdb;
75
-        $this->_old_table = $wpdb->prefix . "events_venue_rel";
76
-        $this->_new_table = $wpdb->prefix . "esp_event_venue";
77
-        $this->_pretty_name = esc_html__("Event to Venue Relations", "event_espresso");
78
-        parent::__construct();
79
-    }
66
+		);
67
+		return $count;
68
+	}
69
+	public function __construct()
70
+	{
71
+		global $wpdb;
72
+		$this->_old_table = $wpdb->prefix . "events_venue_rel";
73
+		$this->_new_table = $wpdb->prefix . "esp_event_venue";
74
+		$this->_pretty_name = esc_html__("Event to Venue Relations", "event_espresso");
75
+		parent::__construct();
76
+	}
80 77
 
81
-    /**
82
-     * Attempts to insert a new question group inthe new format given an old one
83
-     * @global type $wpdb
84
-     * @param array $old_event_venue_rel
85
-     * @return int
86
-     */
87
-    private function _insert_new_event_to_venue_rel($old_event_venue_rel)
88
-    {
89
-        global $wpdb;
90
-        $new_event_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_detail", $old_event_venue_rel['event_id'], $wpdb->prefix . "posts");
91
-        $new_venue_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_venue", $old_event_venue_rel['venue_id'], $wpdb->prefix . "posts");
92
-        if (! $new_event_id) {
93
-            $this->add_error(sprintf(esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"), $old_event_venue_rel['event_id']));
94
-            return 0;
95
-        }
96
-        if (! $new_venue_id) {
97
-            $this->add_error(sprintf(esc_html__("Could not find 4.1 venue id for 3.1 venue #%d.", "event_espresso"), $old_event_venue_rel['venue_id']));
98
-            return 0;
99
-        }
100
-        // first ensure there are no other relation entries for this event
101
-        // because although EE4 supports it, EE3 didn't really
102
-        $wpdb->delete(
103
-            $this->_new_table,
104
-            array(
105
-                    'EVT_ID' => $new_event_id,
106
-                ),
107
-            array(
108
-                    '%d',// EVT_ID
109
-                )
110
-        );
78
+	/**
79
+	 * Attempts to insert a new question group inthe new format given an old one
80
+	 * @global type $wpdb
81
+	 * @param array $old_event_venue_rel
82
+	 * @return int
83
+	 */
84
+	private function _insert_new_event_to_venue_rel($old_event_venue_rel)
85
+	{
86
+		global $wpdb;
87
+		$new_event_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_detail", $old_event_venue_rel['event_id'], $wpdb->prefix . "posts");
88
+		$new_venue_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_venue", $old_event_venue_rel['venue_id'], $wpdb->prefix . "posts");
89
+		if (! $new_event_id) {
90
+			$this->add_error(sprintf(esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"), $old_event_venue_rel['event_id']));
91
+			return 0;
92
+		}
93
+		if (! $new_venue_id) {
94
+			$this->add_error(sprintf(esc_html__("Could not find 4.1 venue id for 3.1 venue #%d.", "event_espresso"), $old_event_venue_rel['venue_id']));
95
+			return 0;
96
+		}
97
+		// first ensure there are no other relation entries for this event
98
+		// because although EE4 supports it, EE3 didn't really
99
+		$wpdb->delete(
100
+			$this->_new_table,
101
+			array(
102
+					'EVT_ID' => $new_event_id,
103
+				),
104
+			array(
105
+					'%d',// EVT_ID
106
+				)
107
+		);
111 108
 //      echo "last query". $wpdb->last_query;die;
112
-        $cols_n_values = array(
113
-            'EVT_ID' => $new_event_id,
114
-            'VNU_ID' => $new_venue_id,
115
-            'EVV_primary' => true
116
-        );
117
-        $datatypes = array(
118
-            '%d',// EVT_ID
119
-            '%d',// VNU_ID
120
-            '%d',// EVT_primary
121
-        );
122
-        $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
123
-        if (! $success) {
124
-            $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_event_venue_rel, $this->_new_table, $cols_n_values, $datatypes));
125
-            return 0;
126
-        }
127
-        return $wpdb->insert_id;
128
-    }
109
+		$cols_n_values = array(
110
+			'EVT_ID' => $new_event_id,
111
+			'VNU_ID' => $new_venue_id,
112
+			'EVV_primary' => true
113
+		);
114
+		$datatypes = array(
115
+			'%d',// EVT_ID
116
+			'%d',// VNU_ID
117
+			'%d',// EVT_primary
118
+		);
119
+		$success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
120
+		if (! $success) {
121
+			$this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_event_venue_rel, $this->_new_table, $cols_n_values, $datatypes));
122
+			return 0;
123
+		}
124
+		return $wpdb->insert_id;
125
+	}
129 126
 }
Please login to merge, or discard this patch.
Spacing   +14 added lines, -14 removed lines patch added patch discarded remove patch
@@ -42,7 +42,7 @@  discard block
 block discarded – undo
42 42
         $rows = $wpdb->get_results(
43 43
             $wpdb->prepare(
44 44
                 "SELECT * FROM $this->_old_table AS ev 
45
-                    INNER JOIN " . $wpdb->prefix . "events_detail AS e ON ev.event_id=e.id
45
+                    INNER JOIN ".$wpdb->prefix."events_detail AS e ON ev.event_id=e.id
46 46
                     WHERE e.event_status!='D' LIMIT %d,%d",
47 47
                 $start_at_record,
48 48
                 $num_items
@@ -63,8 +63,8 @@  discard block
 block discarded – undo
63 63
     {
64 64
         global $wpdb;
65 65
         $count = $wpdb->get_var(
66
-            "SELECT COUNT(ev.id) FROM " . $this->_old_table . " AS ev 
67
-            INNER JOIN " . $wpdb->prefix . 'events_detail AS e ON ev.event_id=e.id
66
+            "SELECT COUNT(ev.id) FROM ".$this->_old_table." AS ev 
67
+            INNER JOIN " . $wpdb->prefix.'events_detail AS e ON ev.event_id=e.id
68 68
             WHERE e.event_status!="D"'
69 69
         );
70 70
         return $count;
@@ -72,8 +72,8 @@  discard block
 block discarded – undo
72 72
     public function __construct()
73 73
     {
74 74
         global $wpdb;
75
-        $this->_old_table = $wpdb->prefix . "events_venue_rel";
76
-        $this->_new_table = $wpdb->prefix . "esp_event_venue";
75
+        $this->_old_table = $wpdb->prefix."events_venue_rel";
76
+        $this->_new_table = $wpdb->prefix."esp_event_venue";
77 77
         $this->_pretty_name = esc_html__("Event to Venue Relations", "event_espresso");
78 78
         parent::__construct();
79 79
     }
@@ -87,13 +87,13 @@  discard block
 block discarded – undo
87 87
     private function _insert_new_event_to_venue_rel($old_event_venue_rel)
88 88
     {
89 89
         global $wpdb;
90
-        $new_event_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_detail", $old_event_venue_rel['event_id'], $wpdb->prefix . "posts");
91
-        $new_venue_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_venue", $old_event_venue_rel['venue_id'], $wpdb->prefix . "posts");
92
-        if (! $new_event_id) {
90
+        $new_event_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_detail", $old_event_venue_rel['event_id'], $wpdb->prefix."posts");
91
+        $new_venue_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_venue", $old_event_venue_rel['venue_id'], $wpdb->prefix."posts");
92
+        if ( ! $new_event_id) {
93 93
             $this->add_error(sprintf(esc_html__("Could not find 4.1 event id for 3.1 event #%d.", "event_espresso"), $old_event_venue_rel['event_id']));
94 94
             return 0;
95 95
         }
96
-        if (! $new_venue_id) {
96
+        if ( ! $new_venue_id) {
97 97
             $this->add_error(sprintf(esc_html__("Could not find 4.1 venue id for 3.1 venue #%d.", "event_espresso"), $old_event_venue_rel['venue_id']));
98 98
             return 0;
99 99
         }
@@ -105,7 +105,7 @@  discard block
 block discarded – undo
105 105
                     'EVT_ID' => $new_event_id,
106 106
                 ),
107 107
             array(
108
-                    '%d',// EVT_ID
108
+                    '%d', // EVT_ID
109 109
                 )
110 110
         );
111 111
 //      echo "last query". $wpdb->last_query;die;
@@ -115,12 +115,12 @@  discard block
 block discarded – undo
115 115
             'EVV_primary' => true
116 116
         );
117 117
         $datatypes = array(
118
-            '%d',// EVT_ID
119
-            '%d',// VNU_ID
120
-            '%d',// EVT_primary
118
+            '%d', // EVT_ID
119
+            '%d', // VNU_ID
120
+            '%d', // EVT_primary
121 121
         );
122 122
         $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
123
-        if (! $success) {
123
+        if ( ! $success) {
124 124
             $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_event_venue_rel, $this->_new_table, $cols_n_values, $datatypes));
125 125
             return 0;
126 126
         }
Please login to merge, or discard this patch.
4_1_0_stages/EE_DMS_4_1_0_question_group_question.dmsstage.php 2 patches
Indentation   +106 added lines, -108 removed lines patch added patch discarded remove patch
@@ -12,8 +12,6 @@  discard block
 block discarded – undo
12 12
   KEY `group_id` (`group_id`),
13 13
   KEY `question_id` (`question_id`)
14 14
 ) ENGINE=InnoDB AUTO_INCREMENT=19 DEFAULT CHARSET=utf8$$
15
-
16
-
17 15
  * 4.1 question group question model's tables and fields:
18 16
  $this->_tables = array(
19 17
             'Question_Group_Question'=>new EE_Primary_Table('esp_question_group_question','QGQ_ID')
@@ -29,114 +27,114 @@  discard block
 block discarded – undo
29 27
  */
30 28
 class EE_DMS_4_1_0_question_group_question extends EE_Data_Migration_Script_Stage
31 29
 {
32
-    private $_old_table;
33
-    private $_new_table;
34
-    public function _migration_step($num_items = 50)
35
-    {
30
+	private $_old_table;
31
+	private $_new_table;
32
+	public function _migration_step($num_items = 50)
33
+	{
36 34
 
37
-        global $wpdb;
38
-        $start_at_record = $this->count_records_migrated();
39
-        $rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d", $start_at_record, $num_items), ARRAY_A);
40
-        $items_actually_migrated = 0;
41
-        foreach ($rows as $question_group_question) {
42
-            $this->_insert_new_question_group_question($question_group_question);
43
-            $items_actually_migrated++;
44
-        }
45
-        if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
46
-            $this->set_completed();
47
-        }
48
-        return $items_actually_migrated;
49
-    }
50
-    public function _count_records_to_migrate()
51
-    {
52
-        global $wpdb;
53
-        $count = $wpdb->get_var("SELECT COUNT(id) FROM " . $this->_old_table);
54
-        return $count;
55
-    }
56
-    public function __construct()
57
-    {
58
-        global $wpdb;
59
-        $this->_old_table = $wpdb->prefix . "events_qst_group_rel";
60
-        $this->_new_table = $wpdb->prefix . "esp_question_group_question";
61
-        $this->_pretty_name = esc_html__("Question Group to Question Relations", "event_espresso");
62
-        parent::__construct();
63
-    }
35
+		global $wpdb;
36
+		$start_at_record = $this->count_records_migrated();
37
+		$rows = $wpdb->get_results($wpdb->prepare("SELECT * FROM $this->_old_table LIMIT %d,%d", $start_at_record, $num_items), ARRAY_A);
38
+		$items_actually_migrated = 0;
39
+		foreach ($rows as $question_group_question) {
40
+			$this->_insert_new_question_group_question($question_group_question);
41
+			$items_actually_migrated++;
42
+		}
43
+		if ($this->count_records_migrated() + $items_actually_migrated >= $this->count_records_to_migrate()) {
44
+			$this->set_completed();
45
+		}
46
+		return $items_actually_migrated;
47
+	}
48
+	public function _count_records_to_migrate()
49
+	{
50
+		global $wpdb;
51
+		$count = $wpdb->get_var("SELECT COUNT(id) FROM " . $this->_old_table);
52
+		return $count;
53
+	}
54
+	public function __construct()
55
+	{
56
+		global $wpdb;
57
+		$this->_old_table = $wpdb->prefix . "events_qst_group_rel";
58
+		$this->_new_table = $wpdb->prefix . "esp_question_group_question";
59
+		$this->_pretty_name = esc_html__("Question Group to Question Relations", "event_espresso");
60
+		parent::__construct();
61
+	}
64 62
 
65
-    /**
66
-     * Attempts to insert a new question group inthe new format given an old one
67
-     * @global type $wpdb
68
-     * @param array $old_question_group_question
69
-     * @return int
70
-     */
71
-    private function _insert_new_question_group_question($old_question_group_question)
72
-    {
73
-        global $wpdb;
74
-        $new_question_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_question", $old_question_group_question['question_id'], $wpdb->prefix . "esp_question");
75
-        $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_qst_group", $old_question_group_question['group_id'], $wpdb->prefix . "esp_question_group");
76
-        if (! $new_question_id) {
77
-            $this->add_error(sprintf(esc_html__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"), $old_question_group_question['question_id']));
78
-            return 0;
79
-        }
80
-        if (! $new_question_group_id) {
81
-            $this->add_error(sprintf(esc_html__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"), $old_question_group_question['group_id']));
82
-            return 0;
83
-        }
84
-        // if it's a system question, it needs to be in the right system group. otherwise no dice!
85
-        if (
86
-            ($this->_is_system_question_group($new_question_group_id) == $this->_is_system_question_for_question_group($new_question_id) )
87
-                ||
88
-                ! $this->_is_system_question_for_question_group($new_question_id)
89
-        ) {
90
-            $cols_n_values = array(
91
-                'QSG_ID' => $new_question_group_id,
92
-                'QST_ID' => $new_question_id
93
-            );
94
-            $datatypes = array(
95
-                '%d',// QSG_ID
96
-                '%d',// QST_ID
97
-            );
98
-            $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
99
-            if (! $success) {
100
-                $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_question_group_question, $this->_new_table, $cols_n_values, $datatypes));
101
-                return 0;
102
-            }
103
-            return $wpdb->insert_id;
104
-        } else {
105
-            return false;
106
-        }
107
-    }
63
+	/**
64
+	 * Attempts to insert a new question group inthe new format given an old one
65
+	 * @global type $wpdb
66
+	 * @param array $old_question_group_question
67
+	 * @return int
68
+	 */
69
+	private function _insert_new_question_group_question($old_question_group_question)
70
+	{
71
+		global $wpdb;
72
+		$new_question_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_question", $old_question_group_question['question_id'], $wpdb->prefix . "esp_question");
73
+		$new_question_group_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_qst_group", $old_question_group_question['group_id'], $wpdb->prefix . "esp_question_group");
74
+		if (! $new_question_id) {
75
+			$this->add_error(sprintf(esc_html__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"), $old_question_group_question['question_id']));
76
+			return 0;
77
+		}
78
+		if (! $new_question_group_id) {
79
+			$this->add_error(sprintf(esc_html__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"), $old_question_group_question['group_id']));
80
+			return 0;
81
+		}
82
+		// if it's a system question, it needs to be in the right system group. otherwise no dice!
83
+		if (
84
+			($this->_is_system_question_group($new_question_group_id) == $this->_is_system_question_for_question_group($new_question_id) )
85
+				||
86
+				! $this->_is_system_question_for_question_group($new_question_id)
87
+		) {
88
+			$cols_n_values = array(
89
+				'QSG_ID' => $new_question_group_id,
90
+				'QST_ID' => $new_question_id
91
+			);
92
+			$datatypes = array(
93
+				'%d',// QSG_ID
94
+				'%d',// QST_ID
95
+			);
96
+			$success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
97
+			if (! $success) {
98
+				$this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_question_group_question, $this->_new_table, $cols_n_values, $datatypes));
99
+				return 0;
100
+			}
101
+			return $wpdb->insert_id;
102
+		} else {
103
+			return false;
104
+		}
105
+	}
108 106
 
109
-    /**
110
-     * If this question is a system question, returns the QSG_system number that
111
-     * indicates the question group its permitted in.
112
-     * @global type $wpdb
113
-     * @param type $new_question_id
114
-     * @return int
115
-     */
116
-    private function _is_system_question_for_question_group($new_question_id)
117
-    {
118
-        global $wpdb;
119
-        $system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM " . $wpdb->prefix . "esp_question WHERE QST_ID=%d", $new_question_id));
120
-        if (in_array($system_id, array('fname','lname','email'))) {
121
-            return 1;
122
-        } elseif ($system_id != '' && $system_id) {
123
-            return 2;
124
-        } else {
125
-            return 0;
126
-        }
127
-    }
107
+	/**
108
+	 * If this question is a system question, returns the QSG_system number that
109
+	 * indicates the question group its permitted in.
110
+	 * @global type $wpdb
111
+	 * @param type $new_question_id
112
+	 * @return int
113
+	 */
114
+	private function _is_system_question_for_question_group($new_question_id)
115
+	{
116
+		global $wpdb;
117
+		$system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM " . $wpdb->prefix . "esp_question WHERE QST_ID=%d", $new_question_id));
118
+		if (in_array($system_id, array('fname','lname','email'))) {
119
+			return 1;
120
+		} elseif ($system_id != '' && $system_id) {
121
+			return 2;
122
+		} else {
123
+			return 0;
124
+		}
125
+	}
128 126
 
129
-    /**
130
-     * Returns the questino group's QSG_system value (1 meaning personal info, 2
131
-     * being address info, and 0 being neither)
132
-     * @global type $wpdb
133
-     * @param type $new_question_group_id
134
-     * @return boolean
135
-     */
136
-    private function _is_system_question_group($new_question_group_id)
137
-    {
138
-        global $wpdb;
139
-        $system_id = $wpdb->get_var($wpdb->prepare("SELECT QSG_system FROM " . $wpdb->prefix . "esp_question_group WHERE QSG_ID=%d", $new_question_group_id));
140
-        return intval($system_id);
141
-    }
127
+	/**
128
+	 * Returns the questino group's QSG_system value (1 meaning personal info, 2
129
+	 * being address info, and 0 being neither)
130
+	 * @global type $wpdb
131
+	 * @param type $new_question_group_id
132
+	 * @return boolean
133
+	 */
134
+	private function _is_system_question_group($new_question_group_id)
135
+	{
136
+		global $wpdb;
137
+		$system_id = $wpdb->get_var($wpdb->prepare("SELECT QSG_system FROM " . $wpdb->prefix . "esp_question_group WHERE QSG_ID=%d", $new_question_group_id));
138
+		return intval($system_id);
139
+	}
142 140
 }
Please login to merge, or discard this patch.
Spacing   +14 added lines, -14 removed lines patch added patch discarded remove patch
@@ -50,14 +50,14 @@  discard block
 block discarded – undo
50 50
     public function _count_records_to_migrate()
51 51
     {
52 52
         global $wpdb;
53
-        $count = $wpdb->get_var("SELECT COUNT(id) FROM " . $this->_old_table);
53
+        $count = $wpdb->get_var("SELECT COUNT(id) FROM ".$this->_old_table);
54 54
         return $count;
55 55
     }
56 56
     public function __construct()
57 57
     {
58 58
         global $wpdb;
59
-        $this->_old_table = $wpdb->prefix . "events_qst_group_rel";
60
-        $this->_new_table = $wpdb->prefix . "esp_question_group_question";
59
+        $this->_old_table = $wpdb->prefix."events_qst_group_rel";
60
+        $this->_new_table = $wpdb->prefix."esp_question_group_question";
61 61
         $this->_pretty_name = esc_html__("Question Group to Question Relations", "event_espresso");
62 62
         parent::__construct();
63 63
     }
@@ -71,19 +71,19 @@  discard block
 block discarded – undo
71 71
     private function _insert_new_question_group_question($old_question_group_question)
72 72
     {
73 73
         global $wpdb;
74
-        $new_question_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_question", $old_question_group_question['question_id'], $wpdb->prefix . "esp_question");
75
-        $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix . "events_qst_group", $old_question_group_question['group_id'], $wpdb->prefix . "esp_question_group");
76
-        if (! $new_question_id) {
74
+        $new_question_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_question", $old_question_group_question['question_id'], $wpdb->prefix."esp_question");
75
+        $new_question_group_id = $this->get_migration_script()->get_mapping_new_pk($wpdb->prefix."events_qst_group", $old_question_group_question['group_id'], $wpdb->prefix."esp_question_group");
76
+        if ( ! $new_question_id) {
77 77
             $this->add_error(sprintf(esc_html__("Could not find 4.1 question id for 3.1 question #%d.", "event_espresso"), $old_question_group_question['question_id']));
78 78
             return 0;
79 79
         }
80
-        if (! $new_question_group_id) {
80
+        if ( ! $new_question_group_id) {
81 81
             $this->add_error(sprintf(esc_html__("Could not find 4.1 question group id for 3.1 question group #%d.", "event_espresso"), $old_question_group_question['group_id']));
82 82
             return 0;
83 83
         }
84 84
         // if it's a system question, it needs to be in the right system group. otherwise no dice!
85 85
         if (
86
-            ($this->_is_system_question_group($new_question_group_id) == $this->_is_system_question_for_question_group($new_question_id) )
86
+            ($this->_is_system_question_group($new_question_group_id) == $this->_is_system_question_for_question_group($new_question_id))
87 87
                 ||
88 88
                 ! $this->_is_system_question_for_question_group($new_question_id)
89 89
         ) {
@@ -92,11 +92,11 @@  discard block
 block discarded – undo
92 92
                 'QST_ID' => $new_question_id
93 93
             );
94 94
             $datatypes = array(
95
-                '%d',// QSG_ID
96
-                '%d',// QST_ID
95
+                '%d', // QSG_ID
96
+                '%d', // QST_ID
97 97
             );
98 98
             $success = $wpdb->insert($this->_new_table, $cols_n_values, $datatypes);
99
-            if (! $success) {
99
+            if ( ! $success) {
100 100
                 $this->add_error($this->get_migration_script()->_create_error_message_for_db_insertion($this->_old_table, $old_question_group_question, $this->_new_table, $cols_n_values, $datatypes));
101 101
                 return 0;
102 102
             }
@@ -116,8 +116,8 @@  discard block
 block discarded – undo
116 116
     private function _is_system_question_for_question_group($new_question_id)
117 117
     {
118 118
         global $wpdb;
119
-        $system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM " . $wpdb->prefix . "esp_question WHERE QST_ID=%d", $new_question_id));
120
-        if (in_array($system_id, array('fname','lname','email'))) {
119
+        $system_id = $wpdb->get_var($wpdb->prepare("SELECT QST_system FROM ".$wpdb->prefix."esp_question WHERE QST_ID=%d", $new_question_id));
120
+        if (in_array($system_id, array('fname', 'lname', 'email'))) {
121 121
             return 1;
122 122
         } elseif ($system_id != '' && $system_id) {
123 123
             return 2;
@@ -136,7 +136,7 @@  discard block
 block discarded – undo
136 136
     private function _is_system_question_group($new_question_group_id)
137 137
     {
138 138
         global $wpdb;
139
-        $system_id = $wpdb->get_var($wpdb->prepare("SELECT QSG_system FROM " . $wpdb->prefix . "esp_question_group WHERE QSG_ID=%d", $new_question_group_id));
139
+        $system_id = $wpdb->get_var($wpdb->prepare("SELECT QSG_system FROM ".$wpdb->prefix."esp_question_group WHERE QSG_ID=%d", $new_question_group_id));
140 140
         return intval($system_id);
141 141
     }
142 142
 }
Please login to merge, or discard this patch.