hehele/hyperf_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat : oss callback

Browse Source
This commit is contained in:
ctexthuang
2024-10-31 17:57:49 +08:00
parent 2d8f35ddf0
commit c4a59d68f8
12 changed files with 435 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
app/Cache/Redis/Common/CommonRedisKey.php
View File

@@ -12,4 +12,22 @@ class CommonRedisKey
{
return '__system:address:list:'.$type;
}
/**
* 待删除oss文件队列-根据url
* @return string
*/
public static function getDeleteOssImgListByUrl(): string
{
return '__system:deleteOssImgList:url';
}
/**
* 待删除oss文件队列-根据id
* @return string
*/
public static function getDeleteOssImgListByOssId(): string
{
return '__system:deleteOssImgList:oss_id';
}
}

2
app/Cache/Redis/RedisCache.php
View File

@@ -421,7 +421,7 @@ class RedisCache
* @throws NotFoundExceptionInterface
* @throws RedisException
*/
public function lPush(string $key, string $data, string $poolName = 'default')
public function lPush(string $key, string $data, string $poolName = 'default'): false|int|Redis
{
return $this->getRedis($poolName)->lPush($key, $data);
}

3
app/Controller/Admin/ConfigController.php
View File

@@ -7,11 +7,10 @@ namespace App\Controller\Admin;
use App\Controller\AbstractController;
use App\Middleware\Admin\JwtAuthMiddleware;
use App\Service\Admin\System\ConfigService;
use App\Service\System\SystemService;
use App\Service\Admin\System\SystemService;
use Hyperf\HttpServer\Annotation\Controller;
use Hyperf\HttpServer\Annotation\Middlewares;
use Hyperf\HttpServer\Annotation\RequestMapping;
use Hyperf\Validation\Annotation\Scene;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
use RedisException;

23
app/Cron/Oss/OssDelByDisableTask.php Normal file
View File

@@ -0,0 +1,23 @@
<?php
/**
* This crontab file is part of item.
*
* @author ctexthuang
* @contact ctexthuang@qq.com
*/
declare(strict_types=1);
namespace App\Cron\Oss;
use Hyperf\Crontab\Annotation\Crontab;
#[Crontab(rule: "* * * * *", name: "OssDelByDisableTask", singleton: true , callback: "execute", memo: "这是一个示例的定时任务")]
class OssDelByDisableTask
{
public function execute()
{
//todo Write logic
var_dump(date('Y-m-d H:i:s', time()));
}
}

23
app/Cron/Oss/OssDelByOssIdTask.php Normal file
View File

@@ -0,0 +1,23 @@
<?php
/**
* This crontab file is part of item.
*
* @author ctexthuang
* @contact ctexthuang@qq.com
*/
declare(strict_types=1);
namespace App\Cron\Oss;
use Hyperf\Crontab\Annotation\Crontab;
#[Crontab(rule: "* * * * *", name: "OssDelByOssIdTask", singleton: true , callback: "execute", memo: "这是一个示例的定时任务")]
class OssDelByOssIdTask
{
public function execute()
{
//todo Write logic
var_dump(date('Y-m-d H:i:s', time()));
}
}

23
app/Cron/Oss/OssDelByUrlTask.php Normal file
View File

@@ -0,0 +1,23 @@
<?php
/**
* This crontab file is part of item.
*
* @author ctexthuang
* @contact ctexthuang@qq.com
*/
declare(strict_types=1);
namespace App\Cron\Oss;
use Hyperf\Crontab\Annotation\Crontab;
#[Crontab(rule: "* * * * *", name: "OssDelByUrlTask", singleton: true , callback: "execute", memo: "这是一个示例的定时任务")]
class OssDelByUrlTask
{
public function execute()
{
//todo Write logic
var_dump(date('Y-m-d H:i:s', time()));
}
}

14
app/Lib/Log.php
View File

