system/src/Controller/QueueJobLogController.php

<?php

declare(strict_types=1);

namespace SixShop\System\Controller;

use SixShop\System\Entity\QueueJobLogEntity;
use think\Request;
use think\Response;

use function SixShop\Core\page_response;
use function SixShop\Core\success_response;

class QueueJobLogController
{
    /**
     * 队列任务日志列表
     */
    public function index(Request $request, QueueJobLogEntity $entity): Response
    {
        $params = $request->get([
            'name/s',
            'success/d',
            'start_time/s',
            'end_time/s'
        ]);
        $list = $entity->getList($params, $request->pageAndLimit());
        $stats = $entity->getStats($params);
        return page_response($list, $stats);
    }

    /**
     * 删除单条日志
     */
    public function delete(int $id, QueueJobLogEntity $entity): Response
    {
        $entity->deleteById($id);
        return success_response();
    }

    /**
     * 批量删除日志
     */
    public function batchDelete(Request $request, QueueJobLogEntity $entity): Response
    {
        $ids = $request->post('ids', []);
        if (empty($ids) || !is_array($ids)) {
            return success_response([], 'ok', 200, '没有可删除的记录');
        }
        $entity->deleteByIds($ids);
        return success_response([], 'ok', 200, '批量删除成功');
    }

    /**
     * 清空所有日志
     */
    public function clearAll(QueueJobLogEntity $entity): Response
    {
        $entity->clearAll();
        return success_response([], 'ok', 200, '清空成功');
    }
}