1
0
mirror of https://gitee.com/koogua/course-tencent-cloud.git synced 2025-06-22 03:32:47 +08:00
course-tencent-cloud/app/Console/Tasks/OptimizeTableTask.php

101 lines
2.5 KiB
PHP

<?php
namespace App\Console\Tasks;
use App\Models\ImMessage as ImMessageModel;
use App\Models\Learning as LearningModel;
use App\Models\Task as TaskModel;
use App\Models\UserSession as UserSessionModel;
use App\Models\UserToken as UserTokenModel;
class OptimizeTableTask extends Task
{
public function mainAction()
{
$this->optimizeUserSessionTable();
$this->optimizeUserTokenTable();
$this->optimizeImMessageTable();
$this->optimizeLearningTable();
$this->optimizeTaskTable();
}
protected function optimizeUserSessionTable()
{
$sessionModel = new UserSessionModel();
$tableName = $sessionModel->getSource();
$this->db->delete($tableName, "expire_time < :expire_time", [
'expire_time' => strtotime('-3 days'),
]);
$this->db->execute("OPTIMIZE TABLE {$tableName}");
}
protected function optimizeUserTokenTable()
{
$tokenModel = new UserTokenModel();
$tableName = $tokenModel->getSource();
$this->db->delete($tableName, "expire_time < :expire_time", [
'expire_time' => strtotime('-3 days'),
]);
$this->db->execute("OPTIMIZE TABLE {$tableName}");
}
protected function optimizeImMessageTable()
{
$count = ImMessageModel::count();
if ($count < 1000000) return;
$messageModel = new ImMessageModel();
$tableName = $messageModel->getSource();
$this->db->delete($tableName, "create_time < :create_time", [
'create_time' => strtotime('-6 months'),
]);
$this->db->execute("OPTIMIZE TABLE {$tableName}");
}
protected function optimizeLearningTable()
{
$count = LearningModel::count();
if ($count < 1000000) return;
$learningModel = new LearningModel();
$tableName = $learningModel->getSource();
$this->db->delete($tableName, "create_time < :create_time", [
'create_time' => strtotime('-6 months'),
]);
$this->db->execute("OPTIMIZE TABLE {$tableName}");
}
protected function optimizeTaskTable()
{
$count = TaskModel::count();
if ($count < 1000000) return;
$taskModel = new TaskModel();
$tableName = $taskModel->getSource();
$this->db->delete($tableName, "create_time < :create_time AND status > :status", [
'create_time' => strtotime('-6 months'),
'status' => TaskModel::STATUS_PENDING,
]);
$this->db->execute("OPTIMIZE TABLE {$tableName}");
}
}