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 - консольный
       */

      protected $mode;

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

      protected $configuration;

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

      protected $data;

      function __construct()
      {
          set_time_limit(300);
      }
  

      /**
       * @param mixed $mode
       */
      public function setMode($mode)
      {
          $this->mode = $mode;
      }
  
      /**
       * @param mixed $configuration
       */
      public function setConfiguration($configuration)
      {
          $this->configuration = $configuration;
      }
  
      /**
       * @param mixed $data
       */
      public function setData($data)
      {
          $this->data = $data;
      }
  
  
  
      public function writePriceToDB()

      {
          // 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) {

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

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

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

                  if (isset($row['ARTICLE'])) {

  
                      $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 {
                          if (isset($row['ARTICLE']))
                              $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())

                      $details_model->throwStringErrorException(key($this->data));

  
              }

          }

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

          $this->data = CustomArrayHelper::addColumns($this->data, ['IMPORT_ID' => $this->configuration['importer_id'], 'timestamp' => $update_date]);
          $transaction = \Yii::$app->db->beginTransaction();

          try {

              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()) {

                  $transaction->rollBack();

                  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()) {

                  $transaction->rollBack();

                  $imp_model->throwStringErrorException();;

              }

              $transaction->commit();
  

          } catch (ErrorException  $e) {

              $transaction->rollBack();

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

  
  
          return true;
      }

      public function deletePriceFromDB()
      {
  
          $importer_id = '';
          $update_date = '';
  
          if (isset($this->configuration['importer_id']))
              $importer_id = $this->configuration['importer_id'];
  
          if (isset($this->configuration['update_date']))
              $update_date = $this->configuration['update_date'];
  
          if (!$importer_id) {
              throw new \ErrorException('Не указан поставщик прайса для удаления');
          } elseif (!$update_date) {
              throw new \ErrorException('Не указана дата загрузки прайса для удаления');
          }
  
          $transaction = \Yii::$app->db->beginTransaction();
          try {
              // 1. удалим из таблицы файлов поставщика (ImportersFiles)
  
              $rows = ImportersFiles::deleteAll(['importer_id' => $importer_id, 'upload_time' => $update_date]);
              if ($rows != 1) {
                  $transaction->rollBack();
                  throw new \ErrorException('Ошибка удаления из таблицы фалов поставщиков');
              }
  
              $last_upload_time = ImportersFiles::find(['importer_id' => $importer_id])->orderBy(['upload_time' => SORT_DESC])->one()->upload_time;
  
                  // 2. удалим прайс из таблицы товаров (Details)
          $details_model = new Details();
              $conditions = "importer_id = {$importer_id} AND upload_time = {$update_date}";
              $details_model->manualDelete($conditions);
  
              // 3. откатимся до старой даты загрузки в таблице поставщиков
              $imp_model = Importers::findOne( $importer_id );
              $imp_model->price_date_update = $last_upload_time;
  
              if (!$imp_model->save()) {
                  $transaction->rollBack();
                  $imp_model->throwStringErrorException();
              }
  
              $transaction->commit();
          } catch (ErrorException  $e) {
              $transaction->rollBack();
              throw new \ErrorException($e->getMessage());
          }
      }

  }