@@ -83,6 +83,20 @@ class Log
$this->getLogger($name,$group)->error($msg,$content);
}
/**
* callback 请求日志
* @param $msg
* @param string $name
* @param string $group
* @return void
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/
function callbackLog($msg, string $name = 'info', string $group = 'callback'): void
{
$this->getLogger($name,$group)->info($msg);
}
/**
* admin 请求日志
* @param $msg

2
app/Service/System/SystemService.php → app/Service/Admin/System/SystemService.php
View File

@@ -8,7 +8,7 @@
declare(strict_types=1);
namespace App\Service\System;
namespace App\Service\Admin\System;
use App\Cache\Redis\Common\CityCache;
use App\Constants\Common\CityCode;

311
app/Service/Common/OssCallbackService.php Normal file
View File

@@ -0,0 +1,311 @@
<?php
/**
* This service file is part of item.
*
* @author ctexthuang
* @contact ctexthuang@qq.com
*/
declare(strict_types=1);
namespace App\Service\Common;
use AlibabaCloud\SDK\Sts\V20150401\Sts;
use App\Cache\Redis\Common\CommonRedisKey;
use App\Cache\Redis\RedisCache;
use App\Exception\AdminException;
use App\Lib\AdminReturn;
use App\Lib\Log;
use App\Service\ServiceTrait\Common\AliStsTrait;
use Exception;
use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Contract\RequestInterface;
use OSS\Core\OssException;
use OSS\OssClient;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
use function Hyperf\Config\config;
class OssCallbackService
{
use AliStsTrait;
/**
* 请求对象
* @var RequestInterface
*/
#[Inject]
protected RequestInterface $request;
/**
* @var AdminReturn
*/
#[Inject]
protected AdminReturn $adminReturn;
/**
* @var Log
*/
#[Inject]
protected Log $log;
/**
* @var RedisCache
*/
#[Inject]
protected RedisCache $redisCache;
/**
* 请求的值解析字段
* @var mixed
*/
private mixed $data;
/**
* oss连接类
* @var OssClient
*/
protected OssClient $ossClient;
/**
* 空间
* @var string
*/
protected string $bucket;
/**
* 文件的类型
* @var string
*/
private string $mimeType;
/**
* 文件名字
* @var string
*/
private string $fileName;
/**
* 新的文件放置区域
* @var string
*/
private string $newObjectPath;
/**
* 新的id
* @var int
*/
private int $newId;
/**
* 允许的文件夹
* @var array|string[]
*/
private array $allowType = [
'admin_avatar',
'avatar',
'menu',
];
/**
* OssCallbackService constructor.
*/
public function __construct()
{
$this->ossClient = new OssClient(
config('ali.access_key_id'),
config('ali.access_key_secret'),
config('oss.sts_endpoint')
);
$this->bucket = config('ali.bucket');
}
/**
* @return array
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
* @throws \RedisException
*/
public function process(): array
{
try {
//记录回调内容
$this->filePutContents();
//检测直传type
$this->checkType();
//检测文件格式
$this->checkMimeType();
//获取新文件名
$this->getNewFileName();
//复制旧文件到指定文件夹
try {
$this->ossClient->copyObject($this->bucket, urldecode($this->data['object']), $this->bucket, $this->newObjectPath);
} catch (OssException $e) {
throw new Exception($e->getMessage());
}
date_default_timezone_set('Asia/Shanghai');
//增加oss object数据
$this->addOssObjectData();
//删除旧的文件
$this->deleteOssObject();
}catch (Exception $exception){
$this->deleteOssObject();
throw new AdminException($exception->getMessage());
}
$this->log->callbackLog(__CLASS__.':oss回调完成'.json_encode($this->data),'oss');
return $this->adminReturn->success('上传成功',[
'id' => $this->newId,
'url' => config('ali.oss_url') . $this->newObjectPath, 'old_file_name' => $this->fileName
]);
}
/**
* 记录回调内容
* @return void
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/
private function filePutContents(): void
{
$this->data = $this->request->all();
$this->log->callbackLog(__CLASS__.':oss回调'.json_encode($this->data),'oss');
}
/**
* 检测直传type
* @return void
* @throws Exception
*/
private function checkType(): void
{
if (!in_array($this->data['type'], $this->allowType)) {
throw new Exception('上传类型错误');
}
}
/**
* 检测文件格式
* @return void
* @throws Exception
*/
private function checkMimeType(): void
{
$mimeType = explode('/', $this->data['mimeType']);
switch ($this->data['mimeType']) {
case 'text/plain':
if ($mimeType[0] != 'text') {
throw new Exception("不允许此格式文件");
}
$this->mimeType = 'txt';
break;
default:
if (!in_array($mimeType[1], ['mp3', 'jpeg', 'jpg', 'png', 'gif', 'mp4', 'mpeg','aac', 'quicktime'])) {
throw new Exception("不允许此格式文件");
}
$this->mimeType = $mimeType[1];
}
}
/**
* 获取新文件名
* @return void
*/
private function getNewFileName(): void
{
$this->fileName = explode('/', urldecode($this->data['object']))[1];
switch ($this->data['type'])
{
case 'video_main':
$newFileName = date('YmdHis').md5($this->data['type'].$this->fileName);
$this->newObjectPath = sprintf("upload/%s/%s/%s/%s.%s", 'admin', $this->data['type'], $this->data['library_dir'],$newFileName,$this->mimeType);
break;
case 'avatar':
$newFileName = date('YmdHis').md5($this->data['type'].$this->fileName);
$this->newObjectPath = sprintf("upload/%s/%s/%s/%s.%s", 'user', $this->data['user_id'], $this->data['type'],$newFileName,$this->mimeType);
break;
default:
$newFileName = md5(date('YmdHis').$this->data['type'].$this->fileName);
$newMimeType = $this->mimeType;
if ($this->mimeType == 'quicktime') {
$newMimeType = 'mov';
}
$this->newObjectPath = sprintf("upload/%s/%s/%s.%s",'admin', $this->data['type'], $newFileName,$newMimeType);
break;
}
}
/**
* 增加oss object数据
* @return void
*/
private function addOssObjectData(): void
{
$type = 0;
switch ($this->mimeType) {
case 'jpg':
case 'jpeg':
case 'png':
case 'bmp':
$type = 1;
break;
case 'mp3':
$type = 2;
break;
case 'mp4':
case 'swf':
$type = 3;
break;
}
// $ossObjectModel = new OssObject();
//
// $ossObjectModel->url = $this->newObjectPath;
//// $ossObjectModel->url = urldecode($this->data['object']);
// $ossObjectModel->width = $this->data['imageInfo_width'] ?? 0;
// $ossObjectModel->height = $this->data['imageInfo_height'] ?? 0;
// $ossObjectModel->audio_second = $this->data['audio_second'] ?? 0;
// $ossObjectModel->video_duration = $this->data['video_duration'] ?? 0;
// $ossObjectModel->size = $this->data['size'] ?? 0;
//
// $ossObjectModel->type = $type;
//
// if (!$ossObjectModel->save()){
// throw new AdminException('保存图片失败');
// }
// $this->newId = $ossObjectModel->id;
}
/**
* @return void
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
* @throws \RedisException
*/
private function deleteOssObject(): void
{
//删除旧的文件
$this->redisCache->lPush(CommonRedisKey::getDeleteOssImgListByUrl(), $this->data['object']);
}
}

