master

分支 (2)

管理

管理

master

v7.0

icms
/
app
/
patch
/
Patch.php

<?php

/**
 * iCMS - i Content Management System
 * Copyright (c) 2007-2017 iCMSdev.com. All rights reserved.
 *
 * @author icmsdev <master@icmsdev.com>
 * @site https://www.icmsdev.com
 * @licence https://www.icmsdev.com/LICENSE.html
 */
/**
 * 自动更新类
 *
 * @author icmsdev
 */
define('PATCH_DIR', iPHP_APP_PATH . 'cache/iCMS/patch/'); //临时文件夹
Http::$CURLOPT_REFERER = $_SERVER['REQUEST_HOST'];

class Patch
{
    public const PATCH_URL = 'https://patch.icmsdev.com/v8';    //自动更新服务器
    public const APP = 'patch';
    public const APPID = iCMS_APP_PATCH;

    public static $version = '';
    public static $release = '';
    public static $zipName = '';
    public static $gitFiles = [];
    public static $upgrade = false;
    public static $test = false;

    public static function init($force = false)
    {
        $info = self::info($force);
        $gitDate = date('Ymd', iCMS_GIT_TIME);
        if (
            $info &&
            $info->app == iPHP_APP &&
            version_compare($info->version, iCMS_VERSION, '>=') &&
            $info->release > iCMS_RELEASE &&
            $info->release > $gitDate
        ) {
            self::$version = $info->version;
            self::$release = $info->release;
            self::$zipName = sprintf('iCMS.%s.patch.%s.zip', self::$version, self::$release);
            return [self::$version, self::$release, $info->update, $info->changelog];
        }
    }

    public static function setTime()
    {
        $release = strtotime(iCMS_RELEASE);
        $gitTime = iCMS_GIT_TIME;
        $_GET['iCMS_RELEASE'] && $release = strtotime($_GET['iCMS_RELEASE']);
        $_GET['iCMS_GIT_TIME'] && $gitTime = $_GET['iCMS_GIT_TIME'];
        Cache::set('patch.time', [$release, $gitTime], 3600);
    }

    public static function getTime()
    {
        return (array) Cache::get('patch.time');
    }
    public static function getUpgradeTime()
    {
        $time = Cache::get('patch.upgrade.time');
        return $time ? $time : 0;
    }

    public static function git($do, $commit_id = null, $type = 'array')
    {
        $commit_id === null && $commit_id = iCMS_GIT_COMMIT;
        $_GET['commit_id'] && $commit_id = Request::sget('commit_id');
        $last_commit_id = Request::sget('last_commit_id');
        $path = $_GET['path'];
        $url = sprintf(
            '%s/git?do=%s&VERSION=%s&RELEASE=%s&commit_id=%s&last_commit_id=%s',
            Patch::PATCH_URL,
            $do,
            iCMS_VERSION,
            iCMS_RELEASE,
            $commit_id,
            $last_commit_id
        );
        $path && $url .= '&path=' . urlencode($path);
        $url .= '&t=' . time();
        $data = Http::send($url);
        if (is_null($data)) {
            iPHP::alert('iCMS GIT版本服务出错请联系开发人员，谢谢！');
        }
        return $data;
    }

    public static function version($force = false)
    {
        $url = sprintf(
            '%s/cms.version?VERSION=%s&RELEASE=%s&iCMS_GIT_COMMIT=%s&callback=?',
            self::PATCH_URL,
            iCMS_VERSION,
            iCMS_RELEASE,
            iCMS_GIT_COMMIT
        );
        $data = Http::send($url);
        if (is_null($data)) {
            iPHP::alert('iCMS版本服务出错请联系开发人员，谢谢！');
        }
        return $data;
    }

