zyedu/application/admin/controller/setting/SystemBucket.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016～2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------


namespace app\admin\controller\setting;

use service\JsonService as Json;
use think\Request;
use think\Url;
use app\admin\controller\AuthController;
use service\AlipayDisposeService;
use app\admin\model\system\SystemBucket as SystemBucketModel;
use service\SystemConfigService;

/**
 * Class SystemBucket
 * @package app\admin\controller\setting
 */
class SystemBucket extends AuthController
{

    protected static $endpoint = [
        '华东1(杭州)' => 'oss-cn-hangzhou.aliyuncs.com',
        '华东2(上海)' => 'oss-cn-shanghai.aliyuncs.com',
        '华北1(青岛)' => 'oss-cn-qingdao.aliyuncs.com',
        '华北2(北京)' => 'oss-cn-beijing.aliyuncs.com',
        '华北3(张家口)' => 'oss-cn-zhangjiakou.aliyuncs.com',
        '华北5(呼和浩特)' => 'oss-cn-huhehaote.aliyuncs.com',
        '华北6(乌兰察布)' => 'oss-cn-wulanchabu.aliyuncs.com',
        '华南1(深圳)' => 'oss-cn-shenzhen.aliyuncs.com',
        '华南2(河源)' => 'oss-cn-heyuan.aliyuncs.com',
        '华南3(广州)' => 'oss-cn-guangzhou.aliyuncs.com',
        '西南1(成都)' => 'oss-cn-chengdu.aliyuncs.com',
        '中国(香港)' => 'oss-cn-hongkong.aliyuncs.com',
        '新加坡' => 'oss-ap-southeast-1.aliyuncs.com',
        '澳大利亚(悉尼)' => 'oss-ap-southeast-2.aliyuncs.com',
        '马来西亚(吉隆坡)' => 'oss-ap-southeast-3.aliyuncs.com',
        '印度尼西亚(雅加达)' => 'oss-ap-southeast-5.aliyuncs.com',
        '日本(东京)' => 'oss-ap-northeast-1.aliyuncs.com',
        '印度(孟买)' => 'oss-ap-south-1.aliyuncs.com',
        '德国(法兰克福)' => 'oss-eu-central-1.aliyuncs.com',
        '英国(伦敦)' => 'oss-eu-west-1.aliyuncs.com',
        '美国(硅谷)' => 'oss-us-west-1.aliyuncs.com',
        '美国(佛吉尼亚)' => 'oss-us-east-1.aliyuncs.com',
        '阿联酋(迪拜)' => 'oss-me-east-1.aliyuncs.com',
    ];

    /**
     * 对象存储OSS配置页面
     * @return \think\Response
     */
    public function index()
    {
        $endpoint = self::$endpoint;
        $this->assign(['endpoint' => $endpoint]);
        return $this->fetch();
    }

    /**
     * Bucket列表
     */
    public function bucket_list()
    {
        $where = parent::getMore([
            ['title', ''],
            ['endpoint', ''],
            ['types', 1],
        ], $this->request);
        return Json::successlayui(SystemBucketModel::bucKetList($where));
    }

    /**
     * 拉取储存空间
     */
    public function pullBucket()
    {
        $where = parent::getMore([
            ['endpoint', ''],
        ], $this->request);
        $list = AlipayDisposeService::ossBucketList($where['endpoint']);
        if (count($list) > 0) {
            SystemBucketModel::addListBucket($list);
        }
        return Json::successful('ok');
    }

    /**
     * 添加存储空间
     */
    public function create()
    {
        $endpoint = self::$endpoint;
        $this->assign(['endpoint' => json_encode($endpoint)]);
        return $this->fetch();
    }

    /**
     * 添加存储空间
     */
    public function save()
    {
        $data = parent::postMore([
            ['bucket_name', ''],
            ['endpoint', ''],
            ['type', 1],
            ['jurisdiction', 1],
        ]);
        if (!$data['bucket_name']) return Json::fail('请输入存储空间名称');
        if (AlipayDisposeService::doesBucketExist($data['endpoint'], $data['bucket_name'])) {
            return Json::fail('存储空间已存在');
        }
        SystemBucketModel::beginTrans();
        $res = AlipayDisposeService::ossDispose($data['endpoint'], $data['bucket_name'], $data['jurisdiction'], $data['type']);
        if ($res) {
            $res1 = AlipayDisposeService::putBucketCors($data['endpoint'], $data['bucket_name']);
            if ($res1 && SystemBucketModel::addBucket($data)) {
                SystemBucketModel::commitTrans();
                return Json::successful('添加存储空间成功！');
            } else {
                SystemBucketModel::rollbackTrans();
                return Json::fail('添加到数据库失败或设置跨域规则失败！');
            }
        } else {
            SystemBucketModel::rollbackTrans();
            return Json::fail('添加存储空间失败！');
        }
    }

    /**
     * 删除存储空间
     */
    public function delete($id = 0)
    {
        if (!$id) return Json::fail('参数错误');
        $bucket = SystemBucketModel::where('id', $id)->where('is_del', 0)->find();
        if (!$bucket) return Json::fail('删除存储空间不存在');
        $res = AlipayDisposeService::deleteBucket($bucket['endpoint'], $bucket['bucket_name']);
        if ($res) {
            SystemBucketModel::where('id', $id)->update(['is_del' => 1]);
            return Json::successful('删除存储空间成功');
        } else {
            return Json::fail('删除存储空间失败');
        }
    }

    /**使用储存空间
     * @param int $id
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function userUse($id = 0)
    {
        if (!$id) return Json::fail('参数错误');
        $bucket = SystemBucketModel::where('id', $id)->where('is_del', 0)->find();
        if (!$bucket) return Json::fail('存储空间不存在');
        $res = SystemConfigService::setOneValue('uploadUrl', $bucket['domain_name']);
        $res1 = SystemConfigService::setOneValue('OssBucket', $bucket['bucket_name']);
        $res2 = SystemConfigService::setOneValue('end_point', $bucket['endpoint']);
        if ($res && $res1 && $res2) {
            SystemBucketModel::where('is_use', 1)->where('is_del', 0)->update(['is_use' => 0]);
            SystemBucketModel::where('id', $id)->where('is_del', 0)->update(['is_use' => 1]);
            return Json::successful('设置存储空间成功');
        } else {
            return Json::fail('设置存储空间失败');
        }
    }

}