xingyou/app/Services/Interface/Database/DbManager.php

<?php

declare(strict_types=1);

namespace App\Services\Interface\Database;

use App\Services\Interface\Database\Add\AddDb;
use App\Services\Interface\Database\Delete\DeleteDb;
use App\Services\Interface\Database\Query\QueryDb;
use App\Services\Interface\Database\Update\UpdateDb;
use App\Services\Interface\Database\Uploader\UploaderDb;

class DbManager extends CommonDb
{
    public function __construct(array $interfaceInfo, array $assembleInfo, array $assembleColumns, array $requestData, array $columnIdToCodes)
    {
        parent::__construct($interfaceInfo, $assembleInfo, $assembleColumns, $requestData, $columnIdToCodes);
    }

    public function exec()
    {
        $operateType = $this->interfaceInfo['operate_type'];

        if (1 === $operateType) { // 查询
            $result = (new QueryDb($this->interfaceInfo, $this->assembleInfo, $this->assembleColumns, $this->requestData, $this->columnIdToCodes))->exec();
        } elseif (2 === $operateType) { // 添加
            $result = (new AddDb($this->interfaceInfo, $this->assembleInfo, $this->assembleColumns, $this->requestData, $this->columnIdToCodes))->exec();
        } elseif (3 === $operateType) { // 更新
            $result = (new UpdateDb($this->interfaceInfo, $this->assembleInfo, $this->assembleColumns, $this->requestData, $this->columnIdToCodes))->exec();
        } elseif (4 === $operateType) { // 删除
            $result = (new DeleteDb($this->interfaceInfo, $this->assembleInfo, $this->assembleColumns, $this->requestData, $this->columnIdToCodes))->exec();
        } elseif (5 === $operateType) { // 上传
            $result = (new UploaderDb($this->interfaceInfo, $this->assembleInfo, $this->assembleColumns, $this->requestData, $this->columnIdToCodes))->exec();
        } else {
            abort(508, '接口配置[operateType]错误');
        }

        return $result;
    }
}