github/dootask
1
0
Fork 0
mirror of https://github.com/kuaifan/dootask.git synced 2025-12-16 14:12:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
kuaifan 2025-04-22 21:37:13 +08:00
parent ca65eb907d
commit ada526fa63
2 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
resources/assets/js/pages/manage/components/DialogWrapper.vue
View File

@ -842,7 +842,7 @@ export default {
mounted() { mounted() {
emitter.on('websocketMsg', this.onWebsocketMsg); emitter.on('websocketMsg', this.onWebsocketMsg);
emitter.on('dialogMsgChange', this.onMsgChange); emitter.on('streamMsgData', this.onMsgChange);
this.keepInterval = setInterval(this.keepIntoInput, 1000) this.keepInterval = setInterval(this.keepIntoInput, 1000)
this.windowTouch && document.addEventListener('selectionchange', this.onSelectionchange); this.windowTouch && document.addEventListener('selectionchange', this.onSelectionchange);
}, },
@ -850,7 +850,7 @@ export default {
beforeDestroy() { beforeDestroy() {
this.windowTouch && document.removeEventListener('selectionchange', this.onSelectionchange); this.windowTouch && document.removeEventListener('selectionchange', this.onSelectionchange);
clearInterval(this.keepInterval); clearInterval(this.keepInterval);
emitter.off('dialogMsgChange', this.onMsgChange); emitter.off('streamMsgData', this.onMsgChange);
emitter.off('websocketMsg', this.onWebsocketMsg); emitter.off('websocketMsg', this.onWebsocketMsg);
this.generateUnreadData(this.dialogId) this.generateUnreadData(this.dialogId)
// //

23
resources/assets/js/store/actions.js vendored
View File

@ -3823,12 +3823,12 @@ export default {
}, },
/** /**
* 消息流 * 消息流订阅
* @param state * @param state
* @param dispatch * @param dispatch
* @param streamUrl * @param streamUrl
*/ */
streamDialogMsg({state, dispatch}, streamUrl) { streamMsgSubscribe({state, dispatch}, streamUrl) {
if (!/^https?:\/\//i.test(streamUrl)) { if (!/^https?:\/\//i.test(streamUrl)) {
streamUrl = $A.mainUrl(streamUrl.substring(1)) streamUrl = $A.mainUrl(streamUrl.substring(1))
} }
@ -3841,11 +3841,11 @@ export default {
case 'append': case 'append':
case 'replace': case 'replace':
const data = $A.jsonParse(e.data); const data = $A.jsonParse(e.data);
emitter.emit('dialogMsgChange', { dispatch("streamMsgData", {
type, type,
id: e.lastEventId, id: e.lastEventId,
text: data.content text: data.content
}); })
break; break;
case 'done': case 'done':
@ -3863,6 +3863,16 @@ export default {
} }
}, },
/**
* 消息流数据
* @param state
* @param data
*/
streamMsgData({state}, data) {
$A.syncDispatch("streamMsgData", data)
emitter.emit('streamMsgData', data);
},
/** /**
* 保存翻译 * 保存翻译
* @param state * @param state
@ -4155,7 +4165,10 @@ export default {
break break
case "msgStream": case "msgStream":
dispatch("streamDialogMsg", msgDetail.stream_url); if ($A.isSubElectron) {
return
}
dispatch("streamMsgSubscribe", msgDetail.stream_url);
break break
default: default: