<?php
namespace Module\ModuleStore\Util;
use Chumper\Zipper\Zipper;
use Illuminate\Support\Facades\Cache;
use ModStart\Core\Exception\BizException;
use ModStart\Core\Input\InputPackage;
use ModStart\Core\Input\Response;
use ModStart\Core\Util\CurlUtil;
use ModStart\Core\Util\FileUtil;
use ModStart\Core\Util\LogUtil;
use ModStart\Core\Util\SerializeUtil;
use ModStart\Core\Util\VersionUtil;
use ModStart\ModStart;
use ModStart\Module\ModuleManager;
class ModuleStoreUtil
{
const REMOTE_BASE = 'https://modstart.com';
public static function remoteModuleData()
{
$input = InputPackage::buildFromInput();
$memberUserId = $input->getInteger('memberUserId');
$apiToken = $input->getTrimString('apiToken');
return Cache::remember('ModuleStore_Modules:' . $memberUserId, 60, function () use ($apiToken) {
$app = 'cms';
if (class_exists('\App\Constant\AppConstant')) {
$app = \App\Constant\AppConstant::APP;
}
$ret = CurlUtil::getJSONData(self::REMOTE_BASE . '/api/store/module', [
'app' => $app,
'api_token' => $apiToken,
]);
return $ret;
});
}
public static function all()
{
$storeConfig = [
'disable' => config('env.MS_MODULE_STORE_DISABLE', false),
];
$result = self::remoteModuleData();
$categories = [];
if (!empty($result['data']['categories'])) {
$categories = $result['data']['categories'];
}
$types = [];
if (!empty($result['data']['types'])) {
$types = $result['data']['types'];
}
$modules = [];
if (!empty($result['data']['modules'])) {
foreach ($result['data']['modules'] as $remote) {
$remote['_isLocal'] = false;
$remote['_isInstalled'] = false;
$remote['_isEnabled'] = false;
$remote['_localVersion'] = null;
$remote['_isSystem'] = false;
$remote['_hasConfig'] = false;
$modules[$remote['name']] = $remote;
}
}
foreach (ModuleManager::listModules() as $m => $config) {
$info = ModuleManager::getModuleBasic($m);
if (isset($modules[$m])) {
$modules[$m]['_isInstalled'] = $config['isInstalled'];
$modules[$m]['_isEnabled'] = $config['enable'];
$modules[$m]['_localVersion'] = $info['version'];
$modules[$m]['_isSystem'] = $config['isSystem'];
$modules[$m]['_hasConfig'] = !empty($info['config']);
} else {
$modules[$m] = [
'id' => 0,
'name' => $m,
'title' => $info['title'],
'cover' => null,
'categoryId' => null,
'latestVersion' => $info['version'],
'releases' => [],
'url' => null,
'isFee' => false,
'priceSuper' => null,
'priceSuperEnable' => false,
'priceYear' => null,
'priceYearEnable' => false,
'description' => $info['description'],
'_isLocal' => true,
'_isInstalled' => $config['isInstalled'],
'_isEnabled' => $config['enable'],
'_localVersion' => $info['version'],
'_isSystem' => $config['isSystem'],
'_hasConfig' => !empty($info['config']),
];
}
}
return [
'storeConfig' => $storeConfig,
'categories' => $categories,
'types' => $types,
'modules' => array_values($modules),
];
}
private static function baseRequest($api, $data, $token)
{
return CurlUtil::postJSONBody(self::REMOTE_BASE . $api, $data, [
'header' => [
'api-token' => $token,
'X-Requested-With' => 'XMLHttpRequest',
]
]);
}
public static function checkPackage($token, $module, $version)
{
$ret = self::baseRequest('/api/store/module_info', [
'module' => $module,
'version' => $version,
], $token);
if ($ret['code'] && isset($ret['data']['buyCode'])) {
return Response::generate(-1, $ret['msg'], [
'msg' => $ret['data']['buyCode'],
'buyCodeId' => isset($ret['data']['buyCodeId']) ? $ret['data']['buyCodeId'] : null,
'payWatchUrl' => isset($ret['data']['payWatchUrl']) ? $ret['data']['payWatchUrl'] : null,
]);
}
BizException::throwsIfResponseError($ret);
$config = $ret['data']['config'];
$packageSize = $ret['data']['packageSize'];
$requires = [];
if (!empty($config['modstartVersion'])) {
$require = [
'name' => "<a href='https://modstart.com/download' class='ub-text-white tw-underline' target='_blank'>MSCore</a>:" . htmlspecialchars($config['modstartVersion']),
'success' => VersionUtil::match(ModStart::$version, $config['modstartVersion']),
'resolve' => null,
];
if (!$require['success']) {
$require['resolve'] = '请使用 MSCore' . $config['modstartVersion'] . ' 的版本';
}
$requires[] = $require;
}
if (!empty($config['require'])) {
foreach ($config['require'] as $require) {
list($m, $v) = VersionUtil::parse($require);
$require = [
'name' => "<a href='https://modstart.com/m/$m' class='ub-text-white tw-underline' target='_blank'>$m</a>:" . htmlspecialchars($v),
'success' => true,
'resolve' => null,
];
if (ModuleManager::isModuleInstalled($m)) {
$basic = ModuleManager::getModuleBasic($m);
BizException::throwsIfEmpty("获取模块 $m 信息失败", $basic);
$require['success'] = VersionUtil::match($basic['version'], $v);
if (!$require['success']) {
$require['resolve'] = "请使用版本 " . htmlspecialchars($v) . " 的模块 <a href='https://modstart.com/m/$m' class='ub-text-white tw-underline' target='_blank'>$m</a>";
}
} else {
$require['success'] = false;
$require['resolve'] = "请先安装 $require[name] <a href='https://modstart.com/m/$m' class='ub-text-white tw-underline' target='_blank'>[点击查看]</a>";
}
$requires[] = $require;
}
}
if (empty($config['env'])) {
$config['env'] = ['laravel5'];
}
$env = ModStart::env();
BizException::throwsIf(
L('Module %s:%s compatible with env %s, current is %s', $module, $config['version'], join(',', $config['env']), $env),
!in_array($env, $config['env'])
);
return Response::generateSuccessData([
'requires' => $requires,
'errorCount' => count(array_filter($requires, function ($o) {
return !$o['success'];
})),
'packageSize' => $packageSize,
]);
}
public static function downloadPackage($token, $module, $version)
{
$ret = self::baseRequest('/api/store/module_package', [
'module' => $module,
'version' => $version,
], $token);
BizException::throwsIfResponseError($ret);
$package = $ret['data']['package'];
$packageMd5 = $ret['data']['packageMd5'];
$licenseKey = $ret['data']['licenseKey'];
$ret = CurlUtil::getRaw($package, [], [
'returnRaw' => true,
]);
if ($ret['httpCode'] != 200) {
$error = '安装包获取失败';
if (!empty($ret['error'])) {
$error .= '(' . $ret['error'] . ')';
}
BizException::throws($error);
}
$zipTemp = FileUtil::generateLocalTempPath('zip');
file_put_contents($zipTemp, $ret['body']);
BizException::throwsIf('文件MD5校验失败', md5_file($zipTemp) != $packageMd5);
return Response::generateSuccessData([
'package' => $zipTemp,
'licenseKey' => $licenseKey,
'packageSize' => filesize($zipTemp),
]);
}
public static function cleanDownloadedPackage($package)
{
FileUtil::safeCleanLocalTemp($package);
}
public static function unpackModule($module, $package, $licenseKey)
{
$results = [];
BizException::throwsIf('文件不存在 ' . $package, empty($package) || !file_exists($package));
$ret = FileUtil::filePathWritableCheck(['module/._write_check_']);
BizException::throwsIfResponseError($ret);
$moduleDir = base_path('module/' . $module);
if (file_exists($moduleDir)) {
$moduleBackup = '_delete_.' . date('Ymd_His') . '.' . $module;
BizException::throwsIf('模块目录 module/' . $module . ' 不正常，请手动删除', !is_dir($moduleDir));
$moduleBackupDir = base_path("module/$moduleBackup");
try {
rename($moduleDir, $moduleBackupDir);
} catch (\Exception $e) {
BizException::throws("备份模块 $module 到 $moduleBackup 失败（确保模块中所有文件和目录已关闭）");
}
BizException::throwsIf('备份模块旧文件失败', !file_exists($moduleBackupDir));
$results[] = "备份模块 $module 到 $moduleBackup";
}
BizException::throwsIf('模块目录 module/' . $module . ' 不正常，请手动删除', file_exists($moduleDir));
@set_time_limit(60 * 10);
$zipper = new Zipper();
$zipper->make($package);
if ($zipper->contains($module . '/config.json')) {
$zipper->folder($module . '');
}
$zipper->extractTo($moduleDir);
$zipper->close();
BizException::throwsIf('解压失败', !file_exists($moduleDir . '/config.json'));
file_put_contents($moduleDir . '/license.json', SerializeUtil::jsonEncode([
'licenseKey' => $licenseKey,
]));
self::cleanDownloadedPackage($package);
return Response::generateSuccessData($results);
}
public static function removeModule($module, $version)
{
$moduleDir = base_path('module/' . $module);
BizException::throwsIf('模块目录不存在 ', !file_exists($moduleDir));
BizException::throwsIf('模块目录 module/' . $module . ' 不正常，请手动删除', !is_dir($moduleDir));
$moduleBackup = '_delete_.' . date('Ymd_His') . '.' . $module;
$moduleBackupDir = base_path("module/$moduleBackup");
try {
rename($moduleDir, $moduleBackupDir);
} catch (\Exception $e) {
BizException::throws("移除模块 $module 到 $moduleBackup 失败，请确保模块 $module 中没有文件正在被使用");
}
BizException::throwsIf('模块目录备份失败', !file_exists($moduleBackupDir));
return Response::generateSuccessData([]);
}
}