api/app/Lib/Account.php

<?php namespace Api\Lib;
use Dever;
# 官方平台账户
class Account
{
    public function update($db, $data)
    {
        if (isset($data['app_platform']) && $data['app_platform']) {
            $app_platform = $data['app_platform'];
            if (is_string($app_platform)) {
                $app_platform = explode(',', $app_platform);
            }
            $data['app_id'] = $app_platform[0];
            $data['platform_id'] = $app_platform[1] ?? 0;
            if (!$data['platform_id']) {
                Dever::error('请选择平台');
            }
        }
        return $data;
    }

    public function get($account, $project = 'api')
    {
        if (is_array($account)) {
            return $account;
        }
        if (is_numeric($account)) {
            $where = ['id' => $account];
        } else {
            $where = ['key' => $account];
        }
        $account = Dever::db($project . '/account')->find($where);
        if (!$account) {
            Dever::error('账户无效');
        }
        if ($project != 'api') {
            $info = Dever::db('api/account')->find(['key' => $account['key']]);
            if (!$info) {
                Dever::error('账户无效');
            }
            $account['app_id'] = $info['app_id'];
            $account['platform_id'] = $info['platform_id'];
        }
        return $account;
        /*
        $account = Dever::db('api/account')->find($where);
        if ($project != 'api') {
            $info = Dever::db($project . '/account')->find(['key' => $account['key']]);
            if ($info) {
                $info['app_id'] = $account['app_id'];
                $info['platform_id'] = $account['platform_id'];
                return $info;
            } else {
                Dever::error('账户无效');
            }
        }
        return $account;
        */
    }

    public function run($account, $func, $param = [], $env = 1, $method = 'run', $project = 'api')
    {
        $account = $this->get($account, $project);
        if (!$account) {
            Dever::error('账户无效');
        }
        if (!is_array($func)) {
            $func = Dever::db('api/app_func')->find(['app_id' => $account['app_id'], 'key' => $func]);
        }
        if (!$func) {
            Dever::error('功能无效');
        }
        $api = Dever::load(App::class)->getApi($func['id'], $env);
        if (!$api) {
            Dever::error('接口无效');
        }
        $param['account_project'] = $project;
        $param['account_id'] = $account['id'];
        $result = [];
        if ($func['type'] == 1) {
            # 仅执行第一个
            $result = Dever::load(Api::class)->$method($api[0], $param);
            if (is_array($result)) {
                $result['account_id'] = $account['id'];
                $result['api_id'] = $api[0]['id'];
            }
        } elseif ($func['type'] == 2) {
            # 同步执行
            foreach ($api as $k => $v) {
                $result = Dever::load(Api::class)->$method($v, $param);
                if ($result && is_array($result)) {
                    $param = array_merge($result, $param);
                }
            }
        } elseif ($func['type'] == 3) {
            # 异步执行
            $result = true;
            foreach ($api as $k => $v) {
                $param['api_id'] = $v['id'];
                \Dever\Helper\Cmd::run('task.api', $param, 'api');
            }
        }
        return $result;
    }
}