common/components/PriceWriter.php

<?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 {
    public $mode;
    public $configuration;
    public $data;
    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->multiparser->convertToFloat($row['PRICE']);
                $row['BOX'] = \Yii::$app->multiparser->convertToInteger($row['BOX']);
                // присвоим полный артикул
                $row['FULL_ARTICLE'] = $row['ARTICLE'];
                if(isset($row['ADD_BOX']))
                    $row['ADD_BOX'] = \Yii::$app->multiparser->convertToInteger($row['ADD_BOX']);
                // проверим все ли обязательные колонки были указаны пользователем
                $details_model->load(['Details' => $row]);
                if (!$details_model->validate())
                    //@todo предоставить более детальную информацию об ошибке
                    throw new \ErrorException('Ошибка записи товаров');
            }
        }
            // дополним данные значением импортера и даты обновления цены
            $this->data = \Yii::$app->multiparser->addColumns($this->data, ['IMPORT_ID' => $this->configuration['importer_id'], 'timestamp' => $update_date]);
            try {
                //@todo add transaction
                // попытаемся вставить данные в БД с апдейтом по ключам
                $details_model->ManualInsert($this->data);
                // 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;
    }
}