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

<?php

namespace app\controller\merchant;

use app\extra\basic\Base;
use app\extra\tools\CodeExtend;
use app\extra\tools\UploadExtend;
use app\middleware\AuthMiddleware;
use app\model\system\SystemExport;
use app\model\system\SystemImport;
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());
        }
    }


    #[PostMapping('import')]
    public function importOrder(Request $request): Response
    {
        try {
            $resp = UploadExtend::disk(UploadExtend::MODE_LOCAL)->uploadFile();
            if (!isset($resp[0]['url'])) return error("上传文档失败");
            $logId = (new SystemImport)->insertGetId([
                "uuid"      => $request->user['id'],
                "poi_id"    => $request->user['store_id'],
                "path"      => $resp[0]['url'],
                "title"     => $resp[0]['origin_name'],
                "order_sn"  => CodeExtend::uniqidDate()
            ]);
            Redis::send("import-order",[
                "logId"     => $logId,
                "poi_id"    => $request->user['store_id'],
                "path"      => $resp[0]['url'],
            ]);
            return success("导入成功，请耐心等待系统完成，",[],200);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

}