cunkebao_v3/Server/application/common/controller/Attachment.php

<?php
namespace app\common\controller;

use think\Controller;
use think\facade\Request;
use app\common\model\Attachment as AttachmentModel;
use app\common\util\AliyunOSS;

class Attachment extends Controller
{
    /**
     * 上传文件
     * @return \think\response\Json
     */
    public function upload()
    {
        try {
            // 获取上传文件
            $file = Request::file('file');
            if (!$file) {
                return json([
                    'code' => 400,
                    'msg' => '请选择要上传的文件'
                ]);
            }
            
            // 验证文件
            $validate = \think\facade\Validate::rule([
                'file' => [
                    'fileSize' => 50485760, // 50MB
                    'fileExt' => 'jpg,jpeg,png,gif,webp,doc,docx,pdf,zip,rar,mp4,mp3,csv,xlsx,xls,ppt,pptx,txt',
                ]
            ]);
            
            if (!$validate->check(['file' => $file])) {
                return json([
                    'code' => 400,
                    'msg' => $validate->getError()
                ]);
            }
            
            // 生成文件hash
            $hashKey = md5_file($file->getRealPath());
            
            // 检查文件是否已存在
            $existFile = AttachmentModel::getByHashKey($hashKey);
            if ($existFile) {
                return json([
                    'code' => 200,
                    'msg' => '文件已存在',
                    'data' => [
                        'id' => $existFile['id'],
                        'name' => $existFile['name'],
                        'url' => $existFile['source'],
                        'size' => isset($existFile['size']) ? $existFile['size'] : 0
                    ]
                ]);
            }

       
            
            // 生成OSS对象名称
            $objectName = AliyunOSS::generateObjectName($file->getInfo('name'));
            
            // 上传到OSS
            $result = AliyunOSS::uploadFile($file->getRealPath(), $objectName);

            // OSS 不可用时回落本地 public/uploads（Docker 本地开发）
            if (!$result['success']) {
                $local = $this->saveLocalUpload($file, $hashKey);
                if ($local) {
                    $result = $local;
                } else {
                    return json([
                        'code' => 500,
                        'msg' => '文件上传失败：' . ($result['error'] ?? 'OSS 不可用')
                    ]);
                }
            }
            
            if (empty($result['success'])) {
                return json([
                    'code' => 500,
                    'msg' => '文件上传失败'
                ]);
            }
            
            // 保存到数据库
            $attachmentData = [
                'name' => Request::param('name') ?: $file->getInfo('name'),
                'hash_key' => $hashKey,
                'server' => 'aliyun_oss',
                'source' => $result['url'],
                'size' => $result['size'],
                'suffix' => pathinfo($file->getInfo('name'), PATHINFO_EXTENSION),
                // 兼容 ck_attachments.scene 非空约束：默认获客海报场景
                'scene' => (int)Request::param('scene', 1),
            ];
            
            $attachment = AttachmentModel::addAttachment($attachmentData);
            
            if (!$attachment) {
                return json([
                    'code' => 500,
                    'msg' => '保存附件信息失败'
                ]);
            }
            
            return json([
                'code' => 200,
                'msg' => '上传成功',
                'data' => [
                    'id' => $attachment->id,
                    'name' => $attachmentData['name'],
                    'url' => $attachmentData['source'],
                    'size' => $attachmentData['size']
                ]
            ]);
            
        } catch (\Exception $e) {
            return json([
                'code' => 500,
                'msg' => '上传失败：' . $e->getMessage()
            ]);
        }
    }

    /**
     * 本地存储回落（OSS 失败 / 离线 Docker）
     */
    private function saveLocalUpload($file, string $hashKey): ?array
    {
        try {
            $subdir = date('Y/m/d');
            $dir = root_path() . 'public/uploads/' . $subdir;
            if (!is_dir($dir) && !mkdir($dir, 0755, true) && !is_dir($dir)) {
                return null;
            }
            $origName = $file->getInfo('name') ?: 'upload.bin';
            $ext = pathinfo($origName, PATHINFO_EXTENSION) ?: 'bin';
            $filename = $hashKey . '.' . $ext;
            $target = $dir . '/' . $filename;
            if (!copy($file->getRealPath(), $target)) {
                return null;
            }
            $relative = '/uploads/' . $subdir . '/' . $filename;
            $domain = rtrim(Request::domain(), '/');
            return [
                'success' => true,
                'url' => $domain . $relative,
                'size' => filesize($target),
            ];
        } catch (\Throwable $e) {
            return null;
        }
    }
    
    /**
     * 获取附件信息
     * @param int $id 附件ID
     * @return \think\response\Json
     */
    public function info($id)
    {
        try {
            $attachment = AttachmentModel::find($id);
            
            if (!$attachment) {
                return json([
                    'code' => 404,
                    'msg' => '附件不存在'
                ]);
            }
            
            return json([
                'code' => 200,
                'msg' => '获取成功',
                'data' => $attachment
            ]);
            
        } catch (\Exception $e) {
            return json([
                'code' => 500,
                'msg' => '获取失败：' . $e->getMessage()
            ]);
        }
    }
}