From ad747a1fba37c9ea63dab1351ce22bc1d5802d4e Mon Sep 17 00:00:00 2001
From: wujingjing <gersonwu@qq.com>
Date: 星期日, 13 四月 2025 19:37:48 +0800
Subject: [PATCH] conversationId
---
src/components/chat/components/playBar/hook/useDigitalHuman.ts | 166 +++++++++++++++++++++++++++++++++----------------------
1 files changed, 99 insertions(+), 67 deletions(-)
diff --git a/src/components/chat/components/playBar/hook/useDigitalHuman.ts b/src/components/chat/components/playBar/hook/useDigitalHuman.ts
index 918c9af..ec2cea5 100644
--- a/src/components/chat/components/playBar/hook/useDigitalHuman.ts
+++ b/src/components/chat/components/playBar/hook/useDigitalHuman.ts
@@ -1,22 +1,46 @@
-import { nextTick, onDeactivated, onMounted, ref } from 'vue';
import { SignJWT } from 'jose';
+import { nextTick, onDeactivated, onMounted, ref } from 'vue';
+import axios from 'axios';
+import { ElMessage } from 'element-plus';
+import { markdownToTxt } from 'markdown-to-txt';
import './libs/duix.js';
import { questionStreamByPost } from '/@/api/ai/chat';
import { activeGroupType, activeRoomId } from '/@/stores/chatRoom';
-import { markdownToTxt } from 'markdown-to-txt';
-
+import type { QuestionLifecycle } from '../../../types';
export type UseDigitalHumanProps = {
container: string;
+ autoSendMessage: (question: string, lifecycleCall?: QuestionLifecycle) => void;
+};
+
+export const getKnowledgePlainText = (item) => {
+ let result = '';
+ const knowledgeText = item.knowledge.reduce((acc, cur) => {
+ const mdText = cur.answer;
+ const linkText = cur.metadata?.Title;
+ if (linkText) {
+ return `${mdText}\n\n${linkText}`;
+ }
+ return acc + mdText;
+ }, '');
+ // const conclusionText =
+ // item.conclusion
+ // ?.filter((item) => !!item.report)
+ // .map((item) => item.report)
+ // .join('\n\n') ?? '';
+ // result += knowledgeText + conclusionText;
+ result = knowledgeText;
+ return markdownToTxt(result);
};
export const useDigitalHuman = (props: UseDigitalHumanProps) => {
- const { container } = props;
+ const { container, autoSendMessage } = props;
+ const digitalHumanWidth = '240px';
const duixConfig = {
appId: '1356792813207031808',
appKey: '659b068e-900c-4fe5-bb96-3ca70fe0aae4',
sign: '',
- conversationId: '1909088110274277378',
+ conversationId: '1911336603251347458',
/** @description 杩囨湡鏃堕棿锛堝皬鏃讹級 */
expired: 12,
};
@@ -30,6 +54,32 @@
digitalHumanIsShow.value = false;
resetDuixStatus();
};
+ /**
+ * 妫�鏌ユ暟瀛椾汉鏄惁鍙敤
+ */
+ const checkIsUseable = async () => {
+ const config = {
+ method: 'get',
+ url: `https://duix.guiji.ai/duix-openapi-v2/v1/getconcurrentNumber?appId=${duixConfig.appId}`,
+ headers: {
+ priority: 'u=1, i',
+ sig: duixConfig.sign,
+ },
+ };
+
+ const response = await axios(config);
+ const data = response.data.data;
+ const total = data.totalConcurrentNumber;
+ const user = data.userConcurrentNumber;
+ if (total === null || total === 0) {
+ return false;
+ }
+ if (total !== null && total === user) {
+ return false;
+ }
+
+ return true;
+ };
const resetDuixStatus = () => {
humanIsLoading.value = true;
@@ -37,25 +87,6 @@
// isSpeaking.value = false;
digitalHumanIsShow.value = false;
duix?.stop();
- };
- const getPlainText = (item) => {
- let result = '';
- const knowledgeText = item.knowledge.reduce((acc, cur) => {
- const mdText = cur.answer;
- const linkText = cur.metadata?.Title;
- if (linkText) {
- return `${mdText}\n\n${linkText}`;
- }
- return acc + mdText;
- }, '');
- // const conclusionText =
- // item.conclusion
- // ?.filter((item) => !!item.report)
- // .map((item) => item.report)
- // .join('\n\n') ?? '';
- // result += knowledgeText + conclusionText;
- result = knowledgeText;
- return markdownToTxt(result);
};
let isWaitingSpeak = false;
@@ -67,6 +98,19 @@
duix.speak({
content,
});
+ };
+
+ const startDuix = () => {
+ const conversationId = duixConfig.conversationId; // duix骞冲彴浼氳瘽id
+
+ duix
+ .start({ conversationId, openAsr: true, wipeGreen: true })
+ .then((res) => {
+ console.info('start', res);
+ })
+ .catch((err) => {
+ console.error('start error', err);
+ });
};
const initDuix = () => {
@@ -81,9 +125,7 @@
duix.on('intialSucccess', () => {
console.info('intialSucccess');
// 姝ゆ椂鍒濆鍖栨垚鍔燂紝鍙皟鐢╯tart
- duix.start({ conversationId, openAsr: true,wipeGreen:true }).then((res) => {
- console.info('start', res);
- });
+ startDuix();
});
duix.on('bye', (data) => {
console.info('bye', data);
@@ -110,6 +152,7 @@
duix.on('speakEnd', (data) => {
if (!isWaitingSpeak) {
isReceiveRes.value = false;
+ duix.openAsr().then((...a) => {});
}
});
duix.on('speakSection', (data) => {
@@ -123,45 +166,30 @@
if (isReceiveRes.value) {
return;
}
+ duix.closeAsr().then((...a) => {});
- let hasResult = false;
isReceiveRes.value = true;
- try {
- isWaitingSpeak = true;
- duix.speak({
- content: '宸叉敹鍒版偍鐨勯棶棰橈紝姝ｅ湪鎬濊�冧腑...璇风◢绛�',
- });
- questionStreamByPost(
- {
- question: data,
- history_group_id: activeRoomId.value,
- raw_mode: false,
- group_type: activeGroupType.value,
- is_digital_human: true,
- },
- (chunkRes) => {
- if (chunkRes.mode === 'result' && chunkRes.value?.answer_type === 'knowledge') {
- const plainText = getPlainText(chunkRes.value);
- hasResult = true;
- speakContent(plainText);
- } else if (!chunkRes.value?.json_ok && chunkRes.value?.err_code === 'MESSAGE') {
- if (hasResult) return;
- hasResult = true;
- speakContent(chunkRes.value.json_msg);
- }
+ isWaitingSpeak = true;
+ duix.speak({
+ content: '宸叉敹鍒版偍鐨勯棶棰橈紝姝ｅ湪鎬濊�冧腑...璇风◢绛�',
+ });
- if (chunkRes.mode === 'finish') {
- if (!hasResult) {
- speakContent('鏆傛椂鏃犳硶鍙ｅご鎻忚堪浣犳墍璇寸殑闂');
- } else {
- hasResult = false;
- }
- // isReceiveRes.value = false;
+ let content = '';
+
+ try {
+ autoSendMessage(data, {
+ receiveText: (text: string) => {
+ content += text;
+ },
+ finish: () => {
+ if (!content) {
+ speakContent('鏆傛椂鏃犳硶鍙ｅご鎻忚堪浣犳墍璇寸殑闂');
+ } else {
+ speakContent(content);
}
- }
- );
+ },
+ });
} catch (error) {
- console.error(error);
isReceiveRes.value = false;
}
});
@@ -180,20 +208,23 @@
let hasInitDuix = false;
let duix: any;
- const openDigitalHuman = () => {
+ const openDigitalHuman = async () => {
+ duixConfig.sign = await createSig(duixConfig.appId, duixConfig.appKey, 60 * 60 * duixConfig.expired);
+ const isUsable = await checkIsUseable();
+ if (!isUsable) {
+ ElMessage.warning('"璧勬簮鍗犵敤涓紝璇锋鏌ュ悗鍐嶈瘯~"');
+ return;
+ }
digitalHumanIsShow.value = true;
- nextTick(async () => {
- duixConfig.sign = await createSig(duixConfig.appId, duixConfig.appKey, 60 * 60 * duixConfig.expired);
+ nextTick(() => {
if (!hasInitDuix) {
hasInitDuix = true;
duix = new DUIX();
initDuix();
} else {
- duix.start({ conversationId: duixConfig.conversationId, openAsr: true }).then((res) => {
- console.info('start', res);
- });
+ startDuix();
}
});
};
@@ -226,5 +257,6 @@
isHumanTalking: isReceiveRes,
closeDigitalHuman,
humanIsLoading,
+ digitalHumanWidth,
};
};
--
Gitblit v1.9.3