|
@@ -61,12 +61,14 @@ import {useRouter} from "vue-router";
|
|
|
import {isValue, YMDHms} from "@/utils/czr-util";
|
|
|
import {fetchSuggestedQuestions, updateFeedback} from "@/views/smart-ask-answer/assistant-2/dify/share";
|
|
|
import {staticConQueryQuestionslist} from "@/views/smart-ask-answer/assistant-2/cms/api";
|
|
|
+import {ElMessage} from "element-plus";
|
|
|
|
|
|
const emit = defineEmits(['getText', 'getSuggest', 'loadingSuggest'])
|
|
|
const router = useRouter()
|
|
|
const state: any = reactive({
|
|
|
text: '',
|
|
|
loading: false,
|
|
|
+ waiting: false,
|
|
|
params: {
|
|
|
response_mode: "streaming",
|
|
|
conversation_id: "",
|
|
@@ -95,7 +97,14 @@ const scrollToEnd = () => {
|
|
|
}
|
|
|
const onSend = (text = '') => {
|
|
|
if ((isValue(state.text.trim()) || text) && !state.loading) {
|
|
|
- state.loading = true
|
|
|
+ if (state.waiting) {
|
|
|
+ ElMessage({
|
|
|
+ message: '问题回复中,请稍后提问!',
|
|
|
+ grouping: true,
|
|
|
+ type: 'info',
|
|
|
+ })
|
|
|
+ return
|
|
|
+ }
|
|
|
if (text) {
|
|
|
state.params.query = text
|
|
|
} else {
|
|
@@ -118,13 +127,15 @@ const onSend = (text = '') => {
|
|
|
type: 'answer',
|
|
|
content: '',
|
|
|
messageId: '',
|
|
|
- suggest: []
|
|
|
+ suggest: [],
|
|
|
+ loading: true
|
|
|
})
|
|
|
state.chats.push(answer)
|
|
|
scrollToEnd()
|
|
|
const floatingDiv = ref_auto.value
|
|
|
floatingDiv.style.visibility = 'hidden';
|
|
|
floatingDiv.style.display = 'flex';
|
|
|
+ state.waiting = true
|
|
|
ssePost(`/installed-apps/${window.czrConfig.dify.appId}/chat-messages`, {
|
|
|
body: state.params,
|
|
|
}, {
|
|
@@ -141,7 +152,8 @@ const onSend = (text = '') => {
|
|
|
}
|
|
|
answer.messageId = messageEnd.message_id
|
|
|
state.params.parent_message_id = messageEnd.message_id
|
|
|
- state.loading = false
|
|
|
+ state.waiting = false
|
|
|
+ answer.loading = false
|
|
|
if (state.chatConfig?.suggested_questions_after_answer?.enabled && state.isSuggest) {
|
|
|
const warningStr1 = state.chatConfig?.sensitive_word_avoidance?.config?.outputs_config?.preset_response
|
|
|
if (warningStr1 && answer.content.includes(warningStr1)) {
|
|
@@ -158,7 +170,10 @@ const onSend = (text = '') => {
|
|
|
}
|
|
|
},
|
|
|
onMessageReplace: (messageReplace) => {},
|
|
|
- onError() {},
|
|
|
+ onError(msg, code) {
|
|
|
+ console.error(msg, code)
|
|
|
+ state.waiting = false
|
|
|
+ },
|
|
|
onWorkflowStarted: ({ workflow_run_id, task_id }) => {},
|
|
|
onWorkflowFinished: ({ data: workflowFinishedData }) => {},
|
|
|
onIterationStart: ({ data: iterationStartedData }) => {},
|
|
@@ -168,7 +183,6 @@ const onSend = (text = '') => {
|
|
|
onTTSChunk: (messageId: string, audio: string) => {},
|
|
|
onTTSEnd: (messageId: string, audio: string) => {},
|
|
|
})
|
|
|
- // getRelation(state.params.query)
|
|
|
}
|
|
|
}
|
|
|
const getRelation = (text) => {
|