new_sdk_wu/www/new_sdk/application/common/library/AliyunOSS.php

<?php
/**
 * 阿里云oss文件上传处理类
 */
namespace app\common\library;

vendor('aliyun-oss.autoload');

use OSS\OssClient;
use OSS\Core\OssException;
use think\Env;

/**
 * Class aliyunOSS
 *
 * 获取OssClient实例和其他公用方法
 * 阿里云文档 https://promotion.aliyun.com/ntms/act/ossdoclist.html
 */
class AliyunOSS
{
    private static $endpoint;
    private static $accessKeyId;
    private static $accessKeySecret;
    private static $bucket;

    private static $self  = NULL;
    /**
     * 根据Config配置，得到一个OssClient实例
     *
     * @return OssClient 一个OssClient实例
     */
    static public function getOssClient()
    {
        if (is_null(self::$self)) {
            try {
                self::$self = new OssClient(Env::get('ali_oss.access_keysid'), Env::get('ali_oss.access_keysecrt'), Env::get('ali_oss.access_endpoint'),false);
            } catch (OssException $e) {
                printf(__FUNCTION__ . "creating OssClient instance: FAILED\n");
                printf($e->getMessage() . "\n");
                return null;
            }
        }
        return self::$self;
    }

    /*******************************************************************************/
    /**********************   bucket操作     *******************************/
    /*******************************************************************************/

