<?php

namespace app\common\library;

use app\common\exception\UploadException;
use app\common\model\Attachment;
use app\common\service\OssService;
use fast\Random;
use think\File;
use think\Hook;

/**
 * OSS 文件上传
 * 本地只落地到 runtime/temp（PHP 运行用户可写，不依赖 public/uploads 的写权限），
 * 上传到 OSS 后删除临时文件，附件记录保存 OSS 路径
 */
class OssUpload extends Upload
{
    /**
     * 上传到 OSS（普通上传与分片合并共用）
     * @param string|null $savekey 未使用，OSS 路径固定为 uploads/{Ymd}/{随机串}/{原文件名}
     * @return \app\common\model\attachment|\think\Model
     * @throws UploadException
     */
    public function upload($savekey = null)
    {
        if (empty($this->file)) {
            throw new UploadException(__('No file upload or server upload limit exceeded'));
        }

        $this->checkSize();
        $this->checkExecutable();
        $this->checkMimetype();
        $this->checkImage();

        $tempDir = RUNTIME_PATH . 'temp' . DS;
        if (!is_dir($tempDir) && !@mkdir($tempDir, 0775, true) && !is_dir($tempDir)) {
            throw new UploadException('上传临时目录创建失败或无写权限：' . $tempDir);
        }
        $tempName = Random::alnum(16) . '.' . $this->fileInfo['suffix'];
        $tempFile = $tempDir . $tempName;

        $sha1 = $this->file->hash();

        if ($this->merging) {
            if (!$this->file->check()) {
                throw new UploadException($this->file->getError());
            }
            $sourceFile = $this->file->getRealPath() ?: $this->file->getPathname();
            $info = $this->file->getInfo();
            $this->file = null;
            if (!@rename($sourceFile, $tempFile)) {
                throw new UploadException('分片文件合并失败');
            }
            $file = new File($tempFile);
            $file->setSaveName($tempName)->setUploadInfo($info);
        } else {
            $file = $this->file->move($tempDir, $tempName);
            if (!$file) {
                throw new UploadException($this->file->getError());
            }
        }
        $this->file = $file;

        $filename = mb_substr(htmlspecialchars(strip_tags($this->fileInfo['name'])), 0, 100);
        $object = 'uploads/' . date('Ymd/') . Random::alnum(16) . '/' . $filename;
        try {
            OssService::instance()->uploadFile($tempFile, $object);
        } catch (\Exception $e) {
            throw new UploadException($e->getMessage());
        } finally {
            @unlink($tempFile);
        }

        $category = request()->post('category');
        $category = array_key_exists($category, config('site.attachmentcategory') ?? []) ? $category : '';
        $auth = Auth::instance();
        $params = [
            'admin_id'    => (int)session('admin.id'),
            'user_id'     => (int)$auth->id,
            'filename'    => $filename,
            'category'    => $category,
            'filesize'    => $this->fileInfo['size'],
            'imagewidth'  => $this->fileInfo['imagewidth'],
            'imageheight' => $this->fileInfo['imageheight'],
            'imagetype'   => $this->fileInfo['suffix'],
            'imageframes' => 0,
            'mimetype'    => $this->fileInfo['type'],
            'url'         => '/' . $object,
            'uploadtime'  => time(),
            'storage'     => 'oss',
            'sha1'        => $sha1,
            'extparam'    => '',
        ];
        $attachment = new Attachment();
        $attachment->data(array_filter($params));
        $attachment->save();

        Hook::listen('upload_after', $attachment);
        return $attachment;
    }
}