    public static function info($force = false)
    {
        File::mkdir(PATCH_DIR);
        $tFilePath = PATCH_DIR . 'version.json'; //临时文件夹
        if (File::exist($tFilePath) && time() - File::mtime($tFilePath) < 3600 && !$force) {
            $FileData = File::get($tFilePath);
        } else {
            $url = sprintf(
                '%s/version.%s.%s.patch.%s?t=%d',
                self::PATCH_URL,
                iPHP_APP,
                iCMS_VERSION,
                iCMS_RELEASE,
                time()
            );
            $FileData = Http::remote($url);
            File::put($tFilePath, $FileData);
        }
        return json_decode($FileData); //版本列表
    }

    public static function download(&$flag = true)
    {
        $zipFile = PATCH_DIR . self::$zipName; //临时文件
        $zipHttp = self::PATCH_URL . '/' . self::$zipName;
        $msg = '正在下载 [' . self::$release . '] 更新包 ' . $zipHttp . '<iCMS>';
        $flag = true;
        if (!File::exist($zipFile)) {
            try {
                $FileData = Http::remote($zipHttp);
                if ($FileData) {
                    File::mkdir(PATCH_DIR);
                    File::put($zipFile, $FileData); //下载更新包
                    $msg .= '下载完成....<iCMS>';
                }            //code...
            } catch (\Exception $ex) {
                $flag = false;
                $msg .= '下载失败....<iCMS>';
                $msg .= $ex->getMessage();
            }
        } else {
            $msg .= '更新包已存在....<iCMS>';
        }
        return $msg;
    }

    public static function update()
    {
        @set_time_limit(0);
        // Unzip uses a lot of memory
        @ini_set('memory_limit', '256M');
        Vendor::run('PclZip'); //加载zip操作类
        $zipFile = PATCH_DIR . self::$zipName; //临时文件
        $msg = '正在对 [' . self::$zipName . '] 更新包进行解压缩<iCMS>';
        $zip = new PclZip($zipFile);

        if (false == ($archive_files = $zip->extract(PCLZIP_OPT_EXTRACT_AS_STRING))) {
            exit('ZIP包错误');
        }

        if (0 == count($archive_files)) {
            exit('空的ZIP文件');
        }

        $msg .= '解压完成<iCMS>';
        $msg .= '开始测试目录权限<iCMS>';
        $update = true;
        if (!File::checkDir(iPHP_APP_PATH)) {
            $update = false;
            $msg .= iPHP_APP_PATH . ' 目录无写权限<iCMS>';
        }

        //测试目录文件是否写
        foreach ($archive_files as $file) {
            $folder = $file['folder'] ? $file['filename'] : dirname($file['filename']);
            $dp = iPHP_APP_PATH . $folder;
            if (!File::checkDir($dp) && File::isDir($dp)) {
                $update = false;
                $msg .= $dp . ' 目录无写权限<iCMS>';
            }
            if (empty($file['folder'])) {
                $fp = iPHP_APP_PATH . $file['filename'];
                if (file_exists($fp) && !@is_writable($fp)) {
                    $update = false;
                    $msg .= $fp . ' 文件无写权限<iCMS>';
                }
            }
        }
        if (self::$gitFiles) {
            foreach (self::$gitFiles as $git) {
                if ($git[0] == 'D') { //git删除资源
                    $fp = iPHP_APP_PATH . ltrim($git[1], '/');
                    if (file_exists($fp) && !@is_writable($fp)) {
                        $update = false;
                        $msg .= $fp . ' 文件无删除权限<iCMS>';
                    }
                }
            }
        }
        if (!$update) {
            $msg .= '权限测试无法完成<iCMS>';
            $msg .= '请设置好上面提示的文件写权限<iCMS>';
            $msg .= '然后重新更新<iCMS>';
            self::$upgrade = false;
            $msg = Security::filterPath($msg);
            return $msg;
        }
        $msg .= '权限测试通过<iCMS>';
        //测试通过！
        $msg .= '备份目录创建完成<iCMS>';
        $bakdir = self::getBackupDir(self::$release);
        File::mkdir($bakdir);

        $msg .= '开始更新程序<iCMS>';

        foreach ($archive_files as $file) {
            preg_match('@^app/(\w+)/@', $file['filename'], $match);
            if ($match[1]) {
                if (!Apps::check($match[1]) && $match[1] != 'func') {
                    $msg .= '应用 [' . $match[1] . '] 不存在,跳过[' . $file['filename'] . ']更新<iCMS>';
                    continue;
                }
            }
            $folder = $file['folder'] ? $file['filename'] : dirname($file['filename']);
            $dp = iPHP_APP_PATH . $folder;
            if (!File::isDir($dp)) {
                $msg .= '创建 [' . $dp . '] 文件夹<iCMS>';
                File::mkdir($dp);
            }
            if (empty($file['folder'])) {
                $fp = iPHP_APP_PATH . $file['filename'];
                $bfp = $bakdir . '/' . $file['filename'];
                File::mkdir(dirname($bfp));
                if (File::exist($fp)) {
                    $msg .= '备份 [' . $fp . '] 文件 到 [' . $bfp . ']<iCMS>';
                    File::copy($fp, $bfp); //备份旧文件
                }
                $msg .= '更新 [' . $fp . '] 文件<iCMS>';
                if (self::$test) {
                    $msg .= '[' . $fp . '] 测试更新完成!<iCMS>';
                } else {
                    File::put($fp, $file['content']);
                    $msg .= '[' . $fp . '] 更新完成!<iCMS>';
                }
            }
        }
        if (self::$gitFiles) {
            foreach (self::$gitFiles as $git) {
                if ($git[0] == 'D' && $git[1]) { //git删除资源
                    $fp = iPHP_APP_PATH . ltrim($git[1], '/');
                    if (file_exists($fp) && !@is_writable($fp)) {
                        $bfp = $bakdir . '/' . ltrim($git[1], '/');
                        File::mkdir(dirname($bfp));
                        if (File::exist($fp)) {
                            $msg .= '备份 [' . $fp . '] 文件 到 [' . $bfp . ']<iCMS>';
                            File::copy($fp, $bfp); //备份旧文件
                            $msg .= '删除 [' . $fp . '] 文件<iCMS>';
                            if (self::$test) {
                                $msg .= '[' . $fp . '] 测试删除完成!<iCMS>';
                            } else {
                                File::rm($fp);
                                $msg .= '[' . $fp . '] 删除完成!<iCMS>';
                            }
                        }
                    }
                }
            }
        }
        $msg .= '清除临时文件!<iCMS>';
        $msg .= '注:原文件备份在 [' . $bakdir . '] 目录<iCMS>';
        $msg .= '请暂时保留本次更新的备份，以备回滚使用!<iCMS>';

        $msg = Security::filterPath($msg);
        self::get_upgrade_files() && self::$upgrade = true;

        if (!self::$test) {
            Config::vset('patch.last', [iCMS_GIT_COMMIT, Patch::$release, time()]);
            Cache::delete('patch/git.info');
        }

        return $msg;
    }

