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
if ( ! defined( &#039;ABSPATH&#039; ) ) {
  exit; // Exit if accessed directly.
}


if ( ! class_exists( &#039;OsCustomersController&#039; ) ) :


  class OsCustomersController extends OsController {

    function __construct(){
      parent::__construct();


      $this-&gt;views_folder = LATEPOINT_VIEWS_ABSPATH . &#039;customers/&#039;;
      $this-&gt;vars[&#039;page_header&#039;] = OsMenuHelper::get_menu_items_by_id(&#039;customers&#039;);
      $this-&gt;vars[&#039;breadcrumbs&#039;][] = array(&#039;label&#039; =&gt; __(&#039;Customers&#039;, &#039;latepoint&#039;), &#039;link&#039; =&gt; OsRouterHelper::build_link(OsRouterHelper::build_route_name(&#039;customers&#039;, &#039;index&#039;) ) );
    }

    public function destroy(){
      if(filter_var($this-&gt;params[&#039;id&#039;], FILTER_VALIDATE_INT)){
	      $this-&gt;check_nonce(&#039;destroy_customer_&#039;.$this-&gt;params[&#039;id&#039;]);
        $customer = new OsCustomerModel($this-&gt;params[&#039;id&#039;]);
        if($customer-&gt;delete()){
          $status = LATEPOINT_STATUS_SUCCESS;
          $response_html = __(&#039;Customer Removed&#039;, &#039;latepoint&#039;);
        }else{
          $status = LATEPOINT_STATUS_ERROR;
          $response_html = __(&#039;Error Removing Customer&#039;, &#039;latepoint&#039;);
        }
      }else{
        $status = LATEPOINT_STATUS_ERROR;
        $response_html = __(&#039;Error Removing Customer&#039;, &#039;latepoint&#039;);
      }

      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; $status, &#039;message&#039; =&gt; $response_html));
      }
    }


		public function view_customer_log(){

			$activities = new OsActivityModel();
			$activities = $activities-&gt;where([&#039;customer_id&#039; =&gt; absint($this-&gt;params[&#039;customer_id&#039;])])-&gt;order_by(&#039;id desc&#039;)-&gt;get_results_as_models();

			$customer = new OsCustomerModel($this-&gt;params[&#039;customer_id&#039;]);

			$this-&gt;vars[&#039;customer&#039;] = $customer;
			$this-&gt;vars[&#039;activities&#039;] = $activities;

      $this-&gt;format_render(__FUNCTION__);
		}


		public function quick_new(){
			$customer = new OsCustomerModel();

			$this-&gt;vars[&#039;customer&#039;] = $customer;

			$this-&gt;format_render(&#039;quick_edit&#039;);
		}

		public function quick_edit(){
			if(!filter_var($this-&gt;params[&#039;customer_id&#039;], FILTER_VALIDATE_INT)) $this-&gt;access_not_allowed();
			$customer = new OsCustomerModel($this-&gt;params[&#039;customer_id&#039;]);

			$this-&gt;vars[&#039;customer&#039;] = $customer;

			$this-&gt;format_render(__FUNCTION__);
		}


    public function inline_edit_form(){
      $selected_customer = new OsCustomerModel();
      if(isset($this-&gt;params[&#039;customer_id&#039;])){
        $selected_customer-&gt;load_by_id($this-&gt;params[&#039;customer_id&#039;]);
      }
      $this-&gt;vars[&#039;default_fields_for_customer&#039;] = OsSettingsHelper::get_default_fields_for_customer();
      $this-&gt;vars[&#039;selected_customer&#039;] = $selected_customer;
      $this-&gt;format_render(__FUNCTION__);
    }

		public function set_as_guest(){
      if(filter_var($this-&gt;params[&#039;id&#039;], FILTER_VALIDATE_INT)){
        $customer = new OsCustomerModel($this-&gt;params[&#039;id&#039;]);
        if($customer-&gt;update_attributes([&#039;is_guest&#039; =&gt; true])){
          $status = LATEPOINT_STATUS_SUCCESS;
          $response_html = __(&#039;Customer is now allowed to book without password&#039;, &#039;latepoint&#039;);
        }else{
          $status = LATEPOINT_STATUS_ERROR;
          $response_html = $customer-&gt;get_error_messages();
        }
      }else{
        $status = LATEPOINT_STATUS_ERROR;
        $response_html = __(&#039;Error setting customer as guest&#039;, &#039;latepoint&#039;);
      }

      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; $status, &#039;message&#039; =&gt; $response_html));
      }
		}

    /*
      Edit customer
    */

    public function edit_form(){
      $this-&gt;vars[&#039;page_header&#039;] = __(&#039;Edit Customer&#039;, &#039;latepoint&#039;);
      $this-&gt;vars[&#039;breadcrumbs&#039;][] = array(&#039;label&#039; =&gt; __(&#039;Edit Customer&#039;, &#039;latepoint&#039;), &#039;link&#039; =&gt; false );

      if(filter_var($this-&gt;params[&#039;id&#039;], FILTER_VALIDATE_INT)){
				// check if allowed to access
				$customer = new OsCustomerModel();
				$customer = $customer-&gt;where([LATEPOINT_TABLE_CUSTOMERS.&#039;.id&#039; =&gt; absint($this-&gt;params[&#039;id&#039;])])-&gt;filter_allowed_records()-&gt;set_limit(1)-&gt;get_results_as_models();
	      $this-&gt;vars[&#039;customer&#039;] = $customer;
	      $this-&gt;vars[&#039;wp_users_for_select&#039;] = OsWpUserHelper::get_wp_users_for_select();
      }

      $this-&gt;format_render(__FUNCTION__);
    }


    public function query_for_booking_form(){
      $query = trim($this-&gt;params[&#039;query&#039;]);
      $sql_query = &#039;%&#039;.$query.&#039;%&#039;;
      $query = $this-&gt;params[&#039;query&#039;];
      $customers = new OsCustomerModel();
      $this-&gt;vars[&#039;query&#039;] = $query;
      $this-&gt;vars[&#039;customers&#039;] = $customers-&gt;where(array(&#039;OR&#039; =&gt; array(&#039;CONCAT (first_name, &quot; &quot;, last_name) LIKE &#039; =&gt; $sql_query, &#039;email LIKE&#039; =&gt; $sql_query, &#039;phone LIKE&#039; =&gt; $sql_query)))-&gt;set_limit(20)-&gt;order_by(&#039;first_name asc, last_name asc&#039;)-&gt;get_results_as_models();

      $this-&gt;format_render(__FUNCTION__);
    }


    /*
      Create customer
    */

    public function create(){
      $this-&gt;check_nonce(&#039;new_customer&#039;);
      $customer = new OsCustomerModel();
      $customer-&gt;set_data($this-&gt;params[&#039;customer&#039;]);
      if($customer-&gt;save()){
	      // translators: %s is the html of a customer edit link
				$response_html = sprintf(__(&#039;Customer Created ID: %s&#039;, &#039;latepoint&#039;), &#039;&lt;span class=&quot;os-notification-link&quot; &#039;.OsCustomerHelper::quick_customer_btn_html($customer-&gt;id).&#039;&gt;&#039;.$customer-&gt;id.&#039;&lt;/span&gt;&#039;);
        $status = LATEPOINT_STATUS_SUCCESS;
        do_action(&#039;latepoint_customer_created&#039;, $customer);
      }else{
        $response_html = $customer-&gt;get_error_messages();
        $status = LATEPOINT_STATUS_ERROR;
      }
      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; $status, &#039;message&#039; =&gt; $response_html));
      }
    }


    /*
      Update customer
    */

    public function update(){
      if(isset($this-&gt;params[&#039;customer&#039;][&#039;id&#039;]) &amp;&amp; filter_var($this-&gt;params[&#039;customer&#039;][&#039;id&#039;], FILTER_VALIDATE_INT)){
	      $this-&gt;check_nonce(&#039;edit_customer_&#039;.$this-&gt;params[&#039;customer&#039;][&#039;id&#039;]);
	      $customer = new OsCustomerModel($this-&gt;params[&#039;customer&#039;][&#039;id&#039;]);
				if(!$customer || !OsRolesHelper::can_user_make_action_on_model_record($customer, &#039;edit&#039;)){
	        $response_html = __(&#039;Access Restricted&#039;, &#039;latepoint&#039;);
	        $status = LATEPOINT_STATUS_ERROR;
				}else{
					$old_customer_data = $customer-&gt;get_data_vars();
		      $customer-&gt;set_data($this-&gt;params[&#039;customer&#039;]);
		      if($customer-&gt;save()){
				  // translators: %s is the html of a customer edit link
						$response_html = sprintf(__(&#039;Customer Updated ID: %s&#039;, &#039;latepoint&#039;), &#039;&lt;span class=&quot;os-notification-link&quot; &#039;.OsCustomerHelper::quick_customer_btn_html($customer-&gt;id).&#039;&gt;&#039;.$customer-&gt;id.&#039;&lt;/span&gt;&#039;);
		        $status = LATEPOINT_STATUS_SUCCESS;
		        do_action(&#039;latepoint_customer_updated&#039;, $customer, $old_customer_data);
		      }else{
		        $response_html = $customer-&gt;get_error_messages();
		        $status = LATEPOINT_STATUS_ERROR;
		      }
				}
      }else{
        $response_html = __(&#039;Invalid customer ID&#039;, &#039;latepoint&#039;);
        $status = LATEPOINT_STATUS_ERROR;
      }
      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; $status, &#039;message&#039; =&gt; $response_html));
      }
    }

    public function mini_profile(){
      if(filter_var($this-&gt;params[&#039;customer_id&#039;], FILTER_VALIDATE_INT)){
        $customer = new OsCustomerModel($this-&gt;params[&#039;customer_id&#039;]);
        $this-&gt;vars[&#039;upcoming_booking&#039;] = $customer-&gt;get_future_bookings(1, true);
        $this-&gt;vars[&#039;customer&#039;] = $customer;


        $pie_labels = [];
        $pie_colors = [];
        $pie_values = [];
        $pie_chart_data = OsBookingHelper::get_stat(&#039;bookings&#039;, [&#039;group_by&#039; =&gt; &#039;status&#039;, &#039;customer_id&#039; =&gt; $customer-&gt;id]);
        $colors = [&#039;#2752E4&#039;, &#039;#C066F1&#039;, &#039;#26B7DD&#039;, &#039;#E8C634&#039;, &#039;#19CED6&#039;, &#039;#2FEAA3&#039;, &#039;#252a3e&#039;, &#039;#8d87a5&#039;, &#039;#b9b784&#039;];
        $status_colors = [
          LATEPOINT_BOOKING_STATUS_APPROVED =&gt; &#039;#35d893&#039;,
          LATEPOINT_BOOKING_STATUS_PENDING =&gt; &#039;#e6b935&#039;,
          LATEPOINT_BOOKING_STATUS_PAYMENT_PENDING =&gt; &#039;#4ca4ef&#039;,
          LATEPOINT_BOOKING_STATUS_CANCELLED =&gt; &#039;#f1585d&#039;
        ];
        $i = 0;
        foreach($pie_chart_data as $pie_data){
          $pie_labels[] = $pie_data[&#039;status&#039;];
          $pie_colors[] = isset($status_colors[$pie_data[&#039;status&#039;]]) ? $status_colors[$pie_data[&#039;status&#039;]] : $colors[$i];
          $pie_values[] = $pie_data[&#039;stat&#039;];
          $i++;
        }

        $this-&gt;vars[&#039;pie_chart_data&#039;] = [&#039;labels&#039; =&gt; $pie_labels, &#039;colors&#039; =&gt; $pie_colors, &#039;values&#039; =&gt; $pie_values];


        $this-&gt;set_layout(&#039;none&#039;);
        $response_html = $this-&gt;format_render_return(__FUNCTION__);
      }else{
        $status = LATEPOINT_STATUS_ERROR;
        $response_html = __(&#039;Error Accessing Customer&#039;, &#039;latepoint&#039;);
      }

      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; $status, &#039;message&#039; =&gt; $response_html));
      }
    }

    public function connect_all_to_wp_users(){
      $customers = new OsCustomerModel();
      $customers = $customers-&gt;where([&#039;wordpress_user_id&#039; =&gt; [&#039;OR&#039; =&gt; [0, &#039;IS NULL&#039;]]])-&gt;get_results_as_models();
      if($customers){
        foreach($customers as $customer){
          $wp_user_id = OsCustomerHelper::create_wp_user_for_customer($customer);
          if($wp_user_id) {
			  //check if wp user already connected to another customer
	          $connected_customer = new OsCustomerModel();
	          $connected_customer = $connected_customer-&gt;where( [ &#039;wordpress_user_id&#039; =&gt; $wp_user_id ] )-&gt;set_limit( 1 )-&gt;get_results_as_models();
	          if ( !$connected_customer ) {
		          $customer-&gt;update_attributes( [ &#039;wordpress_user_id&#039; =&gt; $wp_user_id ] );
	          }
          }
        }
      }

      if($this-&gt;get_return_format() == &#039;json&#039;){
	      $this-&gt;send_json(array(&#039;status&#039; =&gt; LATEPOINT_STATUS_SUCCESS, &#039;message&#039; =&gt; __(&#039;Customers Connected&#039;, &#039;latepoint&#039;)));
      }
    }

    public function disconnect_from_wp_user(){
      $customer_id = $this-&gt;params[&#039;customer_id&#039;];
      $customer = new OsCustomerModel();
      $customer = $customer-&gt;where([&#039;id&#039; =&gt; $customer_id])-&gt;set_limit(1)-&gt;get_results_as_models();
      if($customer){
        $customer-&gt;update_attributes([&#039;wordpress_user_id&#039; =&gt; NULL]);
      }
      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; LATEPOINT_STATUS_SUCCESS, &#039;message&#039; =&gt; __(&#039;Customer Disconnected&#039;, &#039;latepoint&#039;)));
      }
    }

    public function connect_to_wp_user(){
      $customer_id = $this-&gt;params[&#039;customer_id&#039;];
      $customer = new OsCustomerModel();
      $customer = $customer-&gt;where([&#039;id&#039; =&gt; $customer_id])-&gt;set_limit(1)-&gt;get_results_as_models();
      if($customer &amp;&amp; !$customer-&gt;wordpress_user_id){
        $wp_user = OsCustomerHelper::create_wp_user_for_customer($customer);
      }
      if($this-&gt;get_return_format() == &#039;json&#039;){
        $this-&gt;send_json(array(&#039;status&#039; =&gt; LATEPOINT_STATUS_SUCCESS, &#039;message&#039; =&gt; __(&#039;Customer Connected&#039;, &#039;latepoint&#039;)));
      }
    }


    public function index(){

			$this-&gt;vars[&#039;page_header&#039;] = false;
      $page_number = isset($this-&gt;params[&#039;page_number&#039;]) ? $this-&gt;params[&#039;page_number&#039;] : 1;
      $per_page = OsSettingsHelper::get_number_of_records_per_page();
      $offset = ($page_number &gt; 1) ? (($page_number - 1) * $per_page) : 0;


      $customers = new OsCustomerModel();
      $query_args = [];

      $filter = isset($this-&gt;params[&#039;filter&#039;]) ? $this-&gt;params[&#039;filter&#039;] : false;

      // TABLE SEARCH FILTERS
      if($filter){
        if($filter[&#039;id&#039;]) $query_args[&#039;id&#039;] = $filter[&#039;id&#039;];
        if($filter[&#039;registration_date_from&#039;] &amp;&amp; $filter[&#039;registration_date_to&#039;]){
          $query_args[LATEPOINT_TABLE_CUSTOMERS.&#039;.created_at &gt;=&#039;] = $filter[&#039;registration_date_from&#039;];
          $query_args[LATEPOINT_TABLE_CUSTOMERS.&#039;.created_at &lt;=&#039;] = $filter[&#039;registration_date_to&#039;];
        }
        if($filter[&#039;customer&#039;]){
          $query_args[&#039;concat_ws(&quot; &quot;, &#039;.LATEPOINT_TABLE_CUSTOMERS.&#039;.first_name,&#039;.LATEPOINT_TABLE_CUSTOMERS.&#039;.last_name) LIKE&#039;] = &#039;%&#039;.$filter[&#039;customer&#039;].&#039;%&#039;;
          $this-&gt;vars[&#039;customer_name_query&#039;] = $filter[&#039;customer&#039;];
        }
        if($filter[&#039;phone&#039;]){
          $query_args[&#039;phone LIKE&#039;] = &#039;%&#039;.$filter[&#039;phone&#039;].&#039;%&#039;;
          $this-&gt;vars[&#039;phone_query&#039;] = $filter[&#039;phone&#039;];
        }
        if($filter[&#039;email&#039;]){
          $query_args[&#039;email LIKE&#039;] = &#039;%&#039;.$filter[&#039;email&#039;].&#039;%&#039;;
          $this-&gt;vars[&#039;email_query&#039;] = $filter[&#039;email&#039;];
        }
      }


      // OUTPUT CSV IF REQUESTED
      if(isset($this-&gt;params[&#039;download&#039;]) &amp;&amp; $this-&gt;params[&#039;download&#039;] == &#039;csv&#039;){
        $csv_filename = &#039;customers_&#039;.OsUtilHelper::random_text();
        
        header(&quot;Content-Type: text/csv&quot;);
        header(&quot;Content-Disposition: attachment; filename={$csv_filename}.csv&quot;);

        $labels_row = [ __(&#039;ID&#039;, &#039;latepoint&#039;),
                        __(&#039;Name&#039;, &#039;latepoint&#039;),
                        __(&#039;Phone&#039;, &#039;latepoint&#039;),
                        __(&#039;Email&#039;, &#039;latepoint&#039;),
                        __(&#039;Total Appointments&#039;, &#039;latepoint&#039;),
						__(&#039;Next Appointment&#039;, &#039;latepoint&#039;),
                        __(&#039;Registered On&#039;, &#039;latepoint&#039;) ];


        $customers_data = [];
        $customers_data[] = $labels_row;


        $customers_arr = $customers-&gt;where($query_args)-&gt;filter_allowed_records()-&gt;order_by(&#039;id desc&#039;)-&gt;get_results_as_models();
        if($customers_arr){
          foreach($customers_arr as $customer){
	        $next_booking = $customer-&gt;get_future_bookings(1, true);
            $values_row = [ $customer-&gt;id, 
                            $customer-&gt;full_name, 
                            $customer-&gt;phone, 
                            $customer-&gt;email, 
                            $customer-&gt;total_bookings_count,
	                        $next_booking ? $next_booking-&gt;nice_start_datetime : &#039;n/a&#039;,
                            $customer-&gt;formatted_created_date()];
            $values_row = apply_filters(&#039;latepoint_customer_row_for_csv_export&#039;, $values_row, $customer, $this-&gt;params);
            $customers_data[] = $values_row;
          }
        }
        $customers_data = apply_filters(&#039;latepoint_customers_data_for_csv_export&#039;, $customers_data, $this-&gt;params);
        OsCSVHelper::array_to_csv($customers_data);
        return;
      }

			$customers-&gt;where($query_args)-&gt;filter_allowed_records();
      $count_total_customers = clone $customers;

      $total_customers = $count_total_customers-&gt;count();
      $total_pages = ceil($total_customers / $per_page);

      $this-&gt;vars[&#039;customers&#039;] = $customers-&gt;set_limit($per_page)-&gt;set_offset($offset)-&gt;order_by(&#039;id desc&#039;)-&gt;get_results_as_models();
      $this-&gt;vars[&#039;total_customers&#039;] = $total_customers;

      $this-&gt;vars[&#039;total_pages&#039;] = ceil($total_customers / $per_page);
      $this-&gt;vars[&#039;per_page&#039;] = $per_page;
      $this-&gt;vars[&#039;current_page_number&#039;] = $page_number;
      
      $this-&gt;vars[&#039;showing_from&#039;] = (($page_number - 1) * $per_page) ? (($page_number - 1) * $per_page) : 1;
      $this-&gt;vars[&#039;showing_to&#039;] = min($page_number * $per_page, $this-&gt;vars[&#039;total_customers&#039;]);

      $this-&gt;format_render([&#039;json_view_name&#039; =&gt; &#039;_table_body&#039;, &#039;html_view_name&#039; =&gt; __FUNCTION__], [], [&#039;total_pages&#039; =&gt; $total_pages, &#039;showing_from&#039; =&gt; $this-&gt;vars[&#039;showing_from&#039;], &#039;showing_to&#039; =&gt; $this-&gt;vars[&#039;showing_to&#039;], &#039;total_records&#039; =&gt; $total_customers]);
    }


	  public function import_csv_modal(  ) {
		  $current_step = $this-&gt;params[&#039;step&#039;] ?? &#039;upload_csv&#039;;
		  $steps = [
			  &#039;upload_csv&#039; =&gt; [&#039;next_step&#039; =&gt; &#039;mapping&#039;],
			  &#039;mapping&#039; =&gt; [&#039;next_step&#039; =&gt; &#039;importing&#039;],
		  ];
		  $this-&gt;vars[&#039;current_step&#039;] = $current_step;
		  $this-&gt;vars[&#039;next_step&#039;] = array_key_exists($current_step, $steps) ? $steps[$current_step][&#039;next_step&#039;] : &#039;upload_csv&#039;;
		  $this-&gt;format_render( __FUNCTION__ );
	}

	public function import_load_step() {
		$this-&gt;check_nonce( &#039;import_customers_csv&#039; );
		$current_step = $this-&gt;params[&#039;step&#039;] ?? &#039;upload_csv&#039;;
		$status = LATEPOINT_STATUS_SUCCESS;

		try {
			switch ($current_step) {
				case &#039;upload_csv&#039;:
					$response_html = $this-&gt;_handle_upload_step();
					break;

				case &#039;mapping&#039;:
					$response_html = $this-&gt;_handle_mapping_step();
					break;

				case &#039;confirmation&#039;:
					$response_html = $this-&gt;_handleConfirmationStep();
					break;

				default:
					throw new Exception(&#039;Invalid step provided&#039;);
			}
		} catch (Exception $e) {
			$response_html = $e-&gt;getMessage();
			$status = LATEPOINT_STATUS_ERROR;
		}

		$this-&gt;send_json(array(&#039;status&#039; =&gt; $status, &#039;message&#039; =&gt; $response_html));
	}

	  private function _handle_upload_step(): string {
		  $file_path = OsCSVHelper::upload_csv_file( $this-&gt;files, &#039;latepoint_customers_csv&#039; );
		  $csv_data  = OsCSVHelper::get_csv_data( $file_path, 1 );

		  return $this-&gt;render( $this-&gt;views_folder . &#039;import_steps/step_mapping.php&#039;, &#039;none&#039;, [
			  &#039;csv_data&#039; =&gt; $csv_data,
		  ] );
	  }

	  private function _handle_mapping_step(): string {
		  $columnMapping = $this-&gt;params[&#039;latepoint_column_mapping&#039;] ?? [];

		  if (!OsCustomerImportHelper::validate_import_mapping($columnMapping)) {
			  throw new Exception(esc_html__(&#039;Email field is required&#039;, &#039;latepoint&#039;));
		  }

		  $csv_data = OsCSVHelper::get_csv_data(OsCustomerImportHelper::get_import_tmp_filepath());
		  $validation_result = OsCustomerImportHelper::validate_csv_data($csv_data, $columnMapping);

		  return $this-&gt;render($this-&gt;views_folder . &#039;import_steps/step_confirmation.php&#039;, &#039;none&#039;, [
			  &#039;conflicts&#039; =&gt; $validation_result[&#039;conflicts&#039;],
			  &#039;can_be_imported&#039; =&gt; $validation_result[&#039;importable_count&#039;],
			  &#039;latepoint_column_mapping&#039; =&gt; $columnMapping
		  ]);
	  }


	  private function _handleConfirmationStep(): string {
		  $update_existing_customers = !empty($this-&gt;params[&#039;latepoint_update_customers_acknowledgement&#039;]) &amp;&amp; OsUtilHelper::is_on($this-&gt;params[&#039;latepoint_update_customers_acknowledgement&#039;]);
		  $column_mapping = !empty($this-&gt;params[&#039;latepoint_column_mapping&#039;]) ? json_decode($this-&gt;params[&#039;latepoint_column_mapping&#039;], true) : [];

		  $file_path = OsCustomerImportHelper::get_import_tmp_filepath();
		  $csv_data = OsCSVHelper::get_csv_data($file_path);

		  $importResult = OsCustomerImportHelper::import_customers( $csv_data, $column_mapping, $update_existing_customers );

		  // Cleanup after successful import
		  OsCustomerImportHelper::cleanup_stored_file();

		  return $this-&gt;render($this-&gt;views_folder . &#039;import_steps/step_done.php&#039;, &#039;none&#039;, [
			  &#039;skipped_records&#039; =&gt; $importResult[&#039;skipped_count&#039;],
			  &#039;updated_records&#039; =&gt; $importResult[&#039;updated_count&#039;],
		  ]);
	  }


  }


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