    /**
     * 工具方法，创建一个存储空间，如果发生异常直接exit
     */
    static public function createBucket($bucket)
    {
        $ossClient = self::getOssClient();
        if (is_null($ossClient)) exit(1);
        $acl = OssClient::OSS_ACL_TYPE_PUBLIC_READ;
        try {
            return $ossClient->createBucket($bucket, $acl);
        } catch (OssException $e) {

            $message = $e->getMessage();
            if (\OSS\Core\OssUtil::startsWith($message, 'http status: 403')) {
                echo "Please Check your AccessKeyId and AccessKeySecret" . "\n";
                exit(0);
            } elseif (strpos($message, "BucketAlreadyExists") !== false) {
                echo "Bucket already exists. Please check whether the bucket belongs to you, or it was visited with correct endpoint. " . "\n";
                exit(0);
            }
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
    }
    /**
     * 列出用户所有的Bucket
     * @return null
     */
    public static function listBuckets()
    {
        $ossClient = self::getOssClient();
        $bucketList = null;
        try {
            $bucketListInfo = $ossClient->listBuckets();
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }

        $bucketList = $bucketListInfo->getBucketList();
       /* foreach ($bucketList as $bucket) {
            print($bucket->getLocation() . "\t" . $bucket->getName() . "\t" . $bucket->getCreatedate() . "\n");
        }*/
        return $bucketList;
    }

    /**
     *  判断Bucket是否存在
     * @param string $bucket 存储空间名称
     */
    public static function doesBucketExist($bucket)
    {
        $ossClient = self::getOssClient();
        try {
            $res = $ossClient->doesBucketExist($bucket);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $res;
    }
    /**
     * 获取bucket的acl配置
     * @param string $bucket 存储空间名称
     * @return null
     */
    public static function getBucketAcl($bucket)
    {
        $ossClient = self::getOssClient();
        try {
            $res = $ossClient->getBucketAcl($bucket);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
       return $res;
    }
    /**
     * 设置bucket的acl配置
     * @param string $bucket 存储空间名称
     * @return null
     */
    public static function putBucketAcl($bucket)
    {
        $ossClient = self::getOssClient();
        $acl = OssClient::OSS_ACL_TYPE_PRIVATE;
        try {
            $res = $ossClient->putBucketAcl($bucket, $acl);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
       return $res;
    }

    /*******************************************************************************/
    /**********************   文件上传和下载 操作     *******************************/
    /*******************************************************************************/

    /**
     * 创建目录
     * $dir 目录名
     */
    public static function createDir($dir)
    {
        $time      = date("Y-m-d H:i:s");
        $content   = "这是一个{$dir}目录，创建时间{$time}";
        $fileName  = $dir."/Readme.txt";
        $ossClient = self::getOssClient();
        $options = array();
        try {
            $res = $ossClient->putObject(Env::get('ali_oss.access_bucket'), $fileName, $content, $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $res;
    }

    public static function doesDirExist($dir){
        $fileName  = $dir."/Readme.txt";
        $res = self::doesObjectExist($fileName);
        return $res;
    }
    /**
     * 把本地变量的内容存到文件  如果是远程图片，则把图片变成二进制流，在写入文件中
     *
     * 简单上传,上传指定变量的内存值作为object的内容
     * @param string $fileName 要存储文件名称  当上传远程图片时可以不给名字 会与远程名字同名
     * @param string $content  要写入的内容
     * @return null
     */
    public static function putObject($content,$fileName='',$dir='')
    {
        $extentionArr = array( 'gif', 'jpg', 'jpeg', 'png');
        $extention = pathinfo($content, PATHINFO_EXTENSION);
        if(in_array($extention,$extentionArr)){
            $picName = pathinfo($content,PATHINFO_BASENAME);
            $content = file_get_contents($content);
            if(empty($fileName)){
                $fileName = $picName;
            }
            if(empty($dir)){
                $dir = date("Ym");
            }
            $fileName = $dir.'/'.$fileName;
        }else{
            return '1';
        }
        $ossClient = self::getOssClient();
        $options = array();
        try {
            $res = $ossClient->putObject(Env::get('ali_oss.access_bucket'), $fileName, $content, $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $res;
    }

    /**
     * 上传指定的本地文件内容
     * @param string $new_fileName 给文件重命名
     * @param string $filePath     文件路劲
     * @param string $dir          存放目录 不给默认为最新的时间为目录
     * @return null
     */
    public static function uploadFile($filePath,$new_fileName,$dir='')
    {
        $ossClient      = self::getOssClient();
        $options        = [];
        $dir            = empty($dir) ? date("Ym",time()) : $dir;
        $new_fileName   = $dir.'/'.$new_fileName;
        try {
           $res =  $ossClient->uploadFile(Env::get('ali_oss.access_bucket'), $new_fileName, $filePath, $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n - ");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $res;
    }

    /**
     * 列出Bucket内所有文件, 注意如果符合条件的文件数目超过设置的max-keys， 用户需要使用返回的nextMarker作为入参，通过
     * @param string $prefix 模糊查询
     $prefix        限定返回的Object 必须以Prefix作为前缀。注意使用prefix查询时，返回的key中仍会包含Prefix。
     $delimiter     用于对Object名字进行分组的字符。所有名字包含指定的前缀且第一次出现Delimiter字符之间的Object作为一组元素
     $nextMarker    设定结果从Marker之后按字母排序的第一个开始返回。作为下一页的标记
     $maxkeys = 1000 限定此次返回Object的最大数，如果不设定，默认为100，MaxKeys取值不能大于1000。
     * @return null
     */
    public static function listObjects($prefix = '',$delimiter='',$nextMarker='',$maxkeys=50)
    {
        $ossClient = self::getOssClient();
        $options = array(
            'delimiter' => $delimiter,
            'prefix' => $prefix,
            'max-keys' => $maxkeys,
            'marker' => $nextMarker,
        );
        try {
            $listObjectInfo = $ossClient->listObjects(Env::get('ali_oss.access_bucket'), $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }

        $data = array();
        //下一页的标记
        $nextMarker     = $listObjectInfo->getNextMarker();
        if($delimiter){
            $objectList = $listObjectInfo->getPrefixList();
            if (!empty($objectList)) {
                foreach ($objectList as $objectInfo) {
                    $data[] = $objectInfo->getPrefix();
                }
            }
        }else{
            $objectList = $listObjectInfo->getObjectList(); // 文件列表
            if (!empty($objectList)) {
                foreach ($objectList as $objectInfo) {
                    $data[] = ['key' => $objectInfo->getKey(), 'LastModified' => $objectInfo->getLastModified()];
                }
            }
        }
        return array("data"=>$data,'nextMarker'=>$nextMarker);
    }

    /**
     * 获取object的内容
     * @param string $fileName 获取文件的内容，如果是图片，则得到二进制流 不用绝对地址，按照bucket相对路劲
     * @return null
     */
    public static function getObject($fileName,$options = array())
    {
        $ossClient = self::getOssClient();
        try {
            $content = $ossClient->getObject(Env::get('ali_oss.access_bucket'), $fileName, $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
//        $content = getimagesize($content);  得到图片具体信息
        return $content;
    }

    /**
     * get_object_to_local_file
     *
     * 获取object
     * 将object下载到指定的文件  少用，还不是很清楚，怎么用
     * @param string $fileName 获取文件的内容，如果是图片，则得到二进制流 不用绝对地址，按照bucket相对路劲
     * $localfile 本地文件名
     * @return null
     */
    public static function getObjectToLocalFile($fileName,$localfile)
    {
        $ossClient = self::getOssClient();
        $options = array(
            OssClient::OSS_FILE_DOWNLOAD => $localfile,
        );

        try {
            $res = $ossClient->getObject(Env::get('ali_oss.access_bucket'), $fileName, $options);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $res;
    }

    /**
     * 删除object
     * @param string $fileName 不用绝对地址，按照bucket相对路劲
     *        $fileName也可以是数组形式 那么就是批量删除
     * @param string $bucket,为空时使用默认配置的bucket
     * @return null
     */
    public static function deleteObject($fileName,$bucket='')
    {
        $ossClient = self::getOssClient();
        try {
            $bucket = !empty($bucket) ? $bucket : Env::get('ali_oss.access_bucket');
            $res = $ossClient->deleteObject($bucket, $fileName);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $res;
    }


    /**
     * 判断object是否存在
     * @param string $fileName 不用绝对地址，按照bucket相对路劲
     * @return null
     */
    public static function doesObjectExist($fileName)
    {
        $ossClient = self::getOssClient();
        try {
            $exist = $ossClient->doesObjectExist(Env::get('ali_oss.access_bucket'), $fileName);
        } catch (OssException $e) {
            printf(__FUNCTION__ . ": FAILED\n");
            printf($e->getMessage() . "\n");
            return '';
        }
        return $exist;
    }
}