    public static function parsePartialDate($str)
    {
        $len = strlen($str);

        $defaults = [
            'year'   => date('Y'),
            'month'  => '01',
            'day'    => '01',
            'hour'   => '00',
            'minute' => '00',
            'second' => '00'
        ];

        $parts = [];
        if ($len >= 4)  $parts['year']   = substr($str, 0, 4);
        if ($len >= 6)  $parts['month']  = substr($str, 4, 2);
        if ($len >= 8)  $parts['day']    = substr($str, 6, 2);
        if ($len >= 10) $parts['hour']   = substr($str, 8, 2);
        if ($len >= 12) $parts['minute'] = substr($str, 10, 2);
        if ($len >= 14) $parts['second'] = substr($str, 12, 2);

        $merged = array_merge($defaults, $parts);

        return sprintf('%s-%s-%s %s:%s:%s',
            $merged['year'], $merged['month'], $merged['day'],
            $merged['hour'], $merged['minute'], $merged['second']
        );
    }

    public static function get_upgrade_files($flag = false)
    {
        $files = [];
        $patch_dir = Application::path('patch/files');
        $upgrade_time = self::getUpgradeTime();
        foreach (glob($patch_dir . '*.{php,sql}', GLOB_BRACE) as $file) {
            $d = str_replace([$patch_dir, 'db.', 'fs.', '.php', '.sql'], '', $file);
            $t = strtotime(self::parsePartialDate($d));
            if ($flag) {
                $files[$t] = $file;
            } else {
                if ($t > $upgrade_time) {
                    $files[$t] = $file;
                } else {
                    File::rm($file);
                }
            }
        }
        return $files;
    }

