mirror of
https://github.com/droomo/AliOssForTypecho.git
synced 2024-12-25 23:40:09 +08:00
771 lines
36 KiB
PHP
771 lines
36 KiB
PHP
<?php
|
||
|
||
require_once 'aliyun-oss-php-sdk-2.4.3/autoload.php';
|
||
|
||
use OSS\OssClient;
|
||
use OSS\Core\OssException;
|
||
|
||
/**
|
||
* AliyunOSS储存Typecho上传附件.
|
||
*
|
||
* @package AliOssForTypecho
|
||
* @author droomo.
|
||
* @version 1.1.8
|
||
* @link https://www.droomo.top/
|
||
*/
|
||
|
||
class AliOssForTypecho_Plugin extends Typecho_Widget implements Typecho_Plugin_Interface {
|
||
|
||
const UPLOAD_DIR = 'usr/uploads/';//上传文件目录，相对网站根目录
|
||
const LOG_SUFFIX = '__oss-plugin-log/';//日志目录，放置于UPLOAD_DIR下
|
||
|
||
public function api_version() {
|
||
echo __FUNCTION__;
|
||
var_dump (self::get_plugin_information()['version']);
|
||
}
|
||
public function api_log() {
|
||
if ($_SERVER['REQUEST_METHOD'] == 'GET') {
|
||
} else {
|
||
}
|
||
}
|
||
|
||
public static function get_plugin_information() {
|
||
Typecho_Widget::widget('Widget_Plugins_List@activated', 'activated=1')->to($activatedPlugins);
|
||
$activatedPlugins = json_decode(json_encode($activatedPlugins),true);
|
||
$plugins_list = $activatedPlugins['stack'];
|
||
$plugins_info = array();
|
||
for ($i = 0; $i < count($plugins_list); $i++){
|
||
if($plugins_list[$i]['title'] == 'AliOssForTypecho'){
|
||
$plugins_info = $plugins_list[$i];
|
||
break;
|
||
}
|
||
}
|
||
if (count($plugins_info) < 1) {
|
||
return false;
|
||
}
|
||
return $plugins_info;
|
||
}
|
||
|
||
|
||
/**
|
||
* 激活插件方法,如果激活失败,直接抛出异常
|
||
*
|
||
* @access public
|
||
* @return void
|
||
* @throws Typecho_Plugin_Exception
|
||
*/
|
||
public static function activate() {
|
||
Typecho_Plugin::factory('Widget_Upload')->uploadHandle = array('AliOssForTypecho_Plugin', 'uploadHandle');
|
||
Typecho_Plugin::factory('Widget_Upload')->modifyHandle = array('AliOssForTypecho_Plugin', 'modifyHandle');
|
||
Typecho_Plugin::factory('Widget_Upload')->deleteHandle = array('AliOssForTypecho_Plugin', 'deleteHandle');
|
||
Typecho_Plugin::factory('Widget_Upload')->attachmentHandle = array('AliOssForTypecho_Plugin', 'attachmentHandle');
|
||
Typecho_Plugin::factory('Widget_Upload')->attachmentDataHandle = array('AliOssForTypecho_Plugin', 'attachmentDataHandle');
|
||
|
||
Helper::addRoute('__alioss_for_tp_plugin_version__', '/__alioss_for_tp_plugin_api__/version', 'AliOssForTypecho_Plugin', 'api_version');
|
||
Helper::addRoute('__alioss_for_tp_plugin_log__', '/__alioss_for_tp_plugin_api__/log', 'AliOssForTypecho_Plugin', 'api_log');
|
||
|
||
return _t('启用成功，请进行相应设置！');
|
||
}
|
||
|
||
/**
|
||
* 禁用插件方法,如果禁用失败,直接抛出异常
|
||
*
|
||
* @static
|
||
* @access public
|
||
* @return void
|
||
* @throws Typecho_Plugin_Exception
|
||
*/
|
||
public static function deactivate() {
|
||
Helper::removeRoute('__alioss_for_tp_plugin_version__');
|
||
Helper::removeRoute('__alioss_for_tp_plugin_log__');
|
||
}
|
||
|
||
/**
|
||
* 获取插件配置面板
|
||
*
|
||
* @access public
|
||
* @param Typecho_Widget_Helper_Form $form 配置面板
|
||
* @return void
|
||
*/
|
||
public static function config(Typecho_Widget_Helper_Form $form) {
|
||
$upload_root = Typecho_Common::url(defined('__TYPECHO_UPLOAD_DIR__') ? __TYPECHO_UPLOAD_DIR__ : self::UPLOAD_DIR,
|
||
defined('__TYPECHO_UPLOAD_ROOT_DIR__') ? __TYPECHO_UPLOAD_ROOT_DIR__ : __TYPECHO_ROOT_DIR__);
|
||
|
||
$log_file_name = $upload_root . self::LOG_SUFFIX . 'error.log';
|
||
|
||
if (is_writable($upload_root)) {
|
||
$log_content = '恭喜！暂无错误日志产生，请继续保持维护～';
|
||
$log_color = '#009900';
|
||
|
||
if (!file_exists($log_file_name)) {
|
||
self::makeUploadDir($upload_root . self::LOG_SUFFIX);
|
||
fopen($log_file_name, 'w');
|
||
if (!file_exists($log_file_name)) {
|
||
$log_content = '无法创建日志文件，请检查权限设置！！！开启SELinux的用户注意合理配置权限！';
|
||
$log_color = '#f00000';
|
||
}
|
||
} else {
|
||
try {
|
||
$content = file_get_contents($log_file_name);
|
||
if ($content) {
|
||
$log_content = $content;
|
||
$log_color = '#dd0000';
|
||
}
|
||
} catch (Exception $e) {
|
||
$log_content = '注意！无法读取日志文件，请检查文件状态！';
|
||
$log_color = '#f00000';
|
||
}
|
||
}
|
||
} else {
|
||
$log_content = '！！！注意！！！
|
||
当前网站上传目录无写入权限，无法记录日志！
|
||
请给路径 '.$upload_root.' 赋予写入权限。开启SELinux的用户注意合理配置权限。';
|
||
$log_color = '#f00000';
|
||
}
|
||
?>
|
||
<div>
|
||
<h3>插件使用说明</h3>
|
||
<ol>
|
||
<li>插件基于<a href="https://github.com/aliyun/aliyun-oss-php-sdk/releases/tag/v2.3.1">aliyun-oss-php-sdk Release 2.3.1</a>开发，
|
||
若以后SDK开发包更新导致插件不可用，请到 <a target="_blank" href="https://www.droomo.top/AliOssForTypecho.html">我的博客^-^</a>获取新版本插件，如果我还用typecho、阿里云OSS就会更新。<br/></li>
|
||
<li>为保证正确记录日志，请赋予以下目录写权限：<code style="color:#333;font-size:12px;"><?php echo $upload_root;?></code>，并定期查阅日志处理事件错误。开启SELinux的用户注意合理配置权限。</li>
|
||
<li>当文件成功上传到OSS，但保存到服务器失败时，总体进度会显示失败。在OSS中的文件不会自动删除，请根据错误日志自行处理。</li>
|
||
<li>运行在云应用引擎上的站点“在服务器保留备份”选项无效，且无法记录日志。</li>
|
||
<li>旧版本Typecho存在无法上传大写扩展名文件的bug，请更新Typecho程序。<br/></li>
|
||
<li>如有问题或建议请到 <a target="_blank" href="https://www.droomo.top/AliOssForTypecho.html">我的博客https://www.droomo.top/AliOssForTypecho.html</a> 留言</li>
|
||
</ol>
|
||
<p>以下是本插件产生的错误日志，请定期查看并处理：</p>
|
||
<p>日志文件是 <span style="color:#666;font-sieze:8px"><?php echo $log_file_name;?><span></p>
|
||
<div style="width:98%;margin: 0 auto">
|
||
<textarea style="color:<?php echo $log_color;?>;height:160px;width:100%;"><?php echo $log_content;?></textarea></div>
|
||
</div>
|
||
<?php
|
||
$buketName = new Typecho_Widget_Helper_Form_Element_Text('bucketName', NULL, null,
|
||
_t('Bucket名称'), _t('请填写Buket名称'));
|
||
$form->addInput($buketName->addRule('required', _t('必须填写Bucket名称')));
|
||
|
||
$accessKeyId = new Typecho_Widget_Helper_Form_Element_Text('accessKeyId', NULL, null,
|
||
_t('ACCESS KEY ID'), _t('请填写ACCESS KEY ID'));
|
||
$form->addInput($accessKeyId->addRule('required', _t('必须填写ACCESS KEY ID')));
|
||
|
||
$accessKeySecret = new Typecho_Widget_Helper_Form_Element_Text('accessKeySecret', NULL, null,
|
||
_t('ACCESS KEY SECRET'), _t('请填写请填写ACCESS KEY SECRET'));
|
||
$form->addInput($accessKeySecret->addRule('required', _t('必须填写ACCESS_KEY')));
|
||
|
||
$endPoint = new Typecho_Widget_Helper_Form_Element_Select('endPoint',
|
||
array(
|
||
"oss-cn-hangzhou" => "华东1（杭州）oss-cn-hangzhou",
|
||
"oss-cn-shanghai" => "华东2（上海）oss-cn-shanghai",
|
||
"oss-cn-qingdao" => "华北1（青岛）oss-cn-qingdao",
|
||
"oss-cn-beijing" => "华北2（北京）oss-cn-beijing",
|
||
"oss-cn-zhangjiakou" => "华北3（张家口）oss-cn-zhangjiakou",
|
||
"oss-cn-huhehaote" => "华北5（呼和浩特）oss-cn-huhehaote",
|
||
"oss-cn-wulanchabu" => "华北6（乌兰察布）oss-cn-wulanchabu",
|
||
"oss-cn-shenzhen" => "华南1（深圳）oss-cn-shenzhen",
|
||
"oss-cn-heyuan" => "华南2（河源）oss-cn-heyuan",
|
||
"oss-cn-chengdu" => "西南1（成都）oss-cn-chengdu",
|
||
"oss-cn-hongkong" => "中国（香港）oss-cn-hongkong",
|
||
"oss-us-west-1" => "美国西部1（硅谷）oss-us-west-1",
|
||
"oss-us-east-1" => "美国东部1（弗吉尼亚）oss-us-east-1",
|
||
"oss-ap-southeast-1" =>"亚太东南1（新加坡）oss-ap-southeast-1",
|
||
"oss-ap-southeast-2" =>"亚太东南2（悉尼）oss-ap-southeast-2",
|
||
"oss-ap-southeast-3" =>"亚太东南3（吉隆坡）oss-ap-southeast-3",
|
||
"oss-ap-southeast-5" =>"亚太东南5（雅加达）oss-ap-southeast-5",
|
||
"oss-ap-northeast-1" =>"亚太东北1（日本）oss-ap-northeast-1",
|
||
"oss-ap-south-1" => "亚太南部1（孟买）oss-ap-south-1",
|
||
"oss-eu-central-1" => "欧洲中部1（法兰克福）oss-eu-central-1",
|
||
"oss-eu-west-1" => "英国（伦敦）oss-eu-west-1",
|
||
"oss-me-east-1" => "中东东部1（迪拜）oss-me-east-1",
|
||
"other" => '自定义'
|
||
),
|
||
'oss-cn-qingdao',
|
||
_t('区域选择（若区域不在列表中则选择自定义，然后填写区域）'), '');
|
||
$form->addInput($endPoint);
|
||
|
||
$endPointType = new Typecho_Widget_Helper_Form_Element_Select('endPointType',
|
||
array(
|
||
".aliyuncs.com" => '外网',
|
||
"-internal.aliyuncs.com" => '内网',
|
||
),
|
||
'.aliyuncs.com', '<label class="AliossForTypecho-mark-other-endpoint-hide">选择服务器与OSS连接方式</label>',
|
||
'<span class="AliossForTypecho-mark-other-endpoint-hide">在你了解两种连接方式的不同作用的情况下修改此选项</span>');
|
||
$form->addInput($endPointType);
|
||
|
||
$otherEndPoint = new Typecho_Widget_Helper_Form_Element_Text('otherEndPoint', NULL, '',
|
||
'<label class="AliossForTypecho-mark-other-endpoint-show">自定义EndPoint</label>', '<span class="AliossForTypecho-mark-other-endpoint-show">
|
||
填写全部Endpoint地址，通常以\'.aliyuncs.com\'或\'-internal.aliyuncs.com\'结尾。开头不包含http://，结尾不包含"/"。<br/>例如"oss-cn-qingdao.aliyuncs.com"</span>');
|
||
$form->addInput($otherEndPoint);
|
||
|
||
$userDir = new Typecho_Widget_Helper_Form_Element_Text('userDir', NULL, 'typecho/',
|
||
_t('要储存的路径'), _t('请填写文件储存的路径（相对OSS根目录），以字母或数字开头，以"/"结尾。留空则上传到根目录。'));
|
||
$form->addInput($userDir);
|
||
|
||
$cdnUrl = new Typecho_Widget_Helper_Form_Element_Text('cdnUrl', NULL, '',
|
||
_t('自定义（CDN）域名'), '请填写自定义域名，留空则使用外网Endpoint访问，以http://或https://开头，以"/"结尾');
|
||
$form->addInput($cdnUrl);
|
||
|
||
$diy_style = new Typecho_Widget_Helper_Form_Element_Text('des', NULL, '', _t('默认自定义样式'),
|
||
_t('通过后缀的方式使用自定义样式，留空为不使用。使用详情见<a target="_blank" href="https://help.aliyun.com/document_detail/48884.html">阿里云文档</a>'));
|
||
$form->addInput($diy_style);
|
||
|
||
$form->addInput(new Typecho_Widget_Helper_Form_Element_Radio('ifLoaclSave', array( "1" => '保留', "0" => '不保留' ), "1",
|
||
_t('在服务器保留备份'), _t('是否在服务器保留备份')));
|
||
?>
|
||
<script>
|
||
window.onload = function() {
|
||
(function() {
|
||
var AliossForTypecho_otherSelected = document.getElementsByName("endPoint")[0].value === "other";
|
||
var AliossForTypecho_otherEndpointShowingTags = document.getElementsByClassName("AliossForTypecho-mark-other-endpoint-show");
|
||
var AliossForTypecho_otherEndpointHiddingTags = document.getElementsByClassName("AliossForTypecho-mark-other-endpoint-hide");
|
||
var AliossForTypecho_otherEndPointInputTag = document.getElementsByName("otherEndPoint")[0];
|
||
var AliossForTypecho_endPointTypeInputTag = document.getElementsByName("endPointType")[0];
|
||
var AliossForTypecho_loadLabels = function () {
|
||
var AliossForTypecho_s1 = null, AliossForTypecho_s2 = null;
|
||
if (AliossForTypecho_otherSelected) {
|
||
AliossForTypecho_s1 = "none";
|
||
AliossForTypecho_s2 = "block";
|
||
AliossForTypecho_otherEndPointInputTag.type = "text";
|
||
} else {
|
||
AliossForTypecho_s2 = "none";
|
||
AliossForTypecho_s1 = "block";
|
||
AliossForTypecho_otherEndPointInputTag.type = "hidden";
|
||
AliossForTypecho_endPointTypeInputTag.type = "";
|
||
}
|
||
AliossForTypecho_endPointTypeInputTag.style.display = AliossForTypecho_s1;
|
||
for (var AliossForTypecho_i = 0; AliossForTypecho_i < AliossForTypecho_otherEndpointShowingTags.length; AliossForTypecho_i++) {
|
||
AliossForTypecho_otherEndpointShowingTags[AliossForTypecho_i].style.display = AliossForTypecho_s2;
|
||
}
|
||
for (var AliossForTypecho_i = 0; AliossForTypecho_i < AliossForTypecho_otherEndpointHiddingTags.length; AliossForTypecho_i++) {
|
||
AliossForTypecho_otherEndpointHiddingTags[AliossForTypecho_i].style.display = AliossForTypecho_s1;
|
||
}
|
||
};
|
||
document.getElementsByName("endPoint")[0].onchange = function(e) {
|
||
AliossForTypecho_otherSelected = e.target.value === "other";
|
||
AliossForTypecho_loadLabels();
|
||
};
|
||
AliossForTypecho_loadLabels();
|
||
})();
|
||
}
|
||
</script>
|
||
<?php
|
||
}
|
||
|
||
/**
|
||
* 个人用户的配置面板
|
||
*
|
||
* @access public
|
||
* @param Typecho_Widget_Helper_Form $form
|
||
* @return void
|
||
*/
|
||
public static function personalConfig(Typecho_Widget_Helper_Form $form) {}
|
||
|
||
/**
|
||
* 上传文件处理函数
|
||
*
|
||
* @access public
|
||
* @param array $file 上传的文件
|
||
* @return mixed
|
||
*/
|
||
public static function uploadHandle($file) {
|
||
if (empty($file['name'])) {
|
||
return FALSE;
|
||
}
|
||
$ext = self::getExtentionName($file['name']);
|
||
if (!self::checkFileType($ext)) {
|
||
return FALSE;
|
||
}
|
||
if (isset($file['tmp_name'])) {
|
||
$content = file_get_contents($file['tmp_name']);
|
||
} else if (isset($file['bytes'])) {
|
||
$content = $file['bytes'];
|
||
} else {
|
||
return FALSE;
|
||
}
|
||
|
||
$upload_root = Typecho_Common::url(defined('__TYPECHO_UPLOAD_DIR__') ? __TYPECHO_UPLOAD_DIR__ : self::UPLOAD_DIR,
|
||
defined('__TYPECHO_UPLOAD_ROOT_DIR__') ? __TYPECHO_UPLOAD_ROOT_DIR__ : __TYPECHO_ROOT_DIR__);
|
||
|
||
$options = Typecho_Widget::widget('Widget_Options');
|
||
$user_dir = $options->plugin('AliOssForTypecho')->userDir;
|
||
$bucket_name = $options->plugin('AliOssForTypecho')->bucketName;
|
||
$end_point = 'http://' . (($options->plugin('AliOssForTypecho')->endPoint === "other") ?
|
||
$options->plugin('AliOssForTypecho')->otherEndPoint :
|
||
$options->plugin('AliOssForTypecho')->endPoint . $options->plugin('AliOssForTypecho')->endPointType);
|
||
$access_id = $options->plugin('AliOssForTypecho')->accessKeyId;
|
||
$access_key = $options->plugin('AliOssForTypecho')->accessKeySecret;
|
||
|
||
try {
|
||
$oss_client = new OssClient($access_id, $access_key, $end_point);
|
||
$oss_client->doesBucketExist($bucket_name);
|
||
} catch (Exception $e) {
|
||
$error = '错误：连接OSS Client实例失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
$save_on_server = $options->plugin('AliOssForTypecho')->ifLoaclSave;
|
||
|
||
$file_origin_name = self::getSafeName($file['name']);
|
||
$relative_path = date('Y/m/d/');
|
||
|
||
$remote_file_name = $user_dir . $relative_path . $file_origin_name;
|
||
|
||
if ($save_on_server === "1" && !Typecho_Common::isAppEngine()) {
|
||
|
||
$upload_root = Typecho_Common::url(defined('__TYPECHO_UPLOAD_DIR__') ? __TYPECHO_UPLOAD_DIR__ : self::UPLOAD_DIR,
|
||
defined('__TYPECHO_UPLOAD_ROOT_DIR__') ? __TYPECHO_UPLOAD_ROOT_DIR__ : __TYPECHO_ROOT_DIR__);
|
||
|
||
$local_file_name = $upload_root . $relative_path . $file_origin_name;
|
||
try{
|
||
$exist_on_oss = $oss_client->doesObjectExist($bucket_name, $remote_file_name);
|
||
$exist_on_server = file_exists($local_file_name);
|
||
} catch(OssException $e) {
|
||
$error = '错误：检查OSS或本地服务器中中是否存在同名文件时失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
if ($exist_on_oss || $exist_on_server) {
|
||
// find a name neither exist on oss nor the server
|
||
$pathinfo = pathinfo($file_origin_name);
|
||
for ($i = 1;; $i++) {
|
||
$file_origin_name = $pathinfo['filename'] . '(' . strval($i) . ').' . self::getExtentionName($file_origin_name);
|
||
$remote_file_name = $user_dir . $relative_path . $file_origin_name;
|
||
$local_file_name = $upload_root . $relative_path . $file_origin_name;
|
||
|
||
try{
|
||
$exist_on_oss = $oss_client->doesObjectExist($bucket_name, $remote_file_name);
|
||
$exist_on_server = file_exists($local_file_name);
|
||
} catch(OssException $e) {
|
||
$error = '错误：检查OSS或本地服务器中中是否存在同名文件时失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
if ($exist_on_oss || $exist_on_server) {
|
||
} else {
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
try{
|
||
$exist_on_oss = $oss_client->doesObjectExist($bucket_name, $remote_file_name);
|
||
} catch(OssException $e) {
|
||
$error = '错误：检查OSS中是否存在同名文件时失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
if ($exist_on_oss || $exist_on_server) {
|
||
// find a name not exist on oss
|
||
$pathinfo = pathinfo($file_origin_name);
|
||
for ($i = 1;; $i++) {
|
||
$file_origin_name = $pathinfo['filename'] . '(' . strval($i) . ').' . self::getExtentionName($file_origin_name);
|
||
$remote_file_name = $user_dir . $relative_path . $file_origin_name;
|
||
|
||
try{
|
||
$exist_on_oss = $oss_client->doesObjectExist($bucket_name, $remote_file_name);
|
||
} catch(OssException $e) {
|
||
$error = '错误：检查OSS中是否存在同名文件时失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
if (!$exist_on_oss) {
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
try{
|
||
$ali_response = $oss_client->putObject($bucket_name, $remote_file_name, $content);
|
||
} catch(OssException $e) {
|
||
$error = '错误：将文件储存到OSS失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
if (200 != $ali_response['info']['http_code']) {
|
||
$error = '错误：将文件储存到OSS时返回码不正常' . "\r\n" .
|
||
'错误码：' . $ali_response['info']['http_code'] . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
} else {
|
||
if ($save_on_server === "1" && !Typecho_Common::isAppEngine()) {
|
||
$file_dir_name = dirname($local_file_name);
|
||
$dir_exist = true;
|
||
|
||
if (!is_dir($file_dir_name) && !self::makeUploadDir($file_dir_name)) {
|
||
$dir_exist = false;
|
||
}
|
||
|
||
if ($dir_exist) {
|
||
if (!file_put_contents($local_file_name, $content)) {
|
||
$error = '错误：文件已保存到OSS，将文件储存到本地服务器时失败，请手动删除OSS上的文件，开启SELinux的用户注意合理配置权限。' . "\r\n" .
|
||
'文件路径：' . $local_file_name . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
} else {
|
||
$error = '错误：文件已保存到OSS，将文件储存到本地服务器时创建目录失败，请检查服务器权限设置，开启SELinux的用户注意合理配置权限。' . "\r\n" .
|
||
'无法创建路径：' . $file_dir_name . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
}
|
||
|
||
return array(
|
||
'name' => $file_origin_name,
|
||
'path' => $relative_path . $file_origin_name,
|
||
'size' => intval($ali_response['oss-requestheaders']['Content-Length']),
|
||
'type' => $ext,
|
||
'mime' => $ali_response['oss-requestheaders']['Content-Type']
|
||
);
|
||
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 修改文件处理函数
|
||
*
|
||
* @access public
|
||
* @param array $content 老文件
|
||
* @param array $file 新上传的文件
|
||
* @return mixed
|
||
*/
|
||
public static function modifyHandle($content, $file)
|
||
{
|
||
if (empty($file['name'])) {
|
||
return false;
|
||
}
|
||
$ext = self::getExtentionName($file['name']);
|
||
if ($content['attachment']->type != $ext) {
|
||
return false;
|
||
}
|
||
if (isset($file['tmp_name'])) {
|
||
$new_file_content = file_get_contents($file['tmp_name']);
|
||
} else if (isset($file['bytes'])) {
|
||
$new_file_content = $file['bytes'];
|
||
} else {
|
||
return false;
|
||
}
|
||
|
||
$options = Typecho_Widget::widget('Widget_Options');
|
||
$userDir = $options->plugin('AliOssForTypecho')->userDir;
|
||
$bucket_name = $options->plugin('AliOssForTypecho')->bucketName;
|
||
$end_point = 'http://' . (($options->plugin('AliOssForTypecho')->endPoint === "other") ?
|
||
$options->plugin('AliOssForTypecho')->otherEndPoint :
|
||
$options->plugin('AliOssForTypecho')->endPoint . $options->plugin('AliOssForTypecho')->endPointType);
|
||
$access_id = $options->plugin('AliOssForTypecho')->accessKeyId;
|
||
$access_key = $options->plugin('AliOssForTypecho')->accessKeySecret;
|
||
|
||
$path = $content['attachment']->path;
|
||
|
||
$remote_file_name = $userDir . $path;
|
||
|
||
$ifLoaclSave = $options->plugin('AliOssForTypecho')->ifLoaclSave;
|
||
$upload_root = Typecho_Common::url(defined('__TYPECHO_UPLOAD_DIR__') ? __TYPECHO_UPLOAD_DIR__ : self::UPLOAD_DIR,
|
||
defined('__TYPECHO_UPLOAD_ROOT_DIR__') ? __TYPECHO_UPLOAD_ROOT_DIR__ : __TYPECHO_ROOT_DIR__);
|
||
$local_file_name = $upload_root . $path;
|
||
|
||
if ($ifLoaclSave && (!is_writable($upload_root) || !is_writable($local_file_name))) {
|
||
$error = '错误：修改文件失败，旧文件无写权限，开启SELinux的用户注意合理配置权限。' . "\r\n" .
|
||
'本地文件：' . $local_file_name . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
try {
|
||
$oss_client = new OssClient($access_id, $access_key, $end_point);
|
||
$oss_client->doesBucketExist($bucket_name);
|
||
} catch (Exception $e) {
|
||
$error = '错误：连接OSS Client实例失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
try{
|
||
$ali_response = $oss_client->putObject($bucket_name, $remote_file_name, $new_file_content);
|
||
} catch(OssException $e) {
|
||
$error = '错误：将文件储存到OSS时失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
if (200 != $ali_response['info']['http_code']) {
|
||
$error = '错误：将文件储存到OSS时返回码不正常' . "\r\n" .
|
||
'错误码：' . $ali_response['info']['http_code'] . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
} else {
|
||
if ($ifLoaclSave === "1" && !Typecho_Common::isAppEngine()) {
|
||
if (file_exists($local_file_name) && !unlink($local_file_name)) {
|
||
$error = '错误：修改文件失败，无法删除旧文件' . "\r\n" .
|
||
'本地文件：' . $local_file_name . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
$file_dir_name = dirname($local_file_name);
|
||
$dir_exist = true;
|
||
|
||
if (!is_dir($file_dir_name) && !self::makeUploadDir($file_dir_name)) {
|
||
$dir_exist = false;
|
||
}
|
||
|
||
if ($dir_exist) {
|
||
if (!file_put_contents($local_file_name, $new_file_content)) {
|
||
$error = '错误：文件已保存到OSS，将文件储存到本地服务器时失败，请手动删除OSS上的文件' . "\r\n" .
|
||
'文件路径：' . $local_file_name . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
} else {
|
||
$error = '错误：文件已保存到OSS，将文件储存到本地服务器时创建目录失败，请检查服务器权限设置，请手动删除OSS上的文件' . "\r\n" .
|
||
'无法创建路径：' . $file_dir_name . "\r\n" .
|
||
'远程文件：' . $remote_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
}
|
||
}
|
||
|
||
return array(
|
||
'name' => $content['attachment']->name,
|
||
'path' => $path,
|
||
'size' => intval($ali_response['oss-requestheaders']['Content-Length']),
|
||
'type' => $ext,
|
||
'mime' => $ali_response['oss-requestheaders']['Content-Type']
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 删除文件
|
||
*
|
||
* @access public
|
||
* @param array $content 文件相关信息
|
||
* @return string
|
||
*/
|
||
public static function deleteHandle(array $content)
|
||
{
|
||
$options = Typecho_Widget::widget('Widget_Options');
|
||
$userDir = $options->plugin('AliOssForTypecho')->userDir;
|
||
$bucket_name = $options->plugin('AliOssForTypecho')->bucketName;
|
||
$end_point = 'http://' . (($options->plugin('AliOssForTypecho')->endPoint === "other") ?
|
||
$options->plugin('AliOssForTypecho')->otherEndPoint :
|
||
$options->plugin('AliOssForTypecho')->endPoint . $options->plugin('AliOssForTypecho')->endPointType);
|
||
$access_id = $options->plugin('AliOssForTypecho')->accessKeyId;
|
||
$access_key = $options->plugin('AliOssForTypecho')->accessKeySecret;
|
||
$ifLoaclSave = $options->plugin('AliOssForTypecho')->ifLoaclSave;
|
||
|
||
$path = $content['attachment']->path;
|
||
$object_name = $userDir . $path;
|
||
try {
|
||
$oss_client = new OssClient($access_id, $access_key, $end_point);
|
||
$oss_client->doesBucketExist($bucket_name);
|
||
} catch (Exception $e) {
|
||
$error = '错误：删除文件失败，无法连接OSS Client实例' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'OSS文件:' . $object_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
return false;
|
||
}
|
||
|
||
try {
|
||
$ali_response = $oss_client->deleteObject($bucket_name, $object_name);
|
||
} catch (Exception $e) {
|
||
$error = '错误：删除OSS文件失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'OSS文件： ' . $object_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
}
|
||
|
||
$delete_local_succeed = true;
|
||
if ($ifLoaclSave === "1" && !Typecho_Common::isAppEngine()) {
|
||
$upload_root = Typecho_Common::url(defined('__TYPECHO_UPLOAD_DIR__') ? __TYPECHO_UPLOAD_DIR__ : self::UPLOAD_DIR,
|
||
defined('__TYPECHO_UPLOAD_ROOT_DIR__') ? __TYPECHO_UPLOAD_ROOT_DIR__ : __TYPECHO_ROOT_DIR__);
|
||
$local_file_name = $upload_root . $path;
|
||
|
||
$delete_local_succeed = false;
|
||
if (file_exists($local_file_name)) {
|
||
if (!is_writable($local_file_name)) {
|
||
$error = '错误：删除本地文件失败，请检查权限设置' . "\r\n" .
|
||
'文件路径：' . $local_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
} else {
|
||
try {
|
||
$delete_local_succeed = unlink($local_file_name);
|
||
} catch (Exception $e) {
|
||
$error = '错误：删除本地文件失败' . "\r\n" .
|
||
'错误描述：' . $e->getMessage() . "\r\n" .
|
||
'文件路径：' . $local_file_name . "\r\n" .
|
||
'时间：' . date('Y-m-d h:i:sa') . "\r\n\r\n";
|
||
self::my_error_log($error);
|
||
}
|
||
}
|
||
} else {
|
||
$delete_local_succeed = true;
|
||
}
|
||
}
|
||
return $delete_local_succeed && ($ali_response['info']['http_code'] === 204);
|
||
}
|
||
|
||
/**
|
||
* 获取实际文件绝对访问路径
|
||
*
|
||
* @access public
|
||
* @param array $content 文件相关信息
|
||
* @return string
|
||
*/
|
||
public static function attachmentHandle(array $content) {
|
||
$options = Typecho_Widget::widget('Widget_Options');
|
||
|
||
$cdnUrl = $options->plugin('AliOssForTypecho')->cdnUrl;
|
||
$userDir = $options->plugin('AliOssForTypecho')->userDir;
|
||
$diy_style = $options->plugin('AliOssForTypecho')->des;
|
||
if (empty($cdnUrl)) {
|
||
$bucket_name = $options->plugin('AliOssForTypecho')->bucketName;
|
||
$end_point = ($options->plugin('AliOssForTypecho')->endPoint === "other") ?
|
||
$options->plugin('AliOssForTypecho')->otherEndPoint :
|
||
$options->plugin('AliOssForTypecho')->endPoint;
|
||
return 'https://' . $bucket_name . '.' . $end_point . '.aliyuncs.com/' . $userDir . $content['attachment']->path . $diy_style;
|
||
} else {
|
||
return $cdnUrl . $userDir . $content['attachment']->path . $diy_style;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取实际文件数据
|
||
*
|
||
* @access public
|
||
* @param array $content
|
||
* @return string
|
||
*/
|
||
public static function attachmentDataHandle(array $content)
|
||
{
|
||
return file_get_contents(self::attachmentHandle($content));
|
||
}
|
||
|
||
/**
|
||
* 检查文件名
|
||
*
|
||
* @access private
|
||
* @param string $ext 扩展名
|
||
* @return boolean
|
||
*/
|
||
private static function checkFileType($ext)
|
||
{
|
||
$options = Typecho_Widget::widget('Widget_Options');
|
||
return in_array($ext, $options->allowedAttachmentTypes);
|
||
}
|
||
|
||
/**
|
||
* 创建上传路径
|
||
*
|
||
* @access private
|
||
* @param string $path 路径
|
||
* @return boolean
|
||
*/
|
||
private static function makeUploadDir($path)
|
||
{
|
||
$path = preg_replace("/\\\+/", '/', $path);
|
||
$current = rtrim($path, '/');
|
||
$last = $current;
|
||
|
||
while (!is_dir($current) && false !== strpos($path, '/')) {
|
||
$last = $current;
|
||
$current = dirname($current);
|
||
}
|
||
|
||
if ($last == $current) {
|
||
return true;
|
||
}
|
||
|
||
if (!@mkdir($last)) {
|
||
return false;
|
||
}
|
||
|
||
$stat = @stat($last);
|
||
$perms = $stat['mode'] & 0007777;
|
||
@chmod($last, $perms);
|
||
|
||
return self::makeUploadDir($path);
|
||
}
|
||
|
||
/**
|
||
* 获取安全的文件名
|
||
*
|
||
* @param string $name
|
||
* @static
|
||
* @access private
|
||
* @return string
|
||
*/
|
||
private static function getSafeName(&$name) {
|
||
$name = str_replace(array('"', '<', '>'), '', $name);
|
||
$name = str_replace('\\', '/', $name);
|
||
$name = false === strpos($name, '/') ? ('a' . $name) : str_replace('/', '/a', $name);
|
||
$info = pathinfo($name);
|
||
$name = substr($info['basename'], 1);
|
||
return $name;
|
||
}
|
||
|
||
private static function my_error_log(&$error) {
|
||
if (!Typecho_Common::isAppEngine()) {
|
||
$upload_root = Typecho_Common::url(defined('__TYPECHO_UPLOAD_DIR__') ? __TYPECHO_UPLOAD_DIR__ : self::UPLOAD_DIR,
|
||
defined('__TYPECHO_UPLOAD_ROOT_DIR__') ? __TYPECHO_UPLOAD_ROOT_DIR__ : __TYPECHO_ROOT_DIR__);
|
||
$error_log_file = $upload_root . self::LOG_SUFFIX . 'error.log';
|
||
|
||
$log_dir = dirname($error_log_file);
|
||
if (!is_dir($log_dir)) {
|
||
if (is_writeable($upload_root)) {
|
||
self::makeUploadDir($log_dir);
|
||
}
|
||
}
|
||
if (is_writeable($log_dir)) {
|
||
error_log($error, 3, $error_log_file);
|
||
}
|
||
}
|
||
}
|
||
|
||
private static function getExtentionName(&$name) {
|
||
$info = pathinfo($name);
|
||
return isset($info['extension']) ? strtolower($info['extension']) : '';
|
||
}
|
||
|
||
}
|