import 'dart:math'; import '../models/msg/account.dart'; import '../models/msg/session.dart'; import '../utils/wbi_sign.dart'; import 'api.dart'; import 'init.dart'; class MsgHttp { // 会话列表 static Future sessionList({int? endTs}) async { Map params = { 'session_type': 1, 'group_fold': 1, 'unfollow_fold': 0, 'sort_rule': 2, 'build': 0, 'mobi_app': 'web', }; if (endTs != null) { params['end_ts'] = endTs; } Map signParams = await WbiSign().makSign(params); var res = await Request().get(Api.sessionList, data: signParams); if (res.data['code'] == 0) { try { return { 'status': true, 'data': SessionDataModel.fromJson(res.data['data']), }; } catch (err) { return { 'status': false, 'date': [], 'msg': err.toString(), }; } } else { return { 'status': false, 'date': [], 'msg': res.data['message'], }; } } static Future accountList(uids) async { var res = await Request().get(Api.sessionAccountList, data: { 'uids': uids, 'build': 0, 'mobi_app': 'web', }); if (res.data['code'] == 0) { try { return { 'status': true, 'data': res.data['data'] .map((e) => AccountListModel.fromJson(e)) .toList(), }; } catch (err) { print('err🔟: $err'); } } else { return { 'status': false, 'date': [], 'msg': res.data['message'], }; } } static Future sessionMsg({ int? talkerId, }) async { Map params = await WbiSign().makSign({ 'talker_id': talkerId, 'session_type': 1, 'size': 20, 'sender_device_id': 1, 'build': 0, 'mobi_app': 'web', }); var res = await Request().get(Api.sessionMsg, data: params); if (res.data['code'] == 0) { try { return { 'status': true, 'data': SessionMsgDataModel.fromJson(res.data['data']), }; } catch (err) { print(err); } } else { return { 'status': false, 'date': [], 'msg': res.data['message'], }; } } // 消息标记已读 static Future ackSessionMsg({ int? talkerId, int? ackSeqno, }) async { String csrf = await Request.getCsrf(); Map params = await WbiSign().makSign({ 'talker_id': talkerId, 'session_type': 1, 'ack_seqno': ackSeqno, 'build': 0, 'mobi_app': 'web', 'csrf_token': csrf, 'csrf': csrf }); var res = await Request().get(Api.ackSessionMsg, data: params); if (res.data['code'] == 0) { return { 'status': true, 'data': res.data['data'], }; } else { return { 'status': false, 'date': [], 'msg': "message: ${res.data['message']}," " msg: ${res.data['msg']}," " code: ${res.data['code']}", }; } } // 发送私信 static Future sendMsg({ int? senderUid, int? receiverId, int? receiverType, int? msgType, dynamic content, }) async { String csrf = await Request.getCsrf(); Map params = await WbiSign().makSign({ 'msg[sender_uid]': senderUid, 'msg[receiver_id]': receiverId, 'msg[receiver_type]': receiverType ?? 1, 'msg[msg_type]': msgType ?? 1, 'msg[msg_status]': 0, 'msg[dev_id]': getDevId(), 'msg[timestamp]': DateTime.now().millisecondsSinceEpoch ~/ 1000, 'msg[new_face_version]': 0, 'msg[content]': content, 'from_firework': 0, 'build': 0, 'mobi_app': 'web', 'csrf_token': csrf, 'csrf': csrf, }); var res = await Request().post(Api.sendMsg, queryParameters: { ...params, 'csrf_token': csrf, 'csrf': csrf, }, data: { 'w_sender_uid': params['msg[sender_uid]'], 'w_receiver_id': params['msg[receiver_id]'], 'w_dev_id': params['msg[dev_id]'], 'w_rid': params['w_rid'], 'wts': params['wts'], 'csrf_token': csrf, 'csrf': csrf, }); if (res.data['code'] == 0) { return { 'status': true, 'data': res.data['data'], }; } else { return { 'status': false, 'date': [], 'msg': "message: ${res.data['message']}," " msg: ${res.data['msg']}," " code: ${res.data['code']}", }; } } static String getDevId() { final List b = [ '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' ]; final List s = "xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".split(''); for (int i = 0; i < s.length; i++) { if ('-' == s[i] || '4' == s[i]) { continue; } final int randomInt = Random().nextInt(16); if ('x' == s[i]) { s[i] = b[randomInt]; } else { s[i] = b[3 & randomInt | 8]; } } return s.join(); } }