芝麻web文件管理V1.00

编辑当前文件:/home/qrafawbu/minscoop.com/app/Models/AwsModel.php

<?php namespace App\Models;

require APPPATH . 'ThirdParty/aws-sdk/vendor/autoload.php';

use CodeIgniter\Model;
use Aws\S3\S3Client;
use Aws\S3\Exception\S3Exception;

class AwsModel extends BaseModel
{
    protected $key;
    protected $secret;
    protected $bucket;
    protected $region;
    protected $s3;

public function __construct()
    {
        parent::__construct();
        $this->key = $this->generalSettings->aws_key;
        $this->secret = $this->generalSettings->aws_secret;
        $this->bucket = $this->generalSettings->aws_bucket;
        $this->region = $this->generalSettings->aws_region;

$credentials = new \Aws\Credentials\Credentials($this->key, $this->secret);
        $this->s3 = new S3Client([
            'version' => 'latest',
            'region' => $this->region,
            'credentials' => $credentials
        ]);
    }

//upload file
    public function uploadFile($path)
    {
        if (!empty($path) && file_exists(FCPATH . $path)) {
            $this->putFileObject($path, FCPATH . $path);
            @unlink(FCPATH . $path);
        }
    }

//upload file direct
    public function uploadFileDirect($inputName, $path, $prefix = '')
    {
        if (!empty($inputName) && !empty($path)) {
            $orjName = $_FILES[$inputName]['name'];
            $name = pathinfo($orjName, PATHINFO_FILENAME);
            $ext = pathinfo($orjName, PATHINFO_EXTENSION);
            $uniqueName = $prefix . generateToken(true) . '.' . $ext;
            $this->putObjectDirect($path . $uniqueName, $_FILES[$inputName]['tmp_name']);
            return ['orjName' => $orjName, 'path' => $path . $uniqueName];
        }
    }

//put file object
    public function putFileObject($path)
    {
        if (!empty($path)) {
            $this->putObject($path, FCPATH . $path);
        }
    }

//dowbload file
    function downloadFile($fileName, $filePath)
    {
        header('Content-Disposition: attachment; filename=' . $fileName);
        readfile(getAWSBaseURL() . $filePath);
        exit();
    }

//delete file
    public function deleteFile($path)
    {
        if (!empty($path)) {
            $this->deleteObject($path);
        }
    }

//put object
    public function putObject($key, $tempPath)
    {
        if (file_exists($tempPath)) {
            try {
                $file = fopen($tempPath, 'r');
                $this->s3->putObject([
                    'Bucket' => $this->bucket,
                    'Key' => $key,
                    'Body' => $file,
                    'ACL' => 'public-read'
                ]);
                fclose($file);
                return true;
            } catch (S3Exception $e) {
                echo $e->getMessage() . PHP_EOL;
            }
        }
    }

//put object direct
    public function putObjectDirect($key, $tempPath)
    {
        $this->s3->putObject([
            'Bucket' => $this->bucket,
            'Key' => $key,
            'Body' => fopen($tempPath, 'rb'),
            'ACL' => 'public-read'
        ]);
    }

//delete object
    public function deleteObject($key)
    {
        if (!empty($key)) {
            try {
                $this->s3->deleteObject([
                    'Bucket' => $this->bucket,
                    'Key' => $key
                ]);
            } catch (S3Exception $e) {
                echo $e->getMessage() . PHP_EOL;
            }
        }
    }

}