backend/models/Details.php

<?php
namespace backend\models;
use common\components\CustomVarDamp;
use Yii;
use backend\components\base\BaseActiveRecord;
/**
 * This is the model class for table "{{%details}}".
 *
 * @property string $ID
 * @property string $IMPORT_ID
 * @property string $BRAND
 * @property string $ARTICLE
 * @property string $FULL_ARTICLE
 * @property double $PRICE
 * @property string $DESCR
 * @property string $BOX
 * @property string $ADD_BOX
 * @property string $GROUP
 * @property string $timestamp
 *
 *
 */
class Details extends BaseActiveRecord
{
    /**
     *обязательные колонки
     */
    const KEY_COLUMN = 'IMPORT_ID~~BRAND~~ARTICLE';
    /**
     * int - размер пакета запроса
     */
    const BATCH = 500;
    /**
     * @var bool - признак необходимости удалить префикс Артикула перед вставкой
     */
    public $delete_price = false;
    /**
     * @inheritdoc
     */
    public static function tableName()
    {
        return '{{%details}}';
    }
    /**
     * @inheritdoc
     */
    public function rules()
    {
        return [
            [['BRAND', 'ARTICLE', 'PRICE', 'DESCR', 'BOX'], 'required'],
            [['PRICE'], 'number'],
            [['BOX'], 'integer'],
            [['timestamp'], 'safe'],
            [['BRAND', 'ARTICLE'], 'string', 'max' => 100],
            [['FULL_ARTICLE'], 'string', 'max' => 150],
            [['DESCR', 'GROUP'], 'string', 'max' => 200]
        ];
    }
    /**
     * @inheritdoc
     */
    public function attributeLabels()
    {
        return [
            'ID' => Yii::t('app', 'ID'),
            'IMPORT_ID' => Yii::t('app', 'Import  ID'),
            'BRAND' => Yii::t('app', 'Brand'),
            'ARTICLE' => Yii::t('app', 'Article'),
            'FULL_ARTICLE' => Yii::t('app', 'Full  Article'),
            'PRICE' => Yii::t('app', 'Price'),
            'DESCR' => Yii::t('app', 'Descr'),
            'BOX' => Yii::t('app', 'Box'),
            'ADD_BOX' => Yii::t('app', 'Add  Box'),
            'GROUP' => Yii::t('app', 'Group'),
            'timestamp' => Yii::t('app', 'Timestamp'),
        ];
    }
    /**
     *удаление (если $delete_price установлен)б а затем вставка данных с апдейтом прямымыми запросоми SQL
     * @param $data - массив вставляемых данных, вставка будет прозводится пакетами размером указанным в константе BATCH
     * @param $importer_id - (int) - идентификатор поставщика у которого будет сперва удалены прайсы а потом вставлены из массива $data
     * @throws \yii\db\Exception
     */
    public function  manualInsert($data, $importer_id)
    {
        if ($this->delete_price) {
            // запустим пакетное удаление всех прайсов поставщика
            $conditions = "IMPORT_ID = {$importer_id}";
            $this->manualDelete( $conditions );
        }
        $this->manualInsertWithUpdate($data);
    }
    /**
     * вставка данных с апдейтом прямым запросом SQL
     * @param $data - массив вставляемых данный, вставка будет прозводится пакетами размером указанным в константе BATCH
     * @throws \yii\db\Exception
     */
    private function manualInsertWithUpdate($data)
    {
        $table_name = self::tableName();
        $keys_arr = array_keys($data[0]);
        // найдем те поля которые не являются ключами. Их нужно будет при дубляже апдейтить
        $fields_arr_to_update = array_diff($keys_arr, explode('~~', $this::KEY_COLUMN ));
        $query_update = ' on duplicate key update ';
        foreach ($fields_arr_to_update as $field) {
            $query_update .= "[[{$field}]] = values([[{$field}]]),";
        }
        // удалим последнюю запятую
        $query_update = substr($query_update, 0, strlen($query_update) - 1);
        // запросы будем выполнять пакетами
        // размер пакета установлен в константе
        // разобъем массив на пакеты и будем их проходить
        $data = array_chunk($data, $this::BATCH);
        foreach ($data as $current_batch_array) {
            //воспользуемся пакетной вставкой от фреймворка
            $query_insert = Yii::$app->db->createCommand()->batchInsert($table_name, $keys_arr, $current_batch_array)->sql;
            // добавим фрагмент с апдейтом при дубляже
            $query = "{$query_insert} {$query_update}";
            // \common\components\CustomVarDamp::dumpAndDie($query);
            Yii::$app->db->createCommand($query)->execute();
        }
    }
    public function manualDelete( $conditions, $params = [] )
    {
        do {
            $query = Yii::$app->db->createCommand()->delete( self::tableName(), $conditions, $params )->sql . ' Limit ' . $this::BATCH;
//            try {
                $res = Yii::$app->db->createCommand($query)->execute();
//            } catch (\Exception $e) {
//                throw new \ErrorException('Ошибка удаления товаров '.$e->getMessage());
//            }
        } while ($res);
        return true;
    }
}