feat(all): 移除远程日志集中

反正也没有备用集群的需求，一个集群用到头就好

.gitignore

@@ -32,7 +32,7 @@ buildNumber.properties
 !.vscode/*.code-snippets
 .history/
 *.vsix
-.idea/**
+**/.idea/**
 cmake-build-*/
 .idea/**/mongoSettings.xml
 *.iws

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_normal} 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_normal('service-cli-runner', 'service-cli')
+} 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_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', 'service-executor', 'service-executor/service-executor-core'])
+    await run_package('service-executor/service-executor-manager')
+    await run_upload_normal('service-executor-manager', 'service-executor')
+} 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_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', 'service-executor', 'service-executor/service-executor-core'])
+    await run_package('service-executor/service-executor-task')
+    await run_upload_normal('service-executor-task', 'service-executor')
+} 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-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_normal} 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_normal('**/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, 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, 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, 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, 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/library.js

@@ -0,0 +1,102 @@
+import {$, fetch, fs, glob, os, path, spinner, syncProcessCwd, usePowerShell} from 'zx'
+import {isEqual, trim} from "licia";
+
+syncProcessCwd(true)
+if (isEqual(os.platform(), 'win32')) {
+    usePowerShell()
+}
+
+const maven_setting = '/Users/lanyuanxiaoyao/.m2/settings-nas.xml'
+
+const upload_url = 'http://132.126.207.124:36800'
+const upload_username = 'AxhEbscwsJDbYMH2'
+const upload_password = 'cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4'
+
+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('')
+}
+
+export const run_deploy = async (project) => {
+    let output = await spinner(
+        `Deploying project ${project}`,
+        () => $`mvn -pl ${project} clean deploy -D skipTests -s ${maven_setting}`
+    )
+    console.log(`✅  Finish deploy ${project} (${millisecondToString(output['duration'])})`)
+}
+
+export const run_deploy_root = async () => {
+    let output = await spinner(
+        `Deploying root`,
+        () => $`mvn clean deploy -N -D skipTests -s ${maven_setting}`
+    )
+    console.log(`✅  Finish deploy root (${millisecondToString(output['duration'])})`)
+}
+
+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(`✅  Finish 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)
+    }
+}
+
+const upload = async (file_path) => {
+    let response = await spinner(
+        `Uploading project ${file_path}`,
+        () => fetch(`${upload_url}/file/upload/${path.basename(file_path)}`, {
+            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(`✅  Finish upload ${file_path}`)
+    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,5 +1,7 @@
 #!/bin/bash
 
+maven_setting=/Users/lanyuanxiaoyao/.m2/settings-nas.xml
+
 build_profile=b2b12
 
 upload_username=AxhEbscwsJDbYMH2
@@ -27,10 +29,14 @@ function joining {
   fi
 }
 
+function deploy_root() {
+    mvn deploy -N -D skipTests -s $maven_setting
+}
+
 function deploy() {
-  mvn -pl $(joining , $@) clean install -D skipTests
+  mvn -pl $(joining , $@) clean deploy -D skipTests -s $maven_setting
 }
 
 function package() {
-  mvn -pl $(joining , $@) clean package -D skipTests -P $build_profile
+  mvn -pl $(joining , $@) clean package -D skipTests -P $build_profile -s $maven_setting
 }

bin/package.json

@@ -0,0 +1,18 @@
+{
+  "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",
+    "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,327 @@
+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
+      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==}
+
+  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: {}
+
+  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: {}

pom.xml

@@ -8,7 +8,7 @@
     <artifactId>hudi-service</artifactId>
     <version>1.0.0-SNAPSHOT</version>
     <packaging>pom</packaging>
-    <description>Hudi服务模块系列应用</description>
+    <description>Hudi服务应用集合</description>
     <modules>
         <module>service-common</module>
         <module>service-dependencies</module>

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-chat.js

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

service-ai/bin/package.json

@@ -0,0 +1,18 @@
+{
+  "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",
+    "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,327 @@
+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
+      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==}
+
+  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: {}
+
+  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/pom.xml

@@ -0,0 +1,177 @@
+<?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>
+
+    <groupId>com.lanyuanxiaoyao</groupId>
+    <artifactId>service-ai</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+    <packaging>pom</packaging>
+    <description>Hudi AI服务集合</description>
+    <modules>
+        <module>service-ai-core</module>
+        <module>service-ai-chat</module>
+        <module>service-ai-knowledge</module>
+    </modules>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+
+        <build-tag>b2b12</build-tag>
+
+        <spring-boot.version>3.4.3</spring-boot.version>
+        <spring-cloud.version>2024.0.1</spring-cloud.version>
+        <spring-ai.version>1.0.0-RC1</spring-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>
+    </properties>
+
+    <dependencyManagement>
+        <dependencies>
+            <!-- 当前项目依赖 -->
+            <dependency>
+                <groupId>com.lanyuanxiaoyao</groupId>
+                <artifactId>service-common</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.lanyuanxiaoyao</groupId>
+                <artifactId>service-configuration</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.lanyuanxiaoyao</groupId>
+                <artifactId>service-dependencies</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.lanyuanxiaoyao</groupId>
+                <artifactId>service-forest</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.lanyuanxiaoyao</groupId>
+                <artifactId>service-ai-core</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+
+            <!-- spring boot 相关依赖 -->
+            <dependency>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-dependencies</artifactId>
+                <version>${spring-boot.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.springframework.cloud</groupId>
+                <artifactId>spring-cloud-dependencies</artifactId>
+                <version>${spring-cloud.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.springframework.ai</groupId>
+                <artifactId>spring-ai-bom</artifactId>
+                <version>${spring-ai.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+            <dependency>
+                <groupId>com.dtflys.forest</groupId>
+                <artifactId>forest-spring-boot3-starter</artifactId>
+                <version>1.5.36</version>
+            </dependency>
+            <dependency>
+                <groupId>com.fasterxml.jackson.datatype</groupId>
+                <artifactId>jackson-datatype-eclipse-collections</artifactId>
+                <version>2.17.1</version>
+            </dependency>
+            <dependency>
+                <groupId>com.github.ulisesbocchio</groupId>
+                <artifactId>jasypt-spring-boot-starter</artifactId>
+                <version>3.0.5</version>
+            </dependency>
+
+            <!-- 日志相关 -->
+            <dependency>
+                <groupId>pl.tkowalcz.tjahzi</groupId>
+                <artifactId>logback-appender</artifactId>
+                <version>0.9.23</version>
+            </dependency>
+            <dependency>
+                <groupId>com.github.loki4j</groupId>
+                <artifactId>loki-logback-appender-jdk8</artifactId>
+                <version>1.4.2</version>
+            </dependency>
+
+            <!-- 其他 -->
+            <dependency>
+                <groupId>dev.failsafe</groupId>
+                <artifactId>failsafe</artifactId>
+                <version>3.3.1</version>
+            </dependency>
+            <dependency>
+                <groupId>org.eclipse.collections</groupId>
+                <artifactId>eclipse-collections</artifactId>
+                <version>${eclipse-collections.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.eclipse.collections</groupId>
+                <artifactId>eclipse-collections-api</artifactId>
+                <version>${eclipse-collections.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>cn.hutool</groupId>
+                <artifactId>hutool-all</artifactId>
+                <version>${hutool.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.yomahub</groupId>
+                <artifactId>liteflow-spring-boot-starter</artifactId>
+                <version>2.13.2</version>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <pluginManagement>
+            <plugins>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-source-plugin</artifactId>
+                    <version>3.3.0</version>
+                </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-shade-plugin</artifactId>
+                    <version>3.3.0</version>
+                </plugin>
+                <plugin>
+                    <groupId>org.springframework.boot</groupId>
+                    <artifactId>spring-boot-maven-plugin</artifactId>
+                    <version>${spring-boot.version}</version>
+                </plugin>
+            </plugins>
+        </pluginManagement>
+    </build>
+
+    <distributionManagement>
+        <repository>
+            <id>${releases.id}</id>
+            <name>${releases.name}</name>
+            <url>${releases.url}</url>
+        </repository>
+        <snapshotRepository>
+            <id>${snapshots.id}</id>
+            <name>${snapshots.name}</name>
+            <url>${snapshots.url}</url>
+        </snapshotRepository>
+    </distributionManagement>
+
+</project>

service-ai/service-ai-chat/pom.xml

@@ -0,0 +1,41 @@
+<?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-chat</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.lanyuanxiaoyao</groupId>
+            <artifactId>service-ai-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.ai</groupId>
+            <artifactId>spring-ai-starter-model-openai</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-chat/src/main/java/com/lanyuanxiaoyao/service/ai/chat/AiChatApplication.java

@@ -0,0 +1,23 @@
+package com.lanyuanxiaoyao.service.ai.chat;
+
+import com.ulisesbocchio.jasyptspringboot.annotation.EnableEncryptableProperties;
+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.retry.annotation.EnableRetry;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250514
+ */
+@SpringBootApplication(scanBasePackages = "com.lanyuanxiaoyao.service")
+@EnableDiscoveryClient
+@EnableConfigurationProperties
+@EnableEncryptableProperties
+@EnableRetry
+public class AiChatApplication {
+  public static void main(String[] args) {
+    SpringApplication.run(AiChatApplication.class, args);
+  }
+}

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

@@ -0,0 +1,87 @@
+package com.lanyuanxiaoyao.service.ai.chat.controller;
+
+import cn.hutool.core.util.StrUtil;
+import com.lanyuanxiaoyao.service.ai.chat.entity.MessageVO;
+import com.lanyuanxiaoyao.service.ai.chat.tools.DatetimeTools;
+import java.io.IOException;
+import org.eclipse.collections.api.list.ImmutableList;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.ai.chat.client.ChatClient;
+import org.springframework.ai.chat.messages.AssistantMessage;
+import org.springframework.ai.chat.messages.Message;
+import org.springframework.ai.chat.messages.UserMessage;
+import org.springframework.stereotype.Controller;
+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(ImmutableList<MessageVO> messages) {
+    return chatClient.prompt()
+        .system("""
+            你是一名专业的AI运维助手，负责“Hudi数据同步服务平台”的运维工作；
+            你将会友好地帮助用户解答关于该平台运维工作的问题，你会尽可能通过各种方式获取知识和数据来解答；
+            对于无法通过已有知识回答的问题，你会提示用户你无法解答该问题，而不是虚构不存在的数据或答案；
+            对于与该平台无关的问题，你会委婉地拒绝用户，并提示无法回答；
+            你将始终在中文语境下进行对话。
+            """)
+        .tools(new DatetimeTools())
+        .messages(
+            messages
+                .collect(message -> StrUtil.equals(message.getRole(), "assistant")
+                    ? new AssistantMessage(message.getContent())
+                    : new UserMessage(message.getContent()))
+                .collect(message -> (Message) message)
+                .toList()
+        );
+  }
+
+  @PostMapping("sync")
+  @ResponseBody
+  public String chatSync(@RequestBody ImmutableList<MessageVO> messages) {
+    String content = buildRequest(messages)
+        .call()
+        .content();
+    return StrUtil.trimToEmpty(content);
+  }
+
+  @PostMapping("async")
+  public SseEmitter chatAsync(@RequestBody ImmutableList<MessageVO> messages) {
+    SseEmitter emitter = new SseEmitter();
+    buildRequest(messages)
+        .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/java/com/lanyuanxiaoyao/service/ai/chat/entity/MessageVO.java

@@ -0,0 +1,34 @@
+package com.lanyuanxiaoyao.service.ai.chat.entity;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250516
+ */
+public class MessageVO {
+  private String role;
+  private String content;
+
+  public String getRole() {
+    return role;
+  }
+
+  public void setRole(String role) {
+    this.role = role;
+  }
+
+  public String getContent() {
+    return content;
+  }
+
+  public void setContent(String content) {
+    this.content = content;
+  }
+
+  @Override
+  public String toString() {
+    return "MessageVO{" +
+           "role='" + role + '\'' +
+           ", content='" + content + '\'' +
+           '}';
+  }
+}

service-ai/service-ai-chat/src/main/java/com/lanyuanxiaoyao/service/ai/chat/tools/DatetimeTools.java

@@ -0,0 +1,18 @@
+package com.lanyuanxiaoyao.service.ai.chat.tools;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import org.springframework.ai.tool.annotation.Tool;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250516
+ */
+public class DatetimeTools {
+  private final static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+  @Tool(description = "获取当前日期和时间")
+  public String getCurrentDateTime() {
+    return LocalDateTime.now().format(formatter);
+  }
+}

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

@@ -0,0 +1,15 @@
+spring:
+  application:
+    name: service-ai-chat
+  profiles:
+    include: random-port,common,discovery,metrics,forest
+  ai:
+    openai:
+      base-url: http://132.121.206.65:10086
+      api-key: ENC(K+Hff9QGC+fcyi510VIDd9CaeK/IN5WBJ9rlkUsHEdDgIidW+stHHJlsK0lLPUXXREha+ToQZqqDXJrqSE+GUKCXklFhelD8bRHFXBIeP/ZzT2cxhzgKUXgjw3S0Qw2R)
+      chat:
+        options:
+          model: 'Qwen3-1.7-vllm'
+  mvc:
+    async:
+      request-timeout: 300000

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

@@ -0,0 +1,34 @@
+<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>

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

@@ -0,0 +1,37 @@
+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-core/pom.xml

@@ -0,0 +1,54 @@
+<?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-core</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.lanyuanxiaoyao</groupId>
+            <artifactId>service-forest</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.dtflys.forest</groupId>
+                    <artifactId>forest-spring-boot-starter</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.springframework.cloud</groupId>
+                    <artifactId>spring-cloud-starter-sleuth</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>commons-logging</groupId>
+                    <artifactId>commons-logging</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.dtflys.forest</groupId>
+            <artifactId>forest-spring-boot3-starter</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>commons-logging</groupId>
+                    <artifactId>commons-logging</artifactId>
+                </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,39 @@
+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 {
+  private HttpClient httpClient() {
+    return HttpClient.newBuilder()
+        .version(HttpClient.Version.HTTP_1_1)
+        .build();
+  }
+
+  @Bean
+  @Primary
+  public RestClient.Builder restClientBuilder() {
+    return RestClient.builder()
+        .requestFactory(new JdkClientHttpRequestFactory(httpClient()));
+  }
+
+  @Bean
+  @Primary
+  public WebClient.Builder webClientBuilder() {
+    return WebClient.builder()
+        .clientConnector(new JdkClientHttpConnector(httpClient()));
+  }
+}

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

@@ -0,0 +1,58 @@
+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.security.config.Customizer;
+import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
+import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
+import org.springframework.security.core.userdetails.User;
+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;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250514
+ */
+@Configuration
+@EnableWebSecurity
+public class SecurityConfig {
+  private static final Logger logger = LoggerFactory.getLogger(SecurityConfig.class);
+
+  @Bean
+  public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
+    return http.authorizeHttpRequests(registry -> registry.anyRequest().authenticated())
+        .httpBasic(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()
+        .username(securityProperties.getUsername())
+        .password("{noop}" + securityProperties.getDarkcode())
+        .authorities(securityProperties.getAuthority())
+        .build();
+    return new InMemoryUserDetailsManager(user);
+  }
+}

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

@@ -0,0 +1,67 @@
+<?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-starter-model-openai</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.ai</groupId>
+            <artifactId>spring-ai-starter-vector-store-qdrant</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.ai</groupId>
+            <artifactId>spring-ai-markdown-document-reader</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.mysql</groupId>
+            <artifactId>mysql-connector-j</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.yomahub</groupId>
+            <artifactId>liteflow-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

@@ -0,0 +1,29 @@
+package com.lanyuanxiaoyao.service.ai.knowledge;
+
+import com.ulisesbocchio.jasyptspringboot.annotation.EnableEncryptableProperties;
+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.retry.annotation.EnableRetry;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250515
+ */
+@SpringBootApplication(scanBasePackages = "com.lanyuanxiaoyao.service")
+@EnableDiscoveryClient
+@EnableConfigurationProperties
+@EnableEncryptableProperties
+@EnableRetry
+public class KnowledgeApplication implements ApplicationRunner {
+  public static void main(String[] args) {
+    SpringApplication.run(KnowledgeApplication.class, args);
+  }
+
+  @Override
+  public void run(ApplicationArguments args) {
+  }
+}

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

@@ -0,0 +1,129 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.controller;
+
+import com.lanyuanxiaoyao.service.ai.knowledge.entity.vo.KnowledgeVO;
+import com.lanyuanxiaoyao.service.ai.knowledge.entity.vo.PointVO;
+import com.lanyuanxiaoyao.service.ai.knowledge.reader.TextLineReader;
+import com.lanyuanxiaoyao.service.ai.knowledge.service.KnowledgeService;
+import io.qdrant.client.QdrantClient;
+import io.qdrant.client.grpc.Points;
+import java.nio.charset.StandardCharsets;
+import java.util.concurrent.ExecutionException;
+import java.util.stream.Collectors;
+import org.eclipse.collections.api.factory.Lists;
+import org.eclipse.collections.api.list.ImmutableList;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.ai.embedding.EmbeddingModel;
+import org.springframework.ai.reader.TextReader;
+import org.springframework.ai.reader.markdown.MarkdownDocumentReader;
+import org.springframework.ai.reader.markdown.config.MarkdownDocumentReaderConfig;
+import org.springframework.ai.vectorstore.VectorStore;
+import org.springframework.ai.vectorstore.qdrant.QdrantVectorStore;
+import org.springframework.core.io.ByteArrayResource;
+import org.springframework.web.bind.annotation.GetMapping;
+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.RequestParam;
+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);
+
+  private final KnowledgeService knowledgeService;
+  private final QdrantClient client;
+  private final EmbeddingModel embeddingModel;
+
+  public KnowledgeController(KnowledgeService knowledgeService, VectorStore vectorStore, EmbeddingModel embeddingModel) {
+    this.knowledgeService = knowledgeService;
+    client = (QdrantClient) vectorStore.getNativeClient().orElseThrow();
+    this.embeddingModel = embeddingModel;
+  }
+
+  @PostMapping("add")
+  public void add(
+      @RequestParam("name") String name,
+      @RequestParam("strategy") String strategy
+  ) throws ExecutionException, InterruptedException {
+    knowledgeService.add(name, strategy);
+  }
+
+  @GetMapping("list")
+  public ImmutableList<KnowledgeVO> list() {
+    return knowledgeService.list();
+  }
+
+  @GetMapping("list_points")
+  public ImmutableList<PointVO> listPoints(@RequestParam("name") String name) throws ExecutionException, InterruptedException {
+    Points.ScrollResponse response = client.scrollAsync(
+            Points.ScrollPoints.newBuilder()
+                .setCollectionName(name)
+                // .setLimit(2)
+                .setWithPayload(Points.WithPayloadSelector.newBuilder().setEnable(true).build())
+                .setWithVectors(Points.WithVectorsSelector.newBuilder().setEnable(false).build())
+                .build()
+        )
+        .get();
+    return response.getResultList()
+        .stream()
+        .collect(Collectors.toCollection(Lists.mutable::empty))
+        .collect(point -> {
+          PointVO vo = new PointVO();
+          vo.setId(point.getId().getUuid());
+          vo.setText(point.getPayloadMap().get("doc_content").getStringValue());
+          return vo;
+        })
+        .toImmutable();
+  }
+
+  @GetMapping("delete")
+  public void delete(@RequestParam("name") String name) throws ExecutionException, InterruptedException {
+    knowledgeService.remove(name);
+  }
+
+  @PostMapping("preview_text")
+  public ImmutableList<PointVO> previewText(
+      @RequestParam("name") String name,
+      @RequestParam(value = "mode", defaultValue = "normal") String mode,
+      @RequestParam(value = "type", defaultValue = "text") String type,
+      @RequestParam("content") String content
+  ) {
+    TextReader reader = new TextLineReader(new ByteArrayResource(content.getBytes(StandardCharsets.UTF_8)));
+    return reader.get()
+        .stream()
+        .collect(Collectors.toCollection(Lists.mutable::empty))
+        .collect(doc -> {
+          PointVO vo = new PointVO();
+          vo.setId(doc.getId());
+          vo.setText(doc.getText());
+          return vo;
+        })
+        .toImmutable();
+  }
+
+  @PostMapping(value = "process_text", consumes = "text/plain;charset=utf-8")
+  public void processText(
+      @RequestParam("name") String name,
+      @RequestBody String text
+  ) {
+    VectorStore source = QdrantVectorStore.builder(client, embeddingModel)
+        .collectionName(name)
+        .initializeSchema(true)
+        .build();
+    MarkdownDocumentReader reader = new MarkdownDocumentReader(
+        new ByteArrayResource(text.getBytes(StandardCharsets.UTF_8)),
+        MarkdownDocumentReaderConfig.builder()
+            .withHorizontalRuleCreateDocument(true)
+            .withIncludeCodeBlock(false)
+            .withIncludeBlockquote(false)
+            .build()
+    );
+    source.add(reader.get());
+  }
+}

service-ai/service-ai-knowledge/src/main/java/com/lanyuanxiaoyao/service/ai/knowledge/entity/Knowledge.java

@@ -0,0 +1,54 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.entity;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250522
+ */
+public class Knowledge {
+  private Long id;
+  private Long vectorSourceId;
+  private String name;
+  private String strategy;
+
+  public Long getId() {
+    return id;
+  }
+
+  public void setId(Long id) {
+    this.id = id;
+  }
+
+  public Long getVectorSourceId() {
+    return vectorSourceId;
+  }
+
+  public void setVectorSourceId(Long vectorSourceId) {
+    this.vectorSourceId = vectorSourceId;
+  }
+
+  public String getName() {
+    return name;
+  }
+
+  public void setName(String name) {
+    this.name = name;
+  }
+
+  public String getStrategy() {
+    return strategy;
+  }
+
+  public void setStrategy(String strategy) {
+    this.strategy = strategy;
+  }
+
+  @Override
+  public String toString() {
+    return "Knowledge{" +
+           "id=" + id +
+           ", vectorSourceId=" + vectorSourceId +
+           ", name='" + name + '\'' +
+           ", strategy='" + strategy + '\'' +
+           '}';
+  }
+}

service-ai/service-ai-knowledge/src/main/java/com/lanyuanxiaoyao/service/ai/knowledge/entity/vo/KnowledgeVO.java

@@ -0,0 +1,74 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.entity.vo;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250516
+ */
+public class KnowledgeVO {
+  private String name;
+  private String strategy;
+  private Long size;
+  private Long points;
+  private Long segments;
+  private String status;
+
+  public String getName() {
+    return name;
+  }
+
+  public void setName(String name) {
+    this.name = name;
+  }
+
+  public String getStrategy() {
+    return strategy;
+  }
+
+  public void setStrategy(String strategy) {
+    this.strategy = strategy;
+  }
+
+  public Long getSize() {
+    return size;
+  }
+
+  public void setSize(Long size) {
+    this.size = size;
+  }
+
+  public Long getPoints() {
+    return points;
+  }
+
+  public void setPoints(Long points) {
+    this.points = points;
+  }
+
+  public Long getSegments() {
+    return segments;
+  }
+
+  public void setSegments(Long segments) {
+    this.segments = segments;
+  }
+
+  public String getStatus() {
+    return status;
+  }
+
+  public void setStatus(String status) {
+    this.status = status;
+  }
+
+  @Override
+  public String toString() {
+    return "CollectionVO{" +
+           "name='" + name + '\'' +
+           ", strategy='" + strategy + '\'' +
+           ", size=" + size +
+           ", points=" + points +
+           ", segments=" + segments +
+           ", status='" + status + '\'' +
+           '}';
+  }
+}

service-ai/service-ai-knowledge/src/main/java/com/lanyuanxiaoyao/service/ai/knowledge/entity/vo/PointVO.java

@@ -0,0 +1,34 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.entity.vo;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250516
+ */
+public class PointVO {
+  private String id;
+  private String text;
+
+  public String getId() {
+    return id;
+  }
+
+  public void setId(String id) {
+    this.id = id;
+  }
+
+  public String getText() {
+    return text;
+  }
+
+  public void setText(String text) {
+    this.text = text;
+  }
+
+  @Override
+  public String toString() {
+    return "PointVO{" +
+           "id='" + id + '\'' +
+           ", text='" + text + '\'' +
+           '}';
+  }
+}

service-ai/service-ai-knowledge/src/main/java/com/lanyuanxiaoyao/service/ai/knowledge/reader/TextLineReader.java

@@ -0,0 +1,34 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.reader;
+
+import cn.hutool.core.util.StrUtil;
+import java.util.List;
+import java.util.stream.Stream;
+import org.springframework.ai.document.Document;
+import org.springframework.ai.reader.TextReader;
+import org.springframework.core.io.Resource;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250522
+ */
+public class TextLineReader extends TextReader {
+  public TextLineReader(Resource resource) {
+    super(resource);
+  }
+
+  @Override
+  public List<Document> get() {
+    return super.get()
+        .stream()
+        .flatMap(doc -> {
+          String text = doc.getText();
+          if (StrUtil.isBlank(text)) {
+            return Stream.of(doc);
+          }
+          return Stream.of(text.split("\n\n"))
+              .filter(StrUtil::isNotBlank)
+              .map(line -> new Document(line, doc.getMetadata()));
+        })
+        .toList();
+  }
+}

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

@@ -0,0 +1,16 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.service;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250522
+ */
+@Service
+public class EmbeddingService {
+  private static final Logger logger = LoggerFactory.getLogger(EmbeddingService.class);
+
+
+}

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

@@ -0,0 +1,58 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.service;
+
+import club.kingon.sql.builder.SqlBuilder;
+import cn.hutool.core.util.IdUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250522
+ */
+@Service
+public class KnowledgeGroupService {
+  private static final Logger logger = LoggerFactory.getLogger(KnowledgeGroupService.class);
+  private static final String GROUP_TABLE_NAME = "service_ai_group";
+
+  private final JdbcTemplate template;
+
+  public KnowledgeGroupService(JdbcTemplate template) {
+    this.template = template;
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  public void add(Long knowledgeId, String name) {
+    template.update(
+        SqlBuilder.insertInto(GROUP_TABLE_NAME, "id", "knowledge_id", "name")
+            .values()
+            .addValue("?", "?", "?")
+            .precompileSql(),
+        IdUtil.getSnowflakeNextId(),
+        knowledgeId,
+        name
+    );
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  public void remove(Long groupId) {
+    template.update(
+        SqlBuilder.delete(GROUP_TABLE_NAME)
+            .whereEq("id", "?")
+            .precompileSql(),
+        groupId
+    );
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  public void removeByKnowledgeId(Long knowledgeId) {
+    template.update(
+        SqlBuilder.delete(GROUP_TABLE_NAME)
+            .whereEq("knowledge_id", "?")
+            .precompileSql(),
+        knowledgeId
+    );
+  }
+}

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

@@ -0,0 +1,151 @@
+package com.lanyuanxiaoyao.service.ai.knowledge.service;
+
+import club.kingon.sql.builder.SqlBuilder;
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.lanyuanxiaoyao.service.ai.knowledge.entity.Knowledge;
+import com.lanyuanxiaoyao.service.ai.knowledge.entity.vo.KnowledgeVO;
+import io.qdrant.client.QdrantClient;
+import io.qdrant.client.grpc.Collections;
+import java.util.concurrent.ExecutionException;
+import java.util.stream.Collectors;
+import org.eclipse.collections.api.factory.Lists;
+import org.eclipse.collections.api.list.ImmutableList;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.ai.embedding.EmbeddingModel;
+import org.springframework.ai.vectorstore.VectorStore;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @author lanyuanxiaoyao
+ * @version 20250522
+ */
+@Service
+public class KnowledgeService {
+  private static final Logger logger = LoggerFactory.getLogger(KnowledgeService.class);
+  private static final String KNOWLEDGE_TABLE_NAME = "service_ai_knowledge";
+
+  private final JdbcTemplate template;
+  private final EmbeddingModel embeddingModel;
+  private final QdrantClient client;
+  private final KnowledgeGroupService knowledgeGroupService;
+
+  public KnowledgeService(JdbcTemplate template, EmbeddingModel embeddingModel, VectorStore vectorStore, KnowledgeGroupService knowledgeGroupService) {
+    this.template = template;
+    this.embeddingModel = embeddingModel;
+    this.client = (QdrantClient) vectorStore.getNativeClient().orElseThrow();
+    this.knowledgeGroupService = knowledgeGroupService;
+  }
+
+  public Knowledge get(Long id) {
+    return template.queryForObject(
+        SqlBuilder.select("id", "vector_source_id", "name", "strategy")
+            .from(KNOWLEDGE_TABLE_NAME)
+            .whereEq("id", "?")
+            .precompileSql(),
+        Knowledge.class,
+        id
+    );
+  }
+
+  public Knowledge get(String name) {
+    return template.queryForObject(
+        SqlBuilder.select("id", "vector_source_id", "name", "strategy")
+            .from(KNOWLEDGE_TABLE_NAME)
+            .whereEq("name", "?")
+            .precompileSql(),
+        Knowledge.class,
+        name
+    );
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  public void add(String name, String strategy) throws ExecutionException, InterruptedException {
+    Integer count = template.queryForObject(
+        SqlBuilder.select("count(*)")
+            .from(KNOWLEDGE_TABLE_NAME)
+            .whereEq("name", "?")
+            .precompileSql(),
+        Integer.class,
+        name
+    );
+    if (count > 0) {
+      throw new RuntimeException("名称已存在");
+    }
+
+    long id = IdUtil.getSnowflakeNextId();
+    long vectorSourceId = IdUtil.getSnowflakeNextId();
+    template.update(
+        SqlBuilder.insertInto(KNOWLEDGE_TABLE_NAME, "id", "vector_source_id", "name", "strategy")
+            .values()
+            .addValue("?", "?", "?", "?")
+            .precompileSql(),
+        id,
+        vectorSourceId,
+        name,
+        strategy
+    );
+    client.createCollectionAsync(
+        String.valueOf(vectorSourceId),
+        Collections.VectorParams.newBuilder()
+            .setDistance(Collections.Distance.valueOf(strategy))
+            .setSize(embeddingModel.dimensions())
+            .build()
+    ).get();
+  }
+
+  public ImmutableList<KnowledgeVO> list() {
+    return template.query(
+            SqlBuilder.select("id", "vector_source_id", "name", "strategy")
+                .from(KNOWLEDGE_TABLE_NAME)
+                .build(),
+            (rs, index) -> {
+              Knowledge knowledge = new Knowledge();
+              knowledge.setId(rs.getLong(1));
+              knowledge.setVectorSourceId(rs.getLong(2));
+              knowledge.setName(rs.getString(3));
+              knowledge.setStrategy(rs.getString(4));
+              return knowledge;
+            }
+        )
+        .stream()
+        .map(knowledge -> {
+          try {
+            Collections.CollectionInfo info = client.getCollectionInfoAsync(String.valueOf(knowledge.getVectorSourceId())).get();
+            KnowledgeVO vo = new KnowledgeVO();
+            vo.setName(knowledge.getName());
+            vo.setPoints(info.getPointsCount());
+            vo.setSegments(info.getSegmentsCount());
+            vo.setStatus(info.getStatus().name());
+            Collections.VectorParams vectorParams = info.getConfig().getParams().getVectorsConfig().getParams();
+            vo.setStrategy(vectorParams.getDistance().name());
+            vo.setSize(vectorParams.getSize());
+            return vo;
+          } catch (InterruptedException | ExecutionException e) {
+            throw new RuntimeException(e);
+          }
+        })
+        .collect(Collectors.toCollection(Lists.mutable::empty))
+        .toImmutable();
+  }
+
+  @Transactional(rollbackFor = Exception.class)
+  public void remove(String name) throws ExecutionException, InterruptedException {
+    Knowledge knowledge = get(name);
+    if (ObjectUtil.isNull(knowledge)) {
+      throw new RuntimeException(StrUtil.format("{} 不存在"));
+    }
+    template.update(
+        SqlBuilder.delete(KNOWLEDGE_TABLE_NAME)
+            .whereEq("id", "?")
+            .precompileSql(),
+        knowledge.getId()
+    );
+    knowledgeGroupService.removeByKnowledgeId(knowledge.getId());
+    client.deleteCollectionAsync(String.valueOf(knowledge.getVectorSourceId())).get();
+  }
+}

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

@@ -0,0 +1,51 @@
+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
+  datasource:
+    url: jdbc:mysql://localhost:3307/ai?useSSL=false
+    username: test
+    password: test
+    driver-class-name: com.mysql.cj.jdbc.Driver
+  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: ENC(K+Hff9QGC+fcyi510VIDd9CaeK/IN5WBJ9rlkUsHEdDgIidW+stHHJlsK0lLPUXXREha+ToQZqqDXJrqSE+GUKCXklFhelD8bRHFXBIeP/ZzT2cxhzgKUXgjw3S0Qw2R)
+      chat:
+        options:
+          model: 'Qwen3-1.7'
+      embedding:
+        options:
+          model: 'Bge-m3'
+    vectorstore:
+      qdrant:
+        api-key: lanyuanxiaoyao
+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
+liteflow:
+  rule-source: config/flow.xml
+  print-banner: false
+  check-node-exists: false

service-ai/service-ai-knowledge/src/main/resources/config/flow.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<flow>
+    <chain name="embedding">
+        SER(
+            embedding_start,
+            SWITCH(embedding_mode_switch).TO(
+                normal_embedding,
+                llm_embedding,
+                qa_embedding
+            ),
+            embedding_finish
+        );
+    </chain>
+</flow>

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

@@ -0,0 +1,34 @@
+<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>

service-api/src/main/resources/logback-spring.xml

@@ -7,23 +7,6 @@
     <springProperty scope="context" name="LOGGING_PARENT" source="logging.parent"/>
     <springProperty scope="context" name="APP_NAME" source="spring.application.name"/>
 
-    <appender name="Loki" class="com.github.loki4j.logback.Loki4jAppender">
-        <metricsEnabled>true</metricsEnabled>
-        <http class="com.github.loki4j.logback.ApacheHttpSender">
-            <url>${LOKI_PUSH_URL:-http://localhost/loki/api/v1/push}</url>
-        </http>
-        <format>
-            <label>
-                <pattern>app=${APP_NAME:-none},host=${HOSTNAME:-none},level=%level</pattern>
-                <readMarkers>true</readMarkers>
-            </label>
-            <message>
-                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %p [${HOSTNAME}] [%t] %logger #@# %m%n%wEx</pattern>
-            </message>
-            <sortByTime>true</sortByTime>
-        </format>
-    </appender>
-
     <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>
@@ -45,7 +28,6 @@
     <logger name="com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver" level="WARN"/>
 
     <root level="INFO">
-        <appender-ref ref="Loki"/>
         <appender-ref ref="Console"/>
         <appender-ref ref="RollingFile"/>
     </root>

service-check/pom.xml

@@ -60,10 +60,6 @@
                 </exclusion>
             </exclusions>
         </dependency>
-        <dependency>
-            <groupId>io.juicefs</groupId>
-            <artifactId>juicefs-hadoop</artifactId>
-        </dependency>
         <dependency>
             <groupId>com.lanyuanxiaoyao</groupId>
             <artifactId>service-configuration</artifactId>

service-cli/service-cli-core/src/main/java/com/lanyuanxiaoyao/service/cli/core/RuntimeInfo.java

@@ -1,5 +1,7 @@
 package com.lanyuanxiaoyao.service.cli.core;
 
+import java.util.Map;
+
 /**
  * 运行配置
  *
@@ -10,7 +12,8 @@ public class RuntimeInfo {
     private String signature;
     private String user;
     private String jarPath;
-    private String jdkPath;
+    private String defaultJdk;
+    private Map<String, String> jdkPath;
     private String logPath;
     private String confPath;
     private String dataPath;
@@ -47,11 +50,19 @@ public class RuntimeInfo {
         this.jarPath = jarPath;
     }
 
-    public String getJdkPath() {
+    public String getDefaultJdk() {
+        return defaultJdk;
+    }
+
+    public void setDefaultJdk(String defaultJdk) {
+        this.defaultJdk = defaultJdk;
+    }
+
+    public Map<String, String> getJdkPath() {
         return jdkPath;
     }
 
-    public void setJdkPath(String jdkPath) {
+    public void setJdkPath(Map<String, String> jdkPath) {
         this.jdkPath = jdkPath;
     }
 
@@ -146,22 +157,23 @@ public class RuntimeInfo {
     @Override
     public String toString() {
         return "RuntimeInfo{" +
-               "signature='" + signature + '\'' +
-               ", user='" + user + '\'' +
-               ", jarPath='" + jarPath + '\'' +
-               ", jdkPath='" + jdkPath + '\'' +
-               ", logPath='" + logPath + '\'' +
-               ", confPath='" + confPath + '\'' +
-               ", dataPath='" + dataPath + '\'' +
-               ", downloadUrl='" + downloadUrl + '\'' +
-               ", kerberosKeytabPath='" + kerberosKeytabPath + '\'' +
-               ", loki=" + loki +
-               ", zkUrl='" + zkUrl + '\'' +
-               ", connectorZkUrl='" + connectorZkUrl + '\'' +
-               ", hudi=" + hudi +
-               ", security=" + security +
-               ", yarn=" + yarn +
-               '}';
+                "signature='" + signature + '\'' +
+                ", user='" + user + '\'' +
+                ", jarPath='" + jarPath + '\'' +
+                ", defaultJdk='" + defaultJdk + '\'' +
+                ", jdkPath=" + jdkPath +
+                ", logPath='" + logPath + '\'' +
+                ", confPath='" + confPath + '\'' +
+                ", dataPath='" + dataPath + '\'' +
+                ", downloadUrl='" + downloadUrl + '\'' +
+                ", kerberosKeytabPath='" + kerberosKeytabPath + '\'' +
+                ", loki=" + loki +
+                ", zkUrl='" + zkUrl + '\'' +
+                ", connectorZkUrl='" + connectorZkUrl + '\'' +
+                ", hudi=" + hudi +
+                ", security=" + security +
+                ", yarn=" + yarn +
+                '}';
     }
 
     public static final class LokiInfo {

service-cli/service-cli-core/src/main/java/com/lanyuanxiaoyao/service/cli/core/ServiceInfo.java

@@ -17,6 +17,7 @@ public class ServiceInfo {
     private List<String> groups = new ArrayList<>();
     private Integer replicas = 0;
     private String sourceJar;
+    private String jdk;
     private List<String> classpath = new ArrayList<>();
     private Map<String, Object> environments = new HashMap<>();
     private Map<String, Object> arguments = new HashMap<>();
@@ -61,6 +62,14 @@ public class ServiceInfo {
         this.sourceJar = sourceJar;
     }
 
+    public String getJdk() {
+        return jdk;
+    }
+
+    public void setJdk(String jdk) {
+        this.jdk = jdk;
+    }
+
     public List<String> getClasspath() {
         return classpath;
     }
@@ -88,14 +97,15 @@ public class ServiceInfo {
     @Override
     public String toString() {
         return "ServiceInfo{" +
-               "enabled=" + enabled +
-               ", order=" + order +
-               ", groups=" + groups +
-               ", replicas=" + replicas +
-               ", sourceJar='" + sourceJar + '\'' +
-               ", classpath=" + classpath +
-               ", environments=" + environments +
-               ", arguments=" + arguments +
-               '}';
+                "enabled=" + enabled +
+                ", order=" + order +
+                ", groups=" + groups +
+                ", replicas=" + replicas +
+                ", sourceJar='" + sourceJar + '\'' +
+                ", jdk=" + jdk +
+                ", classpath=" + classpath +
+                ", environments=" + environments +
+                ", arguments=" + arguments +
+                '}';
     }
 }

service-cli/service-cli-runner/src/main/java/com/lanyuanxiaoyao/service/cli/runner/RunnerApplication.java

@@ -138,7 +138,8 @@ public class RunnerApplication implements ApplicationRunner {
         Path planPath = Paths.get(root.toString(), "deploy.plan");
         Map<String, List<String>> deployPlans = new HashMap<>();
         if (Files.exists(planPath) && !deployInformationProperties.getShuffler()) {
-            deployPlans = mapper.readValue(new String(Files.readAllBytes(planPath)), new TypeReference<Map<String, List<String>>>() {});
+            deployPlans = mapper.readValue(new String(Files.readAllBytes(planPath)), new TypeReference<Map<String, List<String>>>() {
+            });
         }
 
         for (ServiceInfoWrapper serviceInfo : serviceInfoList) {
@@ -187,8 +188,8 @@ public class RunnerApplication implements ApplicationRunner {
                     MapUtil.builder()
                             .put("currentPath", absolutRootPath)
                             .put("hosts", hostInfoList
-                                    .collect(HostInfoWrapper::getIp)
-                                    .toSortedList(Comparator.naturalOrder()))
+                                    .collect(HostInfoWrapper::getHostnameIp)
+                                    .toSortedList((o1, o2) -> Comparator.<String>naturalOrder().compare(o1.getIp(), o2.getIp())))
                             .put("runtime", runtimeInfo)
                             .put("info", serviceInfo)
                             .put("arguments", serviceInfo.getArguments())
@@ -204,8 +205,8 @@ public class RunnerApplication implements ApplicationRunner {
                     MapUtil.builder()
                             .put("currentPath", absolutRootPath)
                             .put("hosts", hostInfoList
-                                    .collect(HostInfoWrapper::getIp)
-                                    .toSortedList(Comparator.naturalOrder()))
+                                    .collect(HostInfoWrapper::getHostnameIp)
+                                    .toSortedList((o1, o2) -> Comparator.<String>naturalOrder().compare(o1.getIp(), o2.getIp())))
                             .put("selectedHosts", selectedHosts)
                             .put("runtime", runtimeInfo)
                             .put("info", serviceInfo)
@@ -220,12 +221,15 @@ public class RunnerApplication implements ApplicationRunner {
         }
 
         generateTemplate(
-                "cloud/stop-script.ftl",
+                "cloud/ssh-script.ftl",
                 MapUtil.builder()
                         .put("currentPath", absolutRootPath)
+                        .put("hosts", hostInfoList
+                                .collect(HostInfoWrapper::getHostnameIp)
+                                .toSortedList((o1, o2) -> Comparator.<String>naturalOrder().compare(o1.getIp(), o2.getIp())))
                         .put("runtime", runtimeInfo)
                         .build(),
-                Paths.get(root.toString(), "stop.sh")
+                Paths.get(root.toString(), "ssh.sh")
         );
 
         MutableMap<String, MutableList<ServiceInfoWrapper>> groups = Maps.mutable.empty();
@@ -326,14 +330,14 @@ public class RunnerApplication implements ApplicationRunner {
                 Paths.get(root.toString(), "update.sh")
         );
 
-        Template stopTemplate = engine.getTemplate("cloud/stop-script.ftl");
-        String stopScript = stopTemplate.render(MapUtil.builder()
-                .put("currentPath", absolutRootPath)
-                .put("runtime", runtimeInfo)
-                .build());
-        // 一个魔法操作
-        stopScript = stopScript.replaceAll("application_name=\".*\"", "application_name=\"service-uploader.jar\"");
-        Files.write(Paths.get(root.toString(), "stop.sh"), stopScript.getBytes());
+        generateTemplate(
+                "uploader/stop.ftl",
+                MapUtil.builder()
+                        .put("currentPath", absolutRootPath)
+                        .put("runtime", runtimeInfo)
+                        .build(),
+                Paths.get(root.toString(), "stop.sh")
+        );
     }
 
     private void generateUpdateJar(Path root) throws IOException {

service-cli/service-cli-runner/src/main/java/com/lanyuanxiaoyao/service/cli/runner/ServiceInfoWrapper.java

@@ -49,6 +49,10 @@ public class ServiceInfoWrapper {
         return serviceInfo.getSourceJar();
     }
 
+    public String getJdk() {
+        return serviceInfo.getJdk();
+    }
+
     public List<String> getClasspath() {
         return serviceInfo.getClasspath();
     }

service-cli/service-cli-runner/src/main/resources/application-b12.yml

@@ -7,7 +7,11 @@ deploy:
     # 应用jar包
     jar-path: /data/datalake/jars
     # 主机jdk根目录
-    jdk-path: /opt/jdk8u252-b09
+    default-jdk: jdk8_arm
+    jdk-path:
+      "jdk8": /opt/jdk1.8.0_162
+      "jdk8_arm": /opt/jdk8u252-b09
+      "jdk17": /opt/jdk-17.0.15
     # 应用日志
     log-path: /data/datalake/logs
     # 应用配置

service-cli/service-cli-runner/src/main/resources/application.yml

@@ -38,8 +38,6 @@ deploy:
         "[connector.hadoop.kerberos-keytab-path]": ${deploy.runtime.kerberos-keytab-path}
         "[connector.hudi.app-hdfs-path]": ${deploy.runtime.hudi.app-hdfs-path}
         "[connector.hudi.app-test-hdfs-path]": ${deploy.runtime.hudi.app-test-hdfs-path}
-        "[connector.hudi.victoria-push-url]": ${deploy.runtime.hudi.victoria-push-url}
-        "[connector.hudi.loki-push-url]": ${deploy.runtime.hudi.loki-push-url}
       arguments:
         "[spring.application.name]": service-launcher-b1
         "[connector.cluster.cluster]": b1
@@ -59,8 +57,6 @@ deploy:
         "[connector.hadoop.kerberos-keytab-path]": ${deploy.runtime.kerberos-keytab-path}
         "[connector.hudi.app-hdfs-path]": ${deploy.runtime.hudi.app-hdfs-path}
         "[connector.hudi.app-test-hdfs-path]": ${deploy.runtime.hudi.app-test-hdfs-path}
-        "[connector.hudi.victoria-push-url]": ${deploy.runtime.hudi.victoria-push-url}
-        "[connector.hudi.loki-push-url]": ${deploy.runtime.hudi.loki-push-url}
       arguments:
         "[spring.application.name]": service-launcher-a4
         "[connector.cluster.cluster]": a4
@@ -80,8 +76,6 @@ deploy:
         "[connector.hadoop.kerberos-keytab-path]": ${deploy.runtime.kerberos-keytab-path}
         "[connector.hudi.app-hdfs-path]": ${deploy.runtime.hudi.app-hdfs-path}
         "[connector.hudi.app-test-hdfs-path]": ${deploy.runtime.hudi.app-test-hdfs-path}
-        "[connector.hudi.victoria-push-url]": ${deploy.runtime.hudi.victoria-push-url}
-        "[connector.hudi.loki-push-url]": ${deploy.runtime.hudi.loki-push-url}
       arguments:
         "[spring.application.name]": service-launcher-b12
         "[connector.cluster.cluster]": b12
@@ -147,7 +141,6 @@ deploy:
         "[connector.hadoop.kerberos-principal]": ${deploy.runtime.user}/$\{hostname}.hdp.dc@ECLD.COM
         "[connector.hadoop.kerberos-keytab-path]": ${deploy.runtime.kerberos-keytab-path}
       arguments:
-        "[executor.loki-push-url]": ${deploy.runtime.loki.hudi-push-url}
         "[executor.task-jar-path]": ${deploy.runtime.executor.task-jar-path}
         "[executor.task-result-path]": ${deploy.runtime.executor.task-result-path}
     service-web:
@@ -168,3 +161,10 @@ deploy:
         - "service"
       source-jar: service-monitor-1.0.0-SNAPSHOT.jar
       replicas: 1
+    service-ai-chat:
+      order: 6
+      groups:
+        - "ai"
+      source-jar: service-ai-chat-1.0.0-SNAPSHOT.jar
+      jdk: "jdk17"
+      replicas: 1

service-cli/service-cli-runner/src/main/resources/template/check/check.ftl

@@ -1,4 +1,4 @@
 #!/bin/bash
 mkdir -p ${runtime.jarPath}
 curl ${runtime.downloadUrl}/service-check-1.0.0-SNAPSHOT.jar -o ${runtime.jarPath}/service-check.jar
-${runtime.jdkPath}/bin/java -jar ${runtime.jarPath}/service-check.jar
+${runtime.jdkPath['jdk8']}/bin/java -jar ${runtime.jarPath}/service-check.jar

service-cli/service-cli-runner/src/main/resources/template/cloud/deploy.ftl

@@ -13,7 +13,7 @@ hostname_full=`ssh $host 'hostname -f'`
 <#-- 获取当前时间 -->
 start_time=`date +%Y%m%d%H%M%S`
 ssh $host "mkdir -p ${runtime.jarPath};curl ${runtime.downloadUrl}/${info.sourceJar} -o ${runtime.jarPath}/${info.name}.jar"
-ssh $host "export JASYPT_ENCRYPTOR_PASSWORD='r#(R,P\"Dp^A47>WSn:Wn].gs/+\"v:q_Q*An~zF*g-@j@jtSTv5H/,S-3:R?r9R}.';nohup ${runtime.jdkPath}/bin/java <#list environments?keys as key>-D${key}=${environments[key]?string} </#list>-jar ${runtime.jarPath}/${info.name}.jar <#noparse>--deploy.datetime=${datetime} --deploy.ip=${host} --deploy.hostname=${hostname} --deploy.hostname-full=${hostname_full} --deploy.start-time=${start_time}</#noparse> --hudi-service.signature=${runtime.signature} --logging.parent=${runtime.logPath} --loki.url=${runtime.loki.servicePushUrl} --spring.cloud.zookeeper.connect-string=${runtime.zkUrl} --spring.security.meta.authority='${runtime.security.authority}' --spring.security.meta.username='${runtime.security.username}' --spring.security.meta.darkcode='${runtime.security.darkcode}' --yarn-cluster.sync-clusters=${runtime.yarn.syncClusters} --yarn-cluster.compaction-clusters=${runtime.yarn.compactionClusters} <#list arguments?keys as key>--${key}='${arguments[key]?string}' </#list>> /dev/null 2>&1 &"
+ssh $host "export JASYPT_ENCRYPTOR_PASSWORD='r#(R,P\"Dp^A47>WSn:Wn].gs/+\"v:q_Q*An~zF*g-@j@jtSTv5H/,S-3:R?r9R}.';nohup ${runtime.jdkPath[info.jdk!(runtime.defaultJdk)]}/bin/java <#list environments?keys as key>-D${key}=${environments[key]?string} </#list>-jar ${runtime.jarPath}/${info.name}.jar <#noparse>--deploy.datetime=${datetime} --deploy.ip=${host} --deploy.hostname=${hostname} --deploy.hostname-full=${hostname_full} --deploy.start-time=${start_time}</#noparse> --hudi-service.signature=${runtime.signature} --logging.parent=${runtime.logPath} --spring.cloud.zookeeper.connect-string=${runtime.zkUrl} --spring.security.meta.authority='${runtime.security.authority}' --spring.security.meta.username='${runtime.security.username}' --spring.security.meta.darkcode='${runtime.security.darkcode}' --yarn-cluster.sync-clusters=${runtime.yarn.syncClusters} --yarn-cluster.compaction-clusters=${runtime.yarn.compactionClusters} <#list arguments?keys as key>--${key}='${arguments[key]?string}' </#list>> /dev/null 2>&1 &"
 </#if>
 echo ''
 </#list>

service-cli/service-cli-runner/src/main/resources/template/cloud/log.ftl

@@ -13,5 +13,5 @@ for host in <#noparse>${hosts[@]}</#noparse>
 do
   hostname=`ssh $host 'echo $HOSTNAME'`
   echo "$host $hostname"
-  ssh $host "cat ${runtime.logPath}/${info.name}.log" > ${currentPath}/logs/${info.name}/$hostname.log
+  scp $host:${runtime.logPath}/${info.name}.log ${currentPath}/logs/${info.name}/$hostname.log
 done