mirror of
https://github.com/WuKongIM/WuKongIMFlutterSDK
synced 2025-06-02 09:02:48 +00:00
fix:update sync channel message
This commit is contained in:
parent
8f58729b9b
commit
b0172b8a3b
@ -45,7 +45,8 @@ class HttpUtils {
|
|||||||
conversation.conversations = [];
|
conversation.conversations = [];
|
||||||
if (response.statusCode == HttpStatus.ok) {
|
if (response.statusCode == HttpStatus.ok) {
|
||||||
try {
|
try {
|
||||||
var list = jsonDecode(response.data);
|
var list = response.data;
|
||||||
|
// var list = jsonDecode(response.data);
|
||||||
for (int i = 0; i < list.length; i++) {
|
for (int i = 0; i < list.length; i++) {
|
||||||
var json = list[i];
|
var json = list[i];
|
||||||
WKSyncConvMsg convMsg = WKSyncConvMsg();
|
WKSyncConvMsg convMsg = WKSyncConvMsg();
|
||||||
@ -84,7 +85,6 @@ class HttpUtils {
|
|||||||
int pullMode,
|
int pullMode,
|
||||||
Function(WKSyncChannelMsg) back) async {
|
Function(WKSyncChannelMsg) back) async {
|
||||||
final dio = Dio();
|
final dio = Dio();
|
||||||
print('开始seq: $startMsgSeq 结束seq: $endMsgSeq');
|
|
||||||
final response = await dio.post('$apiURL/channel/messagesync', data: {
|
final response = await dio.post('$apiURL/channel/messagesync', data: {
|
||||||
"login_uid": UserInfo.uid, // 当前登录用户uid
|
"login_uid": UserInfo.uid, // 当前登录用户uid
|
||||||
"channel_id": channelID, // 频道ID
|
"channel_id": channelID, // 频道ID
|
||||||
@ -95,18 +95,12 @@ class HttpUtils {
|
|||||||
"pull_mode": pullMode // 拉取模式 0:向下拉取 1:向上拉取
|
"pull_mode": pullMode // 拉取模式 0:向下拉取 1:向上拉取
|
||||||
});
|
});
|
||||||
if (response.statusCode == HttpStatus.ok) {
|
if (response.statusCode == HttpStatus.ok) {
|
||||||
var data = jsonDecode(response.data);
|
var data = response.data;
|
||||||
WKSyncChannelMsg msg = WKSyncChannelMsg();
|
WKSyncChannelMsg msg = WKSyncChannelMsg();
|
||||||
msg.startMessageSeq = data['start_message_seq'];
|
msg.startMessageSeq = data['start_message_seq'];
|
||||||
msg.endMessageSeq = data['end_message_seq'];
|
msg.endMessageSeq = data['end_message_seq'];
|
||||||
msg.more = data['more'];
|
msg.more = data['more'];
|
||||||
var messages;
|
var messages = data['messages'];
|
||||||
var list = data['messages'];
|
|
||||||
if (list is String) {
|
|
||||||
messages = jsonDecode(data['messages']);
|
|
||||||
} else {
|
|
||||||
messages = list;
|
|
||||||
}
|
|
||||||
|
|
||||||
List<WKSyncMsg> msgList = [];
|
List<WKSyncMsg> msgList = [];
|
||||||
for (int i = 0; i < messages.length; i++) {
|
for (int i = 0; i < messages.length; i++) {
|
||||||
|
@ -122,13 +122,21 @@ packages:
|
|||||||
source: hosted
|
source: hosted
|
||||||
version: "1.0.5"
|
version: "1.0.5"
|
||||||
dio:
|
dio:
|
||||||
dependency: transitive
|
dependency: "direct main"
|
||||||
description:
|
description:
|
||||||
name: dio
|
name: dio
|
||||||
sha256: ce75a1b40947fea0a0e16ce73337122a86762e38b982e1ccb909daa3b9bc4197
|
sha256: e17f6b3097b8c51b72c74c9f071a605c47bcc8893839bd66732457a5ebe73714
|
||||||
url: "https://pub.flutter-io.cn"
|
url: "https://pub.flutter-io.cn"
|
||||||
source: hosted
|
source: hosted
|
||||||
version: "5.3.2"
|
version: "5.5.0+1"
|
||||||
|
dio_web_adapter:
|
||||||
|
dependency: transitive
|
||||||
|
description:
|
||||||
|
name: dio_web_adapter
|
||||||
|
sha256: "36c5b2d79eb17cdae41e974b7a8284fec631651d2a6f39a8a2ff22327e90aeac"
|
||||||
|
url: "https://pub.flutter-io.cn"
|
||||||
|
source: hosted
|
||||||
|
version: "1.0.1"
|
||||||
encrypt:
|
encrypt:
|
||||||
dependency: transitive
|
dependency: transitive
|
||||||
description:
|
description:
|
||||||
@ -539,7 +547,7 @@ packages:
|
|||||||
path: ".."
|
path: ".."
|
||||||
relative: true
|
relative: true
|
||||||
source: path
|
source: path
|
||||||
version: "1.4.1"
|
version: "1.5.1"
|
||||||
x25519:
|
x25519:
|
||||||
dependency: transitive
|
dependency: transitive
|
||||||
description:
|
description:
|
||||||
|
@ -36,6 +36,7 @@ dependencies:
|
|||||||
cupertino_icons: ^1.0.2
|
cupertino_icons: ^1.0.2
|
||||||
wukongimfluttersdk:
|
wukongimfluttersdk:
|
||||||
path: ../
|
path: ../
|
||||||
|
dio: ^5.5.0+1
|
||||||
dev_dependencies:
|
dev_dependencies:
|
||||||
flutter_test:
|
flutter_test:
|
||||||
sdk: flutter
|
sdk: flutter
|
||||||
|
@ -392,6 +392,10 @@ class MessageDB {
|
|||||||
|
|
||||||
if (pullMode == 0) {
|
if (pullMode == 0) {
|
||||||
//下拉获取消息
|
//下拉获取消息
|
||||||
|
if (oldestMsgSeq == 1) {
|
||||||
|
iGetOrSyncHistoryMsgBack([]);
|
||||||
|
return;
|
||||||
|
}
|
||||||
if (maxMessageSeq != 0 &&
|
if (maxMessageSeq != 0 &&
|
||||||
oldestMsgSeq != 0 &&
|
oldestMsgSeq != 0 &&
|
||||||
oldestMsgSeq - maxMessageSeq > 1) {
|
oldestMsgSeq - maxMessageSeq > 1) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user