506 lines
15 KiB
Vue
506 lines
15 KiB
Vue
<template>
|
||
<div class="application-workflow" v-loading="loading">
|
||
<div class="header border-b flex-between p-12-24">
|
||
<div class="flex align-center">
|
||
<back-button @click="back"></back-button>
|
||
<h4>{{ detail?.name }}</h4>
|
||
<div v-if="showHistory && disablePublic">
|
||
<el-text type="info" class="ml-16 color-secondary"
|
||
>{{ $t('views.applicationWorkflow.info.previewVersion') }}
|
||
{{ currentVersion.name || datetimeFormat(currentVersion.update_time) }}</el-text
|
||
>
|
||
</div>
|
||
<el-text type="info" class="ml-16 color-secondary" v-else-if="saveTime"
|
||
>{{ $t('views.applicationWorkflow.info.saveTime')
|
||
}}{{ datetimeFormat(saveTime) }}</el-text
|
||
>
|
||
</div>
|
||
<div v-if="showHistory && disablePublic">
|
||
<el-button type="primary" class="mr-8" @click="refreshVersion()">
|
||
{{ $t('views.applicationWorkflow.setting.restoreVersion') }}
|
||
</el-button>
|
||
<el-divider direction="vertical" />
|
||
<el-button text @click="closeHistory">
|
||
<el-icon><Close /></el-icon>
|
||
</el-button>
|
||
</div>
|
||
<div v-else>
|
||
<el-button icon="Plus" @click="showPopover = !showPopover">
|
||
{{ $t('views.applicationWorkflow.setting.addComponent') }}
|
||
</el-button>
|
||
<el-button @click="clickShowDebug" :disabled="showDebug">
|
||
<AppIcon iconName="app-play-outlined" class="mr-4"></AppIcon>
|
||
{{ $t('views.applicationWorkflow.setting.debug') }}</el-button
|
||
>
|
||
<el-button @click="saveApplication(true)">
|
||
<AppIcon iconName="app-save-outlined" class="mr-4"></AppIcon>
|
||
{{ $t('common.save') }}
|
||
</el-button>
|
||
<el-button type="primary" @click="publish">
|
||
{{ $t('views.application.operation.publish') }}
|
||
</el-button>
|
||
|
||
<el-dropdown trigger="click">
|
||
<el-button text @click.stop class="ml-8 mt-4">
|
||
<el-icon class="rotate-90"><MoreFilled /></el-icon>
|
||
</el-button>
|
||
<template #dropdown>
|
||
<el-dropdown-menu>
|
||
<a :href="shareUrl" target="_blank">
|
||
<el-dropdown-item>
|
||
<AppIcon iconName="app-create-chat" class="mr-4"></AppIcon>
|
||
{{ $t('views.application.operation.toChat') }}
|
||
</el-dropdown-item>
|
||
</a>
|
||
|
||
<el-dropdown-item @click="openHistory">
|
||
<AppIcon iconName="app-history-outlined"></AppIcon>
|
||
{{ $t('views.applicationWorkflow.setting.releaseHistory') }}
|
||
</el-dropdown-item>
|
||
<el-dropdown-item>
|
||
<AppIcon iconName="app-save-outlined"></AppIcon>
|
||
{{ $t('views.applicationWorkflow.setting.autoSave') }}
|
||
<div class="ml-4">
|
||
<el-switch size="small" v-model="isSave" @change="changeSave" />
|
||
</div>
|
||
</el-dropdown-item>
|
||
</el-dropdown-menu>
|
||
</template>
|
||
</el-dropdown>
|
||
</div>
|
||
</div>
|
||
<!-- 下拉框 -->
|
||
<el-collapse-transition>
|
||
<DropdownMenu
|
||
:show="showPopover"
|
||
:id="id"
|
||
v-click-outside="clickoutside"
|
||
@clickNodes="clickNodes"
|
||
@onmousedown="onmousedown"
|
||
:workflowRef="workflowRef"
|
||
/>
|
||
</el-collapse-transition>
|
||
<!-- 主画布 -->
|
||
<div class="workflow-main" ref="workflowMainRef">
|
||
<workflow ref="workflowRef" v-if="detail" :data="detail?.work_flow" />
|
||
</div>
|
||
<!-- 调试 -->
|
||
<el-collapse-transition>
|
||
<div class="workflow-debug-container" :class="enlarge ? 'enlarge' : ''" v-if="showDebug">
|
||
<div class="workflow-debug-header" :class="!isDefaultTheme ? 'custom-header' : ''">
|
||
<div class="flex-between">
|
||
<div class="flex align-center">
|
||
<div class="mr-12 ml-24 flex">
|
||
<el-avatar
|
||
v-if="isAppIcon(detail?.icon)"
|
||
shape="square"
|
||
:size="32"
|
||
style="background: none"
|
||
>
|
||
<img :src="detail?.icon" alt="" />
|
||
</el-avatar>
|
||
<LogoIcon v-else height="32px" />
|
||
</div>
|
||
|
||
<h4>
|
||
{{ detail?.name || $t('views.application.form.appName.label') }}
|
||
</h4>
|
||
</div>
|
||
<div class="mr-16">
|
||
<el-button link @click="enlarge = !enlarge">
|
||
<AppIcon
|
||
:iconName="enlarge ? 'app-minify' : 'app-magnify'"
|
||
class="color-secondary"
|
||
style="font-size: 20px"
|
||
></AppIcon>
|
||
</el-button>
|
||
<el-button link @click="showDebug = false">
|
||
<el-icon :size="20" class="color-secondary"><Close /></el-icon>
|
||
</el-button>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
<div class="scrollbar-height">
|
||
<AiChat :application-details="detail" :type="'debug-ai-chat'"></AiChat>
|
||
</div>
|
||
</div>
|
||
</el-collapse-transition>
|
||
<!-- 发布历史 -->
|
||
<PublishHistory
|
||
v-if="showHistory"
|
||
@click="checkVersion"
|
||
v-click-outside="clickoutsideHistory"
|
||
@refreshVersion="refreshVersion"
|
||
/>
|
||
</div>
|
||
</template>
|
||
<script setup lang="ts">
|
||
import { ref, onMounted, onBeforeUnmount, computed, nextTick } from 'vue'
|
||
import { useRouter, useRoute } from 'vue-router'
|
||
import type { Action } from 'element-plus'
|
||
import Workflow from '@/workflow/index.vue'
|
||
import DropdownMenu from '@/views/application-workflow/component/DropdownMenu.vue'
|
||
import PublishHistory from '@/views/application-workflow/component/PublishHistory.vue'
|
||
import applicationApi from '@/api/application/application'
|
||
import { isAppIcon } from '@/utils/common'
|
||
import { MsgSuccess, MsgError, MsgConfirm } from '@/utils/message'
|
||
import { datetimeFormat } from '@/utils/time'
|
||
import { mapToUrlParams } from '@/utils/application'
|
||
import useStore from '@/stores'
|
||
import { WorkFlowInstance } from '@/workflow/common/validate'
|
||
import { hasPermission } from '@/utils/permission'
|
||
import { t } from '@/locales'
|
||
|
||
const { theme, application } = useStore()
|
||
const router = useRouter()
|
||
const route = useRoute()
|
||
|
||
const isDefaultTheme = computed(() => {
|
||
return theme.isDefaultTheme()
|
||
})
|
||
const {
|
||
params: { id },
|
||
} = route as any
|
||
|
||
let interval: any
|
||
const workflowRef = ref()
|
||
const workflowMainRef = ref()
|
||
const loading = ref(false)
|
||
const detail = ref<any>(null)
|
||
|
||
const showPopover = ref(false)
|
||
const showDebug = ref(false)
|
||
const enlarge = ref(false)
|
||
const saveTime = ref<any>('')
|
||
const isSave = ref(false)
|
||
const showHistory = ref(false)
|
||
const disablePublic = ref(false)
|
||
const currentVersion = ref<any>({})
|
||
const cloneWorkFlow = ref(null)
|
||
|
||
const apiInputParams = ref([])
|
||
|
||
const urlParams = computed(() =>
|
||
mapToUrlParams(apiInputParams.value) ? '?' + mapToUrlParams(apiInputParams.value) : '',
|
||
)
|
||
const shareUrl = computed(
|
||
() => `${window.location.origin}/chat/` + detail.value?.access_token + urlParams.value,
|
||
)
|
||
|
||
function back() {
|
||
if (JSON.stringify(cloneWorkFlow.value) !== JSON.stringify(getGraphData())) {
|
||
MsgConfirm(t('common.tip'), t('views.applicationWorkflow.tip.saveMessage'), {
|
||
confirmButtonText: t('views.applicationWorkflow.setting.exitSave'),
|
||
cancelButtonText: t('views.applicationWorkflow.setting.exit'),
|
||
type: 'warning',
|
||
distinguishCancelAndClose: true,
|
||
})
|
||
.then(() => {
|
||
saveApplication(true, true)
|
||
})
|
||
.catch((action: Action) => {
|
||
action === 'cancel' && router.push({ path: `/application/${id}/WORK_FLOW/overview` })
|
||
})
|
||
} else {
|
||
router.push({ path: `/application/${id}/WORK_FLOW/overview` })
|
||
}
|
||
}
|
||
function clickoutsideHistory() {
|
||
if (!disablePublic.value) {
|
||
showHistory.value = false
|
||
disablePublic.value = false
|
||
}
|
||
}
|
||
|
||
function refreshVersion(item?: any) {
|
||
if (item) {
|
||
renderGraphData(item)
|
||
}
|
||
// if (hasPermission(`APPLICATION:MANAGE:${id}`, 'AND') && isSave.value) {
|
||
// initInterval()
|
||
// }
|
||
showHistory.value = false
|
||
disablePublic.value = false
|
||
}
|
||
|
||
function checkVersion(item: any) {
|
||
disablePublic.value = true
|
||
currentVersion.value = item
|
||
renderGraphData(item)
|
||
closeInterval()
|
||
}
|
||
|
||
function renderGraphData(item: any) {
|
||
item.work_flow['nodes'].map((v: any) => {
|
||
v['properties']['noRender'] = true
|
||
})
|
||
detail.value.work_flow = item.work_flow
|
||
saveTime.value = item?.update_time
|
||
workflowRef.value?.clearGraphData()
|
||
nextTick(() => {
|
||
workflowRef.value?.render(item.work_flow)
|
||
})
|
||
}
|
||
|
||
function closeHistory() {
|
||
getDetail()
|
||
if (isSave.value) {
|
||
initInterval()
|
||
}
|
||
showHistory.value = false
|
||
disablePublic.value = false
|
||
}
|
||
|
||
function openHistory() {
|
||
showHistory.value = true
|
||
}
|
||
|
||
function changeSave(bool: boolean) {
|
||
bool ? initInterval() : closeInterval()
|
||
localStorage.setItem('workflowAutoSave', bool.toString())
|
||
}
|
||
|
||
function clickNodes(item: any) {
|
||
showPopover.value = false
|
||
}
|
||
|
||
function onmousedown(item: any) {
|
||
showPopover.value = false
|
||
}
|
||
|
||
function clickoutside() {
|
||
showPopover.value = false
|
||
}
|
||
const publish = () => {
|
||
const workflow = getGraphData()
|
||
const workflowInstance = new WorkFlowInstance(workflow)
|
||
try {
|
||
workflowInstance.is_valid()
|
||
} catch (e: any) {
|
||
MsgError(e.toString())
|
||
return
|
||
}
|
||
applicationApi
|
||
.putApplication(id, { work_flow: workflow }, loading)
|
||
.then((ok) => {
|
||
return applicationApi.publish(id, {}, loading)
|
||
})
|
||
.then((ok: any) => {
|
||
detail.value.name = ok.data.name
|
||
MsgSuccess(t('views.application.tip.publishSuccess'))
|
||
})
|
||
.catch((res: any) => {
|
||
const node = res.node
|
||
const err_message = res.errMessage
|
||
if (typeof err_message == 'string') {
|
||
MsgError(
|
||
res.node.properties?.stepName +
|
||
` ${t('views.applicationWorkflow.node').toLowerCase()} ` +
|
||
err_message.toLowerCase(),
|
||
)
|
||
} else {
|
||
const keys = Object.keys(err_message)
|
||
MsgError(
|
||
node.properties?.stepName +
|
||
` ${t('views.applicationWorkflow.node').toLowerCase()} ` +
|
||
err_message[keys[0]]?.[0]?.message.toLowerCase(),
|
||
)
|
||
}
|
||
})
|
||
}
|
||
|
||
const clickShowDebug = () => {
|
||
workflowRef.value
|
||
?.validate()
|
||
.then(() => {
|
||
const graphData = getGraphData()
|
||
const workflow = new WorkFlowInstance(graphData)
|
||
try {
|
||
workflow.is_valid()
|
||
detail.value = {
|
||
...detail.value,
|
||
type: 'WORK_FLOW',
|
||
...workflow.get_base_node()?.properties.node_data,
|
||
work_flow: getGraphData(),
|
||
}
|
||
|
||
showDebug.value = true
|
||
} catch (e: any) {
|
||
MsgError(e.toString())
|
||
}
|
||
})
|
||
.catch((res: any) => {
|
||
const node = res.node
|
||
const err_message = res.errMessage
|
||
if (typeof err_message == 'string') {
|
||
MsgError(
|
||
res.node.properties?.stepName + ` ${t('views.applicationWorkflow.node')}，` + err_message,
|
||
)
|
||
} else {
|
||
const keys = Object.keys(err_message)
|
||
MsgError(
|
||
node.properties?.stepName +
|
||
` ${t('views.applicationWorkflow.node')}，` +
|
||
err_message[keys[0]]?.[0]?.message,
|
||
)
|
||
}
|
||
})
|
||
}
|
||
function getGraphData() {
|
||
return workflowRef.value?.getGraphData()
|
||
}
|
||
|
||
function getDetail() {
|
||
application.asyncGetApplicationDetail(id).then((res: any) => {
|
||
res.data?.work_flow['nodes'].map((v: any) => {
|
||
v['properties']['noRender'] = true
|
||
})
|
||
detail.value = res.data
|
||
detail.value.stt_model_id = res.data.stt_model
|
||
detail.value.tts_model_id = res.data.tts_model
|
||
detail.value.tts_type = res.data.tts_type
|
||
saveTime.value = res.data?.update_time
|
||
detail.value.work_flow?.nodes
|
||
?.filter((v: any) => v.id === 'base-node')
|
||
.map((v: any) => {
|
||
apiInputParams.value = v.properties.api_input_field_list
|
||
? v.properties.api_input_field_list.map((v: any) => {
|
||
return {
|
||
name: v.variable,
|
||
value: v.default_value,
|
||
}
|
||
})
|
||
: v.properties.input_field_list
|
||
? v.properties.input_field_list
|
||
.filter((v: any) => v.assignment_method === 'api_input')
|
||
.map((v: any) => {
|
||
return {
|
||
name: v.variable,
|
||
value: v.default_value,
|
||
}
|
||
})
|
||
: []
|
||
})
|
||
application.asyncGetAccessToken(id, loading).then((res: any) => {
|
||
detail.value = { ...detail.value, ...res.data }
|
||
})
|
||
workflowRef.value?.clearGraphData()
|
||
nextTick(() => {
|
||
workflowRef.value?.render(detail.value.work_flow)
|
||
cloneWorkFlow.value = getGraphData()
|
||
})
|
||
})
|
||
}
|
||
|
||
function saveApplication(bool?: boolean, back?: boolean) {
|
||
const obj = {
|
||
work_flow: getGraphData(),
|
||
}
|
||
loading.value = back || false
|
||
application
|
||
.asyncPutApplication(id, obj)
|
||
.then((res) => {
|
||
saveTime.value = new Date()
|
||
if (bool) {
|
||
cloneWorkFlow.value = getGraphData()
|
||
MsgSuccess(t('common.saveSuccess'))
|
||
if (back) {
|
||
router.push({ path: `/application/${id}/WORK_FLOW/overview` })
|
||
}
|
||
}
|
||
})
|
||
.catch(() => {
|
||
loading.value = false
|
||
})
|
||
}
|
||
|
||
/**
|
||
* 定时保存
|
||
*/
|
||
const initInterval = () => {
|
||
interval = setInterval(() => {
|
||
saveApplication()
|
||
}, 60000)
|
||
}
|
||
|
||
/**
|
||
* 关闭定时
|
||
*/
|
||
const closeInterval = () => {
|
||
if (interval) {
|
||
clearInterval(interval)
|
||
}
|
||
}
|
||
|
||
onMounted(() => {
|
||
getDetail()
|
||
const workflowAutoSave = localStorage.getItem('workflowAutoSave')
|
||
isSave.value = workflowAutoSave === 'true' ? true : false
|
||
// 初始化定时任务
|
||
if (isSave.value) {
|
||
initInterval()
|
||
}
|
||
})
|
||
|
||
onBeforeUnmount(() => {
|
||
// 清除定时任务
|
||
closeInterval()
|
||
workflowRef.value?.clearGraphData()
|
||
})
|
||
</script>
|
||
<style lang="scss">
|
||
.application-workflow {
|
||
background: var(--app-layout-bg-color);
|
||
height: 100%;
|
||
.header {
|
||
background: #ffffff;
|
||
}
|
||
.workflow-main {
|
||
height: calc(100vh - 62px);
|
||
box-sizing: border-box;
|
||
}
|
||
|
||
.workflow-dropdown-tabs {
|
||
.el-tabs__nav-wrap {
|
||
padding: 0 16px;
|
||
}
|
||
}
|
||
}
|
||
|
||
.workflow-debug-container {
|
||
z-index: 2000;
|
||
position: relative;
|
||
border-radius: 8px;
|
||
border: 1px solid #ffffff;
|
||
background: var(--dialog-bg-gradient-color);
|
||
box-shadow: 0px 4px 8px 0px rgba(31, 35, 41, 0.1);
|
||
position: fixed;
|
||
bottom: 16px;
|
||
right: 16px;
|
||
overflow: hidden;
|
||
width: 450px;
|
||
height: 600px;
|
||
.workflow-debug-header {
|
||
background: var(--app-header-bg-color);
|
||
height: var(--app-header-height);
|
||
line-height: var(--app-header-height);
|
||
box-sizing: border-box;
|
||
border-bottom: 1px solid var(--el-border-color);
|
||
}
|
||
.scrollbar-height {
|
||
height: calc(100% - var(--app-header-height) - 24px);
|
||
padding-top: 24px;
|
||
}
|
||
&.enlarge {
|
||
width: 50% !important;
|
||
height: 100% !important;
|
||
bottom: 0 !important;
|
||
right: 0 !important;
|
||
}
|
||
.chat-width {
|
||
max-width: 100% !important;
|
||
margin: 0 auto;
|
||
}
|
||
}
|
||
</style>
|