Administrator / test_1

  <?php

  namespace console\controllers;
  

  use yii\console\Controller;

  use yii\helpers\Console;
  use common\components\PriceWriter;
  use backend\models\ImportersFiles;

  use backend\models\Importers;
  use yii\base\ErrorException;

  
  class ParserController extends Controller{

  
      public function actionParseCsv ()

      {

          \Yii::info('Начало загрузки файлов прайсов csv','parser');

          foreach (glob( \Yii::getAlias('@auto_upload') . '/*.csv' ) as $file_path) {

              $file_name = basename( $file_path,".csv" );
              \Yii::info("Обработка файла - $file_path",'parser');
              $importer_id = ImportersFiles::findOne(['id' => $file_name])->importer_id;
              $keys = Importers::findOne( ['id' => $importer_id] )->keys;

              $config = ['record_id' => $file_name,
                  'importer_id' => $importer_id,
                  'parser_config' => ['keys' => $keys,
                      'mode' => 'console']
              ];
              if( $this->parseFileConsole( $file_path, $config ) ){
                  unlink( \Yii::getAlias('@temp_upload') . '/' . $file_name . '.csv' );
                  \Yii::info("Загрузка файла - $file_path успешно завершена",'parser');
              } else{
                  \Yii::error( "Загрузка файла - $file_path завершена с ошибкой", 'parser' );
              }
                  //при любом завершении скрипта файл с очереди автозагрузки нужно удалить
              unlink( \Yii::getAlias('@auto_upload') . '/' . $file_name . '.csv' );
          }

      }

      protected function parseFileConsole( $file_path, $configuration ){

  
          if( !file_exists( $file_path ) )

              throw new ErrorException("$file_path - файл не найден!");

          $parser_config = [];
          if ( isset( $configuration['parser_config'] ) ) {
              $parser_config = $configuration['parser_config'];
          }

          $data = \Yii::$app->multiparser->parse( $file_path, $parser_config );

          if (! $data) {
              // @todo переделать, что бы ошибка автоматически останавливала сценарий
              return false;
          }

          $writer = new PriceWriter();
          $writer->configuration = $configuration;
          $writer->data = $data;
          $writer->mode = 1; //console-режим

          if ( $writer->writeDataToDB() ){

              return true;
          }

          return false;

      }

      public function actionParseXml ()
      {

          \Yii::info('Начало загрузки файлов прайсов xml','parser');
          foreach (glob( \Yii::getAlias('@auto_upload') . '/*.xml' ) as $file_path) {
              $file_name = basename( $file_path,".xml" );
              \Yii::info("Обработка файла - $file_path",'parser');

              $config = ['record_id' => $file_name,
                  'importer_id' => 1,
                  'parser_config' => [
                      'mode' => 'console']
              ];
              if( $this->parseFileConsole( $file_path, $config ) ){
                  unlink( \Yii::getAlias('@auto_upload') . '/' . $file_name . '.xml' );
                  \Yii::info("Загрузка файла - $file_path успешно завершена",'parser');
              } else{
                  \Yii::error( "Загрузка файла - $file_path завершена с ошибкой", 'parser' );
              }
          }

      }
  

      public function actionTest ()
      {

          Console::output('It is working ');
         \Yii::info('2','parser');

  
      }

  }