$batchSize = 500;
$offset = 0;
- $csvFilePath = Yii::getAlias('@runtime/missing_users.csv');
- $fileHandle = fopen($csvFilePath, 'w');
- fputcsv($fileHandle, ['phone', 'username', 'chat_id', 'is-blocked', 'is_registered', 'reason'], ';');
+ // $csvFilePath = Yii::getAlias('@runtime/missing_users.csv');
+ // $fileHandle = fopen($csvFilePath, 'w');
+ // fputcsv($fileHandle, ['phone', 'username', 'chat_id', 'is-blocked', 'is_registered', 'reason'], ';');
while (true) {
$chatbotUsers = $remoteDb
$isBlocked = (int)$remoteUser['is_blocked'];
$isRegistered = (int)$remoteUser['is_registered'];
if (empty($phone)) {
- fputcsv($fileHandle, [$phone, $username, $chatId, $isBlocked, $isRegistered, 'Отсутствует телефон'], ';');
+ // fputcsv($fileHandle, [$phone, $username, $chatId, $isBlocked, $isRegistered, 'Отсутствует телефон'], ';');
continue;
}
$user = Users::findOne(['phone' => $phone]);
if (!$user) {
- fputcsv($fileHandle, [$phone, $username, $chatId, $isBlocked, $isRegistered, 'Пользователь не найден'], ';');
+ // fputcsv($fileHandle, [$phone, $username, $chatId, $isBlocked, $isRegistered, 'Пользователь не найден'], ';');
continue;
/* $user = new Users([
'phone' => $phone,
$this->stdout("Обработано записей: {$offset}\n", BaseConsole::FG_GREEN);
}
- fclose($fileHandle);
+ // fclose($fileHandle);
$this->stdout(
"Синхронизация завершена успешно. Записи без пользователей сохранены в {$csvFilePath}\n",
BaseConsole::FG_GREEN
if (!isset($tableSchema)) {
$this->createTable(self::TABLE_NAME, [
- 'phone' => $this->string()->notNull()->unique()->comment('Телефон'),
+ 'id' => $this->primaryKey()->comment('Первичный ключ'),
+ 'phone' => $this->string()->notNull()->comment('Телефон'),
'is_blocked' => $this->integer(1)->notNull()->defaultValue(0)->comment(
'Заблокирован: 0 - нет, 1 - да'
),
'date_end' => $this->date()->null()->comment('Дата окончания активности'),
]);
- $this->addPrimaryKey('pk_users_telegram_log', self::TABLE_NAME, 'phone');
+
}
}