You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
111 lines
3.2 KiB
111 lines
3.2 KiB
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Models\EventCalendar;
|
|
use App\Services\AdminNoticeService;
|
|
use App\Services\OperationLogService;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
class AutomaticallyStartActivity extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
* @var string
|
|
*/
|
|
protected $signature = 'run:automatically-start-activity';
|
|
|
|
/**
|
|
* The console command description.
|
|
* @var string
|
|
*/
|
|
protected $description = 'Command description';
|
|
|
|
protected OperationLogService $logService;
|
|
|
|
public function __construct(OperationLogService $log)
|
|
{
|
|
parent::__construct();
|
|
$this->logService = $log;
|
|
$this->logService->menuTitle = 'event_calendar';
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*/
|
|
public function handle()
|
|
{
|
|
$now_times = time();
|
|
$now_time = date("Y-m-d H:i:s", $now_times);
|
|
// 结束活动,调整为默认模式
|
|
$where = [
|
|
['status', '=', 1]
|
|
];
|
|
$runRes = EventCalendar::query()->where($where)->orderBy('created_at')
|
|
->first();
|
|
|
|
$start = true;
|
|
// 数据存在,且结束时间到了,结束时间
|
|
if ($runRes) {
|
|
$end_time = $runRes['end_time'];
|
|
$run_id = $runRes['id'];
|
|
$is_manual = $runRes['is_manual'];
|
|
if ($end_time && strtotime($end_time) <= $now_times) {
|
|
$this->updateStatus($run_id, 2);
|
|
} elseif ($is_manual == 1) {
|
|
// 手动开始的不切换模式
|
|
$start = false;
|
|
}
|
|
}
|
|
|
|
// 启动 新模式
|
|
if ($start) {
|
|
$where = [
|
|
['status', '=', 0],
|
|
['start_time', '>=', $now_time],
|
|
['end_time', '<=', $now_time]
|
|
];
|
|
$res = EventCalendar::query()->where($where)->orderBy('start_time')
|
|
->first(['id']);
|
|
if ($res) {
|
|
// 新活动运行 直接关闭就活动
|
|
$new_id = $res['id'];
|
|
if ($runRes && $runRes['id'] != $new_id) {
|
|
$this->updateStatus($run_id, 2);
|
|
}
|
|
$this->updateStatus($new_id, true);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param $id
|
|
* @param int $status // 1运行 、 2结束
|
|
* @param bool $is_notice
|
|
* @return void
|
|
*/
|
|
protected function updateStatus(
|
|
$id,
|
|
int $status = 1,
|
|
bool $is_notice = false
|
|
): void {
|
|
$model = EventCalendar::query()->findOrFail($id);
|
|
$oldValue = $model->toArray();
|
|
$model->update([
|
|
'status' => $status,
|
|
'updated_at' => date("Y-m-d H:i:s", time())
|
|
]);
|
|
// 记录日志
|
|
$this->logService->logUpdated($model, $oldValue, 'event_calendar.update');
|
|
// 记录警报信息, 切换任务
|
|
if ($is_notice) {
|
|
$data = [
|
|
'pattern_id' => $oldValue['pattern_id']
|
|
];
|
|
$user_id = DB::table('admin_users')->where('username', 'Admin')
|
|
->value('id');
|
|
AdminNoticeService::createData(2, 5, $data, $user_id);
|
|
}
|
|
}
|
|
}
|
|
|