    public static function run()
    {
        $flag = isset($_GET['force']);
        $files = self::get_upgrade_files($flag);
        if ($files) {
            self::$upgrade = true;
            ksort($files);
            foreach ($files as $t => $file) {
                if (stripos($file, '.php') !== false) {
                    $name = str_replace(['.php', '.'], ['', '_'], basename($file));
                    $patch_name = 'patch_' . $name;
                    $patch_func = require_once $file;
                    $title = sprintf('%s[%s]', ($title ?: ''), $patch_name);
                    if (is_callable($patch_func)) {
                        $msg .= sprintf('执行%s升级程序<iCMS>', $title);
                        try {
                            if (self::$test) {
                                $msg .= '测试升级顺利完成!<iCMS>';
                            } else {
                                $msg .= call_user_func($patch_func);
                                $msg .= '升级顺利完成!<iCMS>';
                                self::$test or Cache::set('patch.upgrade.time', $t);
                                self::$test or File::rm($file);
                            }
                            $msg .= '删除升级程序!<iCMS>';
                        } catch (\Exception $ex) {
                            $msg = sprintf('%s升级出错<iCMS>', $title);
                            $msg .= $ex->getMessage() . '<iCMS>';
                        }
                    } else {
                        $msg = sprintf('%s升级出错<iCMS>', $title);
                        $msg .= '找不到升级程序<iCMS>';
                    }
                } elseif (stripos($file, '.sql') !== false) {
                    $sql = file_get_contents($file);
                    $name = basename($file);
                    if ($sql) {
                        try {
                            if (self::$test) {
                                $msg .= '测试SQL执行顺利完成!<iCMS>';
                            } else {
                                $prefix = DB::getTablePrefix();
                                runQuery($sql, $prefix);
                                $msg .= 'SQL执行顺利完成!<iCMS>';
                                self::$test or Cache::set('patch.upgrade.time', $t);
                                self::$test or File::rm($file);
                            }
                            $msg .= '删除文件!<iCMS>';
                        } catch (\Exception $ex) {
                            $msg = '[' . $name . ']SQL执行出错<iCMS>';
                            $msg = $ex->getMessage() . '<iCMS>';
                        }
                    }
                }
            }
        } else {
            $msg = '升级顺利完成!';
        }

        self::$upgrade = false;
        return $msg;
    }

    public static $check_login = true;

    public static function getBackupDir($name)
    {
        return iPHP_APP_PATH . '.backup/patch.' . $name;
    }

    public static function upgrade($func)
    {
        if (is_null(self::$upgrade)) {
            return;
        }
        if (self::$upgrade) {
            return $func;
        }

        if (self::$check_login && !Admin::isLogin()) {
            exit('请先登录');
        }

        $output = $func();
        is_array($output) && $output = implode('<br />', $output);
        $output = str_replace('<iCMS>', '<br />', $output);
        $output = Security::filterPath($output);
        echo $output;
        $path = strtr(ADMINCP_URL, '\\', '/');
        $path = ltrim($path, '/');
        if (preg_match('@app/patch/files/\d+.php@', $path)) {
            File::rm(iPHP_APP_PATH . $path);
        }
    }

    public static function query($title, $sql)
    {
        $msg = $title . '<iCMS>';
        try {
            DB::query($sql);
        } catch (PDOException $ex) {
            $err = $ex->getMessage();
            if (stripos($err, 'already exists') !== false) {
                return $msg;
            } else {
                $msg .= '<span style="color:red;">';
                $msg .= $title . '出错<br />';
                $msg .= $ex->getMessage();
                $msg .= '</span><iCMS>';
            }
        }
        return $msg;
    }
}