Administrator / test_1

  <?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'],
              //  [['IMPORT_ID', 'BOX', 'ADD_BOX'], 'integer'],

              [['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) {
              // запустим пакетное удаление всех прайсов поставщика
              do {
                  $query = Yii::$app->db->createCommand()->delete(self::tableName(), "IMPORT_ID = {$importer_id}")->sql . ' Limit ' . $this::BATCH;
                  $res = Yii::$app->db->createCommand($query)->execute();
              } while ($res);
  
          }
  
          $this->ManualInsertWithUpdate($data);
      }
  
      /**
       * вставка данных с апдейтом прямым запросом SQL
       * @param $data - массив вставляемых данный, вставка будет прозводится пакетами размером указанным в константе BATCH
       * @throws \yii\db\Exception
       */
      private function ManualInsertWithUpdate($data)

      {

          // \common\components\CustomVarDamp::dumpAndDie($data);

          $table_name = self::tableName();

          $keys_arr = array_keys($data[0]);

          // найдем те поля которые не являются ключами. Их нужно будет при дубляже апдейтить

          $fields_arr_to_update = array_diff($keys_arr, $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;

              if ($this->delete_prefix) {
                  $query_insert = $this->prepareArticul( $query_insert );
              }

              // добавим фрагмент с апдейтом при дубляже
              $query = "{$query_insert} {$query_update}";

              // \common\components\CustomVarDamp::dumpAndDie($query);

              Yii::$app->db->createCommand($query)->execute();

  
          }

      }

  }