jiaoyi-webman/app/controller/merchant/Tasks.php

<?php

namespace app\controller\merchant;

use app\extra\basic\Base;
use app\middleware\AuthMiddleware;
use app\model\system\SystemExport;
use LinFly\Annotation\Attributes\Route\Controller;
use LinFly\Annotation\Attributes\Route\GetMapping;
use LinFly\Annotation\Attributes\Route\Middleware;
use LinFly\Annotation\Attributes\Route\PostMapping;
use support\Request;
use support\Response;
use Webman\RedisQueue\Redis;


#[Controller("/api/tasks"),Middleware(AuthMiddleware::class)]
class Tasks extends Base
{


    #[GetMapping('list')]
    public function getTaskList(Request $request): Response
    {
        try {
            $param = $request->get();
            $mode = (new SystemExport);
            if ($request->user['is_super'] == 0) {
                $mode = $mode->where("uuid",$request->user['id']);
            }
            $list = $mode->order("create_at","desc")->select()->toArray();
            return successTrans(100010,$list,200);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

    #[PostMapping('export')]
    public function exportOrder(Request $request): Response
    {
        try {
            $param = $request->all();
            $param['poi_id'] = $request->user['store_id'];
            $logId = (new SystemExport)->insertGetId([
                "uuid"      => $request->user['id'],
                "name"      => $param['fileName'],
                "params"    => json_encode($param),
            ]);
            Redis::send("export-order",[
                "logId"     => $logId,
                "param"     => $param,
            ]);
            return success("任务发起成功，请留意任务台状态并下载",[],200);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

}