ZF/open-anylink-web
1
0
Fork 0
mirror of https://gitee.com/lijingbo-2021/open-anylink-web.git synced 2026-05-14 19:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

消息业务层超时重发机制

Browse Source
This commit is contained in:
bob
2024-12-30 23:22:38 +08:00
parent 081430bfe8
commit 98a5d85244
11 changed files with 407 additions and 335 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/js/websocket/constructor.js
View File

@@ -3,7 +3,7 @@ import { proto } from '@/const/msgConst'
import { userStore } from '@/stores'
import { v4 as uuidv4 } from 'uuid'
export const chatConstructor = (sessionId, toId, content, tempMsgId) => {
export const chatConstructor = (sessionId, toId, content, seq) => {
const header = Header.create({
magic: proto.magic,
version: proto.version,
@@ -18,7 +18,7 @@ export const chatConstructor = (sessionId, toId, content, tempMsgId) => {
toId: toId,
sessionId: sessionId,
content: content,
tempMsgId: tempMsgId
seq: seq
})
const chatMsg = Msg.create({ header: header, body: body })
const payload = Msg.encode(chatMsg).finish()
@@ -27,7 +27,7 @@ export const chatConstructor = (sessionId, toId, content, tempMsgId) => {
return data
}
export const groupChatConstructor = (sessionId, groupId, content, tempMsgId) => {
export const groupChatConstructor = (sessionId, groupId, content, seq) => {
const header = Header.create({
magic: proto.magic,
version: proto.version,
@@ -42,7 +42,7 @@ export const groupChatConstructor = (sessionId, groupId, content, tempMsgId) =>
sessionId: sessionId,
groupId: groupId,
content: content,
tempMsgId: tempMsgId
seq: seq
})
const msg = Msg.create({ header: header, body: body })
const payload = Msg.encode(msg).finish()
@@ -94,7 +94,7 @@ export const chatReadConstructor = (sessionId, toId, content) => {
toId: toId,
sessionId: sessionId,
content: content,
tempMsgId: uuidv4()
seq: uuidv4()
})
const chatMsg = Msg.create({ header: header, body: body })
const payload = Msg.encode(chatMsg).finish()
@@ -118,7 +118,7 @@ export const groupChatReadConstructor = (sessionId, groupId, content) => {
toId: groupId,
sessionId: sessionId,
content: content,
tempMsgId: uuidv4()
seq: uuidv4()
})
const chatMsg = Msg.create({ header: header, body: body })
const payload = Msg.encode(chatMsg).finish()