Administrator / test_1

  <?php
  /**
   * Created by PhpStorm.
   * User: Cibermag
   * Date: 30.09.2015
   * Time: 9:34
   */
  
  namespace common\components;
  
  
  use yii\base\ErrorException;
  use backend\models\ImportersFiles;
  use backend\models\Importers;
  use backend\models\Details;
  

  /**
   * Class PriceWriter
   * @package common\components
   * записывает в БД отпарсенные данные
   * запись происходит в несколько таблиц
   */
  class PriceWriter
  {
      /**
       * @var - int - 0 - интерактивный режим, 1 - консольный
       */

      public $mode;

  
      /**
       * @var - массив с настройками записи
       */

      public $configuration;

  
      /**
       * @var - массив с данными которые нужно записать
       */

      public $data;

      function __construct()
      {
          set_time_limit(300);
      }
  
      public function writeDataToDB()

      {
          // 1. запишем дату старта в таблицу файлов поставщика (ImportersFiles)
          // id  загруженного файла получим из конфигурации

          $files_model = ImportersFiles::findOne($this->configuration['record_id']);

          $update_date = date('Y-m-d H:i:s');
          $files_model->time_start = $update_date;
          // запишем дату начала загрузки
          if (!$files_model->save()) {

              throw new \ErrorException(implode(', ', $files_model->getErrors()));

          }
  

          // 2. запишем полученные данные в таблицу товаров (Details)
          $details_model = new Details();

          // только для ручной загрузки, в авто режиме все делает конвертер при первом же проходе (в процессе парсинга)

          if ($this->mode == 0) {

              // преобразуем числовые значения
              foreach ($this->data as &$row) {

                  $row['PRICE'] = \Yii::$app->converter->convertTo('float',$row['PRICE']);
                  $row['BOX'] = \Yii::$app->converter->convertTo('integer',$row['BOX']);

                  // присвоим полный артикул

                  $row['FULL_ARTICLE'] = $row['ARTICLE'];

                  if ((int)$this->configuration['delete_prefix']) {

                      $row = \Yii::$app->converter->convertTo( 'Article', $row, ['importer_id' => $this->configuration['importer_id']] );

                  } else {

                      $row['ARTICLE'] = \Yii::$app->converter->convertTo( 'Article', $row['ARTICLE'] );

                  }
  
  

                  if (isset($row['ADD_BOX']))

                      $row['ADD_BOX'] = \Yii::$app->converter->convertTo( 'integer', $row['ADD_BOX'] );

  
                  // проверим все ли обязательные колонки были указаны пользователем
                  $details_model->load(['Details' => $row]);

                  if (!$details_model->validate())
                      //@todo предоставить более детальную информацию об ошибке
                      throw new \ErrorException('Ошибка записи товаров');
  
              }

          }

          // дополним данные значением импортера и даты обновления цены

          $this->data = CustomArrayHelper::addColumns( $this->data, ['IMPORT_ID' => $this->configuration['importer_id'], 'timestamp' => $update_date] );

          try {
              //@todo add transaction

              if ( isset($this->configuration['delete_price']) && (int)$this->configuration['delete_price'] ) {

                  $details_model->delete_price = true;
              }
              //2. попытаемся вставить данные в БД с апдейтом по ключам
              $details_model->ManualInsert($this->data, $this->configuration['importer_id']);

              // 3. зафиксируем дату конца загрузки в файлах поставщика
              if (!$files_model->save()) {
                  throw new \ErrorException(implode(', ', $files_model->getErrors()));
              }

              // 4. зафиксируем дату загрузки в таблице поставщиков
              $imp_model = Importers::findOne($this->configuration['importer_id']);
              $imp_model->price_date_update = $update_date;

              if (!$imp_model->save()) {
                  throw new \ErrorException(implode(', ', $imp_model->getErrors()));

              }

          } catch (ErrorException  $e) {
              throw new \ErrorException($e->getMessage());
          }

  
  
          return true;
      }

  }