2
app/Service/ServiceTrait/Common/AliStsTrait.php
View File

@@ -52,7 +52,7 @@ trait AliStsTrait
* @throws NotFoundExceptionInterface
*/
public function getAliStsControls($payload){
$client = self::createClient();
$client = $this->createClient();
$assumeRoleRequest = new AssumeRoleRequest($payload);
$runtime = new RuntimeOptions([]);
try {

18
config/autoload/logger.php
View File

@@ -99,4 +99,22 @@ return [
],
],
],
'callback' => [
'handler' => [
'class' => Monolog\Handler\RotatingFileHandler::class,
'constructor' => [
'filename' => BASE_PATH . '/runtime/logs/callback/hyperf.log',
'level' => Monolog\Logger::DEBUG,
],
],
'formatter' => [
'class' => Monolog\Formatter\LineFormatter::class,
'constructor' => [
'format' => null,
'dateFormat' => null,
'allowInlineLineBreaks' => true,
'ignoreEmptyContextAndExtra' => true,
],
],
],
];

2
sync/http/admin/address.http
View File

@@ -37,7 +37,7 @@ Content-Type: application/json
Authorization: Bearer {{admin_token}}
###城市列表 - 联表数据
GET {{host}}/admin/config/system/address_list?deep=1&pid=82
GET {{host}}/admin/config/system/address_list?deep=1&pid=14
Content-Type: application/json
Authorization: Bearer {{admin_token}}