52 lines
1.6 KiB
PHP
52 lines
1.6 KiB
PHP
<?php
|
||
declare(strict_types=1);
|
||
|
||
namespace app\process;
|
||
|
||
use app\dice\logic\reward_config_record\WeightTestRunner;
|
||
use app\dice\model\reward_config_record\DiceRewardConfigRecord;
|
||
use Workerman\Timer;
|
||
use Workerman\Worker;
|
||
|
||
/**
|
||
* 一键测试权重定时任务进程：每隔一定时间检查 status=0 的测试记录并执行一条，不占用 HTTP worker 资源
|
||
*/
|
||
class WeightTestProcess
|
||
{
|
||
/** 轮询间隔（秒） */
|
||
private const INTERVAL = 15;
|
||
|
||
public function onWorkerStart(Worker $worker): void
|
||
{
|
||
Timer::add(self::INTERVAL, function () {
|
||
$this->runOnePending();
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 执行一条待完成的测试记录（status=0）
|
||
* 先原子更新为 STATUS_EXECUTING，避免定时器 15 秒重入时同一条记录被重复执行（导致顺/逆时针各跑两倍次数）
|
||
*/
|
||
private function runOnePending(): void
|
||
{
|
||
$record = DiceRewardConfigRecord::where('status', DiceRewardConfigRecord::STATUS_RUNNING)
|
||
->order('id')
|
||
->find();
|
||
if (!$record) {
|
||
return;
|
||
}
|
||
$recordId = (int) $record->id;
|
||
$affected = DiceRewardConfigRecord::where('id', $recordId)
|
||
->where('status', DiceRewardConfigRecord::STATUS_RUNNING)
|
||
->update(['status' => DiceRewardConfigRecord::STATUS_EXECUTING]);
|
||
if ($affected !== 1) {
|
||
return;
|
||
}
|
||
try {
|
||
(new WeightTestRunner())->run($recordId);
|
||
} catch (\Throwable $e) {
|
||
// WeightTestRunner 内部会更新 status=-1 和 remark
|
||
}
|
||
}
|
||
}
|