feat(ai-web): 输出节点改为多变量输出

将输入表单放在流程图中一起定义，方便统一参数的处理，不需要单独为输入表单的变量进行合并和操作

.gitignore

@@ -32,7 +32,7 @@ buildNumber.properties
 !.vscode/*.code-snippets
 .history/
 *.vsix
-.idea/**
+**/.idea/**
 cmake-build-*/
 .idea/**/mongoSettings.xml
 *.iws
@@ -109,3 +109,5 @@ Icon
 Network Trash Folder
 Temporary Items
 .apdisk
+**/temp/
+.build

bin/.gitignore

@@ -0,0 +1,102 @@
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+!.vscode/*.code-snippets
+.history/
+*.vsix
+*~
+.fuse_hidden*
+.directory
+.Trash-*
+.nfs*
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+.pnpm-debug.log*
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+pids
+*.pid
+*.seed
+*.pid.lock
+lib-cov
+coverage
+*.lcov
+.nyc_output
+.grunt
+bower_components
+.lock-wscript
+build/Release
+node_modules/
+jspm_packages/
+web_modules/
+*.tsbuildinfo
+.npm
+.eslintcache
+.stylelintcache
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+.node_repl_history
+*.tgz
+.yarn-integrity
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+.cache
+.parcel-cache
+.next
+out
+.nuxt
+dist
+.cache/
+.vuepress/dist
+.temp
+.docusaurus
+.serverless/
+.fusebox/
+.dynamodb/
+.tern-port
+.vscode-test
+.yarn/cache
+.yarn/unplugged
+.yarn/build-state.yml
+.yarn/install-state.gz
+.pnp.*
+Thumbs.db
+Thumbs.db:encryptable
+ehthumbs.db
+ehthumbs_vista.db
+*.stackdump
+[Dd]esktop.ini
+$RECYCLE.BIN/
+*.cab
+*.msi
+*.msix
+*.msm
+*.msp
+*.lnk
+.DS_Store
+.AppleDouble
+.LSOverride
+Icon
+._*
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk

bin/build-all.js

@@ -0,0 +1,54 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_package_batch, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch([
+        'service-common',
+        'service-dependencies',
+        'service-configuration',
+        'service-forest',
+        'service-cli',
+        'service-cli/service-cli-core',
+        'service-executor',
+        'service-executor/service-executor-core',
+        'utils/executor',
+    ])
+    await run_package_batch([
+        'service-api',
+        'service-check',
+        'service-cli/service-cli-runner',
+        'service-cloud-query',
+        'service-executor/service-executor-manager',
+        'service-executor/service-executor-task',
+        'service-command',
+        'service-command-pro',
+        'service-exporter',
+        'service-flink-query',
+        'service-gateway',
+        'service-hudi-query',
+        'service-info-query',
+        'service-monitor',
+        'service-loki-query',
+        'service-pulsar-query',
+        'service-queue',
+        'service-scheduler',
+        'service-uploader',
+        'service-web',
+        'service-yarn-query',
+        'service-zookeeper-query',
+        'utils/patch',
+        'utils/sync',
+    ])
+    for (const profile of ['b2a4', 'b2b1', 'b2b12']) {
+        await run_package('service-launcher', profile)
+        await run_upload(`**/service-launcher-${profile}-1.0.0-SNAPSHOT.jar`)
+    }
+    await run_upload('**/target/*-1.0.0-SNAPSHOT.jar')
+} catch (e) {
+    console.error(e)
+}

bin/build-all.sh

@@ -1,38 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-mvn install -N -D skipTests
-deploy service-common service-dependencies service-configuration service-forest service-cli service-cli/service-cli-core service-executor service-executor/service-executor-core utils/executor
-package service-api service-check service-cli/service-cli-runner service-cloud-query service-executor/service-executor-manager service-executor/service-executor-task service-command service-command-pro service-exporter service-flink-query service-gateway service-hudi-query service-info-query service-monitor service-loki-query service-pulsar-query service-queue service-scheduler service-uploader service-web service-yarn-query service-zookeeper-query utils/patch utils/sync
-
-configs=(b2a4 b2b1 b2b12)
-for config in ${configs[*]};
-do
-  mvn -pl service-launcher clean package -D skipTests -P $config
-  upload $root_path/service-launcher/target/service-launcher-$config-1.0.0-SNAPSHOT.jar
-done
-
-upload $root_path/service-api/target/service-api-1.0.0-SNAPSHOT.jar
-upload $root_path/service-check/target/service-check-1.0.0-SNAPSHOT.jar
-upload $root_path/service-cloud-query/target/service-cloud-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-command/target/service-command-1.0.0-SNAPSHOT.jar
-upload $root_path/service-command-pro/target/service-command-pro-1.0.0-SNAPSHOT.jar
-upload $root_path/service-executor/service-executor-manager/target/service-executor-manager-1.0.0-SNAPSHOT.jar
-upload $root_path/service-executor/service-executor-task/target/service-executor-task-1.0.0-SNAPSHOT.jar
-upload $root_path/service-exporter/target/service-exporter-1.0.0-SNAPSHOT.jar
-upload $root_path/service-flink-query/target/service-flink-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-gateway/target/service-gateway-1.0.0-SNAPSHOT.jar
-upload $root_path/service-hudi-query/target/service-hudi-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-info-query/target/service-info-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-loki-query/target/service-loki-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-monitor/target/service-monitor-1.0.0-SNAPSHOT.jar
-upload $root_path/service-pulsar-query/target/service-pulsar-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-queue/target/service-queue-1.0.0-SNAPSHOT.jar
-upload $root_path/service-scheduler/target/service-scheduler-1.0.0-SNAPSHOT.jar
-upload $root_path/service-web/target/service-web-1.0.0-SNAPSHOT.jar
-upload $root_path/service-yarn-query/target/service-yarn-query-1.0.0-SNAPSHOT.jar
-upload $root_path/service-zookeeper-query/target/service-zookeeper-query-1.0.0-SNAPSHOT.jar
-upload $root_path/utils/sync/target/sync-1.0.0-SNAPSHOT.jar
-
-upload $root_path/service-cli/service-cli-runner/target/service-cli-runner-1.0.0-SNAPSHOT.jar
-upload $root_path/service-uploader/target/service-uploader-1.0.0-SNAPSHOT.jar

bin/build-api.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-api')
+    await run_upload_normal('service-api')
+} catch (e) {
+    console.error(e)
+}

bin/build-api.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-api
-upload $root_path/service-api/target/service-api-1.0.0-SNAPSHOT.jar

bin/build-check.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-check')
+    await run_upload_normal('service-check')
+} catch (e) {
+    console.error(e)
+}

bin/build-check.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-check
-upload $root_path/service-check/target/service-check-1.0.0-SNAPSHOT.jar

bin/build-cli.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-cli', 'service-cli/service-cli-core'])
+    await run_package('service-cli/service-cli-runner')
+    await run_upload('**/service-cli-runner-1.0.0-SNAPSHOT.jar')
+} catch (e) {
+    console.error(e)
+}

bin/build-cli.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-cli service-cli/service-cli-core
-package service-cli/service-cli-runner
-upload $root_path/service-cli/service-cli-runner/target/service-cli-runner-1.0.0-SNAPSHOT.jar

bin/build-cloud-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-cloud-query')
+    await run_upload_normal('service-cloud-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-cloud-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-cloud-query
-upload $root_path/service-cloud-query/target/service-cloud-query-1.0.0-SNAPSHOT.jar

bin/build-command-pro.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-command-pro')
+    await run_upload_normal('service-command-pro')
+} catch (e) {
+    console.error(e)
+}

bin/build-command-pro.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-command-pro
-upload $root_path/service-command-pro/target/service-command-pro-1.0.0-SNAPSHOT.jar

bin/build-command.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-command')
+    await run_upload_normal('service-command')
+} catch (e) {
+    console.error(e)
+}

bin/build-command.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-command
-upload $root_path/service-command/target/service-command-1.0.0-SNAPSHOT.jar

bin/build-executor-manager.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest', 'service-executor', 'service-executor/service-executor-core'])
+    await run_package('service-executor/service-executor-manager')
+    await run_upload('**/service-executor-manager-1.0.0-SNAPSHOT.jar')
+} catch (e) {
+    console.error(e)
+}

bin/build-executor-manager.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest service-executor service-executor/service-executor-core
-package service-executor/service-executor-manager
-upload $root_path/service-executor/service-executor-manager/target/service-executor-manager-1.0.0-SNAPSHOT.jar

bin/build-executor-task.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest', 'service-executor', 'service-executor/service-executor-core'])
+    await run_package('service-executor/service-executor-task')
+    await run_upload('**/service-executor-task-1.0.0-SNAPSHOT.jar')
+} catch (e) {
+    console.error(e)
+}

bin/build-executor-task.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest service-executor service-executor/service-executor-core
-package service-executor/service-executor-task
-upload $root_path/service-executor/service-executor-task/target/service-executor-task-1.0.0-SNAPSHOT.jar

bin/build-exporter.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-exporter')
+    await run_upload_normal('service-exporter')
+} catch (e) {
+    console.error(e)
+}

bin/build-exporter.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-exporter
-upload $root_path/service-exporter/target/service-exporter-1.0.0-SNAPSHOT.jar

bin/build-flink-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-flink-query')
+    await run_upload_normal('service-flink-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-flink-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-flink-query
-upload $root_path/service-flink-query/target/service-flink-query-1.0.0-SNAPSHOT.jar

bin/build-forest.js

@@ -0,0 +1,13 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+} catch (e) {
+    console.error(e)
+}

bin/build-gateway.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-gateway')
+    await run_upload_normal('service-gateway')
+} catch (e) {
+    console.error(e)
+}

bin/build-gateway.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-gateway
-upload $root_path/service-gateway/target/service-gateway-1.0.0-SNAPSHOT.jar

bin/build-hudi-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-hudi-query')
+    await run_upload_normal('service-hudi-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-hudi-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-hudi-query
-upload $root_path/service-hudi-query/target/service-hudi-query-1.0.0-SNAPSHOT.jar

bin/build-info-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-info-query')
+    await run_upload_normal('service-info-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-info-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-info-query
-upload $root_path/service-info-query/target/service-info-query-1.0.0-SNAPSHOT.jar

bin/build-launcher.js

@@ -0,0 +1,17 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    for (const profile of ['b2a4', 'b2b1', 'b2b12']) {
+        await run_package('service-launcher', profile)
+        await run_upload(`**/service-launcher-${profile}-1.0.0-SNAPSHOT.jar`)
+    }
+} catch (e) {
+    console.error(e)
+}

bin/build-launcher.sh

@@ -1,11 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-
-configs=(b2a4 b2b1 b2b12)
-for config in ${configs[*]};
-do
-  mvn -pl service-launcher clean package -D skipTests -P $config
-  upload $root_path/service-launcher/target/service-launcher-$config-1.0.0-SNAPSHOT.jar
-done

bin/build-loki-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-loki-query')
+    await run_upload_normal('service-loki-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-loki-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-loki-query
-upload $root_path/service-loki-query/target/service-loki-query-1.0.0-SNAPSHOT.jar

bin/build-monitor.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-monitor')
+    await run_upload_normal('service-monitor')
+} catch (e) {
+    console.error(e)
+}

bin/build-monitor.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-monitor
-upload $root_path/service-monitor/target/service-monitor-1.0.0-SNAPSHOT.jar

bin/build-patch.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common'])
+    await run_package('utils/patch')
+    await run_upload('**/patch-1.0.0-SNAPSHOT.jar')
+} catch (e) {
+    console.error(e)
+}

bin/build-patch.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package utils/patch
-upload $root_path/utils/patch/target/patch-1.0.0-SNAPSHOT.jar

bin/build-pulsar-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-pulsar-query')
+    await run_upload_normal('service-pulsar-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-pulsar-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-pulsar-query
-upload $root_path/service-pulsar-query/target/service-pulsar-query-1.0.0-SNAPSHOT.jar

bin/build-queue.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-queue')
+    await run_upload_normal('service-queue')
+} catch (e) {
+    console.error(e)
+}

bin/build-queue.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-queue
-upload $root_path/service-queue/target/service-queue-1.0.0-SNAPSHOT.jar

bin/build-scheduler.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-scheduler')
+    await run_upload_normal('service-scheduler')
+} catch (e) {
+    console.error(e)
+}

bin/build-scheduler.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-scheduler
-upload $root_path/service-scheduler/target/service-scheduler-1.0.0-SNAPSHOT.jar

bin/build-sync.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'utils/patch'])
+    await run_package('utils/sync')
+    await run_upload('**/sync-1.0.0-SNAPSHOT.jar')
+} catch (e) {
+    console.error(e)
+}

bin/build-sync.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest utils/patch
-package utils/sync
-upload $root_path/utils/sync/target/sync-1.0.0-SNAPSHOT.jar

bin/build-uploader.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-uploader')
+    await run_upload_normal('service-uploader')
+} catch (e) {
+    console.error(e)
+}

bin/build-uploader.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-uploader
-ytp-transfer2 $root_path/service-uploader/target/service-uploader-1.0.0-SNAPSHOT.jar

bin/build-web.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-web')
+    await run_upload_normal('service-web')
+} catch (e) {
+    console.error(e)
+}

bin/build-web.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-web
-upload $root_path/service-web/target/service-web-1.0.0-SNAPSHOT.jar

bin/build-yarn-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-yarn-query')
+    await run_upload_normal('service-yarn-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-yarn-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-yarn-query
-upload $root_path/service-yarn-query/target/service-yarn-query-1.0.0-SNAPSHOT.jar

bin/build-zookeeper-query.js

@@ -0,0 +1,15 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy_batch, run_deploy_root, run_package, run_upload_normal} from "./library.js";
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+    await run_deploy_root()
+    await run_deploy_batch(['service-common', 'service-dependencies', 'service-configuration', 'service-forest'])
+    await run_package('service-zookeeper-query')
+    await run_upload_normal('service-zookeeper-query')
+} catch (e) {
+    console.error(e)
+}

bin/build-zookeeper-query.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-root_path=$(dirname $(cd $(dirname $0);pwd))
-source $root_path/bin/library.sh
-deploy service-common service-dependencies service-configuration service-forest
-package service-zookeeper-query
-upload $root_path/service-zookeeper-query/target/service-zookeeper-query-1.0.0-SNAPSHOT.jar

bin/generate

@@ -4,7 +4,7 @@ jars_path=/data/datalake/jars
 jdk_path=/opt/jdk1.8.0_162/bin/java
 
 arguments=$@
-# 手动上传jar包则注释掉这行，更显神通吧反正是
+# 手动上传jar包则注释掉这行，各显神通吧反正是
 curl http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.124:36800/file/download/service-cli-runner-1.0.0-SNAPSHOT.jar -o ${jars_path}/service-cli-runner.jar
 ${jdk_path} -jar ${jars_path}/service-cli-runner.jar \
   --spring.profiles.active=b12 \

bin/library.js

@@ -0,0 +1,164 @@
+import {$, fetch, fs, glob, os, path, spinner, syncProcessCwd, usePowerShell} from 'zx'
+import {fileSize, isEqual, trim} from "licia";
+import md5file from 'md5-file'
+
+syncProcessCwd(true)
+if (isEqual(os.platform(), 'win32')) {
+    usePowerShell()
+}
+
+const maven_setting = path.join(os.homedir(), '.m2', 'settings-nas.xml')
+
+const upload_url = 'http://132.126.207.124:36800'
+const upload_username = 'AxhEbscwsJDbYMH2'
+const upload_password = 'cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4'
+
+/**
+ * 时间戳转自然语言
+ *
+ * @param timestamp 时间戳
+ * @returns {string} 自然语言描述的时间
+ */
+const millisecondToString = (timestamp) => {
+    const totalSeconds = Math.floor(parseFloat(timestamp) / 1000)
+    if (isNaN(totalSeconds) || totalSeconds < 0) {
+        return "0秒";
+    }
+
+    const days = Math.floor(totalSeconds / 86400)
+    let remaining = totalSeconds % 86400
+    const hours = Math.floor(remaining / 3600)
+    remaining %= 3600
+    const minutes = Math.floor(remaining / 60)
+    const seconds = remaining % 60
+
+    const parts = []
+    if (days > 0) parts.push(`${days}天`)
+    if (days > 0 || hours > 0) parts.push(`${hours}小时`)
+    if (days > 0 || hours > 0 || minutes > 0) parts.push(`${minutes}分钟`)
+    parts.push(`${seconds}秒`)
+
+    return parts.join('')
+}
+
+const dotBuildPath = () => `.build`
+const modifiedDataPath = () => `${dotBuildPath()}/modified_time.json`
+
+const readModifiedTimeData = async () => {
+    if (!fs.existsSync(dotBuildPath())) {
+        fs.mkdirSync(dotBuildPath(), {recursive: true})
+    }
+    if (!(await fs.exists(modifiedDataPath()))) {
+        fs.writeFileSync(modifiedDataPath(), '{}')
+    }
+    return JSON.parse(await fs.readFile(modifiedDataPath(), 'utf-8'))
+}
+
+const updateModifiedTimeData = (data) => {
+    fs.writeFileSync(modifiedDataPath(), JSON.stringify(data, null, 2))
+}
+
+const isModified = async (target) => {
+    if (!target || !(await fs.exists(target))) {
+        throw new Error("Target 不存在")
+    }
+    let stat = fs.statSync(target)
+    let currentModifiedTime = stat.mtimeMs
+
+    let lastModifiedTime = (await readModifiedTimeData())[target]
+    return !(lastModifiedTime && isEqual(currentModifiedTime, lastModifiedTime));
+
+}
+
+const updateModifiedTime = async (target) => {
+    if (!target || !(await fs.exists(target))) {
+        throw new Error("Target 不存在")
+    }
+    let stat = fs.statSync(target)
+    let currentModifiedTime = stat.mtimeMs
+    let modifiedTimeData = await readModifiedTimeData()
+    modifiedTimeData[target] = currentModifiedTime
+    updateModifiedTimeData(modifiedTimeData)
+}
+
+export const run_deploy = async (project) => {
+    if (!(await isModified(project))) {
+        console.log(`✅  Skip deploy ${project}`)
+        return
+    }
+    let output = await spinner(
+        `Deploying project ${project}`,
+        () => $`mvn -pl ${project} clean deploy -D skipTests -s ${maven_setting}`
+    )
+    console.log(`✅  Finished deploy ${project} (${millisecondToString(output['duration'])})`)
+    await updateModifiedTime(project)
+}
+
+export const run_deploy_root = async () => {
+    if (!(await isModified('pom.xml'))) {
+        console.log(`✅  Skip deploy root`)
+        return
+    }
+    let output = await spinner(
+        `Deploying root`,
+        () => $`mvn clean deploy -N -D skipTests -s ${maven_setting}`
+    )
+    console.log(`✅  Finished deploy root (${millisecondToString(output['duration'])})`)
+    await updateModifiedTime('pom.xml')
+}
+
+export const run_deploy_batch = async (projects) => {
+    for (const project of projects) {
+        await run_deploy(project)
+    }
+}
+
+export const run_package = async (project, profile = 'b2b12') => {
+    let output = await spinner(
+        `Packaging project ${project}${isEqual(profile, 'b2b12') ? '' : ` ${profile}`}`,
+        () => $`mvn -pl ${project} clean package -D skipTests -P ${profile} -s ${maven_setting}`
+    )
+    console.log(`✅  Finished package ${project}${isEqual(profile, 'b2b12') ? '' : ` ${profile}`} (${millisecondToString(output['duration'])})`)
+}
+
+export const run_package_batch = async (projects) => {
+    for (const project of projects) {
+        await run_package(project)
+    }
+}
+
+export const upload = async (file_path) => {
+    let start = new Date().getTime()
+    let basename = path.basename(file_path)
+    let response = await spinner(
+        `Uploading project ${file_path}`,
+        () => fetch(`${upload_url}/file/upload/${basename}`, {
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/octet-stream',
+                'Authorization': `Basic ${Buffer.from(`${upload_username}:${upload_password}`).toString('base64')}`,
+            },
+            body: fs.createReadStream(file_path),
+            duplex: 'half',
+        })
+    )
+
+    if (!isEqual(response.status, 200)) {
+        throw response
+    }
+    console.log(`✅  Finished upload ${file_path} (${millisecondToString((new Date().getTime()) - start)})`)
+    console.log(`📘  Uploaded ${fileSize(fs.statSync(file_path).size)}`)
+    console.log(`📘  MD5 ${md5file.sync(file_path)}`)
+    console.log(`📘  Download curl http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.124:36800/file/download/${basename} -o ${basename}`)
+    fs.rmSync(file_path)
+}
+
+export const run_upload = async (pattern) => {
+    for (let p of glob.sync(pattern)) {
+        await upload(path.join(trim($.sync`pwd`.text()), p))
+    }
+}
+
+export const run_upload_normal = async (project) => {
+    await run_upload(`${project}/target/${project}-1.0.0-SNAPSHOT.jar`)
+}

bin/library.sh

@@ -1,36 +0,0 @@
-#!/bin/bash
-
-build_profile=b2b12
-
-upload_username=AxhEbscwsJDbYMH2
-upload_password=cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4
-upload_url=http://$upload_username:$upload_password@132.126.207.124:36800
-
-root_path=$(dirname $(cd $(dirname $0);pwd))
-
-function upload() {
-  source_file_path=$(realpath $1)
-  file_name=$(basename $source_file_path)
-  echo "↪ Source md5: $(md5sum $source_file_path | awk '{print $1}')"
-  echo "↪ Uploading $source_file_path"
-  curl $upload_url/file/upload/$file_name -T $source_file_path
-  echo "↪ Upload ytp success"
-  echo "↪ Download: curl $upload_url/file/download/$file_name -o $file_name"
-  echo "↪ Delete source"
-  rm $source_file_path
-}
-
-function joining {
-  local d=${1-} f=${2-}
-  if shift 2; then
-    printf %s "$f" "${@/#/$d}"
-  fi
-}
-
-function deploy() {
-  mvn -pl $(joining , $@) clean install -D skipTests
-}
-
-function package() {
-  mvn -pl $(joining , $@) clean package -D skipTests -P $build_profile
-}

bin/package.json

@@ -0,0 +1,19 @@
+{
+  "name": "bin",
+  "version": "1.0.0",
+  "type": "module",
+  "dependencies": {
+    "@webpod/ps": "^0.1.1",
+    "chalk": "^5.4.1",
+    "envapi": "^0.2.3",
+    "fs-extra": "^11.3.0",
+    "globby": "^14.1.0",
+    "licia": "^1.48.0",
+    "md5-file": "^5.0.0",
+    "minimist": "^1.2.8",
+    "node-fetch-native": "^1.6.6",
+    "which": "^5.0.0",
+    "yaml": "^2.8.0",
+    "zx": "^8.5.4"
+  }
+}

bin/pnpm-lock.yaml

@@ -0,0 +1,337 @@
+lockfileVersion: '9.0'
+
+settings:
+  autoInstallPeers: true
+  excludeLinksFromLockfile: false
+
+importers:
+
+  .:
+    dependencies:
+      '@webpod/ps':
+        specifier: ^0.1.1
+        version: 0.1.1
+      chalk:
+        specifier: ^5.4.1
+        version: 5.4.1
+      envapi:
+        specifier: ^0.2.3
+        version: 0.2.3
+      fs-extra:
+        specifier: ^11.3.0
+        version: 11.3.0
+      globby:
+        specifier: ^14.1.0
+        version: 14.1.0
+      licia:
+        specifier: ^1.48.0
+        version: 1.48.0
+      md5-file:
+        specifier: ^5.0.0
+        version: 5.0.0
+      minimist:
+        specifier: ^1.2.8
+        version: 1.2.8
+      node-fetch-native:
+        specifier: ^1.6.6
+        version: 1.6.6
+      which:
+        specifier: ^5.0.0
+        version: 5.0.0
+      yaml:
+        specifier: ^2.8.0
+        version: 2.8.0
+      zx:
+        specifier: ^8.5.4
+        version: 8.5.4
+
+packages:
+
+  '@nodelib/fs.scandir@2.1.5':
+    resolution: {integrity: sha512-vq24Bq3ym5HEQm2NKCr3yXDwjc7vTsEThRDnkp2DK9p1uqLR+DHurm/NOTo0KG7HYHU7eppKZj3MyqYuMBf62g==}
+    engines: {node: '>= 8'}
+
+  '@nodelib/fs.stat@2.0.5':
+    resolution: {integrity: sha512-RkhPPp2zrqDAQA/2jNhnztcPAlv64XdhIp7a7454A5ovI7Bukxgt7MX7udwAu3zg1DcpPU0rz3VV1SeaqvY4+A==}
+    engines: {node: '>= 8'}
+
+  '@nodelib/fs.walk@1.2.8':
+    resolution: {integrity: sha512-oGB+UxlgWcgQkgwo8GcEGwemoTFt3FIO9ababBmaGwXIoBKZ+GTy0pP185beGg7Llih/NSHSV2XAs1lnznocSg==}
+    engines: {node: '>= 8'}
+
+  '@sindresorhus/merge-streams@2.3.0':
+    resolution: {integrity: sha512-LtoMMhxAlorcGhmFYI+LhPgbPZCkgP6ra1YL604EeF6U98pLlQ3iWIGMdWSC+vWmPBWBNgmDBAhnAobLROJmwg==}
+    engines: {node: '>=18'}
+
+  '@webpod/ingrid@0.0.0-beta.3':
+    resolution: {integrity: sha512-PkorwT+q/MiIF+It47ORX0wCYHumOeMKwp5KX5WbUvbCeOtSB6b5UUC5FvzlijdwK/YPR+sOitQzyVSsRrMmJA==}
+
+  '@webpod/ps@0.1.1':
+    resolution: {integrity: sha512-SIgb4wWEVlKgdRByMMz9c3y1hpKfNm2sbretCPD49O9LG6itibULMkiRISdkpMdGRiUpbGHp8tiN3ZLYRDHj1g==}
+
+  braces@3.0.3:
+    resolution: {integrity: sha512-yQbXgO/OSZVD2IsiLlro+7Hf6Q18EJrKSEsdoMzKePKXct3gvD8oLcOQdIzGupr5Fj+EDe8gO/lxc1BzfMpxvA==}
+    engines: {node: '>=8'}
+
+  chalk@5.4.1:
+    resolution: {integrity: sha512-zgVZuo2WcZgfUEmsn6eO3kINexW8RAE4maiQ8QNs8CtpPCSyMiYsULR3HQYkm3w8FIA3SberyMJMSldGsW+U3w==}
+    engines: {node: ^12.17.0 || ^14.13 || >=16.0.0}
+
+  envapi@0.2.3:
+    resolution: {integrity: sha512-kSPSecU+/eH0IajEYZ/LndeBjzSBmLyp/SZFgx8Zgyeu0SoGioHkICOOVJgJLaX/rqZrCrQ+eDxiaYNVcyCsbQ==}
+
+  fast-glob@3.3.3:
+    resolution: {integrity: sha512-7MptL8U0cqcFdzIzwOTHoilX9x5BrNqye7Z/LuC7kCMRio1EMSyqRK3BEAUD7sXRq4iT4AzTVuZdhgQ2TCvYLg==}
+    engines: {node: '>=8.6.0'}
+
+  fastq@1.19.1:
+    resolution: {integrity: sha512-GwLTyxkCXjXbxqIhTsMI2Nui8huMPtnxg7krajPJAjnEG/iiOS7i+zCtWGZR9G0NBKbXKh6X9m9UIsYX/N6vvQ==}
+
+  fill-range@7.1.1:
+    resolution: {integrity: sha512-YsGpe3WHLK8ZYi4tWDg2Jy3ebRz2rXowDxnld4bkQB00cc/1Zw9AWnC0i9ztDJitivtQvaI9KaLyKrc+hBW0yg==}
+    engines: {node: '>=8'}
+
+  fs-extra@11.3.0:
+    resolution: {integrity: sha512-Z4XaCL6dUDHfP/jT25jJKMmtxvuwbkrD1vNSMFlo9lNLY2c5FHYSQgHPRZUjAB26TpDEoW9HCOgplrdbaPV/ew==}
+    engines: {node: '>=14.14'}
+
+  glob-parent@5.1.2:
+    resolution: {integrity: sha512-AOIgSQCepiJYwP3ARnGx+5VnTu2HBYdzbGP45eLw1vr3zB3vZLeyed1sC9hnbcOc9/SrMyM5RPQrkGz4aS9Zow==}
+    engines: {node: '>= 6'}
+
+  globby@14.1.0:
+    resolution: {integrity: sha512-0Ia46fDOaT7k4og1PDW4YbodWWr3scS2vAr2lTbsplOt2WkKp0vQbkI9wKis/T5LV/dqPjO3bpS/z6GTJB82LA==}
+    engines: {node: '>=18'}
+
+  graceful-fs@4.2.11:
+    resolution: {integrity: sha512-RbJ5/jmFcNNCcDV5o9eTnBLJ/HszWV0P73bc+Ff4nS/rJj+YaS6IGyiOL0VoBYX+l1Wrl3k63h/KrH+nhJ0XvQ==}
+
+  ignore@7.0.4:
+    resolution: {integrity: sha512-gJzzk+PQNznz8ysRrC0aOkBNVRBDtE1n53IqyqEf3PXrYwomFs5q4pGMizBMJF+ykh03insJ27hB8gSrD2Hn8A==}
+    engines: {node: '>= 4'}
+
+  is-extglob@2.1.1:
+    resolution: {integrity: sha512-SbKbANkN603Vi4jEZv49LeVJMn4yGwsbzZworEoyEiutsN3nJYdbO36zfhGJ6QEDpOZIFkDtnq5JRxmvl3jsoQ==}
+    engines: {node: '>=0.10.0'}
+
+  is-glob@4.0.3:
+    resolution: {integrity: sha512-xelSayHH36ZgE7ZWhli7pW34hNbNl8Ojv5KVmkJD4hBdD3th8Tfk9vYasLM+mXWOZhFkgZfxhLSnrwRr4elSSg==}
+    engines: {node: '>=0.10.0'}
+
+  is-number@7.0.0:
+    resolution: {integrity: sha512-41Cifkg6e8TylSpdtTpeLVMqvSBEVzTttHvERD741+pnZ8ANv0004MRL43QKPDlK9cGvNp6NZWZUBlbGXYxxng==}
+    engines: {node: '>=0.12.0'}
+
+  isexe@3.1.1:
+    resolution: {integrity: sha512-LpB/54B+/2J5hqQ7imZHfdU31OlgQqx7ZicVlkm9kzg9/w8GKLEcFfJl/t7DCEDueOyBAD6zCCwTO6Fzs0NoEQ==}
+    engines: {node: '>=16'}
+
+  jsonfile@6.1.0:
+    resolution: {integrity: sha512-5dgndWOriYSm5cnYaJNhalLNDKOqFwyDB/rr1E9ZsGciGvKPs8R2xYGCacuf3z6K1YKDz182fd+fY3cn3pMqXQ==}
+
+  licia@1.48.0:
+    resolution: {integrity: sha512-bBWiT5CSdEtwuAHiYTJ74yItCjIFdHi4xiFk6BRDfKa+sdCpkUHp69YKb5udNOJlHDzFjNjcMgNZ/+wQIHrB8A==}
+
+  md5-file@5.0.0:
+    resolution: {integrity: sha512-xbEFXCYVWrSx/gEKS1VPlg84h/4L20znVIulKw6kMfmBUAZNAnF00eczz9ICMl+/hjQGo5KSXRxbL/47X3rmMw==}
+    engines: {node: '>=10.13.0'}
+    hasBin: true
+
+  merge2@1.4.1:
+    resolution: {integrity: sha512-8q7VEgMJW4J8tcfVPy8g09NcQwZdbwFEqhe/WZkoIzjn/3TGDwtOCYtXGxA3O8tPzpczCCDgv+P2P5y00ZJOOg==}
+    engines: {node: '>= 8'}
+
+  micromatch@4.0.8:
+    resolution: {integrity: sha512-PXwfBhYu0hBCPw8Dn0E+WDYb7af3dSLVWKi3HGv84IdF4TyFoC0ysxFd0Goxw7nSv4T/PzEJQxsYsEiFCKo2BA==}
+    engines: {node: '>=8.6'}
+
+  minimist@1.2.8:
+    resolution: {integrity: sha512-2yyAR8qBkN3YuheJanUpWC5U3bb5osDywNB8RzDVlDwDHbocAJveqqj1u8+SVD7jkWT4yvsHCpWqqWqAxb0zCA==}
+
+  node-fetch-native@1.6.6:
+    resolution: {integrity: sha512-8Mc2HhqPdlIfedsuZoc3yioPuzp6b+L5jRCRY1QzuWZh2EGJVQrGppC6V6cF0bLdbW0+O2YpqCA25aF/1lvipQ==}
+
+  path-type@6.0.0:
+    resolution: {integrity: sha512-Vj7sf++t5pBD637NSfkxpHSMfWaeig5+DKWLhcqIYx6mWQz5hdJTGDVMQiJcw1ZYkhs7AazKDGpRVji1LJCZUQ==}
+    engines: {node: '>=18'}
+
+  picomatch@2.3.1:
+    resolution: {integrity: sha512-JU3teHTNjmE2VCGFzuY8EXzCDVwEqB2a8fsIvwaStHhAWJEeVd1o1QD80CU6+ZdEXXSLbSsuLwJjkCBWqRQUVA==}
+    engines: {node: '>=8.6'}
+
+  queue-microtask@1.2.3:
+    resolution: {integrity: sha512-NuaNSa6flKT5JaSYQzJok04JzTL1CA6aGhv5rfLW3PgqA+M2ChpZQnAC8h8i4ZFkBS8X5RqkDBHA7r4hej3K9A==}
+
+  reusify@1.1.0:
+    resolution: {integrity: sha512-g6QUff04oZpHs0eG5p83rFLhHeV00ug/Yf9nZM6fLeUrPguBTkTQOdpAWWspMh55TZfVQDPaN3NQJfbVRAxdIw==}
+    engines: {iojs: '>=1.0.0', node: '>=0.10.0'}
+
+  run-parallel@1.2.0:
+    resolution: {integrity: sha512-5l4VyZR86LZ/lDxZTR6jqL8AFE2S0IFLMP26AbjsLVADxHdhB/c0GUsH+y39UfCi3dzz8OlQuPmnaJOMoDHQBA==}
+
+  slash@5.1.0:
+    resolution: {integrity: sha512-ZA6oR3T/pEyuqwMgAKT0/hAv8oAXckzbkmR0UkUosQ+Mc4RxGoJkRmwHgHufaenlyAgE1Mxgpdcrf75y6XcnDg==}
+    engines: {node: '>=14.16'}
+
+  to-regex-range@5.0.1:
+    resolution: {integrity: sha512-65P7iz6X5yEr1cwcgvQxbbIw7Uk3gOy5dIdtZ4rDveLqhrdJP+Li/Hx6tyK0NEb+2GCyneCMJiGqrADCSNk8sQ==}
+    engines: {node: '>=8.0'}
+
+  unicorn-magic@0.3.0:
+    resolution: {integrity: sha512-+QBBXBCvifc56fsbuxZQ6Sic3wqqc3WWaqxs58gvJrcOuN83HGTCwz3oS5phzU9LthRNE9VrJCFCLUgHeeFnfA==}
+    engines: {node: '>=18'}
+
+  universalify@2.0.1:
+    resolution: {integrity: sha512-gptHNQghINnc/vTGIk0SOFGFNXw7JVrlRUtConJRlvaw6DuX0wO5Jeko9sWrMBhh+PsYAZ7oXAiOnf/UKogyiw==}
+    engines: {node: '>= 10.0.0'}
+
+  which@5.0.0:
+    resolution: {integrity: sha512-JEdGzHwwkrbWoGOlIHqQ5gtprKGOenpDHpxE9zVR1bWbOtYRyPPHMe9FaP6x61CmNaTThSkb0DAJte5jD+DmzQ==}
+    engines: {node: ^18.17.0 || >=20.5.0}
+    hasBin: true
+
+  yaml@2.8.0:
+    resolution: {integrity: sha512-4lLa/EcQCB0cJkyts+FpIRx5G/llPxfP6VQU5KByHEhLxY3IJCH0f0Hy1MHI8sClTvsIb8qwRJ6R/ZdlDJ/leQ==}
+    engines: {node: '>= 14.6'}
+    hasBin: true
+
+  zurk@0.11.2:
+    resolution: {integrity: sha512-OKUQsmG588B18hzO4ThzOU0NUwr4C8aKl9NjGQfXUv5fskLfS6Sj3XGNbTzKj3d2+jWvmnqS2cgrwYX6bIkDyA==}
+
+  zx@8.5.4:
+    resolution: {integrity: sha512-44oKea9Sa8ZnOkTnS6fRJpg3quzgnbB43nLrVfYnqE86J4sxgZMUDLezzKET/FdOAVkF4X+Alm9Bume+W+RW9Q==}
+    engines: {node: '>= 12.17.0'}
+    hasBin: true
+
+snapshots:
+
+  '@nodelib/fs.scandir@2.1.5':
+    dependencies:
+      '@nodelib/fs.stat': 2.0.5
+      run-parallel: 1.2.0
+
+  '@nodelib/fs.stat@2.0.5': {}
+
+  '@nodelib/fs.walk@1.2.8':
+    dependencies:
+      '@nodelib/fs.scandir': 2.1.5
+      fastq: 1.19.1
+
+  '@sindresorhus/merge-streams@2.3.0': {}
+
+  '@webpod/ingrid@0.0.0-beta.3': {}
+
+  '@webpod/ps@0.1.1':
+    dependencies:
+      '@webpod/ingrid': 0.0.0-beta.3
+      zurk: 0.11.2
+
+  braces@3.0.3:
+    dependencies:
+      fill-range: 7.1.1
+
+  chalk@5.4.1: {}
+
+  envapi@0.2.3: {}
+
+  fast-glob@3.3.3:
+    dependencies:
+      '@nodelib/fs.stat': 2.0.5
+      '@nodelib/fs.walk': 1.2.8
+      glob-parent: 5.1.2
+      merge2: 1.4.1
+      micromatch: 4.0.8
+
+  fastq@1.19.1:
+    dependencies:
+      reusify: 1.1.0
+
+  fill-range@7.1.1:
+    dependencies:
+      to-regex-range: 5.0.1
+
+  fs-extra@11.3.0:
+    dependencies:
+      graceful-fs: 4.2.11
+      jsonfile: 6.1.0
+      universalify: 2.0.1
+
+  glob-parent@5.1.2:
+    dependencies:
+      is-glob: 4.0.3
+
+  globby@14.1.0:
+    dependencies:
+      '@sindresorhus/merge-streams': 2.3.0
+      fast-glob: 3.3.3
+      ignore: 7.0.4
+      path-type: 6.0.0
+      slash: 5.1.0
+      unicorn-magic: 0.3.0
+
+  graceful-fs@4.2.11: {}
+
+  ignore@7.0.4: {}
+
+  is-extglob@2.1.1: {}
+
+  is-glob@4.0.3:
+    dependencies:
+      is-extglob: 2.1.1
+
+  is-number@7.0.0: {}
+
+  isexe@3.1.1: {}
+
+  jsonfile@6.1.0:
+    dependencies:
+      universalify: 2.0.1
+    optionalDependencies:
+      graceful-fs: 4.2.11
+
+  licia@1.48.0: {}
+
+  md5-file@5.0.0: {}
+
+  merge2@1.4.1: {}
+
+  micromatch@4.0.8:
+    dependencies:
+      braces: 3.0.3
+      picomatch: 2.3.1
+
+  minimist@1.2.8: {}
+
+  node-fetch-native@1.6.6: {}
+
+  path-type@6.0.0: {}
+
+  picomatch@2.3.1: {}
+
+  queue-microtask@1.2.3: {}
+
+  reusify@1.1.0: {}
+
+  run-parallel@1.2.0:
+    dependencies:
+      queue-microtask: 1.2.3
+
+  slash@5.1.0: {}
+
+  to-regex-range@5.0.1:
+    dependencies:
+      is-number: 7.0.0
+
+  unicorn-magic@0.3.0: {}
+
+  universalify@2.0.1: {}
+
+  which@5.0.0:
+    dependencies:
+      isexe: 3.1.1
+
+  yaml@2.8.0: {}
+
+  zurk@0.11.2: {}
+
+  zx@8.5.4: {}

bin/test.js

@@ -0,0 +1,3 @@
+import {isModified} from './library.js'
+
+console.log(await isModified('/Users/lanyuanxiaoyao/Project/IdeaProjects/hudi-service/pom.xml'))

pom.xml

@@ -417,6 +417,16 @@
                     <artifactId>maven-shade-plugin</artifactId>
                     <version>3.3.0</version>
                 </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-jar-plugin</artifactId>
+                    <version>3.4.2</version>
+                </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-invoker-plugin</artifactId>
+                    <version>3.9.0</version>
+                </plugin>
                 <plugin>
                     <groupId>org.springframework.boot</groupId>
                     <artifactId>spring-boot-maven-plugin</artifactId>

service-ai/.gitignore

@@ -1,84 +0,0 @@
-.idea/**/workspace.xml
-.idea/**/tasks.xml
-.idea/**/usage.statistics.xml
-.idea/**/dictionaries
-.idea/**/shelf
-.idea/**/aws.xml
-.idea/**/contentModel.xml
-.idea/**/dataSources/
-.idea/**/dataSources.ids
-.idea/**/dataSources.local.xml
-.idea/**/sqlDataSources.xml
-.idea/**/dynamic.xml
-.idea/**/uiDesigner.xml
-.idea/**/dbnavigator.xml
-.idea/**/gradle.xml
-.idea/**/libraries
-cmake-build-*/
-.idea/**/mongoSettings.xml
-*.iws
-out/
-.idea_modules/
-atlassian-ide-plugin.xml
-.idea/replstate.xml
-.idea/sonarlint/
-com_crashlytics_export_strings.xml
-crashlytics.properties
-crashlytics-build.properties
-fabric.properties
-.idea/httpRequests
-.idea/caches/build_file_checksums.ser
-target/
-pom.xml.tag
-pom.xml.releaseBackup
-pom.xml.versionsBackup
-pom.xml.next
-release.properties
-dependency-reduced-pom.xml
-buildNumber.properties
-.mvn/timing.properties
-.mvn/wrapper/maven-wrapper.jar
-.project
-.classpath
-*~
-.fuse_hidden*
-.directory
-.Trash-*
-.nfs*
-.gradle
-**/build/
-!src/**/build/
-gradle-app.setting
-!gradle-wrapper.jar
-!gradle-wrapper.properties
-.gradletasknamecache
-Thumbs.db
-Thumbs.db:encryptable
-ehthumbs.db
-ehthumbs_vista.db
-*.stackdump
-[Dd]esktop.ini
-$RECYCLE.BIN/
-*.cab
-*.msi
-*.msix
-*.msm
-*.msp
-*.lnk
-.DS_Store
-.AppleDouble
-.LSOverride
-Icon
-._*
-.DocumentRevisions-V100
-.fseventsd
-.Spotlight-V100
-.TemporaryItems
-.Trashes
-.VolumeIcon.icns
-.com.apple.timemachine.donotpresent
-.AppleDB
-.AppleDesktop
-Network Trash Folder
-Temporary Items
-.apdisk

service-ai/.idea/.gitignore

@@ -1,10 +0,0 @@
-# 默认忽略的文件
-/shelf/
-/workspace.xml
-# 基于编辑器的 HTTP 客户端请求
-/httpRequests/
-# 依赖于环境的 Maven 主目录路径
-/mavenHomeManager.xml
-# Datasource local storage ignored files
-/dataSources/
-/dataSources.local.xml

service-ai/.idea/ApifoxUploaderProjectSetting.xml

@@ -1,6 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ApifoxUploaderProjectSetting">
-    <option name="apiAccessToken" value="APS-0ZZaS4q0gUiFOlbBJMN8hAmS7viQNi4D" />
-  </component>
-</project>

service-ai/.idea/codeStyles/Project.xml

@@ -1,29 +0,0 @@
-<component name="ProjectCodeStyleConfiguration">
-  <code_scheme name="Project" version="173">
-    <JavaCodeStyleSettings>
-      <option name="PACKAGES_TO_USE_IMPORT_ON_DEMAND">
-        <value />
-      </option>
-      <option name="IMPORT_LAYOUT_TABLE">
-        <value>
-          <package name="" withSubpackages="true" static="false" module="true" />
-          <package name="" withSubpackages="true" static="false" />
-          <emptyLine />
-          <package name="" withSubpackages="true" static="true" />
-        </value>
-      </option>
-    </JavaCodeStyleSettings>
-    <JetCodeStyleSettings>
-      <option name="CODE_STYLE_DEFAULTS" value="KOTLIN_OFFICIAL" />
-    </JetCodeStyleSettings>
-    <ScalaCodeStyleSettings>
-      <option name="MULTILINE_STRING_CLOSING_QUOTES_ON_NEW_LINE" value="true" />
-    </ScalaCodeStyleSettings>
-    <codeStyleSettings language="JAVA">
-      <option name="KEEP_FIRST_COLUMN_COMMENT" value="false" />
-    </codeStyleSettings>
-    <codeStyleSettings language="kotlin">
-      <option name="CODE_STYLE_DEFAULTS" value="KOTLIN_OFFICIAL" />
-    </codeStyleSettings>
-  </code_scheme>
-</component>

service-ai/.idea/codeStyles/codeStyleConfig.xml

@@ -1,5 +0,0 @@
-<component name="ProjectCodeStyleConfiguration">
-  <state>
-    <option name="PREFERRED_PROJECT_CODE_STYLE" value="Default" />
-  </state>
-</component>

service-ai/.idea/compiler.xml

@@ -1,15 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="CompilerConfiguration">
-    <annotationProcessing>
-      <profile name="Maven default annotation processors profile" enabled="true">
-        <sourceOutputDir name="target/generated-sources/annotations" />
-        <sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
-        <outputRelativeToContentRoot value="true" />
-        <module name="service-ai-knowledge" />
-        <module name="service-ai-chat" />
-        <module name="service-ai-core" />
-      </profile>
-    </annotationProcessing>
-  </component>
-</project>

service-ai/.idea/encodings.xml

@@ -1,13 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="Encoding">
-    <file url="file://$PROJECT_DIR$/service-ai-chat/src/main/java" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/service-ai-chat/src/main/resources" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/service-ai-core/src/main/java" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/service-ai-core/src/main/resources" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/service-ai-knowledge/src/main/java" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/service-ai-knowledge/src/main/resources" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
-    <file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
-  </component>
-</project>

service-ai/.idea/jarRepositories.xml

@@ -1,30 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="RemoteRepositoriesConfiguration">
-    <remote-repository>
-      <option name="id" value="central" />
-      <option name="name" value="Central Repository" />
-      <option name="url" value="https://repo.maven.apache.org/maven2" />
-    </remote-repository>
-    <remote-repository>
-      <option name="id" value="lanyuanxiaoyao-maven-central" />
-      <option name="name" value="lanyuanxiaoyao-maven-central" />
-      <option name="url" value="https://maven.lanyuanxiaoyao.com/central" />
-    </remote-repository>
-    <remote-repository>
-      <option name="id" value="central" />
-      <option name="name" value="Maven Central repository" />
-      <option name="url" value="https://repo1.maven.org/maven2" />
-    </remote-repository>
-    <remote-repository>
-      <option name="id" value="jboss.community" />
-      <option name="name" value="JBoss Community repository" />
-      <option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
-    </remote-repository>
-    <remote-repository>
-      <option name="id" value="central" />
-      <option name="name" value="Central Repository" />
-      <option name="url" value="https://maven.lanyuanxiaoyao.com/central" />
-    </remote-repository>
-  </component>
-</project>

service-ai/.idea/misc.xml

@@ -1,12 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ExternalStorageConfigurationManager" enabled="true" />
-  <component name="MavenProjectsManager">
-    <option name="originalFiles">
-      <list>
-        <option value="$PROJECT_DIR$/pom.xml" />
-      </list>
-    </option>
-  </component>
-  <component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="temurin-17" project-jdk-type="JavaSDK" />
-</project>

service-ai/.idea/vcs.xml

@@ -1,6 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="VcsDirectoryMappings">
-    <mapping directory="$PROJECT_DIR$/.." vcs="Git" />
-  </component>
-</project>

service-ai/bin/.gitignore

@@ -0,0 +1,102 @@
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+!.vscode/*.code-snippets
+.history/
+*.vsix
+*~
+.fuse_hidden*
+.directory
+.Trash-*
+.nfs*
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+.pnpm-debug.log*
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+pids
+*.pid
+*.seed
+*.pid.lock
+lib-cov
+coverage
+*.lcov
+.nyc_output
+.grunt
+bower_components
+.lock-wscript
+build/Release
+node_modules/
+jspm_packages/
+web_modules/
+*.tsbuildinfo
+.npm
+.eslintcache
+.stylelintcache
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+.node_repl_history
+*.tgz
+.yarn-integrity
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+.cache
+.parcel-cache
+.next
+out
+.nuxt
+dist
+.cache/
+.vuepress/dist
+.temp
+.docusaurus
+.serverless/
+.fusebox/
+.dynamodb/
+.tern-port
+.vscode-test
+.yarn/cache
+.yarn/unplugged
+.yarn/build-state.yml
+.yarn/install-state.gz
+.pnp.*
+Thumbs.db
+Thumbs.db:encryptable
+ehthumbs.db
+ehthumbs_vista.db
+*.stackdump
+[Dd]esktop.ini
+$RECYCLE.BIN/
+*.cab
+*.msi
+*.msix
+*.msm
+*.msp
+*.lnk
+.DS_Store
+.AppleDouble
+.LSOverride
+Icon
+._*
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk

service-ai/bin/build-ai-core.js

@@ -0,0 +1,12 @@
+import {cd, path} from 'zx'
+import {trim} from "licia";
+import {run_deploy} from '../../bin/library.js'
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+  await run_deploy('service-ai-core')
+} catch (e) {
+  console.error(e)
+}

service-ai/bin/build-ai-web.js

@@ -0,0 +1,21 @@
+import {
+  cd,
+  path,
+} from 'zx'
+import {trim} from "licia";
+import {
+  run_deploy,
+  run_package,
+  run_upload_normal,
+} from '../../bin/library.js'
+
+// 切换目录
+cd(trim(path.dirname(import.meta.dirname)))
+// 执行流程
+try {
+  await run_deploy('service-ai-core')
+  await run_package('service-ai-web')
+  await run_upload_normal('service-ai-web')
+} catch (e) {
+  console.error(e)
+}

service-ai/bin/package.json

@@ -0,0 +1,19 @@
+{
+  "name": "bin",
+  "version": "1.0.0",
+  "type": "module",
+  "dependencies": {
+    "@webpod/ps": "^0.1.1",
+    "chalk": "^5.4.1",
+    "envapi": "^0.2.3",
+    "fs-extra": "^11.3.0",
+    "globby": "^14.1.0",
+    "licia": "^1.48.0",
+    "md5-file": "^5.0.0",
+    "minimist": "^1.2.8",
+    "node-fetch-native": "^1.6.6",
+    "which": "^5.0.0",
+    "yaml": "^2.8.0",
+    "zx": "^8.5.4"
+  }
+}

service-ai/bin/pnpm-lock.yaml

@@ -0,0 +1,337 @@
+lockfileVersion: '9.0'
+
+settings:
+  autoInstallPeers: true
+  excludeLinksFromLockfile: false
+
+importers:
+
+  .:
+    dependencies:
+      '@webpod/ps':
+        specifier: ^0.1.1
+        version: 0.1.1
+      chalk:
+        specifier: ^5.4.1
+        version: 5.4.1
+      envapi:
+        specifier: ^0.2.3
+        version: 0.2.3
+      fs-extra:
+        specifier: ^11.3.0
+        version: 11.3.0
+      globby:
+        specifier: ^14.1.0
+        version: 14.1.0
+      licia:
+        specifier: ^1.48.0
+        version: 1.48.0
+      md5-file:
+        specifier: ^5.0.0
+        version: 5.0.0
+      minimist:
+        specifier: ^1.2.8
+        version: 1.2.8
+      node-fetch-native:
+        specifier: ^1.6.6
+        version: 1.6.6
+      which:
+        specifier: ^5.0.0
+        version: 5.0.0
+      yaml:
+        specifier: ^2.8.0
+        version: 2.8.0
+      zx:
+        specifier: ^8.5.4
+        version: 8.5.4
+
+packages:
+
+  '@nodelib/fs.scandir@2.1.5':
+    resolution: {integrity: sha512-vq24Bq3ym5HEQm2NKCr3yXDwjc7vTsEThRDnkp2DK9p1uqLR+DHurm/NOTo0KG7HYHU7eppKZj3MyqYuMBf62g==}
+    engines: {node: '>= 8'}
+
+  '@nodelib/fs.stat@2.0.5':
+    resolution: {integrity: sha512-RkhPPp2zrqDAQA/2jNhnztcPAlv64XdhIp7a7454A5ovI7Bukxgt7MX7udwAu3zg1DcpPU0rz3VV1SeaqvY4+A==}
+    engines: {node: '>= 8'}
+
+  '@nodelib/fs.walk@1.2.8':
+    resolution: {integrity: sha512-oGB+UxlgWcgQkgwo8GcEGwemoTFt3FIO9ababBmaGwXIoBKZ+GTy0pP185beGg7Llih/NSHSV2XAs1lnznocSg==}
+    engines: {node: '>= 8'}
+
+  '@sindresorhus/merge-streams@2.3.0':
+    resolution: {integrity: sha512-LtoMMhxAlorcGhmFYI+LhPgbPZCkgP6ra1YL604EeF6U98pLlQ3iWIGMdWSC+vWmPBWBNgmDBAhnAobLROJmwg==}
+    engines: {node: '>=18'}
+
+  '@webpod/ingrid@0.0.0-beta.3':
+    resolution: {integrity: sha512-PkorwT+q/MiIF+It47ORX0wCYHumOeMKwp5KX5WbUvbCeOtSB6b5UUC5FvzlijdwK/YPR+sOitQzyVSsRrMmJA==}
+
+  '@webpod/ps@0.1.1':
+    resolution: {integrity: sha512-SIgb4wWEVlKgdRByMMz9c3y1hpKfNm2sbretCPD49O9LG6itibULMkiRISdkpMdGRiUpbGHp8tiN3ZLYRDHj1g==}
+
+  braces@3.0.3:
+    resolution: {integrity: sha512-yQbXgO/OSZVD2IsiLlro+7Hf6Q18EJrKSEsdoMzKePKXct3gvD8oLcOQdIzGupr5Fj+EDe8gO/lxc1BzfMpxvA==}
+    engines: {node: '>=8'}
+
+  chalk@5.4.1:
+    resolution: {integrity: sha512-zgVZuo2WcZgfUEmsn6eO3kINexW8RAE4maiQ8QNs8CtpPCSyMiYsULR3HQYkm3w8FIA3SberyMJMSldGsW+U3w==}
+    engines: {node: ^12.17.0 || ^14.13 || >=16.0.0}
+
+  envapi@0.2.3:
+    resolution: {integrity: sha512-kSPSecU+/eH0IajEYZ/LndeBjzSBmLyp/SZFgx8Zgyeu0SoGioHkICOOVJgJLaX/rqZrCrQ+eDxiaYNVcyCsbQ==}
+
+  fast-glob@3.3.3:
+    resolution: {integrity: sha512-7MptL8U0cqcFdzIzwOTHoilX9x5BrNqye7Z/LuC7kCMRio1EMSyqRK3BEAUD7sXRq4iT4AzTVuZdhgQ2TCvYLg==}
+    engines: {node: '>=8.6.0'}
+
+  fastq@1.19.1:
+    resolution: {integrity: sha512-GwLTyxkCXjXbxqIhTsMI2Nui8huMPtnxg7krajPJAjnEG/iiOS7i+zCtWGZR9G0NBKbXKh6X9m9UIsYX/N6vvQ==}
+
+  fill-range@7.1.1:
+    resolution: {integrity: sha512-YsGpe3WHLK8ZYi4tWDg2Jy3ebRz2rXowDxnld4bkQB00cc/1Zw9AWnC0i9ztDJitivtQvaI9KaLyKrc+hBW0yg==}
+    engines: {node: '>=8'}
+
+  fs-extra@11.3.0:
+    resolution: {integrity: sha512-Z4XaCL6dUDHfP/jT25jJKMmtxvuwbkrD1vNSMFlo9lNLY2c5FHYSQgHPRZUjAB26TpDEoW9HCOgplrdbaPV/ew==}
+    engines: {node: '>=14.14'}
+
+  glob-parent@5.1.2:
+    resolution: {integrity: sha512-AOIgSQCepiJYwP3ARnGx+5VnTu2HBYdzbGP45eLw1vr3zB3vZLeyed1sC9hnbcOc9/SrMyM5RPQrkGz4aS9Zow==}
+    engines: {node: '>= 6'}
+
+  globby@14.1.0:
+    resolution: {integrity: sha512-0Ia46fDOaT7k4og1PDW4YbodWWr3scS2vAr2lTbsplOt2WkKp0vQbkI9wKis/T5LV/dqPjO3bpS/z6GTJB82LA==}
+    engines: {node: '>=18'}
+
+  graceful-fs@4.2.11:
+    resolution: {integrity: sha512-RbJ5/jmFcNNCcDV5o9eTnBLJ/HszWV0P73bc+Ff4nS/rJj+YaS6IGyiOL0VoBYX+l1Wrl3k63h/KrH+nhJ0XvQ==}
+
+  ignore@7.0.4:
+    resolution: {integrity: sha512-gJzzk+PQNznz8ysRrC0aOkBNVRBDtE1n53IqyqEf3PXrYwomFs5q4pGMizBMJF+ykh03insJ27hB8gSrD2Hn8A==}
+    engines: {node: '>= 4'}
+
+  is-extglob@2.1.1:
+    resolution: {integrity: sha512-SbKbANkN603Vi4jEZv49LeVJMn4yGwsbzZworEoyEiutsN3nJYdbO36zfhGJ6QEDpOZIFkDtnq5JRxmvl3jsoQ==}
+    engines: {node: '>=0.10.0'}
+
+  is-glob@4.0.3:
+    resolution: {integrity: sha512-xelSayHH36ZgE7ZWhli7pW34hNbNl8Ojv5KVmkJD4hBdD3th8Tfk9vYasLM+mXWOZhFkgZfxhLSnrwRr4elSSg==}
+    engines: {node: '>=0.10.0'}
+
+  is-number@7.0.0:
+    resolution: {integrity: sha512-41Cifkg6e8TylSpdtTpeLVMqvSBEVzTttHvERD741+pnZ8ANv0004MRL43QKPDlK9cGvNp6NZWZUBlbGXYxxng==}
+    engines: {node: '>=0.12.0'}
+
+  isexe@3.1.1:
+    resolution: {integrity: sha512-LpB/54B+/2J5hqQ7imZHfdU31OlgQqx7ZicVlkm9kzg9/w8GKLEcFfJl/t7DCEDueOyBAD6zCCwTO6Fzs0NoEQ==}
+    engines: {node: '>=16'}
+
+  jsonfile@6.1.0:
+    resolution: {integrity: sha512-5dgndWOriYSm5cnYaJNhalLNDKOqFwyDB/rr1E9ZsGciGvKPs8R2xYGCacuf3z6K1YKDz182fd+fY3cn3pMqXQ==}
+
+  licia@1.48.0:
+    resolution: {integrity: sha512-bBWiT5CSdEtwuAHiYTJ74yItCjIFdHi4xiFk6BRDfKa+sdCpkUHp69YKb5udNOJlHDzFjNjcMgNZ/+wQIHrB8A==}
+
+  md5-file@5.0.0:
+    resolution: {integrity: sha512-xbEFXCYVWrSx/gEKS1VPlg84h/4L20znVIulKw6kMfmBUAZNAnF00eczz9ICMl+/hjQGo5KSXRxbL/47X3rmMw==}
+    engines: {node: '>=10.13.0'}
+    hasBin: true
+
+  merge2@1.4.1:
+    resolution: {integrity: sha512-8q7VEgMJW4J8tcfVPy8g09NcQwZdbwFEqhe/WZkoIzjn/3TGDwtOCYtXGxA3O8tPzpczCCDgv+P2P5y00ZJOOg==}
+    engines: {node: '>= 8'}
+
+  micromatch@4.0.8:
+    resolution: {integrity: sha512-PXwfBhYu0hBCPw8Dn0E+WDYb7af3dSLVWKi3HGv84IdF4TyFoC0ysxFd0Goxw7nSv4T/PzEJQxsYsEiFCKo2BA==}
+    engines: {node: '>=8.6'}
+
+  minimist@1.2.8:
+    resolution: {integrity: sha512-2yyAR8qBkN3YuheJanUpWC5U3bb5osDywNB8RzDVlDwDHbocAJveqqj1u8+SVD7jkWT4yvsHCpWqqWqAxb0zCA==}
+
+  node-fetch-native@1.6.6:
+    resolution: {integrity: sha512-8Mc2HhqPdlIfedsuZoc3yioPuzp6b+L5jRCRY1QzuWZh2EGJVQrGppC6V6cF0bLdbW0+O2YpqCA25aF/1lvipQ==}
+
+  path-type@6.0.0:
+    resolution: {integrity: sha512-Vj7sf++t5pBD637NSfkxpHSMfWaeig5+DKWLhcqIYx6mWQz5hdJTGDVMQiJcw1ZYkhs7AazKDGpRVji1LJCZUQ==}
+    engines: {node: '>=18'}
+
+  picomatch@2.3.1:
+    resolution: {integrity: sha512-JU3teHTNjmE2VCGFzuY8EXzCDVwEqB2a8fsIvwaStHhAWJEeVd1o1QD80CU6+ZdEXXSLbSsuLwJjkCBWqRQUVA==}
+    engines: {node: '>=8.6'}
+
+  queue-microtask@1.2.3:
+    resolution: {integrity: sha512-NuaNSa6flKT5JaSYQzJok04JzTL1CA6aGhv5rfLW3PgqA+M2ChpZQnAC8h8i4ZFkBS8X5RqkDBHA7r4hej3K9A==}
+
+  reusify@1.1.0:
+    resolution: {integrity: sha512-g6QUff04oZpHs0eG5p83rFLhHeV00ug/Yf9nZM6fLeUrPguBTkTQOdpAWWspMh55TZfVQDPaN3NQJfbVRAxdIw==}
+    engines: {iojs: '>=1.0.0', node: '>=0.10.0'}
+
+  run-parallel@1.2.0:
+    resolution: {integrity: sha512-5l4VyZR86LZ/lDxZTR6jqL8AFE2S0IFLMP26AbjsLVADxHdhB/c0GUsH+y39UfCi3dzz8OlQuPmnaJOMoDHQBA==}
+
+  slash@5.1.0:
+    resolution: {integrity: sha512-ZA6oR3T/pEyuqwMgAKT0/hAv8oAXckzbkmR0UkUosQ+Mc4RxGoJkRmwHgHufaenlyAgE1Mxgpdcrf75y6XcnDg==}
+    engines: {node: '>=14.16'}
+
+  to-regex-range@5.0.1:
+    resolution: {integrity: sha512-65P7iz6X5yEr1cwcgvQxbbIw7Uk3gOy5dIdtZ4rDveLqhrdJP+Li/Hx6tyK0NEb+2GCyneCMJiGqrADCSNk8sQ==}
+    engines: {node: '>=8.0'}
+
+  unicorn-magic@0.3.0:
+    resolution: {integrity: sha512-+QBBXBCvifc56fsbuxZQ6Sic3wqqc3WWaqxs58gvJrcOuN83HGTCwz3oS5phzU9LthRNE9VrJCFCLUgHeeFnfA==}
+    engines: {node: '>=18'}
+
+  universalify@2.0.1:
+    resolution: {integrity: sha512-gptHNQghINnc/vTGIk0SOFGFNXw7JVrlRUtConJRlvaw6DuX0wO5Jeko9sWrMBhh+PsYAZ7oXAiOnf/UKogyiw==}
+    engines: {node: '>= 10.0.0'}
+
+  which@5.0.0:
+    resolution: {integrity: sha512-JEdGzHwwkrbWoGOlIHqQ5gtprKGOenpDHpxE9zVR1bWbOtYRyPPHMe9FaP6x61CmNaTThSkb0DAJte5jD+DmzQ==}
+    engines: {node: ^18.17.0 || >=20.5.0}
+    hasBin: true
+
+  yaml@2.8.0:
+    resolution: {integrity: sha512-4lLa/EcQCB0cJkyts+FpIRx5G/llPxfP6VQU5KByHEhLxY3IJCH0f0Hy1MHI8sClTvsIb8qwRJ6R/ZdlDJ/leQ==}
+    engines: {node: '>= 14.6'}
+    hasBin: true
+
+  zurk@0.11.2:
+    resolution: {integrity: sha512-OKUQsmG588B18hzO4ThzOU0NUwr4C8aKl9NjGQfXUv5fskLfS6Sj3XGNbTzKj3d2+jWvmnqS2cgrwYX6bIkDyA==}
+
+  zx@8.5.4:
+    resolution: {integrity: sha512-44oKea9Sa8ZnOkTnS6fRJpg3quzgnbB43nLrVfYnqE86J4sxgZMUDLezzKET/FdOAVkF4X+Alm9Bume+W+RW9Q==}
+    engines: {node: '>= 12.17.0'}
+    hasBin: true
+
+snapshots:
+
+  '@nodelib/fs.scandir@2.1.5':
+    dependencies:
+      '@nodelib/fs.stat': 2.0.5
+      run-parallel: 1.2.0
+
+  '@nodelib/fs.stat@2.0.5': {}
+
+  '@nodelib/fs.walk@1.2.8':
+    dependencies:
+      '@nodelib/fs.scandir': 2.1.5
+      fastq: 1.19.1
+
+  '@sindresorhus/merge-streams@2.3.0': {}
+
+  '@webpod/ingrid@0.0.0-beta.3': {}
+
+  '@webpod/ps@0.1.1':
+    dependencies:
+      '@webpod/ingrid': 0.0.0-beta.3
+      zurk: 0.11.2
+
+  braces@3.0.3:
+    dependencies:
+      fill-range: 7.1.1
+
+  chalk@5.4.1: {}
+
+  envapi@0.2.3: {}
+
+  fast-glob@3.3.3:
+    dependencies:
+      '@nodelib/fs.stat': 2.0.5
+      '@nodelib/fs.walk': 1.2.8
+      glob-parent: 5.1.2
+      merge2: 1.4.1
+      micromatch: 4.0.8
+
+  fastq@1.19.1:
+    dependencies:
+      reusify: 1.1.0
+
+  fill-range@7.1.1:
+    dependencies:
+      to-regex-range: 5.0.1
+
+  fs-extra@11.3.0:
+    dependencies:
+      graceful-fs: 4.2.11
+      jsonfile: 6.1.0
+      universalify: 2.0.1
+
+  glob-parent@5.1.2:
+    dependencies:
+      is-glob: 4.0.3
+
+  globby@14.1.0:
+    dependencies:
+      '@sindresorhus/merge-streams': 2.3.0
+      fast-glob: 3.3.3
+      ignore: 7.0.4
+      path-type: 6.0.0
+      slash: 5.1.0
+      unicorn-magic: 0.3.0
+
+  graceful-fs@4.2.11: {}
+
+  ignore@7.0.4: {}
+
+  is-extglob@2.1.1: {}
+
+  is-glob@4.0.3:
+    dependencies:
+      is-extglob: 2.1.1
+
+  is-number@7.0.0: {}
+
+  isexe@3.1.1: {}
+
+  jsonfile@6.1.0:
+    dependencies:
+      universalify: 2.0.1
+    optionalDependencies:
+      graceful-fs: 4.2.11
+
+  licia@1.48.0: {}
+
+  md5-file@5.0.0: {}
+
+  merge2@1.4.1: {}
+
+  micromatch@4.0.8:
+    dependencies:
+      braces: 3.0.3
+      picomatch: 2.3.1
+
+  minimist@1.2.8: {}
+
+  node-fetch-native@1.6.6: {}
+
+  path-type@6.0.0: {}
+
+  picomatch@2.3.1: {}
+
+  queue-microtask@1.2.3: {}
+
+  reusify@1.1.0: {}
+
+  run-parallel@1.2.0:
+    dependencies:
+      queue-microtask: 1.2.3
+
+  slash@5.1.0: {}
+
+  to-regex-range@5.0.1:
+    dependencies:
+      is-number: 7.0.0
+
+  unicorn-magic@0.3.0: {}
+
+  universalify@2.0.1: {}
+
+  which@5.0.0:
+    dependencies:
+      isexe: 3.1.1
+
+  yaml@2.8.0: {}
+
+  zurk@0.11.2: {}
+
+  zx@8.5.4: {}

service-ai/database/20250702.sql

@@ -0,0 +1,86 @@
+create table hudi_collect_build_b12.service_ai_feedback
+(
+    id            bigint                                                     not null comment '记录唯一标记',
+    created_time  datetime(6) comment '记录创建时间',
+    modified_time datetime(6) comment '记录更新时间',
+    analysis      longtext comment 'AI的分析结果',
+    conclusion    longtext comment 'AI的解决方案',
+    source        longtext                                                   not null comment '原始报障说明',
+    status        enum ('ANALYSIS_PROCESSING','ANALYSIS_SUCCESS','FINISHED') not null comment '报障处理状态',
+    primary key (id)
+) comment ='报障信息记录' charset = utf8mb4;
+
+create table hudi_collect_build_b12.service_ai_feedback_pictures
+(
+    feedback_id bigint not null,
+    pictures_id bigint not null,
+    primary key (feedback_id, pictures_id)
+) comment ='报障相关截图' charset = utf8mb4;
+
+alter table hudi_collect_build_b12.service_ai_feedback_pictures
+    add constraint UK3npjcyjyqfbdlf2v5tj64j2g3 unique (pictures_id);
+
+create table hudi_collect_build_b12.service_ai_file
+(
+    id            bigint not null comment '记录唯一标记',
+    created_time  datetime(6) comment '记录创建时间',
+    modified_time datetime(6) comment '记录更新时间',
+    filename      varchar(255) comment '文件名称',
+    md5           varchar(255) comment '文件的md5编码，用于校验文件的完整性',
+    path          varchar(255) comment '文件在主机上存储的实际路径',
+    size          bigint comment '文件大小，单位是byte',
+    type          varchar(255) comment '文件类型，通常记录的是文件的后缀名',
+    primary key (id)
+) comment ='记录上传的文件存储信息' charset = utf8mb4;
+
+create table hudi_collect_build_b12.service_ai_flow_task
+(
+    id                    bigint                              not null comment '记录唯一标记',
+    created_time          datetime(6) comment '记录创建时间',
+    modified_time         datetime(6) comment '记录更新时间',
+    comment               text comment '任务注释，用于额外说明',
+    error                 longtext comment '任务运行产生的报错',
+    input                 longtext comment '任务输入',
+    result                longtext comment '任务运行结果',
+    status                enum ('ERROR','FINISHED','RUNNING') not null comment '任务运行状态',
+    template_description  varchar(255) comment '任务对应的模板功能、内容说明',
+    template_flow_graph   longtext                            not null comment '任务对应的模板前端流程图数据',
+    template_input_schema longtext comment '任务对应的模板入参Schema',
+    template_name         varchar(255)                        not null comment '任务对应的模板名称',
+    primary key (id)
+) comment ='流程任务记录' charset = utf8mb4;
+
+create table hudi_collect_build_b12.service_ai_flow_task_template
+(
+    id            bigint       not null comment '记录唯一标记',
+    created_time  datetime(6) comment '记录创建时间',
+    modified_time datetime(6) comment '记录更新时间',
+    description   varchar(255) comment '模板功能、内容说明',
+    flow_graph    longtext     not null comment '前端流程图数据',
+    input_schema  longtext comment '模板入参Schema',
+    name          varchar(255) not null comment '模板名称',
+    primary key (id)
+) comment ='流程任务模板' charset = utf8mb4;
+
+create table hudi_collect_build_b12.service_ai_group
+(
+    id            bigint                      not null comment '记录唯一标记',
+    created_time  datetime(6) comment '记录创建时间',
+    modified_time datetime(6) comment '记录更新时间',
+    name          varchar(255)                not null comment '分组名称',
+    status        enum ('FINISHED','RUNNING') not null comment '分组处理状态',
+    knowledge_id  bigint                      not null,
+    primary key (id)
+) comment ='知识库下包含的分组' charset = utf8mb4;
+
+create table hudi_collect_build_b12.service_ai_knowledge
+(
+    id               bigint                   not null comment '记录唯一标记',
+    created_time     datetime(6) comment '记录创建时间',
+    modified_time    datetime(6) comment '记录更新时间',
+    description      longtext                 not null comment '知识库说明',
+    name             varchar(255)             not null comment '知识库名称',
+    strategy         enum ('Cosine','Euclid') not null comment '知识库策略',
+    vector_source_id bigint                   not null comment '知识库对应的向量库名',
+    primary key (id)
+) comment ='知识库' charset = utf8mb4;

service-ai/pom.xml

@@ -11,8 +11,8 @@
     <description>Hudi AI服务集合</description>
     <modules>
         <module>service-ai-core</module>
-        <module>service-ai-chat</module>
-        <module>service-ai-knowledge</module>
+        <module>service-ai-web</module>
+        <module>service-ai-cli</module>
     </modules>
 
     <properties>
@@ -24,12 +24,27 @@
 
         <spring-boot.version>3.4.3</spring-boot.version>
         <spring-cloud.version>2024.0.1</spring-cloud.version>
-        <spring-ai.version>1.0.0-M6</spring-ai.version>
+        <spring-ai.version>1.0.0</spring-ai.version>
+        <solon-ai.version>3.3.1</solon-ai.version>
         <eclipse-collections.version>11.1.0</eclipse-collections.version>
         <curator.version>5.1.0</curator.version>
         <hutool.version>5.8.27</hutool.version>
+        <mapstruct.version>1.6.3</mapstruct.version>
+        <liteflow.version>2.13.2</liteflow.version>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.mapstruct</groupId>
+            <artifactId>mapstruct</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+    </dependencies>
+
     <dependencyManagement>
         <dependencies>
             <!-- 当前项目依赖 -->
@@ -96,6 +111,11 @@
                 <artifactId>jasypt-spring-boot-starter</artifactId>
                 <version>3.0.5</version>
             </dependency>
+            <dependency>
+                <groupId>com.blinkfox</groupId>
+                <artifactId>fenix-spring-boot-starter</artifactId>
+                <version>3.0.0</version>
+            </dependency>
 
             <!-- 日志相关 -->
             <dependency>
@@ -131,12 +151,57 @@
                 <artifactId>hutool-all</artifactId>
                 <version>${hutool.version}</version>
             </dependency>
+            <dependency>
+                <groupId>com.yomahub</groupId>
+                <artifactId>liteflow-spring-boot-starter</artifactId>
+                <version>${liteflow.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.yomahub</groupId>
+                <artifactId>liteflow-el-builder</artifactId>
+                <version>${liteflow.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.yomahub</groupId>
+                <artifactId>liteflow-script-graaljs</artifactId>
+                <version>${liteflow.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.yomahub</groupId>
+                <artifactId>liteflow-script-python</artifactId>
+                <version>${liteflow.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.yomahub</groupId>
+                <artifactId>liteflow-script-lua</artifactId>
+                <version>${liteflow.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.noear</groupId>
+                <artifactId>solon-ai</artifactId>
+                <version>${solon-ai.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.noear</groupId>
+                <artifactId>solon-ai-dialect-openai</artifactId>
+                <version>${solon-ai.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.mapstruct</groupId>
+                <artifactId>mapstruct</artifactId>
+                <version>${mapstruct.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 
     <build>
         <pluginManagement>
             <plugins>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-compiler-plugin</artifactId>
+                    <version>3.14.0</version>
+                </plugin>
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-source-plugin</artifactId>
@@ -145,7 +210,7 @@
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-shade-plugin</artifactId>
-                    <version>3.3.0</version>
+                    <version>3.6.0</version>
                 </plugin>
                 <plugin>
                     <groupId>org.springframework.boot</groupId>

service-ai/service-ai-chat/src/main/java/com/lanyuanxiaoyao/service/ai/chat/controller/ChatController.java

@@ -1,65 +0,0 @@
-package com.lanyuanxiaoyao.service.ai.chat.controller;
-
-import java.io.IOException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.ai.chat.client.ChatClient;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.CrossOrigin;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
-
-/**
- * 聊天
- *
- * @author lanyuanxiaoyao
- * @version 20250514
- */
-@Controller
-@RequestMapping("chat")
-public class ChatController {
-  private static final Logger logger = LoggerFactory.getLogger(ChatController.class);
-
-  private final ChatClient chatClient;
-
-  public ChatController(ChatClient.Builder builder) {
-    this.chatClient = builder.build();
-  }
-
-  private ChatClient.ChatClientRequestSpec buildRequest(String message) {
-    return chatClient.prompt()
-        .user(message);
-  }
-
-  @PostMapping(value = "sync", consumes = "text/plain;charset=utf-8")
-  @ResponseBody
-  public String chatSync(@RequestBody String message) {
-    return buildRequest(message)
-        .call()
-        .content();
-  }
-
-  @PostMapping(value = "async", consumes = "text/plain;charset=utf-8")
-  public SseEmitter chatAsync(@RequestBody String message) {
-    SseEmitter emitter = new SseEmitter();
-    buildRequest(message)
-        .stream()
-        .content()
-        .subscribe(
-            content -> {
-              try {
-                emitter.send(content);
-              } catch (IOException e) {
-                emitter.completeWithError(e);
-                throw new RuntimeException(e);
-              }
-            },
-            emitter::completeWithError,
-            emitter::complete
-        );
-    return emitter;
-  }
-}

service-ai/service-ai-chat/src/main/resources/application.yml

@@ -1,36 +0,0 @@
-spring:
-  application:
-    name: service-ai-chat
-  profiles:
-    include: common,metrics,forest
-  cloud:
-    zookeeper:
-      enabled: true
-      connect-string: b1m2.hdp.dc:2181,b1m3.hdp.dc:2181,b1m4.hdp.dc:2181,b1m5.hdp.dc:2181,b1m6.hdp.dc:2181
-      discovery:
-        enabled: ${spring.cloud.zookeeper.enabled}
-        root: /hudi-services
-        instance-id: ${spring.application.name}-127.0.0.1-${random.uuid}-20250514
-        metadata:
-          discovery: zookeeper
-          ip: 127.0.0.1
-          hostname: localhost
-          hostname_full: localhost
-          start_time: 20250514112750
-  security:
-    meta:
-      authority: ENC(GXKnbq1LS11U2HaONspvH+D/TkIx13aWTaokdkzaF7HSvq6Z0Rv1+JUWFnYopVXu)
-      username: ENC(moIO5mO39V1Z+RDwROK9JXY4GfM8ZjDgM6Si7wRZ1MPVjbhTpmLz3lz28rAiw7c2LeCmizfJzHkEXIwGlB280g==)
-      darkcode: ENC(0jzpQ7T6S+P7bZrENgYsUoLhlqGvw7DA2MN3BRqEOwq7plhtg72vuuiPQNnr3DaYz0CpyTvxInhpx11W3VZ1trD6NINh7O3LN70ZqO5pWXk=)
-  ai:
-    openai:
-      base-url: http://132.121.206.65:10086
-      api-key: '*XMySqV%>hR&v>>g*NwCs3tpQ5FVMFEF2VHVTj<MYQd$&@$sY7CgqNyea4giJi4'
-      chat:
-        options:
-          model: 'Qwen3-1.7'
-jasypt:
-  encryptor:
-    password: 'r#(R,P"Dp^A47>WSn:Wn].gs/+"v:q_Q*An~zF*g-@j@jtSTv5H/,S-3:R?r9R}.'
-server:
-  port: 8080

service-ai/service-ai-chat/src/test/java/com/lanyuanxiaoyao/service/ai/chat/TestChat.java

@@ -1,37 +0,0 @@
-package com.lanyuanxiaoyao.service.ai.chat;
-
-import org.springframework.ai.chat.client.ChatClient;
-import org.springframework.ai.openai.OpenAiChatModel;
-import org.springframework.ai.openai.OpenAiChatOptions;
-import org.springframework.ai.openai.api.OpenAiApi;
-import reactor.core.Disposable;
-
-/**
- * @author lanyuanxiaoyao
- * @version 20250514
- */
-public class TestChat {
-  public static void main(String[] args) {
-    ChatClient client = ChatClient.builder(
-            OpenAiChatModel.builder()
-                .openAiApi(
-                    OpenAiApi.builder()
-                        .baseUrl("http://132.121.206.65:10086")
-                        .apiKey("*XMySqV%>hR&v>>g*NwCs3tpQ5FVMFEF2VHVTj<MYQd$&@$sY7CgqNyea4giJi4")
-                        .build()
-                )
-                .defaultOptions(
-                    OpenAiChatOptions.builder()
-                        .model("Qwen3-1.7")
-                        .build()
-                )
-                .build()
-        )
-        .build();
-    String content = client.prompt()
-        .user("你好")
-        .call()
-        .content();
-    System.out.println(content);
-  }
-}

service-ai/service-ai-cli/pom.xml

@@ -9,16 +9,20 @@
         <version>1.0.0-SNAPSHOT</version>
     </parent>
 
-    <artifactId>service-ai-chat</artifactId>
+    <artifactId>service-ai-cli</artifactId>
 
     <dependencies>
         <dependency>
-            <groupId>com.lanyuanxiaoyao</groupId>
-            <artifactId>service-ai-core</artifactId>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
         </dependency>
         <dependency>
-            <groupId>org.springframework.ai</groupId>
-            <artifactId>spring-ai-openai-spring-boot-starter</artifactId>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.freemarker</groupId>
+            <artifactId>freemarker</artifactId>
         </dependency>
     </dependencies>
 
@@ -38,4 +42,5 @@
             </plugin>
         </plugins>
     </build>
+
 </project>

service-ai/service-ai-cli/src/main/java/com/lanyuanxiaoyao/service/ai/cli/Generator.java

@@ -0,0 +1,22 @@
+package com.lanyuanxiaoyao.service.ai.cli;
+
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250612
+ */
+@SpringBootApplication
+public class Generator implements ApplicationRunner {
+  public static void main(String[] args) {
+    SpringApplication.run(Generator.class, args);
+  }
+
+  @Override
+  public void run(ApplicationArguments args) throws Exception {
+    new LlamaSwapTool().generate();
+  }
+}

service-ai/service-ai-cli/src/main/java/com/lanyuanxiaoyao/service/ai/cli/GeneratorTool.java

@@ -0,0 +1,26 @@
+package com.lanyuanxiaoyao.service.ai.cli;
+
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.extra.template.Template;
+import cn.hutool.extra.template.TemplateConfig;
+import cn.hutool.extra.template.TemplateEngine;
+import cn.hutool.extra.template.TemplateUtil;
+import java.nio.charset.StandardCharsets;
+import java.util.Map;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250612
+ */
+public abstract class GeneratorTool {
+  private final TemplateEngine engine = TemplateUtil.createEngine(new TemplateConfig("template", TemplateConfig.ResourceMode.CLASSPATH));
+
+  protected void generateTemplate(String templatePath, Map<?, ?> data, String targetScriptPath) {
+    Template template = engine.getTemplate(templatePath);
+    String script = template.render(data);
+    FileUtil.del(targetScriptPath);
+    FileUtil.writeString(script, targetScriptPath, StandardCharsets.UTF_8);
+  }
+
+  public abstract void generate() throws Exception;
+}

service-ai/service-ai-cli/src/main/java/com/lanyuanxiaoyao/service/ai/cli/LlamaSwapTool.java

@@ -0,0 +1,244 @@
+package com.lanyuanxiaoyao.service.ai.cli;
+
+import cn.hutool.core.collection.ListUtil;
+import cn.hutool.core.util.StrUtil;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250612
+ */
+public class LlamaSwapTool extends GeneratorTool {
+  private static final String API_KEY = "*XMySqV%>hR&v>>g*NwCs3tpQ5FVMFEF2VHVTj<MYQd$&@$sY7CgqNyea4giJi4";
+
+  public static String displayName(String name) {
+    return name.replaceAll("\\s+", "_")
+        .replaceAll("\\.", "_")
+        .toLowerCase();
+  }
+
+  @Override
+  public void generate() {
+    generateTemplate(
+        "llama-swap.ftl",
+        Map.of(
+            "models", List.of(
+                llamaCppEmbeddingCmd("BGE/bge-m3-q4km", "bge-m3-Q4_K_M.gguf", 20),
+                vllmEmbeddingCmd("BGE/bge-m3", "bge-m3", 5),
+                llamaCppRerankerCmd("BGE/beg-reranker-v2-q4km", "bge-reranker-v2-m3-Q4_K_M.gguf", 20),
+                vllmRerankerCmd("BGE/beg-reranker-v2", "bge-reranker-v2-m3", 5),
+
+                vllmCmd("Qwen3/qwen3-0.6b", "Qwen3-0.6B", 5, true),
+                vllmCmd("Qwen3/qwen3-1.7b", "Qwen3-1.7B", 5, true),
+                vllmCmd("Qwen3/qwen3-4b", "Qwen3-4B", 8, true),
+                llamaCppCmd("Qwen3/qwen3-4b-q4km", "Qwen3-4B-Q4_K_M.gguf", 35),
+                llamaCppCmd("Qwen3/qwen3-8b-q4km", "Qwen3-8B-Q4_K_M.gguf", 35),
+
+                vllmEmbeddingCmd("Qwen3/qwen3-embedding-0.6b", "Qwen3-Embedding-0.6B", 5),
+                vllmEmbeddingCmd("Qwen3/qwen3-embedding-4b", "Qwen3-Embedding-4B", 8),
+                llamaCppEmbeddingCmd("Qwen3/qwen3-embedding-4b-q4km", "Qwen3-Embedding-4B-Q4_K_M.gguf", 35),
+                llamaCppEmbeddingCmd("Qwen3/qwen3-embedding-8b-q4km", "Qwen3-Embedding-8B-Q4_K_M.gguf", 35),
+
+                // 0.9.1 vllm还未支持
+                // vllmRerankerCmd("Qwen3/qwen3-reranker-0.6b", "Qwen3-Reranker-0.6B", 5),
+                // vllmRerankerCmd("Qwen3/qwen3-reranker-4b", "Qwen3-Reranker-4B", 8),
+
+                llamaCppVisualCmd("Qwen2.5/qwen2.5-vl-7b", "Qwen2.5-VL-7B-Instruct-BF16.gguf", 35),
+                llamaCppVisualCmd("Qwen2.5/qwen2.5-vl-7b-q4km", "Qwen2.5-VL-7B-Instruct-Q4_K_M.gguf", 35),
+                vllmCmd("Qwen2.5/qwen2.5-vl-3b-instruct", "Qwen2.5-VL-3B-Instruct", 8, false),
+                vllmCmd("Qwen2.5/qwen2.5-vl-7b-instruct", "Qwen2.5-VL-7B-Instruct", 8, false),
+
+                llamaCppVisualCmd("MiniCPM/minicpm-o-2.6-7.6b-q4km", "MiniCPM-o-2_6-7.6B-Q4_K_M.gguf", 35),
+                vllmCmd("MiniCPM/minicpm-o-2.6-7.6b", "MiniCPM-o-2_6", 10, false)
+            )
+        ),
+        "config.yaml"
+    );
+  }
+
+  private DockerCmd llamaCppCmd(String name, String model, Integer thread) {
+    return llamaCppCmd(name, model, thread, false, false, false);
+  }
+
+  private DockerCmd llamaCppEmbeddingCmd(String name, String model, Integer thread) {
+    return llamaCppCmd(name, model, thread, true, false, false);
+  }
+
+  private DockerCmd llamaCppRerankerCmd(String name, String model, Integer thread) {
+    return llamaCppCmd(name, model, thread, false, true, false);
+  }
+
+  private DockerCmd llamaCppVisualCmd(String name, String model, Integer thread) {
+    return llamaCppCmd(name, model, thread, false, false, true);
+  }
+
+  private DockerCmd llamaCppCmd(String name, String model, Integer thread, Boolean isEmbedding, Boolean isReranker, Boolean isVisual) {
+    List<String> arguments = ListUtil.list(
+        false,
+        StrUtil.format("-m /models/{}", model),
+        "--port ${PORT}",
+        StrUtil.format("--api-key {}", API_KEY),
+        "-c 0",
+        "-b 4096",
+        StrUtil.format("-t {}", thread),
+        "-np 5",
+        "--log-disable",
+        "--no-webui"
+    );
+    if (isEmbedding) {
+      arguments.add("--embedding");
+      arguments.add("-ub 8192");
+      arguments.add("--pooling mean");
+    } else if (isReranker) {
+      arguments.add("--reranking");
+    } else if (isVisual) {
+      arguments.add(StrUtil.format("--mmproj /models/{}.mmproj", model));
+    } else {
+      arguments.add("--jinja");
+    }
+    return new DockerCmd(
+        "ghcr.io/ggml-org/llama.cpp:server",
+        name,
+        model,
+        StrUtil.format("http://llamacpp-{}:${PORT}", displayName(model)),
+        List.of(StrUtil.format("--name llamacpp-{}", displayName(model))),
+        arguments
+    );
+  }
+
+  private DockerCmd vllmCmd(String name, String model, Integer cache, Boolean isReasonable) {
+    return vllmCmd(name, model, cache, false, false, isReasonable);
+  }
+
+  private DockerCmd vllmEmbeddingCmd(String name, String model, Integer cache) {
+    return vllmCmd(name, model, cache, true, false, false);
+  }
+
+  private DockerCmd vllmRerankerCmd(String name, String model, Integer cache) {
+    return vllmCmd(name, model, cache, false, true, false);
+  }
+
+  private DockerCmd vllmVisualCmd(String name, String model, Integer cache, Boolean isReasonable) {
+    return vllmCmd(name, model, cache, false, false, isReasonable);
+  }
+
+  private DockerCmd vllmCmd(String name, String model, Integer cache, Boolean isEmbedding, Boolean isReranker, Boolean isReasonable) {
+    List<String> arguments = ListUtil.list(
+        false,
+        StrUtil.format("--model /models/{}", model),
+        StrUtil.format("--served-model-name {}", name),
+        "--port ${PORT}",
+        StrUtil.format("--api-key {}", API_KEY),
+        "--disable-log-requests",
+        "--uvicorn-log-level error",
+        "--trust-remote-code"
+    );
+    if (isEmbedding) {
+      arguments.add("--task embedding");
+    } else if (isReranker) {
+      arguments.add("--task score");
+    } else if (isReasonable) {
+      arguments.add("--enable-auto-tool-choice");
+      arguments.add("--tool-call-parser hermes");
+      arguments.add("--enable-reasoning");
+      arguments.add("--reasoning-parser deepseek_r1");
+    }
+    return new DockerCmd(
+        "vllm-server-cpu:0.8.5.post1",
+        name,
+        model,
+        StrUtil.format("http://vllm-{}:${PORT}", displayName(model)),
+        List.of(
+            StrUtil.format("--name vllm-{}", displayName(model)),
+            "--privileged=true",
+            "--shm-size=4g",
+            StrUtil.format("-e VLLM_CPU_KVCACHE_SPACE={}", cache)
+        ),
+        arguments
+    );
+  }
+
+  public static class DockerCmd {
+    private String image;
+    private String name;
+    private String model;
+    private String proxy;
+    private List<String> options = ListUtil.list(
+        false,
+        "--rm",
+        "--network llama",
+        "-v /data/models:/models"
+    );
+    private List<String> arguments = ListUtil.list(false);
+
+    public DockerCmd(String image, String name, String model, String proxy, List<String> options, List<String> arguments) {
+      this.image = image;
+      this.name = name;
+      this.model = model;
+      this.proxy = proxy;
+      this.options.addAll(options);
+      this.arguments.addAll(arguments);
+    }
+
+    public String getImage() {
+      return image;
+    }
+
+    public void setImage(String image) {
+      this.image = image;
+    }
+
+    public String getName() {
+      return name;
+    }
+
+    public void setName(String name) {
+      this.name = name;
+    }
+
+    public String getModel() {
+      return model;
+    }
+
+    public void setModel(String model) {
+      this.model = model;
+    }
+
+    public String getProxy() {
+      return proxy;
+    }
+
+    public void setProxy(String proxy) {
+      this.proxy = proxy;
+    }
+
+    public List<String> getOptions() {
+      return options;
+    }
+
+    public void setOptions(List<String> options) {
+      this.options = options;
+    }
+
+    public List<String> getArguments() {
+      return arguments;
+    }
+
+    public void setArguments(List<String> arguments) {
+      this.arguments = arguments;
+    }
+
+    @Override
+    public String toString() {
+      return "DockerCmd{" +
+             "image='" + image + '\'' +
+             ", name='" + name + '\'' +
+             ", model='" + model + '\'' +
+             ", proxy='" + proxy + '\'' +
+             ", options=" + options +
+             ", arguments=" + arguments +
+             '}';
+    }
+  }
+}

service-ai/service-ai-cli/src/main/resources/template/llama-swap.ftl

@@ -0,0 +1,25 @@
+healthCheckTimeout: 600
+logLevel: warn
+models:
+<#list models as model>
+  "${model.name}":
+    proxy: ${model.proxy}
+    ttl: 86400
+    cmd: |
+      docker run
+      <#list model.options as option>
+      ${option}
+      </#list>
+      ${model.image}
+      <#list model.arguments as arg>
+      ${arg}
+      </#list>
+</#list>
+groups:
+  "persistent":
+    swap: false
+    exclusive: false
+    members:
+      <#list models as model>
+      - "${model.name}"
+      </#list>

service-ai/service-ai-core/pom.xml

@@ -44,5 +44,11 @@
                 </exclusion>
             </exclusions>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 </project>

service-ai/service-ai-core/src/main/java/com/lanyuanxiaoyao/service/ai/core/configuration/WebClientConfiguration.java

@@ -0,0 +1,47 @@
+package com.lanyuanxiaoyao.service.ai.core.configuration;
+
+import java.net.http.HttpClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.http.client.JdkClientHttpRequestFactory;
+import org.springframework.http.client.reactive.JdkClientHttpConnector;
+import org.springframework.web.client.RestClient;
+import org.springframework.web.reactive.function.client.WebClient;
+
+/**
+ * vLLM只能使用http1.0
+ *
+ * @author lanyuanxiaoyao
+ * @version 20250519
+ */
+@Configuration
+public class WebClientConfiguration {
+  @Bean
+  @Primary
+  public RestClient.Builder restClientBuilder() {
+    return generateRestClientBuilder();
+  }
+
+  @Bean
+  @Primary
+  public WebClient.Builder webClientBuilder() {
+    return generateWebClientBuilder();
+  }
+
+  private static HttpClient httpClient() {
+    return HttpClient.newBuilder()
+        .version(HttpClient.Version.HTTP_1_1)
+        .build();
+  }
+
+  public static RestClient.Builder generateRestClientBuilder() {
+    return RestClient.builder()
+        .requestFactory(new JdkClientHttpRequestFactory(httpClient()));
+  }
+
+  public static WebClient.Builder generateWebClientBuilder() {
+    return WebClient.builder()
+        .clientConnector(new JdkClientHttpConnector(httpClient()));
+  }
+}

service-ai/service-ai-core/src/main/java/com/lanyuanxiaoyao/service/ai/core/entity/amis/AmisCrudResponse.java

@@ -0,0 +1,30 @@
+package com.lanyuanxiaoyao.service.ai.core.entity.amis;
+
+/**
+ * Crud 响应
+ *
+ * @author lanyuanxiaoyao
+ * @date 2023-07-06
+ */
+public class AmisCrudResponse extends AmisMapResponse {
+    public void setData(Iterable<?> list) {
+        getData().put("items", list);
+    }
+
+    public void setTotal(Long total) {
+        getData().put("total", total);
+    }
+
+    public void setTotal(Integer total) {
+        setTotal(total.longValue());
+    }
+
+    public void setData(Iterable<?> list, Long total) {
+        setData(list);
+        setTotal(total);
+    }
+
+    public void setData(Iterable<?> list, Integer total) {
+        setData(list, total.longValue());
+    }
+}

service-ai/service-ai-core/src/main/java/com/lanyuanxiaoyao/service/ai/core/entity/amis/AmisDetailResponse.java

@@ -0,0 +1,13 @@
+package com.lanyuanxiaoyao.service.ai.core.entity.amis;
+
+/**
+ * Crud 响应
+ *
+ * @author lanyuanxiaoyao
+ * @date 2023-07-06
+ */
+public class AmisDetailResponse extends AmisMapResponse {
+    public void setDetail(Object detail) {
+        getData().put("detail", detail);
+    }
+}

service-ai/service-ai-core/src/main/java/com/lanyuanxiaoyao/service/ai/core/entity/amis/AmisMapResponse.java

@@ -0,0 +1,21 @@
+package com.lanyuanxiaoyao.service.ai.core.entity.amis;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Map 响应
+ *
+ * @author lanyuanxiaoyao
+ * @date 2023-07-06
+ */
+public class AmisMapResponse extends AmisResponse<Map<String, Object>> {
+    public AmisMapResponse() {
+        setData(new HashMap<>());
+    }
+
+    public AmisMapResponse setData(String key, Object value) {
+        getData().put(key, value);
+        return this;
+    }
+}

service-ai/service-ai-core/src/main/java/com/lanyuanxiaoyao/service/ai/core/entity/amis/AmisResponse.java

@@ -0,0 +1,138 @@
+package com.lanyuanxiaoyao.service.ai.core.entity.amis;
+
+import java.util.Map;
+
+/**
+ * Amis 组件结构化返回值
+ *
+ * @author lanyuanxiaoyao
+ * @date 2022-09-21
+ */
+public class AmisResponse<T> {
+    private static final int SUCCESS_STATUS = 0;
+    private static final int ERROR_STATUS = 500;
+    private static final String SUCCESS_MESSAGE = "OK";
+    private static final String ERROR_MESSAGE = "ERROR";
+    private Integer status;
+    private String message;
+    private T data;
+
+    public static AmisResponse<Object> responseError() {
+      return responseError(ERROR_MESSAGE);
+    }
+
+    public static AmisResponse<Object> responseError(String message) {
+        AmisResponse<Object> response = new AmisResponse<>();
+        response.setStatus(ERROR_STATUS);
+        response.setMessage(message);
+        return response;
+    }
+
+    public static AmisResponse<Object> responseSuccess() {
+        AmisResponse<Object> response = new AmisResponse<>();
+        response.setStatus(SUCCESS_STATUS);
+        response.setMessage(SUCCESS_MESSAGE);
+        return response;
+    }
+
+    public static AmisResponse<Object> responseSuccess(String message) {
+        AmisResponse<Object> response = new AmisResponse<>();
+        response.setStatus(SUCCESS_STATUS);
+        response.setMessage(message);
+        return response;
+    }
+
+    public static <E> AmisResponse<E> responseSuccess(String message, E data) {
+        AmisResponse<E> response = new AmisResponse<>();
+        response.setStatus(SUCCESS_STATUS);
+        response.setMessage(message);
+        response.setData(data);
+        return response;
+    }
+
+    public static <E> AmisResponse<E> responseSuccess(E data) {
+        AmisResponse<E> response = new AmisResponse<>();
+        response.setStatus(SUCCESS_STATUS);
+        response.setMessage(SUCCESS_MESSAGE);
+        response.setData(data);
+        return response;
+    }
+
+    public static AmisMapResponse responseMapData() {
+        AmisMapResponse response = new AmisMapResponse();
+        response.setStatus(SUCCESS_STATUS);
+        response.setMessage(SUCCESS_MESSAGE);
+        return response;
+    }
+
+    public static AmisMapResponse responseMapData(Map<String, Object> data) {
+        AmisMapResponse response = responseMapData();
+        response.setData(data);
+        return response;
+    }
+
+    public static AmisMapResponse responseMapData(String key, Object value) {
+        AmisMapResponse response = responseMapData();
+        response.setData(key, value);
+        return response;
+    }
+
+    public static AmisCrudResponse responseCrudData(Iterable<?> data) {
+        AmisCrudResponse response = new AmisCrudResponse();
+        response.setStatus(SUCCESS_STATUS);
+        response.setMessage(SUCCESS_MESSAGE);
+        response.setData(data);
+        return response;
+    }
+
+    public static AmisCrudResponse responseCrudData(Iterable<?> data, Integer total) {
+        AmisCrudResponse response = responseCrudData(data);
+        response.setTotal(total);
+        return response;
+    }
+
+    public static AmisCrudResponse responseCrudData(Iterable<?> data, Long total) {
+        AmisCrudResponse response = responseCrudData(data);
+        response.setTotal(total);
+        return response;
+    }
+
+    public static AmisDetailResponse responseDetailData(Object detail) {
+        AmisDetailResponse response = new AmisDetailResponse();
+        response.setDetail(detail);
+        return response;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+
+    @Override
+    public String toString() {
+        return "AmisResponse{" +
+                "status=" + status +
+                ", message='" + message + '\'' +
+                ", data=" + data +
+                '}';
+    }
+}

service-ai/service-ai-core/src/main/java/com/lanyuanxiaoyao/service/configuration/SecurityConfig.java

@@ -1,9 +1,8 @@
 package com.lanyuanxiaoyao.service.configuration;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.http.HttpMethod;
 import org.springframework.security.config.Customizer;
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
 import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
@@ -13,8 +12,8 @@ import org.springframework.security.core.userdetails.UserDetails;
 import org.springframework.security.provisioning.InMemoryUserDetailsManager;
 import org.springframework.security.web.SecurityFilterChain;
 import org.springframework.web.cors.CorsConfiguration;
-import org.springframework.web.cors.CorsConfigurationSource;
 import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+import org.springframework.web.filter.CorsFilter;
 
 /**
  * @author lanyuanxiaoyao
@@ -23,29 +22,35 @@ import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
 @Configuration
 @EnableWebSecurity
 public class SecurityConfig {
-  private static final Logger logger = LoggerFactory.getLogger(SecurityConfig.class);
+  @Bean
+  public CorsFilter corsFilter() {
+    CorsConfiguration configuration = new CorsConfiguration();
+    configuration.setAllowCredentials(true);
+    configuration.addAllowedOriginPattern("*");
+    configuration.addAllowedHeader("*");
+    configuration.addAllowedMethod("*");
+    configuration.setMaxAge(7200L);
+    UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+    source.registerCorsConfiguration("/**", configuration);
+    return new CorsFilter(source);
+  }
 
   @Bean
   public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
-    return http.authorizeHttpRequests(registry -> registry.anyRequest().authenticated())
+    return http.authorizeHttpRequests(
+            registry -> registry
+                .requestMatchers(HttpMethod.OPTIONS, "/**")
+                .permitAll()
+                .anyRequest()
+                .authenticated()
+        )
         .httpBasic(Customizer.withDefaults())
+        .cors(Customizer.withDefaults())
         .csrf(AbstractHttpConfigurer::disable)
-        .cors(configurer -> configurer.configurationSource(corsConfigurationSource()))
         .formLogin(AbstractHttpConfigurer::disable)
         .build();
   }
 
-  private CorsConfigurationSource corsConfigurationSource() {
-    CorsConfiguration configuration = new CorsConfiguration();
-    configuration.setAllowCredentials(true);
-    configuration.addAllowedHeader("*");
-    configuration.addAllowedMethod("*");
-    configuration.addAllowedOriginPattern("*");
-    UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
-    source.registerCorsConfiguration("/**", configuration);
-    return source;
-  }
-
   @Bean
   public InMemoryUserDetailsManager userDetailsService(SecurityProperties securityProperties) {
     UserDetails user = User.builder()

service-ai/service-ai-knowledge/pom.xml

@@ -1,51 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <parent>
-        <groupId>com.lanyuanxiaoyao</groupId>
-        <artifactId>service-ai</artifactId>
-        <version>1.0.0-SNAPSHOT</version>
-    </parent>
-
-    <artifactId>service-ai-knowledge</artifactId>
-
-    <dependencies>
-        <dependency>
-            <groupId>com.lanyuanxiaoyao</groupId>
-            <artifactId>service-ai-core</artifactId>
-            <exclusions>
-                <exclusion>
-                    <groupId>com.google.protobuf</groupId>
-                    <artifactId>protobuf-java</artifactId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework.ai</groupId>
-            <artifactId>spring-ai-openai-spring-boot-starter</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework.ai</groupId>
-            <artifactId>spring-ai-qdrant-store-spring-boot-starter</artifactId>
-        </dependency>
-    </dependencies>
-
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-maven-plugin</artifactId>
-                <executions>
-                    <execution>
-                        <phase>package</phase>
-                        <goals>
-                            <goal>repackage</goal>
-                        </goals>
-                    </execution>
-                </executions>
-            </plugin>
-        </plugins>
-    </build>
-</project>

service-ai/service-ai-knowledge/src/main/java/com/lanyuanxiaoyao/service/ai/knowledge/KnowledgeApplication.java

@@ -1,59 +0,0 @@
-package com.lanyuanxiaoyao.service.ai.knowledge;
-
-import com.ulisesbocchio.jasyptspringboot.annotation.EnableEncryptableProperties;
-import jakarta.annotation.Resource;
-import java.net.MalformedURLException;
-import org.springframework.ai.chat.client.ChatClient;
-import org.springframework.ai.model.Media;
-import org.springframework.boot.ApplicationArguments;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
-import org.springframework.core.io.FileUrlResource;
-import org.springframework.retry.annotation.EnableRetry;
-import org.springframework.util.MimeTypeUtils;
-
-/**
- * @author lanyuanxiaoyao
- * @version 20250515
- */
-@SpringBootApplication(scanBasePackages = "com.lanyuanxiaoyao.service")
-@EnableDiscoveryClient
-@EnableConfigurationProperties
-@EnableEncryptableProperties
-@EnableRetry
-public class KnowledgeApplication implements ApplicationRunner {
-  @Resource
-  private ChatClient.Builder builder;
-
-  public static void main(String[] args) {
-    SpringApplication.run(KnowledgeApplication.class, args);
-  }
-
-  @Override
-  public void run(ApplicationArguments args) throws Exception {
-    ChatClient client = builder.build();
-    String content = client.prompt()
-        .user(
-            prompt -> {
-              try {
-                prompt
-                    .text("如实描述图片中的内容，不要加入自己的思考以及与图片内容无关的任何文本")
-                    .media(
-                        Media.builder()
-                            .mimeType(MimeTypeUtils.IMAGE_PNG)
-                            .data(new FileUrlResource("/Users/lanyuanxiaoyao/Pictures/数据使用合同签订.png"))
-                            .build()
-                    );
-              } catch (MalformedURLException e) {
-                throw new RuntimeException(e);
-              }
-            }
-        )
-        .call()
-        .content();
-    System.out.println(content);
-  }
-}

service-ai/service-ai-knowledge/src/main/java/com/lanyuanxiaoyao/service/ai/knowledge/controller/KnowledgeController.java

@@ -1,24 +0,0 @@
-package com.lanyuanxiaoyao.service.ai.knowledge.controller;
-
-import jakarta.annotation.PostConstruct;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * @author lanyuanxiaoyao
- * @version 20250515
- */
-@RestController
-@RequestMapping("knowledge")
-public class KnowledgeController {
-  private static final Logger logger = LoggerFactory.getLogger(KnowledgeController.class);
-
-  public KnowledgeController() {
-  }
-
-  @PostConstruct
-  public void initial() {
-  }
-}

service-ai/service-ai-knowledge/src/main/resources/application.yml

@@ -1,43 +0,0 @@
-spring:
-  application:
-    name: service-ai-knowledge
-  profiles:
-    include: common,metrics,forest
-  cloud:
-    zookeeper:
-      enabled: true
-      connect-string: b1m2.hdp.dc:2181,b1m3.hdp.dc:2181,b1m4.hdp.dc:2181,b1m5.hdp.dc:2181,b1m6.hdp.dc:2181
-      discovery:
-        enabled: ${spring.cloud.zookeeper.enabled}
-        root: /hudi-services
-        instance-id: ${spring.application.name}-127.0.0.1-${random.uuid}-20250514
-        metadata:
-          discovery: zookeeper
-          ip: 127.0.0.1
-          hostname: localhost
-          hostname_full: localhost
-          start_time: 20250514112750
-  security:
-    meta:
-      authority: ENC(GXKnbq1LS11U2HaONspvH+D/TkIx13aWTaokdkzaF7HSvq6Z0Rv1+JUWFnYopVXu)
-      username: ENC(moIO5mO39V1Z+RDwROK9JXY4GfM8ZjDgM6Si7wRZ1MPVjbhTpmLz3lz28rAiw7c2LeCmizfJzHkEXIwGlB280g==)
-      darkcode: ENC(0jzpQ7T6S+P7bZrENgYsUoLhlqGvw7DA2MN3BRqEOwq7plhtg72vuuiPQNnr3DaYz0CpyTvxInhpx11W3VZ1trD6NINh7O3LN70ZqO5pWXk=)
-  ai:
-    openai:
-      base-url: http://localhost:3000
-      api-key: '*XMySqV%>hR&v>>g*NwCs3tpQ5FVMFEF2VHVTj<MYQd$&@$sY7CgqNyea4giJi4'
-      chat:
-        options:
-          model: '/models/InternVL3-1B-Instruct-Q8_0.gguf'
-      embedding:
-        options:
-          model: 'Bge-m3'
-#    vectorstore:
-#      qdrant:
-#        api-key: lanyuanxiaoyao
-#        initialize-schema: true
-jasypt:
-  encryptor:
-    password: 'r#(R,P"Dp^A47>WSn:Wn].gs/+"v:q_Q*An~zF*g-@j@jtSTv5H/,S-3:R?r9R}.'
-server:
-  port: 8080

service-ai/service-ai-knowledge/src/main/resources/logback-spring.xml

@@ -1,34 +0,0 @@
-<configuration>
-    <conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter" />
-    <conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter" />
-    <conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
-
-    <springProperty scope="context" name="LOKI_PUSH_URL" source="loki.url"/>
-    <springProperty scope="context" name="LOGGING_PARENT" source="logging.parent"/>
-    <springProperty scope="context" name="APP_NAME" source="spring.application.name"/>
-
-    <appender name="Console" class="ch.qos.logback.core.ConsoleAppender">
-        <encoder>
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %clr(%5p) %clr([${HOSTNAME}]){yellow} %clr([%t]){magenta} %clr(%logger{40}){cyan} #@# %m%n%wEx</pattern>
-        </encoder>
-    </appender>
-
-    <appender name="RollingFile" class="ch.qos.logback.core.rolling.RollingFileAppender">
-        <file>${LOGGING_PARENT:-.}/${APP_NAME:-run}.log</file>
-        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-            <fileNamePattern>${LOGGING_PARENT:-.}/archive/${APP_NAME:-run}-%d{yyyy-MM-dd}.gz</fileNamePattern>
-            <MaxHistory>7</MaxHistory>
-        </rollingPolicy>
-        <encoder>
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %p [${HOSTNAME}] [%t] %logger #@# %m%n%wEx</pattern>
-        </encoder>
-    </appender>
-
-    <logger name="com.zaxxer.hikari" level="ERROR"/>
-    <logger name="com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver" level="WARN"/>
-
-    <root level="INFO">
-        <appender-ref ref="Console"/>
-<!--        <appender-ref ref="RollingFile"/>-->
-    </root>
-</configuration>