shkong/OpenShamrock
1
0
Fork 0
mirror of https://github.com/whitechi73/OpenShamrock.git synced 2024-08-14 13:12:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

ShamrockPublic: 自発メッセージ同期ロジックの変更 x2

Browse Source 
Signed-off-by: WhiteChi <whitechi73@outlook.com>
This commit is contained in:
WhiteChi 2023-11-03 01:17:11 +08:00
parent c3c14d6ead
commit 6043c21de5
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
xposed/src/main/java/moe/fuqiuluo/shamrock/remote/service/listener/AioListener.kt
View File

@ -126,12 +126,32 @@ internal object AioListener: IKernelMsgListener {
override fun onMsgInfoListUpdate(msgList: ArrayList<MsgRecord>?) {
msgList?.forEach { record ->
GlobalScope.launch {
if (!ShamrockConfig.enableSelfMsg())
if (record.sendStatus == MsgConstant.KSENDSTATUSFAILED
|| record.sendStatus == MsgConstant.KSENDSTATUSSENDING) {
return@launch
}
val msgHash = MessageHelper.generateMsgIdHash(record.chatType, record.msgId)
MessageDB.getInstance().messageMappingDao().updateMsgSeqByMsgHash(msgHash, record.msgSeq.toInt())
val mapping = MessageHelper.getMsgMappingByHash(msgHash)
if (mapping == null) {
MessageHelper.saveMsgMapping(
hash = msgHash,
qqMsgId = record.msgId,
chatType = record.chatType,
subChatType = record.chatType,
peerId = record.peerUin.toString(),
msgSeq = record.msgSeq.toInt(),
time = record.msgTime
)
}
if (!ShamrockConfig.enableSelfMsg())
return@launch
LogCenter.log("Update message info from ${mapping?.msgSeq} to ${record.msgSeq}", Level.INFO)
MessageDB.getInstance().messageMappingDao()
.updateMsgSeqByMsgHash(msgHash, record.msgSeq.toInt())
val rawMsg = record.elements.toCQCode(record.chatType, record.peerUin.toString())
if (rawMsg.isEmpty()) return@launch