<?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');

    }
}