Обновить 'src/lib/Agents.php'

fix import statement in Ipol\DPD\Agents

src/lib/Agents.php

@@ -1,181 +1,181 @@
-<?php
-namespace Ipol\DPD;
-
-use \Ipol\DPD\API\User as API;
-use \Ipol\DPD\Config\ConfigInterface;
-
-/**
- * Класс содержит набор готовых методов реализующих выполнение периодических
- * заданий
- */
-class Agents
-{
-	/**
-	 * Обновляет статусы заказов
-	 * 
-	 * Обновление статусов происходит в 2 этапа.
-	 * На первом этапе обрабатываются заказы, которые создались в статусе "Ожидают проверки менеджером DPD"
-	 * На втором этапе обрабатываются остальные заказы. Для получения изменений по статусам используется 
-	 * метод getStatesByClient
-	 * 
-	 * @param \Ipol\DPD\Config\ConfigInterface $config
-	 * 
-	 * @return void
-	 */
-	public static function checkOrderStatus(ConfigInterface $config)
-	{
-		self::checkPindingOrderStatus($config);
-		self::checkTrakingOrderStatus($config);
-	}
-
-	/**
-	 * Проверяет статусы заказов ожидающих проверки
-	 * 
-	 * @return void
-	 */
-	protected static function checkPindingOrderStatus(ConfigInterface $config)
-	{
-		$table  = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('order');
-		$orders = $table->find([
-			'where' => 'ORDER_STATUS = :order_status',
-			'order' => 'ORDER_DATE_STATUS ASC, ORDER_DATE_CREATE ASC',
-			'limit' => '0,2',
-			'bind'  => [
-				':order_status' => \Ipol\DPD\Order::STATUS_PENDING
-			]
-		])->fetchAll(PDO::FETCH_CLASS|PDO::FETCH_PROPS_LATE, $table->getModelClass(), $table);
-		
-		foreach ($orders as $order) {
-			$order->dpd()->checkStatus();
-		}
-	}
-
-	/**
-	 * Проверяет статусы заказов прошедшие проверку
-	 * 
-	 * @return void
-	 */
-	protected static function checkTrakingOrderStatus(ConfigInterface $config)
-	{
-		if (!$config->get('STATUS_ORDER_CHECK')) {
-			return;
-		}
-
-		do {
-			$ret = API::getInstanceByConfig($config)->getService('tracking')->getStatesByClient();
-			if (!$ret) {
-				return;
-			}
-
-			$states = (array) $ret['STATES'];
-			$states = array_key_exists('DPD_ORDER_NR', $states) ? array($states) : $states;
-
-			// сортируем статусы по их времени наступления
-			uasort($states, function($a, $b) {
-				if ($a['CLIENT_ORDER_NR'] == $b['CLIENT_ORDER_NR']) {
-					$time1 = strtotime($a['TRANSITION_TIME']);
-					$time2 = strtotime($b['TRANSITION_TIME']);
-
-					return $time1 - $time2;
-				}
-
-				return $a['CLIENT_ORDER_NR'] - $b['CLIENT_ORDER_NR'];
-			});
-
-			foreach ($states as $state) {
-				$order = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('order')->getByOrderId($state['CLIENT_ORDER_NR']);
-				if (!$order) {
-					continue;
-				}
-
-				$status = $state['NEW_STATE'];
-				
-				if ($order->isSelfDelivery()
-					&& $status == \Ipol\DPD\Order::STATUS_TRANSIT_TERMINAL
-					&& $order->receiverTerminalCode == $state['TERMINAL_CODE']
-				) {
-					$status = \Ipol\DPD\Order::STATUS_ARRIVE;
-				}
-
-				$order->setOrderStatus($status, $statusTime);
-				$order->orderNum = $state['DPD_ORDER_NR'] ?: $order->orderNum;
-				$order->save();
-			}
-
-			if ($ret['DOC_ID'] > 0) {
-				API::getInstanceByConfig($config)->getService('tracking')->confirm($ret['DOC_ID']);
-			}
-		} while($ret['RESULT_COMPLETE'] != 1);
-	}
-
-	/**
-	 * Загружает в локальную БД данные о местоположениях и терминалах
-	 * 
-	 * @param \Ipol\DPD\Config\ConfigInterface $config
-	 * 
-	 * @return string
-	 */
-	public static function loadExternalData(ConfigInterface $config)
-	{
-		$api = API::getInstanceByConfig($config);
-
-		$locationTable  = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('location');
-		$terminalTable  = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('terminal');
-
-		$locationLoader = new \Ipol\DPD\DB\Location\Agent($api, $locationTable);
-		$terminalLoader = new \Ipol\DPD\DB\Terminal\Agent($api, $terminalTable);
-
-		$currStep = $config->get('LOAD_EXTERNAL_DATA_STEP');
-		$position = $config->get('LOAD_EXTERNAL_DATA_POSITION');
-
-		switch ($currStep) {
-			case 'LOAD_LOCATION_ALL':
-				$ret      = $locationLoader->loadAll($position);
-				$currStep = 'LOAD_LOCATION_ALL';
-				$nextStep = 'LOAD_LOCATION_CASH_PAY';
-
-				if ($ret !== true) {
-					break;
-				}
-
-			case 'LOAD_LOCATION_CASH_PAY':
-				$ret      = $locationLoader->loadCashPay($position);
-				$currStep = 'LOAD_LOCATION_CASH_PAY';
-				$nextStep = 'LOAD_TERMINAL_UNLIMITED';
-
-				if ($ret !== true) {
-					break;
-				}
-
-			case 'LOAD_TERMINAL_UNLIMITED':
-				$ret      = $terminalLoader->loadUnlimited($position);
-				$currStep = 'LOAD_TERMINAL_UNLIMITED';
-				$nextStep = 'LOAD_TERMINAL_LIMITED';
-
-				if ($ret !== true) {
-					break;
-				}
-
-			case 'LOAD_TERMINAL_LIMITED':
-				$ret      = $terminalLoader->loadLimited($position);
-				$currStep = 'LOAD_TERMINAL_LIMITED';
-				$nextStep = 'LOAD_FINISH';
-
-				if ($ret !== true) {
-					break;
-				}
-			
-			default:
-				$ret      = true;
-				$currStep = 'LOAD_FINISH';
-				$nextStep = 'LOAD_LOCATION_ALL';
-			break;
-		}
-
-		$nextStep = is_bool($ret) ? $nextStep : $currStep;
-		$position = is_bool($ret) ? ''        : $ret;
-
-		$config->set('LOAD_EXTERNAL_DATA_STEP', $nextStep);
-		$config->set('LOAD_EXTERNAL_DATA_POSITION', $position);
-	}
+<?php
+namespace Ipol\DPD;
+
+use \Ipol\DPD\API\User\User as API;
+use \Ipol\DPD\Config\ConfigInterface;
+
+/**
+ * Класс содержит набор готовых методов реализующих выполнение периодических
+ * заданий
+ */
+class Agents
+{
+	/**
+	 * Обновляет статусы заказов
+	 * 
+	 * Обновление статусов происходит в 2 этапа.
+	 * На первом этапе обрабатываются заказы, которые создались в статусе "Ожидают проверки менеджером DPD"
+	 * На втором этапе обрабатываются остальные заказы. Для получения изменений по статусам используется 
+	 * метод getStatesByClient
+	 * 
+	 * @param \Ipol\DPD\Config\ConfigInterface $config
+	 * 
+	 * @return void
+	 */
+	public static function checkOrderStatus(ConfigInterface $config)
+	{
+		self::checkPindingOrderStatus($config);
+		self::checkTrakingOrderStatus($config);
+	}
+
+	/**
+	 * Проверяет статусы заказов ожидающих проверки
+	 * 
+	 * @return void
+	 */
+	protected static function checkPindingOrderStatus(ConfigInterface $config)
+	{
+		$table  = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('order');
+		$orders = $table->find([
+			'where' => 'ORDER_STATUS = :order_status',
+			'order' => 'ORDER_DATE_STATUS ASC, ORDER_DATE_CREATE ASC',
+			'limit' => '0,2',
+			'bind'  => [
+				':order_status' => \Ipol\DPD\Order::STATUS_PENDING
+			]
+		])->fetchAll(PDO::FETCH_CLASS|PDO::FETCH_PROPS_LATE, $table->getModelClass(), $table);
+		
+		foreach ($orders as $order) {
+			$order->dpd()->checkStatus();
+		}
+	}
+
+	/**
+	 * Проверяет статусы заказов прошедшие проверку
+	 * 
+	 * @return void
+	 */
+	protected static function checkTrakingOrderStatus(ConfigInterface $config)
+	{
+		if (!$config->get('STATUS_ORDER_CHECK')) {
+			return;
+		}
+
+		do {
+			$ret = API::getInstanceByConfig($config)->getService('tracking')->getStatesByClient();
+			if (!$ret) {
+				return;
+			}
+
+			$states = (array) $ret['STATES'];
+			$states = array_key_exists('DPD_ORDER_NR', $states) ? array($states) : $states;
+
+			// сортируем статусы по их времени наступления
+			uasort($states, function($a, $b) {
+				if ($a['CLIENT_ORDER_NR'] == $b['CLIENT_ORDER_NR']) {
+					$time1 = strtotime($a['TRANSITION_TIME']);
+					$time2 = strtotime($b['TRANSITION_TIME']);
+
+					return $time1 - $time2;
+				}
+
+				return $a['CLIENT_ORDER_NR'] - $b['CLIENT_ORDER_NR'];
+			});
+
+			foreach ($states as $state) {
+				$order = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('order')->getByOrderId($state['CLIENT_ORDER_NR']);
+				if (!$order) {
+					continue;
+				}
+
+				$status = $state['NEW_STATE'];
+				
+				if ($order->isSelfDelivery()
+					&& $status == \Ipol\DPD\Order::STATUS_TRANSIT_TERMINAL
+					&& $order->receiverTerminalCode == $state['TERMINAL_CODE']
+				) {
+					$status = \Ipol\DPD\Order::STATUS_ARRIVE;
+				}
+
+				$order->setOrderStatus($status, $statusTime);
+				$order->orderNum = $state['DPD_ORDER_NR'] ?: $order->orderNum;
+				$order->save();
+			}
+
+			if ($ret['DOC_ID'] > 0) {
+				API::getInstanceByConfig($config)->getService('tracking')->confirm($ret['DOC_ID']);
+			}
+		} while($ret['RESULT_COMPLETE'] != 1);
+	}
+
+	/**
+	 * Загружает в локальную БД данные о местоположениях и терминалах
+	 * 
+	 * @param \Ipol\DPD\Config\ConfigInterface $config
+	 * 
+	 * @return string
+	 */
+	public static function loadExternalData(ConfigInterface $config)
+	{
+		$api = API::getInstanceByConfig($config);
+
+		$locationTable  = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('location');
+		$terminalTable  = \Ipol\DPD\DB\Connection::getInstance($config)->getTable('terminal');
+
+		$locationLoader = new \Ipol\DPD\DB\Location\Agent($api, $locationTable);
+		$terminalLoader = new \Ipol\DPD\DB\Terminal\Agent($api, $terminalTable);
+
+		$currStep = $config->get('LOAD_EXTERNAL_DATA_STEP');
+		$position = $config->get('LOAD_EXTERNAL_DATA_POSITION');
+
+		switch ($currStep) {
+			case 'LOAD_LOCATION_ALL':
+				$ret      = $locationLoader->loadAll($position);
+				$currStep = 'LOAD_LOCATION_ALL';
+				$nextStep = 'LOAD_LOCATION_CASH_PAY';
+
+				if ($ret !== true) {
+					break;
+				}
+
+			case 'LOAD_LOCATION_CASH_PAY':
+				$ret      = $locationLoader->loadCashPay($position);
+				$currStep = 'LOAD_LOCATION_CASH_PAY';
+				$nextStep = 'LOAD_TERMINAL_UNLIMITED';
+
+				if ($ret !== true) {
+					break;
+				}
+
+			case 'LOAD_TERMINAL_UNLIMITED':
+				$ret      = $terminalLoader->loadUnlimited($position);
+				$currStep = 'LOAD_TERMINAL_UNLIMITED';
+				$nextStep = 'LOAD_TERMINAL_LIMITED';
+
+				if ($ret !== true) {
+					break;
+				}
+
+			case 'LOAD_TERMINAL_LIMITED':
+				$ret      = $terminalLoader->loadLimited($position);
+				$currStep = 'LOAD_TERMINAL_LIMITED';
+				$nextStep = 'LOAD_FINISH';
+
+				if ($ret !== true) {
+					break;
+				}
+			
+			default:
+				$ret      = true;
+				$currStep = 'LOAD_FINISH';
+				$nextStep = 'LOAD_LOCATION_ALL';
+			break;
+		}
+
+		$nextStep = is_bool($ret) ? $nextStep : $currStep;
+		$position = is_bool($ret) ? ''        : $ret;
+
+		$config->set('LOAD_EXTERNAL_DATA_STEP', $nextStep);
+		$config->set('LOAD_EXTERNAL_DATA_POSITION', $position);
+	}
 }