38 lines
962 B
PHP
38 lines
962 B
PHP
<?php
|
||
|
||
namespace app\api\job;
|
||
|
||
use think\queue\Job;
|
||
use app\common\PromotionService;
|
||
|
||
/**
|
||
* 队列任务：对单个 promotion_task 执行 prepareTask（预生成 subject/body）。
|
||
*
|
||
* 队列名：promotion
|
||
* 启动 worker：php think queue:listen --queue promotion
|
||
*/
|
||
class PromotionPrepare
|
||
{
|
||
public function fire(Job $job, $data)
|
||
{
|
||
$taskId = intval(isset($data['task_id']) ? $data['task_id'] : 0);
|
||
$service = new PromotionService();
|
||
|
||
if (!$taskId) {
|
||
$job->delete();
|
||
return;
|
||
}
|
||
|
||
try {
|
||
$result = $service->prepareTask($taskId);
|
||
$service->log('[PromotionPrepare] task=' . $taskId
|
||
. ' prepared=' . $result['prepared']
|
||
. ' failed=' . $result['failed']);
|
||
} catch (\Exception $e) {
|
||
$service->log('[PromotionPrepare] task=' . $taskId . ' exception=' . $e->getMessage());
|
||
}
|
||
|
||
$job->delete();
|
||
}
|
||
}
|