Details.php
3.52 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
<?php
namespace backend\models;
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'];
const BATCH = 500;
/**
* @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'),
];
}
public function ManualInsert ($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;
// добавим фрагмент с апдейтом при дубляже
$query = "{$query_insert} {$query_update}";
// \common\components\CustomVarDamp::dumpAndDie($query);
$res = Yii::$app->db->createCommand($query)->execute();
}
}
}