no message

2025-05-04 22:40:38 +08:00
parent 5414accc6c
commit 5a0d1ac0c0
3 changed files with 54 additions and 12 deletions
--- a/app/Module/Apps.php
+++ b/app/Module/Apps.php
@@ -0,0 +1,133 @@
+<?php
+
+namespace App\Module;
+
+use Symfony\Component\Yaml\Yaml;
+use Symfony\Component\Yaml\Exception\ParseException;
+
+class Apps
+{
+    /**
+     * 生成docker-compose.yml文件配置
+     *
+     * @param string $filePath docker-compose.yml文件路径
+     * @param string|null $savePath 保存文件路径，为空则覆盖原文件
+     * @param array $params 可选参数，可包含ports、volumes、container_name和config配置
+     * @return bool 是否生成成功
+     */
+    public static function generateDockerComposeYml(string $filePath, ?string $savePath = null, array $params = []): bool
+    {
+        // 应用名称
+        $appName = basename(dirname($filePath));
+        $appName = preg_replace('/(?<!^)([A-Z])/', '-$1', $appName);
+        $appName = 'dootask-app-' . strtolower($appName);
+
+        // 网络名称
+        $networkName = 'dootask-networks-' . env('APP_ID');
+
+        try {
+            // 解析YAML文件
+            $content = Yaml::parseFile($filePath);
+
+            // 确保services部分存在
+            if (!isset($content['services'])) {
+                return false;
+            }
+
+            // 设置服务名称
+            $content['name'] = $appName;
+
+            // 删除所有现有网络配置
+            unset($content['networks']);
+
+            // 添加网络配置
+            $content['networks'][$networkName] = ['external' => true];
+
+            // 查找要修改的服务
+            $mainService = null;
+            $firstService = null;
+
+            foreach ($content['services'] as $name => $service) {
+                // 记录第一个服务
+                if ($firstService === null) {
+                    $firstService = $name;
+                }
+
+                // 检查是否有labels.main=true的服务
+                if (isset($service['labels']['main']) && $service['labels']['main'] === true) {
+                    $mainService = $name;
+                    break;
+                }
+            }
+
+            // 确定要修改的服务名称
+            $targetService = $mainService ?? $firstService;
+
+            if ($targetService !== null) {
+                $service = &$content['services'][$targetService];
+
+                // 更新网络配置
+                $service['networks'] = [$networkName];
+
+                // 处理ports参数
+                if (isset($params['ports'])) {
+                    $service['ports'] = $params['ports'];
+                }
+
+                // 处理volumes参数
+                if (isset($params['volumes'])) {
+                    $service['volumes'] = $params['volumes'];
+                }
+
+                // 处理container_name参数
+                if (isset($params['container_name'])) {
+                    $service['container_name'] = $params['container_name'];
+                }
+            }
+
+            // 生成YAML内容
+            $yamlContent = Yaml::dump($content, 4, 2);
+
+            // 替换${XXX}格式变量
+            $yamlContent = preg_replace_callback('/\$\{(.*?)\}/', function($matches) use ($params) {
+                $varName = $matches[1];
+                return $params['config'][$varName] ?? $varName;
+            }, $yamlContent);
+
+            // 写回文件
+            file_put_contents($savePath ?? $filePath, $yamlContent);
+
+            return true;
+        } catch (ParseException) {
+            // YAML解析错误
+            return false;
+        } catch (\Exception) {
+            // 其他错误
+            return false;
+        }
+    }
+
+    /**
+     * 执行docker-compose up|down命令
+     * @param string $appName
+     * @param string $command
+     * @return array
+     */
+    public static function dockerComposeUp(string $appName, string $command = 'up'): array
+    {
+        $url = "http://host.docker.internal:" . env("APPS_PORT") . "/apps/{$command}/{$appName}";
+        $extra = [
+            'Content-Type' => 'application/json',
+            'Authorization' => 'Bearer ' . env('APP_KEY'),
+        ];
+        $res = Ihttp::ihttp_request($url, [], $extra);
+        if (Base::isError($res)) {
+            return Base::retError("请求错误", $res);
+        }
+        $resData = Base::json2array($res['data']);
+        if ($resData['code'] != 200) {
+            return Base::retError("请求失败", $resData);
+        }
+        return Base::retSuccess("success", $resData['data']);
+    }
+}