22

✏️ Editing: class-wpml-tm-jobs-repository.php

<?php

use \WPML\TM\Jobs\Query\Query;
use WPML\FP\Fns;

class WPML_TM_Jobs_Repository {
	/** @var wpdb */
	private $wpdb;

/** @var Query */
	private $query_builder;

/** @var WPML_TM_Job_Elements_Repository */
	private $elements_repository;

/**
	 * @param wpdb                            $wpdb
	 * @param Query              $query_builder
	 * @param WPML_TM_Job_Elements_Repository $elements_repository
	 */
	public function __construct(
		wpdb $wpdb,
		Query $query_builder,
		WPML_TM_Job_Elements_Repository $elements_repository
	) {
		$this->wpdb                = $wpdb;
		$this->query_builder       = $query_builder;
		$this->elements_repository = $elements_repository;
	}

/**
	 * @param WPML_TM_Jobs_Search_Params $params
	 *
	 * @return WPML_TM_Jobs_Collection|array
	 */
	public function get( WPML_TM_Jobs_Search_Params $params ) {
		if ( $params->get_columns_to_select() ) {
			return $this->wpdb->get_results( $this->query_builder->get_data_query( $params ) );
		}

$results = $this->wpdb->get_results( $this->query_builder->get_data_query( $params ) );
		return is_array( $results )
			? new WPML_TM_Jobs_Collection( array_map(
				array( $this, 'build_job_entity' ),
				$results
			  ) )
			: new WPML_TM_Jobs_Collection( [] );
	}

/**
	 * @param WPML_TM_Jobs_Search_Params $params
	 *
	 * @throws \InvalidArgumentException When get_columns_to_select() is used. In that case use get().
	 *
	 * @return WPML_TM_Jobs_Collection
	 */
	public function get_collection( WPML_TM_Jobs_Search_Params $params ) {
		if ( $params->get_columns_to_select() ) {
			throw new \InvalidArgumentException( 'Not valid with get_columns_to_select().' );
		}

return $this->get( $params );
	}

/**
	 * @param array $ateJobIds
	 *
	 * @return bool
	 */
	public function increment_ate_sync_count( array $ateJobIds ) {
		if ( empty( $ateJobIds ) ) {
			return true;
		} else {
			$query = sprintf(
				'UPDATE %sicl_translate_job SET ate_sync_count=ate_sync_count+1 WHERE editor_job_id IN( %s )',
				$this->wpdb->prefix,
				wpml_prepare_in( $ateJobIds )
			);

return (bool) $this->wpdb->query( $query );
		}
	}

/**
	 * @param WPML_TM_Jobs_Search_Params $params
	 *
	 * @return int
	 */
	public function get_count( WPML_TM_Jobs_Search_Params $params ) {
		return (int) $this->wpdb->get_var( $this->query_builder->get_count_query( $params ) );
	}

/**
	 * @param int    $local_job_id
	 * @param string $job_type
	 *
	 * @throws InvalidArgumentException
	 * @return WPML_TM_Job_Entity|false
	 */
	public function get_job( $local_job_id, $job_type ) {
		$params = new WPML_TM_Jobs_Search_Params();
		$params->set_local_job_id( $local_job_id );
		$params->set_job_types( $job_type );

$data = $this->wpdb->get_row( $this->query_builder->get_data_query( $params ) );
		if ( is_object( $data )  ) {
			$data = $this->build_job_entity( $data );
		}

return $data;
	}

/**
	 * @param object $raw_data
	 *
	 * @return WPML_TM_Job_Entity
	 */
	private function build_job_entity( $raw_data ) {
		$types = [ WPML_TM_Job_Entity::POST_TYPE, WPML_TM_Job_Entity::PACKAGE_TYPE, WPML_TM_Job_Entity::STRING_BATCH ];
		$batch = new WPML_TM_Jobs_Batch( $raw_data->local_batch_id, $raw_data->batch_name, $raw_data->tp_batch_id );

if ( in_array( $raw_data->type, $types, true ) ) {
			$job = new WPML_TM_Post_Job_Entity(
				$raw_data->id,
				$raw_data->type,
				$raw_data->tp_id,
				$batch,
				(int) $raw_data->status,
				array( $this->elements_repository, 'get_job_elements' )
			);
			$job->set_translate_job_id( $raw_data->translate_job_id );
			$job->set_editor( $raw_data->editor );
			$job->set_completed_date( $raw_data->completed_date ? new DateTime( $raw_data->completed_date ) : null );
			$job->set_editor_job_id( $raw_data->editor_job_id );
			$job->set_automatic( $raw_data->automatic );
			$job->set_review_status( $raw_data->review_status );
			$job->set_trid( $raw_data->trid );
			$job->set_element_type( $raw_data->element_type );
			$job->set_element_id( $raw_data->element_id );
			$job->set_element_type_prefix( $raw_data->element_type );
			$job->set_job_title( $raw_data->job_title );

} else {
			$job = new WPML_TM_Job_Entity(
				$raw_data->id,
				$raw_data->type,
				$raw_data->tp_id,
				$batch,
				(int) $raw_data->status
			);
		}

$job->set_original_element_id( $raw_data->original_element_id );

$job->set_source_language( $raw_data->source_language );
		$job->set_target_language( $raw_data->target_language );
		$job->set_translation_service( $raw_data->translation_service );
		$job->set_sent_date( new DateTime( $raw_data->sent_date ) );
		$job->set_deadline( $this->get_deadline( $raw_data ) );
		$job->set_translator_id( $raw_data->translator_id );
		$job->set_revision( $raw_data->revision );
		$job->set_ts_status( $raw_data->ts_status );
		$job->set_needs_update( $raw_data->needs_update );
		$job->set_has_completed_translation( $raw_data->has_completed_translation );
		$job->set_title( $raw_data->title );

return $job;
	}

/**
	 * @param object $raw_data
	 *
	 * @return DateTime|null
	 */
	private function get_deadline( $raw_data ) {
		if ( $raw_data->deadline_date && '0000-00-00 00:00:00' !== $raw_data->deadline_date ) {
			return new DateTime( $raw_data->deadline_date );
		}

return null;
	}
}

MR SKB