552 lines
21 KiB
PHP
552 lines
21 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace app\admin\library\module;
|
||
|
||
use Throwable;
|
||
use ba\Depends;
|
||
use ba\Exception;
|
||
use ba\Filesystem;
|
||
use support\think\Db;
|
||
use FilesystemIterator;
|
||
use RecursiveIteratorIterator;
|
||
use RecursiveDirectoryIterator;
|
||
use think\db\exception\PDOException;
|
||
use app\admin\library\crud\Helper;
|
||
use GuzzleHttp\Exception\TransferException;
|
||
|
||
/**
|
||
* 模块服务类（Webman 迁移版）
|
||
*/
|
||
class Server
|
||
{
|
||
private static string $apiBaseUrl = '/api/v7.store/';
|
||
|
||
/**
|
||
* 下载
|
||
* @throws Throwable
|
||
*/
|
||
public static function download(string $uid, string $dir, array $extend = []): string
|
||
{
|
||
$tmpFile = $dir . $uid . ".zip";
|
||
try {
|
||
$client = get_ba_client();
|
||
$response = $client->get(self::$apiBaseUrl . 'download', ['query' => array_merge(['uid' => $uid, 'server' => 1], $extend)]);
|
||
$body = $response->getBody();
|
||
$content = $body->getContents();
|
||
if ($content == '' || stripos($content, '<title>系统发生错误</title>') !== false) {
|
||
throw new Exception('package download failed', 0);
|
||
}
|
||
if (str_starts_with($content, '{')) {
|
||
$json = (array)json_decode($content, true);
|
||
throw new Exception($json['msg'], $json['code'], $json['data'] ?? []);
|
||
}
|
||
} catch (TransferException $e) {
|
||
throw new Exception('package download failed', 0, ['msg' => $e->getMessage()]);
|
||
}
|
||
|
||
if ($write = fopen($tmpFile, 'w')) {
|
||
fwrite($write, $content);
|
||
fclose($write);
|
||
return $tmpFile;
|
||
}
|
||
throw new Exception("No permission to write temporary files");
|
||
}
|
||
|
||
/**
|
||
* 安装预检
|
||
* @throws Throwable
|
||
*/
|
||
public static function installPreCheck(array $query = []): bool
|
||
{
|
||
try {
|
||
$client = get_ba_client();
|
||
$response = $client->get(self::$apiBaseUrl . 'preCheck', ['query' => $query]);
|
||
$body = $response->getBody();
|
||
$statusCode = $response->getStatusCode();
|
||
$content = $body->getContents();
|
||
if ($content == '' || stripos($content, '<title>系统发生错误</title>') !== false || $statusCode != 200) {
|
||
return true;
|
||
}
|
||
if (str_starts_with($content, '{')) {
|
||
$json = json_decode($content, true);
|
||
if ($json && $json['code'] == 0) {
|
||
throw new Exception($json['msg'], $json['code'], $json['data'] ?? []);
|
||
}
|
||
}
|
||
} catch (TransferException $e) {
|
||
throw new Exception('package check failed', 0, ['msg' => $e->getMessage()]);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
public static function getConfig(string $dir, $key = ''): array
|
||
{
|
||
$configFile = $dir . 'config.json';
|
||
if (!is_dir($dir) || !is_file($configFile)) {
|
||
return [];
|
||
}
|
||
$configContent = @file_get_contents($configFile);
|
||
$configContent = json_decode($configContent, true);
|
||
if (!$configContent) {
|
||
return [];
|
||
}
|
||
if ($key) {
|
||
return $configContent[$key] ?? [];
|
||
}
|
||
return $configContent;
|
||
}
|
||
|
||
public static function getDepend(string $dir, string $key = ''): array
|
||
{
|
||
if ($key) {
|
||
return self::getConfig($dir, $key);
|
||
}
|
||
$configContent = self::getConfig($dir);
|
||
$dependKey = ['require', 'require-dev', 'dependencies', 'devDependencies', 'nuxtDependencies', 'nuxtDevDependencies'];
|
||
$dependArray = [];
|
||
foreach ($dependKey as $item) {
|
||
if (array_key_exists($item, $configContent) && $configContent[$item]) {
|
||
$dependArray[$item] = $configContent[$item];
|
||
}
|
||
}
|
||
return $dependArray;
|
||
}
|
||
|
||
/**
|
||
* 依赖冲突检查
|
||
* @throws Throwable
|
||
*/
|
||
public static function dependConflictCheck(string $dir): array
|
||
{
|
||
$depend = self::getDepend($dir);
|
||
$serverDep = new Depends(root_path() . 'composer.json', 'composer');
|
||
$webDep = new Depends(root_path() . 'web' . DIRECTORY_SEPARATOR . 'package.json');
|
||
$webNuxtDep = new Depends(root_path() . 'web-nuxt' . DIRECTORY_SEPARATOR . 'package.json');
|
||
$sysDepend = [
|
||
'require' => $serverDep->getDepends(),
|
||
'require-dev' => $serverDep->getDepends(true),
|
||
'dependencies' => $webDep->getDepends(),
|
||
'devDependencies' => $webDep->getDepends(true),
|
||
'nuxtDependencies' => $webNuxtDep->getDepends(),
|
||
'nuxtDevDependencies' => $webNuxtDep->getDepends(true),
|
||
];
|
||
|
||
$conflict = [];
|
||
foreach ($depend as $key => $item) {
|
||
$conflict[$key] = array_uintersect_assoc($item, $sysDepend[$key] ?? [], function ($a, $b) {
|
||
return $a == $b ? -1 : 0;
|
||
});
|
||
}
|
||
return $conflict;
|
||
}
|
||
|
||
/**
|
||
* 获取模块[冲突]文件列表
|
||
*/
|
||
public static function getFileList(string $dir, bool $onlyConflict = false): array
|
||
{
|
||
if (!is_dir($dir)) {
|
||
return [];
|
||
}
|
||
|
||
$fileList = [];
|
||
$overwriteDir = self::getOverwriteDir();
|
||
$moduleFileList = self::getRuntime($dir, 'files');
|
||
|
||
if ($moduleFileList) {
|
||
if ($onlyConflict) {
|
||
$excludeFile = ['info.ini'];
|
||
foreach ($moduleFileList as $file) {
|
||
$path = Filesystem::fsFit(str_replace($dir, '', $file['path']));
|
||
$paths = explode(DIRECTORY_SEPARATOR, $path);
|
||
$overwriteFile = in_array($paths[0], $overwriteDir) ? root_path() . $path : $dir . $path;
|
||
if (is_file($overwriteFile) && !in_array($path, $excludeFile) && (filesize($overwriteFile) != $file['size'] || md5_file($overwriteFile) != $file['md5'])) {
|
||
$fileList[] = $path;
|
||
}
|
||
}
|
||
} else {
|
||
foreach ($overwriteDir as $item) {
|
||
$baseDir = $dir . $item;
|
||
foreach ($moduleFileList as $file) {
|
||
if (!str_starts_with($file['path'], $baseDir)) continue;
|
||
$fileList[] = Filesystem::fsFit(str_replace($dir, '', $file['path']));
|
||
}
|
||
}
|
||
}
|
||
return $fileList;
|
||
}
|
||
|
||
foreach ($overwriteDir as $item) {
|
||
$baseDir = $dir . $item;
|
||
if (!is_dir($baseDir)) {
|
||
continue;
|
||
}
|
||
$files = new RecursiveIteratorIterator(
|
||
new RecursiveDirectoryIterator($baseDir, FilesystemIterator::SKIP_DOTS), RecursiveIteratorIterator::CHILD_FIRST
|
||
);
|
||
foreach ($files as $file) {
|
||
if ($file->isFile()) {
|
||
$filePath = $file->getPathName();
|
||
$path = str_replace($dir, '', $filePath);
|
||
$path = str_replace(['/', '\\'], DIRECTORY_SEPARATOR, $path);
|
||
|
||
if ($onlyConflict) {
|
||
$overwriteFile = root_path() . $path;
|
||
if (is_file($overwriteFile) && (filesize($overwriteFile) != filesize($filePath) || md5_file($overwriteFile) != md5_file($filePath))) {
|
||
$fileList[] = $path;
|
||
}
|
||
} else {
|
||
$fileList[] = $path;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return $fileList;
|
||
}
|
||
|
||
public static function getOverwriteDir(): array
|
||
{
|
||
return [
|
||
'app',
|
||
'config',
|
||
'database',
|
||
'extend',
|
||
'modules',
|
||
'public',
|
||
'vendor',
|
||
'web',
|
||
'web-nuxt',
|
||
];
|
||
}
|
||
|
||
public static function importSql(string $dir): bool
|
||
{
|
||
$sqlFile = $dir . 'install.sql';
|
||
$tempLine = '';
|
||
$prefix = config('thinkorm.connections.mysql.prefix', config('database.connections.mysql.prefix', ''));
|
||
if (is_file($sqlFile)) {
|
||
$lines = file($sqlFile);
|
||
foreach ($lines as $line) {
|
||
if (str_starts_with($line, '--') || $line == '' || str_starts_with($line, '/*')) {
|
||
continue;
|
||
}
|
||
|
||
$tempLine .= $line;
|
||
if (str_ends_with(trim($line), ';')) {
|
||
$tempLine = str_ireplace('__PREFIX__', $prefix, $tempLine);
|
||
$tempLine = str_ireplace('INSERT INTO ', 'INSERT IGNORE INTO ', $tempLine);
|
||
try {
|
||
Db::execute($tempLine);
|
||
} catch (PDOException) {
|
||
// ignore
|
||
}
|
||
$tempLine = '';
|
||
}
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
|
||
public static function installedList(string $dir): array
|
||
{
|
||
if (!is_dir($dir)) {
|
||
return [];
|
||
}
|
||
$installedDir = scandir($dir);
|
||
$installedList = [];
|
||
foreach ($installedDir as $item) {
|
||
if ($item === '.' or $item === '..' || is_file($dir . $item)) {
|
||
continue;
|
||
}
|
||
$tempDir = $dir . $item . DIRECTORY_SEPARATOR;
|
||
if (!is_dir($tempDir)) {
|
||
continue;
|
||
}
|
||
$info = self::getIni($tempDir);
|
||
if (!isset($info['uid'])) {
|
||
continue;
|
||
}
|
||
$installedList[] = $info;
|
||
}
|
||
return $installedList;
|
||
}
|
||
|
||
public static function getInstalledIds(string $dir): array
|
||
{
|
||
$installedIds = [];
|
||
$installed = self::installedList($dir);
|
||
foreach ($installed as $item) {
|
||
$installedIds[] = $item['uid'];
|
||
}
|
||
return $installedIds;
|
||
}
|
||
|
||
public static function getIni(string $dir): array
|
||
{
|
||
$infoFile = $dir . 'info.ini';
|
||
$info = [];
|
||
if (is_file($infoFile)) {
|
||
$info = parse_ini_file($infoFile, true, INI_SCANNER_TYPED) ?: [];
|
||
if (!$info) return [];
|
||
}
|
||
return $info;
|
||
}
|
||
|
||
/**
|
||
* @throws Throwable
|
||
*/
|
||
public static function setIni(string $dir, array $arr): bool
|
||
{
|
||
$infoFile = $dir . 'info.ini';
|
||
$ini = [];
|
||
foreach ($arr as $key => $val) {
|
||
if (is_array($val)) {
|
||
$ini[] = "[$key]";
|
||
foreach ($val as $ikey => $ival) {
|
||
$ini[] = "$ikey = $ival";
|
||
}
|
||
} else {
|
||
$ini[] = "$key = $val";
|
||
}
|
||
}
|
||
if (!file_put_contents($infoFile, implode("\n", $ini) . "\n", LOCK_EX)) {
|
||
throw new Exception("Configuration file has no write permission");
|
||
}
|
||
return true;
|
||
}
|
||
|
||
public static function getClass(string $uid, string $type = 'event', ?string $class = null): string
|
||
{
|
||
$name = parse_name($uid);
|
||
if (!is_null($class) && strpos($class, '.')) {
|
||
$class = explode('.', $class);
|
||
$class[count($class) - 1] = parse_name(end($class), 1);
|
||
$class = implode('\\', $class);
|
||
} else {
|
||
$class = parse_name(is_null($class) ? $name : $class, 1);
|
||
}
|
||
$namespace = match ($type) {
|
||
'controller' => '\\modules\\' . $name . '\\controller\\' . $class,
|
||
default => '\\modules\\' . $name . '\\' . $class,
|
||
};
|
||
return class_exists($namespace) ? $namespace : '';
|
||
}
|
||
|
||
public static function execEvent(string $uid, string $event, array $params = []): void
|
||
{
|
||
$eventClass = self::getClass($uid);
|
||
if (class_exists($eventClass)) {
|
||
$handle = new $eventClass();
|
||
if (method_exists($eventClass, $event)) {
|
||
$handle->$event($params);
|
||
}
|
||
}
|
||
}
|
||
|
||
public static function analysisWebBootstrap(string $uid, string $dir): array
|
||
{
|
||
$bootstrapFile = $dir . 'webBootstrap.stub';
|
||
if (!file_exists($bootstrapFile)) return [];
|
||
$bootstrapContent = file_get_contents($bootstrapFile);
|
||
$pregArr = [
|
||
'mainTsImport' => '/#main.ts import code start#([\s\S]*?)#main.ts import code end#/i',
|
||
'mainTsStart' => '/#main.ts start code start#([\s\S]*?)#main.ts start code end#/i',
|
||
'appVueImport' => '/#App.vue import code start#([\s\S]*?)#App.vue import code end#/i',
|
||
'appVueOnMounted' => '/#App.vue onMounted code start#([\s\S]*?)#App.vue onMounted code end#/i',
|
||
'nuxtAppVueImport' => '/#web-nuxt\/app.vue import code start#([\s\S]*?)#web-nuxt\/app.vue import code end#/i',
|
||
'nuxtAppVueStart' => '/#web-nuxt\/app.vue start code start#([\s\S]*?)#web-nuxt\/app.vue start code end#/i',
|
||
];
|
||
$codeStrArr = [];
|
||
foreach ($pregArr as $key => $item) {
|
||
preg_match($item, $bootstrapContent, $matches);
|
||
if (isset($matches[1]) && $matches[1]) {
|
||
$mainImportCodeArr = array_filter(preg_split('/\r\n|\r|\n/', $matches[1]));
|
||
if ($mainImportCodeArr) {
|
||
$codeStrArr[$key] = "\n";
|
||
if (count($mainImportCodeArr) == 1) {
|
||
foreach ($mainImportCodeArr as $codeItem) {
|
||
$codeStrArr[$key] .= $codeItem . self::buildMarkStr('module-line-mark', $uid, $key);
|
||
}
|
||
} else {
|
||
$codeStrArr[$key] .= self::buildMarkStr('module-multi-line-mark-start', $uid, $key);
|
||
foreach ($mainImportCodeArr as $codeItem) {
|
||
$codeStrArr[$key] .= $codeItem . "\n";
|
||
}
|
||
$codeStrArr[$key] .= self::buildMarkStr('module-multi-line-mark-end', $uid, $key);
|
||
}
|
||
}
|
||
}
|
||
unset($matches);
|
||
}
|
||
return $codeStrArr;
|
||
}
|
||
|
||
public static function installWebBootstrap(string $uid, string $dir): void
|
||
{
|
||
$bootstrapCode = self::analysisWebBootstrap($uid, $dir);
|
||
if (!$bootstrapCode) {
|
||
return;
|
||
}
|
||
|
||
$webPath = root_path() . 'web' . DIRECTORY_SEPARATOR . 'src' . DIRECTORY_SEPARATOR;
|
||
$webNuxtPath = root_path() . 'web-nuxt' . DIRECTORY_SEPARATOR;
|
||
$filePaths = [
|
||
'mainTsImport' => $webPath . 'main.ts',
|
||
'mainTsStart' => $webPath . 'main.ts',
|
||
'appVueImport' => $webPath . 'App.vue',
|
||
'appVueOnMounted' => $webPath . 'App.vue',
|
||
'nuxtAppVueImport' => $webNuxtPath . 'app.vue',
|
||
'nuxtAppVueStart' => $webNuxtPath . 'app.vue',
|
||
];
|
||
|
||
$marks = [
|
||
'mainTsImport' => self::buildMarkStr('import-root-mark'),
|
||
'mainTsStart' => self::buildMarkStr('start-root-mark'),
|
||
'appVueImport' => self::buildMarkStr('import-root-mark'),
|
||
'appVueOnMounted' => self::buildMarkStr('onMounted-root-mark'),
|
||
'nuxtAppVueImport' => self::buildMarkStr('import-root-mark'),
|
||
'nuxtAppVueStart' => self::buildMarkStr('start-root-mark'),
|
||
];
|
||
|
||
foreach ($bootstrapCode as $key => $item) {
|
||
if ($item && isset($marks[$key]) && isset($filePaths[$key]) && is_file($filePaths[$key])) {
|
||
$content = file_get_contents($filePaths[$key]);
|
||
$markPos = stripos($content, $marks[$key]);
|
||
if ($markPos && strripos($content, self::buildMarkStr('module-line-mark', $uid, $key)) === false && strripos($content, self::buildMarkStr('module-multi-line-mark-start', $uid, $key)) === false) {
|
||
$content = substr_replace($content, $item, $markPos + strlen($marks[$key]), 0);
|
||
file_put_contents($filePaths[$key], $content);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public static function uninstallWebBootstrap(string $uid): void
|
||
{
|
||
$webPath = root_path() . 'web' . DIRECTORY_SEPARATOR . 'src' . DIRECTORY_SEPARATOR;
|
||
$webNuxtPath = root_path() . 'web-nuxt' . DIRECTORY_SEPARATOR;
|
||
$filePaths = [
|
||
'mainTsImport' => $webPath . 'main.ts',
|
||
'mainTsStart' => $webPath . 'main.ts',
|
||
'appVueImport' => $webPath . 'App.vue',
|
||
'appVueOnMounted' => $webPath . 'App.vue',
|
||
'nuxtAppVueImport' => $webNuxtPath . 'app.vue',
|
||
'nuxtAppVueStart' => $webNuxtPath . 'app.vue',
|
||
];
|
||
|
||
$marksKey = [
|
||
'mainTsImport',
|
||
'mainTsStart',
|
||
'appVueImport',
|
||
'appVueOnMounted',
|
||
'nuxtAppVueImport',
|
||
'nuxtAppVueStart',
|
||
];
|
||
|
||
foreach ($marksKey as $item) {
|
||
if (!isset($filePaths[$item]) || !is_file($filePaths[$item])) {
|
||
continue;
|
||
}
|
||
$content = file_get_contents($filePaths[$item]);
|
||
$moduleLineMark = self::buildMarkStr('module-line-mark', $uid, $item);
|
||
$moduleMultiLineMarkStart = self::buildMarkStr('module-multi-line-mark-start', $uid, $item);
|
||
$moduleMultiLineMarkEnd = self::buildMarkStr('module-multi-line-mark-end', $uid, $item);
|
||
|
||
$moduleLineMarkPos = strripos($content, $moduleLineMark);
|
||
if ($moduleLineMarkPos !== false) {
|
||
$delStartTemp = explode($moduleLineMark, $content);
|
||
$delStartPos = strripos(rtrim($delStartTemp[0], "\n"), "\n");
|
||
$delEndPos = stripos($content, "\n", $moduleLineMarkPos);
|
||
$content = substr_replace($content, '', $delStartPos, $delEndPos - $delStartPos);
|
||
}
|
||
|
||
$moduleMultiLineMarkStartPos = stripos($content, $moduleMultiLineMarkStart);
|
||
if ($moduleMultiLineMarkStartPos !== false) {
|
||
$moduleMultiLineMarkStartPos--;
|
||
$moduleMultiLineMarkEndPos = stripos($content, $moduleMultiLineMarkEnd);
|
||
$delLang = ($moduleMultiLineMarkEndPos + strlen($moduleMultiLineMarkEnd)) - $moduleMultiLineMarkStartPos;
|
||
$content = substr_replace($content, '', $moduleMultiLineMarkStartPos, $delLang);
|
||
}
|
||
|
||
if (($moduleLineMarkPos ?? false) !== false || ($moduleMultiLineMarkStartPos ?? false) !== false) {
|
||
file_put_contents($filePaths[$item], $content);
|
||
}
|
||
}
|
||
}
|
||
|
||
public static function buildMarkStr(string $type, string $uid = '', string $extend = ''): string
|
||
{
|
||
$nonTabKeys = ['mti', 'avi', 'navi', 'navs'];
|
||
$extend = match ($extend) {
|
||
'mainTsImport' => 'mti',
|
||
'mainTsStart' => 'mts',
|
||
'appVueImport' => 'avi',
|
||
'appVueOnMounted' => 'avo',
|
||
'nuxtAppVueImport' => 'navi',
|
||
'nuxtAppVueStart' => 'navs',
|
||
default => '',
|
||
};
|
||
return match ($type) {
|
||
'import-root-mark' => '// modules import mark, Please do not remove.',
|
||
'start-root-mark' => '// modules start mark, Please do not remove.',
|
||
'onMounted-root-mark' => '// Modules onMounted mark, Please do not remove.',
|
||
'module-line-mark' => ' // Code from module \'' . $uid . "'" . ($extend ? "($extend)" : ''),
|
||
'module-multi-line-mark-start' => (in_array($extend, $nonTabKeys) ? '' : Helper::tab()) . "// Code from module '$uid' start" . ($extend ? "($extend)" : '') . "\n",
|
||
'module-multi-line-mark-end' => (in_array($extend, $nonTabKeys) ? '' : Helper::tab()) . "// Code from module '$uid' end",
|
||
default => '',
|
||
};
|
||
}
|
||
|
||
public static function getNuxtVersion(): mixed
|
||
{
|
||
$nuxtPackageJsonPath = Filesystem::fsFit(root_path() . 'web-nuxt/package.json');
|
||
if (is_file($nuxtPackageJsonPath)) {
|
||
$nuxtPackageJson = file_get_contents($nuxtPackageJsonPath);
|
||
$nuxtPackageJson = json_decode($nuxtPackageJson, true);
|
||
if ($nuxtPackageJson && isset($nuxtPackageJson['version'])) {
|
||
return $nuxtPackageJson['version'];
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
public static function createRuntime(string $dir): void
|
||
{
|
||
$runtimeFilePath = $dir . '.runtime';
|
||
$files = new RecursiveIteratorIterator(
|
||
new RecursiveDirectoryIterator($dir), RecursiveIteratorIterator::LEAVES_ONLY
|
||
);
|
||
$filePaths = [];
|
||
foreach ($files as $file) {
|
||
if (!$file->isDir()) {
|
||
$pathName = $file->getPathName();
|
||
if ($pathName == $runtimeFilePath) continue;
|
||
$filePaths[] = [
|
||
'path' => Filesystem::fsFit($pathName),
|
||
'size' => filesize($pathName),
|
||
'md5' => md5_file($pathName),
|
||
];
|
||
}
|
||
}
|
||
|
||
file_put_contents($runtimeFilePath, json_encode([
|
||
'files' => $filePaths,
|
||
'pure' => config('buildadmin.module_pure_install', false),
|
||
]));
|
||
}
|
||
|
||
public static function getRuntime(string $dir, string $key = ''): mixed
|
||
{
|
||
$runtimeFilePath = $dir . '.runtime';
|
||
$runtimeContent = @file_get_contents($runtimeFilePath);
|
||
$runtimeContentArr = json_decode($runtimeContent, true);
|
||
if (!$runtimeContentArr) return [];
|
||
|
||
if ($key) {
|
||
return $runtimeContentArr[$key] ?? [];
|
||
}
|
||
return $runtimeContentArr;
|
||
}
|
||
}
|